/dports/benchmarks/fio/fio-3.29/ |
H A D | flow.c | 10 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 D | fio.h | 463 unsigned long long flow_counter; member
|
/dports/net-mgmt/pmacct/pmacct-1.7.5/src/ |
H A D | acct.c | 166 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 D | plugin_common.c | 295 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 D | plugin_cmn_avro.h | 60 pm_counter_t packet_counter, pm_counter_t flow_counter, u_int32_t tcp_flags,
|
H A D | plugin_common.h | 64 pm_counter_t flow_counter; member
|
H A D | imt_plugin.h | 38 pm_counter_t flow_counter; member
|
H A D | preprocess.c | 780 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 D | print_plugin.c | 871 … 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 D | plugin_cmn_avro.c | 403 …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 D | kafka_plugin.c | 602 queue[j]->flow_counter, queue[j]->tcp_flags, &queue[j]->basetime, in kafka_cache_purge()
|
H A D | amqp_plugin.c | 571 queue[j]->flow_counter, queue[j]->tcp_flags, &queue[j]->basetime, in amqp_cache_purge()
|
H A D | server.c | 639 abuf->flo_num += elem->flow_counter; in Accumulate_Counters()
|
/dports/net-mgmt/pmacct/pmacct-1.7.5/examples/custom/ |
H A D | libcustom.h | 47 pm_counter_t packet_counter, pm_counter_t flow_counter,
|
H A D | libcustom.c | 56 pm_counter_t packet_counter, pm_counter_t flow_counter, in print() argument
|
/dports/net/tcpflow/tcpflow-1.5.0/src/ |
H A D | tcpflow.cpp | 894 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 D | tcpdemux.h | 118 uint64_t flow_counter; // how many flows have we seen? variable
|
H A D | tcpdemux.cpp | 29 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 D | egress_lgcy.c | 82 if (MLX5_CAP_ESW_EGRESS_ACL(esw->dev, flow_counter)) { in esw_acl_egress_lgcy_setup()
|
H A D | ingress_lgcy.c | 163 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 D | egress_lgcy.c | 82 if (MLX5_CAP_ESW_EGRESS_ACL(esw->dev, flow_counter)) { in esw_acl_egress_lgcy_setup()
|
H A D | ingress_lgcy.c | 163 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 D | egress_lgcy.c | 82 if (MLX5_CAP_ESW_EGRESS_ACL(esw->dev, flow_counter)) { in esw_acl_egress_lgcy_setup()
|
H A D | ingress_lgcy.c | 163 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 D | fastnetmon.cpp | 376 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 …]
|