| /external/antlr/antlr-3.4/runtime/CSharp3/Sources/Antlr3.Runtime.Debug/ |
| DebugEventSocketProxy.cs | 40 using Socket = System.Net.Sockets.Socket;
45 * A proxy debug event listener that forwards events over a socket to
47 * one event per line. ANTLRWorks listens on server socket with a
49 * be kept in sync. New events must be handled on both sides of socket.
57 protected Socket socket; field in class:Antlr.Runtime.Debug.DebugEventSocketProxy
106 socket = serverSocket.AcceptSocket();
107 socket.NoDelay = true;
110 socket.Send( encoding.GetBytes( "ANTLR " + DebugEventListenerConstants.ProtocolVersion + "\n" ) )
[all...] |
| /external/apache-harmony/x-net/src/test/impl/java.injected/org/apache/harmony/xnet/provider/jsse/ |
| SSLServerSocketImplTest.java | 21 import java.net.Socket;
534 assertFalse("Socket did not reset its want client auth state",
540 assertFalse("Socket did not reset its want client auth state",
555 assertFalse("Socket did not reset its want client auth state",
561 assertFalse("Socket did not reset its want client auth state",
592 private Socket client = null;
598 client = new Socket();
|
| /external/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/ |
| SpdyConnection.java | 25 import java.net.Socket;
36 * A socket connection to a remote peer. A connection hosts streams which can
49 // Socket writes are guarded by spdyWriter.
51 // Socket reads are unguarded but are only made by the reader thread.
378 public Builder(boolean client, Socket socket) throws IOException {
379 this("", client, socket.getInputStream(), socket.getOutputStream());
390 public Builder(String hostName, boolean client, Socket socket) throws IOException
[all...] |
| /frameworks/base/tests/CoreTests/android/core/ |
| TestWebServer.java | 56 /* Default socket timeout value */
122 * @param timeout Indicates the period of time to wait until a socket is
205 * Cause the thread accepting connections on the server socket to close
230 // Socket timeout functionality is not available yet
257 Socket s = ss.accept();
288 // Close this socket
292 /* Stop server socket from processing further. Currently
309 log("IOException caught by server socket close");
331 /* Socket to client we're handling */
332 private Socket s
[all...] |
| SSLSocketTest.java | 34 import java.net.Socket;
85 Socket socket = secure ? socketFactory.createSocket() local
86 : new Socket();
88 socket.setKeepAlive(true);
89 socket.setSoTimeout(timeout * 1000);
91 socket.connect(address);
94 OutputStream output = socket.getOutputStream();
98 DataInputStream input = new DataInputStream(socket.getInputStream());
173 socket.close()
337 final Socket socket = clientFactory.createSocket(); local
732 SSLSocket socket = (SSLSocket) sslContext.getSocketFactory() local
[all...] |
| /libcore/luni/src/main/java/java/nio/ |
| SocketChannelImpl.java | 29 import java.net.Socket;
71 // Our internal Socket.
72 private SocketAdapter socket = null; field in class:SocketChannelImpl
82 // Whether the socket is bound.
90 * Constructor for creating a connected socket channel.
97 * Constructor for creating an optionally connected socket channel.
102 fd = (connect ? IoBridge.socket(true) : new FileDescriptor());
115 * Getting the internal Socket If we have not the socket, we create a new
119 synchronized public Socket socket() method in class:SocketChannelImpl
[all...] |
| /libcore/support/src/test/java/tests/support/ |
| Support_TestWebServer.java | 49 /* Default socket timeout value */
203 * Cause the thread accepting connections on the server socket to close
240 Socket s = ss.accept();
255 // Close this socket
259 /* Stop server socket from processing further. Currently
268 log("IOException caught by server socket close");
312 /* Socket to client we're handling */
313 private Socket s;
337 Worker(Socket s) {
607 log("SOCKET CLOSED")
[all...] |
| /external/apache-harmony/logging/src/test/java/org/apache/harmony/logging/tests/java/util/logging/ |
| SocketHandlerTest.java | 26 import java.net.Socket;
717 Socket s = new Socket("127.0.0.1", 6666);
732 Socket s = null;
|
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| rawtransportchannel.cc | 85 int RawTransportChannel::SetOption(talk_base::Socket::Option opt, int value) {
|
| /external/chromium_org/remoting/protocol/ |
| buffered_socket_writer.cc | 36 void BufferedSocketWriterBase::Init(net::Socket* socket,
39 DCHECK(socket);
40 socket_ = socket;
|
| jingle_session.h | 26 class Socket;
|
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| dtlstransportchannel.h | 140 virtual int SetOption(talk_base::Socket::Option opt, int value) {
|
| rawtransportchannel.cc | 87 int RawTransportChannel::SetOption(talk_base::Socket::Option opt, int value) {
|
| stunport.cc | 129 talk_base::AsyncPacketSocket* socket,
131 : Port(thread, network, socket->GetLocalAddress().ipaddr(),
134 socket_(socket),
162 LOG_J(LS_WARNING, this) << "UDP socket creation failed";
229 int UDPPort::SetOption(talk_base::Socket::Option opt, int value) {
233 int UDPPort::GetOption(talk_base::Socket::Option opt, int* value) {
241 void UDPPort::OnLocalAddressReady(talk_base::AsyncPacketSocket* socket,
248 void UDPPort::OnReadPacket(talk_base::AsyncPacketSocket* socket,
251 ASSERT(socket == socket_);
270 void UDPPort::OnReadyToSend(talk_base::AsyncPacketSocket* socket) {
[all...] |
| 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.";
99 if (talk_base::AsyncPacketSocket* socket =
101 socket->SignalReadPacket.disconnect(this);
102 conn = new TCPConnection(this, address, socket);
112 // If socket isn't bound yet the address will be added in
113 // OnAddressReady(). Socket may be in the CLOSED state if Listen()
114 // failed, we still want ot add the socket address.
134 talk_base::AsyncPacketSocket * socket = NULL; local
136 socket = conn->socket()
192 talk_base::AsyncPacketSocket* socket = NULL; local
[all...] |
| /external/smack/src/org/jivesoftware/smack/ |
| XMPPConnection.java | 49 import java.net.Socket;
60 * Creates a socket connection to a XMPP server. This is the default connection
69 * The socket which is used for this connection.
71 Socket socket; field in class:XMPPConnection
431 // It is *important* that this is done before socket.close()!
434 socket.close();
446 // socket.close(). But just in case do it explicitly.
455 // socket.close(). But just in case do it explicitly.
462 // Make sure that the socket is really close
[all...] |
| /packages/apps/Bluetooth/src/com/android/bluetooth/opp/ |
| BluetoothOppTransfer.java | 61 import java.net.Socket;
350 * 3.2) Try a few seconds to connect to target socket
515 /* create a TCP socket */
517 super("Socket Connect Thread");
524 /* create a Rfcomm Socket */
527 super("Socket Connect Thread");
535 /* create a Rfcomm Socket */
538 super("Socket Connect Thread");
552 Log.v(TAG, "Error when close socket");
564 /* Use TCP socket to connect *
[all...] |
| /external/v8/src/ |
| platform-win32.cc | 1823 SOCKET socket = accept(socket_, NULL, NULL); local
[all...] |
| /development/samples/WiFiDirectDemo/src/com/example/android/wifidirect/ |
| DeviceDetailFragment.java | 47 import java.net.Socket;
158 // socket.
207 * A simple server socket that accepts connection and writes some data on
228 Log.d(WiFiDirectActivity.TAG, "Server: Socket opened");
229 Socket client = serverSocket.accept();
273 statusText.setText("Opening a server socket");
|
| /external/antlr/antlr-3.4/runtime/Java/src/main/java/org/antlr/runtime/debug/ |
| DebugEventSocketProxy.java | 37 import java.net.Socket;
39 /** A proxy debug event listener that forwards events over a socket to
41 * one event per line. ANTLRWorks listens on server socket with a
43 * be kept in sync. New events must be handled on both sides of socket.
49 protected Socket socket; field in class:DebugEventSocketProxy
76 socket = serverSocket.accept();
77 socket.setTcpNoDelay(true);
78 OutputStream os = socket.getOutputStream();
81 InputStream is = socket.getInputStream()
[all...] |
| /external/jmonkeyengine/engine/src/networking/com/jme3/network/kernel/tcp/ |
| SelectorKernel.java | 40 import java.net.Socket;
246 // Create a new non-blocking server socket channel
250 // Bind the server socket to the specified address and port
251 serverChannel.socket().bind(address);
253 // Register the server socket channel, indicating an interest in
311 Socket sock = remoteChan.socket();
|
| /external/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| HttpTransport.java | 28 import java.net.Socket;
49 * we can save socket writes, which in turn saves a packet transmission.
184 Socket socket = connection.getSocket();
185 if (socket == null) return false;
187 int socketTimeout = socket.getSoTimeout();
188 socket.setSoTimeout(DISCARD_STREAM_TIMEOUT_MILLIS);
193 socket.setSoTimeout(socketTimeout);
|
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/test/ |
| ModelInterpreter.java | 29 import java.net.Socket;
202 Socket s;
208 "IOException on socket.accept(); stopping", ex);
217 "IOException on accepted socket(); re-listening", ex);
|
| /libcore/luni/src/test/java/tests/api/javax/net/ssl/ |
| X509KeyManagerTest.java | 4 import java.net.Socket;
[all...] |
| /development/apps/Development/src/com/android/development/ |
| Connectivity.java | 68 import java.net.Socket;
548 onRoutedRequest(SOCKET);
551 private final static int SOCKET = 1;
568 case SOCKET:
656 Socket socket = null; local
658 socket = new Socket(remote, 80, local, 6000);
660 Log.e(TAG, "Exception creating socket: " + e);
664 PrintWriter out = new PrintWriter(socket.getOutputStream(), true)
693 Socket socket = null; local
[all...] |
