ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-03-11 06:43:54 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Log a couple of calls on the Encoder

Browse Source
This commit is contained in:
Jean-Paul Calderone 2019-04-03 08:46:22 -04:00
parent d8187a0f6a
commit 83b520bd68
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/allmydata/immutable/encode.py
View File

@ -13,6 +13,9 @@ from allmydata.codec import CRSEncoder
from allmydata.interfaces import IEncoder, IStorageBucketWriter, \ from allmydata.interfaces import IEncoder, IStorageBucketWriter, \
IEncryptedUploadable, IUploadStatus, UploadUnhappinessError IEncryptedUploadable, IUploadStatus, UploadUnhappinessError
from ..util.eliotutil import (
log_call_deferred,
)
""" """
The goal of the encoder is to turn the original file into a series of The goal of the encoder is to turn the original file into a series of
@ -100,6 +103,7 @@ class Encoder(object):
kwargs["facility"] = "tahoe.encoder" kwargs["facility"] = "tahoe.encoder"
return log.msg(*args, **kwargs) return log.msg(*args, **kwargs)
@log_call_deferred(action_type=u"immutable:encode:set-encrypted-uploadable")
def set_encrypted_uploadable(self, uploadable): def set_encrypted_uploadable(self, uploadable):
eu = self._uploadable = IEncryptedUploadable(uploadable) eu = self._uploadable = IEncryptedUploadable(uploadable)
d = eu.get_size() d = eu.get_size()
@ -205,6 +209,7 @@ class Encoder(object):
assert isinstance(v, set) assert isinstance(v, set)
self.servermap = servermap.copy() self.servermap = servermap.copy()
@log_call_deferred(action_type=u"immutable:encode:start")
def start(self): def start(self):
""" Returns a Deferred that will fire with the verify cap (an instance of """ Returns a Deferred that will fire with the verify cap (an instance of
uri.CHKFileVerifierURI).""" uri.CHKFileVerifierURI)."""