socket 67 base/async_socket_io_handler.h bool Initialize(base::SyncSocket::Handle socket, socket 84 base/async_socket_io_handler.h virtual void OnFileCanWriteWithoutBlocking(int socket) OVERRIDE {} socket 85 base/async_socket_io_handler.h virtual void OnFileCanReadWithoutBlocking(int socket) OVERRIDE; socket 24 base/async_socket_io_handler_posix.cc void AsyncSocketIoHandler::OnFileCanReadWithoutBlocking(int socket) { socket 26 base/async_socket_io_handler_posix.cc DCHECK_EQ(socket, socket_); socket 67 base/async_socket_io_handler_posix.cc bool AsyncSocketIoHandler::Initialize(base::SyncSocket::Handle socket, socket 73 base/async_socket_io_handler_posix.cc socket_ = socket; socket 77 base/async_socket_io_handler_posix.cc int value = fcntl(socket, F_GETFL); socket 80 base/async_socket_io_handler_posix.cc if (fcntl(socket, F_SETFL, O_NONBLOCK) == -1) { socket 21 base/async_socket_io_handler_unittest.cc TestSocketReader(base::CancelableSyncSocket* socket, socket 25 base/async_socket_io_handler_unittest.cc : socket_(socket), buffer_(), socket 70 base/async_socket_io_handler_unittest.cc void SendData(base::CancelableSyncSocket* socket, socket 73 base/async_socket_io_handler_unittest.cc socket->Send(buffer, length); socket 58 base/async_socket_io_handler_win.cc bool AsyncSocketIoHandler::Initialize(base::SyncSocket::Handle socket, socket 65 base/async_socket_io_handler_win.cc socket_ = socket; socket 68 base/async_socket_io_handler_win.cc base::MessageLoopForIO::current()->RegisterIOHandler(socket, this); socket 362 base/message_loop/message_pump_libevent.cc void MessagePumpLibevent::OnWakeup(int socket, short flags, void* context) { socket 364 base/message_loop/message_pump_libevent.cc DCHECK(that->wakeup_pipe_out_ == socket); socket 368 base/message_loop/message_pump_libevent.cc int nread = HANDLE_EINTR(read(socket, &buf, 1)); socket 145 base/message_loop/message_pump_libevent.h static void OnWakeup(int socket, short flags, void* context); socket 17 base/sync_socket_unittest.cc explicit HangingReceiveThread(base::SyncSocket* socket) socket 18 base/sync_socket_unittest.cc : socket_(socket), socket 120 base/sync_socket_win.cc CancelableSyncSocket* socket, socket 162 base/sync_socket_win.cc socket->Close(); socket 97 chrome/browser/devtools/adb_client_socket.cc HttpOverAdbSocket(net::StreamSocket* socket, socket 100 chrome/browser/devtools/adb_client_socket.cc : socket_(socket), socket 106 chrome/browser/devtools/adb_client_socket.cc HttpOverAdbSocket(net::StreamSocket* socket, socket 109 chrome/browser/devtools/adb_client_socket.cc : socket_(socket), socket 292 chrome/browser/devtools/adb_client_socket.cc void AdbClientSocket::HttpQuery(net::StreamSocket* socket, socket 295 chrome/browser/devtools/adb_client_socket.cc new HttpOverAdbSocket(socket, request_path, callback); socket 299 chrome/browser/devtools/adb_client_socket.cc void AdbClientSocket::HttpQuery(net::StreamSocket* socket, socket 302 chrome/browser/devtools/adb_client_socket.cc new HttpOverAdbSocket(socket, request_path, callback); socket 23 chrome/browser/devtools/adb_client_socket.h static void HttpQuery(net::StreamSocket* socket, socket 27 chrome/browser/devtools/adb_client_socket.h static void HttpQuery(net::StreamSocket* socket, socket 73 chrome/browser/devtools/adb_web_socket.cc int result, net::StreamSocket* socket) { socket 74 chrome/browser/devtools/adb_web_socket.cc if (result != net::OK || socket == NULL) { socket 79 chrome/browser/devtools/adb_web_socket.cc socket_.reset(socket); socket 160 chrome/browser/devtools/adb_web_socket.cc scoped_ptr<net::StreamSocket> socket(socket_.release()); socket 161 chrome/browser/devtools/adb_web_socket.cc socket->Disconnect(); socket 38 chrome/browser/devtools/adb_web_socket.h void ConnectedOnHandlerThread(int result, net::StreamSocket* socket); socket 84 chrome/browser/devtools/android_device.cc net::StreamSocket* socket, socket 87 chrome/browser/devtools/android_device.cc net::StreamSocket* socket, socket 89 chrome/browser/devtools/android_device.cc void OnRead(net::StreamSocket* socket, socket 108 chrome/browser/devtools/android_device.cc net::StreamSocket* socket = device_->CreateSocket(command); socket 109 chrome/browser/devtools/android_device.cc int result = socket->Connect(base::Bind(&UsbDeviceImpl::OpenedForCommand, socket 110 chrome/browser/devtools/android_device.cc this, callback, socket)); socket 119 chrome/browser/devtools/android_device.cc net::StreamSocket* socket = device_->CreateSocket(socket_name); socket 120 chrome/browser/devtools/android_device.cc int result = socket->Connect(base::Bind(&UsbDeviceImpl::OnOpenSocket, this, socket 121 chrome/browser/devtools/android_device.cc callback, socket)); socket 127 chrome/browser/devtools/android_device.cc net::StreamSocket* socket, socket 129 chrome/browser/devtools/android_device.cc callback.Run(result, result == net::OK ? socket : NULL); socket 133 chrome/browser/devtools/android_device.cc net::StreamSocket* socket, socket 140 chrome/browser/devtools/android_device.cc result = socket->Read(buffer, kBufferSize, socket 142 chrome/browser/devtools/android_device.cc socket, buffer, std::string(), callback)); socket 144 chrome/browser/devtools/android_device.cc OnRead(socket, buffer, std::string(), callback, result); socket 147 chrome/browser/devtools/android_device.cc void UsbDeviceImpl::OnRead(net::StreamSocket* socket, socket 154 chrome/browser/devtools/android_device.cc delete socket; socket 159 chrome/browser/devtools/android_device.cc result = socket->Read(buffer, kBufferSize, socket 161 chrome/browser/devtools/android_device.cc socket, buffer, new_data, callback)); socket 163 chrome/browser/devtools/android_device.cc OnRead(socket, buffer, new_data, callback, result); socket 304 chrome/browser/devtools/android_device.cc net::StreamSocket* socket) { socket 309 chrome/browser/devtools/android_device.cc AdbClientSocket::HttpQuery(socket, request, callback); socket 316 chrome/browser/devtools/android_device.cc net::StreamSocket* socket) { socket 321 chrome/browser/devtools/android_device.cc AdbClientSocket::HttpQuery(socket, request, callback); socket 439 chrome/browser/devtools/android_device.cc net::StreamSocket* socket, socket 455 chrome/browser/devtools/android_device.cc net::StreamSocket* socket, socket 457 chrome/browser/devtools/android_device.cc callback.Run(result, socket); socket 490 chrome/browser/devtools/android_device.cc net::TCPClientSocket* socket = new net::TCPClientSocket( socket 492 chrome/browser/devtools/android_device.cc socket->Connect(base::Bind(&SelfAsDevice::RunSocketCallback, this, callback, socket 493 chrome/browser/devtools/android_device.cc socket)); socket 50 chrome/browser/devtools/android_device.h net::StreamSocket* socket); socket 54 chrome/browser/devtools/android_device.h net::StreamSocket* socket); socket 87 chrome/browser/devtools/devtools_adb_bridge.cc const char* socket; socket 222 chrome/browser/devtools/devtools_adb_bridge.cc std::string socket = path_field.substr(1); socket 230 chrome/browser/devtools/devtools_adb_bridge.cc socket_to_pid[socket] = pid; socket 441 chrome/browser/devtools/devtools_adb_bridge.cc current_browser()->socket(), socket 476 chrome/browser/devtools/devtools_adb_bridge.cc current_browser()->socket(), socket 532 chrome/browser/devtools/devtools_adb_bridge.cc std::string socket = it->first; socket 537 chrome/browser/devtools/devtools_adb_bridge.cc adb_thread_, remote_device->device(), socket); socket 546 chrome/browser/devtools/devtools_adb_bridge.cc } else if (socket.find(kWebViewSocketPrefix) == 0) { socket 554 chrome/browser/devtools/devtools_adb_bridge.cc std::string name = socket.substr(0, socket.find(channel_pattern)); socket 558 chrome/browser/devtools/devtools_adb_bridge.cc socket_to_unnamed_browser[socket] = browser; socket 581 chrome/browser/devtools/devtools_adb_bridge.cc DescriptorMultimap::value_type(descriptor->socket, descriptor)); socket 589 chrome/browser/devtools/devtools_adb_bridge.cc std::string socket = it->first; socket 592 chrome/browser/devtools/devtools_adb_bridge.cc if (socket_to_descriptor.count(socket) != 1) socket 595 chrome/browser/devtools/devtools_adb_bridge.cc BrowserMap::iterator bit = socket_to_unnamed_browser.find(socket); socket 746 chrome/browser/devtools/devtools_adb_bridge.cc id, browser->device(), browser->socket(), debug_url, socket 887 chrome/browser/devtools/devtools_adb_bridge.cc browser_->socket().c_str(), socket 937 chrome/browser/devtools/devtools_adb_bridge.cc const std::string& socket) socket 940 chrome/browser/devtools/devtools_adb_bridge.cc socket_(socket), socket 90 chrome/browser/devtools/devtools_adb_bridge.h const std::string& socket); socket 95 chrome/browser/devtools/devtools_adb_bridge.h std::string socket() { return socket_; } socket 426 chrome/browser/devtools/devtools_targets_ui.cc browser->socket().c_str()); // Ensure uniqueness on the device. socket 63 chrome/browser/devtools/port_forwarding_controller.cc net::StreamSocket* socket) { socket 67 chrome/browser/devtools/port_forwarding_controller.cc tunnel->Start(socket, host, port); socket 79 chrome/browser/devtools/port_forwarding_controller.cc void Start(net::StreamSocket* socket, const std::string& host, int port) { socket 80 chrome/browser/devtools/port_forwarding_controller.cc remote_socket_.reset(socket); socket 233 chrome/browser/devtools/port_forwarding_controller.cc std::string socket; socket 242 chrome/browser/devtools/port_forwarding_controller.cc socket = browser->socket(); socket 246 chrome/browser/devtools/port_forwarding_controller.cc return socket; socket 259 chrome/browser/devtools/port_forwarding_controller.cc const std::string& socket, socket 315 chrome/browser/devtools/port_forwarding_controller.cc const std::string& socket, socket 326 chrome/browser/devtools/port_forwarding_controller.cc device, socket, kDevToolsRemoteBrowserTarget, socket 574 chrome/browser/devtools/port_forwarding_controller.cc std::string socket = FindBestSocketForTethering(device->browsers()); socket 575 chrome/browser/devtools/port_forwarding_controller.cc if (!socket.empty()) { socket 577 chrome/browser/devtools/port_forwarding_controller.cc ®istry_, device->device(), socket, adb_thread_, pref_service_); socket 341 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc return GetEventRouter(browser_context())->ReleaseSocket(options.socket.id); socket 352 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc socket_ = GetEventRouter(browser_context())->GetSocket(options.socket.id); socket 394 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc base::DictionaryValue* socket; socket 395 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc EXTENSION_FUNCTION_VALIDATE(options->GetDictionary("socket", &socket)); socket 398 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc EXTENSION_FUNCTION_VALIDATE(socket->GetInteger("id", &socket_id)); socket 562 chrome/browser/extensions/api/bluetooth/bluetooth_apitest.cc scoped_refptr<device::MockBluetoothSocket> socket = socket 569 chrome/browser/extensions/api/bluetooth/bluetooth_apitest.cc extension->id(), BluetoothUUID("1234"), device1_.get(), socket); socket 43 chrome/browser/extensions/api/bluetooth/bluetooth_event_router.cc scoped_refptr<device::BluetoothSocket> socket; socket 91 chrome/browser/extensions/api/bluetooth/bluetooth_event_router.cc scoped_refptr<device::BluetoothSocket> socket) { socket 95 chrome/browser/extensions/api/bluetooth/bluetooth_event_router.cc if (i->second.socket.get() == socket.get()) socket 99 chrome/browser/extensions/api/bluetooth/bluetooth_event_router.cc ExtensionBluetoothSocketRecord record = { extension_id, socket }; socket 191 chrome/browser/extensions/api/bluetooth/bluetooth_event_router.cc return socket_entry->second.socket; socket 198 chrome/browser/extensions/api/bluetooth/bluetooth_event_router.cc scoped_refptr<device::BluetoothSocket> socket) { socket 202 chrome/browser/extensions/api/bluetooth/bluetooth_event_router.cc int socket_id = RegisterSocket(extension_id, socket); socket 57 chrome/browser/extensions/api/bluetooth/bluetooth_event_router.h scoped_refptr<device::BluetoothSocket> socket); socket 110 chrome/browser/extensions/api/bluetooth/bluetooth_event_router.h scoped_refptr<device::BluetoothSocket> socket); socket 80 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc void CastChannelAPI::OnError(const CastSocket* socket, socket 84 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc socket->FillChannelInfo(&channel_info); socket 90 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc ->DispatchEventToExtension(socket->owner_extension_id(), event.Pass()); socket 93 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc void CastChannelAPI::OnMessage(const CastSocket* socket, socket 97 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc socket->FillChannelInfo(&channel_info); socket 105 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc ->DispatchEventToExtension(socket->owner_extension_id(), event.Pass()); socket 126 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc CastSocket* socket = GetSocket(channel_id); socket 127 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc if (!socket) { socket 131 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc return socket; socket 134 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc int CastChannelAsyncApiFunction::AddSocket(CastSocket* socket) { socket 136 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc DCHECK(socket); socket 138 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc const int id = manager_->Add(socket); socket 139 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc socket->set_id(id); socket 150 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc CastSocket* socket = GetSocket(channel_id); socket 151 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc DCHECK(socket); socket 153 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc socket->FillChannelInfo(&channel_info); socket 154 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc error_ = socket->error_state(); socket 198 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc scoped_ptr<CastSocket> socket = api_->CreateCastSocket(extension_->id(), socket 200 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc new_channel_id_ = AddSocket(socket.release()); socket 222 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc CastSocket* socket = GetSocketOrCompleteWithError( socket 224 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc if (socket) socket 225 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc socket->SendMessage(params_->message, socket 250 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc CastSocket* socket = GetSocketOrCompleteWithError( socket 252 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc if (socket) socket 253 chrome/browser/extensions/api/cast_channel/cast_channel_api.cc socket->Close(base::Bind(&CastChannelCloseFunction::OnClose, this)); socket 56 chrome/browser/extensions/api/cast_channel/cast_channel_api.h virtual void OnError(const cast_channel::CastSocket* socket, socket 58 chrome/browser/extensions/api/cast_channel/cast_channel_api.h virtual void OnMessage(const cast_channel::CastSocket* socket, socket 88 chrome/browser/extensions/api/cast_channel/cast_channel_api.h int AddSocket(cast_channel::CastSocket* socket); socket 116 chrome/browser/extensions/api/cast_channel/cast_socket.cc scoped_ptr<net::StreamSocket> socket) { socket 136 chrome/browser/extensions/api/cast_channel/cast_socket.cc connection->SetSocket(socket.Pass()); socket 62 chrome/browser/extensions/api/cast_channel/cast_socket.h virtual void OnError(const CastSocket* socket, ChannelError error) = 0; socket 65 chrome/browser/extensions/api/cast_channel/cast_socket.h virtual void OnMessage(const CastSocket* socket, socket 165 chrome/browser/extensions/api/cast_channel/cast_socket.h scoped_ptr<net::StreamSocket> socket); socket 76 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc MOCK_METHOD2(OnError, void(const CastSocket* socket, socket 78 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc MOCK_METHOD2(OnMessage, void(const CastSocket* socket, socket 244 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc scoped_ptr<net::StreamSocket> socket) OVERRIDE { socket 110 chrome/browser/extensions/api/music_manager_private/device_id_linux.cc int sd = socket(AF_INET, SOCK_DGRAM, 0); socket 50 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc MOCK_METHOD2(Accept, int(scoped_ptr<net::StreamSocket>* socket, socket 75 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc scoped_ptr<TCPSocket> socket(TCPSocket::CreateSocketForTesting( socket 84 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc socket->Read(count, base::Bind(&CompleteHandler::OnReadComplete, socket 93 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc scoped_ptr<TCPSocket> socket(TCPSocket::CreateSocketForTesting( socket 106 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc socket->Write(io_buffer.get(), io_buffer->size(), socket 115 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc scoped_ptr<TCPSocket> socket(TCPSocket::CreateSocketForTesting( socket 124 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc socket->Write(io_buffer.get(), io_buffer->size(), socket 140 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc scoped_ptr<TCPSocket> socket(TCPSocket::CreateSocketForTesting( socket 154 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc socket->Write(io_buffers[i].get(), io_buffers[i]->size(), socket 171 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc scoped_ptr<TCPSocket> socket(TCPSocket::CreateSocketForTesting( socket 177 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc int result = socket->SetNoDelay(true); socket 184 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc result = socket->SetNoDelay(false); socket 193 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc scoped_ptr<TCPSocket> socket(TCPSocket::CreateSocketForTesting( socket 202 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc int result = socket->SetKeepAlive(true, 4500); socket 211 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc result = socket->SetKeepAlive(false, 0); socket 221 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc scoped_ptr<TCPSocket> socket(TCPSocket::CreateServerSocketForTesting( socket 229 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc EXPECT_EQ(net::OK, socket->Listen("127.0.0.1", 9999, 10, &err_msg)); socket 230 chrome/browser/extensions/api/socket/tcp_socket_unittest.cc socket->Accept(base::Bind(&CompleteHandler::OnAccept, socket 43 chrome/browser/extensions/api/socket/udp_socket_unittest.cc UDPSocket socket("abcdefghijklmnopqrst"); socket 47 chrome/browser/extensions/api/socket/udp_socket_unittest.cc socket.Connect("127.0.0.1", 40000, base::Bind(&OnConnected)); socket 48 chrome/browser/extensions/api/socket/udp_socket_unittest.cc socket.RecvFrom(4096, base::Bind(&OnCompleted)); socket 49 chrome/browser/extensions/api/socket/udp_socket_unittest.cc socket.RecvFrom(4096, base::Bind(&OnCompleted)); socket 70 chrome/browser/extensions/api/socket/udp_socket_unittest.cc UDPSocket socket("abcdefghijklmnopqrst"); socket 71 chrome/browser/extensions/api/socket/udp_socket_unittest.cc EXPECT_NE(0, socket.SetMulticastTimeToLive(-1)); // Negative TTL shall fail. socket 72 chrome/browser/extensions/api/socket/udp_socket_unittest.cc EXPECT_EQ(0, socket.SetMulticastTimeToLive(3)); socket 73 chrome/browser/extensions/api/socket/udp_socket_unittest.cc socket.Connect(kGroup, 13333, base::Bind(&OnConnected)); socket 78 chrome/browser/extensions/api/socket/udp_socket_unittest.cc UDPSocket socket("abcdefghijklmnopqrst"); socket 79 chrome/browser/extensions/api/socket/udp_socket_unittest.cc EXPECT_EQ(0, socket.SetMulticastLoopbackMode(false)); socket 80 chrome/browser/extensions/api/socket/udp_socket_unittest.cc socket.Connect(kGroup, 13333, base::Bind(&OnConnected)); socket 40 chrome/browser/local_discovery/service_discovery_host_client.cc LocalDiscoveryMsg_SocketInfo socket; socket 41 chrome/browser/local_discovery/service_discovery_host_client.cc socket.descriptor = socket_descriptor; socket 42 chrome/browser/local_discovery/service_discovery_host_client.cc socket.interface_index = interfaces[i].first; socket 43 chrome/browser/local_discovery/service_discovery_host_client.cc socket.address_family = interfaces[i].second; socket 44 chrome/browser/local_discovery/service_discovery_host_client.cc sockets.push_back(socket); socket 839 chrome/browser/net/chrome_network_delegate.cc net::SocketStream* socket, socket 843 chrome/browser/net/chrome_network_delegate.cc url_blacklist_manager_->IsURLBlocked(socket->url())) { socket 845 chrome/browser/net/chrome_network_delegate.cc socket->net_log()->AddEvent( socket 848 chrome/browser/net/chrome_network_delegate.cc &socket->url().possibly_invalid_spec())); socket 217 chrome/browser/process_singleton_linux.cc int sock = socket(PF_UNIX, SOCK_STREAM, 0); socket 350 chrome/browser/process_singleton_linux.cc bool ConnectSocket(ScopedSocket* socket, socket 368 chrome/browser/process_singleton_linux.cc int ret = HANDLE_EINTR(connect(socket->fd(), socket 377 chrome/browser/process_singleton_linux.cc socket->Reset(); socket 387 chrome/browser/process_singleton_linux.cc int ret = HANDLE_EINTR(connect(socket->fd(), socket 485 chrome/browser/process_singleton_linux.cc void StartListening(int socket); socket 554 chrome/browser/process_singleton_linux.cc void ProcessSingleton::LinuxWatcher::StartListening(int socket) { socket 559 chrome/browser/process_singleton_linux.cc ml->WatchFileDescriptor(socket, true, base::MessageLoopForIO::WATCH_READ, socket 712 chrome/browser/process_singleton_linux.cc ScopedSocket socket; socket 715 chrome/browser/process_singleton_linux.cc if (ConnectSocket(&socket, socket_path_, cookie_path_)) socket 770 chrome/browser/process_singleton_linux.cc setsockopt(socket.fd(), SOL_SOCKET, SO_SNDTIMEO, &timeout, sizeof(timeout)); socket 790 chrome/browser/process_singleton_linux.cc if (!WriteToSocket(socket.fd(), to_send.data(), to_send.length())) { socket 797 chrome/browser/process_singleton_linux.cc if (shutdown(socket.fd(), SHUT_WR) < 0) socket 804 chrome/browser/process_singleton_linux.cc ReadFromSocket(socket.fd(), buf, kMaxACKMessageLength, timeout_seconds); socket 212 chrome/common/mac/mock_launchd.cc CFSocketRef socket = socket 215 chrome/common/mac/mock_launchd.cc local_pipe = CFSocketGetNative(socket); socket 66 chrome/common/multi_process_lock_linux.cc int socket_fd = socket(AF_LOCAL, SOCK_STREAM, 0); socket 134 chrome/test/chromedriver/net/adb_client_socket.cc net::StreamSocket* socket) { socket 138 chrome/test/chromedriver/net/adb_client_socket.cc socket_.reset(socket); socket 306 chrome/test/chromedriver/net/adb_client_socket.cc net::StreamSocket* socket, socket 308 chrome/test/chromedriver/net/adb_client_socket.cc callback.Run(result, socket); socket 329 chrome/test/chromedriver/net/adb_client_socket.cc net::TCPClientSocket* socket = new net::TCPClientSocket( socket 331 chrome/test/chromedriver/net/adb_client_socket.cc socket->Connect(base::Bind(&UseTransportQueryForDesktop, callback, socket)); socket 72 chrome/test/chromedriver/net/port_server.cc int sock_fd = socket(AF_UNIX, SOCK_STREAM, 0); socket 68 chrome/test/chromedriver/net/port_server_unittest.cc int server_sock_fd = socket(AF_UNIX, SOCK_STREAM, 0); socket 20 chrome/utility/local_discovery/service_discovery_message_handler.cc void ClosePlatformSocket(net::SocketDescriptor socket); socket 27 chrome/utility/local_discovery/service_discovery_message_handler.cc explicit ScopedSocketFactory(net::SocketDescriptor socket) : socket_(socket) { socket 52 chrome/utility/local_discovery/service_discovery_message_handler.cc SocketInfo(net::SocketDescriptor socket, socket 55 chrome/utility/local_discovery/service_discovery_message_handler.cc : socket(socket), socket 59 chrome/utility/local_discovery/service_discovery_message_handler.cc net::SocketDescriptor socket; socket 83 chrome/utility/local_discovery/service_discovery_message_handler.cc ScopedSocketFactory platform_factory(socket_info.socket); socket 84 chrome/utility/local_discovery/service_discovery_message_handler.cc scoped_ptr<net::DatagramServerSocket> socket( socket 87 chrome/utility/local_discovery/service_discovery_message_handler.cc if (socket) { socket 88 chrome/utility/local_discovery/service_discovery_message_handler.cc socket->DetachFromThread(); socket 89 chrome/utility/local_discovery/service_discovery_message_handler.cc sockets_.push_back(socket.release()); socket 108 chrome/utility/local_discovery/service_discovery_message_handler.cc void ClosePlatformSocket(net::SocketDescriptor socket) { socket 109 chrome/utility/local_discovery/service_discovery_message_handler.cc ::closesocket(socket); socket 128 chrome/utility/local_discovery/service_discovery_message_handler.cc void ClosePlatformSocket(net::SocketDescriptor socket) { socket 129 chrome/utility/local_discovery/service_discovery_message_handler.cc ::close(socket); socket 126 components/nacl/loader/nacl_listener.cc handle->socket = socket 317 components/nacl/loader/nacl_listener.cc browser_handle.socket = socket 319 components/nacl/loader/nacl_listener.cc ppapi_renderer_handle.socket = socket 344 components/nacl/loader/nacl_listener.cc trusted_renderer_handle.socket = base::FileDescriptor( socket 99 components/nacl/renderer/ppb_nacl_private_impl.cc if (channel_handle.socket.fd == -1) { socket 64 content/browser/devtools/tethering_handler.cc scoped_ptr<net::StreamListenSocket> socket) OVERRIDE { socket 72 content/browser/devtools/tethering_handler.cc accepted_socket_ = socket.Pass(); socket 81 content/browser/devtools/tethering_handler.cc virtual void DidRead(net::StreamListenSocket* socket, socket 94 content/browser/devtools/tethering_handler.cc virtual void DidClose(net::StreamListenSocket* socket) OVERRIDE { socket 33 content/browser/renderer_host/java/java_bridge_channel_host.cc if (channel_handle_.socket.fd > 0) { socket 34 content/browser/renderer_host/java/java_bridge_channel_host.cc close(channel_handle_.socket.fd); socket 76 content/browser/renderer_host/java/java_bridge_channel_host.cc channel_handle_.socket.fd = channel_->TakeClientFileDescriptor(); socket 203 content/browser/renderer_host/p2p/socket_dispatcher_host.cc scoped_ptr<P2PSocketHost> socket(P2PSocketHost::Create( socket 206 content/browser/renderer_host/p2p/socket_dispatcher_host.cc if (!socket) { socket 211 content/browser/renderer_host/p2p/socket_dispatcher_host.cc if (socket->Init(local_address, remote_address)) { socket 212 content/browser/renderer_host/p2p/socket_dispatcher_host.cc sockets_[socket_id] = socket.release(); socket 219 content/browser/renderer_host/p2p/socket_dispatcher_host.cc P2PSocketHost* socket = LookupSocket(listen_socket_id); socket 220 content/browser/renderer_host/p2p/socket_dispatcher_host.cc if (!socket) { socket 226 content/browser/renderer_host/p2p/socket_dispatcher_host.cc socket->AcceptIncomingTcpConnection(remote_address, connected_socket_id); socket 237 content/browser/renderer_host/p2p/socket_dispatcher_host.cc P2PSocketHost* socket = LookupSocket(socket_id); socket 238 content/browser/renderer_host/p2p/socket_dispatcher_host.cc if (!socket) { socket 247 content/browser/renderer_host/p2p/socket_dispatcher_host.cc delete socket; socket 252 content/browser/renderer_host/p2p/socket_dispatcher_host.cc socket->Send(socket_address, data, options, packet_id); socket 258 content/browser/renderer_host/p2p/socket_dispatcher_host.cc P2PSocketHost* socket = LookupSocket(socket_id); socket 259 content/browser/renderer_host/p2p/socket_dispatcher_host.cc if (!socket) { socket 264 content/browser/renderer_host/p2p/socket_dispatcher_host.cc socket->SetOption(option, value); socket 65 content/browser/renderer_host/p2p/socket_host_tcp.cc net::StreamSocket* socket) { socket 66 content/browser/renderer_host/p2p/socket_host_tcp.cc DCHECK(socket); socket 71 content/browser/renderer_host/p2p/socket_host_tcp.cc socket_.reset(socket); socket 38 content/browser/renderer_host/p2p/socket_host_tcp.h net::StreamSocket* socket); socket 131 content/browser/renderer_host/p2p/socket_host_tcp_server.cc net::StreamSocket* socket = it->second; socket 141 content/browser/renderer_host/p2p/socket_host_tcp_server.cc if (!result->InitAccepted(remote_address, socket)) socket 33 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc void AddIncoming(net::StreamSocket* socket) { socket 36 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc accept_socket_->reset(socket); socket 46 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc incoming_sockets_.push_back(socket); socket 61 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc virtual int Accept(scoped_ptr<net::StreamSocket>* socket, socket 63 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc DCHECK(socket); socket 65 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc socket->reset(incoming_sockets_.front()); socket 69 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc accept_socket_ = socket; socket 220 content/browser/renderer_host/pepper/content_browser_pepper_host_factory.cc scoped_ptr<net::TCPSocket> socket) { socket 225 content/browser/renderer_host/pepper/content_browser_pepper_host_factory.cc socket.Pass())); socket 42 content/browser/renderer_host/pepper/content_browser_pepper_host_factory.h scoped_ptr<net::TCPSocket> socket); socket 61 content/browser/renderer_host/pepper/pepper_tcp_socket.cc net::StreamSocket* socket, socket 70 content/browser/renderer_host/pepper/pepper_tcp_socket.cc socket_(socket) { socket 83 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc scoped_ptr<net::TCPSocket> socket) socket 95 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc socket_(socket.Pass()), socket 63 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.h scoped_ptr<net::TCPSocket> socket); socket 269 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc scoped_ptr<net::UDPServerSocket> socket(new net::UDPServerSocket( socket 280 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc socket->AllowAddressReuse(); socket 282 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc socket->AllowBroadcast(); socket 285 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc socket->Listen(net::IPEndPoint(address, port))); socket 292 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc pp_result = NetErrorToPepperError(socket->GetLocalAddress(&bound_address)); socket 309 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc socket_.swap(socket); socket 60 content/browser/renderer_host/socket_stream_dispatcher_host.cc void SocketStreamDispatcherHost::OnConnected(net::SocketStream* socket, socket 62 content/browser/renderer_host/socket_stream_dispatcher_host.cc int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); socket 76 content/browser/renderer_host/socket_stream_dispatcher_host.cc void SocketStreamDispatcherHost::OnSentData(net::SocketStream* socket, socket 78 content/browser/renderer_host/socket_stream_dispatcher_host.cc int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); socket 92 content/browser/renderer_host/socket_stream_dispatcher_host.cc net::SocketStream* socket, const char* data, int len) { socket 93 content/browser/renderer_host/socket_stream_dispatcher_host.cc int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); socket 107 content/browser/renderer_host/socket_stream_dispatcher_host.cc void SocketStreamDispatcherHost::OnClose(net::SocketStream* socket) { socket 108 content/browser/renderer_host/socket_stream_dispatcher_host.cc int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); socket 117 content/browser/renderer_host/socket_stream_dispatcher_host.cc void SocketStreamDispatcherHost::OnError(const net::SocketStream* socket, socket 119 content/browser/renderer_host/socket_stream_dispatcher_host.cc int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); socket 135 content/browser/renderer_host/socket_stream_dispatcher_host.cc net::SocketStream* socket, const net::SSLInfo& ssl_info, bool fatal) { socket 136 content/browser/renderer_host/socket_stream_dispatcher_host.cc int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); socket 148 content/browser/renderer_host/socket_stream_dispatcher_host.cc socket->url(), render_process_id_, socket_stream_host->render_frame_id(), socket 152 content/browser/renderer_host/socket_stream_dispatcher_host.cc bool SocketStreamDispatcherHost::CanGetCookies(net::SocketStream* socket, socket 51 content/browser/renderer_host/socket_stream_dispatcher_host.h virtual void OnConnected(net::SocketStream* socket, socket 53 content/browser/renderer_host/socket_stream_dispatcher_host.h virtual void OnSentData(net::SocketStream* socket, int amount_sent) OVERRIDE; socket 54 content/browser/renderer_host/socket_stream_dispatcher_host.h virtual void OnReceivedData(net::SocketStream* socket, socket 56 content/browser/renderer_host/socket_stream_dispatcher_host.h virtual void OnClose(net::SocketStream* socket) OVERRIDE; socket 57 content/browser/renderer_host/socket_stream_dispatcher_host.h virtual void OnError(const net::SocketStream* socket, int error) OVERRIDE; socket 58 content/browser/renderer_host/socket_stream_dispatcher_host.h virtual void OnSSLCertificateError(net::SocketStream* socket, socket 61 content/browser/renderer_host/socket_stream_dispatcher_host.h virtual bool CanGetCookies(net::SocketStream* socket, socket 46 content/browser/renderer_host/socket_stream_host.cc const net::SocketStream* socket) { socket 47 content/browser/renderer_host/socket_stream_host.cc net::SocketStream::UserData* d = socket->GetUserData(kSocketIdKey); socket 38 content/browser/renderer_host/socket_stream_host.h static int SocketIdFromSocketStream(const net::SocketStream* socket); socket 161 content/browser/zygote_host/zygote_host_impl_linux.cc dummy_fd = socket(PF_UNIX, SOCK_DGRAM, 0); socket 72 content/child/npapi/np_channel_base.cc base::ScopedFD fd(channel_handle.socket.auto_close ? socket 73 content/child/npapi/np_channel_base.cc channel_handle.socket.fd : -1); socket 177 content/child/npapi/np_channel_base.cc if (mode_ == IPC::Channel::MODE_CLIENT && -1 == channel_handle_.socket.fd) socket 152 content/common/gpu/gpu_channel_manager.cc channel_handle.socket = base::FileDescriptor(renderer_fd, true); socket 145 content/common/sandbox_linux/sandbox_seccomp_bpf_linux.cc syscall_ret = socket(AF_NETLINK, SOCK_DGRAM, 0); socket 182 content/plugin/plugin_thread.cc channel_handle.socket = socket 500 content/ppapi_plugin/ppapi_thread.cc handle->socket = base::FileDescriptor(dispatcher->TakeRendererFD(), true); socket 501 content/ppapi_plugin/ppapi_thread.cc if (handle->socket.fd == -1) socket 140 content/renderer/media/audio_input_message_filter.cc base::SyncSocket socket(socket_handle); socket 192 content/renderer/media/audio_message_filter.cc base::SyncSocket socket(socket_handle); socket 449 content/renderer/p2p/ipc_socket_factory.cc scoped_ptr<IpcPacketSocket> socket(new IpcPacketSocket()); socket 456 content/renderer/p2p/ipc_socket_factory.cc socket->InitAcceptedTcp(client, local_address_, remote_address); socket 457 content/renderer/p2p/ipc_socket_factory.cc SignalNewConnection(this, socket.release()); socket 577 content/renderer/p2p/ipc_socket_factory.cc scoped_ptr<IpcPacketSocket> socket(new IpcPacketSocket()); socket 580 content/renderer/p2p/ipc_socket_factory.cc if (!socket->Init(P2P_SOCKET_UDP, socket_client, socket 584 content/renderer/p2p/ipc_socket_factory.cc return socket.release(); socket 598 content/renderer/p2p/ipc_socket_factory.cc scoped_ptr<IpcPacketSocket> socket(new IpcPacketSocket()); socket 599 content/renderer/p2p/ipc_socket_factory.cc if (!socket->Init(type, socket_client, local_address, socket 603 content/renderer/p2p/ipc_socket_factory.cc return socket.release(); socket 624 content/renderer/p2p/ipc_socket_factory.cc scoped_ptr<IpcPacketSocket> socket(new IpcPacketSocket()); socket 625 content/renderer/p2p/ipc_socket_factory.cc if (!socket->Init(type, socket_client, local_address, remote_address)) socket 627 content/renderer/p2p/ipc_socket_factory.cc return socket.release(); socket 27 content/renderer/pepper/audio_helper.h base::SyncSocket::Handle socket); socket 42 content/renderer/pepper/host_dispatcher_wrapper.cc DCHECK_NE(-1, channel_handle.socket.fd); socket 43 content/renderer/pepper/host_dispatcher_wrapper.cc if (channel_handle.socket.fd == -1) socket 25 content/renderer/pepper/pepper_audio_input_host.cc base::PlatformFile ConvertSyncSocketHandle(const base::SyncSocket& socket) { socket 26 content/renderer/pepper/pepper_audio_input_host.cc return socket.handle(); socket 81 content/renderer/pepper/pepper_audio_input_host.cc base::SyncSocket::Handle socket) { socket 82 content/renderer/pepper/pepper_audio_input_host.cc OnOpenComplete(PP_OK, shared_memory_handle, shared_memory_size, socket); socket 185 content/renderer/pepper/pepper_audio_input_host.cc const base::SyncSocket& socket, socket 190 content/renderer/pepper/pepper_audio_input_host.cc ConvertSyncSocketHandle(socket), false); socket 39 content/renderer/pepper/pepper_audio_input_host.h base::SyncSocket::Handle socket); socket 57 content/renderer/pepper/pepper_audio_input_host.h const base::SyncSocket& socket, socket 63 content/renderer/pepper/pepper_broker.cc DCHECK_NE(-1, channel_handle.socket.fd); socket 64 content/renderer/pepper/pepper_broker.cc if (channel_handle.socket.fd == -1) socket 54 content/renderer/pepper/ppb_audio_impl.h base::SyncSocket::Handle socket) OVERRIDE; socket 1303 content/renderer/render_thread_impl.cc channel_handle.socket.fd == -1 || socket 118 content/shell/browser/shell_network_delegate.cc net::SocketStream* socket, socket 312 content/zygote/zygote_linux.cc dummy_fd = socket(PF_UNIX, SOCK_DGRAM, 0); socket 171 device/bluetooth/bluetooth_device_win.cc scoped_refptr<BluetoothSocket> socket( socket 173 device/bluetooth/bluetooth_device_win.cc if (socket.get() != NULL) { socket 174 device/bluetooth/bluetooth_device_win.cc callback.Run(socket); socket 291 device/bluetooth/bluetooth_profile_chromeos.cc scoped_refptr<BluetoothSocket> socket(( socket 293 device/bluetooth/bluetooth_profile_chromeos.cc connection_callback_.Run(device, socket); socket 101 device/bluetooth/bluetooth_profile_chromeos_unittest.cc scoped_refptr<BluetoothSocket> socket) { socket 104 device/bluetooth/bluetooth_profile_chromeos_unittest.cc last_socket_ = socket; socket 174 device/bluetooth/bluetooth_profile_chromeos_unittest.cc scoped_refptr<BluetoothSocket> socket = last_socket_; socket 187 device/bluetooth/bluetooth_profile_chromeos_unittest.cc success = socket->Receive(read_buffer.get()); socket 191 device/bluetooth/bluetooth_profile_chromeos_unittest.cc EXPECT_EQ("", socket->GetLastErrorMessage()); socket 197 device/bluetooth/bluetooth_profile_chromeos_unittest.cc success = socket->Send(write_buffer.get()); socket 201 device/bluetooth/bluetooth_profile_chromeos_unittest.cc EXPECT_EQ("", socket->GetLastErrorMessage()); socket 208 device/bluetooth/bluetooth_profile_chromeos_unittest.cc success = socket->Receive(read_buffer.get()); socket 213 device/bluetooth/bluetooth_profile_chromeos_unittest.cc EXPECT_EQ("", socket->GetLastErrorMessage()); socket 223 device/bluetooth/bluetooth_profile_chromeos_unittest.cc success = socket->Send(write_buffer.get()); socket 227 device/bluetooth/bluetooth_profile_chromeos_unittest.cc EXPECT_EQ("Disconnected", socket->GetLastErrorMessage()); socket 232 device/bluetooth/bluetooth_profile_chromeos_unittest.cc success = socket->Receive(read_buffer.get()); socket 236 device/bluetooth/bluetooth_profile_chromeos_unittest.cc EXPECT_EQ("Disconnected", socket->GetLastErrorMessage()); socket 239 device/bluetooth/bluetooth_profile_chromeos_unittest.cc socket = NULL; socket 300 device/bluetooth/bluetooth_profile_chromeos_unittest.cc scoped_refptr<BluetoothSocket> socket = last_socket_; socket 313 device/bluetooth/bluetooth_profile_chromeos_unittest.cc success = socket->Receive(read_buffer.get()); socket 316 device/bluetooth/bluetooth_profile_chromeos_unittest.cc EXPECT_EQ("", socket->GetLastErrorMessage()); socket 322 device/bluetooth/bluetooth_profile_chromeos_unittest.cc success = socket->Send(write_buffer.get()); socket 326 device/bluetooth/bluetooth_profile_chromeos_unittest.cc EXPECT_EQ("", socket->GetLastErrorMessage()); socket 333 device/bluetooth/bluetooth_profile_chromeos_unittest.cc success = socket->Receive(read_buffer.get()); socket 338 device/bluetooth/bluetooth_profile_chromeos_unittest.cc EXPECT_EQ("", socket->GetLastErrorMessage()); socket 348 device/bluetooth/bluetooth_profile_chromeos_unittest.cc success = socket->Send(write_buffer.get()); socket 352 device/bluetooth/bluetooth_profile_chromeos_unittest.cc EXPECT_EQ("Disconnected", socket->GetLastErrorMessage()); socket 357 device/bluetooth/bluetooth_profile_chromeos_unittest.cc success = socket->Receive(read_buffer.get()); socket 360 device/bluetooth/bluetooth_profile_chromeos_unittest.cc EXPECT_EQ("Disconnected", socket->GetLastErrorMessage()); socket 363 device/bluetooth/bluetooth_profile_chromeos_unittest.cc socket = NULL; socket 37 device/bluetooth/bluetooth_profile_win.cc scoped_refptr<BluetoothSocket> socket( socket 39 device/bluetooth/bluetooth_profile_win.cc if (socket.get() != NULL) { socket 40 device/bluetooth/bluetooth_profile_win.cc connection_callback_.Run(device, socket); socket 48 device/bluetooth/bluetooth_socket_win.cc SOCKET socket_fd = socket(AF_BTH, SOCK_STREAM, BTHPROTO_RFCOMM); socket 66 extensions/browser/api/socket/socket_api.cc int SocketAsyncApiFunction::AddSocket(Socket* socket) { socket 67 extensions/browser/api/socket/socket_api.cc return manager_->Add(socket); socket 138 extensions/browser/api/socket/socket_api.cc params_ = core_api::socket::Create::Params::Create(*args_); socket 142 extensions/browser/api/socket/socket_api.cc case extensions::core_api::socket::SOCKET_TYPE_TCP: socket 145 extensions/browser/api/socket/socket_api.cc case extensions::core_api::socket::SOCKET_TYPE_UDP: socket 148 extensions/browser/api/socket/socket_api.cc case extensions::core_api::socket::SOCKET_TYPE_NONE: socket 157 extensions/browser/api/socket/socket_api.cc Socket* socket = NULL; socket 159 extensions/browser/api/socket/socket_api.cc socket = new TCPSocket(extension_->id()); socket 161 extensions/browser/api/socket/socket_api.cc socket = new UDPSocket(extension_->id()); socket 163 extensions/browser/api/socket/socket_api.cc DCHECK(socket); socket 166 extensions/browser/api/socket/socket_api.cc result->SetInteger(kSocketIdKey, AddSocket(socket)); socket 250 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(socket_id_); socket 251 extensions/browser/api/socket/socket_api.cc if (socket) socket 252 extensions/browser/api/socket/socket_api.cc socket->Disconnect(); socket 267 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(socket_id_); socket 269 extensions/browser/api/socket/socket_api.cc if (!socket) { socket 275 extensions/browser/api/socket/socket_api.cc if (socket->GetSocketType() == Socket::TYPE_UDP) { socket 284 extensions/browser/api/socket/socket_api.cc } else if (socket->GetSocketType() == Socket::TYPE_TCP) { socket 290 extensions/browser/api/socket/socket_api.cc result = socket->Bind(address_, port_); socket 299 extensions/browser/api/socket/socket_api.cc params_ = core_api::socket::Listen::Params::Create(*args_); socket 307 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(params_->socket_id); socket 308 extensions/browser/api/socket/socket_api.cc if (socket) { socket 319 extensions/browser/api/socket/socket_api.cc socket->Listen(params_->address, socket 335 extensions/browser/api/socket/socket_api.cc params_ = core_api::socket::Accept::Params::Create(*args_); socket 341 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(params_->socket_id); socket 342 extensions/browser/api/socket/socket_api.cc if (socket) { socket 343 extensions/browser/api/socket/socket_api.cc socket->Accept(base::Bind(&SocketAcceptFunction::OnAccept, this)); socket 351 extensions/browser/api/socket/socket_api.cc net::TCPClientSocket* socket) { socket 354 extensions/browser/api/socket/socket_api.cc if (socket) { socket 355 extensions/browser/api/socket/socket_api.cc Socket* client_socket = new TCPSocket(socket, extension_id(), true); socket 368 extensions/browser/api/socket/socket_api.cc params_ = core_api::socket::Read::Params::Create(*args_); socket 374 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(params_->socket_id); socket 375 extensions/browser/api/socket/socket_api.cc if (!socket) { socket 381 extensions/browser/api/socket/socket_api.cc socket->Read(params_->buffer_size.get() ? *params_->buffer_size.get() : 4096, socket 417 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(socket_id_); socket 419 extensions/browser/api/socket/socket_api.cc if (!socket) { socket 425 extensions/browser/api/socket/socket_api.cc socket->Write(io_buffer_, socket 443 extensions/browser/api/socket/socket_api.cc params_ = core_api::socket::RecvFrom::Params::Create(*args_); socket 449 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(params_->socket_id); socket 450 extensions/browser/api/socket/socket_api.cc if (!socket) { socket 456 extensions/browser/api/socket/socket_api.cc socket->RecvFrom(params_->buffer_size.get() ? *params_->buffer_size : 4096, socket 555 extensions/browser/api/socket/socket_api.cc params_ = core_api::socket::SetKeepAlive::Params::Create(*args_); socket 562 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(params_->socket_id); socket 563 extensions/browser/api/socket/socket_api.cc if (socket) { socket 567 extensions/browser/api/socket/socket_api.cc result = socket->SetKeepAlive(params_->enable, delay); socket 579 extensions/browser/api/socket/socket_api.cc params_ = core_api::socket::SetNoDelay::Params::Create(*args_); socket 586 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(params_->socket_id); socket 587 extensions/browser/api/socket/socket_api.cc if (socket) socket 588 extensions/browser/api/socket/socket_api.cc result = socket->SetNoDelay(params_->no_delay); socket 599 extensions/browser/api/socket/socket_api.cc params_ = core_api::socket::GetInfo::Params::Create(*args_); socket 605 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(params_->socket_id); socket 606 extensions/browser/api/socket/socket_api.cc if (!socket) { socket 611 extensions/browser/api/socket/socket_api.cc core_api::socket::SocketInfo info; socket 614 extensions/browser/api/socket/socket_api.cc if (socket->GetSocketType() == Socket::TYPE_TCP) socket 615 extensions/browser/api/socket/socket_api.cc info.socket_type = extensions::core_api::socket::SOCKET_TYPE_TCP; socket 617 extensions/browser/api/socket/socket_api.cc info.socket_type = extensions::core_api::socket::SOCKET_TYPE_UDP; socket 618 extensions/browser/api/socket/socket_api.cc info.connected = socket->IsConnected(); socket 625 extensions/browser/api/socket/socket_api.cc if (socket->GetPeerAddress(&peerAddress)) { socket 632 extensions/browser/api/socket/socket_api.cc if (socket->GetLocalAddress(&localAddress)) { socket 680 extensions/browser/api/socket/socket_api.cc std::vector<linked_ptr<core_api::socket::NetworkInterface> > create_arg; socket 685 extensions/browser/api/socket/socket_api.cc linked_ptr<core_api::socket::NetworkInterface> info = socket 686 extensions/browser/api/socket/socket_api.cc make_linked_ptr(new core_api::socket::NetworkInterface); socket 693 extensions/browser/api/socket/socket_api.cc results_ = core_api::socket::GetNetworkList::Results::Create(create_arg); socket 702 extensions/browser/api/socket/socket_api.cc params_ = core_api::socket::JoinGroup::Params::Create(*args_); socket 709 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(params_->socket_id); socket 710 extensions/browser/api/socket/socket_api.cc if (!socket) { socket 716 extensions/browser/api/socket/socket_api.cc if (socket->GetSocketType() != Socket::TYPE_UDP) { socket 734 extensions/browser/api/socket/socket_api.cc result = static_cast<UDPSocket*>(socket)->JoinGroup(params_->address); socket 746 extensions/browser/api/socket/socket_api.cc params_ = core_api::socket::LeaveGroup::Params::Create(*args_); socket 753 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(params_->socket_id); socket 755 extensions/browser/api/socket/socket_api.cc if (!socket) { socket 761 extensions/browser/api/socket/socket_api.cc if (socket->GetSocketType() != Socket::TYPE_UDP) { socket 778 extensions/browser/api/socket/socket_api.cc result = static_cast<UDPSocket*>(socket)->LeaveGroup(params_->address); socket 789 extensions/browser/api/socket/socket_api.cc params_ = core_api::socket::SetMulticastTimeToLive::Params::Create(*args_); socket 795 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(params_->socket_id); socket 796 extensions/browser/api/socket/socket_api.cc if (!socket) { socket 802 extensions/browser/api/socket/socket_api.cc if (socket->GetSocketType() != Socket::TYPE_UDP) { socket 809 extensions/browser/api/socket/socket_api.cc static_cast<UDPSocket*>(socket)->SetMulticastTimeToLive(params_->ttl); socket 822 extensions/browser/api/socket/socket_api.cc params_ = core_api::socket::SetMulticastLoopbackMode::Params::Create(*args_); socket 829 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(params_->socket_id); socket 830 extensions/browser/api/socket/socket_api.cc if (!socket) { socket 836 extensions/browser/api/socket/socket_api.cc if (socket->GetSocketType() != Socket::TYPE_UDP) { socket 842 extensions/browser/api/socket/socket_api.cc result = static_cast<UDPSocket*>(socket) socket 854 extensions/browser/api/socket/socket_api.cc params_ = core_api::socket::GetJoinedGroups::Params::Create(*args_); socket 861 extensions/browser/api/socket/socket_api.cc Socket* socket = GetSocket(params_->socket_id); socket 862 extensions/browser/api/socket/socket_api.cc if (!socket) { socket 868 extensions/browser/api/socket/socket_api.cc if (socket->GetSocketType() != Socket::TYPE_UDP) { socket 887 extensions/browser/api/socket/socket_api.cc socket)->GetJoinedGroups()); socket 42 extensions/browser/api/socket/socket_api.h virtual int Add(Socket* socket) = 0; socket 66 extensions/browser/api/socket/socket_api.h virtual int Add(Socket* socket) OVERRIDE { socket 68 extensions/browser/api/socket/socket_api.h return manager_->Add(static_cast<T*>(socket)); socket 104 extensions/browser/api/socket/socket_api.h int AddSocket(Socket* socket); socket 153 extensions/browser/api/socket/socket_api.h scoped_ptr<core_api::socket::Create::Params> params_; socket 244 extensions/browser/api/socket/socket_api.h scoped_ptr<core_api::socket::Listen::Params> params_; socket 261 extensions/browser/api/socket/socket_api.h void OnAccept(int result_code, net::TCPClientSocket* socket); socket 263 extensions/browser/api/socket/socket_api.h scoped_ptr<core_api::socket::Accept::Params> params_; socket 281 extensions/browser/api/socket/socket_api.h scoped_ptr<core_api::socket::Read::Params> params_; socket 322 extensions/browser/api/socket/socket_api.h scoped_ptr<core_api::socket::RecvFrom::Params> params_; socket 367 extensions/browser/api/socket/socket_api.h scoped_ptr<core_api::socket::SetKeepAlive::Params> params_; socket 384 extensions/browser/api/socket/socket_api.h scoped_ptr<core_api::socket::SetNoDelay::Params> params_; socket 401 extensions/browser/api/socket/socket_api.h scoped_ptr<core_api::socket::GetInfo::Params> params_; socket 432 extensions/browser/api/socket/socket_api.h scoped_ptr<core_api::socket::JoinGroup::Params> params_; socket 449 extensions/browser/api/socket/socket_api.h scoped_ptr<core_api::socket::LeaveGroup::Params> params_; socket 467 extensions/browser/api/socket/socket_api.h scoped_ptr<core_api::socket::SetMulticastTimeToLive::Params> params_; socket 485 extensions/browser/api/socket/socket_api.h scoped_ptr<core_api::socket::SetMulticastLoopbackMode::Params> params_; socket 503 extensions/browser/api/socket/socket_api.h scoped_ptr<core_api::socket::GetJoinedGroups::Params> params_; socket 23 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc ResumableTCPSocket* socket) { socket 28 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (!socket->name().empty()) { socket 29 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc socket_info->name.reset(new std::string(socket->name())); socket 31 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc socket_info->persistent = socket->persistent(); socket 32 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (socket->buffer_size() > 0) { socket 33 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc socket_info->buffer_size.reset(new int(socket->buffer_size())); socket 35 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc socket_info->paused = socket->paused(); socket 36 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc socket_info->connected = socket->IsConnected(); socket 40 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (socket->GetLocalAddress(&localAddress)) { socket 51 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (socket->GetPeerAddress(&peerAddress)) { socket 60 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc void SetSocketProperties(ResumableTCPSocket* socket, socket 63 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc socket->set_name(*properties->name.get()); socket 66 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc socket->set_persistent(*properties->persistent.get()); socket 71 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc socket->set_buffer_size(*properties->buffer_size.get()); socket 119 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc ResumableTCPSocket* socket = new ResumableTCPSocket(extension_->id()); socket 123 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc SetSocketProperties(socket, properties); socket 127 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc create_info.socket_id = AddSocket(socket); socket 142 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); socket 143 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (!socket) { socket 148 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc SetSocketProperties(socket, ¶ms_.get()->properties); socket 171 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); socket 172 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (!socket) { socket 177 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (socket->paused() != params_->paused) { socket 178 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc socket->set_paused(params_->paused); socket 179 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (socket->IsConnected() && !params_->paused) { socket 199 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); socket 200 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (!socket) { socket 207 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc bool success = socket->SetKeepAlive(params_->enable, delay); socket 225 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); socket 226 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (!socket) { socket 231 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc bool success = socket->SetNoDelay(params_->no_delay); socket 257 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); socket 258 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (!socket) { socket 285 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); socket 286 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (!socket) { socket 292 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc socket->Connect(resolved_address_, socket 320 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); socket 321 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (!socket) { socket 326 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc socket->Disconnect(); socket 343 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); socket 344 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (!socket) { socket 350 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc socket->Write(io_buffer_, socket 389 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); socket 390 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (!socket) { socket 410 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); socket 411 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (!socket) { socket 417 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc CreateSocketInfo(params_->socket_id, socket); socket 435 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc ResumableTCPSocket* socket = GetTcpSocket(socket_id); socket 436 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc if (socket) { socket 437 extensions/browser/api/sockets_tcp/sockets_tcp_api.cc socket_infos.push_back(CreateSocketInfo(socket_id, socket)); socket 91 extensions/browser/api/sockets_tcp/tcp_socket_event_dispatcher.cc ResumableTCPSocket* socket = socket 93 extensions/browser/api/sockets_tcp/tcp_socket_event_dispatcher.cc if (!socket) { socket 97 extensions/browser/api/sockets_tcp/tcp_socket_event_dispatcher.cc DCHECK(params.extension_id == socket->owner_extension_id()) socket 101 extensions/browser/api/sockets_tcp/tcp_socket_event_dispatcher.cc if (socket->paused()) socket 104 extensions/browser/api/sockets_tcp/tcp_socket_event_dispatcher.cc int buffer_size = socket->buffer_size(); socket 107 extensions/browser/api/sockets_tcp/tcp_socket_event_dispatcher.cc socket->Read(buffer_size, socket 160 extensions/browser/api/sockets_tcp/tcp_socket_event_dispatcher.cc ResumableTCPSocket* socket = socket 162 extensions/browser/api/sockets_tcp/tcp_socket_event_dispatcher.cc if (socket) { socket 163 extensions/browser/api/sockets_tcp/tcp_socket_event_dispatcher.cc socket->set_paused(true); socket 27 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc ResumableTCPServerSocket* socket) { socket 32 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc if (!socket->name().empty()) { socket 33 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc socket_info->name.reset(new std::string(socket->name())); socket 35 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc socket_info->persistent = socket->persistent(); socket 36 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc socket_info->paused = socket->paused(); socket 40 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc if (socket->GetLocalAddress(&localAddress)) { socket 49 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc void SetSocketProperties(ResumableTCPServerSocket* socket, socket 52 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc socket->set_name(*properties->name.get()); socket 55 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc socket->set_persistent(*properties->persistent.get()); socket 88 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc ResumableTCPServerSocket* socket = socket 94 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc SetSocketProperties(socket, properties); socket 98 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc create_info.socket_id = AddSocket(socket); socket 113 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); socket 114 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc if (!socket) { socket 119 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc SetSocketProperties(socket, ¶ms_.get()->properties); socket 143 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); socket 144 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc if (!socket) { socket 149 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc if (socket->paused() != params_->paused) { socket 150 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc socket->set_paused(params_->paused); socket 151 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc if (socket->IsConnected() && !params_->paused) { socket 180 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); socket 181 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc if (!socket) { socket 193 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc int net_result = socket->Listen( socket 221 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); socket 222 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc if (!socket) { socket 227 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc socket->Disconnect(); socket 242 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); socket 243 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc if (!socket) { socket 263 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); socket 264 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc if (!socket) { socket 270 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc CreateSocketInfo(params_->socket_id, socket); socket 288 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc ResumableTCPServerSocket* socket = GetTcpSocket(socket_id); socket 289 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc if (socket) { socket 290 extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc socket_infos.push_back(CreateSocketInfo(socket_id, socket)); socket 101 extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.cc ResumableTCPServerSocket* socket = socket 103 extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.cc if (!socket) { socket 107 extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.cc DCHECK(params.extension_id == socket->owner_extension_id()) socket 111 extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.cc if (socket->paused()) socket 114 extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.cc socket->Accept( socket 122 extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.cc net::TCPClientSocket* socket) { socket 127 extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.cc new ResumableTCPSocket(socket, params.extension_id, true); socket 161 extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.cc ResumableTCPServerSocket* socket = socket 163 extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.cc if (socket) { socket 164 extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.cc socket->set_paused(true); socket 80 extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.h net::TCPClientSocket* socket); socket 51 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket) { socket 57 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (!socket->name().empty()) { socket 58 extensions/browser/api/sockets_udp/sockets_udp_api.cc socket_info->name.reset(new std::string(socket->name())); socket 60 extensions/browser/api/sockets_udp/sockets_udp_api.cc socket_info->persistent = socket->persistent(); socket 61 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (socket->buffer_size() > 0) { socket 62 extensions/browser/api/sockets_udp/sockets_udp_api.cc socket_info->buffer_size.reset(new int(socket->buffer_size())); socket 64 extensions/browser/api/sockets_udp/sockets_udp_api.cc socket_info->paused = socket->paused(); socket 68 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (socket->GetLocalAddress(&localAddress)) { socket 77 extensions/browser/api/sockets_udp/sockets_udp_api.cc void SetSocketProperties(ResumableUDPSocket* socket, socket 80 extensions/browser/api/sockets_udp/sockets_udp_api.cc socket->set_name(*properties->name.get()); socket 83 extensions/browser/api/sockets_udp/sockets_udp_api.cc socket->set_persistent(*properties->persistent.get()); socket 86 extensions/browser/api/sockets_udp/sockets_udp_api.cc socket->set_buffer_size(*properties->buffer_size.get()); socket 101 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = new ResumableUDPSocket(extension_->id()); socket 105 extensions/browser/api/sockets_udp/sockets_udp_api.cc SetSocketProperties(socket, properties); socket 109 extensions/browser/api/sockets_udp/sockets_udp_api.cc create_info.socket_id = AddSocket(socket); socket 124 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); socket 125 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (!socket) { socket 130 extensions/browser/api/sockets_udp/sockets_udp_api.cc SetSocketProperties(socket, ¶ms_.get()->properties); socket 153 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); socket 154 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (!socket) { socket 159 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (socket->paused() != params_->paused) { socket 160 extensions/browser/api/sockets_udp/sockets_udp_api.cc socket->set_paused(params_->paused); socket 161 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (socket->IsBound() && !params_->paused) { socket 189 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); socket 190 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (!socket) { socket 202 extensions/browser/api/sockets_udp/sockets_udp_api.cc int net_result = socket->Bind(params_->address, params_->port); socket 227 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); socket 228 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (!socket) { socket 254 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); socket 255 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (!socket) { socket 261 extensions/browser/api/sockets_udp/sockets_udp_api.cc socket->SendTo(io_buffer_, socket 302 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); socket 303 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (!socket) { socket 308 extensions/browser/api/sockets_udp/sockets_udp_api.cc socket->Disconnect(); socket 324 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); socket 325 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (!socket) { socket 331 extensions/browser/api/sockets_udp/sockets_udp_api.cc CreateSocketInfo(params_->socket_id, socket); socket 349 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = GetUdpSocket(socket_id); socket 350 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (socket) { socket 351 extensions/browser/api/sockets_udp/sockets_udp_api.cc socket_infos.push_back(CreateSocketInfo(socket_id, socket)); socket 369 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); socket 370 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (!socket) { socket 384 extensions/browser/api/sockets_udp/sockets_udp_api.cc int net_result = socket->JoinGroup(params_->address); socket 401 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); socket 402 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (!socket) { socket 416 extensions/browser/api/sockets_udp/sockets_udp_api.cc int net_result = socket->LeaveGroup(params_->address); socket 436 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); socket 437 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (!socket) { socket 442 extensions/browser/api/sockets_udp/sockets_udp_api.cc int net_result = socket->SetMulticastTimeToLive(params_->ttl); socket 462 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); socket 463 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (!socket) { socket 468 extensions/browser/api/sockets_udp/sockets_udp_api.cc int net_result = socket->SetMulticastLoopbackMode(params_->enabled); socket 485 extensions/browser/api/sockets_udp/sockets_udp_api.cc ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); socket 486 extensions/browser/api/sockets_udp/sockets_udp_api.cc if (!socket) { socket 500 extensions/browser/api/sockets_udp/sockets_udp_api.cc const std::vector<std::string>& groups = socket->GetJoinedGroups(); socket 78 extensions/browser/api/sockets_udp/udp_socket_event_dispatcher.cc ResumableUDPSocket* socket = socket 80 extensions/browser/api/sockets_udp/udp_socket_event_dispatcher.cc if (socket == NULL) { socket 84 extensions/browser/api/sockets_udp/udp_socket_event_dispatcher.cc DCHECK(params.extension_id == socket->owner_extension_id()) socket 88 extensions/browser/api/sockets_udp/udp_socket_event_dispatcher.cc if (socket->paused()) socket 91 extensions/browser/api/sockets_udp/udp_socket_event_dispatcher.cc int buffer_size = (socket->buffer_size() <= 0 ? 4096 : socket->buffer_size()); socket 92 extensions/browser/api/sockets_udp/udp_socket_event_dispatcher.cc socket->RecvFrom( socket 146 extensions/browser/api/sockets_udp/udp_socket_event_dispatcher.cc ResumableUDPSocket* socket = socket 148 extensions/browser/api/sockets_udp/udp_socket_event_dispatcher.cc if (socket) { socket 149 extensions/browser/api/sockets_udp/udp_socket_event_dispatcher.cc socket->set_paused(true); socket 22 google_apis/gcm/base/socket_stream.cc SocketInputStream::SocketInputStream(net::StreamSocket* socket) socket 23 google_apis/gcm/base/socket_stream.cc : socket_(socket), socket 30 google_apis/gcm/base/socket_stream.cc DCHECK(socket->IsConnected()); socket 208 google_apis/gcm/base/socket_stream.cc SocketOutputStream::SocketOutputStream(net::StreamSocket* socket) socket 209 google_apis/gcm/base/socket_stream.cc : socket_(socket), socket 216 google_apis/gcm/base/socket_stream.cc DCHECK(socket->IsConnected()); socket 65 google_apis/gcm/base/socket_stream.h explicit SocketInputStream(net::StreamSocket* socket); socket 161 google_apis/gcm/base/socket_stream.h explicit SocketOutputStream(net::StreamSocket* socket); socket 302 google_apis/gcm/base/socket_stream_unittest.cc socket()->Disconnect(); socket 399 google_apis/gcm/base/socket_stream_unittest.cc socket()->Disconnect(); socket 231 google_apis/gcm/engine/connection_factory_impl.cc DCHECK(!socket_handle_.socket()); socket 253 google_apis/gcm/engine/connection_factory_impl.cc connection_handler_->Init(login_request, socket_handle_.socket()); socket 485 google_apis/gcm/engine/connection_factory_impl.cc if (socket_handle_.socket() && socket_handle_.socket()->IsConnected()) socket 486 google_apis/gcm/engine/connection_factory_impl.cc socket_handle_.socket()->Disconnect(); socket 51 google_apis/gcm/engine/connection_handler.h net::StreamSocket* socket) = 0; socket 55 google_apis/gcm/engine/connection_handler_impl.cc net::StreamSocket* socket) { socket 66 google_apis/gcm/engine/connection_handler_impl.cc socket_ = socket; socket 37 google_apis/gcm/engine/connection_handler_impl.h net::StreamSocket* socket) OVERRIDE; socket 615 google_apis/gcm/engine/connection_handler_impl_unittest.cc net::StreamSocket* socket = BuildSocket(read_list, write_list); socket 622 google_apis/gcm/engine/connection_handler_impl_unittest.cc socket->Disconnect(); socket 42 google_apis/gcm/engine/fake_connection_handler.cc net::StreamSocket* socket) { socket 26 google_apis/gcm/engine/fake_connection_handler.h net::StreamSocket* socket) OVERRIDE; socket 48 ipc/ipc_channel_handle.h : name(n), socket(s) {} socket 53 ipc/ipc_channel_handle.h base::FileDescriptor socket; socket 251 ipc/ipc_channel_nacl.cc if (channel_handle.socket.fd == -1) { socket 255 ipc/ipc_channel_nacl.cc pipe_ = channel_handle.socket.fd; socket 248 ipc/ipc_channel_posix.cc if (channel_handle.socket.fd != -1) { socket 250 ipc/ipc_channel_posix.cc local_pipe = channel_handle.socket.fd; socket 150 ipc/ipc_channel_posix_unittest.cc int socket_fd = socket(PF_UNIX, SOCK_STREAM, 0); socket 186 ipc/ipc_channel_posix_unittest.cc handle->socket.fd = socket_fd; socket 664 ipc/ipc_message_utils.cc WriteParam(m, p.socket); socket 673 ipc/ipc_message_utils.cc && ReadParam(m, iter, &r->socket) socket 683 ipc/ipc_message_utils.cc ParamTraits<base::FileDescriptor>::Log(p.socket, l); socket 127 ipc/sync_socket_unittest.cc void Init(base::SyncSocket* socket, IPC::Channel* chan) { socket 128 ipc/sync_socket_unittest.cc socket_ = socket; socket 210 ipc/sync_socket_unittest.cc static void BlockingRead(base::SyncSocket* socket, char* buf, socket 214 ipc/sync_socket_unittest.cc socket->Send(kHelloString, kHelloStringLength); socket 215 ipc/sync_socket_unittest.cc *received = socket->Receive(buf, length); socket 49 ipc/unix_domain_socket_util.cc base::ScopedFD fd(socket(AF_UNIX, SOCK_STREAM, 0)); socket 83 jingle/glue/chrome_async_socket_unittest.cc socket()->OnReadComplete(mock_read); socket 94 jingle/glue/proxy_resolving_client_socket.cc if (transport_.get() && transport_->socket()) socket 95 jingle/glue/proxy_resolving_client_socket.cc return transport_->socket()->Read(buf, buf_len, callback); socket 104 jingle/glue/proxy_resolving_client_socket.cc if (transport_.get() && transport_->socket()) socket 105 jingle/glue/proxy_resolving_client_socket.cc return transport_->socket()->Write(buf, buf_len, callback); socket 111 jingle/glue/proxy_resolving_client_socket.cc if (transport_.get() && transport_->socket()) socket 112 jingle/glue/proxy_resolving_client_socket.cc return transport_->socket()->SetReceiveBufferSize(size); socket 118 jingle/glue/proxy_resolving_client_socket.cc if (transport_.get() && transport_->socket()) socket 119 jingle/glue/proxy_resolving_client_socket.cc return transport_->socket()->SetSendBufferSize(size); socket 315 jingle/glue/proxy_resolving_client_socket.cc if (!transport_.get() || !transport_->socket()) socket 317 jingle/glue/proxy_resolving_client_socket.cc return transport_->socket()->IsConnected(); socket 321 jingle/glue/proxy_resolving_client_socket.cc if (!transport_.get() || !transport_->socket()) socket 323 jingle/glue/proxy_resolving_client_socket.cc return transport_->socket()->IsConnectedAndIdle(); socket 328 jingle/glue/proxy_resolving_client_socket.cc if (transport_.get() && transport_->socket()) socket 329 jingle/glue/proxy_resolving_client_socket.cc return transport_->socket()->GetPeerAddress(address); socket 336 jingle/glue/proxy_resolving_client_socket.cc if (transport_.get() && transport_->socket()) socket 337 jingle/glue/proxy_resolving_client_socket.cc return transport_->socket()->GetLocalAddress(address); socket 343 jingle/glue/proxy_resolving_client_socket.cc if (transport_.get() && transport_->socket()) socket 344 jingle/glue/proxy_resolving_client_socket.cc return transport_->socket()->NetLog(); socket 350 jingle/glue/proxy_resolving_client_socket.cc if (transport_.get() && transport_->socket()) socket 351 jingle/glue/proxy_resolving_client_socket.cc transport_->socket()->SetSubresourceSpeculation(); socket 357 jingle/glue/proxy_resolving_client_socket.cc if (transport_.get() && transport_->socket()) socket 358 jingle/glue/proxy_resolving_client_socket.cc transport_->socket()->SetOmniboxSpeculation(); socket 364 jingle/glue/proxy_resolving_client_socket.cc if (transport_.get() && transport_->socket()) socket 365 jingle/glue/proxy_resolving_client_socket.cc return transport_->socket()->WasEverUsed(); socket 371 jingle/glue/proxy_resolving_client_socket.cc if (transport_.get() && transport_->socket()) socket 372 jingle/glue/proxy_resolving_client_socket.cc return transport_->socket()->UsingTCPFastOpen(); socket 382 jingle/glue/proxy_resolving_client_socket.cc if (transport_.get() && transport_->socket()) socket 383 jingle/glue/proxy_resolving_client_socket.cc return transport_->socket()->GetNegotiatedProtocol(); socket 393 jingle/glue/proxy_resolving_client_socket.cc if (transport_.get() && transport_->socket()) socket 394 jingle/glue/proxy_resolving_client_socket.cc transport_->socket()->Disconnect(); socket 28 jingle/glue/pseudotcp_adapter.cc Core(net::Socket* socket); socket 113 jingle/glue/pseudotcp_adapter.cc PseudoTcpAdapter::Core::Core(net::Socket* socket) socket 115 jingle/glue/pseudotcp_adapter.cc socket_(socket), socket 464 jingle/glue/pseudotcp_adapter.cc PseudoTcpAdapter::PseudoTcpAdapter(net::Socket* socket) socket 465 jingle/glue/pseudotcp_adapter.cc : core_(new Core(socket)) { socket 29 jingle/glue/pseudotcp_adapter.h PseudoTcpAdapter(net::Socket* socket); socket 30 media/audio/audio_device_thread.cc base::SyncSocket::Handle socket, socket 71 media/audio/audio_device_thread.cc base::SyncSocket::Handle socket, socket 77 media/audio/audio_device_thread.cc callback, socket, thread_name, synchronized_buffers); socket 96 media/audio/audio_device_thread.cc base::SyncSocket::Handle socket, socket 101 media/audio/audio_device_thread.cc socket_(socket), socket 80 media/audio/audio_device_thread.h base::SyncSocket::Handle socket, socket 79 media/audio/audio_output_device_unittest.cc ACTION_P2(SendPendingBytes, socket, pending_bytes) { socket 80 media/audio/audio_output_device_unittest.cc socket->Send(&pending_bytes, sizeof(pending_bytes)); socket 568 media/audio/win/audio_output_win_unittest.cc SyncSocketSource(base::SyncSocket* socket, const AudioParameters& params) socket 569 media/audio/win/audio_output_win_unittest.cc : socket_(socket) { socket 605 media/audio/win/audio_output_win_unittest.cc base::SyncSocket* socket; socket 634 media/audio/win/audio_output_win_unittest.cc if (ctx.socket->Receive(&buffers_state, sizeof(buffers_state)) == 0) socket 638 media/audio/win/audio_output_win_unittest.cc ctx.socket->Send(data.get(), ctx.packet_size_bytes); socket 683 media/audio/win/audio_output_win_unittest.cc thread_context.socket = &sockets[1]; socket 97 native_client_sdk/src/examples/api/socket/echo_server.cc void EchoServer::OnAcceptCompletion(int32_t result, pp::TCPSocket socket) { socket 106 native_client_sdk/src/examples/api/socket/echo_server.cc pp::NetAddress addr = socket.GetLocalAddress(); socket 110 native_client_sdk/src/examples/api/socket/echo_server.cc incoming_socket_ = socket; socket 31 native_client_sdk/src/examples/api/socket/echo_server.h void OnAcceptCompletion(int32_t result, pp::TCPSocket socket); socket 979 native_client_sdk/src/examples/demo/nacl_io/handlers.c int sock = socket(AF_INET, SOCK_STREAM, 0); socket 522 native_client_sdk/src/libraries/nacl_io/kernel_intercept.cc return s_state.kp->socket(domain, type, protocol); socket 205 native_client_sdk/src/libraries/nacl_io/kernel_proxy.h virtual int socket(int domain, int type, int protocol); socket 128 native_client_sdk/src/libraries/nacl_io/kernel_wrap.h int socket(int domain, int type, int protocol); socket 34 native_client_sdk/src/libraries/nacl_io/socket/socket_node.cc SocketNode::SocketNode(Filesystem* filesystem, PP_Resource socket) socket 36 native_client_sdk/src/libraries/nacl_io/socket/socket_node.cc socket_resource_(socket), socket 34 native_client_sdk/src/libraries/nacl_io/socket/socket_node.h SocketNode(Filesystem* filesystem, PP_Resource socket); socket 82 native_client_sdk/src/libraries/nacl_io/socket/tcp_event_emitter.cc void TcpEventEmitter::SetAcceptedSocket_Locked(PP_Resource socket) { socket 83 native_client_sdk/src/libraries/nacl_io/socket/tcp_event_emitter.cc accepted_socket_ = socket; socket 37 native_client_sdk/src/libraries/nacl_io/socket/tcp_event_emitter.h void SetAcceptedSocket_Locked(PP_Resource socket); socket 273 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc TcpNode::TcpNode(Filesystem* filesystem, PP_Resource socket) socket 274 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc : SocketNode(filesystem, socket), socket 23 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.h TcpNode(Filesystem* filesystem, PP_Resource socket); socket 443 native_client_sdk/src/libraries/third_party/newlib-extras/sys/socket.h int socket(int, int, int); socket 105 native_client_sdk/src/tests/nacl_io_socket_test/echo_server.cc void EchoServer::OnAcceptCompletion(int32_t result, pp::TCPSocket socket) { socket 114 native_client_sdk/src/tests/nacl_io_socket_test/echo_server.cc pp::NetAddress addr = socket.GetLocalAddress(); socket 118 native_client_sdk/src/tests/nacl_io_socket_test/echo_server.cc incoming_socket_ = socket; socket 41 native_client_sdk/src/tests/nacl_io_socket_test/echo_server.h void OnAcceptCompletion(int32_t result, pp::TCPSocket socket); socket 429 native_client_sdk/src/tests/nacl_io_socket_test/socket_test.cc sock1_ = socket(AF_INET, SOCK_DGRAM, 0); socket 436 native_client_sdk/src/tests/nacl_io_socket_test/socket_test.cc sock2_ = socket(AF_INET, SOCK_STREAM, 0); socket 723 native_client_sdk/src/tests/nacl_io_test/kernel_wrap_test.cc TEST_F(KernelWrapTest, socket) { socket 724 native_client_sdk/src/tests/nacl_io_test/kernel_wrap_test.cc EXPECT_CALL(mock, socket(kDummyInt, kDummyInt2, kDummyInt3)) socket 726 native_client_sdk/src/tests/nacl_io_test/kernel_wrap_test.cc EXPECT_EQ(kDummyInt4, socket(kDummyInt, kDummyInt2, kDummyInt3)); socket 95 native_client_sdk/src/tests/nacl_io_test/mock_kernel_proxy.h MOCK_METHOD3(socket, int(int, int, int)); socket 85 net/base/address_tracker_linux.cc int ioctl_socket = socket(AF_INET, SOCK_DGRAM, 0); socket 120 net/base/address_tracker_linux.cc netlink_fd_ = socket(AF_NETLINK, SOCK_RAW, NETLINK_ROUTE); socket 155 net/base/net_util_posix.cc ioctl_socket = socket(AF_INET6, SOCK_DGRAM, 0); socket 101 net/base/network_delegate.cc SocketStream* socket, socket 104 net/base/network_delegate.cc DCHECK(socket); socket 106 net/base/network_delegate.cc return OnBeforeSocketStreamConnect(socket, callback); socket 223 net/base/network_delegate.cc SocketStream* socket, socket 96 net/base/network_delegate.h int NotifyBeforeSocketStreamConnect(SocketStream* socket, socket 238 net/base/network_delegate.h SocketStream* socket, const CompletionCallback& callback); socket 269 net/dns/address_sorter_posix.cc scoped_ptr<DatagramClientSocket> socket( socket 278 net/dns/address_sorter_posix.cc int rv = socket->Connect(dest); socket 286 net/dns/address_sorter_posix.cc rv = socket->GetLocalAddress(&src); socket 341 net/dns/address_sorter_posix.cc int ioctl_socket = socket(AF_INET6, SOCK_DGRAM, 0); socket 44 net/dns/address_sorter_unittest.cc SOCKET sock = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP); socket 90 net/dns/address_sorter_win.cc SOCKET sock = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP); socket 74 net/dns/dns_session.cc scoped_ptr<DatagramClientSocket> socket) socket 75 net/dns/dns_session.cc : session_(session), server_index_(server_index), socket_(socket.Pass()) {} socket 223 net/dns/dns_session.cc scoped_ptr<DatagramClientSocket> socket; socket 225 net/dns/dns_session.cc socket = socket_pool_->AllocateSocket(server_index); socket 226 net/dns/dns_session.cc if (!socket.get()) socket 229 net/dns/dns_session.cc socket->NetLog().BeginEvent(NetLog::TYPE_SOCKET_IN_USE, socket 232 net/dns/dns_session.cc SocketLease* lease = new SocketLease(this, server_index, socket.Pass()); socket 243 net/dns/dns_session.cc scoped_ptr<DatagramClientSocket> socket) { socket 244 net/dns/dns_session.cc DCHECK(socket.get()); socket 246 net/dns/dns_session.cc socket->NetLog().EndEvent(NetLog::TYPE_SOCKET_IN_USE); socket 248 net/dns/dns_session.cc socket_pool_->FreeSocket(server_index, socket.Pass()); socket 45 net/dns/dns_session.h scoped_ptr<DatagramClientSocket> socket); socket 50 net/dns/dns_session.h DatagramClientSocket* socket() { return socket_.get(); } socket 115 net/dns/dns_session.h scoped_ptr<DatagramClientSocket> socket); socket 107 net/dns/dns_session_unittest.cc scoped_ptr<DatagramClientSocket> socket) OVERRIDE { socket 194 net/dns/dns_session_unittest.cc scoped_ptr<MockUDPClientSocket> socket( socket 196 net/dns/dns_session_unittest.cc data_provider->set_socket(socket.get()); socket 197 net/dns/dns_session_unittest.cc return socket.PassAs<DatagramClientSocket>(); socket 73 net/dns/dns_socket_pool.cc scoped_ptr<DatagramClientSocket> socket; socket 76 net/dns/dns_socket_pool.cc socket = socket_factory_->CreateDatagramClientSocket( socket 79 net/dns/dns_socket_pool.cc if (socket.get()) { socket 80 net/dns/dns_socket_pool.cc int rv = socket->Connect((*nameservers_)[server_index]); socket 83 net/dns/dns_socket_pool.cc socket.reset(); socket 89 net/dns/dns_socket_pool.cc return socket.Pass(); socket 111 net/dns/dns_socket_pool.cc scoped_ptr<DatagramClientSocket> socket) OVERRIDE { socket 141 net/dns/dns_socket_pool.cc scoped_ptr<DatagramClientSocket> socket) OVERRIDE; socket 197 net/dns/dns_socket_pool.cc DatagramClientSocket* socket = pool[socket_index]; socket 201 net/dns/dns_socket_pool.cc return scoped_ptr<DatagramClientSocket>(socket); socket 206 net/dns/dns_socket_pool.cc scoped_ptr<DatagramClientSocket> socket) { socket 214 net/dns/dns_socket_pool.cc DatagramClientSocket* socket = socket 216 net/dns/dns_socket_pool.cc if (!socket) socket 218 net/dns/dns_socket_pool.cc pool.push_back(socket); socket 62 net/dns/dns_socket_pool.h scoped_ptr<DatagramClientSocket> socket) = 0; socket 162 net/dns/dns_transaction.cc return socket_lease_->socket()->NetLog(); socket 175 net/dns/dns_transaction.cc return socket_lease_->socket(); socket 221 net/dns/dns_transaction.cc return socket()->Write(query_->io_buffer(), socket 243 net/dns/dns_transaction.cc return socket()->Read(response_->io_buffer(), socket 299 net/dns/dns_transaction.cc scoped_ptr<StreamSocket> socket, socket 303 net/dns/dns_transaction.cc socket_(socket.Pass()), socket 720 net/dns/dns_transaction.cc scoped_ptr<StreamSocket> socket( socket 734 net/dns/dns_transaction.cc DnsTCPAttempt* attempt = new DnsTCPAttempt(server_index, socket.Pass(), socket 193 net/dns/dns_transaction_unittest.cc scoped_ptr<TestUDPClientSocket> socket( socket 195 net/dns/dns_transaction_unittest.cc data_provider->set_socket(socket.get()); socket 196 net/dns/dns_transaction_unittest.cc return socket.PassAs<DatagramClientSocket>(); socket 172 net/dns/host_resolver_impl.cc scoped_ptr<DatagramClientSocket> socket( socket 178 net/dns/host_resolver_impl.cc int rv = socket->Connect(IPEndPoint(dest, 53)); socket 182 net/dns/host_resolver_impl.cc rv = socket->GetLocalAddress(&endpoint); socket 29 net/dns/mdns_client.cc DatagramServerSocket* socket) { socket 33 net/dns/mdns_client.cc socket->AllowAddressReuse(); socket 34 net/dns/mdns_client.cc socket->SetMulticastInterface(interface_index); socket 36 net/dns/mdns_client.cc int rv = socket->Listen(bind_endpoint); socket 40 net/dns/mdns_client.cc return socket->JoinGroup(multicast_addr.address()); socket 89 net/dns/mdns_client.cc scoped_ptr<DatagramServerSocket> socket( socket 93 net/dns/mdns_client.cc int rv = Bind(multicast_addr, interface_index, socket.get()); socket 95 net/dns/mdns_client.cc socket.reset(); socket 99 net/dns/mdns_client.cc return socket.PassAs<DatagramServerSocket>(); socket 45 net/dns/mdns_client_impl.cc scoped_ptr<DatagramServerSocket> socket( socket 47 net/dns/mdns_client_impl.cc if (socket) socket 48 net/dns/mdns_client_impl.cc sockets->push_back(socket.release()); socket 53 net/dns/mdns_client_impl.cc scoped_ptr<DatagramServerSocket> socket, socket 55 net/dns/mdns_client_impl.cc : socket_(socket.Pass()), socket 60 net/dns/mdns_client_impl.h SocketHandler(scoped_ptr<DatagramServerSocket> socket, socket 1065 net/dns/mdns_client_unittest.cc void PushSocket(DatagramServerSocket* socket) { socket 1066 net/dns/mdns_client_unittest.cc sockets_.push_back(socket); socket 505 net/http/http_network_transaction_unittest.cc scoped_ptr<StreamSocket> socket, socket 112 net/http/http_pipelined_connection_impl.cc connection_->socket()->Disconnect(); socket 56 net/http/http_proxy_client_socket.cc net_log_(transport_socket->socket()->NetLog()) { socket 111 net/http/http_proxy_client_socket.cc DCHECK(transport_->socket()); socket 135 net/http/http_proxy_client_socket.cc transport_->socket()->Disconnect(); socket 144 net/http/http_proxy_client_socket.cc return next_state_ == STATE_DONE && transport_->socket()->IsConnected(); socket 149 net/http/http_proxy_client_socket.cc transport_->socket()->IsConnectedAndIdle(); socket 157 net/http/http_proxy_client_socket.cc if (transport_.get() && transport_->socket()) { socket 158 net/http/http_proxy_client_socket.cc transport_->socket()->SetSubresourceSpeculation(); socket 165 net/http/http_proxy_client_socket.cc if (transport_.get() && transport_->socket()) { socket 166 net/http/http_proxy_client_socket.cc transport_->socket()->SetOmniboxSpeculation(); socket 173 net/http/http_proxy_client_socket.cc if (transport_.get() && transport_->socket()) { socket 174 net/http/http_proxy_client_socket.cc return transport_->socket()->WasEverUsed(); socket 181 net/http/http_proxy_client_socket.cc if (transport_.get() && transport_->socket()) { socket 182 net/http/http_proxy_client_socket.cc return transport_->socket()->UsingTCPFastOpen(); socket 189 net/http/http_proxy_client_socket.cc if (transport_.get() && transport_->socket()) { socket 190 net/http/http_proxy_client_socket.cc return transport_->socket()->WasNpnNegotiated(); socket 197 net/http/http_proxy_client_socket.cc if (transport_.get() && transport_->socket()) { socket 198 net/http/http_proxy_client_socket.cc return transport_->socket()->GetNegotiatedProtocol(); socket 205 net/http/http_proxy_client_socket.cc if (transport_.get() && transport_->socket()) { socket 206 net/http/http_proxy_client_socket.cc return transport_->socket()->GetSSLInfo(ssl_info); socket 229 net/http/http_proxy_client_socket.cc return transport_->socket()->Read(buf, buf_len, callback); socket 237 net/http/http_proxy_client_socket.cc return transport_->socket()->Write(buf, buf_len, callback); socket 241 net/http/http_proxy_client_socket.cc return transport_->socket()->SetReceiveBufferSize(size); socket 245 net/http/http_proxy_client_socket.cc return transport_->socket()->SetSendBufferSize(size); socket 249 net/http/http_proxy_client_socket.cc return transport_->socket()->GetPeerAddress(address); socket 253 net/http/http_proxy_client_socket.cc return transport_->socket()->GetLocalAddress(address); socket 277 net/http/http_proxy_client_socket.cc if (keep_alive && transport_->socket()->IsConnectedAndIdle()) { socket 284 net/http/http_proxy_client_socket.cc transport_->socket()->Disconnect(); socket 526 net/http/http_proxy_client_socket.cc return transport_->socket()->Connect( socket 236 net/http/http_proxy_client_socket_pool.cc transport_socket_handle_->socket()->Disconnect(); socket 241 net/http/http_proxy_client_socket_pool.cc if (transport_socket_handle_->socket()) socket 242 net/http/http_proxy_client_socket_pool.cc transport_socket_handle_->socket()->Disconnect(); socket 247 net/http/http_proxy_client_socket_pool.cc static_cast<SSLClientSocket*>(transport_socket_handle_->socket()); socket 312 net/http/http_proxy_client_socket_pool.cc if (transport_socket_handle_->socket()) socket 313 net/http/http_proxy_client_socket_pool.cc transport_socket_handle_->socket()->Disconnect(); socket 466 net/http/http_proxy_client_socket_pool.cc scoped_ptr<StreamSocket> socket, socket 468 net/http/http_proxy_client_socket_pool.cc base_.ReleaseSocket(group_name, socket.Pass(), id); socket 210 net/http/http_proxy_client_socket_pool.h scoped_ptr<StreamSocket> socket, socket 265 net/http/http_proxy_client_socket_pool_unittest.cc ASSERT_TRUE(handle_.socket()); socket 267 net/http/http_proxy_client_socket_pool_unittest.cc static_cast<HttpProxyClientSocket*>(handle_.socket()); socket 332 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 338 net/http/http_proxy_client_socket_pool_unittest.cc ASSERT_TRUE(handle_.socket()); socket 340 net/http/http_proxy_client_socket_pool_unittest.cc static_cast<ProxyClientSocket*>(handle_.socket()); socket 374 net/http/http_proxy_client_socket_pool_unittest.cc ASSERT_TRUE(handle_.socket()); socket 376 net/http/http_proxy_client_socket_pool_unittest.cc static_cast<HttpProxyClientSocket*>(handle_.socket()); socket 411 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 416 net/http/http_proxy_client_socket_pool_unittest.cc ASSERT_TRUE(handle_.socket()); socket 418 net/http/http_proxy_client_socket_pool_unittest.cc static_cast<HttpProxyClientSocket*>(handle_.socket()); socket 466 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 471 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 491 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 496 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 516 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 521 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 554 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 565 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 593 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 633 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 641 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 695 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 705 net/http/http_proxy_client_socket_pool_unittest.cc EXPECT_FALSE(handle_.socket()); socket 710 net/http/http_proxy_client_socket_pool_unittest.cc ASSERT_TRUE(handle_.socket()); socket 713 net/http/http_proxy_client_socket_pool_unittest.cc static_cast<ProxyClientSocket*>(handle_.socket()); socket 122 net/http/http_stream_factory_impl_job.cc connection_->socket()->Disconnect(); socket 220 net/http/http_stream_factory_impl_job.cc connection_ && connection_->socket()) socket 221 net/http/http_stream_factory_impl_job.cc connection_->socket()->Disconnect(); socket 227 net/http/http_stream_factory_impl_job.cc if (connection_ && connection_->socket()) socket 228 net/http/http_stream_factory_impl_job.cc connection_->socket()->Disconnect(); socket 266 net/http/http_stream_factory_impl_job.cc DCHECK(connection_.get() && connection_->socket()); socket 268 net/http/http_stream_factory_impl_job.cc static_cast<SSLClientSocket*>(connection_->socket()); socket 478 net/http/http_stream_factory_impl_job.cc DCHECK(connection_->socket()); socket 483 net/http/http_stream_factory_impl_job.cc static_cast<ProxyClientSocket*>(connection_->socket()); socket 501 net/http/http_stream_factory_impl_job.cc DCHECK(connection_->socket()); socket 505 net/http/http_stream_factory_impl_job.cc static_cast<ProxyClientSocket*>(connection_->socket()); socket 918 net/http/http_stream_factory_impl_job.cc bool ssl_started = using_ssl_ && (result == OK || connection_->socket() || socket 929 net/http/http_stream_factory_impl_job.cc static_cast<SSLClientSocket*>(connection_->socket()); socket 949 net/http/http_stream_factory_impl_job.cc } else if (proxy_info_.is_https() && connection_->socket() && socket 952 net/http/http_stream_factory_impl_job.cc static_cast<ProxyClientSocket*>(connection_->socket()); socket 996 net/http/http_stream_factory_impl_job.cc if (connection_->socket()) { socket 1017 net/http/http_stream_factory_impl_job.cc if (result == OK && !connection_->socket()->IsConnectedAndIdle()) { socket 1041 net/http/http_stream_factory_impl_job.cc DCHECK(connection_->socket() || existing_spdy_session_.get() || socket 1049 net/http/http_stream_factory_impl_job.cc if (connection_->socket() && !connection_->is_reused()) socket 1107 net/http/http_stream_factory_impl_job.cc if (connection_->socket()) socket 1108 net/http/http_stream_factory_impl_job.cc connection_->socket()->Disconnect(); socket 1169 net/http/http_stream_factory_impl_job.cc static_cast<ProxyClientSocket*>(connection_->socket()); socket 1194 net/http/http_stream_factory_impl_job.cc if (close_connection && connection_->socket()) socket 1195 net/http/http_stream_factory_impl_job.cc connection_->socket()->Disconnect(); socket 1208 net/http/http_stream_factory_impl_job.cc connection_->socket()->SetSubresourceSpeculation(); socket 1210 net/http/http_stream_factory_impl_job.cc connection_->socket()->SetOmniboxSpeculation(); socket 1350 net/http/http_stream_factory_impl_job.cc if (connection_->socket()) socket 1351 net/http/http_stream_factory_impl_job.cc connection_->socket()->Disconnect(); socket 1374 net/http/http_stream_factory_impl_job.cc static_cast<SSLClientSocket*>(connection_->socket()); socket 272 net/http/http_stream_factory_impl_unittest.cc connection_->socket()->Disconnect(); socket 370 net/http/http_stream_factory_impl_unittest.cc scoped_ptr<StreamSocket> socket, socket 220 net/http/http_stream_parser.cc int result = connection_->socket()->GetPeerAddress(&ip_endpoint); socket 323 net/http/http_stream_parser.cc if (not_reusable && connection_->socket()) socket 324 net/http/http_stream_parser.cc connection_->socket()->Disconnect(); socket 427 net/http/http_stream_parser.cc result = connection_->socket() socket 455 net/http/http_stream_parser.cc return connection_->socket() socket 517 net/http/http_stream_parser.cc return connection_->socket() socket 657 net/http/http_stream_parser.cc return connection_->socket() socket 911 net/http/http_stream_parser.cc return connection_->socket() && connection_->socket()->IsConnectedAndIdle(); socket 915 net/http/http_stream_parser.cc if (request_->url.SchemeIsSecure() && connection_->socket()) { socket 917 net/http/http_stream_parser.cc static_cast<SSLClientSocket*>(connection_->socket()); socket 924 net/http/http_stream_parser.cc if (request_->url.SchemeIsSecure() && connection_->socket()) { socket 926 net/http/http_stream_parser.cc static_cast<SSLClientSocket*>(connection_->socket()); socket 117 net/quic/quic_client_session.cc scoped_ptr<DatagramClientSocket> socket, socket 129 net/quic/quic_client_session.cc socket_(socket.Pass()), socket 93 net/quic/quic_client_session.h scoped_ptr<DatagramClientSocket> socket, socket 18 net/quic/quic_default_packet_writer.cc QuicDefaultPacketWriter::QuicDefaultPacketWriter(DatagramClientSocket* socket) socket 20 net/quic/quic_default_packet_writer.cc socket_(socket), socket 25 net/quic/quic_default_packet_writer.h explicit QuicDefaultPacketWriter(DatagramClientSocket* socket); socket 178 net/quic/quic_http_stream_test.cc MockUDPClientSocket* socket = new MockUDPClientSocket(socket_data_.get(), socket 180 net/quic/quic_http_stream_test.cc socket->Connect(peer_addr_); socket 197 net/quic/quic_http_stream_test.cc writer_.reset(new QuicDefaultPacketWriter(socket)); socket 207 net/quic/quic_http_stream_test.cc scoped_ptr<DatagramClientSocket>(socket), socket 702 net/quic/quic_stream_factory.cc scoped_ptr<DatagramClientSocket> socket( socket 707 net/quic/quic_stream_factory.cc int rv = socket->Connect(addr); socket 725 net/quic/quic_stream_factory.cc rv = socket->SetReceiveBufferSize(kSocketBufferSize); socket 733 net/quic/quic_stream_factory.cc rv = socket->SetSendBufferSize(kMaxPacketSize * 20); socket 740 net/quic/quic_stream_factory.cc new QuicDefaultPacketWriter(socket.get())); socket 768 net/quic/quic_stream_factory.cc connection, socket.Pass(), writer.Pass(), this, socket 98 net/server/http_server.cc scoped_ptr<StreamListenSocket> socket) { socket 99 net/server/http_server.cc HttpConnection* connection = new HttpConnection(this, socket.Pass()); socket 105 net/server/http_server.cc void HttpServer::DidRead(StreamListenSocket* socket, socket 108 net/server/http_server.cc HttpConnection* connection = FindConnection(socket); socket 136 net/server/http_server.cc socket->GetPeerAddress(&request.peer); socket 161 net/server/http_server.cc DidClose(socket); socket 176 net/server/http_server.cc void HttpServer::DidClose(StreamListenSocket* socket) { socket 177 net/server/http_server.cc HttpConnection* connection = FindConnection(socket); socket 326 net/server/http_server.cc HttpConnection* HttpServer::FindConnection(StreamListenSocket* socket) { socket 327 net/server/http_server.cc SocketToConnectionMap::iterator it = socket_to_connection_.find(socket); socket 68 net/server/http_server.h scoped_ptr<StreamListenSocket> socket) OVERRIDE; socket 69 net/server/http_server.h virtual void DidRead(StreamListenSocket* socket, socket 72 net/server/http_server.h virtual void DidClose(StreamListenSocket* socket) OVERRIDE; socket 89 net/server/http_server.h HttpConnection* FindConnection(StreamListenSocket* socket); socket 280 net/server/http_server_unittest.cc StreamListenSocket* socket = socket 282 net/server/http_server_unittest.cc server_->DidAccept(NULL, make_scoped_ptr(socket)); socket 290 net/server/http_server_unittest.cc server_->DidRead(socket, request.c_str(), request.length() - 2); socket 292 net/server/http_server_unittest.cc server_->DidRead(socket, request.c_str() + request.length() - 2, 2); socket 263 net/server/web_socket.cc WebSocket* socket = WebSocketHybi17::Create(connection, request, pos); socket 264 net/server/web_socket.cc if (socket) socket 265 net/server/web_socket.cc return socket; socket 155 net/socket/client_socket_handle.h StreamSocket* socket() { return socket_.get(); } socket 138 net/socket/client_socket_pool.h scoped_ptr<StreamSocket> socket, socket 86 net/socket/client_socket_pool_base.cc void ConnectJob::SetSocket(scoped_ptr<StreamSocket> socket) { socket 87 net/socket/client_socket_pool_base.cc if (socket) { socket 89 net/socket/client_socket_pool_base.cc socket->NetLog().source().ToEventParametersCallback()); socket 91 net/socket/client_socket_pool_base.cc socket_ = socket.Pass(); socket 453 net/socket/client_socket_pool_base.cc delete it->socket; socket 458 net/socket/client_socket_pool_base.cc if (it->socket->WasEverUsed()) { socket 482 net/socket/client_socket_pool_base.cc idle_socket.socket->WasEverUsed() ? socket 486 net/socket/client_socket_pool_base.cc scoped_ptr<StreamSocket>(idle_socket.socket), socket 512 net/socket/client_socket_pool_base.cc scoped_ptr<StreamSocket> socket = handle->PassSocket(); socket 513 net/socket/client_socket_pool_base.cc if (socket) { socket 515 net/socket/client_socket_pool_base.cc socket->Disconnect(); socket 516 net/socket/client_socket_pool_base.cc ReleaseSocket(handle->group_name(), socket.Pass(), handle->id()); socket 626 net/socket/client_socket_pool_base.cc int source_id = idle_socket->socket->NetLog().source().id; socket 652 net/socket/client_socket_pool_base.cc if (socket->WasEverUsed()) socket 653 net/socket/client_socket_pool_base.cc return socket->IsConnectedAndIdle(); socket 654 net/socket/client_socket_pool_base.cc return socket->IsConnected(); socket 681 net/socket/client_socket_pool_base.cc j->socket->WasEverUsed() ? socket 684 net/socket/client_socket_pool_base.cc delete j->socket; socket 767 net/socket/client_socket_pool_base.cc scoped_ptr<StreamSocket> socket, socket 780 net/socket/client_socket_pool_base.cc const bool can_reuse = socket->IsConnectedAndIdle() && socket 784 net/socket/client_socket_pool_base.cc AddIdleSocket(socket.Pass(), group); socket 787 net/socket/client_socket_pool_base.cc socket.reset(); socket 874 net/socket/client_socket_pool_base.cc scoped_ptr<StreamSocket> socket = job->PassSocket(); socket 885 net/socket/client_socket_pool_base.cc DCHECK(socket.get()); socket 891 net/socket/client_socket_pool_base.cc socket.Pass(), ClientSocketHandle::UNUSED, connect_timing, socket 896 net/socket/client_socket_pool_base.cc AddIdleSocket(socket.Pass(), group); socket 909 net/socket/client_socket_pool_base.cc if (socket.get()) { socket 911 net/socket/client_socket_pool_base.cc HandOutSocket(socket.Pass(), ClientSocketHandle::UNUSED, socket 975 net/socket/client_socket_pool_base.cc scoped_ptr<StreamSocket> socket, socket 982 net/socket/client_socket_pool_base.cc DCHECK(socket); socket 983 net/socket/client_socket_pool_base.cc handle->SetSocket(socket.Pass()); socket 998 net/socket/client_socket_pool_base.cc handle->socket()->NetLog().source().ToEventParametersCallback()); socket 1005 net/socket/client_socket_pool_base.cc scoped_ptr<StreamSocket> socket, socket 1007 net/socket/client_socket_pool_base.cc DCHECK(socket); socket 1009 net/socket/client_socket_pool_base.cc idle_socket.socket = socket.release(); socket 1086 net/socket/client_socket_pool_base.cc delete idle_sockets->front().socket; socket 117 net/socket/client_socket_pool_base.h void SetSocket(scoped_ptr<StreamSocket> socket); socket 118 net/socket/client_socket_pool_base.h StreamSocket* socket() { return socket_.get(); } socket 251 net/socket/client_socket_pool_base.h scoped_ptr<StreamSocket> socket, socket 340 net/socket/client_socket_pool_base.h IdleSocket() : socket(NULL) {} socket 357 net/socket/client_socket_pool_base.h StreamSocket* socket; socket 536 net/socket/client_socket_pool_base.h void HandOutSocket(scoped_ptr<StreamSocket> socket, socket 545 net/socket/client_socket_pool_base.h void AddIdleSocket(scoped_ptr<StreamSocket> socket, Group* group); socket 773 net/socket/client_socket_pool_base.h scoped_ptr<StreamSocket> socket, socket 775 net/socket/client_socket_pool_base.h return helper_.ReleaseSocket(group_name, socket.Pass(), id); socket 394 net/socket/client_socket_pool_base_unittest.cc static_cast<MockClientSocket*>(socket())->set_has_unread_data(true); socket 407 net/socket/client_socket_pool_base_unittest.cc socket()->Connect(CompletionCallback()); socket 538 net/socket/client_socket_pool_base_unittest.cc scoped_ptr<StreamSocket> socket, socket 540 net/socket/client_socket_pool_base_unittest.cc base_.ReleaseSocket(group_name, socket.Pass(), id); socket 659 net/socket/client_socket_pool_base_unittest.cc scoped_ptr<StreamSocket> socket = owned_job->PassSocket(); socket 661 net/socket/client_socket_pool_base_unittest.cc EXPECT_EQ(socket == NULL, result != OK); socket 844 net/socket/client_socket_pool_base_unittest.cc EXPECT_TRUE(handle.socket()); socket 886 net/socket/client_socket_pool_base_unittest.cc EXPECT_FALSE(handle.socket()); socket 1490 net/socket/client_socket_pool_base_unittest.cc handle_->socket()->Disconnect(); socket 1720 net/socket/client_socket_pool_base_unittest.cc EXPECT_TRUE(handle.socket()); socket 1885 net/socket/client_socket_pool_base_unittest.cc ASSERT_TRUE(req2.handle()->socket()); socket 1887 net/socket/client_socket_pool_base_unittest.cc EXPECT_FALSE(req3.handle()->socket()); socket 2061 net/socket/client_socket_pool_base_unittest.cc handle2.socket()->Disconnect(); socket 2120 net/socket/client_socket_pool_base_unittest.cc handle.socket()->Disconnect(); socket 2135 net/socket/client_socket_pool_base_unittest.cc EXPECT_TRUE(handle.socket()); socket 2155 net/socket/client_socket_pool_base_unittest.cc EXPECT_TRUE(handle.socket()); socket 2173 net/socket/client_socket_pool_base_unittest.cc EXPECT_FALSE(handle.socket()); socket 2195 net/socket/client_socket_pool_base_unittest.cc EXPECT_FALSE(handle.socket()); socket 2225 net/socket/client_socket_pool_base_unittest.cc EXPECT_EQ(1, handle.socket()->Write(NULL, 1, CompletionCallback())); socket 2299 net/socket/client_socket_pool_base_unittest.cc EXPECT_EQ(1, handle2.socket()->Write(NULL, 1, CompletionCallback())); socket 2377 net/socket/client_socket_pool_base_unittest.cc EXPECT_EQ(1, handle2.socket()->Write(NULL, 1, CompletionCallback())); socket 2463 net/socket/client_socket_pool_base_unittest.cc handle.socket()->Disconnect(); socket 2465 net/socket/client_socket_pool_base_unittest.cc handle2.socket()->Disconnect(); socket 2531 net/socket/client_socket_pool_base_unittest.cc handle_b[0].socket()->Disconnect(); socket 2533 net/socket/client_socket_pool_base_unittest.cc handle_a[0].socket()->Disconnect(); socket 2539 net/socket/client_socket_pool_base_unittest.cc handle_b[1].socket()->Disconnect(); socket 2541 net/socket/client_socket_pool_base_unittest.cc handle_a[1].socket()->Disconnect(); socket 2644 net/socket/client_socket_pool_base_unittest.cc EXPECT_FALSE(req.handle()->socket()); socket 3142 net/socket/client_socket_pool_base_unittest.cc EXPECT_EQ(1, handle1.socket()->Write(NULL, 1, CompletionCallback())); socket 3143 net/socket/client_socket_pool_base_unittest.cc EXPECT_EQ(1, handle3.socket()->Write(NULL, 1, CompletionCallback())); socket 3168 net/socket/client_socket_pool_base_unittest.cc EXPECT_TRUE(handle1.socket()->WasEverUsed()); socket 3169 net/socket/client_socket_pool_base_unittest.cc EXPECT_TRUE(handle2.socket()->WasEverUsed()); socket 3170 net/socket/client_socket_pool_base_unittest.cc EXPECT_FALSE(handle3.socket()->WasEverUsed()); socket 3776 net/socket/client_socket_pool_base_unittest.cc EXPECT_EQ(1, handle.socket()->Read(NULL, 1, CompletionCallback())); socket 3817 net/socket/client_socket_pool_base_unittest.cc handle_.socket()->Disconnect(); socket 104 net/socket/deterministic_socket_data_unittest.cc sock_ = connection_.socket(); socket 31 net/socket/server_socket.h virtual int Accept(scoped_ptr<StreamSocket>* socket, socket 50 net/socket/socket_descriptor.cc return ::socket(family, type, protocol); socket 349 net/socket/socket_test_util.cc if (socket() && read_in_progress_) socket 350 net/socket/socket_test_util.cc socket()->OnReadComplete(GetNextRead()); socket 444 net/socket/socket_test_util.cc if (socket() && blocked_) { socket 446 net/socket/socket_test_util.cc socket()->OnReadComplete(GetNextRead()); socket 672 net/socket/socket_test_util.cc scoped_ptr<MockUDPClientSocket> socket( socket 674 net/socket/socket_test_util.cc data_provider->set_socket(socket.get()); socket 676 net/socket/socket_test_util.cc socket->set_source_port(rand_int_cb.Run(1025, 65535)); socket 677 net/socket/socket_test_util.cc return socket.PassAs<DatagramClientSocket>(); socket 685 net/socket/socket_test_util.cc scoped_ptr<MockTCPClientSocket> socket( socket 687 net/socket/socket_test_util.cc data_provider->set_socket(socket.get()); socket 688 net/socket/socket_test_util.cc return socket.PassAs<StreamSocket>(); socket 1313 net/socket/socket_test_util.cc transport_socket->socket()->NetLog()), socket 1330 net/socket/socket_test_util.cc return transport_->socket()->Read(buf, buf_len, callback); socket 1335 net/socket/socket_test_util.cc return transport_->socket()->Write(buf, buf_len, callback); socket 1339 net/socket/socket_test_util.cc int rv = transport_->socket()->Connect( socket 1355 net/socket/socket_test_util.cc if (transport_->socket() != NULL) socket 1356 net/socket/socket_test_util.cc transport_->socket()->Disconnect(); socket 1360 net/socket/socket_test_util.cc return transport_->socket()->IsConnected(); socket 1364 net/socket/socket_test_util.cc return transport_->socket()->WasEverUsed(); socket 1368 net/socket/socket_test_util.cc return transport_->socket()->UsingTCPFastOpen(); socket 1372 net/socket/socket_test_util.cc return transport_->socket()->GetPeerAddress(address); socket 1668 net/socket/socket_test_util.cc (*i)->handle()->socket()->Disconnect(); socket 1685 net/socket/socket_test_util.cc scoped_ptr<StreamSocket> socket, socket 1688 net/socket/socket_test_util.cc : socket_(socket.Pass()), socket 1763 net/socket/socket_test_util.cc scoped_ptr<StreamSocket> socket = socket 1766 net/socket/socket_test_util.cc MockConnectJob* job = new MockConnectJob(socket.Pass(), handle, callback); socket 1785 net/socket/socket_test_util.cc scoped_ptr<StreamSocket> socket, socket 1823 net/socket/socket_test_util.cc scoped_ptr<DeterministicMockUDPClientSocket> socket( socket 1825 net/socket/socket_test_util.cc data_provider->set_delegate(socket->AsWeakPtr()); socket 1826 net/socket/socket_test_util.cc udp_client_sockets().push_back(socket.get()); socket 1828 net/socket/socket_test_util.cc socket->set_source_port(rand_int_cb.Run(1025, 65535)); socket 1829 net/socket/socket_test_util.cc return socket.PassAs<DatagramClientSocket>(); socket 1838 net/socket/socket_test_util.cc scoped_ptr<DeterministicMockTCPClientSocket> socket( socket 1840 net/socket/socket_test_util.cc data_provider->set_delegate(socket->AsWeakPtr()); socket 1841 net/socket/socket_test_util.cc tcp_client_sockets().push_back(socket.get()); socket 1842 net/socket/socket_test_util.cc return socket.PassAs<StreamSocket>(); socket 1851 net/socket/socket_test_util.cc scoped_ptr<MockSSLClientSocket> socket( socket 1855 net/socket/socket_test_util.cc ssl_client_sockets_.push_back(socket.get()); socket 1856 net/socket/socket_test_util.cc return socket.PassAs<SSLClientSocket>(); socket 1889 net/socket/socket_test_util.cc scoped_ptr<StreamSocket> socket, socket 1891 net/socket/socket_test_util.cc return transport_pool_->ReleaseSocket(group_name, socket.Pass(), id); socket 211 net/socket/socket_test_util.h AsyncSocket* socket() { return socket_; } socket 212 net/socket/socket_test_util.h void set_socket(AsyncSocket* socket) { socket_ = socket; } socket 632 net/socket/socket_test_util.h void AddSocketDataProvider(SocketDataProvider* socket); socket 633 net/socket/socket_test_util.h void AddSSLSocketDataProvider(SSLSocketDataProvider* socket); socket 731 net/socket/socket_test_util.h SocketDataProvider* socket); socket 930 net/socket/socket_test_util.h SSLSocketDataProvider* socket); socket 1142 net/socket/socket_test_util.h MockConnectJob(scoped_ptr<StreamSocket> socket, socket 1184 net/socket/socket_test_util.h scoped_ptr<StreamSocket> socket, socket 1202 net/socket/socket_test_util.h void AddSocketDataProvider(DeterministicSocketData* socket); socket 1203 net/socket/socket_test_util.h void AddSSLSocketDataProvider(SSLSocketDataProvider* socket); socket 1269 net/socket/socket_test_util.h scoped_ptr<StreamSocket> socket, socket 44 net/socket/socks5_client_socket.cc net_log_(transport_->socket()->NetLog()) { socket 53 net/socket/socks5_client_socket.cc DCHECK(transport_->socket()); socket 77 net/socket/socks5_client_socket.cc transport_->socket()->Disconnect(); socket 86 net/socket/socks5_client_socket.cc return completed_handshake_ && transport_->socket()->IsConnected(); socket 90 net/socket/socks5_client_socket.cc return completed_handshake_ && transport_->socket()->IsConnectedAndIdle(); socket 98 net/socket/socks5_client_socket.cc if (transport_.get() && transport_->socket()) { socket 99 net/socket/socks5_client_socket.cc transport_->socket()->SetSubresourceSpeculation(); socket 106 net/socket/socks5_client_socket.cc if (transport_.get() && transport_->socket()) { socket 107 net/socket/socks5_client_socket.cc transport_->socket()->SetOmniboxSpeculation(); socket 118 net/socket/socks5_client_socket.cc if (transport_.get() && transport_->socket()) { socket 119 net/socket/socks5_client_socket.cc return transport_->socket()->UsingTCPFastOpen(); socket 126 net/socket/socks5_client_socket.cc if (transport_.get() && transport_->socket()) { socket 127 net/socket/socks5_client_socket.cc return transport_->socket()->WasNpnNegotiated(); socket 134 net/socket/socks5_client_socket.cc if (transport_.get() && transport_->socket()) { socket 135 net/socket/socks5_client_socket.cc return transport_->socket()->GetNegotiatedProtocol(); socket 142 net/socket/socks5_client_socket.cc if (transport_.get() && transport_->socket()) { socket 143 net/socket/socks5_client_socket.cc return transport_->socket()->GetSSLInfo(ssl_info); socket 159 net/socket/socks5_client_socket.cc int rv = transport_->socket()->Read( socket 177 net/socket/socks5_client_socket.cc int rv = transport_->socket()->Write( socket 187 net/socket/socks5_client_socket.cc return transport_->socket()->SetReceiveBufferSize(size); socket 191 net/socket/socks5_client_socket.cc return transport_->socket()->SetSendBufferSize(size); socket 297 net/socket/socks5_client_socket.cc return transport_->socket() socket 320 net/socket/socks5_client_socket.cc return transport_->socket() socket 395 net/socket/socks5_client_socket.cc return transport_->socket() socket 429 net/socket/socks5_client_socket.cc return transport_->socket() socket 499 net/socket/socks5_client_socket.cc return transport_->socket()->GetPeerAddress(address); socket 503 net/socket/socks5_client_socket.cc return transport_->socket()->GetLocalAddress(address); socket 73 net/socket/socks_client_socket.cc net_log_(transport_->socket()->NetLog()) {} socket 81 net/socket/socks_client_socket.cc DCHECK(transport_->socket()); socket 105 net/socket/socks_client_socket.cc transport_->socket()->Disconnect(); socket 114 net/socket/socks_client_socket.cc return completed_handshake_ && transport_->socket()->IsConnected(); socket 118 net/socket/socks_client_socket.cc return completed_handshake_ && transport_->socket()->IsConnectedAndIdle(); socket 126 net/socket/socks_client_socket.cc if (transport_.get() && transport_->socket()) { socket 127 net/socket/socks_client_socket.cc transport_->socket()->SetSubresourceSpeculation(); socket 134 net/socket/socks_client_socket.cc if (transport_.get() && transport_->socket()) { socket 135 net/socket/socks_client_socket.cc transport_->socket()->SetOmniboxSpeculation(); socket 146 net/socket/socks_client_socket.cc if (transport_.get() && transport_->socket()) { socket 147 net/socket/socks_client_socket.cc return transport_->socket()->UsingTCPFastOpen(); socket 154 net/socket/socks_client_socket.cc if (transport_.get() && transport_->socket()) { socket 155 net/socket/socks_client_socket.cc return transport_->socket()->WasNpnNegotiated(); socket 162 net/socket/socks_client_socket.cc if (transport_.get() && transport_->socket()) { socket 163 net/socket/socks_client_socket.cc return transport_->socket()->GetNegotiatedProtocol(); socket 170 net/socket/socks_client_socket.cc if (transport_.get() && transport_->socket()) { socket 171 net/socket/socks_client_socket.cc return transport_->socket()->GetSSLInfo(ssl_info); socket 187 net/socket/socks_client_socket.cc int rv = transport_->socket()->Read( socket 205 net/socket/socks_client_socket.cc int rv = transport_->socket()->Write( socket 215 net/socket/socks_client_socket.cc return transport_->socket()->SetReceiveBufferSize(size); socket 219 net/socket/socks_client_socket.cc return transport_->socket()->SetSendBufferSize(size); socket 355 net/socket/socks_client_socket.cc return transport_->socket()->Write( socket 390 net/socket/socks_client_socket.cc return transport_->socket()->Read( socket 448 net/socket/socks_client_socket.cc return transport_->socket()->GetPeerAddress(address); socket 452 net/socket/socks_client_socket.cc return transport_->socket()->GetLocalAddress(address); socket 242 net/socket/socks_client_socket_pool.cc scoped_ptr<StreamSocket> socket, socket 244 net/socket/socks_client_socket_pool.cc base_.ReleaseSocket(group_name, socket.Pass(), id); socket 139 net/socket/socks_client_socket_pool.h scoped_ptr<StreamSocket> socket, socket 139 net/socket/socks_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 158 net/socket/socks_client_socket_pool_unittest.cc handle.socket()->Disconnect(); socket 178 net/socket/socks_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket() == NULL); socket 192 net/socket/socks_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 196 net/socket/socks_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 211 net/socket/socks_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 225 net/socket/socks_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 229 net/socket/socks_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 247 net/socket/socks_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 267 net/socket/socks_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 271 net/socket/socks_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 609 net/socket/ssl_client_socket_nss.cc bool Init(PRFileDesc* socket, memio_Private* buffers); socket 677 net/socket/ssl_client_socket_nss.cc PRFileDesc* socket, socket 694 net/socket/ssl_client_socket_nss.cc PRFileDesc* socket, socket 702 net/socket/ssl_client_socket_nss.cc PRFileDesc* socket, socket 710 net/socket/ssl_client_socket_nss.cc static SECStatus CanFalseStartCallback(PRFileDesc* socket, socket 716 net/socket/ssl_client_socket_nss.cc static void HandshakeCallback(PRFileDesc* socket, void* arg); socket 749 net/socket/ssl_client_socket_nss.cc PRFileDesc* socket, socket 974 net/socket/ssl_client_socket_nss.cc bool SSLClientSocketNSS::Core::Init(PRFileDesc* socket, socket 980 net/socket/ssl_client_socket_nss.cc nss_fd_ = socket; socket 1279 net/socket/ssl_client_socket_nss.cc PRFileDesc* socket, socket 1286 net/socket/ssl_client_socket_nss.cc ScopedCERTCertificate new_cert(SSL_PeerCertificate(socket)); socket 1306 net/socket/ssl_client_socket_nss.cc PRFileDesc* socket, socket 1520 net/socket/ssl_client_socket_nss.cc PRFileDesc* socket, socket 1546 net/socket/ssl_client_socket_nss.cc PRFileDesc* socket, socket 1560 net/socket/ssl_client_socket_nss.cc void* wincx = SSL_RevealPinArg(socket); socket 1612 net/socket/ssl_client_socket_nss.cc PRFileDesc* socket, socket 1618 net/socket/ssl_client_socket_nss.cc SECStatus rv = SSL_HandshakeNegotiatedExtension(socket, socket 1622 net/socket/ssl_client_socket_nss.cc rv = SSL_HandshakeNegotiatedExtension(socket, socket 1631 net/socket/ssl_client_socket_nss.cc return SSL_RecommendedCanFalseStart(socket, can_false_start); socket 1636 net/socket/ssl_client_socket_nss.cc PRFileDesc* socket, socket 1651 net/socket/ssl_client_socket_nss.cc SSL_CacheSessionUnlocked(socket); socket 2296 net/socket/ssl_client_socket_nss.cc PRFileDesc* socket, socket 2598 net/socket/ssl_client_socket_nss.cc int rv = transport_->socket()->Read( socket 2620 net/socket/ssl_client_socket_nss.cc int rv = transport_->socket()->Write( socket 2817 net/socket/ssl_client_socket_nss.cc net_log_(transport_->socket()->NetLog()), socket 2989 net/socket/ssl_client_socket_nss.cc transport_->socket()->Disconnect(); socket 3006 net/socket/ssl_client_socket_nss.cc transport_->socket()->IsConnected()); socket 3016 net/socket/ssl_client_socket_nss.cc transport_->socket()->IsConnectedAndIdle(); socket 3022 net/socket/ssl_client_socket_nss.cc return transport_->socket()->GetPeerAddress(address); socket 3026 net/socket/ssl_client_socket_nss.cc return transport_->socket()->GetLocalAddress(address); socket 3034 net/socket/ssl_client_socket_nss.cc if (transport_.get() && transport_->socket()) { socket 3035 net/socket/ssl_client_socket_nss.cc transport_->socket()->SetSubresourceSpeculation(); socket 3042 net/socket/ssl_client_socket_nss.cc if (transport_.get() && transport_->socket()) { socket 3043 net/socket/ssl_client_socket_nss.cc transport_->socket()->SetOmniboxSpeculation(); socket 3056 net/socket/ssl_client_socket_nss.cc if (transport_.get() && transport_->socket()) { socket 3057 net/socket/ssl_client_socket_nss.cc return transport_->socket()->UsingTCPFastOpen(); socket 3088 net/socket/ssl_client_socket_nss.cc return transport_->socket()->SetReceiveBufferSize(size); socket 3092 net/socket/ssl_client_socket_nss.cc return transport_->socket()->SetSendBufferSize(size); socket 3260 net/socket/ssl_client_socket_nss.cc int err = transport_->socket()->GetPeerAddress(&peer_address); socket 234 net/socket/ssl_client_socket_openssl.cc std::string GetSocketSessionCacheKey(const SSLClientSocketOpenSSL& socket) { socket 235 net/socket/ssl_client_socket_openssl.cc std::string result = socket.host_and_port().ToString(); socket 237 net/socket/ssl_client_socket_openssl.cc result.append(socket.ssl_session_cache_shard()); socket 251 net/socket/ssl_client_socket_openssl.cc SSLClientSocketOpenSSL* socket = static_cast<SSLClientSocketOpenSSL*>( socket 253 net/socket/ssl_client_socket_openssl.cc DCHECK(socket); socket 254 net/socket/ssl_client_socket_openssl.cc return socket; socket 257 net/socket/ssl_client_socket_openssl.cc bool SetClientSocketForSSL(SSL* ssl, SSLClientSocketOpenSSL* socket) { socket 258 net/socket/ssl_client_socket_openssl.cc return SSL_set_ex_data(ssl, ssl_socket_data_index_, socket) != 0; socket 284 net/socket/ssl_client_socket_openssl.cc SSLClientSocketOpenSSL* socket = GetInstance()->GetClientSocketFromSSL(ssl); socket 285 net/socket/ssl_client_socket_openssl.cc DCHECK(socket); socket 286 net/socket/ssl_client_socket_openssl.cc return GetSocketSessionCacheKey(*socket); socket 292 net/socket/ssl_client_socket_openssl.cc SSLClientSocketOpenSSL* socket = GetInstance()->GetClientSocketFromSSL(ssl); socket 293 net/socket/ssl_client_socket_openssl.cc CHECK(socket); socket 294 net/socket/ssl_client_socket_openssl.cc return socket->ClientCertRequestCallback(ssl, x509, pkey); socket 298 net/socket/ssl_client_socket_openssl.cc SSLClientSocketOpenSSL* socket = GetInstance()->GetClientSocketFromSSL(ssl); socket 299 net/socket/ssl_client_socket_openssl.cc CHECK(socket); socket 300 net/socket/ssl_client_socket_openssl.cc socket->ChannelIDRequestCallback(ssl, pkey); socket 306 net/socket/ssl_client_socket_openssl.cc SSLClientSocketOpenSSL* socket = GetInstance()->GetClientSocketFromSSL(ssl); socket 307 net/socket/ssl_client_socket_openssl.cc CHECK(socket); socket 309 net/socket/ssl_client_socket_openssl.cc return socket->CertVerifyCallback(store_ctx); socket 316 net/socket/ssl_client_socket_openssl.cc SSLClientSocketOpenSSL* socket = GetInstance()->GetClientSocketFromSSL(ssl); socket 317 net/socket/ssl_client_socket_openssl.cc return socket->SelectNextProtoCallback(out, outlen, in, inlen); socket 507 net/socket/ssl_client_socket_openssl.cc net_log_(transport_->socket()->NetLog()) {} socket 597 net/socket/ssl_client_socket_openssl.cc transport_->socket()->Disconnect(); socket 632 net/socket/ssl_client_socket_openssl.cc return transport_->socket()->IsConnected(); socket 649 net/socket/ssl_client_socket_openssl.cc return transport_->socket()->IsConnectedAndIdle(); socket 653 net/socket/ssl_client_socket_openssl.cc return transport_->socket()->GetPeerAddress(addressList); socket 657 net/socket/ssl_client_socket_openssl.cc return transport_->socket()->GetLocalAddress(addressList); socket 665 net/socket/ssl_client_socket_openssl.cc if (transport_.get() && transport_->socket()) { socket 666 net/socket/ssl_client_socket_openssl.cc transport_->socket()->SetSubresourceSpeculation(); socket 673 net/socket/ssl_client_socket_openssl.cc if (transport_.get() && transport_->socket()) { socket 674 net/socket/ssl_client_socket_openssl.cc transport_->socket()->SetOmniboxSpeculation(); socket 685 net/socket/ssl_client_socket_openssl.cc if (transport_.get() && transport_->socket()) socket 686 net/socket/ssl_client_socket_openssl.cc return transport_->socket()->UsingTCPFastOpen(); socket 782 net/socket/ssl_client_socket_openssl.cc return transport_->socket()->SetReceiveBufferSize(size); socket 786 net/socket/ssl_client_socket_openssl.cc return transport_->socket()->SetSendBufferSize(size); socket 1297 net/socket/ssl_client_socket_openssl.cc int rv = transport_->socket()->Write( socket 1337 net/socket/ssl_client_socket_openssl.cc int rv = transport_->socket()->Read( socket 138 net/socket/ssl_client_socket_pool.cc if (transport_socket_handle_->socket()) socket 286 net/socket/ssl_client_socket_pool.cc StreamSocket* socket = transport_socket_handle_->socket(); socket 288 net/socket/ssl_client_socket_pool.cc static_cast<HttpProxyClientSocket*>(socket); socket 601 net/socket/ssl_client_socket_pool.cc scoped_ptr<StreamSocket> socket, socket 603 net/socket/ssl_client_socket_pool.cc base_.ReleaseSocket(group_name, socket.Pass(), id); socket 221 net/socket/ssl_client_socket_pool.h scoped_ptr<StreamSocket> socket, socket 247 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 266 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 270 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 291 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 315 net/socket/ssl_client_socket_pool_unittest.cc handle.socket()->Disconnect(); socket 335 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 339 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 359 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 363 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 383 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 387 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 408 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 412 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 414 net/socket/ssl_client_socket_pool_unittest.cc SSLClientSocket* ssl_socket = static_cast<SSLClientSocket*>(handle.socket()); socket 435 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 439 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 460 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 464 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 467 net/socket/ssl_client_socket_pool_unittest.cc SSLClientSocket* ssl_socket = static_cast<SSLClientSocket*>(handle.socket()); socket 492 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 496 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 499 net/socket/ssl_client_socket_pool_unittest.cc SSLClientSocket* ssl_socket = static_cast<SSLClientSocket*>(handle.socket()); socket 522 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 541 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 545 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 566 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 608 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 612 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 633 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 652 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 656 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 689 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 752 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 756 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 788 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 792 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 798 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_TRUE(tunnel_handle->socket()); socket 799 net/socket/ssl_client_socket_pool_unittest.cc EXPECT_FALSE(tunnel_handle->socket()->IsConnected()); socket 474 net/socket/ssl_client_socket_unittest.cc explicit DeleteSocketCallback(StreamSocket* socket) socket 475 net/socket/ssl_client_socket_unittest.cc : socket_(socket), socket 57 net/socket/ssl_server_socket.h scoped_ptr<StreamSocket> socket, socket 82 net/socket/ssl_server_socket_nss.cc scoped_ptr<StreamSocket> socket, socket 90 net/socket/ssl_server_socket_nss.cc new SSLServerSocketNSS(socket.Pass(), cert, key, ssl_config)); socket 814 net/socket/ssl_server_socket_nss.cc PRFileDesc* socket, socket 825 net/socket/ssl_server_socket_nss.cc void SSLServerSocketNSS::HandshakeCallback(PRFileDesc* socket, socket 27 net/socket/ssl_server_socket_nss.h SSLServerSocketNSS(scoped_ptr<StreamSocket> socket, socket 97 net/socket/ssl_server_socket_nss.h PRFileDesc* socket, socket 100 net/socket/ssl_server_socket_nss.h static void HandshakeCallback(PRFileDesc* socket, void* arg); socket 20 net/socket/ssl_server_socket_openssl.cc scoped_ptr<StreamSocket> socket, socket 33 net/socket/tcp_client_socket_unittest.cc TCPClientSocket socket(AddressList(server_address), NULL, NetLog::Source()); socket 35 net/socket/tcp_client_socket_unittest.cc EXPECT_EQ(OK, socket.Bind(IPEndPoint(lo_address, 0))); socket 38 net/socket/tcp_client_socket_unittest.cc EXPECT_EQ(OK, socket.GetLocalAddress(&local_address_result)); socket 42 net/socket/tcp_client_socket_unittest.cc EXPECT_EQ(ERR_IO_PENDING, socket.Connect(connect_callback.callback())); socket 53 net/socket/tcp_client_socket_unittest.cc EXPECT_TRUE(socket.IsConnected()); socket 54 net/socket/tcp_client_socket_unittest.cc socket.Disconnect(); socket 55 net/socket/tcp_client_socket_unittest.cc EXPECT_FALSE(socket.IsConnected()); socket 57 net/socket/tcp_client_socket_unittest.cc socket.GetLocalAddress(&local_address_result)); socket 65 net/socket/tcp_client_socket_unittest.cc TCPClientSocket socket(AddressList::CreateFromIPAddress(external_ip, 80), socket 70 net/socket/tcp_client_socket_unittest.cc EXPECT_EQ(OK, socket.Bind(IPEndPoint(lo_address, 0))); socket 73 net/socket/tcp_client_socket_unittest.cc int result = socket.Connect(connect_callback.callback()); socket 97 net/socket/tcp_client_socket_unittest.cc TCPClientSocket socket(AddressList(server_address), NULL, NetLog::Source()); socket 101 net/socket/tcp_client_socket_unittest.cc EXPECT_EQ(OK, socket.Bind(IPEndPoint(ipv4_lo_ip, 0))); socket 104 net/socket/tcp_client_socket_unittest.cc int result = socket.Connect(connect_callback.callback()); socket 53 net/socket/tcp_server_socket.cc int TCPServerSocket::Accept(scoped_ptr<StreamSocket>* socket, socket 55 net/socket/tcp_server_socket.cc DCHECK(socket); socket 67 net/socket/tcp_server_socket.cc socket, callback); socket 74 net/socket/tcp_server_socket.cc result = ConvertAcceptedSocket(result, socket); socket 27 net/socket/tcp_server_socket.h virtual int Accept(scoped_ptr<StreamSocket>* socket, socket 61 net/socket/tcp_server_socket_unittest.cc static IPEndPoint GetPeerAddress(StreamSocket* socket) { socket 63 net/socket/tcp_server_socket_unittest.cc EXPECT_EQ(OK, socket->GetPeerAddress(&address)); socket 194 net/socket/tcp_socket_libevent.cc int TCPSocketLibevent::AdoptConnectedSocket(int socket, socket 199 net/socket/tcp_socket_libevent.cc socket_ = socket; socket 243 net/socket/tcp_socket_libevent.cc int TCPSocketLibevent::Accept(scoped_ptr<TCPSocketLibevent>* socket, socket 247 net/socket/tcp_socket_libevent.cc DCHECK(socket); socket 254 net/socket/tcp_socket_libevent.cc int result = AcceptInternal(socket, address); socket 264 net/socket/tcp_socket_libevent.cc accept_socket_ = socket; socket 592 net/socket/tcp_socket_libevent.cc int TCPSocketLibevent::AcceptInternal(scoped_ptr<TCPSocketLibevent>* socket, socket 621 net/socket/tcp_socket_libevent.cc *socket = tcp_socket.Pass(); socket 34 net/socket/tcp_socket_libevent.h int AdoptConnectedSocket(int socket, const IPEndPoint& peer_address); socket 39 net/socket/tcp_socket_libevent.h int Accept(scoped_ptr<TCPSocketLibevent>* socket, socket 158 net/socket/tcp_socket_libevent.h int AcceptInternal(scoped_ptr<TCPSocketLibevent>* socket, socket 31 net/socket/tcp_socket_win.cc int SetSocketReceiveBufferSize(SOCKET socket, int32 size) { socket 32 net/socket/tcp_socket_win.cc int rv = setsockopt(socket, SOL_SOCKET, SO_RCVBUF, socket 39 net/socket/tcp_socket_win.cc int SetSocketSendBufferSize(SOCKET socket, int32 size) { socket 40 net/socket/tcp_socket_win.cc int rv = setsockopt(socket, SOL_SOCKET, SO_SNDBUF, socket 69 net/socket/tcp_socket_win.cc bool DisableNagle(SOCKET socket, bool disable) { socket 71 net/socket/tcp_socket_win.cc int rv = setsockopt(socket, IPPROTO_TCP, TCP_NODELAY, socket 80 net/socket/tcp_socket_win.cc bool SetTCPKeepAlive(SOCKET socket, BOOL enable, int delay_secs) { socket 88 net/socket/tcp_socket_win.cc int rv = WSAIoctl(socket, SIO_KEEPALIVE_VALS, &keepalive_vals, socket 91 net/socket/tcp_socket_win.cc DCHECK(!rv) << "Could not enable TCP Keep-Alive for socket: " << socket socket 133 net/socket/tcp_socket_win.cc explicit Core(TCPSocketWin* socket); socket 201 net/socket/tcp_socket_win.cc TCPSocketWin::Core::Core(TCPSocketWin* socket) socket 205 net/socket/tcp_socket_win.cc socket_(socket), socket 305 net/socket/tcp_socket_win.cc int TCPSocketWin::AdoptConnectedSocket(SOCKET socket, socket 311 net/socket/tcp_socket_win.cc socket_ = socket; socket 363 net/socket/tcp_socket_win.cc int TCPSocketWin::Accept(scoped_ptr<TCPSocketWin>* socket, socket 367 net/socket/tcp_socket_win.cc DCHECK(socket); socket 374 net/socket/tcp_socket_win.cc int result = AcceptInternal(socket, address); socket 381 net/socket/tcp_socket_win.cc accept_socket_ = socket; socket 700 net/socket/tcp_socket_win.cc int TCPSocketWin::AcceptInternal(scoped_ptr<TCPSocketWin>* socket, socket 727 net/socket/tcp_socket_win.cc *socket = tcp_socket.Pass(); socket 35 net/socket/tcp_socket_win.h int AdoptConnectedSocket(SOCKET socket, const IPEndPoint& peer_address); socket 40 net/socket/tcp_socket_win.h int Accept(scoped_ptr<TCPSocketWin>* socket, socket 97 net/socket/tcp_socket_win.h int AcceptInternal(scoped_ptr<TCPSocketWin>* socket, socket 481 net/socket/transport_client_socket_pool.cc scoped_ptr<StreamSocket> socket, socket 483 net/socket/transport_client_socket_pool.cc base_.ReleaseSocket(group_name, socket.Pass(), id); socket 168 net/socket/transport_client_socket_pool.h scoped_ptr<StreamSocket> socket, socket 582 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 586 net/socket/transport_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 876 net/socket/transport_client_socket_pool_unittest.cc handle_->socket()->Disconnect(); socket 974 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 978 net/socket/transport_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 1002 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 1006 net/socket/transport_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 1058 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 1072 net/socket/transport_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 1100 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 1118 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 1146 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 1164 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 1194 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 1212 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 1250 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 1254 net/socket/transport_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 1256 net/socket/transport_client_socket_pool_unittest.cc handle.socket()->GetLocalAddress(&endpoint); socket 1295 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 1299 net/socket/transport_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 1301 net/socket/transport_client_socket_pool_unittest.cc handle.socket()->GetLocalAddress(&endpoint); socket 1329 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 1333 net/socket/transport_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 1335 net/socket/transport_client_socket_pool_unittest.cc handle.socket()->GetLocalAddress(&endpoint); socket 1362 net/socket/transport_client_socket_pool_unittest.cc EXPECT_FALSE(handle.socket()); socket 1366 net/socket/transport_client_socket_pool_unittest.cc EXPECT_TRUE(handle.socket()); socket 1368 net/socket/transport_client_socket_pool_unittest.cc handle.socket()->GetLocalAddress(&endpoint); socket 34 net/socket/unix_domain_socket_posix.cc bool GetPeerIds(int socket, uid_t* user_id, gid_t* group_id) { socket 38 net/socket/unix_domain_socket_posix.cc if (getsockopt(socket, SOL_SOCKET, SO_PEERCRED, &user_cred, &len) == -1) socket 43 net/socket/unix_domain_socket_posix.cc if (getpeereid(socket, user_id, group_id) == -1) socket 53 net/socket_stream/socket_stream.cc SocketStream* socket, const CompletionCallback& callback) { socket 57 net/socket_stream/socket_stream.cc void SocketStream::Delegate::OnAuthRequired(SocketStream* socket, socket 60 net/socket_stream/socket_stream.cc socket->Close(); socket 64 net/socket_stream/socket_stream.cc SocketStream* socket, socket 67 net/socket_stream/socket_stream.cc socket->CancelWithSSLError(ssl_info); socket 70 net/socket_stream/socket_stream.cc bool SocketStream::Delegate::CanGetCookies(SocketStream* socket, socket 216 net/socket_stream/socket_stream.cc if (!connection_->socket() || socket 217 net/socket_stream/socket_stream.cc !connection_->socket()->IsConnected() || next_state_ == STATE_NONE) { socket 277 net/socket_stream/socket_stream.cc if (!connection_->socket()) { socket 387 net/socket_stream/socket_stream.cc if (!connection_->socket() || !connection_->socket()->IsConnected()) { socket 755 net/socket_stream/socket_stream.cc return connection_->socket()->Connect(io_callback_); socket 840 net/socket_stream/socket_stream.cc return connection_->socket()->Write( socket 884 net/socket_stream/socket_stream.cc return connection_->socket()->Read( socket 991 net/socket_stream/socket_stream.cc return connection_->socket()->Connect(io_callback_); socket 1014 net/socket_stream/socket_stream.cc scoped_ptr<StreamSocket> socket(factory_->CreateSSLClientSocket( socket 1020 net/socket_stream/socket_stream.cc connection_->SetSocket(socket.Pass()); socket 1023 net/socket_stream/socket_stream.cc return connection_->socket()->Connect(io_callback_); socket 1055 net/socket_stream/socket_stream.cc if (!connection_->socket()->IsConnectedAndIdle()) socket 1070 net/socket_stream/socket_stream.cc scoped_ptr<StreamSocket> socket( socket 1076 net/socket_stream/socket_stream.cc connection_->SetSocket(socket.Pass()); socket 1079 net/socket_stream/socket_stream.cc return connection_->socket()->Connect(io_callback_); socket 1115 net/socket_stream/socket_stream.cc if (!connection_->socket()->IsConnectedAndIdle()) socket 1129 net/socket_stream/socket_stream.cc if (!connection_->socket() || !connection_->socket()->IsConnected()) { socket 1138 net/socket_stream/socket_stream.cc connection_->socket()->Disconnect(); socket 1150 net/socket_stream/socket_stream.cc result = connection_->socket()->Read( socket 1189 net/socket_stream/socket_stream.cc result = connection_->socket()->Write( socket 1221 net/socket_stream/socket_stream.cc DCHECK(connection_->socket()); socket 1224 net/socket_stream/socket_stream.cc static_cast<SSLClientSocket*>(connection_->socket()); socket 1271 net/socket_stream/socket_stream.cc static_cast<SSLClientSocket*>(connection_->socket()); socket 1293 net/socket_stream/socket_stream.cc connection_->socket()->Disconnect(); socket 1321 net/socket_stream/socket_stream.cc static_cast<SSLClientSocket*>(connection_->socket()); socket 63 net/socket_stream/socket_stream.h virtual int OnStartOpenConnection(SocketStream* socket, socket 71 net/socket_stream/socket_stream.h virtual void OnConnected(SocketStream* socket, socket 75 net/socket_stream/socket_stream.h virtual void OnSentData(SocketStream* socket, socket 79 net/socket_stream/socket_stream.h virtual void OnReceivedData(SocketStream* socket, socket 83 net/socket_stream/socket_stream.h virtual void OnClose(SocketStream* socket) = 0; socket 88 net/socket_stream/socket_stream.h virtual void OnAuthRequired(SocketStream* socket, socket 94 net/socket_stream/socket_stream.h virtual void OnSSLCertificateError(SocketStream* socket, socket 101 net/socket_stream/socket_stream.h virtual void OnError(const SocketStream* socket, int error) {} socket 105 net/socket_stream/socket_stream.h virtual bool CanGetCookies(SocketStream* socket, const GURL& url); socket 50 net/socket_stream/socket_stream_job.h void InitSocketStream(SocketStream* socket) { socket 51 net/socket_stream/socket_stream_job.h socket_ = socket; socket 44 net/socket_stream/socket_stream_unittest.cc : event_type(type), socket(socket_stream), number(num), data(str), socket 48 net/socket_stream/socket_stream_unittest.cc SocketStream* socket; socket 92 net/socket_stream/socket_stream_unittest.cc SocketStream* socket, socket 97 net/socket_stream/socket_stream_unittest.cc socket, 0, std::string(), NULL, OK)); socket 102 net/socket_stream/socket_stream_unittest.cc virtual void OnConnected(SocketStream* socket, socket 106 net/socket_stream/socket_stream_unittest.cc socket, num_pending_send_allowed, std::string(), socket 111 net/socket_stream/socket_stream_unittest.cc virtual void OnSentData(SocketStream* socket, socket 114 net/socket_stream/socket_stream_unittest.cc SocketStreamEvent(SocketStreamEvent::EVENT_SENT_DATA, socket, socket 119 net/socket_stream/socket_stream_unittest.cc virtual void OnReceivedData(SocketStream* socket, socket 122 net/socket_stream/socket_stream_unittest.cc SocketStreamEvent(SocketStreamEvent::EVENT_RECEIVED_DATA, socket, len, socket 127 net/socket_stream/socket_stream_unittest.cc virtual void OnClose(SocketStream* socket) OVERRIDE { socket 129 net/socket_stream/socket_stream_unittest.cc SocketStreamEvent(SocketStreamEvent::EVENT_CLOSE, socket, 0, socket 136 net/socket_stream/socket_stream_unittest.cc virtual void OnAuthRequired(SocketStream* socket, socket 139 net/socket_stream/socket_stream_unittest.cc SocketStreamEvent(SocketStreamEvent::EVENT_AUTH_REQUIRED, socket, 0, socket 144 net/socket_stream/socket_stream_unittest.cc virtual void OnError(const SocketStream* socket, int error) OVERRIDE { socket 155 net/socket_stream/socket_stream_unittest.cc event->socket->Close(); socket 160 net/socket_stream/socket_stream_unittest.cc event->socket->RestartWithAuth(credentials_); socket 201 net/socket_stream/socket_stream_unittest.cc virtual void OnError(const SocketStream* socket, int error) OVERRIDE { socket 217 net/socket_stream/socket_stream_unittest.cc virtual void OnConnected(SocketStream* socket, int max_pending_send_allowed) socket 221 net/socket_stream/socket_stream_unittest.cc virtual void OnSentData(SocketStream* socket, int amount_sent) OVERRIDE { socket 224 net/socket_stream/socket_stream_unittest.cc virtual void OnReceivedData(SocketStream* socket, const char* data, int len) socket 228 net/socket_stream/socket_stream_unittest.cc virtual void OnClose(SocketStream* socket) OVERRIDE { socket 301 net/socket_stream/socket_stream_unittest.cc event->socket->SendData( socket 312 net/socket_stream/socket_stream_unittest.cc EXPECT_TRUE(event->socket->SendData(&frame[0], frame.size())); socket 316 net/socket_stream/socket_stream_unittest.cc event->socket->Close(); socket 321 net/socket_stream/socket_stream_unittest.cc event->socket->DetachContext(); socket 328 net/socket_stream/socket_stream_unittest.cc EXPECT_TRUE(event->socket->SendData(&frame[0], frame.size())); socket 332 net/socket_stream/socket_stream_unittest.cc event->socket->Close(); socket 338 net/socket_stream/socket_stream_unittest.cc EXPECT_FALSE(event->socket->SendData(&frame[0], frame.size())); socket 339 net/socket_stream/socket_stream_unittest.cc event->socket->Close(); socket 526 net/spdy/spdy_session.cc DCHECK(connection_->socket()); socket 528 net/spdy/spdy_session.cc connection_->socket()->Disconnect(); socket 550 net/spdy/spdy_session.cc DCHECK(connection->socket()); socket 560 net/spdy/spdy_session.cc connection_->socket()->GetNegotiatedProtocol(); socket 594 net/spdy/spdy_session.cc connection_->socket()->NetLog().source().ToEventParametersCallback()); socket 726 net/spdy/spdy_session.cc DCHECK(connection_->socket()); socket 727 net/spdy/spdy_session.cc DCHECK(connection_->socket()->IsConnected()); socket 728 net/spdy/spdy_session.cc if (connection_->socket()) { socket 730 net/spdy/spdy_session.cc connection_->socket()->IsConnected()); socket 731 net/spdy/spdy_session.cc if (!connection_->socket()->IsConnected()) { socket 1231 net/spdy/spdy_session.cc CHECK(connection_->socket()); socket 1233 net/spdy/spdy_session.cc return connection_->socket()->Read( socket 1405 net/spdy/spdy_session.cc return connection_->socket()->Write( socket 1660 net/spdy/spdy_session.cc connection_->socket()->GetNegotiatedProtocol())); socket 1696 net/spdy/spdy_session.cc if (connection_->socket()) { socket 1697 net/spdy/spdy_session.cc rv = connection_->socket()->GetPeerAddress(address); socket 1708 net/spdy/spdy_session.cc if (connection_->socket()) { socket 1709 net/spdy/spdy_session.cc rv = connection_->socket()->GetLocalAddress(address); socket 1838 net/spdy/spdy_session.cc *was_npn_negotiated = connection_->socket()->WasNpnNegotiated(); socket 1839 net/spdy/spdy_session.cc *protocol_negotiated = connection_->socket()->GetNegotiatedProtocol(); socket 1840 net/spdy/spdy_session.cc return connection_->socket()->GetSSLInfo(ssl_info); socket 2859 net/spdy/spdy_session.cc reinterpret_cast<SSLClientSocket*>(connection_->socket()); socket 377 net/spdy/spdy_session.h return connection_->socket()->WasEverUsed(); socket 548 net/test/android/javatests/src/org/chromium/net/test/util/TestWebServer.java Socket socket = mSocket.accept(); socket 550 net/test/android/javatests/src/org/chromium/net/test/util/TestWebServer.java conn.bind(socket, params); socket 300 net/test/embedded_test_server/embedded_test_server.cc StreamListenSocket* socket) { socket 304 net/test/embedded_test_server/embedded_test_server.cc connections_.find(socket); socket 171 net/test/embedded_test_server/embedded_test_server.h HttpConnection* FindConnection(StreamListenSocket* socket); socket 13 net/test/embedded_test_server/http_connection.cc HttpConnection::HttpConnection(scoped_ptr<StreamListenSocket> socket, socket 15 net/test/embedded_test_server/http_connection.cc : socket_(socket.Pass()), socket 32 net/test/embedded_test_server/http_connection.h HttpConnection(scoped_ptr<StreamListenSocket> socket, socket 27 net/third_party/nss/ssl/authcert.c PRFileDesc * socket, socket 38 net/third_party/nss/ssl/authcert.c proto_win = SSL_RevealPinArg(socket); socket 1105 net/third_party/nss/ssl/dtlscon.c DTLS_GetHandshakeTimeout(PRFileDesc *socket, PRIntervalTime *timeout) socket 1111 net/third_party/nss/ssl/dtlscon.c ss = ssl_FindSocket(socket); socket 930 net/third_party/nss/ssl/ssl.h SSL_IMPORT CERTCertificate * SSL_RevealCert(PRFileDesc * socket); socket 931 net/third_party/nss/ssl/ssl.h SSL_IMPORT void * SSL_RevealPinArg(PRFileDesc * socket); socket 932 net/third_party/nss/ssl/ssl.h SSL_IMPORT char * SSL_RevealURL(PRFileDesc * socket); socket 945 net/third_party/nss/ssl/ssl.h PRFileDesc * socket, socket 1073 net/third_party/nss/ssl/ssl.h SSL_IMPORT SECStatus SSL_HandshakeNegotiatedExtension(PRFileDesc * socket, socket 1113 net/third_party/nss/ssl/ssl.h SSL_IMPORT SECStatus DTLS_GetHandshakeTimeout(PRFileDesc *socket, socket 74 net/third_party/nss/ssl/sslreveal.c SSL_HandshakeNegotiatedExtension(PRFileDesc * socket, socket 86 net/third_party/nss/ssl/sslreveal.c sslsocket = ssl_FindSocket(socket); socket 89 net/third_party/nss/ssl/sslreveal.c SSL_GETPID(), socket)); socket 135 net/tools/flip_server/create_listener.cc socket(results->ai_family, results->ai_socktype, results->ai_protocol); socket 263 net/tools/flip_server/create_listener.cc socket(results->ai_family, results->ai_socktype, results->ai_protocol); socket 87 net/tools/quic/quic_client.cc fd_ = socket(address_family, SOCK_DGRAM | SOCK_NONBLOCK, IPPROTO_UDP); socket 94 net/tools/quic/quic_server.cc fd_ = socket(address_family, SOCK_DGRAM | SOCK_NONBLOCK, IPPROTO_UDP); socket 42 net/udp/udp_socket_libevent.cc int GetIPv4AddressFromIndex(int socket, uint32 index, uint32* address){ socket 51 net/udp/udp_socket_libevent.cc int rv = ioctl(socket, SIOCGIFADDR, &ifr); socket 178 net/udp/udp_socket_libevent.h explicit ReadWatcher(UDPSocketLibevent* socket) : socket_(socket) {} socket 194 net/udp/udp_socket_libevent.h explicit WriteWatcher(UDPSocketLibevent* socket) : socket_(socket) {} socket 33 net/udp/udp_socket_unittest.cc std::string RecvFromSocket(UDPServerSocket* socket) { socket 36 net/udp/udp_socket_unittest.cc int rv = socket->RecvFrom( socket 50 net/udp/udp_socket_unittest.cc int SendToSocket(UDPServerSocket* socket, std::string msg) { socket 51 net/udp/udp_socket_unittest.cc return SendToSocket(socket, msg, recv_from_address_); socket 54 net/udp/udp_socket_unittest.cc int SendToSocket(UDPServerSocket* socket, socket 66 net/udp/udp_socket_unittest.cc int rv = socket->SendTo( socket 78 net/udp/udp_socket_unittest.cc std::string ReadSocket(UDPClientSocket* socket) { socket 81 net/udp/udp_socket_unittest.cc int rv = socket->Read(buffer_.get(), kMaxRead, callback.callback()); socket 91 net/udp/udp_socket_unittest.cc int WriteSocket(UDPClientSocket* socket, std::string msg) { socket 101 net/udp/udp_socket_unittest.cc int rv = socket->Write( socket 302 net/udp/udp_socket_unittest.cc UDPClientSocket* socket = socket 307 net/udp/udp_socket_unittest.cc sockets.push_back(socket); socket 308 net/udp/udp_socket_unittest.cc EXPECT_EQ(OK, socket->Connect(peer_address)); socket 311 net/udp/udp_socket_unittest.cc EXPECT_EQ(OK, socket->GetLocalAddress(&client_address)); socket 349 net/udp/udp_socket_unittest.cc scoped_ptr<UDPSocket> socket( socket 354 net/udp/udp_socket_unittest.cc int rv = socket->Connect(peer_address); socket 358 net/udp/udp_socket_unittest.cc EXPECT_FALSE(socket->is_connected()); socket 547 net/udp/udp_socket_unittest.cc UDPSocket socket(DatagramSocket::DEFAULT_BIND, socket 551 net/udp/udp_socket_unittest.cc EXPECT_EQ(OK, socket.Bind(bind_address)); socket 552 net/udp/udp_socket_unittest.cc EXPECT_EQ(OK, socket.JoinGroup(group_ip)); socket 554 net/udp/udp_socket_unittest.cc EXPECT_NE(OK, socket.JoinGroup(group_ip)); socket 555 net/udp/udp_socket_unittest.cc EXPECT_EQ(OK, socket.LeaveGroup(group_ip)); socket 557 net/udp/udp_socket_unittest.cc EXPECT_NE(OK, socket.LeaveGroup(group_ip)); socket 559 net/udp/udp_socket_unittest.cc socket.Close(); socket 567 net/udp/udp_socket_unittest.cc UDPSocket socket(DatagramSocket::DEFAULT_BIND, socket 572 net/udp/udp_socket_unittest.cc EXPECT_EQ(OK, socket.SetMulticastLoopbackMode(false)); socket 573 net/udp/udp_socket_unittest.cc EXPECT_EQ(OK, socket.SetMulticastLoopbackMode(true)); socket 574 net/udp/udp_socket_unittest.cc EXPECT_EQ(OK, socket.SetMulticastTimeToLive(0)); socket 575 net/udp/udp_socket_unittest.cc EXPECT_EQ(OK, socket.SetMulticastTimeToLive(3)); socket 576 net/udp/udp_socket_unittest.cc EXPECT_NE(OK, socket.SetMulticastTimeToLive(-1)); socket 577 net/udp/udp_socket_unittest.cc EXPECT_EQ(OK, socket.SetMulticastInterface(0)); socket 579 net/udp/udp_socket_unittest.cc EXPECT_EQ(OK, socket.Bind(bind_address)); socket 581 net/udp/udp_socket_unittest.cc EXPECT_NE(OK, socket.SetMulticastLoopbackMode(false)); socket 582 net/udp/udp_socket_unittest.cc EXPECT_NE(OK, socket.SetMulticastTimeToLive(0)); socket 583 net/udp/udp_socket_unittest.cc EXPECT_NE(OK, socket.SetMulticastInterface(0)); socket 585 net/udp/udp_socket_unittest.cc socket.Close(); socket 43 net/udp/udp_socket_win.cc explicit Core(UDPSocketWin* socket); socket 108 net/udp/udp_socket_win.cc UDPSocketWin::Core::Core(UDPSocketWin* socket) socket 109 net/udp/udp_socket_win.cc : socket_(socket), socket 599 net/url_request/url_request_test_util.cc SocketStream* socket, socket 119 net/websockets/websocket_basic_stream.cc int result = connection_->socket()->Read( socket 177 net/websockets/websocket_basic_stream.cc void WebSocketBasicStream::Close() { connection_->socket()->Disconnect(); } socket 205 net/websockets/websocket_basic_stream.cc int result = connection_->socket()->Write( socket 169 net/websockets/websocket_job.cc SocketStream* socket, const CompletionCallback& callback) { socket 173 net/websockets/websocket_job.cc addresses_ = socket->address_list(); socket 179 net/websockets/websocket_job.cc int result = delegate_->OnStartOpenConnection(socket, callback); socket 193 net/websockets/websocket_job.cc SocketStream* socket, int max_pending_send_allowed) { socket 198 net/websockets/websocket_job.cc delegate_->OnConnected(socket, max_pending_send_allowed); socket 201 net/websockets/websocket_job.cc void WebSocketJob::OnSentData(SocketStream* socket, int amount_sent) { socket 207 net/websockets/websocket_job.cc OnSentHandshakeRequest(socket, amount_sent); socket 232 net/websockets/websocket_job.cc delegate_->OnSentData(socket, amount_sent); socket 237 net/websockets/websocket_job.cc SocketStream* socket, const char* data, int len) { socket 242 net/websockets/websocket_job.cc OnReceivedHandshakeResponse(socket, data, len); socket 247 net/websockets/websocket_job.cc delegate_->OnReceivedData(socket, data, len); socket 250 net/websockets/websocket_job.cc void WebSocketJob::OnClose(SocketStream* socket) { socket 266 net/websockets/websocket_job.cc delegate->OnClose(socket); socket 270 net/websockets/websocket_job.cc SocketStream* socket, AuthChallengeInfo* auth_info) { socket 272 net/websockets/websocket_job.cc delegate_->OnAuthRequired(socket, auth_info); socket 276 net/websockets/websocket_job.cc SocketStream* socket, const SSLInfo& ssl_info, bool fatal) { socket 278 net/websockets/websocket_job.cc delegate_->OnSSLCertificateError(socket, ssl_info, fatal); socket 281 net/websockets/websocket_job.cc void WebSocketJob::OnError(const SocketStream* socket, int error) { socket 283 net/websockets/websocket_job.cc delegate_->OnError(socket, error); socket 420 net/websockets/websocket_job.cc SocketStream* socket, int amount_sent) { socket 432 net/websockets/websocket_job.cc delegate_->OnSentData(socket, original_length); socket 437 net/websockets/websocket_job.cc SocketStream* socket, const char* data, int len) { socket 65 net/websockets/websocket_job.h SocketStream* socket, const CompletionCallback& callback) OVERRIDE; socket 66 net/websockets/websocket_job.h virtual void OnConnected(SocketStream* socket, socket 68 net/websockets/websocket_job.h virtual void OnSentData(SocketStream* socket, int amount_sent) OVERRIDE; socket 69 net/websockets/websocket_job.h virtual void OnReceivedData(SocketStream* socket, socket 72 net/websockets/websocket_job.h virtual void OnClose(SocketStream* socket) OVERRIDE; socket 74 net/websockets/websocket_job.h SocketStream* socket, AuthChallengeInfo* auth_info) OVERRIDE; socket 75 net/websockets/websocket_job.h virtual void OnSSLCertificateError(SocketStream* socket, socket 78 net/websockets/websocket_job.h virtual void OnError(const SocketStream* socket, int error) OVERRIDE; socket 98 net/websockets/websocket_job.h void OnSentHandshakeRequest(SocketStream* socket, int amount_sent); socket 102 net/websockets/websocket_job.h SocketStream* socket, const char* data, int len); socket 100 net/websockets/websocket_job_test.cc SocketStream* socket, socket 106 net/websockets/websocket_job_test.cc virtual void OnConnected(SocketStream* socket, socket 111 net/websockets/websocket_job_test.cc virtual void OnSentData(SocketStream* socket, socket 117 net/websockets/websocket_job_test.cc virtual void OnReceivedData(SocketStream* socket, socket 123 net/websockets/websocket_job_test.cc virtual void OnClose(SocketStream* socket) OVERRIDE { socket 127 net/websockets/websocket_job_test.cc virtual bool CanGetCookies(SocketStream* socket, socket 347 net/websockets/websocket_job_test.cc virtual void OnConnected(SocketStream* socket, socket 352 net/websockets/websocket_job_test.cc virtual void OnSentData(SocketStream* socket, int amount_sent) OVERRIDE { socket 356 net/websockets/websocket_job_test.cc virtual void OnReceivedData(SocketStream* socket, socket 362 net/websockets/websocket_job_test.cc virtual void OnClose(SocketStream* socket) OVERRIDE { DeleteJobMaybe(); } socket 364 net/websockets/websocket_job_test.cc virtual void OnAuthRequired(SocketStream* socket, socket 369 net/websockets/websocket_job_test.cc virtual void OnSSLCertificateError(SocketStream* socket, socket 375 net/websockets/websocket_job_test.cc virtual void OnError(const SocketStream* socket, int error) OVERRIDE { socket 496 net/websockets/websocket_job_test.cc MockSocketStream* socket = socket 498 net/websockets/websocket_job_test.cc DCHECK(socket); socket 499 net/websockets/websocket_job_test.cc return socket->sent_data(); socket 24 net/websockets/websocket_throttle_test.cc net::SocketStream* socket, int max_pending_send_allowed) OVERRIDE {} socket 25 net/websockets/websocket_throttle_test.cc virtual void OnSentData(net::SocketStream* socket, socket 27 net/websockets/websocket_throttle_test.cc virtual void OnReceivedData(net::SocketStream* socket, socket 29 net/websockets/websocket_throttle_test.cc virtual void OnClose(net::SocketStream* socket) OVERRIDE {} socket 46 net/websockets/websocket_throttle_test.cc SocketStream* socket, const AddressList& list) { socket 47 net/websockets/websocket_throttle_test.cc socket->set_addresses(list); socket 49 net/websockets/websocket_throttle_test.cc socket->proxy_info_.UseDirect(); socket 58 net/websockets/websocket_throttle_test.cc DCHECK_EQ(socket->next_state_, SocketStream::STATE_NONE); socket 28 ppapi/cpp/extensions/dev/socket_dev.h namespace socket { socket 31 ppapi/cpp/private/tcp_server_socket_private.h int32_t Accept(PP_Resource* socket, socket 38 ppapi/native_client/src/trusted/plugin/srpc_client.h bool Init(nacl::DescWrapper* socket); socket 264 ppapi/proxy/ppapi_param_traits.cc IPC::PlatformFileForTransit socket; socket 265 ppapi/proxy/ppapi_param_traits.cc if (ParamTraits<IPC::PlatformFileForTransit>::Read(m, iter, &socket)) { socket 266 ppapi/proxy/ppapi_param_traits.cc r->set_socket(socket); socket 93 ppapi/proxy/serialized_handle.h void set_socket(const IPC::PlatformFileForTransit& socket) { socket 95 ppapi/proxy/serialized_handle.h descriptor_ = socket; socket 102 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::CreateInfo_Dev> socket 105 ppapi/tests/extensions/socket/test_socket.cc socket::SocketType_Dev(socket::SocketType_Dev::TCP), socket 106 ppapi/tests/extensions/socket/test_socket.cc Optional<socket::CreateOptions_Dev>(), callback.GetCallback())); socket 127 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::CreateInfo_Dev> socket 130 ppapi/tests/extensions/socket/test_socket.cc socket::SocketType_Dev(socket::SocketType_Dev::TCP), socket 131 ppapi/tests/extensions/socket/test_socket.cc Optional<socket::CreateOptions_Dev>(), callback.GetCallback())); socket 151 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::AcceptInfo_Dev> socket 156 ppapi/tests/extensions/socket/test_socket.cc socket::AcceptInfo_Dev accept_info = callback.output(); socket 164 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::WriteInfo_Dev> socket 171 ppapi/tests/extensions/socket/test_socket.cc socket::WriteInfo_Dev write_info = callback.output(); socket 178 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::ReadInfo_Dev> socket 202 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::CreateInfo_Dev> socket 205 ppapi/tests/extensions/socket/test_socket.cc socket::SocketType_Dev::UDP, Optional<socket::CreateOptions_Dev>(), socket 253 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::CreateInfo_Dev> socket 256 ppapi/tests/extensions/socket/test_socket.cc socket::SocketType_Dev::UDP, Optional<socket::CreateOptions_Dev>(), socket 297 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::CreateInfo_Dev> socket 300 ppapi/tests/extensions/socket/test_socket.cc socket::SocketType_Dev::UDP, Optional<socket::CreateOptions_Dev>(), socket 333 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::RecvFromInfo_Dev> socket 340 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::WriteInfo_Dev> socket 352 ppapi/tests/extensions/socket/test_socket.cc socket::RecvFromInfo_Dev recv_from_info = recv_from_callback.output(); socket 385 ppapi/tests/extensions/socket/test_socket.cc socket::SocketType_Dev socket_type; socket 391 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::CreateInfo_Dev> socket 394 ppapi/tests/extensions/socket/test_socket.cc socket_type, Optional<socket::CreateOptions_Dev>(), socket 404 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::SocketInfo_Dev> socket 411 ppapi/tests/extensions/socket/test_socket.cc socket::SocketInfo_Dev socket_info = callback.output(); socket 425 ppapi/tests/extensions/socket/test_socket.cc if (socket_type.value == socket::SocketType_Dev::TCP) { socket 445 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::SocketInfo_Dev> socket 452 ppapi/tests/extensions/socket/test_socket.cc socket::SocketInfo_Dev socket_info = callback.output(); socket 459 ppapi/tests/extensions/socket/test_socket.cc if (socket_type.value == socket::SocketType_Dev::TCP) { socket 489 ppapi/tests/extensions/socket/test_socket.cc if (socket_type.value == socket::SocketType_Dev::TCP) { socket 504 ppapi/tests/extensions/socket/test_socket.cc if (socket_type.value == socket::SocketType_Dev::TCP) { socket 518 ppapi/tests/extensions/socket/test_socket.cc if (socket_type.value == socket::SocketType_Dev::TCP) { socket 519 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::ReadInfo_Dev> socket 526 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::WriteInfo_Dev> socket 538 ppapi/tests/extensions/socket/test_socket.cc socket::ReadInfo_Dev read_info = read_callback.output(); socket 542 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::RecvFromInfo_Dev> socket 549 ppapi/tests/extensions/socket/test_socket.cc TestExtCompletionCallbackWithOutput<socket::WriteInfo_Dev> socket 562 ppapi/tests/extensions/socket/test_socket.cc socket::RecvFromInfo_Dev recv_from_info = recv_from_callback.output(); socket 587 ppapi/tests/extensions/socket/test_socket.cc std::vector<socket::NetworkInterface_Dev> > callback(pp_instance()); socket 629 ppapi/tests/extensions/socket/test_socket.cc socket::Socket_Dev socket_; socket 48 ppapi/tests/test_host_resolver.cc pp::TCPSocket* socket, socket 51 ppapi/tests/test_host_resolver.cc callback.WaitForResult(socket->Connect(address, callback.GetCallback())); socket 57 ppapi/tests/test_host_resolver.cc std::string TestHostResolver::SyncRead(pp::TCPSocket* socket, socket 63 ppapi/tests/test_host_resolver.cc socket->Read(buffer, num_bytes, callback.GetCallback())); socket 70 ppapi/tests/test_host_resolver.cc std::string TestHostResolver::SyncWrite(pp::TCPSocket* socket, socket 76 ppapi/tests/test_host_resolver.cc socket->Write(buffer, num_bytes, callback.GetCallback())); socket 83 ppapi/tests/test_host_resolver.cc std::string TestHostResolver::CheckHTTPResponse(pp::TCPSocket* socket, socket 88 ppapi/tests/test_host_resolver.cc SyncWrite(socket, request.c_str(), request.size(), &rv)); socket 91 ppapi/tests/test_host_resolver.cc SyncRead(socket, &response_buffer[0], response.size(), &rv)); socket 127 ppapi/tests/test_host_resolver.cc pp::TCPSocket socket(instance_); socket 128 ppapi/tests/test_host_resolver.cc ASSERT_SUBTEST_SUCCESS(SyncConnect(&socket, address)); socket 129 ppapi/tests/test_host_resolver.cc ASSERT_SUBTEST_SUCCESS(CheckHTTPResponse(&socket, socket 132 ppapi/tests/test_host_resolver.cc socket.Close(); socket 28 ppapi/tests/test_host_resolver.h std::string SyncConnect(pp::TCPSocket* socket, socket 30 ppapi/tests/test_host_resolver.h std::string SyncRead(pp::TCPSocket* socket, socket 34 ppapi/tests/test_host_resolver.h std::string SyncWrite(pp::TCPSocket* socket, socket 38 ppapi/tests/test_host_resolver.h std::string CheckHTTPResponse(pp::TCPSocket* socket, socket 49 ppapi/tests/test_host_resolver_private.cc std::string TestHostResolverPrivate::SyncConnect(pp::TCPSocketPrivate* socket, socket 54 ppapi/tests/test_host_resolver_private.cc socket->Connect(host.c_str(), port, callback.GetCallback())); socket 61 ppapi/tests/test_host_resolver_private.cc pp::TCPSocketPrivate* socket, socket 65 ppapi/tests/test_host_resolver_private.cc socket->ConnectWithNetAddress(&address, callback.GetCallback())); socket 71 ppapi/tests/test_host_resolver_private.cc std::string TestHostResolverPrivate::SyncRead(pp::TCPSocketPrivate* socket, socket 77 ppapi/tests/test_host_resolver_private.cc socket->Read(buffer, num_bytes, callback.GetCallback())); socket 84 ppapi/tests/test_host_resolver_private.cc std::string TestHostResolverPrivate::SyncWrite(pp::TCPSocketPrivate* socket, socket 90 ppapi/tests/test_host_resolver_private.cc socket->Write(buffer, num_bytes, callback.GetCallback())); socket 98 ppapi/tests/test_host_resolver_private.cc pp::TCPSocketPrivate* socket, socket 103 ppapi/tests/test_host_resolver_private.cc SyncWrite(socket, request.c_str(), request.size(), &rv)); socket 106 ppapi/tests/test_host_resolver_private.cc SyncRead(socket, &response_buffer[0], response.size(), &rv)); socket 149 ppapi/tests/test_host_resolver_private.cc pp::TCPSocketPrivate socket(instance_); socket 150 ppapi/tests/test_host_resolver_private.cc ASSERT_SUBTEST_SUCCESS(SyncConnect(&socket, address)); socket 151 ppapi/tests/test_host_resolver_private.cc ASSERT_SUBTEST_SUCCESS(CheckHTTPResponse(&socket, socket 154 ppapi/tests/test_host_resolver_private.cc socket.Disconnect(); socket 160 ppapi/tests/test_host_resolver_private.cc pp::TCPSocketPrivate socket(instance_); socket 161 ppapi/tests/test_host_resolver_private.cc ASSERT_SUBTEST_SUCCESS(SyncConnect(&socket, socket 164 ppapi/tests/test_host_resolver_private.cc ASSERT_SUBTEST_SUCCESS(CheckHTTPResponse(&socket, socket 167 ppapi/tests/test_host_resolver_private.cc socket.Disconnect(); socket 31 ppapi/tests/test_host_resolver_private.h std::string SyncConnect(pp::TCPSocketPrivate* socket, socket 34 ppapi/tests/test_host_resolver_private.h std::string SyncConnect(pp::TCPSocketPrivate* socket, socket 36 ppapi/tests/test_host_resolver_private.h std::string SyncRead(pp::TCPSocketPrivate* socket, socket 40 ppapi/tests/test_host_resolver_private.h std::string SyncWrite(pp::TCPSocketPrivate* socket, socket 44 ppapi/tests/test_host_resolver_private.h std::string CheckHTTPResponse(pp::TCPSocketPrivate* socket, socket 55 ppapi/tests/test_net_address_private_untrusted.cc int32_t TestNetAddressPrivateUntrusted::Connect(TCPSocketPrivate* socket, socket 61 ppapi/tests/test_net_address_private_untrusted.cc socket->Connect(host.c_str(), port, callback.GetCallback())); socket 66 ppapi/tests/test_net_address_private_untrusted.cc pp::TCPSocketPrivate socket(instance_); socket 67 ppapi/tests/test_net_address_private_untrusted.cc int32_t rv = Connect(&socket, host_, port_); socket 72 ppapi/tests/test_net_address_private_untrusted.cc ASSERT_TRUE(socket.GetLocalAddress(&local_address)); socket 73 ppapi/tests/test_net_address_private_untrusted.cc ASSERT_TRUE(socket.GetRemoteAddress(&remote_address)); socket 78 ppapi/tests/test_net_address_private_untrusted.cc socket.Disconnect(); socket 83 ppapi/tests/test_net_address_private_untrusted.cc pp::TCPSocketPrivate socket(instance_); socket 84 ppapi/tests/test_net_address_private_untrusted.cc int32_t rv = Connect(&socket, host_, port_); socket 89 ppapi/tests/test_net_address_private_untrusted.cc ASSERT_TRUE(socket.GetLocalAddress(&local_address)); socket 90 ppapi/tests/test_net_address_private_untrusted.cc ASSERT_TRUE(socket.GetRemoteAddress(&remote_address)); socket 95 ppapi/tests/test_net_address_private_untrusted.cc socket.Disconnect(); socket 100 ppapi/tests/test_net_address_private_untrusted.cc pp::TCPSocketPrivate socket(instance_); socket 101 ppapi/tests/test_net_address_private_untrusted.cc int32_t rv = Connect(&socket, host_, port_); socket 106 ppapi/tests/test_net_address_private_untrusted.cc ASSERT_TRUE(socket.GetRemoteAddress(&remote_address)); socket 116 ppapi/tests/test_net_address_private_untrusted.cc socket.Disconnect(); socket 121 ppapi/tests/test_net_address_private_untrusted.cc pp::TCPSocketPrivate socket(instance_); socket 122 ppapi/tests/test_net_address_private_untrusted.cc int32_t rv = Connect(&socket, host_, port_); socket 127 ppapi/tests/test_net_address_private_untrusted.cc ASSERT_TRUE(socket.GetRemoteAddress(&src_addr)); socket 141 ppapi/tests/test_net_address_private_untrusted.cc socket.Disconnect(); socket 158 ppapi/tests/test_net_address_private_untrusted.cc pp::TCPSocketPrivate socket(instance_); socket 159 ppapi/tests/test_net_address_private_untrusted.cc int32_t rv = Connect(&socket, host_, port_); socket 164 ppapi/tests/test_net_address_private_untrusted.cc ASSERT_TRUE(socket.GetRemoteAddress(&remote_address)); socket 169 ppapi/tests/test_net_address_private_untrusted.cc socket.Disconnect(); socket 174 ppapi/tests/test_net_address_private_untrusted.cc pp::TCPSocketPrivate socket(instance_); socket 175 ppapi/tests/test_net_address_private_untrusted.cc int32_t rv = Connect(&socket, host_, port_); socket 180 ppapi/tests/test_net_address_private_untrusted.cc ASSERT_TRUE(socket.GetRemoteAddress(&remote_address)); socket 184 ppapi/tests/test_net_address_private_untrusted.cc socket.Disconnect(); socket 189 ppapi/tests/test_net_address_private_untrusted.cc pp::TCPSocketPrivate socket(instance_); socket 190 ppapi/tests/test_net_address_private_untrusted.cc int32_t rv = Connect(&socket, host_, port_); socket 195 ppapi/tests/test_net_address_private_untrusted.cc ASSERT_TRUE(socket.GetRemoteAddress(&remote_address)); socket 202 ppapi/tests/test_net_address_private_untrusted.cc socket.Disconnect(); socket 27 ppapi/tests/test_net_address_private_untrusted.h int32_t Connect(pp::TCPSocketPrivate* socket, socket 63 ppapi/tests/test_tcp_server_socket_private.cc TCPSocketPrivate socket(instance_); socket 66 ppapi/tests/test_tcp_server_socket_private.cc socket.Connect(host_.c_str(), port_, callback.GetCallback())); socket 69 ppapi/tests/test_tcp_server_socket_private.cc ASSERT_TRUE(socket.GetLocalAddress(address)); socket 70 ppapi/tests/test_tcp_server_socket_private.cc socket.Disconnect(); socket 74 ppapi/tests/test_tcp_server_socket_private.cc std::string TestTCPServerSocketPrivate::SyncRead(TCPSocketPrivate* socket, socket 80 ppapi/tests/test_tcp_server_socket_private.cc socket->Read(buffer, num_bytes, callback.GetCallback())); socket 89 ppapi/tests/test_tcp_server_socket_private.cc std::string TestTCPServerSocketPrivate::SyncWrite(TCPSocketPrivate* socket, socket 95 ppapi/tests/test_tcp_server_socket_private.cc socket->Write(buffer, num_bytes, callback.GetCallback())); socket 105 ppapi/tests/test_tcp_server_socket_private.cc TCPSocketPrivate* socket, socket 109 ppapi/tests/test_tcp_server_socket_private.cc socket->ConnectWithNetAddress(address, callback.GetCallback())); socket 115 ppapi/tests/test_tcp_server_socket_private.cc void TestTCPServerSocketPrivate::ForceConnect(TCPSocketPrivate* socket, socket 119 ppapi/tests/test_tcp_server_socket_private.cc error_message = SyncConnect(socket, address); socket 124 ppapi/tests/test_tcp_server_socket_private.cc TCPServerSocketPrivate* socket, socket 133 ppapi/tests/test_tcp_server_socket_private.cc socket->Listen(address, backlog, callback.GetCallback())); socket 136 ppapi/tests/test_tcp_server_socket_private.cc int32_t rv = socket->GetLocalAddress(address); socket 33 ppapi/tests/test_tcp_server_socket_private.h std::string SyncRead(pp::TCPSocketPrivate* socket, socket 36 ppapi/tests/test_tcp_server_socket_private.h std::string SyncWrite(pp::TCPSocketPrivate* socket, socket 39 ppapi/tests/test_tcp_server_socket_private.h std::string SyncConnect(pp::TCPSocketPrivate* socket, socket 41 ppapi/tests/test_tcp_server_socket_private.h void ForceConnect(pp::TCPSocketPrivate* socket, socket 43 ppapi/tests/test_tcp_server_socket_private.h std::string SyncListen(pp::TCPServerSocketPrivate* socket, socket 53 ppapi/tests/test_tcp_server_socket_private_disallowed.cc PP_Resource socket = socket 55 ppapi/tests/test_tcp_server_socket_private_disallowed.cc ASSERT_TRUE(socket != 0); socket 56 ppapi/tests/test_tcp_server_socket_private_disallowed.cc ASSERT_TRUE(tcp_server_socket_private_interface_->IsTCPServerSocket(socket)); socket 64 ppapi/tests/test_tcp_server_socket_private_disallowed.cc socket, socket 70 ppapi/tests/test_tcp_socket.cc pp::TCPSocket socket(instance_); socket 73 ppapi/tests/test_tcp_socket.cc cb.WaitForResult(socket.Connect(addr_, cb.GetCallback())); socket 78 ppapi/tests/test_tcp_socket.cc local_addr = socket.GetLocalAddress(); socket 79 ppapi/tests/test_tcp_socket.cc remote_addr = socket.GetRemoteAddress(); socket 85 ppapi/tests/test_tcp_socket.cc socket.Close(); socket 90 ppapi/tests/test_tcp_socket.cc pp::TCPSocket socket(instance_); socket 96 ppapi/tests/test_tcp_socket.cc cb.WaitForResult(socket.Bind(any_port_address, cb.GetCallback())); socket 100 ppapi/tests/test_tcp_socket.cc cb.WaitForResult(socket.Connect(addr_, cb.GetCallback())); socket 105 ppapi/tests/test_tcp_socket.cc local_addr = socket.GetLocalAddress(); socket 106 ppapi/tests/test_tcp_socket.cc remote_addr = socket.GetRemoteAddress(); socket 113 ppapi/tests/test_tcp_socket.cc socket.Close(); socket 120 ppapi/tests/test_tcp_socket.cc pp::TCPSocket socket(instance_); socket 123 ppapi/tests/test_tcp_socket.cc cb.WaitForResult(socket.Connect(addr_, cb.GetCallback())); socket 127 ppapi/tests/test_tcp_socket.cc ASSERT_SUBTEST_SUCCESS(WriteToSocket(&socket, "GET / HTTP/1.0\r\n\r\n")); socket 131 ppapi/tests/test_tcp_socket.cc ASSERT_SUBTEST_SUCCESS(ReadFirstLineFromSocket(&socket, &s)); socket 138 ppapi/tests/test_tcp_socket.cc pp::TCPSocket socket(instance_); socket 144 ppapi/tests/test_tcp_socket.cc int32_t result_1 = socket.SetOption(PP_TCPSOCKET_OPTION_NO_DELAY, socket 146 ppapi/tests/test_tcp_socket.cc int32_t result_2 = socket.SetOption(PP_TCPSOCKET_OPTION_SEND_BUFFER_SIZE, socket 148 ppapi/tests/test_tcp_socket.cc int32_t result_3 = socket.SetOption(PP_TCPSOCKET_OPTION_RECV_BUFFER_SIZE, socket 163 ppapi/tests/test_tcp_socket.cc cb_1.WaitForResult(socket.Connect(addr_, cb_1.GetCallback())); socket 167 ppapi/tests/test_tcp_socket.cc result_1 = socket.SetOption(PP_TCPSOCKET_OPTION_NO_DELAY, socket 169 ppapi/tests/test_tcp_socket.cc result_2 = socket.SetOption(PP_TCPSOCKET_OPTION_SEND_BUFFER_SIZE, socket 171 ppapi/tests/test_tcp_socket.cc result_3 = socket.SetOption(PP_TCPSOCKET_OPTION_RECV_BUFFER_SIZE, socket 317 ppapi/tests/test_tcp_socket.cc PP_Resource socket = socket_interface_1_0_->Create(instance_->pp_instance()); socket 318 ppapi/tests/test_tcp_socket.cc ASSERT_NE(0, socket); socket 322 ppapi/tests/test_tcp_socket.cc socket, addr_.pp_resource(), cb.GetCallback().pp_completion_callback())); socket 326 ppapi/tests/test_tcp_socket.cc ASSERT_SUBTEST_SUCCESS(WriteToSocket_1_0(socket, "GET / HTTP/1.0\r\n\r\n")); socket 330 ppapi/tests/test_tcp_socket.cc ASSERT_SUBTEST_SUCCESS(ReadFirstLineFromSocket_1_0(socket, &s)); socket 333 ppapi/tests/test_tcp_socket.cc pp::Module::Get()->core()->ReleaseResource(socket); socket 337 ppapi/tests/test_tcp_socket.cc std::string TestTCPSocket::ReadFirstLineFromSocket(pp::TCPSocket* socket, socket 345 ppapi/tests/test_tcp_socket.cc cb.WaitForResult(socket->Read(buffer, sizeof(buffer), cb.GetCallback())); socket 358 ppapi/tests/test_tcp_socket.cc std::string TestTCPSocket::ReadFirstLineFromSocket_1_0(PP_Resource socket, socket 367 ppapi/tests/test_tcp_socket.cc socket, buffer, sizeof(buffer), socket 381 ppapi/tests/test_tcp_socket.cc std::string TestTCPSocket::ReadFromSocket(pp::TCPSocket* socket, socket 387 ppapi/tests/test_tcp_socket.cc socket->Read(buffer, num_bytes, callback.GetCallback())); socket 397 ppapi/tests/test_tcp_socket.cc std::string TestTCPSocket::WriteToSocket(pp::TCPSocket* socket, socket 404 ppapi/tests/test_tcp_socket.cc socket->Write(buffer + written, s.size() - written, cb.GetCallback())); socket 414 ppapi/tests/test_tcp_socket.cc PP_Resource socket, socket 421 ppapi/tests/test_tcp_socket.cc socket, buffer + written, s.size() - written, socket 432 ppapi/tests/test_tcp_socket.cc pp::TCPSocket socket(instance_); socket 434 ppapi/tests/test_tcp_socket.cc callback.WaitForResult(socket.Connect(addr_, callback.GetCallback())); socket 438 ppapi/tests/test_tcp_socket.cc ASSERT_TRUE(ReplacePort(instance_->pp_instance(), socket.GetLocalAddress(), 0, socket 444 ppapi/tests/test_tcp_socket.cc std::string TestTCPSocket::StartListen(pp::TCPSocket* socket, int32_t backlog) { socket 450 ppapi/tests/test_tcp_socket.cc socket->Bind(any_port_address, callback.GetCallback())); socket 455 ppapi/tests/test_tcp_socket.cc socket->Listen(backlog, callback.GetCallback())); socket 35 ppapi/tests/test_tcp_socket.h std::string ReadFirstLineFromSocket(pp::TCPSocket* socket, std::string* s); socket 36 ppapi/tests/test_tcp_socket.h std::string ReadFirstLineFromSocket_1_0(PP_Resource socket, socket 38 ppapi/tests/test_tcp_socket.h std::string ReadFromSocket(pp::TCPSocket* socket, socket 41 ppapi/tests/test_tcp_socket.h std::string WriteToSocket(pp::TCPSocket* socket, const std::string& s); socket 42 ppapi/tests/test_tcp_socket.h std::string WriteToSocket_1_0(PP_Resource socket, const std::string& s); socket 45 ppapi/tests/test_tcp_socket.h std::string StartListen(pp::TCPSocket* socket, int32_t backlog); socket 61 ppapi/tests/test_tcp_socket_private.cc pp::TCPSocketPrivate socket(instance_); socket 64 ppapi/tests/test_tcp_socket_private.cc cb.WaitForResult(socket.Connect(host_.c_str(), port_, cb.GetCallback())); socket 70 ppapi/tests/test_tcp_socket_private.cc ASSERT_TRUE(socket.GetLocalAddress(&unused)); socket 71 ppapi/tests/test_tcp_socket_private.cc ASSERT_TRUE(socket.GetRemoteAddress(&unused)); socket 73 ppapi/tests/test_tcp_socket_private.cc socket.Disconnect(); socket 79 ppapi/tests/test_tcp_socket_private.cc pp::TCPSocketPrivate socket(instance_); socket 82 ppapi/tests/test_tcp_socket_private.cc cb.WaitForResult(socket.Connect(host_.c_str(), port_, cb.GetCallback())); socket 86 ppapi/tests/test_tcp_socket_private.cc ASSERT_EQ(PP_OK, WriteStringToSocket(&socket, "GET / HTTP/1.0\r\n\r\n")); socket 90 ppapi/tests/test_tcp_socket_private.cc ASSERT_EQ(PP_OK, ReadFirstLineFromSocket(&socket, &s)); socket 93 ppapi/tests/test_tcp_socket_private.cc socket.Disconnect(); socket 99 ppapi/tests/test_tcp_socket_private.cc pp::TCPSocketPrivate socket(instance_); socket 102 ppapi/tests/test_tcp_socket_private.cc cb.WaitForResult(socket.Connect(host_.c_str(), ssl_port_, cb.GetCallback())); socket 107 ppapi/tests/test_tcp_socket_private.cc socket.SSLHandshake(host_.c_str(), ssl_port_, cb.GetCallback())); socket 111 ppapi/tests/test_tcp_socket_private.cc ASSERT_EQ(PP_OK, WriteStringToSocket(&socket, "GET / HTTP/1.0\r\n\r\n")); socket 115 ppapi/tests/test_tcp_socket_private.cc ASSERT_EQ(PP_OK, ReadFirstLineFromSocket(&socket, &s)); socket 118 ppapi/tests/test_tcp_socket_private.cc socket.Disconnect(); socket 128 ppapi/tests/test_tcp_socket_private.cc pp::TCPSocketPrivate socket(instance_); socket 130 ppapi/tests/test_tcp_socket_private.cc cb.WaitForResult(socket.Connect(host_.c_str(), port_, cb.GetCallback())); socket 133 ppapi/tests/test_tcp_socket_private.cc ASSERT_TRUE(socket.GetRemoteAddress(&address)); socket 139 ppapi/tests/test_tcp_socket_private.cc pp::TCPSocketPrivate socket(instance_); socket 141 ppapi/tests/test_tcp_socket_private.cc cb.WaitForResult(socket.ConnectWithNetAddress(&address, cb.GetCallback())); socket 146 ppapi/tests/test_tcp_socket_private.cc ASSERT_EQ(PP_OK, WriteStringToSocket(&socket, "GET / HTTP/1.0\r\n\r\n")); socket 148 ppapi/tests/test_tcp_socket_private.cc ASSERT_EQ(PP_OK, ReadFirstLineFromSocket(&socket, &s)); socket 151 ppapi/tests/test_tcp_socket_private.cc socket.Disconnect(); socket 157 ppapi/tests/test_tcp_socket_private.cc pp::TCPSocketPrivate socket(instance_); socket 161 ppapi/tests/test_tcp_socket_private.cc socket.SetOption(PP_TCPSOCKETOPTION_PRIVATE_NO_DELAY, true, socket 166 ppapi/tests/test_tcp_socket_private.cc cb.WaitForResult(socket.Connect(host_.c_str(), port_, cb.GetCallback())); socket 171 ppapi/tests/test_tcp_socket_private.cc socket.SetOption(PP_TCPSOCKETOPTION_PRIVATE_NO_DELAY, true, socket 177 ppapi/tests/test_tcp_socket_private.cc socket.SetOption(PP_TCPSOCKETOPTION_PRIVATE_INVALID, true, socket 182 ppapi/tests/test_tcp_socket_private.cc socket.Disconnect(); socket 188 ppapi/tests/test_tcp_socket_private.cc pp::TCPSocketPrivate socket(instance_); socket 192 ppapi/tests/test_tcp_socket_private.cc cb.WaitForResult(socket.Connect(host_.c_str(), port_, cb.GetCallback())); socket 197 ppapi/tests/test_tcp_socket_private.cc ASSERT_EQ(PP_OK, WriteStringToSocket(&socket, "GET / HTTP/1.0\r\n\r\n")); socket 206 ppapi/tests/test_tcp_socket_private.cc cb.WaitForResult(socket.Read(buffer, kReadSize * sizeof(*buffer), socket 217 ppapi/tests/test_tcp_socket_private.cc pp::TCPSocketPrivate* socket, socket 225 ppapi/tests/test_tcp_socket_private.cc int32_t rv = socket->Read(buffer, sizeof(buffer), cb.GetCallback()); socket 243 ppapi/tests/test_tcp_socket_private.cc int32_t TestTCPSocketPrivate::WriteStringToSocket(pp::TCPSocketPrivate* socket, socket 249 ppapi/tests/test_tcp_socket_private.cc int32_t rv = socket->Write(buffer + written, s.size() - written, socket 33 ppapi/tests/test_tcp_socket_private.h int32_t ReadFirstLineFromSocket(pp::TCPSocketPrivate* socket, std::string* s); socket 34 ppapi/tests/test_tcp_socket_private.h int32_t WriteStringToSocket(pp::TCPSocketPrivate* socket, socket 38 ppapi/tests/test_tcp_socket_private_disallowed.cc PP_Resource socket = socket 40 ppapi/tests/test_tcp_socket_private_disallowed.cc if (0 != socket) { socket 43 ppapi/tests/test_tcp_socket_private_disallowed.cc socket, kServerName, kPort, socket 42 ppapi/tests/test_tcp_socket_private_trusted.cc pp::TCPSocketPrivate socket(instance_); socket 46 ppapi/tests/test_tcp_socket_private_trusted.cc socket.Connect(host_.c_str(), ssl_port_, cb.GetCallback())); socket 51 ppapi/tests/test_tcp_socket_private_trusted.cc socket.SSLHandshake(host_.c_str(), ssl_port_, cb.GetCallback())); socket 55 ppapi/tests/test_tcp_socket_private_trusted.cc const pp::X509CertificatePrivate& cert = socket.GetServerCertificate(); socket 89 ppapi/tests/test_udp_socket.cc pp::TCPSocket socket(instance_); socket 91 ppapi/tests/test_udp_socket.cc callback.WaitForResult(socket.Connect(address_, callback.GetCallback())); socket 94 ppapi/tests/test_udp_socket.cc *address = socket.GetLocalAddress(); socket 96 ppapi/tests/test_udp_socket.cc socket.Close(); socket 100 ppapi/tests/test_udp_socket.cc std::string TestUDPSocket::SetBroadcastOptions(pp::UDPSocket* socket) { socket 102 ppapi/tests/test_udp_socket.cc callback_1.WaitForResult(socket->SetOption( socket 109 ppapi/tests/test_udp_socket.cc callback_2.WaitForResult(socket->SetOption( socket 117 ppapi/tests/test_udp_socket.cc std::string TestUDPSocket::BindUDPSocket(pp::UDPSocket* socket, socket 120 ppapi/tests/test_udp_socket.cc callback.WaitForResult(socket->Bind(address, callback.GetCallback())); socket 127 ppapi/tests/test_udp_socket.cc pp::UDPSocket* socket, socket 136 ppapi/tests/test_udp_socket.cc if (BindUDPSocket(socket, new_address).empty()) { socket 144 ppapi/tests/test_udp_socket.cc *address = socket->GetBoundAddress(); socket 150 ppapi/tests/test_udp_socket.cc std::string TestUDPSocket::ReadSocket(pp::UDPSocket* socket, socket 158 ppapi/tests/test_udp_socket.cc socket->RecvFrom(&buffer[0], size, callback.GetCallback())); socket 259 ppapi/tests/test_udp_socket.cc pp::UDPSocket socket(instance_); socket 261 ppapi/tests/test_udp_socket.cc ASSERT_SUBTEST_SUCCESS(SetBroadcastOptions(&socket)); socket 265 ppapi/tests/test_udp_socket.cc callback.WaitForResult(socket.SetOption( socket 270 ppapi/tests/test_udp_socket.cc callback.WaitForResult(socket.SetOption( socket 277 ppapi/tests/test_udp_socket.cc callback.WaitForResult(socket.SetOption( socket 283 ppapi/tests/test_udp_socket.cc callback.WaitForResult(socket.SetOption( socket 290 ppapi/tests/test_udp_socket.cc ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&socket, &address)); socket 293 ppapi/tests/test_udp_socket.cc callback.WaitForResult(socket.SetOption( socket 299 ppapi/tests/test_udp_socket.cc callback.WaitForResult(socket.SetOption( socket 305 ppapi/tests/test_udp_socket.cc callback.WaitForResult(socket.SetOption( socket 311 ppapi/tests/test_udp_socket.cc callback.WaitForResult(socket.SetOption( socket 28 ppapi/tests/test_udp_socket.h std::string SetBroadcastOptions(pp::UDPSocket* socket); socket 29 ppapi/tests/test_udp_socket.h std::string BindUDPSocket(pp::UDPSocket* socket, socket 31 ppapi/tests/test_udp_socket.h std::string LookupPortAndBindUDPSocket(pp::UDPSocket* socket, socket 33 ppapi/tests/test_udp_socket.h std::string ReadSocket(pp::UDPSocket* socket, socket 65 ppapi/tests/test_udp_socket_private.cc pp::TCPSocketPrivate socket(instance_); socket 68 ppapi/tests/test_udp_socket_private.cc socket.Connect(host_.c_str(), port_, callback.GetCallback())); socket 71 ppapi/tests/test_udp_socket_private.cc ASSERT_TRUE(socket.GetLocalAddress(address)); socket 72 ppapi/tests/test_udp_socket_private.cc socket.Disconnect(); socket 77 ppapi/tests/test_udp_socket_private.cc pp::UDPSocketPrivate* socket) { socket 78 ppapi/tests/test_udp_socket_private.cc int32_t rv = socket->SetSocketFeature( socket 83 ppapi/tests/test_udp_socket_private.cc rv = socket->SetSocketFeature(PP_UDPSOCKETFEATURE_PRIVATE_BROADCAST, socket 92 ppapi/tests/test_udp_socket_private.cc pp::UDPSocketPrivate* socket, socket 95 ppapi/tests/test_udp_socket_private.cc callback.WaitForResult(socket->Bind(address, callback.GetCallback())); socket 102 ppapi/tests/test_udp_socket_private.cc pp::UDPSocketPrivate* socket, socket 111 ppapi/tests/test_udp_socket_private.cc if (BindUDPSocket(socket, address).empty()) { socket 118 ppapi/tests/test_udp_socket_private.cc if (!socket->GetBoundAddress(address)) socket 124 ppapi/tests/test_udp_socket_private.cc pp::UDPSocketPrivate* socket, socket 127 ppapi/tests/test_udp_socket_private.cc callback.WaitForResult(socket->Bind(address, callback.GetCallback())); socket 130 ppapi/tests/test_udp_socket_private.cc ASSERT_FALSE(socket->GetBoundAddress(address)); socket 134 ppapi/tests/test_udp_socket_private.cc std::string TestUDPSocketPrivate::ReadSocket(pp::UDPSocketPrivate* socket, socket 141 ppapi/tests/test_udp_socket_private.cc socket->RecvFrom(&buffer[0], size, callback.GetCallback())); socket 193 ppapi/tests/test_udp_socket_private.cc pp::UDPSocketPrivate socket(instance_); socket 196 ppapi/tests/test_udp_socket_private.cc std::string error_message = BindUDPSocketFailure(&socket, &invalid_address); socket 248 ppapi/tests/test_udp_socket_private.cc pp::UDPSocketPrivate socket(instance_); socket 250 ppapi/tests/test_udp_socket_private.cc int32_t rv = socket.SetSocketFeature(PP_UDPSOCKETFEATURE_PRIVATE_COUNT, socket 255 ppapi/tests/test_udp_socket_private.cc rv = socket.SetSocketFeature(PP_UDPSOCKETFEATURE_PRIVATE_ADDRESS_REUSE, socket 24 ppapi/tests/test_udp_socket_private.h std::string SetBroadcastOptions(pp::UDPSocketPrivate* socket); socket 25 ppapi/tests/test_udp_socket_private.h std::string BindUDPSocket(pp::UDPSocketPrivate* socket, socket 27 ppapi/tests/test_udp_socket_private.h std::string LookupPortAndBindUDPSocket(pp::UDPSocketPrivate* socket, socket 29 ppapi/tests/test_udp_socket_private.h std::string BindUDPSocketFailure(pp::UDPSocketPrivate* socket, socket 31 ppapi/tests/test_udp_socket_private.h std::string ReadSocket(pp::UDPSocketPrivate* socket, socket 32 ppapi/tests/test_udp_socket_private_disallowed.cc PP_Resource socket = socket 34 ppapi/tests/test_udp_socket_private_disallowed.cc if (0 != socket) { socket 39 ppapi/tests/test_udp_socket_private_disallowed.cc callback.WaitForResult(udp_socket_private_interface_->Bind(socket, &addr, socket 29 remoting/base/socket_reader.cc void SocketReader::Init(net::Socket* socket, socket 31 remoting/base/socket_reader.cc DCHECK(socket); socket 34 remoting/base/socket_reader.cc socket_ = socket; socket 36 remoting/base/socket_reader.h void Init(net::Socket* socket, ReadResultCallback read_result_callback); socket 44 remoting/host/gnubby_auth_handler_posix.cc explicit CompareSocket(net::StreamListenSocket* socket) : socket_(socket) {} socket 190 remoting/host/gnubby_auth_handler_posix.cc net::StreamListenSocket* socket) const { socket 193 remoting/host/gnubby_auth_handler_posix.cc CompareSocket(socket)) != active_sockets_.end(); socket 197 remoting/host/gnubby_auth_handler_posix.cc net::StreamListenSocket* socket) const { socket 199 remoting/host/gnubby_auth_handler_posix.cc active_sockets_.begin(), active_sockets_.end(), CompareSocket(socket)); socket 204 remoting/host/gnubby_auth_handler_posix.cc net::StreamListenSocket* socket) const { socket 206 remoting/host/gnubby_auth_handler_posix.cc active_sockets_.begin(), active_sockets_.end(), CompareSocket(socket)); socket 212 remoting/host/gnubby_auth_handler_posix.cc scoped_ptr<net::StreamListenSocket> socket) { socket 217 remoting/host/gnubby_auth_handler_posix.cc new GnubbySocket(socket.Pass(), socket 223 remoting/host/gnubby_auth_handler_posix.cc void GnubbyAuthHandlerPosix::DidRead(net::StreamListenSocket* socket, socket 229 remoting/host/gnubby_auth_handler_posix.cc active_sockets_.begin(), active_sockets_.end(), CompareSocket(socket)); socket 245 remoting/host/gnubby_auth_handler_posix.cc void GnubbyAuthHandlerPosix::DidClose(net::StreamListenSocket* socket) { socket 249 remoting/host/gnubby_auth_handler_posix.cc active_sockets_.begin(), active_sockets_.end(), CompareSocket(socket)); socket 35 remoting/host/gnubby_auth_handler_posix.h bool HasActiveSocketForTesting(net::StreamListenSocket* socket) const; socket 36 remoting/host/gnubby_auth_handler_posix.h int GetConnectionIdForTesting(net::StreamListenSocket* socket) const; socket 38 remoting/host/gnubby_auth_handler_posix.h net::StreamListenSocket* socket) const; socket 50 remoting/host/gnubby_auth_handler_posix.h scoped_ptr<net::StreamListenSocket> socket) OVERRIDE; socket 51 remoting/host/gnubby_auth_handler_posix.h virtual void DidRead(net::StreamListenSocket* socket, socket 54 remoting/host/gnubby_auth_handler_posix.h virtual void DidClose(net::StreamListenSocket* socket) OVERRIDE; socket 104 remoting/host/gnubby_auth_handler_posix_unittest.cc net::StreamListenSocket* socket = new MockStreamListenSocket(delegate_); socket 106 remoting/host/gnubby_auth_handler_posix_unittest.cc delegate_->DidAccept(NULL, make_scoped_ptr(socket)); socket 107 remoting/host/gnubby_auth_handler_posix_unittest.cc ASSERT_TRUE(auth_handler_posix_->HasActiveSocketForTesting(socket)); socket 109 remoting/host/gnubby_auth_handler_posix_unittest.cc delegate_->DidClose(socket); socket 110 remoting/host/gnubby_auth_handler_posix_unittest.cc ASSERT_FALSE(auth_handler_posix_->HasActiveSocketForTesting(socket)); socket 116 remoting/host/gnubby_auth_handler_posix_unittest.cc net::StreamListenSocket* socket = new MockStreamListenSocket(delegate_); socket 118 remoting/host/gnubby_auth_handler_posix_unittest.cc delegate_->DidAccept(NULL, make_scoped_ptr(socket)); socket 119 remoting/host/gnubby_auth_handler_posix_unittest.cc delegate_->DidRead(socket, socket 127 remoting/host/gnubby_auth_handler_posix_unittest.cc net::StreamListenSocket* socket = new MockStreamListenSocket(delegate_); socket 129 remoting/host/gnubby_auth_handler_posix_unittest.cc delegate_->DidAccept(NULL, make_scoped_ptr(socket)); socket 132 remoting/host/gnubby_auth_handler_posix_unittest.cc socket, reinterpret_cast<const char*>(request_data + i), 1); socket 137 remoting/host/gnubby_auth_handler_posix_unittest.cc net::StreamListenSocket* socket = new MockStreamListenSocket(delegate_); socket 139 remoting/host/gnubby_auth_handler_posix_unittest.cc delegate_->DidAccept(NULL, make_scoped_ptr(socket)); socket 140 remoting/host/gnubby_auth_handler_posix_unittest.cc ASSERT_TRUE(auth_handler_posix_->HasActiveSocketForTesting(socket)); socket 143 remoting/host/gnubby_auth_handler_posix_unittest.cc auth_handler_posix_->GetGnubbySocketForTesting(socket) socket 145 remoting/host/gnubby_auth_handler_posix_unittest.cc delegate_->DidRead(socket, reinterpret_cast<const char*>(request_data), 1); socket 148 remoting/host/gnubby_auth_handler_posix_unittest.cc ASSERT_FALSE(auth_handler_posix_->HasActiveSocketForTesting(socket)); socket 152 remoting/host/gnubby_auth_handler_posix_unittest.cc net::StreamListenSocket* socket = new MockStreamListenSocket(delegate_); socket 154 remoting/host/gnubby_auth_handler_posix_unittest.cc delegate_->DidAccept(NULL, make_scoped_ptr(socket)); socket 158 remoting/host/gnubby_auth_handler_posix_unittest.cc auth_handler_posix_->GetConnectionIdForTesting(socket)); socket 160 remoting/host/gnubby_auth_handler_posix_unittest.cc ASSERT_TRUE(auth_handler_posix_->HasActiveSocketForTesting(socket)); socket 162 remoting/host/gnubby_auth_handler_posix_unittest.cc ASSERT_FALSE(auth_handler_posix_->HasActiveSocketForTesting(socket)); socket 24 remoting/host/gnubby_socket.cc GnubbySocket::GnubbySocket(scoped_ptr<net::StreamListenSocket> socket, socket 26 remoting/host/gnubby_socket.cc : socket_(socket.Pass()) { socket 82 remoting/host/gnubby_socket.cc bool GnubbySocket::IsSocket(net::StreamListenSocket* socket) const { socket 83 remoting/host/gnubby_socket.cc return socket == socket_.get(); socket 28 remoting/host/gnubby_socket.h GnubbySocket(scoped_ptr<net::StreamListenSocket> socket, socket 51 remoting/host/gnubby_socket.h bool IsSocket(net::StreamListenSocket* socket) const; socket 30 remoting/jingle_glue/chromium_socket_factory_unittest.cc void OnPacket(talk_base::AsyncPacketSocket* socket, socket 34 remoting/jingle_glue/chromium_socket_factory_unittest.cc EXPECT_EQ(socket, socket_.get()); socket 88 remoting/jingle_glue/xmpp_signal_strategy.cc buzz::AsyncSocket* socket = new jingle_glue::ChromeAsyncSocket( socket 94 remoting/jingle_glue/xmpp_signal_strategy.cc settings, std::string(), socket, CreatePreXmppAuth(settings)); socket 42 remoting/protocol/auth_util.cc std::string GetAuthBytes(net::SSLSocket* socket, socket 47 remoting/protocol/auth_util.cc int export_result = socket->ExportKeyingMaterial( socket 47 remoting/protocol/auth_util.h std::string GetAuthBytes(net::SSLSocket* socket, socket 139 remoting/protocol/authenticator_test_base.cc scoped_ptr<net::StreamSocket> socket) { socket 141 remoting/protocol/authenticator_test_base.cc host_socket_ = socket.Pass(); socket 146 remoting/protocol/authenticator_test_base.cc scoped_ptr<net::StreamSocket> socket) { socket 148 remoting/protocol/authenticator_test_base.cc client_socket_ = socket.Pass(); socket 51 remoting/protocol/authenticator_test_base.h scoped_ptr<net::StreamSocket> socket); socket 53 remoting/protocol/authenticator_test_base.h scoped_ptr<net::StreamSocket> socket); socket 36 remoting/protocol/buffered_socket_writer.cc void BufferedSocketWriterBase::Init(net::Socket* socket, socket 39 remoting/protocol/buffered_socket_writer.cc DCHECK(socket); socket 40 remoting/protocol/buffered_socket_writer.cc socket_ = socket; socket 43 remoting/protocol/buffered_socket_writer.h void Init(net::Socket* socket, const WriteFailedCallback& callback); socket 35 remoting/protocol/channel_authenticator.h scoped_ptr<net::StreamSocket> socket, socket 52 remoting/protocol/channel_dispatcher_base.cc scoped_ptr<net::StreamSocket> socket) { socket 53 remoting/protocol/channel_dispatcher_base.cc if (!socket.get()) { socket 58 remoting/protocol/channel_dispatcher_base.cc channel_ = socket.Pass(); socket 56 remoting/protocol/channel_dispatcher_base.h void OnChannelReady(scoped_ptr<net::StreamSocket> socket); socket 415 remoting/protocol/channel_multiplexer.cc scoped_ptr<net::StreamSocket> socket) { socket 417 remoting/protocol/channel_multiplexer.cc base_channel_ = socket.Pass(); socket 446 remoting/protocol/channel_multiplexer.cc scoped_ptr<net::StreamSocket> socket; socket 448 remoting/protocol/channel_multiplexer.cc socket = GetOrCreateChannel(c.name)->CreateSocket(); socket 449 remoting/protocol/channel_multiplexer.cc c.callback.Run(socket.Pass()); socket 42 remoting/protocol/channel_multiplexer.h void OnBaseChannelReady(scoped_ptr<net::StreamSocket> socket); socket 48 remoting/protocol/channel_multiplexer_unittest.cc MOCK_METHOD1(OnConnectedPtr, void(net::StreamSocket* socket)); socket 49 remoting/protocol/channel_multiplexer_unittest.cc void OnConnected(scoped_ptr<net::StreamSocket> socket) { socket 50 remoting/protocol/channel_multiplexer_unittest.cc OnConnectedPtr(socket.release()); socket 113 remoting/protocol/channel_multiplexer_unittest.cc scoped_ptr<net::StreamSocket> socket) { socket 114 remoting/protocol/channel_multiplexer_unittest.cc *storage = socket.Pass(); socket 30 remoting/protocol/fake_authenticator.cc scoped_ptr<net::StreamSocket> socket, socket 32 remoting/protocol/fake_authenticator.cc socket_ = socket.Pass(); socket 23 remoting/protocol/fake_authenticator.h scoped_ptr<net::StreamSocket> socket, socket 29 remoting/protocol/fake_authenticator.h scoped_ptr<net::StreamSocket> socket); socket 88 remoting/protocol/jingle_session_unittest.cc MOCK_METHOD1(OnDone, void(net::StreamSocket* socket)); socket 108 remoting/protocol/jingle_session_unittest.cc void OnClientChannelCreated(scoped_ptr<net::StreamSocket> socket) { socket 109 remoting/protocol/jingle_session_unittest.cc client_channel_callback_.OnDone(socket.get()); socket 110 remoting/protocol/jingle_session_unittest.cc client_socket_ = socket.Pass(); socket 113 remoting/protocol/jingle_session_unittest.cc void OnHostChannelCreated(scoped_ptr<net::StreamSocket> socket) { socket 114 remoting/protocol/jingle_session_unittest.cc host_channel_callback_.OnDone(socket.get()); socket 115 remoting/protocol/jingle_session_unittest.cc host_socket_ = socket.Pass(); socket 86 remoting/protocol/libjingle_transport_factory.cc scoped_ptr<net::StreamSocket> socket); socket 96 remoting/protocol/libjingle_transport_factory.cc void NotifyConnected(scoped_ptr<net::StreamSocket> socket); socket 346 remoting/protocol/libjingle_transport_factory.cc scoped_ptr<net::StreamSocket> socket) { socket 352 remoting/protocol/libjingle_transport_factory.cc NotifyConnected(socket.Pass()); socket 381 remoting/protocol/libjingle_transport_factory.cc scoped_ptr<net::StreamSocket> socket) { socket 385 remoting/protocol/libjingle_transport_factory.cc callback.Run(socket.Pass()); socket 32 remoting/protocol/message_reader.cc void MessageReader::Init(net::Socket* socket, socket 36 remoting/protocol/message_reader.cc DCHECK(socket); socket 37 remoting/protocol/message_reader.cc socket_ = socket; socket 46 remoting/protocol/message_reader.h void Init(net::Socket* socket, const MessageReceivedCallback& callback); socket 94 remoting/protocol/message_reader.h void Init(net::Socket* socket, const MessageReceivedCallback& callback) { socket 99 remoting/protocol/message_reader.h socket, base::Bind(&ProtobufMessageReader<T>::OnNewData, socket 44 remoting/protocol/protobuf_video_reader.cc void ProtobufVideoReader::OnChannelReady(scoped_ptr<net::StreamSocket> socket) { socket 45 remoting/protocol/protobuf_video_reader.cc if (!socket.get()) { socket 51 remoting/protocol/protobuf_video_reader.cc channel_ = socket.Pass(); socket 35 remoting/protocol/protobuf_video_reader.h void OnChannelReady(scoped_ptr<net::StreamSocket> socket); socket 36 remoting/protocol/protobuf_video_writer.cc void ProtobufVideoWriter::OnChannelReady(scoped_ptr<net::StreamSocket> socket) { socket 37 remoting/protocol/protobuf_video_writer.cc if (!socket.get()) { socket 43 remoting/protocol/protobuf_video_writer.cc channel_ = socket.Pass(); socket 42 remoting/protocol/protobuf_video_writer.h void OnChannelReady(scoped_ptr<net::StreamSocket> socket); socket 59 remoting/protocol/ssl_hmac_channel_authenticator.cc scoped_ptr<net::StreamSocket> socket, const DoneCallback& done_callback) { socket 61 remoting/protocol/ssl_hmac_channel_authenticator.cc DCHECK(socket->IsConnected()); socket 80 remoting/protocol/ssl_hmac_channel_authenticator.cc net::CreateSSLServerSocket(socket.Pass(), socket 111 remoting/protocol/ssl_hmac_channel_authenticator.cc connection->SetSocket(socket.Pass()); socket 61 remoting/protocol/ssl_hmac_channel_authenticator.h scoped_ptr<net::StreamSocket> socket, socket 39 remoting/protocol/ssl_hmac_channel_authenticator_unittest.cc MOCK_METHOD2(OnDone, void(net::Error error, net::StreamSocket* socket)); socket 113 remoting/protocol/ssl_hmac_channel_authenticator_unittest.cc scoped_ptr<net::StreamSocket> socket) { socket 114 remoting/protocol/ssl_hmac_channel_authenticator_unittest.cc host_callback_.OnDone(error, socket.get()); socket 115 remoting/protocol/ssl_hmac_channel_authenticator_unittest.cc host_socket_ = socket.Pass(); socket 119 remoting/protocol/ssl_hmac_channel_authenticator_unittest.cc scoped_ptr<net::StreamSocket> socket) { socket 120 remoting/protocol/ssl_hmac_channel_authenticator_unittest.cc client_callback_.OnDone(error, socket.get()); socket 121 remoting/protocol/ssl_hmac_channel_authenticator_unittest.cc client_socket_ = socket.Pass(); socket 25 sandbox/win/sandbox_poc/pocdll/network.cc listen_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); socket 212 third_party/libevent/evdns.c int socket; /* a connected UDP socket */ socket 234 third_party/libevent/evdns.c int socket; /* socket we use to read queries and write replies. */ socket 1175 third_party/libevent/evdns.c const int r = recvfrom(ns->socket, packet, sizeof(packet), 0, socket 1178 third_party/libevent/evdns.c int err = last_error(ns->socket); socket 1204 third_party/libevent/evdns.c r = recvfrom(s->socket, packet, sizeof(packet), 0, socket 1207 third_party/libevent/evdns.c int err = last_error(s->socket); socket 1223 third_party/libevent/evdns.c int r = sendto(port->socket, req->response, req->response_len, 0, socket 1226 third_party/libevent/evdns.c int err = last_error(port->socket); socket 1239 third_party/libevent/evdns.c event_set(&port->event, port->socket, EV_READ | EV_PERSIST, socket 1256 third_party/libevent/evdns.c event_set(&ns->event, ns->socket, EV_READ | (waiting ? EV_WRITE : 0) | EV_PERSIST, socket 1478 third_party/libevent/evdns.c evdns_add_server_port(int socket, int is_tcp, evdns_request_callback_fn_type cb, void *user_data) socket 1486 third_party/libevent/evdns.c port->socket = socket; socket 1494 third_party/libevent/evdns.c event_set(&port->event, port->socket, EV_READ | EV_PERSIST, socket 1736 third_party/libevent/evdns.c r = sendto(port->socket, req->response, req->response_len, 0, socket 1739 third_party/libevent/evdns.c int sock_err = last_error(port->socket); socket 1754 third_party/libevent/evdns.c event_set(&port->event, port->socket, (port->closing?0:EV_READ) | EV_WRITE | EV_PERSIST, server_port_ready_callback, port); socket 1849 third_party/libevent/evdns.c if (port->socket > 0) { socket 1850 third_party/libevent/evdns.c CLOSE_SOCKET(port->socket); socket 1851 third_party/libevent/evdns.c port->socket = -1; socket 1922 third_party/libevent/evdns.c r = sendto(server->socket, req->request, req->request_len, 0, socket 1925 third_party/libevent/evdns.c int err = last_error(server->socket); socket 2066 third_party/libevent/evdns.c if (server->socket >= 0) socket 2067 third_party/libevent/evdns.c CLOSE_SOCKET(server->socket); socket 2133 third_party/libevent/evdns.c ns->socket = socket(PF_INET, SOCK_DGRAM, 0); socket 2134 third_party/libevent/evdns.c if (ns->socket < 0) { err = 1; goto out1; } socket 2135 third_party/libevent/evdns.c evutil_make_socket_nonblocking(ns->socket); socket 2140 third_party/libevent/evdns.c event_set(&ns->event, ns->socket, EV_READ | EV_PERSIST, nameserver_ready_callback, ns); socket 2166 third_party/libevent/evdns.c CLOSE_SOCKET(ns->socket); socket 3053 third_party/libevent/evdns.c if (server->socket >= 0) socket 3054 third_party/libevent/evdns.c CLOSE_SOCKET(server->socket); socket 3159 third_party/libevent/evdns.c sock = socket(PF_INET, SOCK_DGRAM, 0); socket 510 third_party/libevent/evdns.h struct evdns_server_port *evdns_add_server_port(int socket, int is_tcp, evdns_request_callback_fn_type callback, void *user_data); socket 98 third_party/libevent/evutil.c listener = socket(AF_INET, type, 0); socket 111 third_party/libevent/evutil.c connector = socket(AF_INET, type, 0); socket 2688 third_party/libevent/http.c fd = socket(AF_INET, SOCK_STREAM, 0); socket 74 third_party/libevent/sample/event-test.c HANDLE socket; socket 76 third_party/libevent/sample/event-test.c socket = CreateFile("test.txt", // open File socket 84 third_party/libevent/sample/event-test.c if(socket == INVALID_HANDLE_VALUE) socket 90 third_party/libevent/sample/event-test.c int socket; socket 108 third_party/libevent/sample/event-test.c socket = open (fifo, O_RDWR | O_NONBLOCK, 0); socket 110 third_party/libevent/sample/event-test.c socket = open (fifo, O_RDONLY | O_NONBLOCK, 0); socket 113 third_party/libevent/sample/event-test.c if (socket == -1) { socket 125 third_party/libevent/sample/event-test.c event_set(&evfifo, (int)socket, EV_READ, fifo_read, &evfifo); socket 127 third_party/libevent/sample/event-test.c event_set(&evfifo, socket, EV_READ, fifo_read, &evfifo); socket 135 third_party/libevent/sample/event-test.c CloseHandle(socket); socket 315 third_party/libevent/test/regress_dns.c sock = socket(AF_INET, SOCK_DGRAM, 0); socket 146 third_party/libevent/test/regress_http.c fd = socket(AF_INET, SOCK_STREAM, 0); socket 107 third_party/libusb/src/libusb/os/linux_netlink.c linux_netlink_socket = socket(PF_NETLINK, socktype, NETLINK_KOBJECT_UEVENT); socket 109 third_party/libusb/src/libusb/os/linux_netlink.c linux_netlink_socket = socket(PF_NETLINK, SOCK_RAW, NETLINK_KOBJECT_UEVENT); socket 157 third_party/libxml/src/nanoftp.c s = socket (AF_INET6, SOCK_STREAM, 0); socket 916 third_party/libxml/src/nanoftp.c ctxt->controlFd = socket (AF_INET6, SOCK_STREAM, 0); socket 921 third_party/libxml/src/nanoftp.c ctxt->controlFd = socket (AF_INET, SOCK_STREAM, 0); socket 950 third_party/libxml/src/nanoftp.c ctxt->controlFd = socket (AF_INET, SOCK_STREAM, 0); socket 1385 third_party/libxml/src/nanoftp.c ctxt->dataFd = socket (AF_INET6, SOCK_STREAM, IPPROTO_TCP); socket 1391 third_party/libxml/src/nanoftp.c ctxt->dataFd = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP); socket 201 third_party/libxml/src/nanohttp.c s = socket (AF_INET6, SOCK_STREAM, 0); socket 865 third_party/libxml/src/nanohttp.c s = socket(PF_INET6, SOCK_STREAM, IPPROTO_TCP); socket 870 third_party/libxml/src/nanohttp.c s = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP); socket 127 third_party/npapi/npspy/extern/nspr/md/_sunos4.h extern int socket (int domain, int type, int protocol); socket 265 third_party/npapi/npspy/extern/nspr/md/_winnt.h extern PRInt32 _PR_MD_CLOSE(PRInt32 osfd, PRBool socket); socket 52 third_party/npapi/npspy/extern/nspr/prtpool.h PRFileDesc *socket; socket 141 third_party/speech-dispatcher/libspeechd.h int socket; socket 92 third_party/talloc/libreplace/getifaddrs.c if ((fd = socket(AF_INET, SOCK_DGRAM, 0)) == -1) { socket 169 third_party/talloc/libreplace/getifaddrs.c if ((fd = socket(AF_INET, SOCK_DGRAM, 0)) == -1) { socket 267 third_party/talloc/libreplace/getifaddrs.c if ((fd = socket(AF_INET, SOCK_DGRAM, 0)) == -1) { socket 1926 third_party/tcmalloc/chromium/src/base/linux_syscall_support.h LSS_INLINE _syscall3(int, socket, int, d, socket 2179 third_party/tcmalloc/chromium/src/base/linux_syscall_support.h LSS_INLINE int LSS_NAME(socket)(int domain, int type, int protocol) { socket 2193 third_party/tcmalloc/chromium/src/base/linux_syscall_support.h LSS_INLINE int LSS_NAME(socket)(int domain, int type, int protocol) { socket 2202 third_party/tcmalloc/chromium/src/base/linux_syscall_support.h LSS_INLINE _syscall3(int, socket, int, d, socket 1834 third_party/tcmalloc/vendor/src/base/linux_syscall_support.h LSS_INLINE _syscall3(int, socket, int, d, socket 2083 third_party/tcmalloc/vendor/src/base/linux_syscall_support.h LSS_INLINE int LSS_NAME(socket)(int domain, int type, int protocol) { socket 2097 third_party/tcmalloc/vendor/src/base/linux_syscall_support.h LSS_INLINE int LSS_NAME(socket)(int domain, int type, int protocol) { socket 2106 third_party/tcmalloc/vendor/src/base/linux_syscall_support.h LSS_INLINE _syscall3(int, socket, int, d, socket 56 tools/android/common/adb_connection.cc int host_socket = socket(AF_INET, SOCK_STREAM, 0); socket 16 tools/android/common/net.cc int DisableNagle(int socket) { socket 18 tools/android/common/net.cc return setsockopt(socket, IPPROTO_TCP, TCP_NODELAY, &on, sizeof(on)); socket 21 tools/android/common/net.cc int DeferAccept(int socket) { socket 23 tools/android/common/net.cc return setsockopt(socket, IPPROTO_TCP, TCP_DEFER_ACCEPT, &on, sizeof(on)); socket 14 tools/android/common/net.h int DisableNagle(int socket); socket 17 tools/android/common/net.h int DeferAccept(int socket); socket 99 tools/android/file_poller/file_poller.cc int sockfd = socket(AF_INET, SOCK_STREAM, 0); socket 169 tools/android/file_poller/file_poller.cc int sockfd = socket(AF_INET, SOCK_STREAM, 0); socket 267 tools/android/forwarder/forwarder.cc int socket = HANDLE_EINTR(accept(server->socket_, socket 270 tools/android/forwarder/forwarder.cc if (socket < 0) { socket 274 tools/android/forwarder/forwarder.cc tools::DisableNagle(socket); socket 279 tools/android/forwarder/forwarder.cc fcntl(socket, F_SETFL, fcntl(socket, F_GETFL) | O_NONBLOCK); socket 285 tools/android/forwarder/forwarder.cc forwarder_info->socket1 = socket; socket 297 tools/android/forwarder/forwarder.cc CloseSocket(socket); socket 319 tools/android/forwarder/forwarder.cc socket_ = socket(AF_INET, SOCK_STREAM, 0); socket 43 tools/android/forwarder2/command.cc bool ReadCommand(Socket* socket, socket 50 tools/android/forwarder2/command.cc int bytes_read = socket->ReadNumBytes(command_buffer, kCommandStringSize); socket 80 tools/android/forwarder2/command.cc bool SendCommand(command::Type command, int port, Socket* socket) { socket 85 tools/android/forwarder2/command.cc return socket->WriteNumBytes(buffer, len) == len; socket 88 tools/android/forwarder2/command.cc bool ReceivedCommand(command::Type command, Socket* socket) { socket 91 tools/android/forwarder2/command.cc if (!ReadCommand(socket, &port, &received_command)) socket 36 tools/android/forwarder2/command.h bool ReadCommand(Socket* socket, socket 42 tools/android/forwarder2/command.h bool ReceivedCommand(command::Type command, Socket* socket); socket 44 tools/android/forwarder2/command.h bool SendCommand(command::Type command, int port, Socket* socket); socket 132 tools/android/forwarder2/daemon.cc scoped_ptr<Socket> socket(new Socket()); socket 133 tools/android/forwarder2/daemon.cc if (!socket->ConnectUnix(socket_name)) { socket 141 tools/android/forwarder2/daemon.cc if (socket->Read(buf, expected_welcome_message.length() + 1) < 0) { socket 149 tools/android/forwarder2/daemon.cc return socket.Pass(); socket 65 tools/android/forwarder2/device_controller.cc scoped_ptr<Socket> socket(new Socket); socket 66 tools/android/forwarder2/device_controller.cc if (!host_socket_->Accept(socket.get())) { socket 77 tools/android/forwarder2/device_controller.cc socket->AddEventFd(exit_notifier_fd_); socket 80 tools/android/forwarder2/device_controller.cc if (!ReadCommand(socket.get(), &port, &command)) { socket 96 tools/android/forwarder2/device_controller.cc socket.Pass(), port, socket 121 tools/android/forwarder2/device_controller.cc listener->SetAdbDataSocket(socket.Pass()); socket 127 tools/android/forwarder2/device_controller.cc SendCommand(command::UNLISTEN_ERROR, port, socket.get()); socket 131 tools/android/forwarder2/device_controller.cc SendCommand(command::UNLISTEN_SUCCESS, port, socket.get()); socket 155 tools/android/forwarder2/host_controller.cc Socket socket; socket 156 tools/android/forwarder2/host_controller.cc if (!socket.ConnectTcp("", adb_port_)) { socket 160 tools/android/forwarder2/host_controller.cc if (!SendCommand(command::UNLISTEN, device_port_, &socket)) { socket 164 tools/android/forwarder2/host_controller.cc if (!ReceivedCommand(command::UNLISTEN_SUCCESS, &socket)) { socket 98 tools/android/forwarder2/socket.cc socket_ = socket(family_, SOCK_STREAM, 0); socket 436 tools/android/forwarder2/socket.cc Socket socket; socket 437 tools/android/forwarder2/socket.cc if (!socket.ConnectUnix(path)) socket 441 tools/android/forwarder2/socket.cc if (getsockopt(socket.socket_, SOL_SOCKET, SO_PEERCRED, &ucred, &len) == -1) { socket 693 tools/ipc_fuzzer/mutate/generate.cc GenerateParam(&p->socket, generator); socket 106 tools/measure_page_load_time/ie_bho/MeasurePageLoadTimeBHO.cpp m_sockListen = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);