Python client for lightstreamer

[epep]

Ok, it works fine without the "self._stream_connection = None".

I notice that my logging was badly formated in reconnect(), I should have written : def reconnect(self):<br /> fail = 0<br /> while True :<br /> try :<br /> log.info("Trying to reconnect")<br /> self._stream_connection.close()<br /> self._session.clear()<br /> self.connect()<br /> self.resubscribe()<br /> break<br /> except :<br /> log.info("fail : {0}".format(sys.exc_info()[0]))<br /> fail += 1<br /> wait = min( 300, 0.125 * ( 2 ** fail ))<br /> log.info("reconnect in {0} seconds".format(wait))<br /> time.sleep(wait)

About errors documented in 4.1 of the network protocol tutorial, do you agree that they should not happen after the connection is established ? I've done this at the end of the _handle_stream method : if self._bind_counter == 0 :<br /> raise IOError()<br /> else :<br /> self.reconnect() Like this, if an error occurred at the first connection, it is raised. If it encounters the bind problem from IG, it reconnects. Is it clean ?

[gianluca.finocchiaro]

Hi epep,

...

About errors documented in 4.1 of the network protocol tutorial, do you agree that they should not happen after the connection is established ? I've done this at the end of the _handle_stream method : if self._bind_counter == 0 :<br /> raise IOError()<br /> else :<br /> self.reconnect() Like this, if an error occurred at the first connection, it is raised. If it encounters the bind problem from IG, it reconnects. Is it clean ?

In case of binding an existing session (hence _bind_counter is greater then 0), you could run against similar issues, as specified in the Paragraph 4.2 of the Network Protocol tutorial.

Obviously you are free to implement the reconnection logic as per your requirements, but in my opinion you should trigger it only if you can be sure that a real network problem has been verified.

Let me know,
Gianluca