Lines Matching refs:flowacct_data
287 flowacct_data_t *flowacct_data) in flowacct_flow_present() argument
289 list_hdr_t *hdr = flowacct_data->flows_tbl[index].head; in flowacct_flow_present()
432 flowacct_update_flows_tbl(header_t *header, flowacct_data_t *flowacct_data) in flowacct_update_flows_tbl() argument
444 fhead = &flowacct_data->flows_tbl[index]; in flowacct_update_flows_tbl()
447 thead = &flowacct_data->flows_tbl[FLOW_TBL_COUNT]; in flowacct_update_flows_tbl()
450 flow = flowacct_flow_present(header, index, flowacct_data); in flowacct_update_flows_tbl()
499 atomic_inc_32(&flowacct_data->nflows); in flowacct_update_flows_tbl()
500 if (flowacct_data->nflows > flowacct_data->max_limit) { in flowacct_update_flows_tbl()
501 atomic_dec_32(&flowacct_data->nflows); in flowacct_update_flows_tbl()
512 flowacct_data); in flowacct_update_flows_tbl()
539 atomic_dec_32(&flowacct_data->nflows); in flowacct_update_flows_tbl()
553 atomic_dec_32(&flowacct_data->nflows); in flowacct_update_flows_tbl()
561 atomic_add_64(&flowacct_data->usedmem, in flowacct_update_flows_tbl()
564 atomic_add_64(&flowacct_data->usedmem, FLOWACCT_ITEM_RECORD_SZ); in flowacct_update_flows_tbl()
638 atomic_add_64(&flowacct_data->tbytes, header->pktlen); in flowacct_update_flows_tbl()
646 flowacct_data_t *flowacct_data = (flowacct_data_t *)args; in flowacct_timeout_flows() local
647 flowacct_timer(FLOWACCT_FLOW_TIMER, flowacct_data); in flowacct_timeout_flows()
648 flowacct_data->flow_tid = timeout(flowacct_timeout_flows, flowacct_data, in flowacct_timeout_flows()
649 drv_usectohz(flowacct_data->timer)); in flowacct_timeout_flows()
727 flowacct_timer(int type, flowacct_data_t *flowacct_data) in flowacct_timer() argument
740 ASSERT(flowacct_data != NULL); in flowacct_timer()
755 thead = &flowacct_data->flows_tbl[FLOW_TBL_COUNT]; in flowacct_timer()
775 (diff < flowacct_data->timeout)) { in flowacct_timer()
802 flowacct_data->act_name; in flowacct_timer()
813 atomic_add_32(&flowacct_data->nflows, in flowacct_timer()
819 atomic_add_64(&flowacct_data->tbytes, (~item->nbytes + in flowacct_timer()
825 atomic_add_64(&flowacct_data->usedmem, item_size); in flowacct_timer()
828 atomic_add_32(&flowacct_data->nflows, (~items_deleted + 1)); in flowacct_timer()
850 atomic_add_64(&flowacct_data->usedmem, flow_size); in flowacct_timer()
876 flowacct_process(mblk_t **mpp, flowacct_data_t *flowacct_data) in flowacct_process() argument
890 atomic_inc_64(&flowacct_data->epackets); in flowacct_process()
898 atomic_inc_64(&flowacct_data->epackets); in flowacct_process()
905 atomic_inc_64(&flowacct_data->epackets); in flowacct_process()
910 if (flowacct_update_flows_tbl(header, flowacct_data) != 0) { in flowacct_process()
912 atomic_inc_64(&flowacct_data->epackets); in flowacct_process()
917 atomic_inc_64(&flowacct_data->npackets); in flowacct_process()
918 atomic_add_64(&flowacct_data->nbytes, header->pktlen); in flowacct_process()
921 if (flowacct_data->flow_tid == 0) { in flowacct_process()
922 flowacct_data->flow_tid = timeout(flowacct_timeout_flows, in flowacct_process()
923 flowacct_data, drv_usectohz(flowacct_data->timer)); in flowacct_process()