| /libcore/harmony-tests/src/test/java/org/apache/harmony/nio/tests/java/nio/channels/ |
| SocketChannelTest.java | 28 import java.net.Socket;
279 Socket s1 = this.channel1.socket();
281 Socket s2 = this.channel1.socket();
291 Socket s1 = this.channel1.socket();
294 Socket s2 = this.channel1.socket();
303 Socket s1 = null
373 Socket socket = channel1.socket(); local
383 Socket socket = channel1.socket(); local
393 Socket socket = channel1.socket(); local
402 Socket socket = channel1.socket(); local
411 Socket socket = channel1.socket(); local
420 Socket socket = channel1.socket(); local
430 Socket socket = channel1.socket(); local
3180 Socket socket = null; local
3530 Socket socket = channel1.socket(); local
3571 public Socket socket() { method in class:SocketChannelTest.MockSocketChannel
[all...] |
| /external/chromium_org/chrome/browser/extensions/api/socket/ |
| tcp_socket.cc | 5 #include "chrome/browser/extensions/api/socket/tcp_socket.h"
12 #include "net/socket/tcp_client_socket.h"
17 "Cannot call both connect and listen on the same socket.";
43 : Socket(owner_extension_id),
50 : Socket(owner_extension_id),
58 : Socket(owner_extension_id),
260 Socket::SocketType TCPSocket::GetSocketType() const {
261 return Socket::TYPE_TCP;
|
| /external/v8/src/ |
| platform.h | 108 class Socket;
238 // Factory method for creating platform dependent Socket.
239 // Please use delete to reclaim the storage for the returned Socket.
240 static Socket* CreateSocket();
632 // Socket
635 class Socket {
637 virtual ~Socket() {}
642 virtual Socket* Accept() const = 0;
647 // Shutdown socket for both read and write. This causes blocking Send and
648 // Receive calls to exit. After Shutdown the Socket object cannot be used fo
[all...] |
| /libcore/luni/src/main/java/libcore/net/url/ |
| FtpURLConnection.java | 31 import java.net.Socket;
73 private Socket controlSocket;
75 private Socket dataSocket;
215 controlSocket = new Socket();
217 controlSocket = new Socket(currentProxy);
|
| /packages/apps/Email/emailcommon/src/com/android/emailcommon/utility/ |
| SSLUtils.java | 35 import java.net.Socket;
221 String[] keyTypes, Principal[] issuers, Socket socket);
232 String keyType, Principal[] issuers, Socket socket) {
258 public String chooseClientAlias(String[] keyTypes, Principal[] issuers, Socket socket) {
260 InetAddress address = socket.getInetAddress();
355 public String chooseClientAlias(String[] keyTypes, Principal[] issuers, Socket socket) {
[all...] |
| /cts/tests/tests/security/src/android/security/cts/ |
| OpenSSLEarlyCCSTest.java | 36 import java.net.Socket;
72 // tearDown() kills the sockets they may be using. To aid this behavior, all Socket and
82 private Socket mMitmServerSocket;
83 private Socket mMitmClientSocket;
241 SSLSocket socket = (SSLSocket) sslContext.getSocketFactory().createSocket(); local
242 setClientSocket(socket);
245 socket.connect(serverAddress);
246 Log.i(TAG, "Client connected to server from " + socket.getLocalSocketAddress());
248 socket.getOutputStream().write("client".getBytes());
249 socket.getOutputStream().flush()
288 SSLSocket socket = null; local
[all...] |
| /external/chromium_org/tools/android/forwarder2/ |
| host_forwarder_main.cc | 43 #include "tools/android/forwarder2/socket.h"
77 // If for some reason the forwarder get stuck in any socket waiting forever,
107 scoped_ptr<Socket> client_socket) {
161 scoped_ptr<Socket> client_socket) {
249 // Wait for the socket to be fully unmapped.
271 Socket bind_socket;
289 bool SendMessage(const std::string& msg, Socket* client_socket) {
322 virtual void OnClientConnected(scoped_ptr<Socket> client_socket) OVERRIDE {
365 virtual void OnDaemonReady(Socket* daemon_socket) OVERRIDE {
|
| /external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/net/ |
| AuthenticatorTest.java | 27 import java.net.Socket;
145 Socket s = ss.accept();
|
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| sslsocketfactory.cc | 40 // the socket adapter is the more appropriate idiom for automatic proxy
118 Socket* SslSocketFactory::CreateSocket(int type) {
122 Socket* SslSocketFactory::CreateSocket(int family, int type) {
142 AsyncSocket* socket = factory_->CreateAsyncSocket(family, type); local
143 if (!socket)
148 socket = new LoggingSocketAdapter(socket, logging_level_,
155 proxy_socket = new AsyncSocksProxySocket(socket, proxy.address,
160 new AsyncHttpsProxySocket(socket, agent_, proxy.address,
166 delete socket;
[all...] |
| virtualsocketserver.h | 107 virtual Socket* CreateSocket(int type);
108 virtual Socket* CreateSocket(int family, int type);
136 // Binds the given socket to addr, assigning and IP and Port if necessary
137 int Bind(VirtualSocket* socket, SocketAddress* addr);
139 // Binds the given socket to the given (fully-defined) address.
140 int Bind(VirtualSocket* socket, const SocketAddress& addr);
142 // Find the socket bound to the given address
145 int Unbind(const SocketAddress& addr, VirtualSocket* socket);
147 // Adds a mapping between this socket pair and the socket
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| basicpacketsocketfactory.cc | 65 talk_base::AsyncSocket* socket = local
68 if (!socket) {
71 if (BindSocket(socket, address, min_port, max_port) < 0) {
73 << socket->GetError();
74 delete socket;
77 return new talk_base::AsyncUDPSocket(socket);
89 talk_base::AsyncSocket* socket = local
92 if (!socket) {
96 if (BindSocket(socket, local_address, min_port, max_port) < 0) {
98 << socket->GetError()
129 talk_base::AsyncSocket* socket = local
[all...] |
| portproxy.cc | 106 int PortProxy::SetOption(talk_base::Socket::Option opt,
112 int PortProxy::GetOption(talk_base::Socket::Option opt,
|
| transportchannel.h | 38 #include "talk/base/socket.h"
89 // Sets a socket option on this channel. Note that not all options are
91 virtual int SetOption(talk_base::Socket::Option opt, int value) = 0;
|
| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| TCPMessageProcessor.java | 31 import java.net.Socket;
50 * accept socket).
108 * Run method for the thread that gets created for each accept socket.
111 // Accept new connectins on our socket.
133 Socket newsock = sock.accept();
|
| /external/smack/src/org/jivesoftware/smackx/bytestreams/socks5/ |
| Socks5BytestreamRequest.java | 17 import java.net.Socket;
179 * Accepts the SOCKS5 Bytestream initialization request and returns the socket to send/receive
185 * @return the socket to send/receive data
198 Socket socket = null;
local
219 // establish socket
226 socket = socks5Client.getSocket(timeout);
246 if (selectedHost == null || socket == null) {
254 return new Socks5BytestreamSession(socket, selectedHost.getJID().equals(
273 String errorMessage = "Could not establish socket with any provided host";
[all...] |
| /libcore/crypto/src/main/java/org/conscrypt/ |
| OpenSSLServerSocketImpl.java | 21 import java.net.Socket;
117 * Enables/disables the TLS Channel ID extension for this server socket.
124 * Checks whether the TLS Channel ID extension is enabled for this server socket.
174 public Socket accept() throws IOException {
180 OpenSSLSocketImpl socket = new OpenSSLSocketImpl(sslParameters, local
183 socket.setChannelIdEnabled(channelIdEnabled);
184 implAccept(socket);
185 return socket;
|
| /libcore/luni/src/main/java/libcore/io/ |
| IoUtils.java | 24 import java.net.Socket;
75 * Closes 'socket', ignoring any exceptions. Does nothing if 'socket' is null.
77 public static void closeQuietly(Socket socket) {
78 if (socket != null) {
80 socket.close();
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/opp/ |
| BluetoothOppRfcommListener.java | 37 import java.net.Socket;
93 Socket clientSocket = mTcpServerSocket.accept();
95 if (V) Log.v(TAG, "Socket connected!");
|
| /cts/tests/tests/net/src/android/net/cts/ |
| TrafficStatsTest.java | 31 import java.net.Socket;
118 // Transfer 1MB of data across an explicitly localhost socket.
127 Socket socket = new Socket("localhost", server.getLocalPort()); local
130 socket.setTcpNoDelay(true);
131 OutputStream out = socket.getOutputStream();
134 TrafficStats.tagSocket(socket);
147 socket.close();
150 Log.i(LOG_TAG, "Badness during writes to socket: " + e)
157 Socket socket = server.accept(); local
[all...] |
| /external/chromium/third_party/libjingle/source/talk/base/ |
| 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...] |
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| stunport.h | 82 virtual int SetOption(talk_base::Socket::Option opt, int value);
94 void OnReadPacket(talk_base::AsyncPacketSocket* socket,
|
| transportchannelproxy.cc | 66 int TransportChannelProxy::SetOption(talk_base::Socket::Option opt, int value) {
|
| udpport.cc | 51 LOG_J(LS_WARNING, this) << "UDP socket creation failed";
93 int UDPPort::SetOption(talk_base::Socket::Option opt, int value) {
101 void UDPPort::OnAddresReady(talk_base::AsyncPacketSocket* socket,
107 talk_base::AsyncPacketSocket* socket, const char* data, size_t size,
109 ASSERT(socket == socket_);
|
| /external/chromium_org/remoting/client/plugin/ |
| pepper_packet_socket_factory.cc | 51 virtual int GetOption(talk_base::Socket::Option opt, int* value) OVERRIDE;
52 virtual int SetOption(talk_base::Socket::Option opt, int value) OVERRIDE;
155 // Socket is being destroyed while binding.
180 LOG(ERROR) << "Failed to bind UDP socket: " << result;
241 int UdpPacketSocket::GetOption(talk_base::Socket::Option opt, int* value) {
246 int UdpPacketSocket::SetOption(talk_base::Socket::Option opt, int value) {
275 // Send is aborted when the socket is being destroyed.
284 LOG(ERROR) << "Send failed on a UDP socket: " << result;
289 // socket may still be useful for other ICE canidadates (e.g. for
334 LOG(ERROR) << "Received error when reading from UDP socket: " << result
[all...] |
| /external/chromium_org/remoting/protocol/ |
| message_reader.cc | 15 #include "net/socket/socket.h"
32 void MessageReader::Init(net::Socket* socket,
36 DCHECK(socket);
37 socket_ = socket;
|
