connectordb/_websocket.py
def __on_open(self, ws):
        """Called when the websocket is opened"""
        logging.debug("ConnectorDB: Websocket opened")

        # Connection success - decrease the wait time for next connection
        self.reconnect_time /= self.reconnect_time_backoff_multiplier

        self.status = "connected"

        self.lastpingtime = time.time()
        self.__ensure_ping()

        self.connected_time = time.time()

        # Release the lock that connect called
        self.ws_openlock.release()
def __on_open(self, ws):
        logging.debug("ConnectorDB: Websocket opened")

        # Connection success - decrease the wait time for next connection
        self.reconnect_time /= self.reconnect_time_backoff_multiplier

        self.status = "connected"

        self.lastpingtime = time.time()
        self.__ensure_ping()

        self.connected_time = time.time()

        # Release the lock that connect called
        self.ws_openlock.release()
def __on_open ( self , ws ) : logging . debug ( "ConnectorDB: Websocket opened" ) # Connection success - decrease the wait time for next connection self . reconnect_time /= self . reconnect_time_backoff_multiplier self . status = "connected" self . lastpingtime = time . time ( ) self . __ensure_ping ( ) self . connected_time = time . time ( ) # Release the lock that connect called self . ws_openlock . release ( )
Called when the websocket is opened
Called when the websocket is opened