Module enrgdaq.cnc.handlers.req_ping

Classes

class ReqPingHandler (cnc: SupervisorCNC)

Expand source code

class ReqPingHandler(CNCMessageHandler):
    """
    Handler for CNCMessageReqPing messages.
    """

    def __init__(self, cnc: SupervisorCNC):
        """
        Initialize the handler.
        :param cnc: The SupervisorCNC instance.
        """
        super().__init__(cnc)

    def handle(
        self, sender_identity: bytes, msg: CNCMessageReqPing
    ) -> Optional[Tuple[CNCMessage, bool]]:
        """
        Handles a ping request.
        :param sender_identity: The ZMQ identity of the message sender.
        :param msg: The ping request message.
        :return: A pong response message.
        """
        self._logger.debug("Received ping, sending pong.")
        return CNCMessageResPing(), True

Handler for CNCMessageReqPing messages.

Initialize the handler. :param cnc: The SupervisorCNC instance.

Ancestors

• CNCMessageHandler
• abc.ABC

Methods

def handle(self, sender_identity: bytes, msg: CNCMessageReqPing) ‑> Tuple[CNCMessage, bool] | None

Expand source code

def handle(
    self, sender_identity: bytes, msg: CNCMessageReqPing
) -> Optional[Tuple[CNCMessage, bool]]:
    """
    Handles a ping request.
    :param sender_identity: The ZMQ identity of the message sender.
    :param msg: The ping request message.
    :return: A pong response message.
    """
    self._logger.debug("Received ping, sending pong.")
    return CNCMessageResPing(), True

Handles a ping request. :param sender_identity: The ZMQ identity of the message sender. :param msg: The ping request message. :return: A pong response message.