Searched defs:socket (Results 126 - 150 of 184) sorted by relevance

12345678

/external/chromium/net/websockets/
H A Dwebsocket_job_unittest.cc60 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 Dopenssladapter.cc60 "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 Dschanneladapter.cc108 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 Dwin32socketserver.cc82 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 Drelayserver.cc51 // 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 Drelayport.cc38 // 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 Dclient_for_testing.py54 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 Dnettest_sdp.c51 #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 DSpdyConnection.java38 * 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 De_os.h232 # 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 Dnet.h132 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 Dnet_wins.cpp29 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 Dnet_ipx.cpp59 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 Dplatform-posix.cc39 #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 DPluginViewGtk.cpp767 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 Dorg.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 Dorg.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 Dorg.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 Dprocess_singleton_linux.cc6 // 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__.py54 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 Dclient_socket_pool_base.cc5 #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 Dclient_socket_pool_base.h13 // 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 Dsocket_test_util.h29 #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 Dm_libcfile.c3 /*--- 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 DSocketChannelTest.java279 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...]

Completed in 527 milliseconds

12345678