| /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
266 Socket socket = serverSocket.accept(); local
275 Socket socket = new Socket("localhost", serverSocket.getLocalPort()); local
[all...] |
| OldSocketImplFactoryTest.java | 8 import java.net.Socket;
30 Socket.setSocketImplFactory(factory);
33 new Socket();
41 Socket.setSocketImplFactory(factory);
48 Socket.setSocketImplFactory(null);
65 Field [] fields = Socket.class.getDeclaredFields();
|
| ConcurrentCloseTest.java | 24 import java.net.Socket;
36 * Test that Socket.close called on another thread interrupts a thread that's blocked doing
45 Socket s = ss.accept();
48 assertEquals("Socket closed", expected.getMessage());
54 Socket s = new Socket();
61 assertEquals("Socket closed", expected.getMessage());
69 Socket s = new Socket();
76 assertEquals("Socket closed", expected.getMessage())
[all...] |
| /sdk/apps/SdkController/src/com/android/tools/sdkcontroller/lib/ |
| Connection.java | 34 * the device side, the connection is bound to the UNIX-domain socket named
37 * 'android.sdk.controller' socket on the device. Typically, the port forwarding
52 * 2. Channels are connected to emulator via separate socket instance (though all
53 * of the connections share the same socket address).
61 * 1. Bind to "android.sdk.controller" socket, listening to emulator connections.
79 /** Server socket used to listen to emulator connections. */
91 private List<Socket> mPendingSockets = new ArrayList<Socket>();
110 * Binds to the socket, and starts the listening thread.
124 * Stops the listener, and closes the socket
133 LocalServerSocket socket; local
269 LocalServerSocket socket = mServerSocket; local
[all...] |
| /external/apache-http/src/org/apache/http/impl/ |
| DefaultHttpClientConnection.java | 35 import java.net.Socket;
56 final Socket socket,
58 if (socket == null) {
59 throw new IllegalArgumentException("Socket may not be null");
65 socket.setTcpNoDelay(HttpConnectionParams.getTcpNoDelay(params));
66 socket.setSoTimeout(HttpConnectionParams.getSoTimeout(params));
70 socket.setSoLinger(linger > 0, linger);
72 super.bind(socket, params);
|
| DefaultHttpServerConnection.java | 35 import java.net.Socket;
55 public void bind(final Socket socket, final HttpParams params) throws IOException {
56 if (socket == null) {
57 throw new IllegalArgumentException("Socket may not be null");
63 socket.setTcpNoDelay(HttpConnectionParams.getTcpNoDelay(params));
64 socket.setSoTimeout(HttpConnectionParams.getSoTimeout(params));
68 socket.setSoLinger(linger > 0, linger);
70 super.bind(socket, params);
|
| /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/third_party/libjingle/source/talk/p2p/base/ |
| transportchannelproxy.h | 56 virtual int SetOption(talk_base::Socket::Option opt, int value);
61 typedef std::pair<talk_base::Socket::Option, int> OptionPair;
|
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| asyncpacketsocket.h | 32 #include "talk/base/socket.h"
52 // socket is not bound yet (GetState() returns STATE_BINDING).
55 // Returns remote address. Returns zeroes if this is not a client TCP socket.
62 // Close the socket.
65 // Returns current state of the socket.
69 virtual int GetOption(Socket::Option opt, int* value) = 0;
70 virtual int SetOption(Socket::Option opt, int value) = 0;
82 // Emitted when the socket is currently able to send.
85 // Emitted after address for the socket is allocated, i.e. binding
86 // is finished. State of the socket is changed from BINDING to BOUN
[all...] |
| asyncudpsocket.h | 41 // Binds |socket| and creates AsyncUDPSocket for it. Takes ownership
42 // of |socket|. Returns NULL if bind() fails (|socket| is destroyed
44 static AsyncUDPSocket* Create(AsyncSocket* socket,
46 // Creates a new socket for sending asynchronous UDP packets using an
47 // asynchronous socket from the given factory.
50 explicit AsyncUDPSocket(AsyncSocket* socket);
60 virtual int GetOption(Socket::Option opt, int* value);
61 virtual int SetOption(Socket::Option opt, int value);
66 // Called when the underlying socket is ready to be read from
[all...] |
| /external/chromium_org/tools/android/forwarder2/ |
| device_listener.cc | 16 #include "tools/android/forwarder2/socket.h"
22 scoped_ptr<Socket> host_socket,
25 scoped_ptr<Socket> listener_socket(new Socket());
34 // currently (non-zero) allocated port for this socket.
54 void DeviceListener::SetAdbDataSocket(scoped_ptr<Socket> adb_data_socket) {
62 scoped_ptr<Socket> listener_socket,
63 scoped_ptr<Socket> host_socket,
88 device_data_socket_.reset(new Socket());
121 scoped_ptr<Socket> adb_data_socket)
[all...] |
| command.cc | 16 #include "tools/android/forwarder2/socket.h"
43 bool ReadCommand(Socket* socket,
50 int bytes_read = socket->ReadNumBytes(command_buffer, kCommandStringSize);
57 LOG(ERROR) << "Read() error, not enough data received from the socket.";
80 bool SendCommand(command::Type command, int port, Socket* socket) {
85 return socket->WriteNumBytes(buffer, len) == len;
88 bool ReceivedCommand(command::Type command, Socket* socket) {
[all...] |
| daemon.cc | 30 #include "tools/android/forwarder2/socket.h"
38 // Socket and also when waiting for its death when it is killed.
55 Socket* server_socket,
59 scoped_ptr<Socket> client_socket(new Socket());
128 scoped_ptr<Socket> ConnectToUnixDomainSocket(
134 scoped_ptr<Socket> socket(new Socket());
135 if (!socket->ConnectUnix(socket_name))
[all...] |
| /external/smack/src/org/jivesoftware/smack/proxy/ |
| HTTPProxySocketFactory.java | 26 import java.net.Socket;
35 * Http Proxy Socket Factory which returns socket connected to Http Proxy
50 public Socket createSocket(String host, int port)
56 public Socket createSocket(String host ,int port, InetAddress localHost,
63 public Socket createSocket(InetAddress host, int port)
70 public Socket createSocket( InetAddress address, int port,
77 private Socket httpProxifiedSocket(String host, int port)
82 Socket socket = new Socket(proxyhost,proxyPort) local
[all...] |
| Socks4ProxySocketFactory.java | 24 import java.net.Socket;
29 * Socket factory for socks4 proxy
43 public Socket createSocket(String host, int port)
50 public Socket createSocket(String host ,int port, InetAddress localHost,
57 public Socket createSocket(InetAddress host, int port)
63 public Socket createSocket( InetAddress address, int port,
71 private Socket socks4ProxifiedSocket(String host, int port)
74 Socket socket = null; local
84 socket=new Socket(proxy_host, proxy_port);
[all...] |
| Socks5ProxySocketFactory.java | 24 import java.net.Socket;
29 * Socket factory for Socks5 proxy
43 public Socket createSocket(String host, int port)
49 public Socket createSocket(String host ,int port, InetAddress localHost,
58 public Socket createSocket(InetAddress host, int port)
66 public Socket createSocket( InetAddress address, int port,
75 private Socket socks5ProxifiedSocket(String host, int port)
78 Socket socket = null; local
88 socket=new Socket(proxy_host, proxy_port);
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/nio/tests/java/nio/channels/ |
| MockSocketChannel.java | 21 import java.net.Socket;
33 public Socket socket() { method in class:MockSocketChannel
|
| /external/chromium_org/remoting/protocol/ |
| message_reader.h | 19 class Socket;
25 // MessageReader reads data from the socket asynchronously and calls
27 // callback as soon as the socket is closed, so the socket should
31 // new data from the socket until all previously received messages are
44 // Initialize the MessageReader with a socket. If a message is received
46 void Init(net::Socket* socket, const MessageReceivedCallback& callback);
56 net::Socket* socket_;
58 // Set to true, when we have a socket read pending, and expectin
[all...] |
| buffered_socket_writer.h | 14 #include "net/socket/socket.h"
17 class Socket;
27 // that doesn't own the socket, as Write() can be called from any thread.
29 // on the thread that owns the socket. GetBufferChunks() and GetBufferSize()
40 // to access the socket in the future. |callback| will be called after each
41 // failed write. Caller retains ownership of |socket|.
42 // TODO(sergeyu): Change it so that it take ownership of |socket|.
43 void Init(net::Socket* socket, const WriteFailedCallback& callback)
[all...] |
| /external/jmonkeyengine/engine/src/networking/com/jme3/network/kernel/tcp/ |
| SocketConnector.java | 41 import java.net.Socket;
48 * A straight forward socket-based connector implementation that
57 private Socket sock;
66 this.sock = new Socket(address, port);
96 Socket temp = sock;
101 throw new ConnectorException( "Error closing socket for:" + remoteAddress, e );
123 // Socket is closed
|
| /development/samples/WiFiDirectServiceDiscovery/src/com/example/android/wifidirect/discovery/ |
| ChatManager.java | 10 import java.net.Socket;
13 * Handles reading and writing of messages with socket buffers. Uses a Handler
18 private Socket socket = null; field in class:ChatManager
21 public ChatManager(Socket socket, Handler handler) {
22 this.socket = socket;
34 iStream = socket.getInputStream();
35 oStream = socket.getOutputStream()
[all...] |
| /external/apache-harmony/x-net/src/test/api/java/org/apache/harmony/xnet/tests/javax/net/ssl/ |
| X509ExtendedKeyManagerTest.java | 20 import java.net.Socket;
56 * java.security.Principal[], java.net.Socket)
59 Socket socket) {
65 * java.security.Principal[], java.net.Socket)
68 Socket socket) {
|
| /external/apache-http/src/org/apache/http/impl/io/ |
| SocketInputBuffer.java | 36 import java.net.Socket;
44 * {@link Socket} bound session input buffer.
54 private final Socket socket; field in class:SocketInputBuffer
57 final Socket socket,
61 if (socket == null) {
62 throw new IllegalArgumentException("Socket may not be null");
64 this.socket = socket;
[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);
|
| /external/ganymed-ssh2/src/main/java/ch/ethz/ssh2/channel/ |
| StreamForwarder.java | 10 import java.net.Socket;
15 * then one can be configured to shutdown the underlying channel/socket
28 Socket s;
31 StreamForwarder(Channel c, StreamForwarder sibling, Socket s, InputStream is, OutputStream os, String mode)
|
