Lines Matching defs:qstats
163 struct hbm_queue_stats qstats = {0};
189 qstats.rate = rate;
190 qstats.stats = stats_flag ? 1 : 0;
191 qstats.loopback = loopback_flag ? 1 : 0;
192 qstats.no_cn = no_cn_flag ? 1 : 0;
193 if (bpf_map_update_elem(queue_stats_fd, &key, &qstats, BPF_ANY)) {
224 bpf_map_lookup_elem(queue_stats_fd, &key, &qstats);
232 last_cg_tx_bytes = qstats.bytes_total;
253 bpf_map_lookup_elem(queue_stats_fd, &key, &qstats);
254 new_cg_tx_bytes = qstats.bytes_total;
284 qstats.rate = rate;
298 qstats.rate = rate;
300 if (bpf_map_update_elem(queue_stats_fd, &key, &qstats, BPF_ANY))
307 if (stats_flag && bpf_map_lookup_elem(queue_stats_fd, &key, &qstats)) {
319 } else if (stats_flag && qstats.lastPacketTime >
320 qstats.firstPacketTime) {
321 long long delta_us = (qstats.lastPacketTime -
322 qstats.firstPacketTime)/1000;
323 unsigned int rate_mbps = ((qstats.bytes_total -
324 qstats.bytes_dropped) * 8 /
347 (qstats.lastPacketTime - qstats.firstPacketTime) /
349 fprintf(fout, "packets:%d\n", (int)qstats.pkts_total);
350 fprintf(fout, "bytes_MB:%d\n", (int)(qstats.bytes_total /
352 fprintf(fout, "pkts_dropped:%d\n", (int)qstats.pkts_dropped);
354 (int)(qstats.bytes_dropped /
357 percent_pkts = (qstats.pkts_marked * 100.0) /
358 (qstats.pkts_total + 1);
359 percent_bytes = (qstats.bytes_marked * 100.0) /
360 (qstats.bytes_total + 1);
365 percent_pkts = (qstats.pkts_dropped * 100.0) /
366 (qstats.pkts_total + 1);
367 percent_bytes = (qstats.bytes_dropped * 100.0) /
368 (qstats.bytes_total + 1);
373 percent_pkts = (qstats.pkts_ecn_ce * 100.0) /
374 (qstats.pkts_total + 1);
376 (int)qstats.pkts_ecn_ce);
380 (int)(qstats.sum_cwnd / (qstats.sum_cwnd_cnt + 1)));
383 (int)(qstats.sum_rtt / (qstats.pkts_total + 1)));
387 (qstats.sum_credit /
388 (qstats.pkts_total + 1.0)) / 1000000.0);
391 (int)(qstats.sum_credit /
392 (1500 * ((int)qstats.pkts_total ) + 1)));
396 percent_pkts = (qstats.returnValCount[k] * 100.0) /
397 (qstats.pkts_total + 1);
399 percent_pkts, (int)qstats.returnValCount[k]);