| /developers/build/prebuilts/gradle/PermissionRequest/Application/src/main/java/com/example/android/permissionrequest/ |
| SimpleWebServer.java | 31 import java.net.Socket;
89 Log.e(TAG, "Error closing the server socket.", e);
98 Socket socket = mServerSocket.accept(); local
99 handle(socket);
100 socket.close();
112 * @param socket The client socket.
115 private void handle(Socket socket) throws IOException
[all...] |
| /developers/samples/android/content/webview/PermissionRequest/Application/src/main/java/com/example/android/permissionrequest/ |
| SimpleWebServer.java | 31 import java.net.Socket;
89 Log.e(TAG, "Error closing the server socket.", e);
98 Socket socket = mServerSocket.accept(); local
99 handle(socket);
100 socket.close();
112 * @param socket The client socket.
115 private void handle(Socket socket) throws IOException
[all...] |
| /development/samples/USB/AdbTest/src/com/android/adb/ |
| AdbDevice.java | 118 AdbSocket socket; local
121 socket = new AdbSocket(this, id);
122 mSockets.put(id, socket);
124 if (socket.open(destination)) {
125 return socket;
137 public void socketClosed(AdbSocket socket) {
139 mSockets.remove(socket.getId());
178 AdbSocket socket = getSocket(message.getArg1()); local
179 if (socket == null) {
180 log("ERROR socket not found")
[all...] |
| /external/apache-harmony/luni/src/test/api/unix/org/apache/harmony/luni/tests/java/net/ |
| UnixSocketTest.java | 27 import java.net.Socket;
35 * @tests java.net.Socket#getInputStream()
40 Socket pingClient = new Socket();
46 Socket worker = pingServer.accept();
91 Socket theSocket = new Socket();
110 Socket socket = new Socket("127.0.0.1", port, false) local
[all...] |
| /external/chromium_org/components/devtools_bridge/android/javatests/src/org/chromium/components/devtools_bridge/ |
| LocalTunnelBridgeTest.java | 70 LocalSocket socket = mServerSocket.accept(); local
71 String request = TestUtils.readAll(socket);
72 TestUtils.writeAndShutdown(socket, RESPONSE);
77 socket.close();
87 LocalSocket socket = mServerSocket.accept(); local
88 int firstByte = socket.getInputStream().read();
92 socket.close();
102 startBridge("jdwp-control"); // Android system socket will reject connection.
|
| SocketTunnelServerTest.java | 78 LocalSocket socket = connectToSocket(1); local
80 socket.close();
113 LocalSocket socket = connectToSocket(CONNECTION_ID); local
117 socket.close();
140 LocalSocket socket = connectToSocket(CONNECTION_ID); local
143 socket.shutdownOutput();
151 socket.close();
157 LocalSocket socket = connectToSocket(CONNECTION_ID); local
162 socket.getOutputStream().write(sample);
163 socket.getOutputStream().flush()
202 LocalSocket socket = connectToSocket(CONNECTION_ID); local
230 LocalSocket socket = connectToSocket(CONNECTION_ID); local
248 LocalSocket socket = connectToSocket(CONNECTION_ID); local
284 LocalSocket socket = connectToSocket(CONNECTION_ID); local
[all...] |
| /external/okhttp/android/main/java/com/squareup/okhttp/internal/ |
| Platform.java | 23 import java.net.Socket;
48 private static final OptionalMethod<Socket> SET_USE_SESSION_TICKETS =
49 new OptionalMethod<Socket>(null, "setUseSessionTickets", Boolean.TYPE);
51 private static final OptionalMethod<Socket> SET_HOSTNAME =
52 new OptionalMethod<Socket>(null, "setHostname", String.class);
54 private static final OptionalMethod<Socket> GET_ALPN_SELECTED_PROTOCOL =
55 new OptionalMethod<Socket>(byte[].class, "getAlpnSelectedProtocol");
57 private static final OptionalMethod<Socket> SET_ALPN_PROTOCOLS =
58 new OptionalMethod<Socket>(null, "setAlpnProtocols", byte[].class );
60 private static final OptionalMethod<Socket> GET_NPN_SELECTED_PROTOCOL
[all...] |
| /external/smack/src/org/jivesoftware/smackx/bytestreams/socks5/ |
| Socks5Proxy.java | 21 import java.net.Socket;
80 /* server socket to accept SOCKS5 connections */
84 private final Map<String, Socket> connectionMap = new ConcurrentHashMap<String, Socket>();
261 * Returns the socket for the given digest. A socket will be returned if the given digest has
266 * @return socket or null if there is no socket for the given digest
268 protected Socket getSocket(String digest) {
315 Socket socket = null; local
[all...] |
| /frameworks/base/core/java/android/net/ |
| SntpClient.java | 73 DatagramSocket socket = null; local
75 socket = new DatagramSocket();
76 socket.setSoTimeout(timeout);
91 socket.send(request);
95 socket.receive(response);
125 if (socket != null) {
126 socket.close();
|
| /frameworks/base/tests/BandwidthTests/src/com/android/tests/bandwidthenforcement/ |
| BandwidthEnforcementTestService.java | 155 final DatagramSocket socket = new DatagramSocket(); local
157 socket.setSoTimeout(10000);
162 socket.send(queryPacket);
166 socket.receive(replyPacket);
170 socket.close();
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/net/ |
| DatagramPacketTest.java | 134 DatagramSocket socket = new DatagramSocket(0, localhost); local
135 final int port = socket.getLocalPort();
137 socket.setSoTimeout(3000);
140 socket.send(packet);
141 socket.receive(packet);
142 socket.close();
230 assertEquals("Socket address not set correctly (1)", theAddress,
232 assertEquals("Socket address not set correctly (2)", theAddress,
271 assertEquals("Socket address not set correctly (1)", theAddress,
273 assertEquals("Socket address not set correctly (2)", theAddress
[all...] |
| /libcore/luni/src/test/java/libcore/java/net/ |
| OldAndroidDatagramTest.java | 42 DatagramSocket socket; field in class:OldAndroidDatagramTest.Reflector
59 socket.receive(packet);
74 socket.send(packet);
81 socket.close();
91 socket = new DatagramSocket(port, address);
121 DatagramSocket socket = null; local
131 socket = new DatagramSocket(2345, InetAddress.getLocalHost());
141 socket.send(packet);
150 socket.receive(packet);
161 if (socket != null)
[all...] |
| OldUnixSocketTest.java | 27 import java.net.Socket;
36 Socket pingClient = new Socket();
42 Socket worker = pingServer.accept();
87 Socket theSocket = new Socket();
106 Socket socket = new Socket("127.0.0.1", port, false); local
107 OutputStream o = socket.getOutputStream()
[all...] |
| /packages/apps/Nfc/src/com/android/nfc/snep/ |
| SnepClient.java | 98 throw new IOException("Socket not connected.");
117 throw new IOException("Socket not connected.");
135 throw new IOException("Socket already in use.");
140 LlcpSocket socket = null; local
143 if (DBG) Log.d(TAG, "about to create socket");
145 socket = NfcService.getInstance().createLlcpSocket(0, mMiu, mRwSize, 1024);
146 if (socket == null) {
147 throw new IOException("Could not connect to socket.");
151 socket.connectToService(mServiceName);
154 socket.connectToSap(mPort)
[all...] |
| /libcore/luni/src/main/java/java/nio/ |
| DatagramChannelImpl.java | 58 private DatagramSocket socket; field in class:DatagramChannelImpl
72 // whether the socket is bound
83 fd = IoBridge.socket(false);
97 * Getting the internal DatagramSocket If we have not the socket, we create
101 synchronized public DatagramSocket socket() { method in class:DatagramChannelImpl
102 if (socket == null) {
103 socket = new DatagramSocketAdapter(new PlainDatagramSocketImpl(fd, localPort), this);
105 return socket;
110 * some or all of the bound state has been left to the OS to decide, or when the Socket handled
114 * if the associated socket (if present) needs to be update
[all...] |
| /external/chromium_org/remoting/webapp/js_proto/ |
| chrome_proto.js | 617 chrome.socket = {};
620 chrome.socket.CreateInfo = function() {
628 * @param {function(chrome.socket.CreateInfo):void} callback
630 chrome.socket.create = function(socketType, options, callback) {};
638 chrome.socket.connect =
642 chrome.socket.WriteInfo = function() {
650 * @param {function(chrome.socket.WriteInfo):void} callback
652 chrome.socket.write = function(socketId, data, callback) {};
655 chrome.socket.ReadInfo = function() {
665 * @param {function(chrome.socket.ReadInfo):void} callbac
[all...] |
| /external/mockwebserver/src/main/java/com/google/mockwebserver/ |
| MockWebServer.java | 32 import java.net.Socket;
85 private final Map<Socket, Boolean> openClientSockets = new ConcurrentHashMap<Socket, Boolean>();
213 // The acceptExecutor handles the Socket.accept() and hands each request off to the
239 logger.log(Level.WARNING, "MockWebServer server socket close failed", e);
241 for (Iterator<Socket> s = openClientSockets.keySet().iterator(); s.hasNext(); ) {
246 logger.log(Level.WARNING, "MockWebServer socket close failed", e);
263 Socket socket;
265 socket = serverSocket.accept()
410 SSLSocket socket = (SSLSocket) sslSocketFactory.createSocket( local
[all...] |
| /packages/apps/Nfc/src/com/android/nfc/echoserver/ |
| EchoServer.java | 180 private void handleClient(LlcpSocket socket) {
187 int size = socket.receive(dataUnit);
205 if (DBG) Log.d(TAG, "about create LLCP service socket");
213 if (DBG) Log.d(TAG, "failed to create LLCP service socket");
216 if (DBG) Log.d(TAG, "created LLCP service socket");
279 LlcpConnectionlessSocket socket; field in class:EchoServer.ConnectionlessServerThread
292 if (DBG) Log.d(TAG, "about create LLCP connectionless socket");
294 socket = mService.createLlcpConnectionLessSocket(
296 if (socket == null) {
297 if (DBG) Log.d(TAG, "failed to create LLCP connectionless socket");
[all...] |
| /packages/experimental/RpcPerformance/src/com/android/rpc_performance/ |
| ProviderPerfActivity.java | 498 LocalSocket socket = null; local
500 socket = new LocalSocket();
501 Log.v(TAG, "Connecting to socket...");
502 socket.connect(new LocalSocketAddress(MiscService.SOCKET_NAME));
503 Log.v(TAG, "Connected to socket.");
504 InputStream is = socket.getInputStream();
505 OutputStream os = socket.getOutputStream();
530 if (socket != null) {
531 try { socket.close(); } catch (IOException e) {}
|
| /sdk/eclipse/plugins/com.android.ide.eclipse.gldebugger/src/com/android/ide/eclipse/gltrace/ |
| CollectTraceAction.java | 57 import java.net.Socket;
63 /** Abstract Unix Domain Socket Name used by the gltrace device code. */
66 /** Local port that is forwarded to the device's {@link #GLTRACE_UDS} socket. */
234 Socket socket = new Socket(); local
238 socket.connect(new java.net.InetSocketAddress("127.0.0.1", port)); //$NON-NLS-1$
239 socket.setTcpNoDelay(true);
240 traceDataStream = new DataInputStream(socket.getInputStream());
241 traceCommandsStream = new DataOutputStream(socket.getOutputStream())
[all...] |
| /cts/suite/audio_quality/test_description/ |
| processing_main.py | 20 import socket namespace
151 if justRead == 0: # socket closed
208 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
209 s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
215 # close the server socket to allow other instance to run
|
| /development/apps/Development/src/com/android/development/ |
| LogViewer.java | 24 import java.net.Socket;
77 final Socket socket; field in class:LogViewer.LogReader
85 this.socket = new Socket("127.0.0.1", 5040);
86 this.in = new DataInputStream(this.socket.getInputStream());
88 this.socket.getOutputStream().write('\n');
89 this.socket.getOutputStream().write('\n');
|
| /external/antlr/antlr-3.4/runtime/Python/tests/ |
| t059debug.py | 9 import socket namespace
21 # create listening socket
26 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
29 except socket.error, exc:
65 except socket.timeout:
67 except socket.error, exc:
|
| /external/apache-http/src/org/apache/http/impl/conn/ |
| DefaultClientConnection.java | 36 import java.net.Socket;
78 /** The unconnected socket */
79 private volatile Socket socket; field in class:DefaultClientConnection
108 public final Socket getSocket() {
109 return this.socket;
113 public void opening(Socket sock, HttpHost target) throws IOException {
115 this.socket = sock;
118 // Check for shutdown after assigning socket, so that
134 bind(this.socket, params)
[all...] |
| /external/chromium_org/content/browser/renderer_host/p2p/ |
| socket_host_tcp_server_unittest.cc | 33 void AddIncoming(net::StreamSocket* socket) {
36 accept_socket_->reset(socket);
46 incoming_sockets_.push_back(socket);
61 virtual int Accept(scoped_ptr<net::StreamSocket>* socket,
63 DCHECK(socket); variable
65 socket->reset(incoming_sockets_.front());
69 accept_socket_ = socket;
|
