| /external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/net/ |
| SocketTest.java | 30 import java.net.Socket;
48 Socket socket = new Socket(); local
50 socket.connect(addr);
52 socket.close();
73 ServerSocket socket = null; local
76 socket = new ServerSocket(port, backlog,
78 port = socket.getLocalPort();
81 socket = new ServerSocket(port, backlog)
247 Socket socket = new Socket(proxy); local
275 Socket socket = new Socket(); local
284 Socket socket = new Socket(); local
[all...] |
| /external/apache-harmony/x-net/src/test/impl/java.injected/org/apache/harmony/xnet/provider/jsse/ |
| SSLSocketFactoriesTest.java | 25 import java.net.Socket;
183 + "socket,String,int,boolean)");
185 Socket socket = new Socket( local
189 socket, "localhost", ssocket.getLocalPort(),
289 final String server_message = "Hello from SSL Server Socket!";
290 final String client_message = "Hello from SSL Socket!";
306 System.out.println("Socket accepted: " + s);
|
| /external/chromium/net/socket/ |
| client_socket_handle.h | 21 #include "net/socket/client_socket.h"
22 #include "net/socket/client_socket_pool.h"
30 // client socket objects.
35 UNUSED = 0, // unused socket that just finished connecting
36 UNUSED_IDLE, // unused socket that has been idle for awhile
37 REUSED_IDLE, // previously used socket
45 // ClientSocketPool to obtain a connected socket, possibly reusing one. This
49 // If this method succeeds, then the socket member will be set to an existing
50 // connected socket if an existing connected socket was available to reuse
134 ClientSocket* socket() { return socket_.get(); } function in class:net::ClientSocketHandle
[all...] |
| ssl_client_socket_openssl.cc | 8 #include "net/socket/ssl_client_socket_openssl.h"
26 #include "net/socket/ssl_error_params.h"
129 // versions supported by the server were disabled in this socket instance.
295 SSLClientSocketOpenSSL* socket = static_cast<SSLClientSocketOpenSSL*>( local
297 DCHECK(socket);
298 return socket;
301 bool SetClientSocketForSSL(SSL* ssl, SSLClientSocketOpenSSL* socket) {
302 return SSL_set_ex_data(ssl, ssl_socket_data_index_, socket) != 0;
334 SSLClientSocketOpenSSL* socket = GetClientSocketFromSSL(ssl); local
335 session_cache_.OnSessionAdded(socket->host_and_port(), session)
349 SSLClientSocketOpenSSL* socket = GetInstance()->GetClientSocketFromSSL(ssl); local
358 SSLClientSocketOpenSSL* socket = GetInstance()->GetClientSocketFromSSL(ssl); local
[all...] |
| ssl_client_socket_pool.cc | 5 #include "net/socket/ssl_client_socket_pool.h"
15 #include "net/socket/client_socket_factory.h"
16 #include "net/socket/client_socket_handle.h"
17 #include "net/socket/socks_client_socket_pool.h"
18 #include "net/socket/ssl_client_socket.h"
19 #include "net/socket/ssl_host_info.h"
20 #include "net/socket/transport_client_socket_pool.h"
158 if (transport_socket_handle_->socket())
314 ClientSocket* socket = transport_socket_handle_->socket(); local
[all...] |
| /external/chromium/net/tools/testserver/ |
| xmppserver.py | 16 import socket namespace
356 socket). It does the XMPP handshake and also implements the (old)
369 sock: The socket to the client.
380 # it does, and that calling dispatcher.__init__ with socket=None
493 self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
|
| /external/chromium/net/websockets/ |
| websocket_unittest.cc | 13 #include "net/socket/socket_test_util.h"
27 : event_type(type), socket(websocket), msg(websocket_msg),
31 net::WebSocket* socket; member in struct:WebSocketEvent
61 virtual void OnOpen(net::WebSocket* socket) {
63 WebSocketEvent(WebSocketEvent::EVENT_OPEN, socket,
69 virtual void OnMessage(net::WebSocket* socket, const std::string& msg) {
71 WebSocketEvent(WebSocketEvent::EVENT_MESSAGE, socket, msg, false));
75 virtual void OnError(net::WebSocket* socket) {
77 WebSocketEvent(WebSocketEvent::EVENT_ERROR, socket,
82 virtual void OnClose(net::WebSocket* socket, bool was_clean)
[all...] |
| /external/chromium/testing/gmock/scripts/ |
| upload.py | 42 import socket namespace
313 old_timeout = socket.getdefaulttimeout()
314 socket.setdefaulttimeout(timeout)
341 socket.setdefaulttimeout(old_timeout)
[all...] |
| /external/chromium/testing/gtest/scripts/ |
| upload.py | 42 import socket namespace
313 old_timeout = socket.getdefaulttimeout()
314 socket.setdefaulttimeout(timeout)
341 socket.setdefaulttimeout(old_timeout)
[all...] |
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| relayserver.h | 64 void AddInternalSocket(talk_base::AsyncPacketSocket* socket);
65 void RemoveInternalSocket(talk_base::AsyncPacketSocket* socket);
70 void AddExternalSocket(talk_base::AsyncPacketSocket* socket);
71 void RemoveExternalSocket(talk_base::AsyncPacketSocket* socket);
75 // internal socket will be added.
76 void AddInternalServerSocket(talk_base::AsyncSocket* socket,
79 // Removes this server socket from the list.
80 void RemoveInternalServerSocket(talk_base::AsyncSocket* socket);
104 void OnInternalPacket(talk_base::AsyncPacketSocket* socket,
107 void OnExternalPacket(talk_base::AsyncPacketSocket* socket,
155 talk_base::AsyncPacketSocket* socket() { return socket_; } function in class:cricket::RelayServerConnection
[all...] |
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/example/ |
| echo_client.py | 71 import socket namespace
130 def _receive_bytes(socket, length):
134 received_bytes = socket.recv(remaining)
187 self._ssl = socket.ssl(raw_socket)
287 def __init__(self, socket, options):
290 self._socket = socket
296 """Performs opening handshake on the specified socket.
494 def __init__(self, socket, options):
497 self._socket = socket
503 """Performs opening handshake on the specified socket
[all...] |
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/mod_pywebsocket/ |
| util.py | 55 import socket namespace
346 """A wrapper class for socket object to intercept send and recv to perform
353 def __init__(self, socket):
354 self._socket = socket
362 """Receives data from the socket specified on the construction up
435 # socket._fileobject.read also blocks until length bytes was read
460 # Set the socket non-blocking.
466 # Drain until the socket is closed or no data is immediately
474 except socket.error, e:
477 # the errors that indicates that the socket blocks. Thos
[all...] |
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
| mux_client_for_testing.py | 52 import socket namespace
508 self._socket = socket.socket()
|
| test_endtoend.py | 39 import socket namespace
170 s = socket.socket()
|
| /external/chromium_org/chrome/browser/devtools/ |
| android_device.cc | 68 net::StreamSocket* socket,
71 net::StreamSocket* socket,
73 void OnRead(net::StreamSocket* socket,
92 net::StreamSocket* socket = device_->CreateSocket(command); local
93 int result = socket->Connect(base::Bind(&UsbDeviceImpl::OpenedForCommand,
94 this, callback, socket));
103 net::StreamSocket* socket = device_->CreateSocket(socket_name); local
104 int result = socket->Connect(base::Bind(&UsbDeviceImpl::OnOpenSocket, this,
105 callback, socket));
111 net::StreamSocket* socket,
[all...] |
| devtools_adb_bridge.h | 19 #include "net/socket/tcp_client_socket.h"
42 // The format used for constructing DevTools server socket names.
90 const std::string& socket);
95 std::string socket() { return socket_; } function in class:DevToolsAdbBridge::RemoteBrowser
|
| /external/chromium_org/chrome/browser/extensions/api/cast_channel/ |
| cast_channel_api.cc | 80 void CastChannelAPI::OnError(const CastSocket* socket,
84 socket->FillChannelInfo(&channel_info);
89 DispatchEventToExtension(socket->owner_extension_id(), event.Pass());
92 void CastChannelAPI::OnMessage(const CastSocket* socket,
96 socket->FillChannelInfo(&channel_info);
103 DispatchEventToExtension(socket->owner_extension_id(), event.Pass());
124 CastSocket* socket = GetSocket(channel_id); local
125 if (!socket) {
129 return socket;
132 int CastChannelAsyncApiFunction::AddSocket(CastSocket* socket) {
148 CastSocket* socket = GetSocket(channel_id); local
196 scoped_ptr<CastSocket> socket = api_->CreateCastSocket(extension_->id(), local
220 CastSocket* socket = GetSocketOrCompleteWithError( local
248 CastSocket* socket = GetSocketOrCompleteWithError( local
[all...] |
| /external/chromium_org/chrome/browser/extensions/api/sockets_tcp_server/ |
| sockets_tcp_server_api.cc | 7 #include "chrome/browser/extensions/api/socket/tcp_socket.h"
22 const char kSocketNotFoundError[] = "Socket not found";
27 ResumableTCPServerSocket* socket) {
29 // This represents what we know about the socket, and does not call through
32 if (!socket->name().empty()) {
33 socket_info->name.reset(new std::string(socket->name()));
35 socket_info->persistent = socket->persistent();
36 socket_info->paused = socket->paused();
40 if (socket->GetLocalAddress(&localAddress)) {
49 void SetSocketProperties(ResumableTCPServerSocket* socket,
88 ResumableTCPServerSocket* socket = local
113 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local
141 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local
176 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local
220 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local
241 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local
262 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local
288 ResumableTCPServerSocket* socket = GetTcpSocket(socket_id); local
[all...] |
| /external/chromium_org/chrome/browser/local_discovery/ |
| service_discovery_host_client.cc | 11 #include "net/socket/socket_descriptor.h"
38 << "Can't create socket, family=" << interfaces[i].second;
40 LocalDiscoveryMsg_SocketInfo socket; local
41 socket.descriptor = socket_descriptor;
42 socket.interface_index = interfaces[i].first;
43 socket.address_family = interfaces[i].second;
44 sockets.push_back(socket);
|
| /external/chromium_org/chrome/common/mac/ |
| mock_launchd.cc | 8 #include <sys/socket.h>
212 CFSocketRef socket = local
215 local_pipe = CFSocketGetNative(socket);
|
| /external/chromium_org/chrome/test/pyautolib/ |
| remote_inspector_client.py | 46 import socket namespace
107 of socket communication.
123 socket messages sent/received when communicating with the remote
145 self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
181 """Called if a writable socket can be written; overridden from asyncore."""
199 """Called when a socket can be read; overridden from asyncore."""
241 """Called when the socket is closed; overridden from asyncore."""
244 'Socket closed.\n'
250 """Determines if writes can occur for this socket; overridden from asyncore
[all...] |
| /external/chromium_org/chrome/utility/local_discovery/ |
| service_discovery_message_handler.cc | 13 #include "net/socket/socket_descriptor.h"
20 void ClosePlatformSocket(net::SocketDescriptor socket);
22 // Sets socket factory used by |net::CreatePlatformSocket|. Implemetation
23 // keeps single socket that will be returned to the first call to
27 explicit ScopedSocketFactory(net::SocketDescriptor socket) : socket_(socket) {
52 SocketInfo(net::SocketDescriptor socket,
55 : socket(socket),
59 net::SocketDescriptor socket; member in struct:local_discovery::__anon7084::SocketInfo
[all...] |
| /external/chromium_org/google_apis/gcm/base/ |
| socket_stream_unittest.cc | 13 #include "net/socket/socket_test_util.h"
34 // Build a socket with the expected reads and writes.
52 net::StreamSocket* socket() { return socket_.get(); } function in class:gcm::__anon8486::GCMSocketStreamTest
302 socket()->Disconnect();
399 socket()->Disconnect();
|
| /external/chromium_org/google_apis/gcm/engine/ |
| connection_handler_impl_unittest.cc | 17 #include "net/socket/socket_test_util.h"
18 #include "net/socket/stream_socket.h"
336 // Build a new socket and reconnect, successfully this time.
527 // Finish the socket read. Should have no effect.
596 // Attempt to send a message after the socket is disconnected due to a timeout.
609 net::StreamSocket* socket = BuildSocket(read_list, write_list); local
616 socket->Disconnect();
|
| /external/chromium_org/net/dns/ |
| dns_session.cc | 19 #include "net/socket/stream_socket.h"
74 scoped_ptr<DatagramClientSocket> socket)
75 : session_(session), server_index_(server_index), socket_(socket.Pass()) {}
220 // Allocate a socket, already connected to the server address.
223 scoped_ptr<DatagramClientSocket> socket; local
225 socket = socket_pool_->AllocateSocket(server_index);
226 if (!socket.get())
229 socket->NetLog().BeginEvent(NetLog::TYPE_SOCKET_IN_USE,
232 SocketLease* lease = new SocketLease(this, server_index, socket.Pass());
241 // Release a socket
[all...] |
