/external/apache-http/src/org/apache/http/impl/io/ |
H A D | SocketOutputBuffer.java | 57 final Socket socket, 61 if (socket == null) { 69 init(socket.getOutputStream(), 8192, params); 56 SocketOutputBuffer( final Socket socket, int buffersize, final HttpParams params) argument
|
/external/chromium_org/third_party/webrtc/base/ |
H A D | ssladapter.h | 22 explicit SSLAdapter(AsyncSocket* socket) argument 23 : AsyncSocketAdapter(socket), ignore_bad_cert_(false) { } 29 // If StartSSL is called while the socket is closed or connecting, the SSL 30 // negotiation will begin as soon as the socket connects. 34 // and deletes |socket|. Otherwise, the returned SSLAdapter takes ownership 35 // of |socket|. 36 static SSLAdapter* Create(AsyncSocket* socket);
|
H A D | asyncsocket.cc | 21 AsyncSocketAdapter::AsyncSocketAdapter(AsyncSocket* socket) : socket_(NULL) { argument 22 Attach(socket); 29 void AsyncSocketAdapter::Attach(AsyncSocket* socket) { argument 31 socket_ = socket;
|
H A D | ssladapter.cc | 38 SSLAdapter::Create(AsyncSocket* socket) { argument 40 return new SChannelAdapter(socket); 42 return new OpenSSLAdapter(socket); 44 delete socket;
|
H A D | socketstream.cc | 15 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) { argument 16 Attach(socket); 23 void SocketStream::Attach(AsyncSocket* socket) { argument 26 socket_ = socket; 36 AsyncSocket* socket = socket_; local 44 return socket; 100 void SocketStream::OnConnectEvent(AsyncSocket* socket) { argument 101 ASSERT(socket == socket_); 105 void SocketStream::OnReadEvent(AsyncSocket* socket) { argument 106 ASSERT(socket 110 OnWriteEvent(AsyncSocket* socket) argument 115 OnCloseEvent(AsyncSocket* socket, int err) argument [all...] |
H A D | proxyserver.cc | 39 void ProxyServer::OnAcceptEvent(AsyncSocket* socket) { argument 40 ASSERT(socket != NULL && socket == server_socket_.get()); 41 AsyncSocket* int_socket = socket->Accept(NULL); 49 LOG(LS_ERROR) << "Unable to create external socket on proxy accept event"; 77 void ProxyBinding::OnConnectRequest(AsyncProxyServerSocket* socket, argument 84 void ProxyBinding::OnInternalRead(AsyncSocket* socket) { argument 89 void ProxyBinding::OnInternalWrite(AsyncSocket* socket) { argument 93 void ProxyBinding::OnInternalClose(AsyncSocket* socket, int err) { argument 97 void ProxyBinding::OnExternalConnect(AsyncSocket* socket) { argument 103 OnExternalRead(AsyncSocket* socket) argument 108 OnExternalWrite(AsyncSocket* socket) argument 112 OnExternalClose(AsyncSocket* socket, int err) argument 119 Read(AsyncSocket* socket, FifoBuffer* buffer) argument 131 Write(AsyncSocket* socket, FifoBuffer* buffer) argument [all...] |
H A D | asynctcpsocket.h | 25 AsyncTCPSocketBase(AsyncSocket* socket, bool listen, size_t max_packet_size); 33 virtual void HandleIncomingConnection(AsyncSocket* socket) = 0; 48 // Binds and connects |socket| and creates AsyncTCPSocket for 49 // it. Takes ownership of |socket|. Returns NULL if bind() or 50 // connect() fail (|socket| is destroyed in that case). 51 static AsyncSocket* ConnectSocket(AsyncSocket* socket, 64 // Called by the underlying socket 65 void OnConnectEvent(AsyncSocket* socket); 66 void OnReadEvent(AsyncSocket* socket); 67 void OnWriteEvent(AsyncSocket* socket); [all...] |
/external/chromium_org/tools/telemetry/telemetry/core/backends/chrome/ |
H A D | websocket.py | 6 import socket namespace 25 sockopt.append((socket.SOL_SOCKET, socket.SO_REUSEADDR, 1))
|
H A D | websocket_unittest.py | 8 import socket namespace 47 ws.sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR), 0) 54 sockopt=[(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)]) 57 ws.sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR), 0) 59 ws.sock.getsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY), 0)
|
/external/kernel-headers/original/uapi/linux/ |
H A D | un.h | 4 #include <linux/socket.h>
|
/external/chromium_org/extensions/browser/api/sockets_tcp_server/ |
H A D | sockets_tcp_server_api.cc | 8 #include "extensions/browser/api/socket/tcp_socket.h" 27 ResumableTCPServerSocket* socket) { 29 // This represents what we know about the socket, and does not call through 32 if (!socket->name().empty()) { 33 socket_info->name.reset(new std::string(socket->name())); 35 socket_info->persistent = socket->persistent(); 36 socket_info->paused = socket->paused(); 40 if (socket->GetLocalAddress(&localAddress)) { 49 void SetSocketProperties(ResumableTCPServerSocket* socket, argument 52 socket 26 CreateSocketInfo(int socket_id, ResumableTCPServerSocket* socket) argument 88 ResumableTCPServerSocket* socket = local 113 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local 143 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local 180 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local 221 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local 242 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local 263 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local 288 ResumableTCPServerSocket* socket = GetTcpSocket(socket_id); local [all...] |
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
H A D | testrelayserver.h | 74 rtc::AsyncSocket* socket = local 76 socket->Bind(addr); 77 socket->Listen(5); 78 socket->SignalReadEvent.connect(this, &TestRelayServer::OnAccept); 79 return socket; 81 void OnAccept(rtc::AsyncSocket* socket) { argument 82 bool external = (socket == tcp_ext_socket_.get() || 83 socket == ssl_ext_socket_.get()); 84 bool ssl = (socket == ssl_int_socket_.get() || 85 socket 102 OnInternalClose(rtc::AsyncPacketSocket* socket, int error) argument 105 OnExternalClose(rtc::AsyncPacketSocket* socket, int error) argument [all...] |
/external/chromium_org/net/base/ |
H A D | sys_addrinfo.h | 24 #include <sys/socket.h>
|
/external/chromium_org/ppapi/tests/ |
H A D | test_net_address_private_untrusted.cc | 55 int32_t TestNetAddressPrivateUntrusted::Connect(TCPSocketPrivate* socket, argument 61 socket->Connect(host.c_str(), port, callback.GetCallback())); 66 pp::TCPSocketPrivate socket(instance_); 67 int32_t rv = Connect(&socket, host_, port_); 72 ASSERT_TRUE(socket.GetLocalAddress(&local_address)); 73 ASSERT_TRUE(socket.GetRemoteAddress(&remote_address)); 78 socket.Disconnect(); 83 pp::TCPSocketPrivate socket(instance_); 84 int32_t rv = Connect(&socket, host_, port_); 89 ASSERT_TRUE(socket [all...] |
/external/chromium_org/third_party/libsrtp/srtp/include/ |
H A D | rtp_priv.h | 61 int socket; member in struct:rtp_sender_ctx_t 68 int socket; member in struct:rtp_receiver_ctx_t
|
/external/compiler-rt/test/asan/TestCases/Posix/ |
H A D | ioctl.cc | 10 #include <sys/socket.h> 14 int fd = socket(AF_INET, SOCK_DGRAM, 0);
|
/external/compiler-rt/test/msan/ |
H A D | ioctl.cc | 7 #include <sys/socket.h> 11 int fd = socket(AF_INET, SOCK_DGRAM, 0);
|
/external/srtp/include/ |
H A D | rtp_priv.h | 61 int socket; member in struct:rtp_sender_ctx_t 68 int socket; member in struct:rtp_receiver_ctx_t
|
/external/valgrind/main/none/tests/ |
H A D | fcntl_setown.c | 4 #include <sys/socket.h> 11 if ((s = socket(PF_INET, SOCK_STREAM, 0)) < 0) 13 perror("socket");
|
/external/chromium_org/net/socket/ |
H A D | tcp_client_socket_unittest.cc | 9 #include "net/socket/tcp_client_socket.h" 15 #include "net/socket/tcp_server_socket.h" 22 // Try binding a socket to loopback interface and verify that we can 33 TCPClientSocket socket(AddressList(server_address), NULL, NetLog::Source()); 35 EXPECT_EQ(OK, socket.Bind(IPEndPoint(lo_address, 0))); 38 EXPECT_EQ(OK, socket.GetLocalAddress(&local_address_result)); 42 EXPECT_EQ(ERR_IO_PENDING, socket.Connect(connect_callback.callback())); 53 EXPECT_TRUE(socket.IsConnected()); 54 socket.Disconnect(); 55 EXPECT_FALSE(socket [all...] |
H A D | websocket_endpoint_lock_manager.cc | 5 #include "net/socket/websocket_endpoint_lock_manager.h" 42 void WebSocketEndpointLockManager::RememberSocket(StreamSocket* socket, argument 48 socket, lock_info_it)).second; 50 DCHECK(!lock_info_it->second.socket); 51 lock_info_it->second.socket = socket; 52 DVLOG(3) << "Remembered (StreamSocket*)" << socket << " for " 54 << " socket(s) remembered)"; 57 void WebSocketEndpointLockManager::UnlockSocket(StreamSocket* socket) { argument 58 SocketLockInfoMap::iterator socket_it = socket_lock_info_map_.find(socket); [all...] |
H A D | unix_domain_server_socket_posix.cc | 5 #include "net/socket/unix_domain_server_socket_posix.h" 8 #include <sys/socket.h> 14 #include "net/socket/socket_libevent.h" 15 #include "net/socket/unix_domain_client_socket_posix.h" 22 void SetStreamSocket(scoped_ptr<StreamSocket>* socket, argument 24 socket->reset(new UnixDomainClientSocket(accepted_socket.Pass())); 27 void SetSocketDescriptor(SocketDescriptor* socket, argument 29 *socket = accepted_socket->ReleaseConnectedSocket(); 46 bool UnixDomainServerSocket::GetPeerCredentials(SocketDescriptor socket, argument 51 if (getsockopt(socket, SOL_SOCKE 110 Accept(scoped_ptr<StreamSocket>* socket, const CompletionCallback& callback) argument 118 AcceptSocketDescriptor( SocketDescriptor* socket, const CompletionCallback& callback) argument [all...] |
/external/chromium_org/third_party/tlslite/tlslite/integration/ |
H A D | imap4_tls.py | 6 import socket namespace 92 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
/external/chromium_org/extensions/browser/api/sockets_udp/ |
H A D | sockets_udp_api.cc | 8 #include "extensions/browser/api/socket/udp_socket.h" 51 ResumableUDPSocket* socket) { 54 // This represents what we know about the socket, and does not call through 57 if (!socket->name().empty()) { 58 socket_info->name.reset(new std::string(socket->name())); 60 socket_info->persistent = socket->persistent(); 61 if (socket->buffer_size() > 0) { 62 socket_info->buffer_size.reset(new int(socket->buffer_size())); 64 socket_info->paused = socket->paused(); 68 if (socket 49 CreateSocketInfo( int socket_id, ResumableUDPSocket* socket) argument 77 SetSocketProperties(ResumableUDPSocket* socket, sockets_udp::SocketProperties* properties) argument 101 ResumableUDPSocket* socket = new ResumableUDPSocket(extension_->id()); local 124 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); local 153 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); local 189 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); local 227 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); local 254 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); local 302 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); local 324 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); local 349 ResumableUDPSocket* socket = GetUdpSocket(socket_id); local 369 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); local 401 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); local 436 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); local 462 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); local 485 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); local [all...] |
/external/chromium_org/third_party/libevent/sample/ |
H A D | event-test.c | 74 HANDLE socket; local 76 socket = CreateFile("test.txt", // open File 84 if(socket == INVALID_HANDLE_VALUE) 90 int socket; 108 socket = open (fifo, O_RDWR | O_NONBLOCK, 0); 110 socket = open (fifo, O_RDONLY | O_NONBLOCK, 0); 113 if (socket == -1) { 125 event_set(&evfifo, (int)socket, EV_READ, fifo_read, &evfifo); 127 event_set(&evfifo, socket, EV_READ, fifo_read, &evfifo); 135 CloseHandle(socket); [all...] |