| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| asyncudpsocket.cc | 36 AsyncSocket* socket,
38 scoped_ptr<AsyncSocket> owned_socket(socket);
39 if (socket->Bind(bind_address) < 0) {
40 LOG(LS_ERROR) << "Bind() failed with error " << socket->GetError();
48 AsyncSocket* socket = local
50 if (!socket)
52 return Create(socket, bind_address);
55 AsyncUDPSocket::AsyncUDPSocket(AsyncSocket* socket)
56 : socket_(socket) {
61 // The socket should start out readable but not writable
[all...] |
| win32socketserver.h | 37 #include "talk/base/socket.h"
54 int Attach(SOCKET s);
85 void OnSocketNotify(SOCKET socket, int event, int error);
88 SOCKET socket_;
118 virtual Socket* CreateSocket(int type);
119 virtual Socket* CreateSocket(int family, int type);
|
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| tcpport.h | 72 virtual int GetOption(talk_base::Socket::Option opt, int* value);
73 virtual int SetOption(talk_base::Socket::Option opt, int value);
83 // Handles sending using the local TCP socket.
88 void OnNewConnection(talk_base::AsyncPacketSocket* socket,
94 talk_base::AsyncPacketSocket* socket; member in struct:cricket::TCPPort::Incoming
100 // Receives packet signal from the local TCP Socket.
101 void OnReadPacket(talk_base::AsyncPacketSocket* socket,
105 void OnReadyToSend(talk_base::AsyncPacketSocket* socket);
107 void OnAddressReady(talk_base::AsyncPacketSocket* socket,
122 // Connection is outgoing unless socket is specifie
130 talk_base::AsyncPacketSocket* socket() { return socket_; } function in class:cricket::TCPConnection
[all...] |
| transportchannel.h | 36 #include "talk/base/socket.h"
85 // Sets a socket option on this channel. Note that not all options are
87 virtual int SetOption(talk_base::Socket::Option opt, int value) = 0;
|
| /external/mockwebserver/src/main/java/com/google/mockwebserver/ |
| RecordedRequest.java | 20 import java.net.Socket;
40 int bodySize, byte[] body, int sequenceNumber, Socket socket) {
48 if (socket instanceof SSLSocket) {
49 SSLSocket sslSocket = (SSLSocket) socket;
|
| 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...] |
| /frameworks/base/core/java/android/net/ |
| LinkSocket.java | 26 import java.net.Socket;
34 public class LinkSocket extends Socket {
46 * Creates a new unconnected socket.
54 * Creates a new unconnected socket usign the given proxy type.
56 * @param proxy the specified proxy for this socket
66 * @return the {@code LinkProperties} for the socket
74 * Set the {@code LinkCapabilies} needed for this socket. If the socket is already connected
75 * or is a duplicate socket the request is ignored and {@code false} will
78 * @param needs the needs of the socket
[all...] |
| /libcore/support/src/test/java/tests/http/ |
| MockWebServer.java | 31 import java.net.Socket;
70 private final Set<Socket> openClientSockets
71 = Collections.newSetFromMap(new ConcurrentHashMap<Socket, Boolean>());
197 logger.log(Level.WARNING, "MockWebServer server socket close failed", e);
199 for (Iterator<Socket> s = openClientSockets.iterator(); s.hasNext();) {
204 logger.log(Level.WARNING, "MockWebServer socket close failed", e);
216 Socket socket;
218 socket = serverSocket.accept();
225 socket.close()
[all...] |
| /sdk/apps/SdkController/src/com/android/tools/sdkcontroller/lib/ |
| Socket.java | 28 * Encapsulates a connection with the emulator over a UNIX-domain socket.
30 public class Socket {
31 /** UNIX-domain socket connected with the emulator. */
33 /** Channel name for the connection established via this socket. */
44 * Constructs Socket instance.
46 * @param socket Socket connection with the emulator.
50 public Socket(LocalSocket socket, String name, ByteOrder endian) {
51 mSocket = socket;
99 LocalSocket socket = mSocket; local
116 LocalSocket socket = mSocket; local
153 LocalSocket socket = mSocket; local
182 LocalSocket socket; local
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/nio/tests/java/nio/channels/ |
| ServerSocketChannelTest.java | 25 import java.net.Socket;
118 // Test for socket()
122 * Test method for 'java.nio.channels.ServerSocketChannel.socket()'
127 ServerSocket s1 = this.serverChannel.socket();
130 ServerSocket s2 = this.serverChannel.socket();
134 // socket close makes the channel close
143 ServerSocket s1 = this.serverChannel.socket();
146 ServerSocket s2 = this.serverChannel.socket();
150 // socket close makes the channel close
160 ServerSocket s1 = this.serverChannel.socket();
346 Socket socket = serverChannel.accept().socket(); local
390 Socket socket = serverChannel.accept().socket(); local
435 Socket socket = serverChannel.accept().socket(); local
457 Socket socket = serverChannel.accept().socket(); local
469 Socket socket; field in class:ServerSocketChannelTest.WriteSocketThread
500 Socket socket = serverChannel.accept().socket(); local
[all...] |
| /cts/hostsidetests/appsecurity/test-apps/AppWithData/src/com/android/cts/appwithdata/ |
| CreatePrivateDataTest.java | 30 import java.net.Socket;
200 // Transfer 1MB of data across an explicitly localhost socket.
209 Socket socket = new Socket("localhost", server.getLocalPort()); local
212 socket.setTcpNoDelay(true);
213 OutputStream out = socket.getOutputStream();
217 TrafficStats.tagSocket(socket);
222 socket.close();
230 Socket socket = server.accept() local
[all...] |
| /external/chromium/third_party/libjingle/source/talk/base/ |
| physicalsocketserver.h | 39 typedef int SOCKET;
66 virtual SOCKET GetSocket() = 0;
74 // A socket server that provides the real sockets of the underlying OS.
81 virtual Socket* CreateSocket(int type);
85 AsyncSocket* WrapSocket(SOCKET s);
|
| sslsocketfactory.h | 73 virtual Socket* CreateSocket(int type);
|
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| rawtransportchannel.h | 68 virtual int SetOption(talk_base::Socket::Option opt, int value);
|
| transportchannel.h | 34 #include "talk/base/socket.h"
64 // Sets a socket option on this channel. Note that not all options are
66 virtual int SetOption(talk_base::Socket::Option opt, int value) = 0;
|
| udpport.h | 66 virtual int SetOption(talk_base::Socket::Option opt, int value);
74 // Handles sending using the local UDP socket.
78 void OnAddresReady(talk_base::AsyncPacketSocket* socket,
82 void OnReadPacket(talk_base::AsyncPacketSocket* socket,
|
| /external/chromium_org/jingle/glue/ |
| channel_socket_adapter.h | 10 #include "net/socket/socket.h"
24 // TransportChannelSocketAdapter implements net::Socket interface on
26 // JingleChromotocolConnection to provide net::Socket interface for channels.
27 class TransportChannelSocketAdapter : public net::Socket,
44 // Socket implementation.
|
| pseudotcp_adapter.h | 15 #include "net/socket/stream_socket.h"
20 // PseudoTcpAdapter adapts a connectionless net::Socket to a connection-
27 // Creates an adapter for the supplied Socket. |socket| should already
29 PseudoTcpAdapter(net::Socket* socket);
32 // net::Socket implementation.
|
| /external/chromium_org/remoting/base/ |
| socket_reader.cc | 13 #include "net/socket/socket.h"
29 void SocketReader::Init(net::Socket* socket,
31 DCHECK(socket);
34 socket_ = socket;
|
| /external/chromium_org/remoting/client/plugin/ |
| pepper_packet_socket_factory.cc | 49 virtual int GetOption(talk_base::Socket::Option opt, int* value) OVERRIDE;
50 virtual int SetOption(talk_base::Socket::Option opt, int value) OVERRIDE;
150 // Socket is being destroyed while binding.
159 LOG(ERROR) << "Failed to get bind address for bound socket?";
181 LOG(ERROR) << "Failed to bind UDP socket: " << result;
240 int UdpPacketSocket::GetOption(talk_base::Socket::Option opt, int* value) {
245 int UdpPacketSocket::SetOption(talk_base::Socket::Option opt, int value) {
273 // Send is aborted when the socket is being destroyed.
282 LOG(ERROR) << "Send failed on a UDP socket: " << result;
287 // socket may still be useful for other ICE canidadates (e.g. fo
[all...] |
| /external/javassist/src/main/javassist/tools/rmi/ |
| ObjectImporter.java | 155 Socket sock = new Socket(servername, port);
224 Socket sock = new Socket(servername, port);
|
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| TestKeyManager.java | 20 import java.net.Socket;
63 public String chooseClientAlias(String[] keyTypes, Principal[] issuers, Socket socket) {
71 dumpSocket(socket);
73 return dumpAlias(keyManager.chooseClientAlias(keyTypes, issuers, socket));
88 public String chooseServerAlias(String keyType, Principal[] issuers, Socket socket) {
94 dumpSocket(socket);
96 return dumpAlias(keyManager.chooseServerAlias(keyType, issuers, socket));
99 private void dumpSocket(Socket socket)
[all...] |
| /packages/apps/Email/src/com/android/email/mail/transport/ |
| MailTransport.java | 36 import java.net.Socket;
60 private Socket mSocket;
117 mSocket = new Socket();
120 // After the socket connects to an SSL server, confirm that the hostname is as expected
151 * TODO should we explicitly close the old socket? This seems funky to abandon it.
179 * connected socket. You MUST call this if you did not supply a hostname
187 * @param socket An SSL socket which has been connected to a server
192 private static void verifyHostname(Socket socket, String hostname) throws IOException
[all...] |
| /cts/tests/tests/os/src/android/os/cts/ |
| ParcelFileDescriptorTest.java | 43 import java.net.Socket;
88 Socket sSocket = ss.accept();
102 Socket socket; local
103 socket = new Socket(InetAddress.getLocalHost(), PORT);
104 ParcelFileDescriptor pfd = ParcelFileDescriptor.fromSocket(socket);
108 socket.close();
170 ParcelFileDescriptor pfd = ParcelFileDescriptor.fromSocket(new Socket());
221 ParcelFileDescriptor pfd = ParcelFileDescriptor.fromSocket(new Socket());
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/examples/peerconnection/client/ |
| peer_connection_client.cc | 180 ASSERT(control_socket_->GetState() == talk_base::Socket::CS_CLOSED);
202 control_socket_->GetState() != talk_base::Socket::CS_CLOSED;
209 if (hanging_get_->GetState() != talk_base::Socket::CS_CLOSED)
212 if (control_socket_->GetState() == talk_base::Socket::CS_CLOSED) {
246 ASSERT(control_socket_->GetState() == talk_base::Socket::CS_CLOSED);
255 void PeerConnectionClient::OnConnect(talk_base::AsyncSocket* socket) {
257 size_t sent = socket->Send(onconnect_data_.c_str(), onconnect_data_.length());
263 void PeerConnectionClient::OnHangingGetConnect(talk_base::AsyncSocket* socket) {
268 int sent = socket->Send(buffer, len);
312 bool PeerConnectionClient::ReadIntoBuffer(talk_base::AsyncSocket* socket,
[all...] |
