From: Brian Warner <warner@allmydata.com>
Date: Fri, 28 Mar 2008 00:33:58 +0000 (-0700)
Subject: storage: emit log messages on bucket allocate/read and mutable writev
X-Git-Url: https://git.rkrishnan.org/COPYING.TGPPL.html?a=commitdiff_plain;h=d6be5116f5cf5cc4ee87aef0c5836a14bd4ad0ab;p=tahoe-lafs%2Ftahoe-lafs.git

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

diff --git a/src/allmydata/storage.py b/src/allmydata/storage.py
index 938a87f9..23fea4dd 100644
--- a/src/allmydata/storage.py
+++ b/src/allmydata/storage.py
@@ -752,6 +752,9 @@ class StorageServer(service.MultiService, Referenceable):
         alreadygot = set()
         bucketwriters = {} # k: shnum, v: BucketWriter
         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)
         # goes into the share files themselves. It could also be put into a
@@ -900,6 +903,8 @@ class StorageServer(service.MultiService, Referenceable):
             pass
 
     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
         for shnum, filename in self._get_bucket_shares(storage_index):
             bucketreaders[shnum] = BucketReader(filename)
@@ -927,6 +932,7 @@ class StorageServer(service.MultiService, Referenceable):
                                                test_and_write_vectors,
                                                read_vector):
         si_s = si_b2a(storage_index)
+        lp = log.msg("storage: slot_writev %s" % si_s)
         si_dir = storage_index_to_dir(storage_index)
         (write_enabler, renew_secret, cancel_secret) = secrets
         # shares exist if there is a file for them