| /dports/net/nmsg/nmsg-1.0.1/nmsg/ |
| H A D | message.h | 77 nmsg_message_t
96 nmsg_message_t
131 nmsg_message_destroy(nmsg_message_t *msg);
164 nmsg_message_get_msgmod(nmsg_message_t msg);
182 nmsg_message_get_vid(nmsg_message_t msg);
188 nmsg_message_get_msgtype(nmsg_message_t msg);
213 nmsg_message_update(nmsg_message_t msg);
248 nmsg_message_get_source(nmsg_message_t msg);
262 nmsg_message_get_group(nmsg_message_t msg);
299 nmsg_message_get_field(nmsg_message_t msg,
[all …]
|
| H A D | msgmod_plugin.h | 48 nmsg_message_t *m);
53 typedef nmsg_res (*nmsg_msgmod_msg_load_fp)(nmsg_message_t m, void **msg_clos);
56 typedef nmsg_res (*nmsg_msgmod_msg_fini_fp)(nmsg_message_t m, void *msg_clos);
59 typedef nmsg_res (*nmsg_msgmod_field_print_fp)(nmsg_message_t m,
66 typedef nmsg_res (*nmsg_msgmod_field_get_fp)(nmsg_message_t m,
74 typedef nmsg_res (*nmsg_msgmod_field_format_fp)(nmsg_message_t m,
81 typedef nmsg_res (*nmsg_msgmod_field_parse_fp)(nmsg_message_t m,
90 nmsg_res funcname(nmsg_message_t m, \
98 nmsg_res funcname(nmsg_message_t m, \
107 nmsg_res funcname(nmsg_message_t m, \
[all …]
|
| H A D | private.h | 457 nmsg_message_t _nmsg_message_from_payload(Nmsg__NmsgPayload *np);
458 nmsg_message_t _nmsg_message_dup(struct nmsg_message *msg);
479 nmsg_res _input_nmsg_read(nmsg_input_t, nmsg_message_t *);
494 nmsg_res _input_nmsg_read_null(nmsg_input_t, nmsg_message_t *);
498 nmsg_res _input_pcap_read(nmsg_input_t, nmsg_message_t *);
499 nmsg_res _input_pcap_read_raw(nmsg_input_t, nmsg_message_t *);
502 nmsg_res _input_pres_read(nmsg_input_t, nmsg_message_t *);
505 nmsg_res _input_json_read(nmsg_input_t, nmsg_message_t *);
520 nmsg_res _output_nmsg_write(nmsg_output_t, nmsg_message_t);
529 nmsg_res _output_pres_write(nmsg_output_t, nmsg_message_t);
[all …]
|
| H A D | nmsg.h | 50 typedef struct nmsg_message * nmsg_message_t; typedef
78 typedef void (*nmsg_cb_message)(nmsg_message_t msg, void *user);
94 typedef nmsg_res (*nmsg_cb_message_read)(nmsg_message_t *msg, void *user);
|
| H A D | container.h | 81 nmsg_container_add(nmsg_container_t c, nmsg_message_t msg);
145 nmsg_message_t **msgarray, size_t *n_msg);
|
| H A D | input_nullnmsg.c | 25 nmsg_message_t *msg __attribute__((unused))) in _input_nmsg_read_null()
43 struct timespec *ts, nmsg_message_t **msgarray, size_t *n_msg) in nmsg_input_read_null()
86 nmsg_message_t msg; in nmsg_input_read_null()
|
| H A D | input_pcap.c | 24 _input_pcap_read(nmsg_input_t input, nmsg_message_t *msg) { in _input_pcap_read()
55 _input_pcap_read_raw(nmsg_input_t input, nmsg_message_t *msg) { in _input_pcap_read_raw()
|
| H A D | input_json.c | 25 _input_json_read(nmsg_input_t input, nmsg_message_t *msg) { in _input_json_read()
68 __attribute__((unused)) nmsg_message_t *msg) { in _input_json_read()
|
| H A D | input.h | 243 nmsg_input_read(nmsg_input_t input, nmsg_message_t *msg);
273 struct timespec *ts, nmsg_message_t **msg, size_t *n_msg);
|
| /dports/net/py-pynmsg/pynmsg-0.5.0/ |
| H A D | nmsg.pxi | 154 ctypedef nmsg_message * nmsg_message_t
164 ctypedef void (*nmsg_cb_message)(nmsg_message_t, void *user)
195 nmsg_message_t nmsg_message_init(nmsg_msgmod_t mod)
196 void nmsg_message_destroy(nmsg_message_t *msg)
205 int32_t nmsg_message_get_vid(nmsg_message_t msg)
206 int32_t nmsg_message_get_msgtype(nmsg_message_t msg)
208 uint32_t nmsg_message_get_source(nmsg_message_t msg)
209 uint32_t nmsg_message_get_operator(nmsg_message_t msg)
210 uint32_t nmsg_message_get_group(nmsg_message_t msg)
253 nmsg_res nmsg_message_from_json(char *, nmsg_message_t *) nogil
[all …]
|
| /dports/net/nmsg/nmsg-1.0.1/nmsg/base/ |
| H A D | dnstap.c | 451 dnstap_get_address(nmsg_message_t msg, in dnstap_get_address()
480 dnstap_get_port(nmsg_message_t msg, in dnstap_get_port()
511 dnstap_get_time_sec(nmsg_message_t msg, in dnstap_get_time_sec()
542 dnstap_get_time_nsec(nmsg_message_t msg, in dnstap_get_time_nsec()
573 dnstap_get_query_zone(nmsg_message_t msg, in dnstap_get_query_zone()
593 dnstap_get_dns(nmsg_message_t msg, in dnstap_get_dns()
622 dnstap_get_id(nmsg_message_t m, in dnstap_get_id()
644 dnstap_get_qname(nmsg_message_t m, in dnstap_get_qname()
665 dnstap_get_qtype(nmsg_message_t m, in dnstap_get_qtype()
686 dnstap_get_qclass(nmsg_message_t m, in dnstap_get_qclass()
[all …]
|
| H A D | dns.c | 120 dns_name_print(nmsg_message_t msg, in dns_name_print()
142 dns_name_format(nmsg_message_t m, in dns_name_format()
163 dns_name_parse(nmsg_message_t m, in dns_name_parse()
193 dns_type_print(nmsg_message_t msg, in dns_type_print()
213 dns_type_format(nmsg_message_t m, in dns_type_format()
235 dns_type_parse(nmsg_message_t msg, in dns_type_parse()
262 dns_class_print(nmsg_message_t msg, in dns_class_print()
282 dns_class_format(nmsg_message_t m, in dns_class_format()
299 dns_class_parse(nmsg_message_t m, in dns_class_parse()
327 dns_rdata_print(nmsg_message_t msg, in dns_rdata_print()
[all …]
|
| H A D | ncap.c | 28 ncap_msg_load(nmsg_message_t m, void **msg_clos);
31 ncap_msg_fini(nmsg_message_t m, void *msg_clos);
147 ncap_msg_load(nmsg_message_t m, void **msg_clos) { in ncap_msg_load()
248 ncap_msg_fini(nmsg_message_t m, void *msg_clos) { in ncap_msg_fini()
254 ncap_get_srcip(nmsg_message_t m, in ncap_get_srcip()
292 ncap_get_dstip(nmsg_message_t m, in ncap_get_dstip()
330 ncap_get_srcport(nmsg_message_t m, in ncap_get_srcport()
350 ncap_get_dstport(nmsg_message_t m, in ncap_get_dstport()
370 ncap_get_proto(nmsg_message_t m, in ncap_get_proto()
390 ncap_get_dns(nmsg_message_t m, in ncap_get_dns()
[all …]
|
| H A D | pkt.c | 29 pkt_pkt_to_payload(void *clos, nmsg_pcap_t pcap, nmsg_message_t *m);
71 pkt_pkt_to_payload(void *clos, nmsg_pcap_t pcap, nmsg_message_t *m) { in pkt_pkt_to_payload()
|
| /dports/net/sie-nmsg/sie-nmsg-1.2.1/ |
| H A D | dnsdedupe.c | 157 time_print(nmsg_message_t msg, in time_print()
186 time_format(nmsg_message_t m, in time_format()
215 time_parse(nmsg_message_t m, in time_parse()
242 dns_name_print(nmsg_message_t msg, in dns_name_print()
265 dns_name_format(nmsg_message_t m, in dns_name_format()
289 dns_name_parse(nmsg_message_t m, in dns_name_parse()
322 dns_type_print(nmsg_message_t msg, in dns_type_print()
343 dns_type_format(nmsg_message_t m, in dns_type_format()
363 dns_type_parse(nmsg_message_t msg, in dns_type_parse()
434 dns_class_parse(nmsg_message_t m, in dns_class_parse()
[all …]
|
| /dports/net/nmsg/nmsg-1.0.1/nmsg/msgmod/ |
| H A D | message.c | 183 nmsg_message_t msg; in nmsg_message_from_raw_payload()
554 nmsg_message_get_msgmod(nmsg_message_t msg) { in nmsg_message_get_msgmod()
559 nmsg_message_get_vid(nmsg_message_t msg) { in nmsg_message_get_vid()
564 nmsg_message_get_msgtype(nmsg_message_t msg) { in nmsg_message_get_msgtype()
569 nmsg_message_get_payload(nmsg_message_t msg) { in nmsg_message_get_payload()
578 nmsg_message_get_payload_size(nmsg_message_t msg) { in nmsg_message_get_payload_size()
585 nmsg_message_update(nmsg_message_t msg) { in nmsg_message_update()
590 nmsg_message_compact_payload(nmsg_message_t msg) { in nmsg_message_compact_payload()
616 nmsg_message_get_source(nmsg_message_t msg) { in nmsg_message_get_source()
623 nmsg_message_get_operator(nmsg_message_t msg) { in nmsg_message_get_operator()
[all …]
|
| /dports/net/axa/axa-2.2.0/axa/ |
| H A D | fields.h | 154 extern bool axa_get_helper(axa_emsg_t *emsg, const nmsg_message_t msg,
172 extern const axa_nmsg_field_t *axa_msg_fields(const nmsg_message_t msg);
200 extern const char *axa_get_field_name(const nmsg_message_t msg,
250 nmsg_message_t *msgp, axa_p_whit_t *whit, size_t whit_len);
|
| /dports/net/nmsg/nmsg-1.0.1/tests/ |
| H A D | test-io.c | 61 nmsg_message_t m; in make_message()
110 nmsg_message_t m; in test_io_sockspec()
177 nmsg_message_t mo, mi; in test_sock()
285 nmsg_message_t mo; in test_ozlib()
720 nmsg_message_t m; in counter_callback()
761 nmsg_message_t m; in test_count()
840 nmsg_message_t m; in test_io_filters2()
919 nmsg_message_t m; in test_rate()
1150 nmsg_message_t m; in test_input_rate()
1241 nmsg_message_t m; in test_misc()
[all …]
|
| H A D | test-misc.c | 166 fill_message(nmsg_message_t m) in fill_message()
188 cmp_nmessages(nmsg_message_t m1, nmsg_message_t m2) in cmp_nmessages()
236 nmsg_message_t m1, m2, m3, *m_arr1, *m_arr2; in test_container()
611 nmsg_message_t m; in test_fltmod()
649 test_read_callback(nmsg_message_t *msg, void *user) in test_read_callback()
661 test_write_callback(nmsg_message_t msg, void *user) in test_write_callback()
679 nmsg_message_t m; in test_callbacks()
753 nmsg_message_t m; in test_miscx()
926 send_container_fd(int fd, nmsg_message_t m, bool set_seq, uint32_t seq, uint64_t seqid) in send_container_fd()
952 nmsg_message_t m, mi; in test_seq()
[all …]
|
| /dports/net/sie-nmsg/sie-nmsg-1.2.1/tests/ |
| H A D | test-io.c | 61 nmsg_message_t m; in test_io_filters2()
177 output_callback(nmsg_message_t msg, void *user) in output_callback()
189 filter_callback(nmsg_message_t *msg, void *user, nmsg_filter_message_verdict *vres) in filter_callback()
207 filter_callback2(nmsg_message_t *msg, void *user, nmsg_filter_message_verdict *vres) in filter_callback2()
|
| H A D | test-misc.c | 43 fill_message(nmsg_message_t m) in fill_message()
65 cmp_nmessages(nmsg_message_t m1, nmsg_message_t m2) in cmp_nmessages()
112 nmsg_message_t m1, m2, m3, *m_arr1, *m_arr2; in test_container()
|
| /dports/dns/dnstable-convert/dnstable-convert-0.11.0/ |
| H A D | dnstable_unconvert.c | 34 static nmsg_message_t entry_to_nmsg(struct dnstable_entry *, const uint8_t *, size_t);
126 nmsg_message_t m; in main()
159 static nmsg_message_t entry_to_nmsg(struct dnstable_entry *e, const uint8_t *data, size_t len_data)… in entry_to_nmsg()
171 nmsg_message_t m = nmsg_message_init(sie_dnsdedupe); in entry_to_nmsg()
|
| /dports/net/axa/axa-2.2.0/axalib/ |
| H A D | whit2nmsg.c | 26 nmsg_message_t *msgp, axa_p_whit_t *whit, size_t whit_len) in axa_whit2nmsg()
29 nmsg_message_t *msgs; in axa_whit2nmsg()
|
| H A D | fields.c | 105 axa_msg_fields(const nmsg_message_t msg) in axa_msg_fields()
122 static nmsg_message_t
126 nmsg_message_t msg; in message_init()
141 nmsg_message_t msg; in get_enum_value()
172 nmsg_message_t msg; in get_field_idx()
635 axa_get_helper(axa_emsg_t *emsg, const nmsg_message_t msg, in axa_get_helper()
|
| /dports/net/axa/axa-2.2.0/sratool/ |
| H A D | print.c | 215 get_nmsg_field(const nmsg_message_t msg, const char *fname, in get_nmsg_field()
233 get_nmsg_field_by_idx(const nmsg_message_t msg, axa_nmsg_idx_t field_idx, in get_nmsg_field_by_idx()
273 fname_enum_to_name(const nmsg_message_t msg, const char *fname, in fname_enum_to_name()
313 fname_to_ip(char *buf, size_t buf_len, const nmsg_message_t msg, in fname_to_ip()
357 nmsg_message_t msg;
459 rdata_nmsg_to_buf(char *buf, size_t buf_len, const nmsg_message_t msg, in rdata_nmsg_to_buf()
616 print_sie_newdomain(const nmsg_message_t msg, in print_sie_newdomain()
712 print_nmsg_base_encode(const nmsg_message_t msg, in print_nmsg_base_encode()
779 get_nm_eq_val(const nmsg_message_t msg, const axa_p_whit_t *whit, in get_nm_eq_val()
906 whit2nmsg(nmsg_message_t *msgp, axa_p_whit_t *whit, size_t whit_len) in whit2nmsg()
[all …]
|