viff

changeset 1203:7fde9811e3bf

Fixed bugs occurring when running without ViffReactor.
author Marcel Keller <mkeller@cs.au.dk>
date Mon, 20 Jul 2009 12:22:02 +0200
parents 90e278d7a950
children d43f766c4cac
files viff/runtime.py
diffstat 1 files changed, 6 insertions(+), 0 deletions(-) [+]
line diff
     1.1 --- a/viff/runtime.py	Mon Jul 20 12:04:46 2009 +0200
     1.2 +++ b/viff/runtime.py	Mon Jul 20 12:22:02 2009 +0200
     1.3 @@ -653,6 +653,9 @@
     1.4          something to be used afterwards, add further callbacks to the returned
     1.5          deferred."""
     1.6  
     1.7 +        if not self.using_viff_reactor:
     1.8 +            return self.schedule_callback(deferred, func, *args, **kwargs)
     1.9 +
    1.10          if isinstance(deferred, Share):
    1.11              fork = Share(deferred.runtime, deferred.field)
    1.12          else:
    1.13 @@ -840,6 +843,9 @@
    1.14  
    1.15          This is where the recursion happens."""
    1.16  
    1.17 +        if not self.using_viff_reactor:
    1.18 +            return
    1.19 +
    1.20          self.activation_counter += 1
    1.21  
    1.22          # setting the number to n makes the reactor called