zktraffic/base/sniffer.py
def _track_client_message(self, request):
    """
    Any request that is not a ping or a close should be tracked
    """
    if self.config.track_replies and not request.is_ping and not request.is_close:
      requests_xids = self._requests_xids[request.client]
      if len(requests_xids) > self.config.max_queued_requests:  # pragma: no cover
        # TODO: logging the counts of each type of pkts in the queue when this happens
        #       could be useful.
        if self._error_to_stderr:
          sys.stderr.write("Too many queued requests, replies for %s will be lost\n" %
                           request.client)
        else:
          log.error("Too many queued requests, replies for %s will be lost", request.client)
        return

      requests_xids[request.xid] = request.opcode

    Any request that is not a ping or a close should be tracked
    
Any request that is not a ping or a close should be tracked
Any request that is not a ping or a close should be tracked
def _track_client_message(self, request):
    if self.config.track_replies and not request.is_ping and not request.is_close:
      requests_xids = self._requests_xids[request.client]
      if len(requests_xids) > self.config.max_queued_requests:  
        if self._error_to_stderr:
          sys.stderr.write("Too many queued requests, replies for %s will be lost\n" %
                           request.client)
        else:
          log.error("Too many queued requests, replies for %s will be lost", request.client)
        return
      requests_xids[request.xid] = request.opcode
def _track_client_message ( self , request ) : if self . config . track_replies and not request . is_ping and not request . is_close : requests_xids = self . _requests_xids [ request . client ] if len ( requests_xids ) > self . config . max_queued_requests : if self . _error_to_stderr : sys . stderr . write ( "Too many queued requests, replies for %s will be lost\n" % request . client ) else : log . error ( "Too many queued requests, replies for %s will be lost" , request . client ) return requests_xids [ request . xid ] = request . opcode
Any request that is not a ping or a close should be tracked
Any request that is not a ping or a close should be tracked
"""
    Any request that is not a ping or a close should be tracked
    """ # pragma: no cover # TODO: logging the counts of each type of pkts in the queue when this happens #       could be useful.
self
request