Lines Matching refs:flow_stats
485 struct flow_stats *nexus_stats; /* shared stats objects between necp_client and skywalk */
1282 struct aop_flow_stats flow_stats = {}; in necp_client_collect_aop_flow_stats() local
1283 struct tcp_info *tcpi = &flow_stats.transport.tcp_stats.tcp_info; in necp_client_collect_aop_flow_stats()
1301 err = net_aop_get_flow_stats(flow->stats_index, &flow_stats); in necp_client_collect_aop_flow_stats()
1308 if (__improbable(flow->flow_tag != flow_stats.flow_id)) { in necp_client_collect_aop_flow_stats()
1310 flow->flow_tag, flow_stats.flow_id); in necp_client_collect_aop_flow_stats()
1363 sf->sf_ibytes = flow_stats.rxbytes; in necp_client_collect_aop_flow_stats()
1364 sf->sf_obytes = flow_stats.txbytes; in necp_client_collect_aop_flow_stats()
1365 sf->sf_ipackets = flow_stats.rxpkts; in necp_client_collect_aop_flow_stats()
1366 sf->sf_opackets = flow_stats.txpkts; in necp_client_collect_aop_flow_stats()
1375 memcpy(&sf->sf_activity, &flow_stats.activity_bitmap, in necp_client_collect_aop_flow_stats()
3532 void **flow_stats) in necp_client_parse_result() argument
3534 #pragma unused(flow_stats) in necp_client_parse_result()
3567 if (flow_stats != NULL && length >= sizeof(struct sk_stats_flow *)) { in necp_client_parse_result()
3568 struct flow_stats * __single fs = *(void **)(void *)value; in necp_client_parse_result()
3570 *flow_stats = fs; in necp_client_parse_result()
6958 struct aop_flow_stats flow_stats = {}; in necp_request_aop_tcp_netstats() local
6959 struct tcp_info *tcpi = &flow_stats.transport.tcp_stats.tcp_info; in necp_request_aop_tcp_netstats()
7013 err = net_aop_get_flow_stats(flow->stats_index, &flow_stats); in necp_request_aop_tcp_netstats()
7020 if (__improbable(flow->flow_tag != flow_stats.flow_id)) { in necp_request_aop_tcp_netstats()
7022 flow->flow_tag, flow_stats.flow_id); in necp_request_aop_tcp_netstats()
7119 desc->rcvbufsize = flow_stats.rx_buffer_stats.bufsize; in necp_request_aop_tcp_netstats()
7120 desc->rcvbufused = flow_stats.rx_buffer_stats.bufused; in necp_request_aop_tcp_netstats()
7123 desc->sndbufsize = flow_stats.tx_buffer_stats.bufsize; in necp_request_aop_tcp_netstats()
7124 desc->sndbufused = flow_stats.tx_buffer_stats.bufused; in necp_request_aop_tcp_netstats()
7131 u_int32_t cc_alg_index = flow_stats.transport.tcp_stats.tcp_cc_algo; in necp_request_aop_tcp_netstats()
11614 struct necp_flow_statistics *flow_stats) in necp_client_copy_flow_stats() argument
11630 if (flow_stats->transport_proto == IPPROTO_TCP) { in necp_client_copy_flow_stats()
11631 struct tcp_info *tcpi = &flow_stats->transport.tcpi; in necp_client_copy_flow_stats()
11644 struct necp_flow_statistics flow_stats = {}; in necp_client_get_flow_statistics() local
11658 if (uap->buffer_size < sizeof(flow_stats) || uap->buffer == 0) { in necp_client_get_flow_statistics()
11663 error = copyin(uap->buffer, &flow_stats, sizeof(flow_stats)); in necp_client_get_flow_statistics()
11669 if (flow_stats.transport_proto != IPPROTO_TCP) { in necp_client_get_flow_statistics()
11671 flow_stats.transport_proto); in necp_client_get_flow_statistics()
11690 error = necp_client_copy_flow_stats(flow_registration, &flow_stats); in necp_client_get_flow_statistics()
11692 error = copyout(&flow_stats, uap->buffer, sizeof(flow_stats)); in necp_client_get_flow_statistics()
12342 u_int32_t flow_adv_index, void *flow_stats, uint32_t flow_id, size_t *message_length) in necp_create_nexus_assign_message() argument
12369 if (flow_stats != NULL) { in necp_create_nexus_assign_message()
12406 if (flow_stats != NULL) { in necp_create_nexus_assign_message()
12407 …rite_tlv(cursor, NECP_CLIENT_RESULT_NEXUS_FLOW_STATS, sizeof(void *), &flow_stats, buffer, valsize… in necp_create_nexus_assign_message()