Searched refs:socket (Results 51 - 75 of 1466) sorted by relevance

1234567891011>>

/external/chromium-trace/trace-viewer/src/tracing/importer/
H A Dtimeline_stream_importer_test.js54 called on the socket.
89 var socket = new FakeWebSocket();
90 importer.connect(socket);
92 socket.connected = true;
95 socket.pushMessage({
106 socket.dispatchAllPendingMessages();
123 var socket = new FakeWebSocket();
124 importer.connect(socket);
125 socket.connected = true;
128 socket
[all...]
/external/chromium_org/ppapi/tests/
H A Dtest_tcp_socket_private.cc61 pp::TCPSocketPrivate socket(instance_);
64 cb.WaitForResult(socket.Connect(host_.c_str(), port_, cb.GetCallback()));
70 ASSERT_TRUE(socket.GetLocalAddress(&unused));
71 ASSERT_TRUE(socket.GetRemoteAddress(&unused));
73 socket.Disconnect();
79 pp::TCPSocketPrivate socket(instance_);
82 cb.WaitForResult(socket.Connect(host_.c_str(), port_, cb.GetCallback()));
86 ASSERT_EQ(PP_OK, WriteStringToSocket(&socket, "GET / HTTP/1.0\r\n\r\n"));
90 ASSERT_EQ(PP_OK, ReadFirstLineFromSocket(&socket, &s));
93 socket
216 ReadFirstLineFromSocket( pp::TCPSocketPrivate* socket, std::string* s) argument
243 WriteStringToSocket(pp::TCPSocketPrivate* socket, const std::string& s) argument
[all...]
H A Dtest_tcp_socket.h35 std::string ReadFirstLineFromSocket(pp::TCPSocket* socket, std::string* s);
36 std::string ReadFirstLineFromSocket_1_0(PP_Resource socket,
38 std::string ReadFromSocket(pp::TCPSocket* socket,
41 std::string WriteToSocket(pp::TCPSocket* socket, const std::string& s);
42 std::string WriteToSocket_1_0(PP_Resource socket, const std::string& s);
45 std::string StartListen(pp::TCPSocket* socket, int32_t backlog);
/external/qemu/slirp/
H A Dudp.h39 extern struct socket *udp_last_so;
77 u_long udps_noport; /* no socket on port */
79 u_long udps_fullsock; /* not delivered, input socket full */
96 extern struct socket udb;
101 int udp_output _P((struct socket *, struct mbuf *, struct sockaddr_in *));
102 int udp_attach _P((struct socket *));
103 void udp_detach _P((struct socket *));
104 struct socket * udp_listen _P((u_int, u_int32_t, u_int, int));
105 int udp_output2(struct socket *so, struct mbuf *m,
/external/qemu/slirp-android/
H A Dudp.h41 extern struct socket *udp_last_so;
78 u_long udps_noport; /* no socket on port */
80 u_long udps_fullsock; /* not delivered, input socket full */
94 extern struct socket udb;
99 int udp_output_ _P((struct socket *, struct mbuf *, SockAddress *));
100 int udp_attach _P((struct socket *));
101 void udp_detach _P((struct socket *));
102 struct socket * udp_listen _P((u_int, u_int32_t, u_int, int));
105 int udp_output2_(struct socket *so, struct mbuf *m,
/external/chromium_org/net/dns/
H A Dmdns_client.cc29 DatagramServerSocket* socket) {
33 socket->AllowAddressReuse();
34 socket->SetMulticastInterface(interface_index);
36 int rv = socket->Listen(bind_endpoint);
40 return socket->JoinGroup(multicast_addr.address());
89 scoped_ptr<DatagramServerSocket> socket(
93 int rv = Bind(multicast_addr, interface_index, socket.get());
95 socket.reset();
99 return socket.PassAs<DatagramServerSocket>();
27 Bind(const IPEndPoint& multicast_addr, uint32 interface_index, DatagramServerSocket* socket) argument
/external/chromium_org/chrome/test/ext_auto/auto_provider/
H A Dserver.js5 var socket = chrome.experimental.socket || chrome.socket; variable
7 // Stream encapsulates read/write operations over socket.
25 socket.read(this.socketId_, function(readInfo) {
35 socket.write(this.socketId_, outputBuffer, function(writeInfo) {
49 socket.write(this.socketId_, outputBuffer, function(writeInfo) {
56 socket.destroy(this.socketId_);
60 // Automation server listens socket and passed its processing to
78 console.log("Accepting socket "
[all...]
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/
H A Dasyncstuntcpsocket.h39 // Binds and connects |socket| and creates AsyncTCPSocket for
40 // it. Takes ownership of |socket|. Returns NULL if bind() or
41 // connect() fail (|socket| is destroyed in that case).
43 rtc::AsyncSocket* socket,
47 AsyncStunTCPSocket(rtc::AsyncSocket* socket, bool listen);
53 virtual void HandleIncomingConnection(rtc::AsyncSocket* socket);
H A Dtcpport.cc53 // Treat failure to create or bind a TCP socket as fatal. This
59 LOG_J(LS_ERROR, this) << "TCP socket creation failed.";
72 delete it->socket;
110 if (rtc::AsyncPacketSocket* socket =
112 socket->SignalReadPacket.disconnect(this);
113 conn = new TCPConnection(this, address, socket);
123 // If socket isn't bound yet the address will be added in
125 // failed, we still want to add the socket address.
149 rtc::AsyncPacketSocket * socket = NULL; local
151 socket
190 OnNewConnection(rtc::AsyncPacketSocket* socket, rtc::AsyncPacketSocket* new_socket) argument
207 rtc::AsyncPacketSocket* socket = NULL; local
220 OnReadPacket(rtc::AsyncPacketSocket* socket, const char* data, size_t size, const rtc::SocketAddress& remote_addr, const rtc::PacketTime& packet_time) argument
227 OnReadyToSend(rtc::AsyncPacketSocket* socket) argument
231 OnAddressReady(rtc::AsyncPacketSocket* socket, const rtc::SocketAddress& address) argument
238 TCPConnection(TCPPort* port, const Candidate& candidate, rtc::AsyncPacketSocket* socket) argument
301 OnConnect(rtc::AsyncPacketSocket* socket) argument
318 OnClose(rtc::AsyncPacketSocket* socket, int error) argument
325 OnReadPacket( rtc::AsyncPacketSocket* socket, const char* data, size_t size, const rtc::SocketAddress& remote_addr, const rtc::PacketTime& packet_time) argument
333 OnReadyToSend(rtc::AsyncPacketSocket* socket) argument
[all...]
/external/chromium_org/third_party/webrtc/base/
H A Dasyncudpsocket.cc19 AsyncSocket* socket,
21 scoped_ptr<AsyncSocket> owned_socket(socket);
22 if (socket->Bind(bind_address) < 0) {
23 LOG(LS_ERROR) << "Bind() failed with error " << socket->GetError();
31 AsyncSocket* socket = local
33 if (!socket)
35 return Create(socket, bind_address);
38 AsyncUDPSocket::AsyncUDPSocket(AsyncSocket* socket) argument
39 : socket_(socket) {
44 // The socket shoul
18 Create( AsyncSocket* socket, const SocketAddress& bind_address) argument
96 OnReadEvent(AsyncSocket* socket) argument
118 OnWriteEvent(AsyncSocket* socket) argument
[all...]
/external/chromium_org/tools/android/forwarder2/
H A Dcommand.h36 bool ReadCommand(Socket* socket,
40 // Helper function to read the command from the |socket| and return true if the
42 bool ReceivedCommand(command::Type command, Socket* socket);
44 bool SendCommand(command::Type command, int port, Socket* socket);
/external/chromium_org/extensions/browser/api/sockets_tcp/
H A Dsockets_tcp_api.cc9 #include "extensions/browser/api/socket/tcp_socket.h"
10 #include "extensions/browser/api/socket/tls_socket.h"
26 "Socket must be a connected client TCP socket.";
30 ResumableTCPSocket* socket) {
32 // This represents what we know about the socket, and does not call through
35 if (!socket->name().empty()) {
36 socket_info->name.reset(new std::string(socket->name()));
38 socket_info->persistent = socket->persistent();
39 if (socket->buffer_size() > 0) {
40 socket_info->buffer_size.reset(new int(socket
29 CreateSocketInfo(int socket_id, ResumableTCPSocket* socket) argument
67 SetSocketProperties(ResumableTCPSocket* socket, SocketProperties* properties) argument
126 ResumableTCPSocket* socket = new ResumableTCPSocket(extension_->id()); local
149 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); local
178 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); local
206 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); local
232 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); local
264 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); local
294 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); local
329 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); local
352 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); local
398 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); local
419 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); local
444 ResumableTCPSocket* socket = GetTcpSocket(socket_id); local
472 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); local
529 TlsConnectDone(scoped_ptr<TLSSocket> socket, int result) argument
[all...]
/external/chromium_org/extensions/browser/api/socket/
H A Dsocket_api.cc5 #include "extensions/browser/api/socket/socket_api.h"
14 #include "extensions/browser/api/socket/socket.h"
15 #include "extensions/browser/api/socket/tcp_socket.h"
16 #include "extensions/browser/api/socket/tls_socket.h"
17 #include "extensions/browser/api/socket/udp_socket.h"
47 "TCP socket does not support bind. For TCP server please use listen.";
48 const char kMulticastSocketTypeError[] = "Only UDP socket supports multicast.";
71 int SocketAsyncApiFunction::AddSocket(Socket* socket) { argument
72 return manager_->Add(socket);
79 ReplaceSocket(int api_resource_id, Socket* socket) argument
166 Socket* socket = NULL; local
261 Socket* socket = GetSocket(socket_id_); local
278 Socket* socket = GetSocket(socket_id_); local
318 Socket* socket = GetSocket(params_->socket_id); local
352 Socket* socket = GetSocket(params_->socket_id); local
361 OnAccept(int result_code, net::TCPClientSocket* socket) argument
385 Socket* socket = GetSocket(params_->socket_id); local
428 Socket* socket = GetSocket(socket_id_); local
460 Socket* socket = GetSocket(params_->socket_id); local
573 Socket* socket = GetSocket(params_->socket_id); local
597 Socket* socket = GetSocket(params_->socket_id); local
616 Socket* socket = GetSocket(params_->socket_id); local
720 Socket* socket = GetSocket(params_->socket_id); local
764 Socket* socket = GetSocket(params_->socket_id); local
806 Socket* socket = GetSocket(params_->socket_id); local
840 Socket* socket = GetSocket(params_->socket_id); local
872 Socket* socket = GetSocket(params_->socket_id); local
921 Socket* socket = GetSocket(params_->socket_id); local
958 TlsConnectDone(scoped_ptr<TLSSocket> socket, int result) argument
[all...]
/external/kernel-headers/original/uapi/linux/caif/
H A Dif_caif.h11 #include <linux/socket.h>
/external/kernel-headers/original/uapi/linux/
H A Dif_pppopns.h21 #include <linux/socket.h>
H A Dnet.h21 #include <linux/socket.h>
22 #include <asm/socket.h>
49 SS_UNCONNECTED, /* unconnected to any socket */
51 SS_CONNECTED, /* connected to socket */
/external/valgrind/main/none/tests/
H A Dfdleak_socketpair.c1 #include <sys/socket.h>
/external/chromium_org/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/
H A DTestUtils.java18 * Utilities to testing a socket tunnel.
23 // Sends |request| string to UNIX socket socketName on another thread and returns
32 LocalSocket socket = new LocalSocket();
33 socket.connect(new LocalSocketAddress(socketName));
34 writeAndShutdown(socket, request);
36 String response = readAll(socket);
37 socket.close();
45 public static void writeAndShutdown(LocalSocket socket, String data) throws IOException { argument
46 socket.getOutputStream().write(data.getBytes(CHARSET));
47 socket
52 readAll(LocalSocket socket) argument
[all...]
/external/deqp/framework/delibs/deutil/
H A DdeSocket.h119 void deSocket_destroy (deSocket* socket);
121 deSocketState deSocket_getState (const deSocket* socket);
122 deUint32 deSocket_getOpenChannels (const deSocket* socket);
124 deBool deSocket_setFlags (deSocket* socket, deUint32 flags);
126 deBool deSocket_listen (deSocket* socket, const deSocketAddress* address);
127 deSocket* deSocket_accept (deSocket* socket, deSocketAddress* clientAddress);
129 deBool deSocket_connect (deSocket* socket, const deSocketAddress* address);
131 deBool deSocket_shutdown (deSocket* socket, deUint32 channels);
132 deBool deSocket_close (deSocket* socket);
134 deSocketResult deSocket_send (deSocket* socket, cons
[all...]
/external/android-clat/
H A Dmtu.c22 #include <sys/socket.h>
36 fd = socket(AF_INET, SOCK_STREAM, 0);
/external/chromium_org/third_party/mesa/src/src/gallium/auxiliary/rbug/
H A Drbug_connection.c32 int socket; member in struct:rbug_connection
39 * Create a rbug connection from a socket created with u_socket.
42 * A new allocated connection using socket as communication path
45 rbug_from_socket(int socket) argument
48 c->socket = socket;
53 * Free a connection, also closes socket.
58 u_socket_close(c->socket);
80 ret = u_socket_peek(c->socket, &header, sizeof(header));
94 ret = u_socket_recv(c->socket, pt
[all...]
/external/mesa3d/src/gallium/auxiliary/rbug/
H A Drbug_connection.c32 int socket; member in struct:rbug_connection
39 * Create a rbug connection from a socket created with u_socket.
42 * A new allocated connection using socket as communication path
45 rbug_from_socket(int socket) argument
48 c->socket = socket;
53 * Free a connection, also closes socket.
58 u_socket_close(c->socket);
80 ret = u_socket_peek(c->socket, &header, sizeof(header));
94 ret = u_socket_recv(c->socket, pt
[all...]
/external/valgrind/main/memcheck/tests/
H A Dbuflen_check.c1 #include <sys/socket.h>
11 res1 = socket(PF_UNIX, SOCK_STREAM, 0);
13 fprintf(stderr, "socket() failed\n");
/external/chromium_org/base/
H A Dasync_socket_io_handler_posix.cc24 void AsyncSocketIoHandler::OnFileCanReadWithoutBlocking(int socket) { argument
26 DCHECK_EQ(socket, socket_);
37 // We're getting notifications that we can read from the socket while
67 bool AsyncSocketIoHandler::Initialize(base::SyncSocket::Handle socket, argument
73 socket_ = socket;
77 int value = fcntl(socket, F_GETFL);
79 // Set the socket to be non-blocking so we can do async reads.
80 if (fcntl(socket, F_SETFL, O_NONBLOCK) == -1) {
/external/chromium_org/remoting/host/
H A Dgnubby_auth_handler_posix.h13 #include "net/socket/stream_listen_socket.h"
35 bool HasActiveSocketForTesting(net::StreamListenSocket* socket) const;
36 int GetConnectionIdForTesting(net::StreamListenSocket* socket) const;
38 net::StreamListenSocket* socket) const;
50 scoped_ptr<net::StreamListenSocket> socket) OVERRIDE;
51 virtual void DidRead(net::StreamListenSocket* socket,
54 virtual void DidClose(net::StreamListenSocket* socket) OVERRIDE;
56 // Create socket for authorization.
62 // Gets an active socket iterator for the connection id in |message|.
65 // Send an error and close an active socket
[all...]

Completed in 3045 milliseconds

1234567891011>>