485 	struct flow_stats *nexus_stats; /* shared stats objects between necp_client and skywalk */
1283 	struct aop_flow_stats flow_stats = {};  in necp_client_collect_aop_flow_stats()  local
1284 	struct tcp_info *tcpi = &flow_stats.transport.tcp_stats.tcp_info;  in necp_client_collect_aop_flow_stats()
1302 			err = net_aop_get_flow_stats(flow->stats_index, &flow_stats);  in necp_client_collect_aop_flow_stats()
1309 			if (__improbable(flow->flow_tag != flow_stats.flow_id)) {  in necp_client_collect_aop_flow_stats()
1311 				    flow->flow_tag, flow_stats.flow_id);  in necp_client_collect_aop_flow_stats()
1364 				sf->sf_ibytes = flow_stats.rxbytes;  in necp_client_collect_aop_flow_stats()
1365 				sf->sf_obytes = flow_stats.txbytes;  in necp_client_collect_aop_flow_stats()
1366 				sf->sf_ipackets = flow_stats.rxpkts;  in necp_client_collect_aop_flow_stats()
1367 				sf->sf_opackets = flow_stats.txpkts;  in necp_client_collect_aop_flow_stats()
1376 				memcpy(&sf->sf_activity, &flow_stats.activity_bitmap,  in necp_client_collect_aop_flow_stats()
3559     void **flow_stats)  in necp_client_parse_result()  argument
3561 #pragma unused(flow_stats)  in necp_client_parse_result()
3594 					if (flow_stats != NULL && length >= sizeof(struct sk_stats_flow *)) {  in necp_client_parse_result()
3595 						struct flow_stats * __single fs = *(void **)(void *)value;  in necp_client_parse_result()
3597 						*flow_stats = fs;  in necp_client_parse_result()
6989 	struct aop_flow_stats flow_stats = {};  in necp_request_aop_tcp_netstats()  local
6990 	struct tcp_info *tcpi = &flow_stats.transport.tcp_stats.tcp_info;  in necp_request_aop_tcp_netstats()
7044 	err = net_aop_get_flow_stats(flow->stats_index, &flow_stats);  in necp_request_aop_tcp_netstats()
7051 	if (__improbable(flow->flow_tag != flow_stats.flow_id)) {  in necp_request_aop_tcp_netstats()
7053 		    flow->flow_tag, flow_stats.flow_id);  in necp_request_aop_tcp_netstats()
7150 		desc->rcvbufsize = flow_stats.rx_buffer_stats.bufsize;  in necp_request_aop_tcp_netstats()
7151 		desc->rcvbufused = flow_stats.rx_buffer_stats.bufused;  in necp_request_aop_tcp_netstats()
7154 		desc->sndbufsize = flow_stats.tx_buffer_stats.bufsize;  in necp_request_aop_tcp_netstats()
7155 		desc->sndbufused = flow_stats.tx_buffer_stats.bufused;  in necp_request_aop_tcp_netstats()
7162 		u_int32_t cc_alg_index = flow_stats.transport.tcp_stats.tcp_cc_algo;  in necp_request_aop_tcp_netstats()
11645     struct necp_flow_statistics *flow_stats)  in necp_client_copy_flow_stats()  argument
11661 	if (flow_stats->transport_proto == IPPROTO_TCP) {  in necp_client_copy_flow_stats()
11662 		struct tcp_info *tcpi = &flow_stats->transport.tcpi;  in necp_client_copy_flow_stats()
11675 	struct necp_flow_statistics flow_stats = {};  in necp_client_get_flow_statistics()  local
11689 	if (uap->buffer_size < sizeof(flow_stats) || uap->buffer == 0) {  in necp_client_get_flow_statistics()
11694 	error = copyin(uap->buffer, &flow_stats, sizeof(flow_stats));  in necp_client_get_flow_statistics()
11700 	if (flow_stats.transport_proto != IPPROTO_TCP) {  in necp_client_get_flow_statistics()
11702 		    flow_stats.transport_proto);  in necp_client_get_flow_statistics()
11721 			error = necp_client_copy_flow_stats(flow_registration, &flow_stats);  in necp_client_get_flow_statistics()
11723 				error = copyout(&flow_stats, uap->buffer, sizeof(flow_stats));  in necp_client_get_flow_statistics()
12373     u_int32_t flow_adv_index, void *flow_stats, uint32_t flow_id, size_t *message_length)  in necp_create_nexus_assign_message()  argument
12400 	if (flow_stats != NULL) {  in necp_create_nexus_assign_message()
12437 	if (flow_stats != NULL) {  in necp_create_nexus_assign_message()
12438 …rite_tlv(cursor, NECP_CLIENT_RESULT_NEXUS_FLOW_STATS, sizeof(void *), &flow_stats, buffer, valsize…  in necp_create_nexus_assign_message()