| /external/chromium_org/device/bluetooth/ |
| bluetooth_adapter_win.cc | 169 scoped_refptr<BluetoothSocketWin> socket = local
172 socket->Listen(this, uuid, options,
173 base::Bind(callback, socket),
|
| /external/chromium_org/extensions/browser/api/sockets_tcp_server/ |
| sockets_tcp_server_api.cc | 8 #include "extensions/browser/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
143 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local
180 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local
221 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local
242 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local
263 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local
288 ResumableTCPServerSocket* socket = GetTcpSocket(socket_id); local
[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::__anon12991::GCMSocketStreamTest
302 socket()->Disconnect();
399 socket()->Disconnect();
|
| /external/chromium_org/media/audio/win/ |
| audio_output_win_unittest.cc | 562 SyncSocketSource(base::SyncSocket* socket, const AudioParameters& params)
563 : socket_(socket) {
564 // Setup AudioBus wrapping data we'll receive over the sync socket.
599 base::SyncSocket* socket; member in struct:media::SyncThreadContext
616 // Setup AudioBus wrapping data we'll pass over the sync socket.
628 if (ctx.socket->Receive(&buffers_state, sizeof(buffers_state)) == 0)
632 ctx.socket->Send(data.get(), ctx.packet_size_bytes);
677 thread_context.socket = &sockets[1];
|
| /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...] |
| /external/chromium_org/net/socket/ |
| client_socket_handle.h | 22 #include "net/socket/client_socket_pool.h"
23 #include "net/socket/stream_socket.h"
31 // client socket objects.
36 UNUSED = 0, // unused socket that just finished connecting
37 UNUSED_IDLE, // unused socket that has been idle for awhile
38 REUSED_IDLE, // previously used socket
46 // ClientSocketPool to obtain a connected socket, possibly reusing one. This
50 // If this method succeeds, then the socket member will be set to an existing
51 // connected socket if an existing connected socket was available to reuse
155 StreamSocket* socket() { return socket_.get(); } function in class:net::ClientSocketHandle
[all...] |
| websocket_transport_client_socket_pool.cc | 5 #include "net/socket/websocket_transport_client_socket_pool.h"
17 #include "net/socket/client_socket_handle.h"
18 #include "net/socket/client_socket_pool_base.h"
19 #include "net/socket/websocket_endpoint_lock_manager.h"
20 #include "net/socket/websocket_transport_connect_sub_job.h"
70 // available socket" implies that nothing is happening.
264 DCHECK(handle->socket());
266 if (handle->socket()->GetPeerAddress(&address) == OK)
369 scoped_ptr<StreamSocket> socket = handle->PassSocket();
370 if (socket)
472 scoped_ptr<StreamSocket> socket = job->PassSocket(); local
[all...] |
| /external/chromium_org/net/tools/testserver/ |
| testserver_base.py | 11 import socket namespace
79 if isinstance(value, socket.error):
104 self.socket.close()
|
| /external/chromium_org/net/udp/ |
| udp_socket_unittest.cc | 34 // Blocks until data is read from the socket.
35 std::string RecvFromSocket(UDPServerSocket* socket) {
38 int rv = socket->RecvFrom(
47 // Loop until |msg| has been written to the socket or until an
50 // to send to. Otherwise, will send to the last socket this server
52 int SendToSocket(UDPServerSocket* socket, std::string msg) {
53 return SendToSocket(socket, msg, recv_from_address_);
56 int SendToSocket(UDPServerSocket* socket,
68 int rv = socket->SendTo(
80 std::string ReadSocket(UDPClientSocket* socket) {
304 UDPClientSocket* socket = local
[all...] |
| /external/chromium_org/ppapi/tests/ |
| test_tcp_socket.cc | 70 pp::TCPSocket socket(instance_);
73 cb.WaitForResult(socket.Connect(addr_, cb.GetCallback()));
78 local_addr = socket.GetLocalAddress();
79 remote_addr = socket.GetRemoteAddress();
85 socket.Close();
89 // Connect a bound socket.
90 pp::TCPSocket socket(instance_);
96 cb.WaitForResult(socket.Bind(any_port_address, cb.GetCallback()));
100 cb.WaitForResult(socket.Connect(addr_, cb.GetCallback()));
105 local_addr = socket.GetLocalAddress()
317 PP_Resource socket = socket_interface_1_0_->Create(instance_->pp_instance()); local
[all...] |
| /external/chromium_org/sync/tools/testserver/ |
| sync_testserver.py | 18 import socket namespace
58 except socket.error:
|
| xmppserver.py | 15 import socket namespace
368 socket). It does the XMPP handshake and also implements the (old)
381 sock: The socket to the client.
392 # it does, and that calling dispatcher.__init__ with socket=None
517 self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
|
| /external/chromium_org/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_org/third_party/WebKit/Tools/Scripts/webkitpy/performance_tests/ |
| perftest.py | 37 import socket namespace
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/coverage/ |
| control.py | 3 import atexit, os, random, socket, sys namespace
165 for m in (atexit, os, random, socket):
190 self.socket = socket
455 self.socket.gethostname(), self.os.getpid(),
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/mod_pywebsocket/ |
| util.py | 55 import socket namespace
373 """A wrapper class for socket object to intercept send and recv to perform
380 def __init__(self, socket):
381 self._socket = socket
389 """Receives data from the socket specified on the construction up
|
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| relayport_unittest.cc | 80 void OnReadPacket(rtc::AsyncPacketSocket* socket,
84 received_packet_count_[socket]++;
106 // The relay server needs an external socket to work properly.
128 // Add a UDP socket to the relay server.
167 // Create a server socket for the RelayServer.
200 // Create a ssl server socket for the RelayServer.
206 // Create a tcp server socket that listens on the fake address so
233 rtc::AsyncSocket* socket = local
236 rtc::AsyncUDPSocket::Create(socket, addr);
243 rtc::AsyncSocket* socket local
[all...] |
| relayserver.h | 64 void AddInternalSocket(rtc::AsyncPacketSocket* socket);
65 void RemoveInternalSocket(rtc::AsyncPacketSocket* socket);
70 void AddExternalSocket(rtc::AsyncPacketSocket* socket);
71 void RemoveExternalSocket(rtc::AsyncPacketSocket* socket);
75 // internal socket will be added.
76 void AddInternalServerSocket(rtc::AsyncSocket* socket,
79 // Removes this server socket from the list.
80 void RemoveInternalServerSocket(rtc::AsyncSocket* socket);
105 void OnInternalPacket(rtc::AsyncPacketSocket* socket,
109 void OnExternalPacket(rtc::AsyncPacketSocket* socket,
158 rtc::AsyncPacketSocket* socket() { return socket_; } function in class:cricket::RelayServerConnection
[all...] |
| turnport_unittest.cc | 171 void OnSocketReadPacket(rtc::AsyncPacketSocket* socket,
175 turn_port_->HandleIncomingPacket(socket, data, size, remote_addr,
179 rtc::AsyncSocket* socket = ss_->CreateAsyncSocket(SOCK_STREAM); local
180 EXPECT_GE(socket->Bind(addr), 0);
181 EXPECT_GE(socket->Listen(5), 0);
182 return socket;
362 EXPECT_EQ(0, turn_port_->SetOption(rtc::Socket::OPT_SNDBUF, 10*1024));
375 EXPECT_EQ(0, turn_port_->SetOption(rtc::Socket::OPT_SNDBUF, 10*1024));
384 // Testing turn port will attempt to create TCP socket on address resolution
394 // will proceed in creating a TCP socket which will fail as there is n
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/session/tunnel/ |
| pseudotcpchannel.cc | 137 channel_->SetOption(Socket::OPT_DONTFRAGMENT, 1);
379 Socket* socket = local
381 rtc::scoped_ptr<Socket> mtu_socket(socket);
382 if (socket == NULL) {
383 LOG_F(LS_WARNING) << "Couldn't create socket while estimating MTU.";
|
| /external/chromium_org/third_party/tlslite/tests/ |
| tlstest.py | 16 import socket namespace
88 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
253 connection.sock.close() #Close the socket without a close_notify!
266 if hasattr(socket, "timeout"):
267 timeoutEx = socket.timeout
269 timeoutEx = socket.error
422 except socket.error as e
[all...] |
| /external/chromium_org/third_party/tlslite/tlslite/ |
| tlsconnection.py | 14 import socket namespace
126 This class wraps a socket and provides TLS handshaking and data
130 socket into the constructor. Then call some handshake function.
133 connection as if it were a socket.
151 @param sock: The socket data will be transmitted on. The
152 socket should already be connected. It may be in blocking or
155 @type sock: L{socket.socket}
203 return 0 if it is waiting to read from the socket, 1 if it is
204 waiting to write to the socket, or will raise StopIteration i
[all...] |
| tlsrecordlayer.py | 21 import socket namespace
48 @type sock: socket.socket
49 @ivar sock: The underlying socket object.
76 @ivar closeSocket: If the socket should be closed when the
80 closing the socket when the TLS Connection is shutdown (either
85 @ivar ignoreAbruptClose: If an abrupt close of the socket should
90 socket is unexpectedly closed. Such an unexpected closure could be
140 #On a call to close(), do we close the socket? (writeable)
143 #If the socket is abruptly closed, do we ignore i
[all...] |
| /external/chromium_org/third_party/webrtc/base/ |
| nat_unittest.cc | 35 AsyncUDPSocket* socket = AsyncUDPSocket::Create(factory, local_addr); local
36 return new TestClient(socket);
182 const char* buf = "hello other socket";
305 void OnConnectEvent(AsyncSocket* socket) {
308 void OnAcceptEvent(AsyncSocket* socket) {
311 void OnCloseEvent(AsyncSocket* socket, int error) {
|
| ssladapter_unittest.cc | 26 rtc::AsyncSocket* socket = rtc::Thread::Current()-> local
30 socket->Bind(address);
32 return socket;
43 rtc::AsyncSocket* socket = CreateSocket(ssl_mode_); local
45 ssl_adapter_.reset(rtc::SSLAdapter::Create(socket));
89 void OnSSLAdapterReadEvent(rtc::AsyncSocket* socket) {
93 int read = socket->Recv(buffer, sizeof(buffer) - 1);
103 void OnSSLAdapterCloseEvent(rtc::AsyncSocket* socket, int error) {
105 // closing the socket! Let's close the socket here. This way GetState() ca
[all...] |
