def wait_cfgmgr(self):
"""Wait for msgq to subscribe.
- When this returs, the config manager is either subscribed, or
+ When this returns, the config manager is either subscribed, or
msgq gave up waiting for it. Success is signified by the return
value.
"""
self.poller = select.poll()
def add_kqueue_socket(self, socket, write_filter=False):
- """Add a kquque filter for a socket. By default the read
+ """Add a kqueue filter for a socket. By default the read
filter is used; if write_filter is set to True, the write
filter is used. We use a boolean value instead of a specific
filter constant, because kqueue filter values do not seem to
recognize it. This is probably either a coding error or inconsistency between
the message queue version and version of the module.
-% MSGQ_CONFIG_DATA Received configuration for the msgq: %1
-Debug message. The message queue received a configuration, handling it.
+% MSGQ_CONFIG_DATA Received configuration update for the msgq: %1
+Debug message. The message queue received a configuration update, handling it.
% MSGQ_HDR_DECODE_ERR Error decoding header received from socket %1: %2
The socket with mentioned file descriptor sent a packet. However, it was not