| /libcore/luni/src/main/java/java/nio/ |
| ServerSocketChannelImpl.java | 24 import java.net.Socket;
43 private final ServerSocketAdapter socket; field in class:ServerSocketChannelImpl
52 this.socket = new ServerSocketAdapter(this);
53 this.impl = socket.getImpl$();
56 @Override public ServerSocket socket() { method in class:ServerSocketChannelImpl
57 return socket;
68 // Create an empty socket channel. This will be populated by ServerSocketAdapter.accept.
74 socket.implAccept(result);
79 // Otherwise, this is a non-blocking socket and there's nothing ready, so we'll
84 end(result.socket().isConnected())
[all...] |
| DatagramChannelImpl.java | 53 private DatagramSocket socket = null; field in class:DatagramChannelImpl
64 // whether the socket is bound
75 fd = IoBridge.socket(false);
89 * Getting the internal DatagramSocket If we have not the socket, we create
93 synchronized public DatagramSocket socket() { method in class:DatagramChannelImpl
94 if (socket == null) {
95 socket = new DatagramSocketAdapter(new PlainDatagramSocketImpl(fd, localPort), this);
97 return socket;
153 if (socket != null) {
154 socket.disconnect()
[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...] |
| /external/mockwebserver/src/main/java/com/google/mockwebserver/ |
| MockWebServer.java | 32 import java.net.Socket;
68 private final Map<Socket, Boolean> openClientSockets = new ConcurrentHashMap<Socket, Boolean>();
210 logger.log(Level.WARNING, "MockWebServer server socket close failed", e);
212 for (Iterator<Socket> s = openClientSockets.keySet().iterator(); s.hasNext(); ) {
217 logger.log(Level.WARNING, "MockWebServer socket close failed", e);
229 Socket socket;
231 socket = serverSocket.accept();
237 dispatchBookkeepingRequest(0, socket);
369 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;
73 /** The unconnected socket */
74 private volatile Socket socket; field in class:DefaultClientConnection
103 public final Socket getSocket() {
104 return this.socket;
108 public void opening(Socket sock, HttpHost target) throws IOException {
110 this.socket = sock;
113 // Check for shutdown after assigning socket, so that
129 bind(this.socket, params)
[all...] |
| /external/chromium_org/chrome/browser/extensions/api/bluetooth/ |
| bluetooth_apitest.cc | 500 scoped_refptr<device::MockBluetoothSocket> socket = local
505 extension->id(), "1234", device1_.get(), socket);
|
| /external/chromium_org/chrome/test/functional/perf/ |
| endure_result_parser.py | 40 import socket namespace
508 except (urllib2.URLError, socket.error, IOError, OSError), e:
|
| /external/chromium_org/chrome/test/pyautolib/ |
| pyauto_utils.py | 11 import socket namespace
215 except (socket.gaierror, socket.error):
|
| /external/chromium_org/content/browser/renderer_host/p2p/ |
| socket_dispatcher_host.cc | 190 LOG(ERROR) << "Received P2PHostMsg_CreateSocket for socket "
195 scoped_ptr<P2PSocketHost> socket(P2PSocketHost::Create(
198 if (!socket) {
203 if (socket->Init(local_address, remote_address)) {
204 sockets_[socket_id] = socket.release();
211 P2PSocketHost* socket = LookupSocket(listen_socket_id); local
212 if (!socket) {
218 socket->AcceptIncomingTcpConnection(remote_address, connected_socket_id);
229 P2PSocketHost* socket = LookupSocket(socket_id); local
230 if (!socket) {
[all...] |
| /external/chromium_org/device/bluetooth/ |
| bluetooth_profile_chromeos_unittest.cc | 96 scoped_refptr<BluetoothSocket> socket) {
99 last_socket_ = socket;
146 // socket instance.
167 // Take the ownership of the socket for the remainder of the test and set
169 scoped_refptr<BluetoothSocket> socket = last_socket_; local
179 // Read data from the socket; since no data should be waiting, this should
182 success = socket->Receive(read_buffer.get());
186 EXPECT_EQ("", socket->GetLastErrorMessage());
188 // Write data to the socket; the data should be consumed and no bytes should
192 success = socket->Send(write_buffer.get())
295 scoped_refptr<BluetoothSocket> socket = last_socket_; local
[all...] |
| /external/chromium_org/media/tools/layout_tests/ |
| layouttest_analyzer_helpers.py | 15 import socket namespace
482 except (socket.gaierror, socket.error, socket.herror), ex:
|
| /external/chromium_org/native_client_sdk/src/build_tools/sdk_tools/third_party/fancy_urllib/ |
| __init__.py | 18 import socket namespace
93 raise socket.error, "Tunnel connection failed: %d %s" % (
137 # change this to socket.create_connection.
160 ssl = socket.ssl(self.sock,
168 # Here to end of _create_connection copied wholesale from Python 2.6"s socket.py
173 """Connect to *address* and return the socket object.
176 port)``) and return the socket object. Passing the optional
177 *timeout* parameter will set the timeout on the socket instance
185 for res in socket.getaddrinfo(host, port, 0, socket.SOCK_STREAM)
[all...] |
| /external/chromium_org/native_client_sdk/src/tools/ |
| httpd.py | 13 import socket namespace
260 except socket.error as e:
|
| /external/chromium_org/remoting/jingle_glue/ |
| xmpp_signal_strategy.cc | 18 #include "net/socket/client_socket_factory.h"
88 buzz::AsyncSocket* socket = new jingle_glue::ChromeAsyncSocket( local
94 settings, std::string(), socket, CreatePreXmppAuth(settings));
|
| /external/chromium_org/third_party/WebKit/Source/devtools/front_end/ |
| inspector.js | 243 // Do not create socket for the worker front-end.
258 WebInspector.socket = new WebSocket(ws);
259 WebInspector.socket.onmessage = function(message) { InspectorBackend.dispatch(message.data); }
260 WebInspector.socket.onerror = function(error) { console.error(error); }
261 WebInspector.socket.onopen = function() {
262 InspectorFrontendHost.sendMessageToBackend = WebInspector.socket.send.bind(WebInspector.socket);
265 WebInspector.socket.onclose = function() {
266 if (!WebInspector.socket._detachReason)
285 if (WebInspector.socket)
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/examples/peerconnection/server/ |
| data_socket.h | 38 #include <sys/socket.h>
55 explicit SocketBase(int socket) : socket_(socket) { }
58 int socket() const { return socket_; } function in class:SocketBase
68 // Represents an HTTP server socket.
78 explicit DataSocket(int socket)
79 : SocketBase(socket),
133 // Clears all held state and prepares the socket for receiving a new request.
158 // The server socket. Accepts connections and generates DataSocket instances
|
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| tcpport.cc | 53 // Treat failure to create or bind a TCP socket as fatal. This
59 LOG_J(LS_ERROR, this) << "TCP socket creation failed.";
72 delete it->socket;
103 if (talk_base::AsyncPacketSocket* socket =
105 socket->SignalReadPacket.disconnect(this);
106 conn = new TCPConnection(this, address, socket);
116 // If socket isn't bound yet the address will be added in
117 // OnAddressReady(). Socket may be in the CLOSED state if Listen()
118 // failed, we still want ot add the socket address.
140 talk_base::AsyncPacketSocket * socket = NULL local
206 talk_base::AsyncPacketSocket* socket = NULL; local
[all...] |
