| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| tcpport.h | 70 virtual int SetOption(talk_base::Socket::Option opt, int value);
79 // Handles sending using the local TCP socket.
84 void OnNewConnection(talk_base::AsyncPacketSocket* socket,
90 talk_base::AsyncPacketSocket* socket; member in struct:cricket::TCPPort::Incoming
96 // Receives packet signal from the local TCP Socket.
97 void OnReadPacket(talk_base::AsyncPacketSocket* socket,
101 void OnAddresReady(talk_base::AsyncPacketSocket* socket,
116 // Connection is outgoing unless socket is specified
118 talk_base::AsyncPacketSocket* socket = 0);
124 talk_base::AsyncPacketSocket* socket() { return socket_; function in class:cricket::TCPConnection
[all...] |
| /external/chromium_org/build/android/pylib/device/ |
| adb_wrapper_test.py | 8 import socket namespace
|
| /external/chromium_org/build/android/pylib/ |
| ports.py | 13 import socket namespace
96 # socket and closing it would leave it in the TIME_WAIT state. Setting
170 except (httplib.HTTPException, socket.error) as e:
|
| /external/chromium_org/chrome/browser/nacl_host/test/ |
| gdb_rsp.py | 8 import socket namespace
33 # On Mac OS X, we have to create a new socket FD for each retry.
34 sock = socket.socket()
37 except socket.error:
50 raise AssertionError('EOF on socket reached with '
|
| /external/chromium_org/chrome/test/chromedriver/server/ |
| server.py | 7 import socket namespace
49 socket.create_connection(('127.0.0.1', port), 0.2).close()
50 except socket.error:
|
| /external/chromium_org/chrome/test/pyautolib/ |
| remote_host.py | 9 import socket namespace
26 listening_socket = socket.socket()
27 listening_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
40 self._socket.shutdown(socket.SHUT_RDWR)
42 except socket.error:
57 """Receives a method call request over the socket and executes the method.
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/layout_tests/servers/ |
| apache_http_server.py | 35 import socket namespace
95 socket.getaddrinfo('::1', 0, 0, 0, 0, socket.AI_ADDRCONFIG)
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/mod_pywebsocket/ |
| _stream_base.py | 42 import socket namespace
121 except socket.error, e:
122 # Catch a socket.error. Because it's not a child class of the
127 'Receiving %d byte failed. socket.error (%s) occurred' %
|
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| proxy_unittest.cc | 38 using talk_base::Socket;
60 // Sets up a virtual socket server and HTTPS/SOCKS5 proxy servers.
95 talk_base::AsyncSocket* socket = local
98 new talk_base::AsyncSocksProxySocket(socket, kSocksProxyIntAddr,
110 EXPECT_EQ(Socket::CS_CONNECTING, proxy_socket->GetState());
112 EXPECT_EQ(Socket::CS_CONNECTED, proxy_socket->GetState());
122 AsyncSocket* socket = ss()->CreateAsyncSocket(SOCK_STREAM);
124 socket, "unittest/1.0", kHttpsProxyIntAddress, "", CryptString());
|
| socketstream.cc | 32 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) {
33 Attach(socket);
40 void SocketStream::Attach(AsyncSocket* socket) {
43 socket_ = socket;
53 AsyncSocket* socket = socket_; local
61 return socket;
67 case Socket::CS_CONNECTED:
69 case Socket::CS_CONNECTING:
71 case Socket::CS_CLOSED:
117 void SocketStream::OnConnectEvent(AsyncSocket* 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...] |
| 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.
90 void OnNewConnection(talk_base::AsyncPacketSocket* socket,
96 talk_base::AsyncPacketSocket* socket; member in struct:cricket::TCPPort::Incoming
102 // Receives packet signal from the local TCP Socket.
103 void OnReadPacket(talk_base::AsyncPacketSocket* socket,
108 void OnReadyToSend(talk_base::AsyncPacketSocket* socket);
110 void OnAddressReady(talk_base::AsyncPacketSocket* socket,
125 // Connection is outgoing unless socket is specifie
134 talk_base::AsyncPacketSocket* socket() { return socket_; } function in class:cricket::TCPConnection
[all...] |
| testturnserver.h | 71 // For TCP we need to create a server socket which can listen for incoming
73 talk_base::AsyncSocket* socket = local
75 socket->Bind(int_addr);
76 socket->Listen(5);
77 server_.AddInternalServerSocket(socket, proto);
|
| /external/chromium_org/tools/gyp/pylib/gyp/ |
| MSVSUserFile.py | 9 import socket # for gethostname namespace
103 'RemoteMachine': socket.gethostname(),
|
| /external/chromium_org/tools/site_compare/utils/ |
| browser_iterate.py | 23 import socket namespace
83 """Invoke the browser process and connect to the socket."""
88 # Try to connect the socket. If it fails, wait and try
90 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM, socket.IPPROTO_TCP)
95 except socket.error:
102 except socket.error
[all...] |
| /external/chromium_org/tools/telemetry/telemetry/core/backends/chrome/ |
| websocket_browser_connection.py | 7 import socket namespace
40 except (socket.error, websocket.WebSocketException):
51 def socket(self): member in class:WebSocketBrowserConnection
52 """Returns the socket for raw access. Please be sure you know what
|
| /external/chromium_org/tools/telemetry/telemetry/core/ |
| util.py | 7 import socket namespace
119 tmp = socket.socket()
|
| /external/chromium_org/v8/tools/testrunner/server/ |
| local_handler.py | 29 import socket namespace
38 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
| status_handler.py | 29 import socket namespace
37 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
| /external/srtp/include/ |
| rtp_priv.h | 61 int socket; member in struct:rtp_sender_ctx_t
68 int socket; member in struct:rtp_receiver_ctx_t
|
| /frameworks/opt/net/voip/src/jni/rtp/ |
| RtpStream.cpp | 22 #include <sys/socket.h>
48 int socket = ::socket(ss.ss_family, SOCK_DGRAM, 0); local
50 if (socket == -1 || bind(socket, (sockaddr *)&ss, sizeof(ss)) != 0 ||
51 getsockname(socket, (sockaddr *)&ss, &len) != 0) {
53 ::close(socket);
61 env->SetIntField(thiz, gSocket, socket);
64 ::close(socket);
66 socket = ::socket(ss.ss_family, SOCK_DGRAM, 0)
91 int socket = env->GetIntField(thiz, gSocket); local
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/nio/tests/java/nio/channels/ |
| MockServerSocketChannel.java | 32 public ServerSocket socket() { method in class:MockServerSocketChannel
|
| /libcore/luni/src/main/java/java/nio/channels/ |
| DatagramChannel.java | 29 * abstraction of a datagram socket. The {@code socket} method of this class can
31 * socket.
83 * Returns the related datagram socket of this channel, which does not
89 public abstract DatagramSocket socket(); method in class:DatagramChannel
92 * Returns whether this channel's socket is connected or not.
94 * @return <code>true</code> if this channel's socket is connected;
100 * Connects the socket of this channel to a remote address, which is the
131 * Disconnects the socket of this channel, which has been connected before
136 * socket is not connected or the channel is closed
[all...] |
| SocketChannel.java | 21 import java.net.Socket;
29 * abstraction of stream connecting socket. {@code socket()} returns the related
30 * {@link Socket} instance which can handle the socket.
32 * A socket channel is open but not connected when created by {@code open()}.
38 * blocked or not; {@code isConnected()} indicates if the socket is finally
52 * Socket channels are thread-safe, no more than one thread can read or write at
71 * Creates an open and unconnected socket channel.
85 * Creates a socket channel and connects it to a socket address
134 public abstract Socket socket(); method in class:SocketChannel
[all...] |
| /libcore/support/src/test/java/org/apache/harmony/xnet/tests/support/ |
| SSLSocketFactoryImpl.java | 6 import java.net.Socket;
17 public Socket createSocket(Socket socket, String s, int i, boolean flag)
19 if (socket == null) {
20 throw new IOException("incorrect socket");
30 socket = new Socket(s, i);
32 socket = new Socket(s, i)
[all...] |
