ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-06-01 07:10:53 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

storage: emit log messages on bucket allocate/read and mutable writev

Browse Source
This commit is contained in:
Brian Warner 2008-03-27 17:33:58 -07:00
parent eb4a7b5b0c
commit d6be5116f5
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/allmydata/storage.py
View File

@ -752,6 +752,9 @@ class StorageServer(service.MultiService, Referenceable):
alreadygot = set() alreadygot = set()
bucketwriters = {} # k: shnum, v: BucketWriter bucketwriters = {} # k: shnum, v: BucketWriter
si_dir = storage_index_to_dir(storage_index) si_dir = storage_index_to_dir(storage_index)
si_s = si_b2a(storage_index)
log.msg("storage: allocate_buckets %s" % si_s)
# in this implementation, the lease information (including secrets) # in this implementation, the lease information (including secrets)
# goes into the share files themselves. It could also be put into a # goes into the share files themselves. It could also be put into a
@ -900,6 +903,8 @@ class StorageServer(service.MultiService, Referenceable):
pass pass
def remote_get_buckets(self, storage_index): def remote_get_buckets(self, storage_index):
si_s = si_b2a(storage_index)
log.msg("storage: get_buckets %s" % si_s)
bucketreaders = {} # k: sharenum, v: BucketReader bucketreaders = {} # k: sharenum, v: BucketReader
for shnum, filename in self._get_bucket_shares(storage_index): for shnum, filename in self._get_bucket_shares(storage_index):
bucketreaders[shnum] = BucketReader(filename) bucketreaders[shnum] = BucketReader(filename)
@ -927,6 +932,7 @@ class StorageServer(service.MultiService, Referenceable):
test_and_write_vectors, test_and_write_vectors,
read_vector): read_vector):
si_s = si_b2a(storage_index) si_s = si_b2a(storage_index)
lp = log.msg("storage: slot_writev %s" % si_s)
si_dir = storage_index_to_dir(storage_index) si_dir = storage_index_to_dir(storage_index)
(write_enabler, renew_secret, cancel_secret) = secrets (write_enabler, renew_secret, cancel_secret) = secrets
# shares exist if there is a file for them # shares exist if there is a file for them