Searched refs:num_sent (Results 1 – 9 of 9) sorted by relevance
80 num_sent = None102 num_sent = int(line.split()[1])110 if num_sent is None:114 if num_sent < 1:117 self.loss = 100.0 * float(num_sent - len(latencies)) / num_sent
173 int num_sent = 0; in SendJustTheRtcpPackets() local191 ++num_sent; in SendJustTheRtcpPackets()195 return num_sent; in SendJustTheRtcpPackets()200 int num_sent = 0; in SendJustTheRtpPackets() local202 if (num_sent >= num_packets_to_send) { in SendJustTheRtpPackets()209 for (; num_sent < num_packets_to_send; ++num_sent) { in SendJustTheRtpPackets()222 return num_sent; in SendJustTheRtpPackets()
242 num_sent = self.send(data)247 if num_sent:248 if num_sent < len(data) or obs < len(first):249 self.producer_fifo[0] = first[num_sent:]
536 num_sent = 0537 num_sent = dispatcher.send(self, self.out_buffer[:512])538 self.out_buffer = self.out_buffer[num_sent:]
251 num_sent = self.send(data)256 if num_sent:257 if num_sent < len(data) or obs < len(first):258 self.producer_fifo[0] = first[num_sent:]
513 num_sent = 0514 num_sent = dispatcher.send(self, self.out_buffer[:65536])515 self.out_buffer = self.out_buffer[num_sent:]
539 int num_sent = 0; in GetStats() local547 num_sent += num_request_per_server[kv.first]; in GetStats()579 stats.num_request_sent = num_sent; in GetStats()583 if (num_sent) { in GetStats()584 stats.success_percent = static_cast<int>(100 * num_received / num_sent); in GetStats()
396 void SocketNode::RecordMessagesSent(uint32_t num_sent) { in RecordMessagesSent() argument397 messages_sent_.FetchAdd(num_sent, MemoryOrder::RELAXED); in RecordMessagesSent()
287 void RecordMessagesSent(uint32_t num_sent);