| /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 …]
|