@@ -72,11 +72,15 @@ def status(self):
7272while self .running :
7373msg = yield from self .child_pipe .coro_recv ()
7474if msg == 'status' :
75+ print ('evloop: got status request' )
7576serialized_aggs = {}
7677for name ,aggregate in self .aggregates .items ():
7778serialized_aggs [name ]= aggregate .as_dict ()
7879aggregate .clear_values ()
7980self .child_pipe .send (serialized_aggs )
81+ print ('evloop: sent status response' )
82+ else :
83+ print ('evloop: unknown message' )
8084
8185
8286@asyncio .coroutine
@@ -94,6 +98,7 @@ def exec_tx(self, tx_block, aggname_prefix, conn_i):
9498agg .finish_tx ('commit' )
9599except psycopg2 .Error as e :
96100agg .finish_tx (e .pgerror )
101+ print ("We've count to infinity!" )
97102
98103@asyncio .coroutine
99104def transfer_tx (self ,conn ,cur ):
@@ -117,6 +122,7 @@ def total_tx(self, conn, cur):
117122yield from cur .execute ('select sum(amount) from bank_test' )
118123total = yield from cur .fetchone ()
119124if total [0 ]!= 0 :
125+ print ('Isolation error, totel = ' ,total [0 ])
120126self .isolation += 1
121127
122128def run (self ):
@@ -138,8 +144,12 @@ def bgrun(self):
138144self .evloop_process .start ()
139145
140146def get_status (self ):
147+ print ('test: sending status request' )
141148self .parent_pipe .send ('status' )
142- return self .parent_pipe .recv ()
149+ print ('test: awaitng status response' )
150+ resp = self .parent_pipe .recv ()
151+ print ('test: got status response' )
152+ return resp
143153
144154def stop (self ):
145155self .running = False