/dports/benchmarks/flowgrind/flowgrind-flowgrind-0.8.2/src/ |
H A D | daemon.c | 165 void uninit_flow(struct flow *flow) in uninit_flow() argument 187 free_all(flow->read_block, flow->write_block, flow->addr, flow->error); in uninit_flow() 284 struct flow *flow = node->data; in prepare_fds() local 303 flow->pmtu = get_pmtu(flow->fd); in prepare_fds() 351 struct flow *flow = node->data; in start_flows() local 392 struct flow *flow = node->data; in stop_flow() local 399 flow->pmtu = get_pmtu(flow->fd); in stop_flow() 414 struct flow *flow = node->data; in stop_flow() local 425 flow->pmtu = get_pmtu(flow->fd); in stop_flow() 701 struct flow *flow = node->data; in timer_check() local [all …]
|
H A D | destination.c | 71 int get_tcp_info(struct flow *flow, struct tcp_info *info); 74 void init_flow(struct flow* flow, int is_source); 75 void uninit_flow(struct flow *flow); 78 static int create_listen_socket(struct flow *flow, char *bind_addr, 160 struct flow *flow; 171 flow = malloc(sizeof(struct flow)); 172 if (!flow) { 181 flow->read_block = calloc(1, flow->settings.maximum_block_size ); 183 flow->id=flow->settings.flow_id; 184 if (flow->write_block == NULL || flow->read_block == NULL) { [all …]
|
H A D | source.c | 70 int get_tcp_info(struct flow *flow, struct tcp_info *info); 73 void init_flow(struct flow* flow, int is_source); 74 void uninit_flow(struct flow *flow); 153 int do_connect(struct flow *flow) { in do_connect() argument 156 rc = connect(flow->fd, flow->addr, flow->addr_len); in do_connect() 164 flow->pmtu = get_pmtu(flow->fd); in do_connect() 182 struct flow *flow; in add_flow_source() local 193 flow = malloc(sizeof(struct flow)); in add_flow_source() 207 flow->id = flow->settings.flow_id; in add_flow_source() 222 flow->fd = name2socket(flow, flow->source_settings.destination_host, in add_flow_source() [all …]
|
/dports/science/afni/afni-AFNI_21.3.16/src/pkundu/meica.libs/mdp/test/ |
H A D | test_flows.py | 13 return flow 29 assert not flow.flow[i].is_training(), \ 32 out = flow(inp) 82 assert_equal(len(flow), len(flow.flow)) 85 assert flow[i]==flow.flow[i], \ 130 newflow = flow + flow 193 flow._check_nodes_consistency(flow.flow) 206 flow += node2 215 oldflow = flow 216 flow += node2 [all …]
|
/dports/science/py-mdp/MDP-3.5/mdp/test/ |
H A D | test_flows.py | 16 return flow 32 assert not flow.flow[i].is_training(), \ 35 out = flow(inp) 85 assert_equal(len(flow), len(flow.flow)) 88 assert flow[i]==flow.flow[i], \ 133 newflow = flow + flow 196 flow._check_nodes_consistency(flow.flow) 209 flow += node2 218 oldflow = flow 219 flow += node2 [all …]
|
/dports/devel/py-taskflow/taskflow-4.6.3/taskflow/tests/unit/ |
H A D | test_flow_dependencies.py | 34 flow = utils.TaskMultiArg() 59 flow = lf.Flow('lf').add( 66 flow = lf.Flow('lf').add( 73 flow = lf.Flow('lf').add( 80 flow = lf.Flow('lf').add( 87 flow = lf.Flow('lf').add( 132 flow = uf.Flow('uf') 141 flow = uf.Flow('uf') 148 flow = uf.Flow('uf') 171 flow = uf.Flow('uf') [all …]
|
/dports/security/snort3/snort3-3.1.19.0/src/stream/ |
H A D | stream.cc | 197 Flow* flow = p->flow; in check_flow_closed() local 253 assert(flow && flow->session); in stop_inspection() 296 Flow* flow = p->flow; in drop_traffic() local 310 Flow* flow = p->flow; in block_flow() local 323 Flow* flow = p->flow; in drop_flow() local 487 assert(flow && flow->session); in set_splitter() 493 assert(flow && flow->session); in get_splitter() 592 Flow* flow = p->flow; in blocked_flow() local 744 assert(flow && flow->session); in update_flow_alert() 751 assert(flow && flow->session); in set_extra_data() [all …]
|
/dports/math/py-or-tools/or-tools-9.2/examples/flatzinc/ |
H A D | max_flow_winston1.fzn | 5 constraint int_le(0, flow[1]); 6 constraint int_le(0, flow[2]); 7 constraint int_le(0, flow[3]); 8 constraint int_le(0, flow[4]); 9 constraint int_le(0, flow[5]); 37 constraint int_lin_eq([1, -1], [flow[9], flow[20]], 0); 38 constraint int_lin_eq([-1, -1, 1], [flow[2], flow[3], flow[21]], 0); 39 constraint int_lin_eq([1, -1, -1], [flow[2], flow[8], flow[9]], 0); 40 constraint int_lin_eq([1, 1, -1], [flow[3], flow[8], flow[15]], 0); 41 constraint int_lin_eq([1, 1, -1], [flow[15], flow[20], flow[21]], 0); [all …]
|
/dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/test/ |
H A D | test_composite_node.cpp | 98 … typedef tbb::flow::tuple<tbb::flow::continue_msg, tbb::flow::tuple<int, int>, int, int, int, int, in add_all_nodes() 101 …typedef tbb::flow::tuple<tbb::flow::continue_msg, tbb::flow::tuple<int, int>, tbb::flow::tagged_ms… in add_all_nodes() 122 tbb::flow::join_node< tbb::flow::tuple< int, int >, tbb::flow::queueing > j(g); in add_all_nodes() 187 typedef tbb::flow::composite_node< tbb::flow::tuple< int >, tbb::flow::tuple< int > > base_type; 260 tbb::flow::join_node< tbb::flow::tuple< int, int >, tbb::flow::queueing > j; 325 tbb::flow::make_edge( tbb::flow::output_port<0>(a0), tbb::flow::input_port<0>(a2) ); in test_adder() 326 tbb::flow::make_edge( tbb::flow::output_port<0>(a1), tbb::flow::input_port<1>(a2) ); in test_adder() 390 tbb::flow::composite_node<tbb::flow::tuple<int, int>, tbb::flow::tuple<int> > outer_node(g); in test_nested_adder() 449 … tbb::flow::get<0>(t) + tbb::flow::get<1>(t) + tbb::flow::get<2>(t) + tbb::flow::get<3>(t), in operator ()() 450 …tbb::flow::get<0>(t) + tbb::flow::get<1>(t) + tbb::flow::get<2>(t) + tbb::flow::get<3>(t) + tbb::f… in operator ()() [all …]
|
/dports/devel/tbb/oneTBB-2020.3/src/test/ |
H A D | test_composite_node.cpp | 98 … typedef tbb::flow::tuple<tbb::flow::continue_msg, tbb::flow::tuple<int, int>, int, int, int, int, in add_all_nodes() 101 …typedef tbb::flow::tuple<tbb::flow::continue_msg, tbb::flow::tuple<int, int>, tbb::flow::tagged_ms… in add_all_nodes() 122 tbb::flow::join_node< tbb::flow::tuple< int, int >, tbb::flow::queueing > j(g); in add_all_nodes() 187 typedef tbb::flow::composite_node< tbb::flow::tuple< int >, tbb::flow::tuple< int > > base_type; 260 tbb::flow::join_node< tbb::flow::tuple< int, int >, tbb::flow::queueing > j; 325 tbb::flow::make_edge( tbb::flow::output_port<0>(a0), tbb::flow::input_port<0>(a2) ); in test_adder() 326 tbb::flow::make_edge( tbb::flow::output_port<0>(a1), tbb::flow::input_port<1>(a2) ); in test_adder() 390 tbb::flow::composite_node<tbb::flow::tuple<int, int>, tbb::flow::tuple<int> > outer_node(g); in test_nested_adder() 449 … tbb::flow::get<0>(t) + tbb::flow::get<1>(t) + tbb::flow::get<2>(t) + tbb::flow::get<3>(t), in operator ()() 450 …tbb::flow::get<0>(t) + tbb::flow::get<1>(t) + tbb::flow::get<2>(t) + tbb::flow::get<3>(t) + tbb::f… in operator ()() [all …]
|
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/test/ |
H A D | test_composite_node.cpp | 98 … typedef tbb::flow::tuple<tbb::flow::continue_msg, tbb::flow::tuple<int, int>, int, int, int, int, in add_all_nodes() 101 …typedef tbb::flow::tuple<tbb::flow::continue_msg, tbb::flow::tuple<int, int>, tbb::flow::tagged_ms… in add_all_nodes() 122 tbb::flow::join_node< tbb::flow::tuple< int, int >, tbb::flow::queueing > j(g); in add_all_nodes() 187 typedef tbb::flow::composite_node< tbb::flow::tuple< int >, tbb::flow::tuple< int > > base_type; 260 tbb::flow::join_node< tbb::flow::tuple< int, int >, tbb::flow::queueing > j; 325 tbb::flow::make_edge( tbb::flow::output_port<0>(a0), tbb::flow::input_port<0>(a2) ); in test_adder() 326 tbb::flow::make_edge( tbb::flow::output_port<0>(a1), tbb::flow::input_port<1>(a2) ); in test_adder() 390 tbb::flow::composite_node<tbb::flow::tuple<int, int>, tbb::flow::tuple<int> > outer_node(g); in test_nested_adder() 449 … tbb::flow::get<0>(t) + tbb::flow::get<1>(t) + tbb::flow::get<2>(t) + tbb::flow::get<3>(t), in operator ()() 450 …tbb::flow::get<0>(t) + tbb::flow::get<1>(t) + tbb::flow::get<2>(t) + tbb::flow::get<3>(t) + tbb::f… in operator ()() [all …]
|
/dports/net/ndpi/nDPI-92a1be2/src/lib/protocols/ |
H A D | http.c | 53 …if((flow->initial_binary_bytes_len >= 2) && (flow->initial_binary_bytes[0] == 0x4D) && (flow->init… in ndpi_analyze_content_signature() 347 if((flow->l4.tcp.http_stage == 0) || (flow->http.url && flow->http_detected)) { in ndpi_http_parse_subprotocol() 502 if(flow->http_detected && (flow->http.response_status_code != 0)) in check_content_type_and_change_protocol() 556 flow->server_id = flow->dst; in check_content_type_and_change_protocol() 575 flow->detected_protocol_stack[1] = flow->guessed_protocol_id; in check_content_type_and_change_protocol() 582 flow->guessed_protocol_id = flow->detected_protocol_stack[1]; in check_content_type_and_change_protocol() 584 flow->guessed_host_protocol_id = flow->detected_protocol_stack[0]; in check_content_type_and_change_protocol() 654 flow->guessed_category = flow->category = ndpi_http_check_content(ndpi_struct, flow); in check_content_type_and_change_protocol() 1172 if(!flow) { in ndpi_get_http_method() 1183 if((!flow) || (!flow->http.url)) in ndpi_get_http_url() [all …]
|
H A D | steam.c | 53 if (flow->steam_stage == 0) { in ndpi_check_steam_tcp() 71 } else if ((flow->steam_stage == 1) || (flow->steam_stage == 2)) { in ndpi_check_steam_tcp() 85 flow->steam_stage = 0; in ndpi_check_steam_tcp() 87 } else if ((flow->steam_stage == 3) || (flow->steam_stage == 4)) { in ndpi_check_steam_tcp() 101 flow->steam_stage = 0; in ndpi_check_steam_tcp() 150 } else if ((flow->steam_stage1 == 1) || (flow->steam_stage1 == 2)) { in ndpi_check_steam_udp1() 164 flow->steam_stage1 = 0; in ndpi_check_steam_udp1() 167 } else if ((flow->steam_stage1 == 3) || (flow->steam_stage1 == 4)) { in ndpi_check_steam_udp1() 181 flow->steam_stage1 = 0; in ndpi_check_steam_udp1() 216 flow->steam_stage2 = 0; in ndpi_check_steam_udp2() [all …]
|
/dports/net-mgmt/flow-tools/flow-tools-2ca53f5/ |
H A D | .gitignore | 45 /docs/flow-mask.1 59 /docs/flow-tag.1 63 /docs/flow-cat.1 89 /src/flow-cat 90 /src/flow-dscan 95 /src/flow-gen 98 /src/flow-mask 99 /src/flow-merge 104 /src/flow-send 106 /src/flow-stat [all …]
|
/dports/security/snort3/snort3-3.1.19.0/src/flow/ |
H A D | flow_cache.cc | 102 if ( flow ) in find() 110 return flow; in find() 159 if ( !flow ) in allocate() 175 if ( flow->session && flow->pkt_type != key->pkt_type ) in allocate() 181 link_uni(flow); in allocate() 182 if ( flow->session && flow->pkt_type != key->pkt_type ) in allocate() 187 return flow; in allocate() 215 remove(flow); in release() 223 flow->term(); in retire() 225 remove(flow); in retire() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/courgette/ |
H A D | encode_decode_unittest.cc | 31 flow.ReadDisassemblerFromBuffer(flow.ONLY, original_buffer); in TestAssembleToStreamDisassemble() 35 flow.CreateAssemblyProgramFromDisassembler(flow.ONLY, false); in TestAssembleToStreamDisassemble() 37 EXPECT_TRUE(nullptr != flow.data(flow.ONLY)->program.get()); in TestAssembleToStreamDisassemble() 41 EXPECT_TRUE(nullptr != flow.data(flow.ONLY)->encoded.get()); in TestAssembleToStreamDisassemble() 43 flow.DestroyAssemblyProgram(flow.ONLY); in TestAssembleToStreamDisassemble() 47 flow.DestroyDisassembler(flow.ONLY); in TestAssembleToStreamDisassemble() 51 flow.WriteSinkStreamSetFromEncodedProgram(flow.ONLY); in TestAssembleToStreamDisassemble() 54 flow.DestroyEncodedProgram(flow.ONLY); in TestAssembleToStreamDisassemble() 59 flow.WriteSinkStreamFromSinkStreamSet(flow.ONLY, &sink); in TestAssembleToStreamDisassemble() 71 flow.ReadEncodedProgramFromSourceStreamSet(flow.ONLY); in TestAssembleToStreamDisassemble() [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/net/sched/ |
H A D | sch_atm.c | 110 return flow ? flow->q : NULL; in atm_tc_leaf() 132 if (flow) in atm_tc_bind_filter() 159 flow->vcc->pop = flow->old_pop; in atm_tc_put() 222 if (flow) in atm_tc_change() 302 flow->vcc->user_back = flow; in atm_tc_change() 304 flow->old_pop = flow->vcc->pop; in atm_tc_change() 373 return flow ? flow->block : p->link.block; in atm_tc_tcf_block() 428 flow = flow->excess; in atm_tc_enqueue() 485 while ((skb = flow->q->ops->peek(flow->q))) { in sch_atm_dequeue() 510 memcpy(skb_push(skb, flow->hdr_len), flow->hdr, in sch_atm_dequeue() [all …]
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/net/sched/ |
H A D | sch_atm.c | 110 return flow ? flow->q : NULL; in atm_tc_leaf() 132 if (flow) in atm_tc_bind_filter() 159 flow->vcc->pop = flow->old_pop; in atm_tc_put() 222 if (flow) in atm_tc_change() 302 flow->vcc->user_back = flow; in atm_tc_change() 304 flow->old_pop = flow->vcc->pop; in atm_tc_change() 373 return flow ? flow->block : p->link.block; in atm_tc_tcf_block() 428 flow = flow->excess; in atm_tc_enqueue() 485 while ((skb = flow->q->ops->peek(flow->q))) { in sch_atm_dequeue() 510 memcpy(skb_push(skb, flow->hdr_len), flow->hdr, in sch_atm_dequeue() [all …]
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/net/sched/ |
H A D | sch_atm.c | 110 return flow ? flow->q : NULL; in atm_tc_leaf() 132 if (flow) in atm_tc_bind_filter() 159 flow->vcc->pop = flow->old_pop; in atm_tc_put() 222 if (flow) in atm_tc_change() 302 flow->vcc->user_back = flow; in atm_tc_change() 304 flow->old_pop = flow->vcc->pop; in atm_tc_change() 373 return flow ? flow->block : p->link.block; in atm_tc_tcf_block() 428 flow = flow->excess; in atm_tc_enqueue() 485 while ((skb = flow->q->ops->peek(flow->q))) { in sch_atm_dequeue() 510 memcpy(skb_push(skb, flow->hdr_len), flow->hdr, in sch_atm_dequeue() [all …]
|
/dports/multimedia/gstreamer1-validate/gst-validate-1.16.1/plugins/flow/ |
H A D | gstvalidateflow.c | 124 if (!flow->error_writing_file && vfprintf (flow->output_file, format, ap) < 0) { in validate_flow_override_vprintf() 166 if (flow->error_writing_file || !flow->record_buffers) in validate_flow_override_buffer_handler() 212 if (!flow->pad_name) { in validate_flow_override_new() 224 flow->caps_properties = parse_caps_properties_setting (flow, config); in validate_flow_override_new() 279 flow->output_file_path = g_strdup (flow->actual_results_file_path); in validate_flow_override_new() 282 flow->output_file_path = g_strdup (flow->expectations_file_path); in validate_flow_override_new() 296 flow->output_file = fopen (flow->output_file_path, "w"); in validate_flow_override_new() 310 return flow; in validate_flow_override_new() 383 run_diff (flow->expectations_file_path, flow->actual_results_file_path); in show_mismatch_error() 398 flow->pad_name); in runner_stopping() [all …]
|
/dports/net/ndpi/nDPI-92a1be2/example/ |
H A D | reader_util.c | 195 flow->hashval, flow->protocol, flow->vlan_id, in ndpi_payload_analyzer() 196 flow->src_name, flow->src_port, in ndpi_payload_analyzer() 197 flow->dst_name, flow->dst_port, in ndpi_payload_analyzer() 316 if(flow->ndpi_flow) { ndpi_flow_free(flow->ndpi_flow); flow->ndpi_flow = NULL; } in ndpi_free_flow_info_half() 317 if(flow->src_id) { ndpi_free(flow->src_id); flow->src_id = NULL; } in ndpi_free_flow_info_half() 318 if(flow->dst_id) { ndpi_free(flow->dst_id); flow->dst_id = NULL; } in ndpi_free_flow_info_half() 784 …flow.hashval = hashval = flow.protocol + flow.src_ip + flow.dst_ip + flow.src_port + flow.dst_port; in get_ndpi_flow_info() 788 flow.src_ip, flow.src_port, ntohs(flow.dst_ip), ntohs(flow.dst_port)); in get_ndpi_flow_info() 1055 flow->risk = flow->ndpi_flow->risk; in process_ndpi_collected_info() 1208 snprintf(flow->info, sizeof(flow->info), "%s", in process_ndpi_collected_info() [all …]
|
/dports/security/snort3/snort3-3.1.19.0/src/stream/base/ |
H A D | stream_ha.cc | 71 if (flow.client_ip.fast_lt6(flow.server_ip)) in is_client_lower() 74 if (flow.server_ip.fast_lt6(flow.client_ip)) in is_client_lower() 81 if (flow.client_port < flow.server_port) in is_client_lower() 113 flow->server_ip.set(flow->key->ip_l); in consume() 114 flow->client_ip.set(flow->key->ip_h); in consume() 115 flow->server_port = flow->key->port_l; in consume() 116 flow->client_port = flow->key->port_h; in consume() 120 flow->client_ip.set(flow->key->ip_l); in consume() 121 flow->server_ip.set(flow->key->ip_h); in consume() 122 flow->client_port = flow->key->port_l; in consume() [all …]
|
/dports/science/py-abipy/abipy-0.9.0/abipy/flowtk/tests/ |
H A D | test_flows.py | 122 assert flow.has_db 158 flow.allocate() 206 flow.show_info() 208 flow.show_inputs() 259 str(flow) 261 flow.build() 344 … assert len(list(flow.iflat_nodes())) == 1 + len(flow.works) + sum(len(work) for work in flow) 345 assert flow.node_from_nid(flow.node_id) == flow 351 flow = Flow.pickle_load(flow.workdir) 357 work = flow[0] [all …]
|
/dports/devel/onetbb/oneTBB-2021.4.0/test/tbb/ |
H A D | test_composite_node.cpp | 309 tbb::flow::make_edge( s, tbb::flow::input_port<0>(a0) ); in test_adder() 310 tbb::flow::make_edge( c, tbb::flow::input_port<1>(a0) ); in test_adder() 312 tbb::flow::make_edge( c, tbb::flow::input_port<0>(a1) ); in test_adder() 313 tbb::flow::make_edge( c, tbb::flow::input_port<1>(a1) ); in test_adder() 315 tbb::flow::make_edge( tbb::flow::output_port<0>(a0), tbb::flow::input_port<0>(a2) ); in test_adder() 316 tbb::flow::make_edge( tbb::flow::output_port<0>(a1), tbb::flow::input_port<1>(a2) ); in test_adder() 318 tbb::flow::make_edge( tbb::flow::output_port<0>(a2), s2 ); in test_adder() 341 tbb::flow::make_edge( a1, tbb::flow::input_port<1>(a3) ); in test_adder() 428 tbb::flow::join_node< my_tuple_t, tbb::flow::queueing > j; 449 …nput_tuple(tbb::flow::input_port<0>(j), tbb::flow::input_port<1>(j), tbb::flow::input_port<2>(j), … in prefix_node() [all …]
|
/dports/net/rude/rude/rude/ |
H A D | main.c | 224 flow->send_func(flow); in main() 313 flow->flow_id, flow->flow_start.tv_sec,flow->flow_start.tv_usec, in dump_config() 314 flow->flow_stop.tv_sec,flow->flow_stop.tv_usec, in dump_config() 333 flow = flow->mod_flow; in dump_config() 350 flow->flow_id, flow->flow_start.tv_sec, flow->flow_start.tv_usec, in dump_config() 353 ntohs(flow->dst.sin_port), flow->errors, flow->success, in dump_config() 368 flow = flow->next; in dump_config() 392 flow->flow_id, flow->flow_start.tv_sec, flow->flow_start.tv_usec, in print_results() 395 ntohs(flow->dst.sin_port), flow->errors, flow->success, in print_results() 410 flow = flow->next; in print_results() [all …]
|