|
|
@ -88,7 +88,10 @@ class ICollector(Thread) :
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
label = id
|
|
|
|
label = id
|
|
|
|
row = data
|
|
|
|
row = data
|
|
|
|
|
|
|
|
#
|
|
|
|
|
|
|
|
# At this point we should check for the status and if it prompts an action
|
|
|
|
|
|
|
|
# @TODO Use a design pattern for this ...
|
|
|
|
|
|
|
|
#
|
|
|
|
self.lock.acquire()
|
|
|
|
self.lock.acquire()
|
|
|
|
store = self.factory.instance(type=write_class,args=read_args)
|
|
|
|
store = self.factory.instance(type=write_class,args=read_args)
|
|
|
|
store.flush(size=200)
|
|
|
|
store.flush(size=200)
|
|
|
|