aboutsummaryrefslogtreecommitdiff
path: root/rpkid/rpki/async.py
diff options
context:
space:
mode:
authorRob Austein <sra@hactrn.net>2010-02-24 01:08:07 +0000
committerRob Austein <sra@hactrn.net>2010-02-24 01:08:07 +0000
commit2ecbf67ba206151a866a23f2861e0da26f393126 (patch)
tree2f158bd3956a21e327d67d2be814205284d9cc24 /rpkid/rpki/async.py
parenta202256cf2183a35ab649b766965c4c1f65abf8d (diff)
Checkpoint. <list_received_resources/> still not quite working yet, but getting closer.
svn path=/rpkid/irbe_cli.py; revision=3005
Diffstat (limited to 'rpkid/rpki/async.py')
-rw-r--r--rpkid/rpki/async.py13
1 files changed, 10 insertions, 3 deletions
diff --git a/rpkid/rpki/async.py b/rpkid/rpki/async.py
index c545a88f..603fa5be 100644
--- a/rpkid/rpki/async.py
+++ b/rpkid/rpki/async.py
@@ -323,8 +323,11 @@ class sync_wrapper(object):
raise ExitNow
def eb(self, err):
- exc_info = sys.exc_info()
- self.err = exc_info if exc_info[1] is err else err
+ if True:
+ exc_info = sys.exc_info()
+ self.err = exc_info if exc_info[1] is err else err
+ else:
+ self.err = err
raise ExitNow
def __call__(self, *args, **kwargs):
@@ -340,7 +343,11 @@ class sync_wrapper(object):
defer(thunk)
event_loop()
if self.err is not None:
- raise self.err
+ #print "Raising self.err: %r" % (self.err,)
+ if isinstance(self.err, tuple):
+ raise self.err[0], self.err[1], self.err[2]
+ else:
+ raise self.err
else:
return self.res