Returns total number of UPDATE, NOTIFICATION and ROUTE_REFRESH
        messages received from this peer.
170137
def total_msg_recv(self):
        
        return (self.get_count(PeerCounterNames.RECV_UPDATES) +
                self.get_count(PeerCounterNames.RECV_REFRESH) +
                self.get_count(PeerCounterNames.RECV_NOTIFICATION))
1050363
def _send_outgoing_route_refresh_msg(self, rr_msg):
        
        assert rr_msg.type == BGP_MSG_ROUTE_REFRESH
        self._protocol.send(rr_msg)
        LOG.debug('RouteRefresh %s>> %s',
                  self._neigh_conf.ip_address, rr_msg)
        # Collect update statistics for sent refresh request.
        if rr_msg.demarcation == 0:
            self.state.incr(PeerCounterNames.SENT_REFRESH)
        # If SOR is sent, we set Max. EOR timer if needed.
        elif (rr_msg.demarcation == 1 and
              self._common_conf.refresh_max_eor_time != 0):
            eor_timer = self._common_conf.refresh_max_eor_time
            # Set timer to send EOR demarcation.
            self._spawn_after('end-of-rib-timer', eor_timer,
                              self._enqueue_eor_msg, rr_msg)
            LOG.debug('Enhanced RR max. EOR timer set.')
887625
def get_connection_count(self, is_full: bool = False) -> int:
        
        payload = self.generate_json_rpc_payload(RpcMethod.GET_NODE_COUNT)
        response = self.__post(self.__url, payload)
        if is_full:
            return response
        return response['result']
339466
def totalBytesSent()
            joinThread()
            v = MiniUPnP.UPNP_GetTotalBytesSent(@urls.controlURL_CIF,
                        @data.servicetype_CIF)
            if v < 0 then
                raise UPnPException.new, "Error while retriving total bytes sent."
            end
            return v
        end
43356
def totalPacketsSent()
            joinThread()
            v = MiniUPnP.UPNP_GetTotalPacketsSent(@urls.controlURL_CIF,
                        @data.servicetype_CIF);
            if v < 0 then
                raise UPnPException.new, "Error while retriving total packets sent."
            end
            return v
        end
430262
public int getNumberOfActiveMessages()
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.entry(tc, "getNumberOfActiveMessages");
    int activeMessages = 
      (int)_sourceStream.countAllMessagesOnStream();
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.exit(tc, "getNumberOfActiveMessages", new Integer(activeMessages));      
    return activeMessages;
  }
70836
public function getMessageCount()
    {
        if ($this->getResultCode() === self::RC_SUCCESS_NO_MESSAGES) {
            return 0;
        }

        $node = $this->getFirst('//epp:epp/epp:response/epp:msgQ');
        if ($node === null) {
            return null;
        }

        return (int) $node->getAttribute('count');
    }
350410
def get_client_unread_messages_count(self, client_name=None):
        
        client = self._clients.get_with_name(client_name)[0]
        return client.get_messages_count_in_buffer()
1187249
def incoming_messages(self) -> t.List[t.Tuple[float, bytes]]:
        
        approximate_messages = self._receive_buffer.qsize()
        messages = []
        for _ in range(approximate_messages):
            try:
                messages.append(self._receive_buffer.get_nowait())
            except queue.Empty:
                break
        return messages
396495
public long getNumberOfCurrentRequests()
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "getNumberOfCurrentRequests");
    //request, value, rejected and accepted messages are all counted
    long returnValue = _aoStream.getNumberOfRequestsInState(TickRange.Requested);
    returnValue+=_aoStream.getNumberOfRequestsInState(TickRange.Value);
    returnValue+=_aoStream.getNumberOfRequestsInState(TickRange.Rejected);
    returnValue+=_aoStream.getNumberOfRequestsInState(TickRange.Accepted);
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "getNumberOfCurrentRequests", new Long(returnValue));
    return returnValue;     
  }
1010643
function getStats() {
  var o = {};
  o.total_connections_received = this.stats.connections;
  o.total_commands_processed = this.stats.commands;
  o.total_net_input_bytes = this.stats.ibytes;
  o.total_net_output_bytes = this.stats.obytes;

  o.rejected_connections = this.stats.rejected;

  o.expired_keys = this.stats.expired;
  o.keyspace_hits = this.stats.hits;
  o.keyspace_misses = this.stats.misses;

  o.pubsub_channels = this.stats.pubsub_channels;
  o.pubsub_patterns = this.stats.pubsub_patterns;

  return o;
}
741493
def publish_receiver_count(self, service, routing_id):
        '''
        '''
        peers = len(list(self._dispatcher.find_peer_routes(
            const.MSG_TYPE_PUBLISH, service, routing_id)))
        if self._dispatcher.locally_handles(const.MSG_TYPE_PUBLISH,
                service, routing_id):
            return peers + 1
        return peers
12749
public function countMessages()
    {
        $count = 0; // "Declare" variable before first usage.
        $octets = 0; // "Declare" variable since it's passed by reference
        $this->_protocol->status($count, $octets);
        return (int)$count;
    }
558011
def count(self):
        
        if self._batch:
            raise CQLEngineException("Only inserts, updates, and deletes are available in batch mode")

        if self._result_cache is None:
            query = self._select_query()
            query.count = True
            result = self._execute(query)
            return result[0]['count']
        else:
            return len(self._result_cache)
632445
function() {

		var new_refresh_queues = [],
			current_level = this._min_scope_refresh_level,
			count_levels = this._scope_refresh_queues.length,
			current_queue,
			i,
			count,
			new_level_queue,
			ticket;

		for (;current_level < count_levels; current_level++) {

			if (current_level in this._scope_refresh_queues) {

				current_queue = this._scope_refresh_queues[current_level];
				i = this._scope_refresh_current_indices[current_level] || 0;
				count = current_queue.length;
				new_level_queue = [];

				for (; i < count; i++) {

					if (current_queue[i]) {

						ticket = current_queue[i];
						ticket.index = new_level_queue.push(ticket) - 1;

					}

				}

				new_refresh_queues[current_level] = new_level_queue;

			}

		}

		return new_refresh_queues;

	}
827296
private int getUnSeenMessageCount() 
   {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(this, tc,"getUnseenMessageCount");
      
      int remain = 0;
      for (int x = nextIndex; x < messages.length; x++)
      {
         if (messages[x] != null) remain++;
      }
      
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(this, tc,"getUnseenMessageCount", ""+remain);
      return remain;
   }
75648
public int getNumberOfActiveMessages()
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "getNumberOfActiveMessages");
    int returnValue = (int)_targetStream.countAllMessagesOnStream();
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "getNumberOfActiveMessages", new Integer(returnValue));
    return returnValue;
  }