async def on_open(self):
self.__ensure_barrier()<EOL>while self.connected:<EOL><INDENT>try:<EOL><INDENT>if self.__lastping > self.__lastpong:<EOL><INDENT>raise IOError("<STR_LIT>")<EOL><DEDENT>self.send_message("<STR_LIT:2>")<EOL>self.send_ack()<EOL>self.__lastping = time.time()<EOL>await asyncio.sleep(self.ping_interval)<EOL><DEDENT>except Exception as ex:<EOL><INDENT>LOGGER.exception("<STR_LIT>")<EOL>try:<EOL><INDENT>self.reraise(ex)<EOL><DEDENT>except Exception:<EOL><INDENT>LOGGER.exception(<EOL>"<STR_LIT>"<EOL>)<EOL><DEDENT>break<EOL><DEDENT><DEDENT>
DingDongmaster the connection is open