/external/chromium-trace/trace-viewer/src/tracing/importer/ |
H A D | timeline_stream_importer_test.js | 54 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 D | test_tcp_socket_private.cc | 61 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 D | test_tcp_socket.h | 35 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 D | udp.h | 39 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 D | udp.h | 41 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 D | mdns_client.cc | 29 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 D | server.js | 5 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 D | asyncstuntcpsocket.h | 39 // 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 D | tcpport.cc | 53 // 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 D | asyncudpsocket.cc | 19 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 D | command.h | 36 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 D | sockets_tcp_api.cc | 9 #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 D | socket_api.cc | 5 #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 D | if_caif.h | 11 #include <linux/socket.h>
|
/external/kernel-headers/original/uapi/linux/ |
H A D | if_pppopns.h | 21 #include <linux/socket.h>
|
H A D | net.h | 21 #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 D | fdleak_socketpair.c | 1 #include <sys/socket.h>
|
/external/chromium_org/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/ |
H A D | TestUtils.java | 18 * 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 D | deSocket.h | 119 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 D | mtu.c | 22 #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 D | rbug_connection.c | 32 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 D | rbug_connection.c | 32 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 D | buflen_check.c | 1 #include <sys/socket.h> 11 res1 = socket(PF_UNIX, SOCK_STREAM, 0); 13 fprintf(stderr, "socket() failed\n");
|
/external/chromium_org/base/ |
H A D | async_socket_io_handler_posix.cc | 24 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 D | gnubby_auth_handler_posix.h | 13 #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...] |