| /sdk/hierarchyviewer/src/com/android/hierarchyviewer/scene/ |
| ProfilesLoader.java | 24 import java.net.Socket;
38 Socket socket = null; local
43 socket = new Socket();
44 socket.connect(new InetSocketAddress("127.0.0.1",
47 out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
48 in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
72 if (socket != null) {
73 socket.close()
[all...] |
| WindowsLoader.java | 29 import java.net.Socket;
34 Socket socket = null; local
42 socket = new Socket();
43 socket.connect(new InetSocketAddress("127.0.0.1",
46 out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
47 in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
86 if (socket != null) {
87 socket.close()
[all...] |
| /external/apache-harmony/nio/src/test/java/common/org/apache/harmony/nio/tests/java/nio/channels/ |
| ServerSocketChannelTest.java | 25 import java.net.Socket;
118 // Test for socket()
122 * Test method for 'java.nio.channels.ServerSocketChannel.socket()'
127 ServerSocket s1 = this.serverChannel.socket();
130 ServerSocket s2 = this.serverChannel.socket();
134 // socket close makes the channel close
143 ServerSocket s1 = this.serverChannel.socket();
146 ServerSocket s2 = this.serverChannel.socket();
150 // socket close makes the channel close
160 ServerSocket s1 = this.serverChannel.socket();
346 Socket socket = serverChannel.accept().socket(); local
390 Socket socket = serverChannel.accept().socket(); local
435 Socket socket = serverChannel.accept().socket(); local
457 Socket socket = serverChannel.accept().socket(); local
469 Socket socket; field in class:ServerSocketChannelTest.WriteSocketThread
500 Socket socket = serverChannel.accept().socket(); local
[all...] |
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| tcpport.h | 70 virtual int SetOption(talk_base::Socket::Option opt, int value);
79 // Handles sending using the local TCP socket.
84 void OnNewConnection(talk_base::AsyncPacketSocket* socket,
90 talk_base::AsyncPacketSocket* socket; member in struct:cricket::TCPPort::Incoming
96 // Receives packet signal from the local TCP Socket.
97 void OnReadPacket(talk_base::AsyncPacketSocket* socket,
101 void OnAddresReady(talk_base::AsyncPacketSocket* socket,
116 // Connection is outgoing unless socket is specified
118 talk_base::AsyncPacketSocket* socket = 0);
124 talk_base::AsyncPacketSocket* socket() { return socket_; function in class:cricket::TCPConnection
[all...] |
| /external/chromium/third_party/libjingle/source/talk/base/ |
| asynctcpsocket.h | 43 explicit AsyncTCPSocket(AsyncSocket* socket, bool listen);
52 virtual Socket::ConnState GetState() const;
53 virtual int GetOption(Socket::Option opt, int* value);
54 virtual int SetOption(Socket::Option opt, int value);
65 // Called by the underlying socket
66 void OnConnectEvent(AsyncSocket* socket);
67 void OnReadEvent(AsyncSocket* socket);
68 void OnWriteEvent(AsyncSocket* socket);
69 void OnCloseEvent(AsyncSocket* socket, int error);
|
| openssladapter.h | 48 OpenSSLAdapter(AsyncSocket* socket);
56 // Note that the socket returns ST_CONNECTING while SSL is being negotiated.
60 virtual void OnConnectEvent(AsyncSocket* socket);
61 virtual void OnReadEvent(AsyncSocket* socket);
62 virtual void OnWriteEvent(AsyncSocket* socket);
63 virtual void OnCloseEvent(AsyncSocket* socket, int err);
91 // If true, socket will retain SSL configuration after Close.
|
| autodetectproxy.h | 76 void OnConnectEvent(AsyncSocket * socket);
77 void OnReadEvent(AsyncSocket * socket);
78 void OnCloseEvent(AsyncSocket * socket, int error);
|
| asyncsocket.h | 33 #include "talk/base/socket.h"
37 // TODO: Remove Socket and rename AsyncSocket to Socket.
39 // Provides the ability to perform socket I/O asynchronously.
40 class AsyncSocket : public Socket {
55 // The adapted socket may explicitly be NULL, and later assigned using Attach.
59 explicit AsyncSocketAdapter(AsyncSocket* socket);
61 void Attach(AsyncSocket* socket);
115 virtual void OnConnectEvent(AsyncSocket* socket) {
118 virtual void OnReadEvent(AsyncSocket* socket) {
[all...] |
| /bionic/libc/unistd/ |
| socketcalls.c | 29 #include <sys/socket.h>
54 int socket(int domain, int type, int protocol) function
159 ssize_t sendto(int socket, const void *message, size_t length, int flags,
164 t[0] = (unsigned long) socket;
176 ssize_t recvfrom(int socket, void *buffer, size_t length, unsigned int flags,
181 t[0] = (unsigned long) socket;
193 int shutdown(int socket, int how)
197 t[0] = (unsigned long) socket;
235 int sendmsg (int socket, const struct msghdr *message, unsigned int flags)
239 t[0] = (unsigned long) socket;
[all...] |
| /system/bluetooth/tools/ |
| sock_shutdown_bug_tcp.c | 20 #include <sys/socket.h>
34 fd = socket(PF_INET, SOCK_STREAM, 0);
52 fd = socket(PF_INET, SOCK_STREAM, 0);
|
| /system/core/nexus/ |
| TiwlanEventListener.cpp | 21 #include <sys/socket.h>
28 TiwlanEventListener::TiwlanEventListener(int socket) :
29 SocketListener(socket, false) {
|
| /bionic/libc/bionic/ |
| if_indextoname.c | 33 #include <sys/socket.h>
52 if ((ctl_sock = socket(AF_INET, SOCK_DGRAM, 0)) >= 0) {
|
| if_nametoindex.c | 33 #include <sys/socket.h>
51 if ((ctl_sock = socket(AF_INET, SOCK_DGRAM, 0)) >= 0) {
|
| /external/apache-harmony/support/src/test/java/tests/support/ |
| Support_HttpSocket.java | 23 import java.net.Socket;
30 private final Socket instance;
34 Support_HttpSocket(Socket socket) {
35 instance = socket;
|
| /external/chromium/net/socket/ |
| tcp_server_socket_libevent.h | 13 #include "net/socket/server_socket.h"
30 virtual int Accept(scoped_ptr<ClientSocket>* socket,
38 int AcceptInternal(scoped_ptr<ClientSocket>* socket);
|
| /external/dbus/cmake/modules/ |
| CheckForAbstractSockets.c | 4 #include <sys/socket.h>
12 listen_fd = socket (PF_UNIX, SOCK_STREAM, 0);
16 fprintf (stderr, "socket() failed: %s\n", strerror (errno));
22 strcpy (addr.sun_path, "X/tmp/dbus-fake-socket-path-used-in-configure-test");
27 fprintf (stderr, "Abstract socket namespace bind() failed: %s\n",
|
| /external/libpcap/lbl/ |
| os-ultrix4.h | 38 int socket(int, int, int);
|
| /external/quake/quake/src/WinQuake/ |
| net_mp.cpp | 35 static int net_acceptsocket = -1; // socket for fielding new connections
100 Sys_Error("MPATH_Init: Unable to open control socket\n");
136 Sys_Error ("MPATH_Listen: Unable to open accept socket\n");
155 if ((newsocket = socket (PF_INET, SOCK_DGRAM, IPPROTO_UDP)) == -1)
176 int MPATH_CloseSocket (int socket)
178 if (socket == net_broadcastsocket)
180 return closesocket (socket);
243 int MPATH_Connect (int socket, struct qsockaddr *addr)
264 int MPATH_Read (int socket, byte *buf, int len, struct qsockaddr *addr)
269 ret = recvfrom (socket, buf, len, 0, (struct sockaddr *)addr, &addrlen);
[all...] |
| /external/tcpdump/lbl/ |
| os-ultrix4.h | 38 int socket(int, int, int);
|
| /libcore/luni/src/main/java/javax/net/ssl/ |
| X509KeyManager.java | 20 import java.net.Socket;
39 * @param socket
40 * the socket for the connection, or {@code null} if
41 * the alias selected does not depend on a specific socket.
46 Socket socket);
57 * @param socket
58 * the socket for the connection, or {@code null} if
59 * the alias selected does not depend on a specific socket.
64 Socket socket)
[all...] |
| /libcore/luni/src/test/java/libcore/javax/net/ |
| ServerSocketFactoryTest.java | 25 import java.net.Socket;
67 Socket s = serverSocket.accept();
75 Socket socket = new Socket(InetAddress.getLocalHost(), serverSocket.getLocalPort()); local
79 InputStream in = socket.getInputStream();
83 socket.close();
93 List<Socket> backlog = new ArrayList<Socket>();
98 Socket socket = new Socket() local
[all...] |
| /system/core/adb/ |
| jdwp_service.c | 12 when adbd starts, it creates a unix server socket
45 - it attaches the first socket in the pair to a local socket
46 which is itself attached to the transport's remote socket:
49 - it sends the file descriptor of the second socket directly
60 then, the JDWP thread uses this new socket descriptor as its
84 due to the way adb works, this doesn't need a special socket
85 type or fancy handling of socket termination if either the debugger
94 ** for each JDWP process, we record its pid and its connected socket
101 #include <sys/socket.h
109 int socket; member in struct:JdwpProcess
552 asocket socket; member in struct:__anon30576
626 asocket socket; member in struct:JdwpTracker
[all...] |
| /cts/tests/tests/net/src/android/net/cts/ |
| LocalSocketTest.java | 112 // create client and server socket
174 //close client socket
183 //close server socket
286 LocalSocket socket = new LocalSocket(); local
289 assertFalse(socket.isBound());
290 socket.bind(addr);
291 assertTrue(socket.isBound());
292 assertEquals(addr, socket.getLocalSocketAddress());
294 String str = socket.toString();
297 socket.setReceiveBufferSize(1999)
[all...] |
| /external/chromium/net/http/ |
| http_proxy_client_socket.cc | 22 #include "net/socket/client_socket_handle.h"
52 net_log_(transport_socket->socket()->NetLog()) {
100 DCHECK(transport_->socket());
124 transport_->socket()->Disconnect();
133 return next_state_ == STATE_DONE && transport_->socket()->IsConnected();
138 transport_->socket()->IsConnectedAndIdle();
146 if (transport_.get() && transport_->socket()) {
147 transport_->socket()->SetSubresourceSpeculation();
154 if (transport_.get() && transport_->socket()) {
155 transport_->socket()->SetOmniboxSpeculation()
[all...] |
| /libcore/luni/src/test/java/libcore/java/net/ |
| SocketTest.java | 26 import java.net.Socket;
40 Socket s = new Socket();
42 // Closing a closed socket does nothing.
52 Socket s = new Socket();
60 // Now close the socket...
73 new Socket("localhost", 80);
92 ssc.socket().bind(listenAddr, 0);
93 ServerSocket ss = ssc.socket();
213 Socket socket = new Socket("localhost", server.port); local
235 Socket socket = new Socket("localhost", server.port); local
[all...] |
