Home
last modified time | relevance | path

Searched refs:flow_counter (Results 1 – 25 of 34) sorted by relevance

12

/dports/benchmarks/fio/fio-3.29/
H A Dflow.c10 unsigned long flow_counter; member
25 flow_counter_ratio = (double)td->flow_counter / in flow_threshold_exceeded()
26 atomic_load_relaxed(&flow->flow_counter); in flow_threshold_exceeded()
51 atomic_add(&flow->flow_counter, 1); in flow_threshold_exceeded()
52 ++td->flow_counter; in flow_threshold_exceeded()
84 flow->flow_counter = 1; in flow_get()
95 static void flow_put(struct fio_flow *flow, unsigned long flow_counter, in flow_put() argument
103 atomic_sub(&flow->flow_counter, flow_counter); in flow_put()
107 assert(flow->flow_counter == 1); in flow_put()
119 td->flow_counter = 0; in flow_init_job()
[all …]
H A Dfio.h463 unsigned long long flow_counter; member
/dports/net-mgmt/pmacct/pmacct-1.7.5/src/
H A Dacct.c166 elem_acc->flow_counter -= MIN(elem_acc->flow_counter, data->cst.fa); in insert_accounting_structure()
196 elem_acc->flow_counter += data->flo_num; in insert_accounting_structure()
203 elem_acc->flow_counter += data->cst.fa; in insert_accounting_structure()
218 elem_acc->flow_counter += data->flo_num; in insert_accounting_structure()
225 elem_acc->flow_counter += data->cst.fa; in insert_accounting_structure()
341 elem_acc->flow_counter += data->flo_num; in insert_accounting_structure()
349 elem_acc->flow_counter += data->cst.fa; in insert_accounting_structure()
470 elem_acc->flow_counter += data->flo_num; in insert_accounting_structure()
478 elem_acc->flow_counter += data->cst.fa; in insert_accounting_structure()
H A Dplugin_common.c295 Cursor->flow_counter -= MIN(Cursor->flow_counter, data->cst.fa); in P_cache_insert()
428 cache_ptr->flow_counter = data->flo_num; in P_cache_insert()
436 cache_ptr->flow_counter += data->cst.fa; in P_cache_insert()
470 cache_ptr->flow_counter += data->flo_num; in P_cache_insert()
478 cache_ptr->flow_counter += data->cst.fa; in P_cache_insert()
498 cache_ptr->flow_counter = data->flo_num; in P_cache_insert()
505 cache_ptr->flow_counter += data->cst.fa; in P_cache_insert()
H A Dplugin_cmn_avro.h60 pm_counter_t packet_counter, pm_counter_t flow_counter, u_int32_t tcp_flags,
H A Dplugin_common.h64 pm_counter_t flow_counter; member
H A Dimt_plugin.h38 pm_counter_t flow_counter; member
H A Dpreprocess.c780 if (queue[x]->flow_counter >= prep.minf) queue[x]->prep_valid++; in P_check_minf()
808 if (!queue[0]->flow_counter) return FALSE; in P_check_minppf()
812 if (queue[x]->packet_counter/queue[x]->flow_counter >= prep.minppf) queue[x]->prep_valid++; in P_check_minppf()
H A Dprint_plugin.c871 … if (config.what_to_count & COUNT_FLOWS) fprintf(f, "%-20" PRIu64 " ", queue[j]->flow_counter); in P_cache_purge()
1235 …o_count & COUNT_FLOWS) fprintf(f, "%s%" PRIu64 "", write_sep(sep, &count), queue[j]->flow_counter); in P_cache_purge()
1257 pvlen, queue[j]->bytes_counter, queue[j]->packet_counter, queue[j]->flow_counter, in P_cache_purge()
1285 queue[j]->packet_counter, queue[j]->flow_counter, queue[j]->tcp_flags, NULL, in P_cache_purge()
H A Dplugin_cmn_avro.c403 …pm_counter_t bytes_counter, pm_counter_t packet_counter, pm_counter_t flow_counter, u_int32_t tcp_… in compose_avro_acct_data() argument
1038 pm_avro_check(avro_value_set_long(&branch, flow_counter)); in compose_avro_acct_data()
H A Dkafka_plugin.c602 queue[j]->flow_counter, queue[j]->tcp_flags, &queue[j]->basetime, in kafka_cache_purge()
H A Damqp_plugin.c571 queue[j]->flow_counter, queue[j]->tcp_flags, &queue[j]->basetime, in amqp_cache_purge()
H A Dserver.c639 abuf->flo_num += elem->flow_counter; in Accumulate_Counters()
/dports/net-mgmt/pmacct/pmacct-1.7.5/examples/custom/
H A Dlibcustom.h47 pm_counter_t packet_counter, pm_counter_t flow_counter,
H A Dlibcustom.c56 pm_counter_t packet_counter, pm_counter_t flow_counter, in print() argument
/dports/net/tcpflow/tcpflow-1.5.0/src/
H A Dtcpflow.cpp894 DEBUG(2)("Flows seen: %d",(int)demux.flow_counter); in main()
909 DEBUG(2)(total_flow_processed.c_str(),demux.flow_counter); in main()
917 xreport->xmlout("total_flows",demux.flow_counter); in main()
926 if(demux.flow_counter > tcpdemux::WARN_TOO_MANY_FILES){ in main()
H A Dtcpdemux.h118 uint64_t flow_counter; // how many flows have we seen? variable
H A Dtcpdemux.cpp29 outdir("."),flow_counter(0),packet_counter(0), in tcpdemux()
155 flow flow(flowa,flow_counter++,pi); in create_tcpip()
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/ethernet/mellanox/mlx5/core/esw/acl/
H A Degress_lgcy.c82 if (MLX5_CAP_ESW_EGRESS_ACL(esw->dev, flow_counter)) { in esw_acl_egress_lgcy_setup()
H A Dingress_lgcy.c163 if (MLX5_CAP_ESW_INGRESS_ACL(esw->dev, flow_counter)) { in esw_acl_ingress_lgcy_setup()
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/ethernet/mellanox/mlx5/core/esw/acl/
H A Degress_lgcy.c82 if (MLX5_CAP_ESW_EGRESS_ACL(esw->dev, flow_counter)) { in esw_acl_egress_lgcy_setup()
H A Dingress_lgcy.c163 if (MLX5_CAP_ESW_INGRESS_ACL(esw->dev, flow_counter)) { in esw_acl_ingress_lgcy_setup()
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/ethernet/mellanox/mlx5/core/esw/acl/
H A Degress_lgcy.c82 if (MLX5_CAP_ESW_EGRESS_ACL(esw->dev, flow_counter)) { in esw_acl_egress_lgcy_setup()
H A Dingress_lgcy.c163 if (MLX5_CAP_ESW_INGRESS_ACL(esw->dev, flow_counter)) { in esw_acl_ingress_lgcy_setup()
/dports/net-mgmt/fastnetmon/fastnetmon-1.1.4/src/
H A Dfastnetmon.cpp376 boost::mutex flow_counter; variable
1940 flow_counter.lock(); in process_packet()
1947 flow_counter.unlock(); in process_packet()
1959 flow_counter.lock(); in process_packet()
1966 flow_counter.unlock(); in process_packet()
2081 flow_counter.lock(); in process_packet()
2088 flow_counter.unlock(); in process_packet()
2100 flow_counter.lock(); in process_packet()
2106 flow_counter.unlock(); in process_packet()
2378 flow_counter.lock(); in recalculate_speed()
[all …]

12