--- /dev/null
+import os
+
+def get_random_bucket_on(nodeid, size=200):
+ d = app.get_remote_service(nodeid, 'storageserver')
+ def get_bucket(rss):
+ return rss.callRemote('allocate_bucket',
+ verifierid=os.urandom(20),
+ bucket_num=26,
+ size=size,
+ leaser=app.tub.tubID,
+ )
+ d.addCallback(get_bucket)
+ return d
+
+def write_to_bucket(bucket, bytes=100):
+ return bucket.callRemote('write', data=os.urandom(bytes))
+
def makeNamespace():
# close over 'self' so we can get access to .parent later
- import debugshell
+ from allmydata import debugshell
debugshell.app = self.parent # make client/queen accesible via 'app'
namespace = {}
for sym in dir(debugshell):
+++ /dev/null
-import os
-
-def get_random_bucket_on(nodeid, size=200):
- d = app.get_remote_service(nodeid, 'storageserver')
- def get_bucket(rss):
- return rss.callRemote('allocate_bucket',
- verifierid=os.urandom(20),
- bucket_num=26,
- size=size,
- leaser=app.tub.tubID,
- )
- d.addCallback(get_bucket)
- return d
-
-def write_to_bucket(bucket, bytes=100):
- return bucket.callRemote('write', data=os.urandom(bytes))
-