parameters: (self, message)
docstring: Processes pong message.
  
          Args:
              message: pong message.
docstring_summary: Processes pong message.
docstring_tokens: Processes pong message .
function: def _process_pong_message(self, message):
          """Processes pong message.
  
          Args:
              message: pong message.
          """
  
          # TODO(tyoshino): Add ping timeout handling.
  
          inflight_pings = deque()
  
          while True:
              try:
                  expected_body = self._ping_queue.popleft()
                  if expected_body == message:
                      # inflight_pings contains pings ignored by the
                      # other peer. Just forget them.
                      self._logger.debug(
                          'Ping %r is acked (%d pings were ignored)',
                          expected_body, len(inflight_pings))
                      break
                  else:
                      inflight_pings.append(expected_body)
              except IndexError, e:
                  # The received pong was unsolicited pong. Keep the
                  # ping queue as is.
                  self._ping_queue = inflight_pings
                  self._logger.debug('Received a unsolicited pong')
                  break
  
          try:
              handler = self._request.on_pong_handler
              if handler:
                  handler(self._request, message)
          except AttributeError, e:
              pass
function_tokens: def _process_pong_message ( self , message ) : # TODO(tyoshino): Add ping timeout handling. inflight_pings = deque ( ) while True : try : expected_body = self . _ping_queue . popleft ( ) if expected_body == message : # inflight_pings contains pings ignored by the # other peer. Just forget them. self . _logger . debug ( 'Ping %r is acked (%d pings were ignored)' , expected_body , len ( inflight_pings ) ) break else : inflight_pings . append ( expected_body ) except IndexError , e : # The received pong was unsolicited pong. Keep the # ping queue as is. self . _ping_queue = inflight_pings self . _logger . debug ( 'Received a unsolicited pong' ) break try : handler = self . _request . on_pong_handler if handler : handler ( self . _request , message ) except AttributeError , e : pass