/external/chromium/net/websockets/ |
H A D | websocket_job_unittest.cc | 60 virtual void OnConnected(SocketStream* socket, int max_pending_send_allowed) { argument 62 virtual void OnSentData(SocketStream* socket, int amount_sent) { argument 65 virtual void OnReceivedData(SocketStream* socket, argument 69 virtual void OnClose(SocketStream* socket) { argument
|
/external/chromium/third_party/libjingle/source/talk/base/ |
H A D | openssladapter.cc | 60 "socket", 73 BIO* BIO_new_socket(talk_base::AsyncSocket* socket) { argument 78 ret->ptr = socket; 85 b->num = 0; // 1 means socket closed 99 talk_base::AsyncSocket* socket = static_cast<talk_base::AsyncSocket*>(b->ptr); 101 int result = socket->Recv(out, outl); 106 } else if (socket->IsBlocking()) { 115 talk_base::AsyncSocket* socket = static_cast<talk_base::AsyncSocket*>(b->ptr); 117 int result = socket->Send(in, inl); 120 } else if (socket 237 OpenSSLAdapter(AsyncSocket* socket) argument 536 OnConnectEvent(AsyncSocket* socket) argument 551 OnReadEvent(AsyncSocket* socket) argument 581 OnWriteEvent(AsyncSocket* socket) argument 612 OnCloseEvent(AsyncSocket* socket, int err) argument [all...] |
H A D | schanneladapter.cc | 108 SChannelAdapter::SChannelAdapter(AsyncSocket* socket) argument 109 : SSLAdapter(socket), state_(SSL_NONE), 610 // socket api doesn't support nice shutdown at this point, we don't bother. 632 SChannelAdapter::OnConnectEvent(AsyncSocket* socket) { argument 636 AsyncSocketAdapter::OnConnectEvent(socket); 647 SChannelAdapter::OnReadEvent(AsyncSocket* socket) { argument 649 AsyncSocketAdapter::OnReadEvent(socket); 675 SChannelAdapter::OnWriteEvent(AsyncSocket* socket) { argument 677 AsyncSocketAdapter::OnWriteEvent(socket); 692 AsyncSocketAdapter::OnWriteEvent(socket); 697 OnCloseEvent(AsyncSocket* socket, int err) argument [all...] |
H A D | win32socketserver.cc | 82 description = "Using a non-blocking socket, will notify later"; 293 LOG(LS_WARNING) << "GetLocalAddress: unable to get local addr, socket=" 310 LOG(LS_WARNING) << "GetRemoteAddress: unable to get remote addr, socket=" 474 Win32Socket* socket = new Win32Socket; local 475 if (0 == socket->Attach(s)) 476 return socket; 477 delete socket; 597 void Win32Socket::OnSocketNotify(SOCKET socket, int event, int error) { argument 599 if (socket != socket_) 715 Win32Socket* socket local [all...] |
/external/chromium/third_party/libjingle/source/talk/p2p/base/ |
H A D | relayserver.cc | 51 // Calls SendTo on the given socket and logs any bad results. 52 void Send(talk_base::AsyncPacketSocket* socket, const char* bytes, size_t size, argument 54 int result = socket->SendTo(bytes, size, addr); 63 // Sends the given STUN message on the given socket. 65 talk_base::AsyncPacketSocket* socket, 69 Send(socket, buf.Data(), buf.Length(), addr); 72 // Constructs a STUN error response and sends it on the given socket. 73 void SendStunError(const StunMessage& msg, talk_base::AsyncPacketSocket* socket, argument 94 SendStun(err_msg, socket, remote_addr); 110 talk_base::AsyncSocket* socket local 64 SendStun(const StunMessage& msg, talk_base::AsyncPacketSocket* socket, const talk_base::SocketAddress& addr) argument 116 AddInternalSocket(talk_base::AsyncPacketSocket* socket) argument 123 RemoveInternalSocket(talk_base::AsyncPacketSocket* socket) argument 131 AddExternalSocket(talk_base::AsyncPacketSocket* socket) argument 138 RemoveExternalSocket(talk_base::AsyncPacketSocket* socket) argument 146 AddInternalServerSocket(talk_base::AsyncSocket* socket, cricket::ProtocolType proto) argument 154 RemoveInternalServerSocket( talk_base::AsyncSocket* socket) argument 188 OnReadEvent(talk_base::AsyncSocket* socket) argument 194 OnInternalPacket( talk_base::AsyncPacketSocket* socket, const char* bytes, size_t size, const talk_base::SocketAddress& remote_addr) argument 241 OnExternalPacket( talk_base::AsyncPacketSocket* socket, const char* bytes, size_t size, const talk_base::SocketAddress& remote_addr) argument 312 HandleStun( const char* bytes, size_t size, const talk_base::SocketAddress& remote_addr, talk_base::AsyncPacketSocket* socket, std::string* username, StunMessage* msg) argument 341 HandleStunAllocate( const char* bytes, size_t size, const talk_base::SocketAddressPair& ap, talk_base::AsyncPacketSocket* socket) argument 494 talk_base::AsyncPacketSocket* socket = external_sockets_[0]; local 558 talk_base::AsyncSocket* socket = local 592 RelayServerConnection( RelayServerBinding* binding, const talk_base::SocketAddressPair& addrs, talk_base::AsyncPacketSocket* socket) argument [all...] |
H A D | relayport.cc | 38 // How long to wait for a socket to connect to remote host in milliseconds 47 talk_base::AsyncPacketSocket* socket, 50 talk_base::AsyncPacketSocket* socket() const { return socket_; } function in class:cricket::RelayConnection 75 // Return the latest error generated by the socket. 78 // Called on behalf of a StunRequest to write data to the socket. This is 106 // Returns the last error on the socket of this entry. 121 RelayConnection* socket); 123 // Sends a packet to the given destination address using the socket of this 133 // Sets this option on the socket of each connection. 139 void HandleConnectFailure(talk_base::AsyncPacketSocket* socket); 373 RelayConnection(const ProtocolAddress* protocol_address, talk_base::AsyncPacketSocket* socket, talk_base::Thread* thread) argument 453 talk_base::AsyncPacketSocket* socket = NULL; local 595 HandleConnectFailure( talk_base::AsyncPacketSocket* socket) argument 630 OnSocketConnect(talk_base::AsyncPacketSocket* socket) argument 638 OnSocketClose(talk_base::AsyncPacketSocket* socket, int error) argument 644 OnReadPacket(talk_base::AsyncPacketSocket* socket, const char* data, size_t size, const talk_base::SocketAddress& remote_addr) argument [all...] |
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
H A D | client_for_testing.py | 54 import socket namespace 132 def receive_bytes(socket, length): 136 received_bytes = socket.recv(remaining) 152 def _read_fields(socket): 160 name = _read_name(socket) 165 ch = _skip_spaces(socket) 167 value = _read_value(socket, ch) 169 ch = receive_bytes(socket, 1) 184 def _read_name(socket): 189 ch = receive_bytes(socket, [all...] |
/external/netperf/ |
H A D | nettest_sdp.c | 51 #include <sys/socket.h> 118 -P local[,remote] Set the local/remote port for the data socket\n\ 120 -s send[,recv] Set local socket send/recv buffer sizes\n\ 121 -S send[,recv] Set remote socket send/recv buffer sizes\n\ 144 get_sdp_info(int socket, int * mss) 151 if (getsockopt(socket, 215 /* the size of the local senc socket buffer. We will want to deal */ 260 /* control socket, and since we want to be able to use different */ 297 /*set up the data socket */ 304 perror("netperf: send_sdp_stream: sdp stream data socket"); 142 get_sdp_info(int socket, int * mss) argument [all...] |
/external/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/ |
H A D | SpdyConnection.java | 38 * A socket connection to a remote peer. A connection hosts streams which can 382 public Builder(boolean client, Socket socket) throws IOException { argument 383 this("", client, socket.getInputStream(), socket.getOutputStream()); 394 public Builder(String hostName, boolean client, Socket socket) throws IOException { argument 395 this(hostName, client, socket.getInputStream(), socket.getOutputStream());
|
/external/openssl/ |
H A D | e_os.h | 232 # include <sys/socket.h> 509 # define socket(d,t,p) ((int)socket(d,t,p)) macro 535 # include <sys/socket.h> 565 # include <socket.h> 569 # include <sys/socket.h>
|
/external/quake/quake/src/WinQuake/ |
H A D | net.h | 132 int socket; member in struct:qsocket_s 164 int (*CloseSocket) (int socket); 165 int (*Connect) (int socket, struct qsockaddr *addr); 167 int (*Read) (int socket, byte *buf, int len, struct qsockaddr *addr); 168 int (*Write) (int socket, byte *buf, int len, struct qsockaddr *addr); 169 int (*Broadcast) (int socket, byte *buf, int len); 172 int (*GetSocketAddr) (int socket, struct qsockaddr *addr);
|
H A D | net_wins.cpp | 29 static int net_acceptsocket = -1; // socket for fielding new connections
142 psocket = (void *)GetProcAddress(hInst, "socket");
231 Con_Printf("WINS_Init: Unable to open control socket\n");
268 Sys_Error ("WINS_Listen: Unable to open accept socket\n");
307 int WINS_CloseSocket (int socket)
argument 309 if (socket == net_broadcastsocket)
311 return pclosesocket (socket);
374 int WINS_Connect (int socket, struct qsockaddr *addr)
argument 397 int WINS_Read (int socket, byte *buf, int len, struct qsockaddr *addr)
argument 402 ret = precvfrom (socket, bu 416 WINS_MakeSocketBroadcastCapable(int socket) argument 430 WINS_Broadcast(int socket, byte *buf, int len) argument 452 WINS_Write(int socket, byte *buf, int len, struct qsockaddr *addr) argument 494 WINS_GetSocketAddr(int socket, struct qsockaddr *addr) argument [all...] |
H A D | net_ipx.cpp | 59 short socket;
member in struct:__anon12634 68 #define sipx_port sipx_addr.socket
87 short socket;
member in struct:ECBStructure 113 // each socket's socketbuffer 0 is used for sending, the others for listening
262 // init socket handles & buffers
273 lma->socketbuffer[s][n].ecb.socket = 0;
286 Con_DPrintf ("IPX_Init: Unable to open control socket\n");
322 Sys_Error ("IPX_Listen: Unable to open accept socket\n");
339 unsigned short socket;
local 344 // open the IPX socket
[all...] |
/external/v8/src/ |
H A D | platform-posix.cc | 39 #include <sys/socket.h> 354 // POSIX socket support. 360 // Create the socket. 361 socket_ = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); 371 explicit POSIXSocket(int socket): socket_(socket) { } argument 382 // Shutdown socket for both read and write. 430 int socket = accept(socket_, NULL, NULL); local 431 if (socket == -1) { 434 return new POSIXSocket(socket); [all...] |
/external/webkit/Source/WebCore/plugins/gtk/ |
H A D | PluginViewGtk.cpp | 767 gboolean PluginView::plugRemovedCallback(GtkSocket* socket, PluginView* view) argument 773 void PluginView::plugAddedCallback(GtkSocket* socket, PluginView* view) argument 775 ASSERT(socket); 781 gtk_widget_size_allocate(GTK_WIDGET(socket), &allocation);
|
/external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/ |
H A D | org.eclipse.ecf.provider.filetransfer_3.1.0.v20100529-0735.jar | ... ecf/provider/filetransfer/events/ org/eclipse/ecf/provider/filetransfer/events/socket/ org/eclipse/ecf/provider/filetransfer/identity/ org/eclipse/ecf/provider ... |
H A D | org.eclipse.ecf.filetransfer_4.0.0.v20100529-0735.jar | ... org/eclipse/ecf/filetransfer/events/ org/eclipse/ecf/filetransfer/events/socket/ org/eclipse/ecf/filetransfer/events/socketfactory/ org/eclipse/ecf/filetransfer ... |
H A D | org.eclipse.ecf.ssl_1.0.0.v20100529-0735.jar | ... throws java.io.IOException java.net.Socket socket
String host
int port
boolean autoClose
public java. ... |
/external/chromium/chrome/browser/ |
H A D | process_singleton_linux.cc | 6 // for a socket in the user's profile directory. If the socket file is open we 12 // sockets, we create the socket in a temporary directory and create a symlink 27 // If writing to the socket fails, the hostname in the lock is checked to see if 48 #include <sys/socket.h> 130 // Close a socket and check return value. 133 DCHECK_EQ(0, rv) << "Error closing socket: " << safe_strerror(errno); 136 // Write a message to a socket fd. 146 // The socket shouldn't block, we're sending so little data. Just give 160 // Wait a socket fo 398 ConnectSocket(ScopedSocket* socket, const FilePath& socket_path, const FilePath& cookie_path) argument 592 StartListening(int socket) argument 774 ScopedSocket socket; local [all...] |
/external/chromium/chrome/common/extensions/docs/examples/apps/hello-python/httplib2/ |
H A D | __init__.py | 54 import socket namespace 61 # Build the appropriate socket wrapper for ssl 67 ssl_sock = socket.ssl(sock, key_file, cert_file) 78 if hasattr(socket, '_GLOBAL_DEFAULT_TIMEOUT'): 79 return (timeout is not None and timeout is not socket._GLOBAL_DEFAULT_TIMEOUT) 724 for res in socket.getaddrinfo(self.host, self.port, 0, 725 socket.SOCK_STREAM): 732 self.sock = socket.socket(af, socktype, proto) 741 except socket [all...] |
/external/chromium/net/socket/ |
H A D | client_socket_pool_base.cc | 5 #include "net/socket/client_socket_pool_base.h" 17 #include "net/socket/client_socket_handle.h" 23 // Indicate whether we should enable idle socket cleanup timer. When timer is 24 // disabled, sockets are closed next time a socket request is made. 96 void ConnectJob::set_socket(ClientSocket* socket) { argument 97 if (socket) { 100 socket->NetLog().source()))); 102 socket_.reset(socket); 130 // Make sure the socket is NULL before calling into |delegate|. 312 // Try to reuse a socket 454 ClientSocket* socket = handle->release_socket(); local 709 ReleaseSocket(const std::string& group_name, ClientSocket* socket, int id) argument 903 HandOutSocket( ClientSocket* socket, bool reused, ClientSocketHandle* handle, base::TimeDelta idle_time, Group* group, const BoundNetLog& net_log) argument 931 AddIdleSocket( ClientSocket* socket, Group* group) argument [all...] |
H A D | client_socket_pool_base.h | 13 // ClientSocketPoolBase abstracts socket connection details behind ConnectJob, 14 // ConnectJobFactory, and SocketParams. When a socket "slot" becomes available, 17 // implement their socket specific connection by subclassing ConnectJob and 45 #include "net/socket/client_socket.h" 46 #include "net/socket/client_socket_pool.h" 52 // ConnectJob provides an abstract interface for "connecting" a socket. 94 // Begins connecting the socket. Returns OK on success, ERR_IO_PENDING if it 98 // completion, ReleaseSocket() can be called to acquire the connected socket 116 void set_socket(ClientSocket* socket); 117 ClientSocket* socket() { retur function in class:net::ConnectJob 333 ClientSocket* socket; member in struct:net::internal::ClientSocketPoolBaseHelper::IdleSocket 705 ReleaseSocket(const std::string& group_name, ClientSocket* socket, int id) argument [all...] |
H A D | socket_test_util.h | 29 #include "net/socket/client_socket_factory.h" 30 #include "net/socket/client_socket_handle.h" 31 #include "net/socket/socks_client_socket_pool.h" 32 #include "net/socket/ssl_client_socket.h" 33 #include "net/socket/ssl_client_socket_pool.h" 34 #include "net/socket/transport_client_socket_pool.h" 40 // A private network error code used by the socket test utility classes. 133 // for getting data about individual reads and writes on the socket. 148 // Accessor for the socket which is using the SocketDataProvider. 149 MockClientSocket* socket() { retur function in class:net::SocketDataProvider 150 set_socket(MockClientSocket* socket) argument 439 set_socket(base::WeakPtr<DeterministicMockTCPClientSocket> socket) argument [all...] |
/external/valgrind/main/coregrind/ |
H A D | m_libcfile.c | 3 /*--- File- and socket-related libc stuff. m_libcfile.c ---*/ 763 the relevant file (socket) descriptor, otherwise. 787 /* create socket */ 788 sd = VG_(socket)(VKI_AF_INET, VKI_SOCK_STREAM, 0 /* IPPROTO_IP ? */); 854 Int VG_(socket) ( Int domain, Int type, Int protocol ) function 930 For Darwin, VG_(socket)() sets SO_NOSIGPIPE to get EPIPE instead of
|
/external/apache-harmony/nio/src/test/java/common/org/apache/harmony/nio/tests/java/nio/channels/ |
H A D | SocketChannelTest.java | 279 Socket s1 = this.channel1.socket(); 281 Socket s2 = this.channel1.socket(); 291 Socket s1 = this.channel1.socket(); 294 Socket s2 = this.channel1.socket(); 308 s1 = this.channel1.socket(); 311 s2 = this.channel1.socket(); 318 s1 = this.channel1.socket(); 320 s2 = this.channel1.socket(); 328 Socket s = this.channel1.socket(); 336 Socket s = this.channel1.socket(); 3571 public Socket socket() { method in class:SocketChannelTest.MockSocketChannel [all...] |