initializing... done
1st while loop
1st while loop
for subdata in data:
break
2nd while loop
self.buffer_condition.acquire()
buffer_finished = self.buffer_finished
deque([([***, ... ,***], 1321412071.306209)])
DEBUG: *** connected successfully
self.buffer_condition.release()
if buffer_finished:
2nd while loop
self.buffer_condition.acquire()
self.buffer_condition.wait()
for subdata in data:
break
2nd while loop
self.buffer_condition.acquire()
self.buffer_condition.wait()
buffer_finished = self.buffer_finished
deque([({u'favorited': False, u'in_reply_to_user_id': None, ... , u'default_profile': True, u'is_translator': False}}, 1321412117.143312)])
self.buffer_condition.release()
if buffer_finished:
2nd while loop
self.buffer_condition.acquire()
self.buffer_condition.wait()
DEBUG: *** disconnected because of curl error 56
before self.buffer_thread.join()
buffer_finished = self.buffer_finished
self.buffer_condition.release()
if buffer_finished:
break
after self.buffer_thread.join()
DEBUG: *** will reconnect in 0.25 seconds
1st while loop
1st while loop
buffer_finished = self.buffer_finished
deque([([***, ... ,***], 1321412242.143593)])
self.buffer_condition.release()
if buffer_finished:
2nd while loop
self.buffer_condition.acquire()
self.buffer_condition.wait()
for subdata in data:
break
2nd while loop
self.buffer_condition.acquire()
self.buffer_condition.wait()
for subdata in data:
break
2nd while loop
self.buffer_condition.acquire()
self.buffer_condition.wait()
DEBUG: *** disconnected because of curl error 56
buffer_finished = self.buffer_finished
self.buffer_condition.release()
if buffer_finished:
break
before self.buffer_thread.join()
^C^C^C^C^C^C^C^C
the modified realtime.py is at https:/ /bugs.launchpad .net/polly/ +bug/887861/ comments/ 12
initializing... done condition. acquire( ) finished 306209) ]) condition. release( ) condition. acquire( ) condition. wait() condition. acquire( ) condition. wait() finished ({u'favorited' : False, u'in_reply_ to_user_ id': None, ... , u'default_profile': True, u'is_translator': False}}, 1321412117. 143312) ]) condition. release( ) condition. acquire( ) condition. wait() thread. join() finished condition. release( ) thread. join() finished 143593) ]) condition. release( ) condition. acquire( ) condition. wait() condition. acquire( ) condition. wait() condition. acquire( ) condition. wait() finished condition. release( ) thread. join()
1st while loop
1st while loop
for subdata in data:
break
2nd while loop
self.buffer_
buffer_finished = self.buffer_
deque([([***, ... ,***], 1321412071.
DEBUG: *** connected successfully
self.buffer_
if buffer_finished:
2nd while loop
self.buffer_
self.buffer_
for subdata in data:
break
2nd while loop
self.buffer_
self.buffer_
buffer_finished = self.buffer_
deque([
self.buffer_
if buffer_finished:
2nd while loop
self.buffer_
self.buffer_
DEBUG: *** disconnected because of curl error 56
before self.buffer_
buffer_finished = self.buffer_
self.buffer_
if buffer_finished:
break
after self.buffer_
DEBUG: *** will reconnect in 0.25 seconds
1st while loop
1st while loop
buffer_finished = self.buffer_
deque([([***, ... ,***], 1321412242.
self.buffer_
if buffer_finished:
2nd while loop
self.buffer_
self.buffer_
for subdata in data:
break
2nd while loop
self.buffer_
self.buffer_
for subdata in data:
break
2nd while loop
self.buffer_
self.buffer_
DEBUG: *** disconnected because of curl error 56
buffer_finished = self.buffer_
self.buffer_
if buffer_finished:
break
before self.buffer_
^C^C^C^C^C^C^C^C