Method run

packages/ibkr/ref/source/pythonclient/ibapi/client.py:574–625

This is the function that has the message loop.

(self)

        pass

    def run(self):
        """This is the function that has the message loop."""

        try:
            while self.isConnected() or not self.msg_queue.empty():
                try:
                    try:
                        text = self.msg_queue.get(block=True, timeout=0.2)
                        if len(text) > MAX_MSG_LEN:
                            self.wrapper.error(
                                NO_VALID_ID,
                                currentTimeMillis(),
                                BAD_LENGTH.code(),
                                f"{BAD_LENGTH.msg()}:{len(text)}:{text}",
                            )
                            break
                    except queue.Empty:
                        logger.debug("queue.get: empty")
                        self.msgLoopTmo()
                    else:

                        if self.serverVersion() >= MIN_SERVER_VER_PROTOBUF:
                            sMsgId = text[:4]
                            msgId = int.from_bytes(sMsgId, 'big')  
                            text = text[4:]
                        else:
                            sMsgId = text[:text.index(b"\0")]
                            text = text[text.index(b"\0") + len(b"\0"):]
                            msgId = int(sMsgId)

                        if msgId > PROTOBUF_MSG_ID:
                            msgId -= PROTOBUF_MSG_ID
                            logger.debug("msgId: %d, protobuf: %s", msgId, text)
                            self.decoder.processProtoBuf(text, msgId)
                        else:
                            fields = comm.read_fields(text)
                            logger.debug("msgId: %d, fields: %s", msgId, fields)
                            self.decoder.interpret(fields, msgId)

                        self.msgLoopRec()
                except (KeyboardInterrupt, SystemExit):
                    logger.info("detected KeyboardInterrupt, SystemExit")
                    self.keyboardInterrupt()
                    self.keyboardInterruptHard()
                except BadMessage:
                    logger.info("BadMessage")

                logger.debug(
                    "conn:%d queue.sz:%d", self.isConnected(), self.msg_queue.qsize()
                )
        finally:
            self.disconnect()

    def reqCurrentTime(self):
        """Asks the current system time on the server side."""