from twisted.trial import unittest
from twisted.application import service
-from foolscap import Tub, eventual
+from foolscap.api import Tub, fireEventually, flushEventualQueue
from allmydata import key_generator
from allmydata.util import pollmixin
+from allmydata.test.common import TEST_RSA_KEY_SIZE
from pycryptopp.publickey import rsa
def flush_but_dont_ignore(res):
- d = eventual.flushEventualQueue()
+ d = flushEventualQueue()
def _done(ignored):
return res
d.addCallback(_done)
self.parent.startService()
self.tub = t = Tub()
+ t.setOption("expose-remote-exception-types", False)
t.setServiceParent(self.parent)
t.listenOn("tcp:0")
t.setLocationAutomatically()
- return eventual.fireEventually()
+ return fireEventually()
def tearDown(self):
d = self.parent.stopService()
- d.addCallback(eventual.fireEventually)
+ d.addCallback(fireEventually)
d.addBoth(flush_but_dont_ignore)
return d
return junk
#print 'starting key generator service'
- keysize = 522
- kgs = key_generator.KeyGeneratorService(display_furl=False, default_key_size=keysize)
+ keysize = TEST_RSA_KEY_SIZE
+ kgs = key_generator.KeyGeneratorService(display_furl=False, default_key_size=keysize, basedir="key_generator_service")
kgs.key_generator.verbose = True
kgs.setServiceParent(self.parent)
kgs.key_generator.pool_size = 8
return len(kgs.key_generator.keypool) == kgs.key_generator.pool_size
# first wait for key gen pool to fill up
- d = eventual.fireEventually()
+ d = fireEventually()
d.addCallback(p, 'waiting for pool to fill up')
d.addCallback(lambda junk: self.poll(keypool_full))