Lines Matching refs:flow_stats

485 	struct flow_stats *nexus_stats; /* shared stats objects between necp_client and skywalk */
1287 struct aop_flow_stats flow_stats = {}; in necp_client_collect_aop_flow_stats() local
1288 struct tcp_info *tcpi = &flow_stats.transport.tcp_stats.tcp_info; in necp_client_collect_aop_flow_stats()
1306 err = net_aop_get_flow_stats(flow->stats_index, &flow_stats); in necp_client_collect_aop_flow_stats()
1313 if (__improbable(flow->flow_tag != flow_stats.flow_id)) { in necp_client_collect_aop_flow_stats()
1315 flow->flow_tag, flow_stats.flow_id); in necp_client_collect_aop_flow_stats()
1368 sf->sf_ibytes = flow_stats.rxbytes; in necp_client_collect_aop_flow_stats()
1369 sf->sf_obytes = flow_stats.txbytes; in necp_client_collect_aop_flow_stats()
1370 sf->sf_ipackets = flow_stats.rxpkts; in necp_client_collect_aop_flow_stats()
1371 sf->sf_opackets = flow_stats.txpkts; in necp_client_collect_aop_flow_stats()
1380 memcpy(&sf->sf_activity, &flow_stats.activity_bitmap, in necp_client_collect_aop_flow_stats()
3537 void **flow_stats) in necp_client_parse_result() argument
3539 #pragma unused(flow_stats) in necp_client_parse_result()
3572 if (flow_stats != NULL && length >= sizeof(struct sk_stats_flow *)) { in necp_client_parse_result()
3573 struct flow_stats * __single fs = *(void **)(void *)value; in necp_client_parse_result()
3575 *flow_stats = fs; in necp_client_parse_result()
6969 struct aop_flow_stats flow_stats = {}; in necp_request_aop_tcp_netstats() local
6970 struct tcp_info *tcpi = &flow_stats.transport.tcp_stats.tcp_info; in necp_request_aop_tcp_netstats()
7024 err = net_aop_get_flow_stats(flow->stats_index, &flow_stats); in necp_request_aop_tcp_netstats()
7031 if (__improbable(flow->flow_tag != flow_stats.flow_id)) { in necp_request_aop_tcp_netstats()
7033 flow->flow_tag, flow_stats.flow_id); in necp_request_aop_tcp_netstats()
7130 desc->rcvbufsize = flow_stats.rx_buffer_stats.bufsize; in necp_request_aop_tcp_netstats()
7131 desc->rcvbufused = flow_stats.rx_buffer_stats.bufused; in necp_request_aop_tcp_netstats()
7134 desc->sndbufsize = flow_stats.tx_buffer_stats.bufsize; in necp_request_aop_tcp_netstats()
7135 desc->sndbufused = flow_stats.tx_buffer_stats.bufused; in necp_request_aop_tcp_netstats()
7142 u_int32_t cc_alg_index = flow_stats.transport.tcp_stats.tcp_cc_algo; in necp_request_aop_tcp_netstats()
11631 struct necp_flow_statistics *flow_stats) in necp_client_copy_flow_stats() argument
11647 if (flow_stats->transport_proto == IPPROTO_TCP) { in necp_client_copy_flow_stats()
11648 struct tcp_info *tcpi = &flow_stats->transport.tcpi; in necp_client_copy_flow_stats()
11661 struct necp_flow_statistics flow_stats = {}; in necp_client_get_flow_statistics() local
11675 if (uap->buffer_size < sizeof(flow_stats) || uap->buffer == 0) { in necp_client_get_flow_statistics()
11680 error = copyin(uap->buffer, &flow_stats, sizeof(flow_stats)); in necp_client_get_flow_statistics()
11686 if (flow_stats.transport_proto != IPPROTO_TCP) { in necp_client_get_flow_statistics()
11688 flow_stats.transport_proto); in necp_client_get_flow_statistics()
11707 error = necp_client_copy_flow_stats(flow_registration, &flow_stats); in necp_client_get_flow_statistics()
11709 error = copyout(&flow_stats, uap->buffer, sizeof(flow_stats)); in necp_client_get_flow_statistics()
12359 u_int32_t flow_adv_index, void *flow_stats, uint32_t flow_id, size_t *message_length) in necp_create_nexus_assign_message() argument
12386 if (flow_stats != NULL) { in necp_create_nexus_assign_message()
12423 if (flow_stats != NULL) { in necp_create_nexus_assign_message()
12424 …rite_tlv(cursor, NECP_CLIENT_RESULT_NEXUS_FLOW_STATS, sizeof(void *), &flow_stats, buffer, valsize… in necp_create_nexus_assign_message()