Commit e28b3b44 authored by Giorgos Korfiatis's avatar Giorgos Korfiatis
Browse files

Expose block parameter

parent d984d780
...@@ -69,8 +69,8 @@ class FileSyncer(object): ...@@ -69,8 +69,8 @@ class FileSyncer(object):
if self.decide_event is not None: if self.decide_event is not None:
self.decide_event.clear() self.decide_event.clear()
def get_next_message(self): def get_next_message(self, block=False):
return self.messager.get(block=False) return self.messager.get(block=block)
def exclude_file(self, objname): def exclude_file(self, objname):
parts = objname.split(common.OBJECT_DIRSEP) parts = objname.split(common.OBJECT_DIRSEP)
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment