thread blocked after a curl error 56

I will investigate this, but it would be easier with some way to artificially simulate the error 56.

Either way, setting a timeout for join is not a fix. It's a workaround that causes more problems than solves.

If the buffer thread is not finishing in certain circumstances, it's a bug that needs to be fixed, not ignored and worked around.

Xu, when this error happens, is anything else relevant printed?

only a "DEBUG: *** disconnected because of curl error 56" message, nothing more.
and can't terminate polly by sending interrupt signal (press ctrl+c in terminal)

using an unstable proxy, like Tor, can easily cause this problem

Strange, I'd expect an exception traceback... the thread simply stopping with no visible consequences is weird.

Could you try throwing some prints in the buffer loop to try figuring out where exactly the lock up is occurring?

the modified realtime.py is at https://bugs.launchpad.net/polly/+bug/887861/comments/12

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

Thanks for the printout, I'll look into this when I have time.