| /third_party/node/test/parallel/ |
| D | test-dgram-multicast-set-interface.js | 7 const socket = dgram.createSocket('udp4'); constant
9 socket.bind(0);
10 socket.on('listening', common.mustCall(() => {
12 socket.setMulticastInterface('0.0.0.0');
14 socket.close();
19 const socket = dgram.createSocket('udp4'); constant
21 socket.bind(0);
22 socket.on('listening', common.mustCall(() => {
23 socket.close(common.mustCall(() => {
24 assert.throws(() => { socket.setMulticastInterface('0.0.0.0'); },
[all …]
|
| D | test-dgram-membership.js | 12 const socket = setup(); constant
13 socket.close(common.mustCall(() => {
15 socket.addMembership(multicastAddress);
26 const socket = setup(); constant
27 socket.close(common.mustCall(() => {
29 socket.dropMembership(multicastAddress);
40 const socket = setup(); constant
42 socket.addMembership();
48 socket.close();
53 const socket = setup(); constant
[all …]
|
| D | test-http2-socket-proxy.js | 27 const socket = stream.session.socket;
30 assert.ok(socket instanceof net.Socket);
32 assert.strictEqual(socket.writable, true);
33 assert.strictEqual(socket.readable, true);
34 assert.strictEqual(typeof socket.address(), 'object');
36 socket.setTimeout(987);
55 assert.throws(() => socket.destroy, errMsg);
56 assert.throws(() => socket.emit, errMsg);
57 assert.throws(() => socket.end, errMsg);
58 assert.throws(() => socket.pause, errMsg);
[all …]
|
| D | test-http-connect.js | 29 server.on('connect', common.mustCall((req, socket, firstBodyChunk) => {
34 assert.strictEqual(socket.listenerCount('close'), 0);
35 assert.strictEqual(socket.listenerCount('drain'), 0);
36 assert.strictEqual(socket.listenerCount('data'), 0);
37 assert.strictEqual(socket.listenerCount('end'), 1);
38 assert.strictEqual(socket.listenerCount('error'), 0);
39 assert.strictEqual(socket.listenerCount('timeout'), 0);
41 socket.write('HTTP/1.1 200 Connection established\r\n\r\n');
44 socket.on('data', (buf) => {
48 socket.on('end', common.mustCall(() => {
[all …]
|
| D | test-http-agent-timeout.js | 17 let socket; variable
20 socket = res.socket;
21 assert(socket);
23 socket.on('free', common.mustCall(() => {
26 assert.strictEqual(socket, res.socket);
27 assert(socket);
48 const socket = res.socket;
49 assert(socket);
51 socket.on('free', common.mustCall(() => {
52 socket.on('timeout', common.mustCall(() => {
[all …]
|
| D | test-wrap-js-stream-destroy.js | 14 const server = net.createServer((socket) => {
15 socket.on('error', common.mustNotCall());
16 socket.on('end', common.mustNotCall());
17 socket.on('close', common.mustCall());
18 socket.destroy();
28 const socket = new net.connect({
31 socket.on('error', common.mustNotCall());
32 socket.on('end', common.mustCall());
33 socket.on('close', common.mustCall());
46 streamWrap = new StreamWrap(socket);
[all …]
|
| D | test-tls-client-reject.js | 36 const server = tls.createServer(options, function(socket) { argument
37 socket.pipe(socket);
39 socket.on('end', () => socket.end());
46 const socket = tls.connect({
52 assert(!socket.authorized);
53 socket.on('data', common.mustCall((data) => {
57 socket.on('end', common.mustCall(() => {
60 socket.on('end', () => rejectUnauthorized());
62 socket.once('session', common.mustCall(() => {
64 socket.on('error', common.mustNotCall());
[all …]
|
| D | test-http2-compat-socket.js | 28 assert.ok(request.socket instanceof net.Socket);
29 assert.ok(response.socket instanceof net.Socket);
30 assert.strictEqual(request.socket, response.socket);
32 assert.ok(request.socket.readable);
34 assert.ok(request.socket.writable);
35 assert.strictEqual(request.socket.destroyed, false);
37 request.socket.setTimeout(987);
39 request.socket.setTimeout(0);
41 assert.throws(() => request.socket.read(), errMsg);
42 assert.throws(() => request.socket.write(), errMsg);
[all …]
|
| D | test-dgram-socket-buffer-size.js | 41 const socket = dgram.createSocket('udp4'); constant
44 socket.setSendBufferSize(8192);
64 socket.getSendBufferSize();
69 const socket = dgram.createSocket('udp4'); constant
75 socket.setRecvBufferSize(8192);
79 socket.getRecvBufferSize();
93 const socket = dgram.createSocket('udp4'); constant
95 socket.bind(common.mustCall(() => {
98 socket.setRecvBufferSize(badBufferSize);
102 socket.setSendBufferSize(badBufferSize);
[all …]
|
| D | test-dgram-send-error.js | 13 const socket = dgram.createSocket('udp4');
15 socket.on('message', common.mustNotCall('Should not receive any messages.'));
16 socket.bind(common.mustCall(() => {
17 socket[kStateSymbol].handle.lookup = function(address, callback) {
21 callback(socket);
23 return socket;
26 getSocket((socket) => {
27 socket.on('error', common.mustCall((err) => {
28 socket.close();
32 socket.send('foo', socket.address().port, 'localhost');
[all …]
|
| D | test-tls-connect-allow-half-open-option.js | 15 const socket = tls.connect({ lookup() {} }); constant
16 assert.strictEqual(socket.allowHalfOpen, false);
20 const socket = tls.connect({ allowHalfOpen: false, lookup() {} }); constant
21 assert.strictEqual(socket.allowHalfOpen, false);
27 }, common.mustCall((socket) => {
32 socket.setEncoding('utf8');
33 socket.on('data', (chunk) => {
37 socket.end(message);
42 socket.on('end', common.mustCall(() => {
48 const socket = tls.connect({ constant
[all …]
|
| D | test-net-pingpong.js | 38 function onSocket(socket) { argument
39 assert.strictEqual(socket.server, server);
47 socket.setNoDelay();
48 socket.timeout = 0;
50 socket.setEncoding('utf8');
51 socket.on('data', common.mustCall(function(data) {
55 assert.ok(socket.bufferSize >= 0 && socket.bufferSize <= 4);
57 assert.strictEqual(socket.writable, true);
58 assert.strictEqual(socket.readable, true);
62 socket.write('PONG', common.mustCall(function() {
[all …]
|
| D | test-dgram-address.js | 29 const socket = dgram.createSocket('udp4'); constant
31 socket.on('listening', common.mustCall(() => {
32 const address = socket.address();
39 socket.close();
42 socket.on('error', (err) => {
43 socket.close();
47 socket.bind(0, common.localhostIPv4);
52 const socket = dgram.createSocket('udp6'); constant
55 socket.on('listening', common.mustCall(() => {
56 const address = socket.address();
[all …]
|
| /third_party/python/Lib/test/ |
| D | test_socket.py | 10 import socket
55 if not hasattr(socket, 'IOCTL_VM_SOCKETS_GET_LOCAL_CID'):
59 r = fcntl.ioctl(f, socket.IOCTL_VM_SOCKETS_GET_LOCAL_CID, " ")
68 s = socket.socket(socket.PF_CAN, socket.SOCK_RAW, socket.CAN_RAW)
78 s = socket.socket(socket.PF_CAN, socket.SOCK_DGRAM, socket.CAN_ISOTP)
88 s = socket.socket(socket.PF_CAN, socket.SOCK_DGRAM, socket.CAN_J1939)
98 s = socket.socket(socket.PF_RDS, socket.SOCK_SEQPACKET, 0)
108 s = socket.socket(socket.AF_ALG, socket.SOCK_SEQPACKET, 0)
118 s = socket.socket(socket.AF_QIPCRTR, socket.SOCK_DGRAM, 0)
136 s = socket.socket(socket.AF_BLUETOOTH, socket.SOCK_STREAM, socket.BTPROTO_RFCOMM)
[all …]
|
| D | test_smtpd.py | 6 import socket
44 smtpd.socket = asyncore.socket = mock_socket
53 channel.socket.queue_recv(line)
73 asyncore.socket = smtpd.socket = socket
79 smtpd.socket = asyncore.socket = mock_socket
83 channel.socket.queue_recv(line)
166 asyncore.socket = smtpd.socket = socket
171 smtpd.socket = asyncore.socket = mock_socket
175 asyncore.socket = smtpd.socket = socket
180 self.assertEqual(server.socket.family, socket.AF_INET6)
[all …]
|
| D | test_timeout.py | 13 import socket
24 return socket.getaddrinfo(host, port, socket.AF_INET,
25 socket.SOCK_STREAM)[0][4]
32 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
148 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
202 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
250 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as serv:
259 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as serv:
269 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as serv:
281 self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
| /third_party/node/lib/ |
| D | _http_server.js | 160 constructor(type, socket) { argument
162 this.socket = socket;
191 DTRACE_HTTP_SERVER_RESPONSE(this.socket);
224 ServerResponse.prototype.assignSocket = function assignSocket(socket) { argument
225 assert(!socket._httpMessage);
226 socket._httpMessage = this;
227 socket.on('close', onServerResponseClose);
228 this.socket = socket;
229 this.emit('socket', socket);
233 ServerResponse.prototype.detachSocket = function detachSocket(socket) { argument
[all …]
|
| D | _http_client.js | 311 const oncreate = once((err, socket) => {
315 this.onSocket(socket);
337 DTRACE_HTTP_CLIENT_REQUEST(this, this.socket);
371 if (this.socket) {
372 _destroy(this, this.socket, err);
380 function _destroy(req, socket, err) { argument
384 if (socket && (!req.agent || req.socket)) {
385 socket.destroy(err);
387 if (socket) {
388 socket.emit('free');
[all …]
|
| D | _http_agent.js | 71 const socket = this;
73 socket.destroy();
74 socket.emit('agentRemove');
112 this.on('free', (socket, options) => {
121 if (!socket.writable) {
122 socket.destroy();
133 asyncResetHandle(socket);
134 setRequestSocket(this, req, socket);
138 setRequestSocket(this, req, socket);
148 const req = socket._httpMessage;
[all …]
|
| /third_party/gstreamer/gstplugins_base/tests/check/elements/ |
| D | multisocketsink.c | 388 GSocket *socket[4]; in GST_START_TEST() local
392 fail_unless (setup_handles (&socket[0], &socket[1])); in GST_START_TEST()
393 fail_unless (setup_handles (&socket[2], &socket[3])); in GST_START_TEST()
399 g_signal_emit_by_name (sink, "add", socket[0]); in GST_START_TEST()
429 fail_unless_read ("first client", socket[1], 4, "babe"); in GST_START_TEST()
430 fail_unless_read ("first client", socket[1], 8, "deadbeef"); in GST_START_TEST()
431 fail_unless_read ("first client", socket[1], 4, "f00d"); in GST_START_TEST()
435 g_signal_emit_by_name (sink, "add", socket[2]); in GST_START_TEST()
446 fail_unless_read ("first client", socket[1], 4, "deaf"); in GST_START_TEST()
448 fail_unless_read ("second client", socket[3], 4, "babe"); in GST_START_TEST()
[all …]
|
| /third_party/python/Tools/demo/ |
| D | mcast.py | 21 import socket
34 addrinfo = socket.getaddrinfo(group, None)[0]
36 s = socket.socket(addrinfo[0], socket.SOCK_DGRAM)
40 if addrinfo[0] == socket.AF_INET: # IPv4
41 s.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, ttl_bin)
43 s.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_MULTICAST_HOPS, ttl_bin)
53 addrinfo = socket.getaddrinfo(group, None)[0]
56 s = socket.socket(addrinfo[0], socket.SOCK_DGRAM)
60 s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
65 group_bin = socket.inet_pton(addrinfo[0], addrinfo[4][0])
[all …]
|
| /third_party/python/Lib/test/support/ |
| D | socket_helper.py | 3 import socket
15 def find_unused_port(family=socket.AF_INET, socktype=socket.SOCK_STREAM):
71 with socket.socket(family, socktype) as tempsock:
91 if sock.family == socket.AF_INET and sock.type == socket.SOCK_STREAM:
92 if hasattr(socket, 'SO_REUSEADDR'):
93 if sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR) == 1:
97 if hasattr(socket, 'SO_REUSEPORT'):
99 if sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT) == 1:
108 if hasattr(socket, 'SO_EXCLUSIVEADDRUSE'):
109 sock.setsockopt(socket.SOL_SOCKET, socket.SO_EXCLUSIVEADDRUSE, 1)
[all …]
|
| /third_party/NuttX/include/nuttx/net/ |
| D | net.h | 128 struct socket; /* Forward reference */
133 CODE int (*si_setup)(FAR struct socket *psock, int protocol);
134 CODE sockcaps_t (*si_sockcaps)(FAR struct socket *psock);
135 CODE void (*si_addref)(FAR struct socket *psock);
136 CODE int (*si_bind)(FAR struct socket *psock,
138 CODE int (*si_getsockname)(FAR struct socket *psock,
140 CODE int (*si_getpeername)(FAR struct socket *psock,
142 CODE int (*si_listen)(FAR struct socket *psock, int backlog);
143 CODE int (*si_connect)(FAR struct socket *psock,
145 CODE int (*si_accept)(FAR struct socket *psock,
[all …]
|
| /third_party/node/deps/npm/node_modules/https-proxy-agent/ |
| D | index.js | 76 var socket;
78 socket = tls.connect(proxy);
80 socket = net.connect(proxy);
91 var b = socket.read();
93 else socket.once('readable', read);
97 socket.removeListener('end', onend);
98 socket.removeListener('error', onerror);
99 socket.removeListener('close', onclose);
100 socket.removeListener('readable', read);
135 var sock = socket;
[all …]
|
| /third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/ |
| D | user_socketvar.h | 127 struct socket { struct
147 struct socket *so_head; /* (e) back pointer to listen socket */ argument
148 TAILQ_HEAD(, socket) so_incomp; /* (e) queue of partial unaccepted connections */
149 TAILQ_HEAD(, socket) so_comp; /* (e) queue of complete unaccepted connections */
150 TAILQ_ENTRY(socket) so_list; /* (e) list of unaccepted connections */
212 void (*so_upcall)(struct socket *, void *, int); argument
390 void soisconnecting(struct socket *so);
391 void soisdisconnecting(struct socket *so);
392 void soisconnected(struct socket *so);
393 struct socket * sonewconn(struct socket *head, int connstatus);
[all …]
|