| /libcore/benchmarks/src/benchmarks/regression/ |
| SSLLoopbackBenchmark.java | 41 SSLSocket[] sockets = TestSSLSocketPair.connect(context, null, null); local
43 sockets[0].close();
44 sockets[1].close();
|
| /bootable/recovery/minadbd/ |
| fuse_adb_provider_test.cpp | 31 int sockets[2]; local
33 ASSERT_EQ(0, socketpair(AF_UNIX, SOCK_STREAM, 0, sockets));
34 data.sfd = sockets[0];
36 int host_socket = sockets[1];
70 close(sockets[0]);
71 close(sockets[1]);
76 int sockets[2]; local
78 ASSERT_EQ(0, socketpair(AF_UNIX, SOCK_STREAM, 0, sockets));
79 data.sfd = sockets[0];
81 ASSERT_EQ(0, close(sockets[1]))
[all...] |
| /frameworks/native/libs/gui/ |
| BitTube.cpp | 71 int sockets[2]; local
72 if (socketpair(AF_UNIX, SOCK_SEQPACKET, 0, sockets) == 0) {
74 setsockopt(sockets[0], SOL_SOCKET, SO_RCVBUF, &rcvbuf, sizeof(rcvbuf));
75 setsockopt(sockets[1], SOL_SOCKET, SO_SNDBUF, &sndbuf, sizeof(sndbuf));
77 setsockopt(sockets[0], SOL_SOCKET, SO_SNDBUF, &size, sizeof(size));
78 setsockopt(sockets[1], SOL_SOCKET, SO_RCVBUF, &size, sizeof(size));
79 fcntl(sockets[0], F_SETFL, O_NONBLOCK);
80 fcntl(sockets[1], F_SETFL, O_NONBLOCK);
81 mReceiveFd = sockets[0];
82 mSendFd = sockets[1]
[all...] |
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| TestSSLSocketPair.java | 60 SSLSocket[] sockets = connect(c, null, null); local
61 return new TestSSLSocketPair(c, sockets[0], sockets[1]);
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/ |
| ObexServerSockets.java | 33 * Create an instance using {@link #create()}, which will block until the sockets have been created
56 /* The wrapped sockets */
147 if (D) Log.d(STAG, "Succeed to create listening sockets ");
148 ObexServerSockets sockets = new ObexServerSockets(validator, rfcommSocket, l2capSocket); local
149 sockets.startAccept();
150 return sockets;
368 // sockets - and that is true, but it closes the l2cap connections, and
369 // therefore it implicitly also closes the accepted sockets...
|
| /libcore/luni/src/test/java/libcore/java/io/ |
| InterruptedStreamTest.java | 47 private Socket[] sockets; field in class:InterruptedStreamTest
57 if (sockets != null) {
58 sockets[0].close();
59 sockets[1].close();
98 sockets = newSocketChannelPair();
99 testInterruptReadableChannel(sockets[0].getChannel());
103 sockets = newSocketChannelPair();
104 testInterruptWritableChannel(sockets[0].getChannel());
108 * Returns a pair of connected sockets backed by NIO socket channels.
|
| /system/core/init/ |
| init.h | 117 struct socketinfo *sockets; member in struct:service
|
| /frameworks/native/libs/input/ |
| InputTransport.cpp | 122 int sockets[2]; local
123 if (socketpair(AF_UNIX, SOCK_SEQPACKET, 0, sockets)) {
133 setsockopt(sockets[0], SOL_SOCKET, SO_SNDBUF, &bufferSize, sizeof(bufferSize));
134 setsockopt(sockets[0], SOL_SOCKET, SO_RCVBUF, &bufferSize, sizeof(bufferSize));
135 setsockopt(sockets[1], SOL_SOCKET, SO_SNDBUF, &bufferSize, sizeof(bufferSize));
136 setsockopt(sockets[1], SOL_SOCKET, SO_RCVBUF, &bufferSize, sizeof(bufferSize));
140 outServerChannel = new InputChannel(serverChannelName, sockets[0]);
144 outClientChannel = new InputChannel(clientChannelName, sockets[1]);
[all...] |
| /packages/apps/Bluetooth/src/com/android/bluetooth/map/ |
| BluetoothMapMasInstance.java | 418 ObexServerSockets sockets = mServerSockets; local
419 if (sockets != null) {
420 sockets.shutdown(block);
|
| /external/openssh/ |
| ssh-agent.c | 110 SocketEntry *sockets = NULL; variable
919 if (sockets[i].type == AUTH_UNUSED) {
920 sockets[i].fd = fd;
921 if ((sockets[i].input = sshbuf_new()) == NULL)
923 if ((sockets[i].output = sshbuf_new()) == NULL)
925 if ((sockets[i].request = sshbuf_new()) == NULL)
927 sockets[i].type = type;
932 sockets = xrealloc(sockets, new_alloc, sizeof(sockets[0]))
[all...] |
| /external/libvncserver/x11vnc/ |
| sslhelper.c | 2929 static int sockets[HPSIZE], first = 1; local
[all...] |
| /libcore/luni/src/test/java/libcore/javax/net/ssl/ |
| SSLSocketTest.java | 1663 final Socket[] sockets = new Socket[2]; local
[all...] |
