Remove dead code
This commit is contained in:
parent
8130d28e27
commit
045c120439
@ -58,7 +58,6 @@ class SyncDriver:
|
|||||||
while self.running_global:
|
while self.running_global:
|
||||||
self.session = SyncSession(self.store)
|
self.session = SyncSession(self.store)
|
||||||
item = self.session.start()
|
item = self.session.start()
|
||||||
logg.debug('item {}'.format(item))
|
|
||||||
if item == None:
|
if item == None:
|
||||||
self.running = False
|
self.running = False
|
||||||
self.running_global = False
|
self.running_global = False
|
||||||
@ -93,6 +92,7 @@ class SyncDriver:
|
|||||||
|
|
||||||
|
|
||||||
def loop(self, conn, item):
|
def loop(self, conn, item):
|
||||||
|
logg.debug('started loop')
|
||||||
tx_start = item.tx_cursor
|
tx_start = item.tx_cursor
|
||||||
while self.running and SyncDriver.running_global:
|
while self.running and SyncDriver.running_global:
|
||||||
self.last_start = time.clock_gettime_ns(self.clock_id)
|
self.last_start = time.clock_gettime_ns(self.clock_id)
|
||||||
@ -114,6 +114,7 @@ class SyncDriver:
|
|||||||
self.process(conn, item, block, tx_start)
|
self.process(conn, item, block, tx_start)
|
||||||
except IndexError:
|
except IndexError:
|
||||||
item.next(advance_block=True)
|
item.next(advance_block=True)
|
||||||
|
logg.debug('foo')
|
||||||
tx_start = 0
|
tx_start = 0
|
||||||
time.sleep(self.yield_delay)
|
time.sleep(self.yield_delay)
|
||||||
if self.post_callback != None:
|
if self.post_callback != None:
|
||||||
|
@ -9,7 +9,6 @@ class SyncSession:
|
|||||||
|
|
||||||
def __init__(self, session_store):
|
def __init__(self, session_store):
|
||||||
self.session_store = session_store
|
self.session_store = session_store
|
||||||
self.filters = []
|
|
||||||
self.started = self.session_store.started
|
self.started = self.session_store.started
|
||||||
self.get = self.session_store.get
|
self.get = self.session_store.get
|
||||||
self.next = self.session_store.next_item
|
self.next = self.session_store.next_item
|
||||||
|
Loading…
Reference in New Issue
Block a user