| /dports/audio/baresip/baresip-0.5.8/modules/ctrl_tcp/ |
| H A D | tcp_netstring.c | 43 struct netstring *netstring = arg; in netstring_send_handler() local
90 struct netstring *netstring = arg; in netstring_recv_handler() local
106 netstring->mb->pos = netstring->mb->end; in netstring_recv_handler()
137 netstring->mb = mem_deref(netstring->mb); in netstring_recv_handler()
150 netstring->frameh(&mb, netstring->arg); in netstring_recv_handler()
155 if (netstring->mb->pos >= netstring->mb->end) { in netstring_recv_handler()
156 netstring->mb = mem_deref(netstring->mb); in netstring_recv_handler()
173 struct netstring *netstring = arg; in destructor() local
184 struct netstring *netstring; in netstring_insert() local
190 netstring = mem_zalloc(sizeof(*netstring), destructor); in netstring_insert()
[all …]
|
| H A D | tcp_netstring.h | 9 struct netstring;
14 int netstring_insert(struct netstring **netstringp, struct tcp_conn *tc,
16 int netstring_debug(struct re_printf *pf, const struct netstring *netstring);
|
| /dports/net/kamailio/kamailio-5.4.5/src/modules/janssonrpcc/ |
| H A D | netstring.c | 39 if(!netstring) return; in free_netstring()
40 if(netstring->buffer) pkg_free(netstring->buffer); in free_netstring()
41 pkg_free(netstring); in free_netstring()
55 if (*netstring == NULL) { in netstring_read_evbuffer()
105 CHECK_MALLOC(netstring); in netstring_read_evbuffer()
106 (*netstring)->read = 0; in netstring_read_evbuffer()
135 (*netstring)->string = (*netstring)->buffer; in netstring_read_evbuffer()
192 read_len = (*netstring)->start+(*netstring)->length-offset+1; in netstring_read_fd()
215 (*netstring)->string = (*netstring)->buffer + (*netstring)->start; in netstring_read_fd()
302 *netstring = NULL; in netstring_encode_new()
[all …]
|
| H A D | netstring.h | 35 void free_netstring(netstring_t* netstring);
37 int netstring_read_evbuffer(struct bufferevent *bev, netstring_t **netstring);
39 int netstring_read_fd(int fd, netstring_t **netstring);
46 size_t netstring_encode_new(char **netstring, char *data, size_t len);
|
| /dports/mail/py-postfix-mta-sts-resolver/postfix-mta-sts-resolver-1.1.1/tests/ |
| H A D | test_netstring.py | 2 import postfix_mta_sts_resolver.netstring as netstring namespace
9 assert reference == netstring.encode(sample)
30 with pytest.raises(netstring.BadLength):
31 list(netstring.decode(encoded))
36 list(netstring.decode(encoded))
39 stream_reader = netstring.StreamReader()
48 list(netstring.decode(encoded))
65 except netstring.WantRead:
80 with pytest.raises(netstring.WantRead):
83 with pytest.raises(netstring.WantRead):
[all …]
|
| H A D | test_responder.py | 9 from postfix_mta_sts_resolver import netstring
54 stream_reader = netstring.StreamReader()
63 except netstring.WantRead:
81 stream_reader = netstring.StreamReader()
91 except netstring.WantRead:
133 stream_reader = netstring.StreamReader()
144 except netstring.WantRead:
162 stream_reader = netstring.StreamReader()
169 except netstring.WantRead:
196 stream_reader = netstring.StreamReader()
[all …]
|
| H A D | test_responder_volatile.py | 8 from postfix_mta_sts_resolver import netstring
44 writer.write(netstring.encode(b'test blackhole.loc'))
56 writer.write(netstring.encode(b'test blackhole.loc'))
57 writer.write(netstring.encode(b'test blackhole.loc'))
58 writer.write(netstring.encode(b'test blackhole.loc'))
70 stream_reader = netstring.StreamReader()
77 except netstring.WantRead:
87 writer.write(netstring.encode(b'test good.loc'))
90 writer.write(netstring.encode(b'test good.loc'))
101 stream_reader = netstring.StreamReader()
[all …]
|
| H A D | test_responder_nosni.py | 8 from postfix_mta_sts_resolver import netstring
39 stream_reader = netstring.StreamReader()
42 writer.write(netstring.encode(request))
47 except netstring.WantRead:
|
| H A D | test_responder_strict.py | 8 from postfix_mta_sts_resolver import netstring
39 stream_reader = netstring.StreamReader()
42 writer.write(netstring.encode(request))
47 except netstring.WantRead:
|
| H A D | test_responder_expiration.py | 8 from postfix_mta_sts_resolver import netstring
28 stream_reader = netstring.StreamReader()
30 writer.write(netstring.encode(b'test ' + domain.encode('ascii')))
36 except netstring.WantRead:
|
| /dports/net/kamailio/kamailio-5.4.5/src/modules/jsonrpcc/ |
| H A D | netstring.c | 34 int netstring_read_fd(int fd, char **netstring) { in netstring_read_fd() argument
38 *netstring = NULL; in netstring_read_fd()
88 *netstring = buffer2; in netstring_read_fd()
168 size_t netstring_encode_new(char **netstring, char *data, size_t len) { in netstring_encode_new() argument
193 *netstring = ns; in netstring_encode_new()
|
| /dports/devel/p5-AnyEvent/AnyEvent-7.17/t/handle/ |
| H A D | 01_readline.t | 72 $wr_ae->push_write (netstring => "0:xx,,");
73 $wr_ae->push_write (netstring => "");
79 $rd_ae->push_read (netstring => sub { is ($_[1], "0:xx,,") });
80 $rd_ae->push_read (netstring => sub { is ($_[1], "") });
|
| /dports/textproc/p5-Text-Netstring/Text-Netstring-0.07/t/ |
| H A D | netstring.t | 3 # $Id: netstring.t,v 1.7 2006/11/20 18:17:11 james Exp $
27 # test 2; encode a string into a netstring
39 # test 3; verify a valid netstring
40 # the result of above should verify as a netstring
81 # test 5; decode a valid netstring
93 # test 6; decode another valid netstring
105 # test 7; decode an invalid netstring
224 # test 17; encode a string with newline into a netstring
236 # test 18; verify a valid netstring
237 # the result of above should verify as a netstring
[all …]
|
| /dports/net-mgmt/xymon-server/xymon-4.3.30/common/ |
| H A D | xymongrep.c | 59 static int netok(char *netstring, char *curnet, int testuntagged) in netok() argument
61 return ( (netstring == NULL) || in netok()
62 (curnet && netstring && (strcmp(curnet, netstring) == 0)) || in netok()
110 char *netstring = NULL; in main() local
202 if (p && strlen(p)) netstring = strdup(p); in main()
216 …if (netok(netstring, curnet, testuntagged) && downok(curname, nodownhosts) && knownhost(curname, h… in main()
|
| /dports/net-mgmt/xymon-client/xymon-4.3.30/common/ |
| H A D | xymongrep.c | 59 static int netok(char *netstring, char *curnet, int testuntagged) in netok() argument
61 return ( (netstring == NULL) || in netok()
62 (curnet && netstring && (strcmp(curnet, netstring) == 0)) || in netok()
110 char *netstring = NULL; in main() local
202 if (p && strlen(p)) netstring = strdup(p); in main()
216 …if (netok(netstring, curnet, testuntagged) && downok(curname, nodownhosts) && knownhost(curname, h… in main()
|
| /dports/mail/py-postfix-mta-sts-resolver/postfix-mta-sts-resolver-1.1.1/postfix_mta_sts_resolver/ |
| H A D | responder.py | 14 from . import netstring
173 return netstring.encode(b'NOTFOUND ')
220 return netstring.encode(b'NOTFOUND ')
227 return netstring.encode(resp.encode('utf-8'))
229 return netstring.encode(b'NOTFOUND ')
233 stream_reader = netstring.StreamReader(REQUEST_LIMIT)
260 except netstring.WantRead:
276 except netstring.ParseError:
|
| /dports/mail/p5-qpsmtpd/qpsmtpd-0.93/docs/ |
| H A D | writing.pod | 88 this byte string as a netstring. The client also encodes the envelope
89 sender address as a netstring, and encodes each envelope recipient address
90 as a netstring.
93 as a netstring, and sends the result.
123 Luckily it's easy to build a netstring without the help of the
145 First the beginning of the netstring of the full package
147 # (+ 2: the ":" and "," of the message's netstring)
150 ."$msglen:$headers" ### beginning of messages netstring
206 print $sock "," # end of messages netstring
208 ."," # end of netstring of
[all …]
|
| /dports/net-p2p/eiskaltdcpp-cli/eiskaltdcpp-2.2.10/json/jsonrpc-cpp/ |
| H A D | jsonrpc_tcpclient.cpp | 49 rep = netstring::encode(rep); in Send()
73 data = netstring::decode(data); in Recv()
75 catch(const netstring::NetstringException& e) in Recv()
|
| H A D | jsonrpc_udpclient.cpp | 49 rep = netstring::encode(rep); in Send()
74 data = netstring::decode(data); in Recv()
76 catch(const netstring::NetstringException& e) in Recv()
|
| /dports/net-p2p/eiskaltdcpp-gtk/eiskaltdcpp-2.2.10/json/jsonrpc-cpp/ |
| H A D | jsonrpc_tcpclient.cpp | 49 rep = netstring::encode(rep); in Send()
73 data = netstring::decode(data); in Recv()
75 catch(const netstring::NetstringException& e) in Recv()
|
| H A D | jsonrpc_udpclient.cpp | 49 rep = netstring::encode(rep); in Send()
74 data = netstring::decode(data); in Recv()
76 catch(const netstring::NetstringException& e) in Recv()
|
| /dports/net-p2p/eiskaltdcpp-lib/eiskaltdcpp-2.2.10/json/jsonrpc-cpp/ |
| H A D | jsonrpc_tcpclient.cpp | 49 rep = netstring::encode(rep); in Send()
73 data = netstring::decode(data); in Recv()
75 catch(const netstring::NetstringException& e) in Recv()
|
| /dports/net-p2p/eiskaltdcpp-data/eiskaltdcpp-2.2.10/json/jsonrpc-cpp/ |
| H A D | jsonrpc_tcpclient.cpp | 49 rep = netstring::encode(rep); in Send()
73 data = netstring::decode(data); in Recv()
75 catch(const netstring::NetstringException& e) in Recv()
|
| H A D | jsonrpc_udpclient.cpp | 49 rep = netstring::encode(rep); in Send()
74 data = netstring::decode(data); in Recv()
76 catch(const netstring::NetstringException& e) in Recv()
|
| /dports/net-p2p/eiskaltdcpp-daemon/eiskaltdcpp-2.2.10/json/jsonrpc-cpp/ |
| H A D | jsonrpc_tcpclient.cpp | 49 rep = netstring::encode(rep); in Send()
73 data = netstring::decode(data); in Recv()
75 catch(const netstring::NetstringException& e) in Recv()
|