socket_ 90 base/async_socket_io_handler.h base::SyncSocket::Handle socket_; socket_ 14 base/async_socket_io_handler_posix.cc : socket_(base::SyncSocket::kInvalidHandle), socket_ 26 base/async_socket_io_handler_posix.cc DCHECK_EQ(socket, socket_); socket_ 30 base/async_socket_io_handler_posix.cc int bytes_read = HANDLE_EINTR(read(socket_, pending_buffer_, socket_ 52 base/async_socket_io_handler_posix.cc int bytes_read = HANDLE_EINTR(read(socket_, buffer, buffer_len)); socket_ 69 base/async_socket_io_handler_posix.cc DCHECK_EQ(socket_, base::SyncSocket::kInvalidHandle); socket_ 73 base/async_socket_io_handler_posix.cc socket_ = socket; socket_ 91 base/async_socket_io_handler_posix.cc if (!is_watching_ && socket_ != base::SyncSocket::kInvalidHandle) { socket_ 93 base/async_socket_io_handler_posix.cc socket_, true, base::MessageLoopForIO::WATCH_READ, socket_ 25 base/async_socket_io_handler_unittest.cc : socket_(socket), buffer_(), socket_ 30 base/async_socket_io_handler_unittest.cc io_handler.Initialize(socket_->handle(), socket_ 60 base/async_socket_io_handler_unittest.cc base::CancelableSyncSocket* socket_; // Ownership lies outside the class. socket_ 10 base/async_socket_io_handler_win.cc : socket_(base::SyncSocket::kInvalidHandle), socket_ 45 base/async_socket_io_handler_win.cc DCHECK_NE(socket_, base::SyncSocket::kInvalidHandle); socket_ 48 base/async_socket_io_handler_win.cc BOOL ok = ::ReadFile(socket_, buffer, buffer_len, &bytes_read, socket_ 61 base/async_socket_io_handler_win.cc DCHECK_EQ(socket_, base::SyncSocket::kInvalidHandle); socket_ 65 base/async_socket_io_handler_win.cc socket_ = socket; socket_ 18 base/sync_socket_unittest.cc : socket_(socket), socket_ 27 base/sync_socket_unittest.cc ASSERT_EQ(socket_->Peek(), 0u); socket_ 30 base/sync_socket_unittest.cc ASSERT_EQ(0u, socket_->ReceiveWithTimeout( socket_ 40 base/sync_socket_unittest.cc base::SyncSocket* socket_; socket_ 78 chrome/browser/devtools/adb_client_socket.cc callback_.Run(net::OK, socket_.release()); socket_ 100 chrome/browser/devtools/adb_client_socket.cc : socket_(socket), socket_ 109 chrome/browser/devtools/adb_client_socket.cc : socket_(socket), socket_ 123 chrome/browser/devtools/adb_client_socket.cc int result = socket_->Write( socket_ 137 chrome/browser/devtools/adb_client_socket.cc result = socket_->Read(response_buffer.get(), socket_ 186 chrome/browser/devtools/adb_client_socket.cc socket_callback_.Run(net::OK, socket_.release()); socket_ 191 chrome/browser/devtools/adb_client_socket.cc result = socket_->Read(response_buffer.get(), socket_ 212 chrome/browser/devtools/adb_client_socket.cc scoped_ptr<net::StreamSocket> socket_; socket_ 321 chrome/browser/devtools/adb_client_socket.cc socket_.reset(new net::TCPClientSocket(address_list, NULL, socket_ 323 chrome/browser/devtools/adb_client_socket.cc int result = socket_->Connect(callback); socket_ 333 chrome/browser/devtools/adb_client_socket.cc int result = socket_->Write(request_buffer.get(), socket_ 352 chrome/browser/devtools/adb_client_socket.cc result = socket_->Read(response_buffer.get(), socket_ 424 chrome/browser/devtools/adb_client_socket.cc result = socket_->Read(response_buffer.get(), socket_ 46 chrome/browser/devtools/adb_client_socket.h scoped_ptr<net::StreamSocket> socket_; socket_ 79 chrome/browser/devtools/adb_web_socket.cc socket_.reset(socket); socket_ 88 chrome/browser/devtools/adb_web_socket.cc int result = socket_->Read( socket_ 98 chrome/browser/devtools/adb_web_socket.cc if (!socket_) socket_ 128 chrome/browser/devtools/adb_web_socket.cc result = socket_->Read( socket_ 137 chrome/browser/devtools/adb_web_socket.cc if (!socket_) socket_ 149 chrome/browser/devtools/adb_web_socket.cc result = socket_->Write(buffer.get(), buffer->size(), socket_ 157 chrome/browser/devtools/adb_web_socket.cc if (!socket_) socket_ 160 chrome/browser/devtools/adb_web_socket.cc scoped_ptr<net::StreamSocket> socket(socket_.release()); socket_ 53 chrome/browser/devtools/adb_web_socket.h scoped_ptr<net::StreamSocket> socket_; socket_ 940 chrome/browser/devtools/devtools_adb_bridge.cc socket_(socket), socket_ 945 chrome/browser/devtools/devtools_adb_bridge.cc return socket_.find(kChromeDefaultSocket) == 0; socket_ 991 chrome/browser/devtools/devtools_adb_bridge.cc base::Bind(&AndroidDevice::HttpQuery, device_, socket_, request, socket_ 1004 chrome/browser/devtools/devtools_adb_bridge.cc adb_thread_, device_, socket_, debug_url, command.Serialize()); socket_ 1027 chrome/browser/devtools/devtools_adb_bridge.cc device_, socket_, request, base::Bind(&NoOp))); socket_ 1031 chrome/browser/devtools/devtools_adb_bridge.cc device_, socket_, kNewPageRequest, socket_ 95 chrome/browser/devtools/devtools_adb_bridge.h std::string socket() { return socket_; } socket_ 130 chrome/browser/devtools/devtools_adb_bridge.h const std::string socket_; socket_ 352 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc socket_ = GetEventRouter(browser_context())->GetSocket(options.socket.id); socket_ 353 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc if (socket_.get() == NULL) { socket_ 365 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc if (!socket_.get()) socket_ 369 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc success_ = socket_->Receive(buffer.get()); socket_ 374 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc SetError(socket_->GetLastErrorMessage()); socket_ 400 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc socket_ = GetEventRouter(browser_context())->GetSocket(socket_id); socket_ 401 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc if (socket_.get() == NULL) { socket_ 411 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc return socket_.get() != NULL; socket_ 417 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc if (socket_.get() == NULL) socket_ 425 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc success_ = socket_->Send(drainable_io_buffer.get()); socket_ 433 chrome/browser/extensions/api/bluetooth/bluetooth_api.cc SetError(socket_->GetLastErrorMessage()); socket_ 180 chrome/browser/extensions/api/bluetooth/bluetooth_api.h scoped_refptr<device::BluetoothSocket> socket_; socket_ 199 chrome/browser/extensions/api/bluetooth/bluetooth_api.h scoped_refptr<device::BluetoothSocket> socket_; socket_ 148 chrome/browser/extensions/api/cast_channel/cast_socket.cc if (!socket_->GetSSLInfo(&ssl_info) || !ssl_info.cert.get()) socket_ 260 chrome/browser/extensions/api/cast_channel/cast_socket.cc socket_ = CreateSslSocket(tcp_socket_.PassAs<net::StreamSocket>()); socket_ 261 chrome/browser/extensions/api/cast_channel/cast_socket.cc return socket_->Connect( socket_ 332 chrome/browser/extensions/api/cast_channel/cast_socket.cc socket_.reset(); socket_ 429 chrome/browser/extensions/api/cast_channel/cast_socket.cc return socket_->Write( socket_ 565 chrome/browser/extensions/api/cast_channel/cast_socket.cc return socket_->Read( socket_ 689 chrome/browser/extensions/api/cast_channel/cast_socket.cc socket_.reset(NULL); socket_ 295 chrome/browser/extensions/api/cast_channel/cast_socket.h scoped_ptr<net::SSLClientSocket> socket_; socket_ 319 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Close(base::Bind(&CompleteHandler::OnCloseComplete, socket_ 324 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_ = TestCastSocket::Create(&mock_delegate_); socket_ 328 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_ = TestCastSocket::CreateSecure(&mock_delegate_); socket_ 335 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK); socket_ 336 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::OK); socket_ 337 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResult(net::ASYNC, net::ERR_IO_PENDING); socket_ 340 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 354 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc scoped_ptr<TestCastSocket> socket_; socket_ 366 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_TRUE(socket_->ParseChannelUrl(GURL("cast://192.0.0.1:8009"))); socket_ 367 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->auth_required()); socket_ 368 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(socket_->ip_endpoint_.ToString(), "192.0.0.1:8009"); socket_ 370 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_TRUE(socket_->ParseChannelUrl(GURL("casts://192.0.0.1:12345"))); socket_ 371 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_TRUE(socket_->auth_required()); socket_ 372 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(socket_->ip_endpoint_.ToString(), "192.0.0.1:12345"); socket_ 374 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->ParseChannelUrl(GURL("http://192.0.0.1:12345"))); socket_ 375 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->ParseChannelUrl(GURL("cast:192.0.0.1:12345"))); socket_ 376 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->ParseChannelUrl(GURL("cast:///192.0.0.1:12345"))); socket_ 377 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->ParseChannelUrl(GURL("cast://:12345"))); socket_ 378 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->ParseChannelUrl(GURL("cast://abcd:8009"))); socket_ 379 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->ParseChannelUrl(GURL("cast://192.0.0.1:abcd"))); socket_ 380 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->ParseChannelUrl(GURL(""))); socket_ 381 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->ParseChannelUrl(GURL("foo"))); socket_ 382 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->ParseChannelUrl(GURL("cast:"))); socket_ 383 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->ParseChannelUrl(GURL("cast::"))); socket_ 384 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->ParseChannelUrl(GURL("cast://192.0.0.1"))); socket_ 385 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->ParseChannelUrl(GURL("cast://:"))); socket_ 386 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_FALSE(socket_->ParseChannelUrl(GURL("cast://192.0.0.1:"))); socket_ 393 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 394 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 397 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Close(base::Bind(&CompleteHandler::OnCloseComplete, socket_ 399 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 400 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 408 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::ASYNC, net::OK); socket_ 409 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl1Connect(net::ASYNC, net::OK); socket_ 410 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResult(net::ASYNC, net::ERR_IO_PENDING); socket_ 413 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 417 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 418 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 429 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::ASYNC, net::OK); socket_ 430 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl1Connect(net::ASYNC, net::ERR_CERT_AUTHORITY_INVALID); socket_ 431 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp2Connect(net::ASYNC, net::OK); socket_ 432 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl2Connect(net::ASYNC, net::OK); socket_ 433 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResult(net::ASYNC, net::ERR_IO_PENDING); socket_ 436 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 440 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 441 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 453 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::ASYNC, net::OK); socket_ 454 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl1Connect(net::ASYNC, net::ERR_CERT_AUTHORITY_INVALID); socket_ 455 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp2Connect(net::ASYNC, net::OK); socket_ 456 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl2Connect(net::ASYNC, net::ERR_CERT_AUTHORITY_INVALID); socket_ 459 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 463 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 464 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_ERROR, socket_->error_state()); socket_ 479 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::ASYNC, net::OK); socket_ 480 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl1Connect(net::ASYNC, net::ERR_CERT_AUTHORITY_INVALID); socket_ 481 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp2Connect(net::ASYNC, net::OK); socket_ 482 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl2Connect(net::ASYNC, net::OK); socket_ 483 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResultForMessage(net::ASYNC, auth_request_); socket_ 484 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResultForMessage(net::ASYNC, auth_reply_); socket_ 485 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResult(net::ASYNC, net::ERR_IO_PENDING); socket_ 488 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 492 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 493 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 500 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK); socket_ 501 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::ERR_CERT_AUTHORITY_INVALID); socket_ 502 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp2Connect(net::SYNCHRONOUS, net::OK); socket_ 503 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl2Connect(net::SYNCHRONOUS, net::OK); socket_ 504 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResultForMessage(net::SYNCHRONOUS, auth_request_); socket_ 505 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResultForMessage(net::SYNCHRONOUS, auth_reply_); socket_ 506 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResult(net::ASYNC, net::ERR_IO_PENDING); socket_ 509 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 513 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 514 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 521 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::ASYNC, net::ERR_FAILED); socket_ 524 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 528 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 529 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_ERROR, socket_->error_state()); socket_ 536 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::ERR_FAILED); socket_ 539 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 543 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 544 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_ERROR, socket_->error_state()); socket_ 551 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK); socket_ 552 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::ERR_FAILED); socket_ 555 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 559 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 560 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_ERROR, socket_->error_state()); socket_ 567 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK); socket_ 568 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl1Connect(net::ASYNC, net::ERR_FAILED); socket_ 571 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 575 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 576 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_ERROR, socket_->error_state()); socket_ 582 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::ASYNC, net::OK); socket_ 583 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl1Connect(net::ASYNC, net::ERR_CERT_AUTHORITY_INVALID); socket_ 585 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetExtractCertResult(false); socket_ 588 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 592 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 593 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_ERROR, socket_->error_state()); socket_ 599 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK); socket_ 600 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::ERR_CERT_AUTHORITY_INVALID); socket_ 602 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetExtractCertResult(false); socket_ 605 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 609 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 610 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_ERROR, socket_->error_state()); socket_ 617 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK); socket_ 618 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::OK); socket_ 619 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResult(net::SYNCHRONOUS, net::ERR_FAILED); socket_ 622 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 626 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 627 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_ERROR, socket_->error_state()); socket_ 634 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK); socket_ 635 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::OK); socket_ 636 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResultForMessage(net::ASYNC, auth_request_); socket_ 637 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResult(net::SYNCHRONOUS, net::ERR_FAILED); socket_ 640 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 644 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 645 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_ERROR, socket_->error_state()); socket_ 652 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK); socket_ 653 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::OK); socket_ 654 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResultForMessage(net::ASYNC, auth_request_); socket_ 655 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResultForMessage(net::ASYNC, auth_reply_); socket_ 656 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResult(net::ASYNC, net::ERR_IO_PENDING); socket_ 657 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SetVerifyChallengeResult(false); socket_ 660 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, socket_ 664 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 665 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_ERROR, socket_->error_state()); socket_ 671 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResultForMessage(net::ASYNC, test_proto_strs_[0]); socket_ 675 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SendMessage(test_messages_[0], socket_ 680 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 681 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 687 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResultForMessage(net::SYNCHRONOUS, test_proto_strs_[0]); socket_ 691 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SendMessage(test_messages_[0], socket_ 696 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 697 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 703 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResultForMessage(net::ASYNC, test_proto_strs_[0], 2); socket_ 707 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SendMessage(test_messages_[0], socket_ 712 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 713 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 719 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResultForMessage(net::SYNCHRONOUS, test_proto_strs_[0], 2); socket_ 723 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SendMessage(test_messages_[0], socket_ 728 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 729 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 737 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResult(net::ASYNC, msg_size); socket_ 743 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SendMessage(test_messages_[i], socket_ 749 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 750 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 758 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResult(net::SYNCHRONOUS, msg_size); socket_ 764 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SendMessage(test_messages_[i], socket_ 770 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 771 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 779 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SendMessage(test_messages_[0], socket_ 783 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_NONE, socket_->ready_state()); socket_ 784 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 796 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SendMessage(test_messages_[0], socket_ 800 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 801 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 808 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResult(net::SYNCHRONOUS, net::ERR_FAILED); socket_ 813 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnError(socket_.get(), cast_channel::CHANNEL_ERROR_SOCKET_ERROR)); socket_ 814 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SendMessage(test_messages_[0], socket_ 819 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 820 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_SOCKET_ERROR, socket_->error_state()); socket_ 826 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResult(net::ASYNC, net::ERR_FAILED); socket_ 831 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnError(socket_.get(), cast_channel::CHANNEL_ERROR_SOCKET_ERROR)); socket_ 832 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SendMessage(test_messages_[0], socket_ 837 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 838 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_SOCKET_ERROR, socket_->error_state()); socket_ 844 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResult(net::SYNCHRONOUS, 0); socket_ 849 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnError(socket_.get(), cast_channel::CHANNEL_ERROR_SOCKET_ERROR)); socket_ 850 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SendMessage(test_messages_[0], socket_ 855 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 856 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_SOCKET_ERROR, socket_->error_state()); socket_ 863 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddWriteResult(net::ASYNC, net::ERR_SOCKET_NOT_CONNECTED); socket_ 870 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnError(socket_.get(), cast_channel::CHANNEL_ERROR_SOCKET_ERROR)); socket_ 872 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->SendMessage(test_messages_[i], socket_ 878 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 879 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_SOCKET_ERROR, socket_->error_state()); socket_ 885 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResultForMessage(net::ASYNC, test_proto_strs_[0]); socket_ 887 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnMessage(socket_.get(), A<const MessageInfo&>())); socket_ 890 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 891 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 897 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResultForMessage(net::SYNCHRONOUS, test_proto_strs_[0]); socket_ 899 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnMessage(socket_.get(), A<const MessageInfo&>())); socket_ 902 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 903 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 909 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResultForMessage(net::ASYNC, test_proto_strs_[0], 2); socket_ 911 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnMessage(socket_.get(), A<const MessageInfo&>())); socket_ 914 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 915 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 921 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResultForMessage(net::SYNCHRONOUS, test_proto_strs_[0], 2); socket_ 923 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnMessage(socket_.get(), A<const MessageInfo&>())); socket_ 926 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 927 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 935 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResultForMessage(net::ASYNC, test_proto_strs_[i]); socket_ 937 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnMessage(socket_.get(), A<const MessageInfo&>())) socket_ 941 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 942 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 950 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResultForMessage(net::SYNCHRONOUS, test_proto_strs_[i]); socket_ 952 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnMessage(socket_.get(), A<const MessageInfo&>())) socket_ 956 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state()); socket_ 957 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state()); socket_ 963 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResult(net::ASYNC, net::ERR_SOCKET_NOT_CONNECTED); socket_ 965 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnError(socket_.get(), socket_ 969 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 970 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_SOCKET_ERROR, socket_->error_state()); socket_ 976 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResult(net::SYNCHRONOUS, net::ERR_SOCKET_NOT_CONNECTED); socket_ 978 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnError(socket_.get(), socket_ 982 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 983 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::CHANNEL_ERROR_SOCKET_ERROR, socket_->error_state()); socket_ 993 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResult(net::SYNCHRONOUS, header, arraysize(header)); socket_ 995 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnError(socket_.get(), socket_ 999 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 1001 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->error_state()); socket_ 1011 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResult(net::SYNCHRONOUS, header, arraysize(header)); socket_ 1012 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->AddReadResult(net::SYNCHRONOUS, body, arraysize(body)); socket_ 1014 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc OnError(socket_.get(), socket_ 1018 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state()); socket_ 1020 chrome/browser/extensions/api/cast_channel/cast_socket_unittest.cc socket_->error_state()); socket_ 169 chrome/browser/extensions/api/dial/dial_service.cc DCHECK(!socket_.get()); socket_ 173 chrome/browser/extensions/api/dial/dial_service.cc socket_.reset(new UDPSocket(net::DatagramSocket::RANDOM_BIND, socket_ 177 chrome/browser/extensions/api/dial/dial_service.cc socket_->AllowBroadcast(); socket_ 182 chrome/browser/extensions/api/dial/dial_service.cc if (!CheckResult("Bind", socket_->Bind(address))) socket_ 185 chrome/browser/extensions/api/dial/dial_service.cc DCHECK(socket_.get()); socket_ 194 chrome/browser/extensions/api/dial/dial_service.cc if (!socket_.get()) { socket_ 205 chrome/browser/extensions/api/dial/dial_service.cc int result = socket_->SendTo( socket_ 219 chrome/browser/extensions/api/dial/dial_service.cc return !socket_.get(); socket_ 240 chrome/browser/extensions/api/dial/dial_service.cc socket_.reset(); socket_ 258 chrome/browser/extensions/api/dial/dial_service.cc if (!socket_.get()) { socket_ 272 chrome/browser/extensions/api/dial/dial_service.cc result = socket_->RecvFrom( socket_ 172 chrome/browser/extensions/api/dial/dial_service.h scoped_ptr<net::UDPSocket> socket_; socket_ 93 chrome/browser/local_discovery/privet_traffic_detector.cc socket_.reset(); socket_ 123 chrome/browser/local_discovery/privet_traffic_detector.cc socket_.reset(new net::UDPServerSocket(NULL, net::NetLog::Source())); socket_ 127 chrome/browser/local_discovery/privet_traffic_detector.cc socket_->AllowAddressReuse(); socket_ 128 chrome/browser/local_discovery/privet_traffic_detector.cc int rv = socket_->Listen(bind_endpoint); socket_ 131 chrome/browser/local_discovery/privet_traffic_detector.cc socket_->SetMulticastLoopbackMode(false); socket_ 132 chrome/browser/local_discovery/privet_traffic_detector.cc return socket_->JoinGroup(multicast_addr.address()); socket_ 170 chrome/browser/local_discovery/privet_traffic_detector.cc socket_.reset(); socket_ 178 chrome/browser/local_discovery/privet_traffic_detector.cc rv = socket_->RecvFrom( socket_ 59 chrome/browser/local_discovery/privet_traffic_detector.h scoped_ptr<net::DatagramServerSocket> socket_; socket_ 211 chrome/browser/net/network_stats.cc DCHECK(!socket_); socket_ 212 chrome/browser/net/network_stats.cc socket_ = udp_socket.Pass(); socket_ 215 chrome/browser/net/network_stats.cc int rv = socket_->Connect(endpoint); socket_ 221 chrome/browser/net/network_stats.cc socket_->SetSendBufferSize(kMaxUdpSendBufferSize); socket_ 222 chrome/browser/net/network_stats.cc socket_->SetReceiveBufferSize(kMaxUdpReceiveBufferSize); socket_ 316 chrome/browser/net/network_stats.cc if (!socket_.get()) socket_ 327 chrome/browser/net/network_stats.cc rv = socket_->Read( socket_ 360 chrome/browser/net/network_stats.cc DCHECK(socket_.get()); socket_ 456 chrome/browser/net/network_stats.cc if (write_buffer_.get() || !socket_.get() || socket_ 463 chrome/browser/net/network_stats.cc int bytes_written = socket_->Write( socket_ 480 chrome/browser/net/network_stats.cc if (result < 0 || !socket_.get() || write_buffer_ == NULL) { socket_ 572 chrome/browser/net/network_stats.cc if (socket_.get()) socket_ 573 chrome/browser/net/network_stats.cc socket_->Close(); socket_ 256 chrome/browser/net/network_stats.h scoped_ptr<net::DatagramClientSocket> socket_; socket_ 39 chrome/common/extensions/docs/examples/extensions/irc/servlet/src/org/chromium/IRCProxyWebSocket.java Socket socket_ = null; socket_ 53 chrome/common/extensions/docs/examples/extensions/irc/servlet/src/org/chromium/IRCProxyWebSocket.java if (socket_ == null) { socket_ 58 chrome/common/extensions/docs/examples/extensions/irc/servlet/src/org/chromium/IRCProxyWebSocket.java socket_ = SocketFactory.getDefault().createSocket(tokens[0], socket_ 60 chrome/common/extensions/docs/examples/extensions/irc/servlet/src/org/chromium/IRCProxyWebSocket.java out_ = new OutputStreamWriter(socket_.getOutputStream()); socket_ 62 chrome/common/extensions/docs/examples/extensions/irc/servlet/src/org/chromium/IRCProxyWebSocket.java socket_.getInputStream()); socket_ 89 chrome/common/extensions/docs/examples/extensions/irc/servlet/src/org/chromium/IRCProxyWebSocket.java socket_.close(); socket_ 75 chrome/test/chromedriver/chrome/devtools_client_impl.cc : socket_(factory.Run().Pass()), socket_ 91 chrome/test/chromedriver/chrome/devtools_client_impl.cc : socket_(factory.Run().Pass()), socket_ 120 chrome/test/chromedriver/chrome/devtools_client_impl.cc if (socket_->IsConnected()) socket_ 123 chrome/test/chromedriver/chrome/devtools_client_impl.cc if (!socket_->Connect(url_)) { socket_ 128 chrome/test/chromedriver/chrome/devtools_client_impl.cc if (!socket_->Connect(url_)) socket_ 174 chrome/test/chromedriver/chrome/devtools_client_impl.cc if (!socket_->IsConnected()) socket_ 180 chrome/test/chromedriver/chrome/devtools_client_impl.cc if (!socket_->HasNextMessage()) { socket_ 205 chrome/test/chromedriver/chrome/devtools_client_impl.cc if (!socket_->IsConnected()) socket_ 218 chrome/test/chromedriver/chrome/devtools_client_impl.cc if (!socket_->Send(message)) socket_ 269 chrome/test/chromedriver/chrome/devtools_client_impl.cc switch (socket_->ReceiveNextMessage(&message, timeout)) { socket_ 127 chrome/test/chromedriver/chrome/devtools_client_impl.h scoped_ptr<SyncWebSocket> socket_; socket_ 79 chrome/test/chromedriver/net/adb_client_socket.cc callback_.Run(net::OK, socket_.release()); socket_ 138 chrome/test/chromedriver/net/adb_client_socket.cc socket_.reset(socket); socket_ 143 chrome/test/chromedriver/net/adb_client_socket.cc result = socket_->Write( socket_ 158 chrome/test/chromedriver/net/adb_client_socket.cc result = socket_->Read(response_buffer.get(), socket_ 206 chrome/test/chromedriver/net/adb_client_socket.cc socket_callback_.Run(net::OK, socket_.release()); socket_ 211 chrome/test/chromedriver/net/adb_client_socket.cc result = socket_->Read(response_buffer.get(), socket_ 232 chrome/test/chromedriver/net/adb_client_socket.cc scoped_ptr<net::StreamSocket> socket_; socket_ 374 chrome/test/chromedriver/net/adb_client_socket.cc socket_.reset(new net::TCPClientSocket(address_list, NULL, socket_ 376 chrome/test/chromedriver/net/adb_client_socket.cc int result = socket_->Connect(callback); socket_ 386 chrome/test/chromedriver/net/adb_client_socket.cc int result = socket_->Write(request_buffer.get(), socket_ 405 chrome/test/chromedriver/net/adb_client_socket.cc result = socket_->Read(response_buffer.get(), socket_ 477 chrome/test/chromedriver/net/adb_client_socket.cc result = socket_->Read(response_buffer.get(), socket_ 49 chrome/test/chromedriver/net/adb_client_socket.h scoped_ptr<net::StreamSocket> socket_; socket_ 121 chrome/test/chromedriver/net/sync_websocket_impl.cc socket_.reset(new WebSocket(url, this)); socket_ 122 chrome/test/chromedriver/net/sync_websocket_impl.cc socket_->Connect(base::Bind( socket_ 143 chrome/test/chromedriver/net/sync_websocket_impl.cc *success = socket_->Send(message); socket_ 88 chrome/test/chromedriver/net/sync_websocket_impl.h scoped_ptr<WebSocket> socket_; socket_ 85 chrome/test/chromedriver/net/websocket.cc socket_.reset(new net::TCPClientSocket(addresses, NULL, source)); socket_ 89 chrome/test/chromedriver/net/websocket.cc int code = socket_->Connect(base::Bind( socket_ 149 chrome/test/chromedriver/net/websocket.cc if (!socket_->IsConnected()) { socket_ 173 chrome/test/chromedriver/net/websocket.cc socket_->Write(write_buffer_.get(), socket_ 182 chrome/test/chromedriver/net/websocket.cc socket_->Read(read_buffer_.get(), socket_ 257 chrome/test/chromedriver/net/websocket.cc socket_->Disconnect(); socket_ 68 chrome/test/chromedriver/net/websocket.h scoped_ptr<net::TCPClientSocket> socket_; socket_ 27 chrome/utility/local_discovery/service_discovery_message_handler.cc explicit ScopedSocketFactory(net::SocketDescriptor socket) : socket_(socket) { socket_ 33 chrome/utility/local_discovery/service_discovery_message_handler.cc ClosePlatformSocket(socket_); socket_ 34 chrome/utility/local_discovery/service_discovery_message_handler.cc socket_ = net::kInvalidSocket; socket_ 42 chrome/utility/local_discovery/service_discovery_message_handler.cc std::swap(result, socket_); socket_ 47 chrome/utility/local_discovery/service_discovery_message_handler.cc net::SocketDescriptor socket_; socket_ 85 cloud_print/gcp20/prototype/dns_sd_server.cc socket_->Close(); socket_ 86 cloud_print/gcp20/prototype/dns_sd_server.cc socket_.reset(NULL); socket_ 108 cloud_print/gcp20/prototype/dns_sd_server.cc socket_->SendTo(buffer.get(), buffer.get()->size(), multicast_address_, socket_ 124 cloud_print/gcp20/prototype/dns_sd_server.cc socket_.reset(new net::UDPSocket(net::DatagramSocket::DEFAULT_BIND, socket_ 133 cloud_print/gcp20/prototype/dns_sd_server.cc socket_->AllowAddressReuse(); socket_ 135 cloud_print/gcp20/prototype/dns_sd_server.cc int status = socket_->Bind(local_address); socket_ 139 cloud_print/gcp20/prototype/dns_sd_server.cc socket_->SetMulticastLoopbackMode(false); socket_ 140 cloud_print/gcp20/prototype/dns_sd_server.cc status = socket_->JoinGroup(multicast_dns_ip_address); socket_ 145 cloud_print/gcp20/prototype/dns_sd_server.cc DCHECK(socket_->is_connected()); socket_ 187 cloud_print/gcp20/prototype/dns_sd_server.cc socket_->SendTo(buffer.get(), buffer.get()->size(), socket_ 268 cloud_print/gcp20/prototype/dns_sd_server.cc rv = socket_->RecvFrom(recv_buf_.get(), recv_buf_->size(), &recv_address_, socket_ 301 cloud_print/gcp20/prototype/dns_sd_server.cc socket_->SendTo(buffer.get(), buffer.get()->size(), multicast_address_, socket_ 51 cloud_print/gcp20/prototype/dns_sd_server.h bool IsOnline() { return !!socket_; } socket_ 82 cloud_print/gcp20/prototype/dns_sd_server.h scoped_ptr<net::UDPSocket> socket_; socket_ 180 content/browser/devtools/tethering_handler.cc socket_(new net::TCPServerSocket(NULL, net::NetLog::Source())), socket_ 194 content/browser/devtools/tethering_handler.cc int result = socket_->Listen(end_point, kListenBacklog); socket_ 199 content/browser/devtools/tethering_handler.cc result = socket_->GetLocalAddress(&local_address); socket_ 212 content/browser/devtools/tethering_handler.cc int result = socket_->Accept( socket_ 240 content/browser/devtools/tethering_handler.cc scoped_ptr<net::ServerSocket> socket_; socket_ 33 content/browser/renderer_host/media/audio_input_sync_writer.cc socket_->Send(&bytes, sizeof(bytes)); socket_ 74 content/browser/renderer_host/media/audio_input_sync_writer.cc socket_->Close(); socket_ 78 content/browser/renderer_host/media/audio_input_sync_writer.cc socket_.reset(new base::CancelableSyncSocket()); socket_ 80 content/browser/renderer_host/media/audio_input_sync_writer.cc return base::CancelableSyncSocket::CreatePair(socket_.get(), socket_ 56 content/browser/renderer_host/media/audio_input_sync_writer.h scoped_ptr<base::CancelableSyncSocket> socket_; socket_ 57 content/browser/renderer_host/media/audio_sync_reader.cc socket_->Send(&bytes, sizeof(bytes)); socket_ 76 content/browser/renderer_host/media/audio_sync_reader.cc socket_->Close(); socket_ 80 content/browser/renderer_host/media/audio_sync_reader.cc socket_.reset(new base::CancelableSyncSocket()); socket_ 82 content/browser/renderer_host/media/audio_sync_reader.cc return base::CancelableSyncSocket::CreatePair(socket_.get(), socket_ 126 content/browser/renderer_host/media/audio_sync_reader.cc bytes_received = socket_->ReceiveWithTimeout( socket_ 62 content/browser/renderer_host/media/audio_sync_reader.h scoped_ptr<base::CancelableSyncSocket> socket_; socket_ 59 content/browser/renderer_host/p2p/socket_host_tcp.cc DCHECK(socket_.get()); socket_ 60 content/browser/renderer_host/p2p/socket_host_tcp.cc socket_.reset(); socket_ 71 content/browser/renderer_host/p2p/socket_host_tcp.cc socket_.reset(socket); socket_ 92 content/browser/renderer_host/p2p/socket_host_tcp.cc socket_.reset(new jingle_glue::ProxyResolvingClientSocket( socket_ 98 content/browser/renderer_host/p2p/socket_host_tcp.cc int status = socket_->Connect( socket_ 118 content/browser/renderer_host/p2p/socket_host_tcp.cc socket_.reset(); socket_ 141 content/browser/renderer_host/p2p/socket_host_tcp.cc scoped_ptr<net::StreamSocket> transport_socket = socket_.Pass(); socket_ 142 content/browser/renderer_host/p2p/socket_host_tcp.cc socket_.reset( socket_ 145 content/browser/renderer_host/p2p/socket_host_tcp.cc int status = socket_->Connect( socket_ 162 content/browser/renderer_host/p2p/socket_host_tcp.cc DCHECK(socket_.get()); socket_ 166 content/browser/renderer_host/p2p/socket_host_tcp.cc socket_handle->SetSocket(socket_.Pass()); socket_ 185 content/browser/renderer_host/p2p/socket_host_tcp.cc socket_ = socket_factory->CreateSSLClientSocket( socket_ 187 content/browser/renderer_host/p2p/socket_host_tcp.cc int status = socket_->Connect( socket_ 208 content/browser/renderer_host/p2p/socket_host_tcp.cc if (!socket_->SetReceiveBufferSize(kRecvSocketBufferSize)) { socket_ 213 content/browser/renderer_host/p2p/socket_host_tcp.cc if (!socket_->SetSendBufferSize(kSendSocketBufferSize)) { socket_ 223 content/browser/renderer_host/p2p/socket_host_tcp.cc DCHECK(socket_.get()); socket_ 226 content/browser/renderer_host/p2p/socket_host_tcp.cc int result = socket_->GetLocalAddress(&address); socket_ 257 content/browser/renderer_host/p2p/socket_host_tcp.cc result = socket_->Read( socket_ 298 content/browser/renderer_host/p2p/socket_host_tcp.cc if (!socket_) { socket_ 338 content/browser/renderer_host/p2p/socket_host_tcp.cc int result = socket_->Write( socket_ 415 content/browser/renderer_host/p2p/socket_host_tcp.cc return socket_->SetReceiveBufferSize(value) == net::OK; socket_ 417 content/browser/renderer_host/p2p/socket_host_tcp.cc return socket_->SetSendBufferSize(value) == net::OK; socket_ 87 content/browser/renderer_host/p2p/socket_host_tcp.h scoped_ptr<net::StreamSocket> socket_; socket_ 27 content/browser/renderer_host/p2p/socket_host_tcp_server.cc socket_(new net::TCPServerSocket(NULL, net::NetLog::Source())), socket_ 38 content/browser/renderer_host/p2p/socket_host_tcp_server.cc DCHECK(socket_.get()); socket_ 39 content/browser/renderer_host/p2p/socket_host_tcp_server.cc socket_.reset(); socket_ 47 content/browser/renderer_host/p2p/socket_host_tcp_server.cc int result = socket_->Listen(local_address, kListenBacklog); socket_ 54 content/browser/renderer_host/p2p/socket_host_tcp_server.cc result = socket_->GetLocalAddress(&local_address_); socket_ 70 content/browser/renderer_host/p2p/socket_host_tcp_server.cc socket_.reset(); socket_ 80 content/browser/renderer_host/p2p/socket_host_tcp_server.cc int result = socket_->Accept(&accept_socket_, accept_callback_); socket_ 59 content/browser/renderer_host/p2p/socket_host_tcp_server.h scoped_ptr<net::ServerSocket> socket_; socket_ 93 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc socket_ = new FakeServerSocket(); socket_ 96 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc socket_host_->socket_.reset(socket_); socket_ 107 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc EXPECT_TRUE(socket_->listening()); socket_ 113 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc return host->socket_.get(); socket_ 117 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc FakeServerSocket* socket_; // Owned by |socket_host_|. socket_ 130 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc socket_->AddIncoming(incoming); socket_ 156 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc socket_->AddIncoming(incoming1); socket_ 157 content/browser/renderer_host/p2p/socket_host_tcp_server_unittest.cc socket_->AddIncoming(incoming2); socket_ 41 content/browser/renderer_host/p2p/socket_host_tcp_unittest.cc socket_ = new FakeSocket(&sent_data_); socket_ 42 content/browser/renderer_host/p2p/socket_host_tcp_unittest.cc socket_->SetLocalAddress(ParseAddress(kTestLocalIpAddress, kTestPort1)); socket_ 43 content/browser/renderer_host/p2p/socket_host_tcp_unittest.cc socket_host_->socket_.reset(socket_); socket_ 63 content/browser/renderer_host/p2p/socket_host_tcp_unittest.cc FakeSocket* socket_; // Owned by |socket_host_|. socket_ 157 content/browser/renderer_host/p2p/socket_host_tcp_unittest.cc socket_->AppendInputData(&received_data[pos], step_size); socket_ 195 content/browser/renderer_host/p2p/socket_host_tcp_unittest.cc socket_->AppendInputData(&received_data[0], received_data.size()); socket_ 214 content/browser/renderer_host/p2p/socket_host_tcp_unittest.cc socket_->set_async_write(true); socket_ 255 content/browser/renderer_host/p2p/socket_host_tcp_unittest.cc socket_->AppendInputData(&received_data[0], received_data.size()); socket_ 340 content/browser/renderer_host/p2p/socket_host_tcp_unittest.cc socket_->AppendInputData(&received_data[pos], step_size); socket_ 366 content/browser/renderer_host/p2p/socket_host_tcp_unittest.cc socket_->set_async_write(true); socket_ 71 content/browser/renderer_host/p2p/socket_host_udp.cc socket_(new net::UDPServerSocket( socket_ 81 content/browser/renderer_host/p2p/socket_host_udp.cc DCHECK(socket_.get()); socket_ 82 content/browser/renderer_host/p2p/socket_host_udp.cc socket_.reset(); socket_ 90 content/browser/renderer_host/p2p/socket_host_udp.cc int result = socket_->Listen(local_address); socket_ 98 content/browser/renderer_host/p2p/socket_host_udp.cc if (socket_->SetReceiveBufferSize(kRecvSocketBufferSize) != net::OK) { socket_ 104 content/browser/renderer_host/p2p/socket_host_udp.cc result = socket_->GetLocalAddress(&address); socket_ 124 content/browser/renderer_host/p2p/socket_host_udp.cc socket_.reset(); socket_ 136 content/browser/renderer_host/p2p/socket_host_udp.cc result = socket_->RecvFrom( socket_ 185 content/browser/renderer_host/p2p/socket_host_udp.cc if (!socket_) { socket_ 228 content/browser/renderer_host/p2p/socket_host_udp.cc int result = socket_->SetDiffServCodePoint(dscp); socket_ 240 content/browser/renderer_host/p2p/socket_host_udp.cc int result = socket_->SendTo( socket_ 250 content/browser/renderer_host/p2p/socket_host_udp.cc result = socket_->SendTo( socket_ 305 content/browser/renderer_host/p2p/socket_host_udp.cc return socket_->SetReceiveBufferSize(value) == net::OK; socket_ 307 content/browser/renderer_host/p2p/socket_host_udp.cc return socket_->SetSendBufferSize(value) == net::OK; socket_ 309 content/browser/renderer_host/p2p/socket_host_udp.cc return (net::OK == socket_->SetDiffServCodePoint( socket_ 72 content/browser/renderer_host/p2p/socket_host_udp.h scoped_ptr<net::DatagramServerSocket> socket_; socket_ 191 content/browser/renderer_host/p2p/socket_host_udp_unittest.cc socket_ = new FakeDatagramServerSocket(&sent_packets_); socket_ 192 content/browser/renderer_host/p2p/socket_host_udp_unittest.cc socket_host_->socket_.reset(socket_); socket_ 206 content/browser/renderer_host/p2p/socket_host_udp_unittest.cc FakeDatagramServerSocket* socket_; // Owned by |socket_host_|. socket_ 267 content/browser/renderer_host/p2p/socket_host_udp_unittest.cc socket_->ReceivePacket(dest1_, request_packet); socket_ 292 content/browser/renderer_host/p2p/socket_host_udp_unittest.cc socket_->ReceivePacket(dest1_, request_packet); socket_ 317 content/browser/renderer_host/p2p/socket_host_udp_unittest.cc socket_->ReceivePacket(dest1_, request_packet); socket_ 359 content/browser/renderer_host/p2p/socket_host_udp_unittest.cc socket_->ReceivePacket(dest1_, request_packet); socket_ 135 content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc int net_result = socket_->Accept( socket_ 151 content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc socket_.reset(); socket_ 172 content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc socket_.reset(new net::TCPSocket(NULL, net::NetLog::Source())); socket_ 176 content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc net_result = socket_->Open(ip_end_point.GetFamily()); socket_ 179 content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc net_result = socket_->SetDefaultOptionsForServer(); socket_ 182 content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc net_result = socket_->Bind(ip_end_point); socket_ 185 content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc net_result = socket_->Listen(backlog); socket_ 206 content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc DCHECK(socket_.get()); socket_ 212 content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc NetErrorToPepperError(socket_->GetLocalAddress(&end_point)); socket_ 99 content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.h scoped_ptr<net::TCPSocket> socket_; socket_ 76 content/browser/renderer_host/pepper/pepper_tcp_socket.cc if (socket_) socket_ 77 content/browser/renderer_host/pepper/pepper_tcp_socket.cc socket_->Disconnect(); socket_ 147 content/browser/renderer_host/pepper/pepper_tcp_socket.cc handle->SetSocket(socket_.Pass()); socket_ 154 content/browser/renderer_host/pepper/pepper_tcp_socket.cc socket_ = factory->CreateSSLClientSocket( socket_ 156 content/browser/renderer_host/pepper/pepper_tcp_socket.cc if (!socket_) { socket_ 162 content/browser/renderer_host/pepper/pepper_tcp_socket.cc int net_result = socket_->Connect( socket_ 189 content/browser/renderer_host/pepper/pepper_tcp_socket.cc int net_result = socket_->Read( socket_ 234 content/browser/renderer_host/pepper/pepper_tcp_socket.cc static_cast<net::TCPClientSocket*>(socket_.get()); socket_ 286 content/browser/renderer_host/pepper/pepper_tcp_socket.cc socket_.reset(new net::TCPClientSocket(addresses, NULL, socket_ 288 content/browser/renderer_host/pepper/pepper_tcp_socket.cc int net_result = socket_->Connect( socket_ 377 content/browser/renderer_host/pepper/pepper_tcp_socket.cc static_cast<net::SSLClientSocket*>(socket_.get()); socket_ 409 content/browser/renderer_host/pepper/pepper_tcp_socket.cc DCHECK(connection_state_ == CONNECT_IN_PROGRESS && socket_.get()); socket_ 419 content/browser/renderer_host/pepper/pepper_tcp_socket.cc socket_->GetLocalAddress(&ip_end_point_local)); socket_ 423 content/browser/renderer_host/pepper/pepper_tcp_socket.cc socket_->GetPeerAddress(&ip_end_point_remote)); socket_ 520 content/browser/renderer_host/pepper/pepper_tcp_socket.cc int net_result = socket_->Write( socket_ 67 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc socket_(new net::TCPSocket(NULL, net::NetLog::Source())), socket_ 95 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc socket_(socket.Pass()), socket_ 110 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc if (socket_) socket_ 111 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc socket_->Close(); socket_ 272 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc if (socket_->GetPeerAddress(&peer_address) != net::OK) socket_ 277 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc new net::TCPClientSocket(socket_.Pass(), peer_address))); socket_ 324 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc if (socket_) { socket_ 326 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc net_result = socket_->Read( socket_ 407 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc int net_result = socket_->Accept( socket_ 425 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc if (socket_) { socket_ 426 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc socket_->Close(); socket_ 447 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc return socket_->SetNoDelay(boolean_value) ? PP_OK : PP_ERROR_FAILED; socket_ 462 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc net_result = socket_->SetSendBufferSize(integer_value); socket_ 466 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc net_result = socket_->SetReceiveBufferSize(integer_value); socket_ 503 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc DCHECK(!socket_->IsValid()); socket_ 504 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc pp_result = NetErrorToPepperError(socket_->Open(bind_addr.GetFamily())); socket_ 508 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc pp_result = NetErrorToPepperError(socket_->SetDefaultOptionsForServer()); socket_ 512 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc pp_result = NetErrorToPepperError(socket_->Bind(bind_addr)); socket_ 518 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc socket_->GetLocalAddress(&ip_end_point_local)); socket_ 536 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc if (socket_->IsValid()) socket_ 537 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc socket_->Close(); socket_ 608 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc if (socket_) { socket_ 610 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc net_result = socket_->Write( socket_ 641 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc int32_t pp_result = NetErrorToPepperError(socket_->Listen(backlog)); socket_ 673 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc if (!socket_->IsValid()) socket_ 674 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc net_result = socket_->Open(address_list_[address_index_].GetFamily()); socket_ 677 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc net_result = socket_->Connect( socket_ 705 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc socket_->GetLocalAddress(&ip_end_point_local)); socket_ 709 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc socket_->GetPeerAddress(&ip_end_point_remote)); socket_ 729 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc socket_->SetDefaultOptionsForClient(); socket_ 744 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc socket_.reset(new net::TCPSocket(NULL, net::NetLog::Source())); socket_ 200 content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.h scoped_ptr<net::TCPSocket> socket_; socket_ 118 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc if (socket_.get()) { socket_ 135 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc if (!socket_.get()) { socket_ 149 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc net_result = socket_->SetSendBufferSize(integer_value); socket_ 155 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc net_result = socket_->SetReceiveBufferSize(integer_value); socket_ 195 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc DCHECK(socket_.get()); socket_ 197 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc if (closed_ || !socket_.get()) socket_ 217 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc int net_result = socket_->RecvFrom( socket_ 264 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc if (closed_ || socket_.get()) { socket_ 309 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc socket_.swap(socket); socket_ 318 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc DCHECK(socket_.get()); socket_ 320 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc if (closed_ || !socket_.get()) { socket_ 352 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc int net_result = socket_->SendTo( socket_ 365 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc if (socket_.get() && !closed_) socket_ 366 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.cc socket_->Close(); socket_ 112 content/browser/renderer_host/pepper/pepper_udp_socket_message_filter.h scoped_ptr<net::UDPServerSocket> socket_; socket_ 337 content/child/npapi/webplugin_delegate_impl.h GtkWidget* socket_; socket_ 43 content/child/npapi/webplugin_delegate_impl_gtk.cc socket_(NULL), socket_ 125 content/child/npapi/webplugin_delegate_impl_gtk.cc socket_ = gtk_socket_new(); socket_ 126 content/child/npapi/webplugin_delegate_impl_gtk.cc gtk_widget_show(socket_); socket_ 127 content/child/npapi/webplugin_delegate_impl_gtk.cc gtk_container_add(GTK_CONTAINER(plug_), socket_); socket_ 134 content/child/npapi/webplugin_delegate_impl_gtk.cc g_signal_connect(socket_, "plug_removed", G_CALLBACK(gtk_true), NULL); socket_ 136 content/child/npapi/webplugin_delegate_impl_gtk.cc windowed_handle_ = gtk_socket_get_id(GTK_SOCKET(socket_)); socket_ 160 content/child/npapi/webplugin_delegate_impl_gtk.cc socket_ = NULL; socket_ 190 extensions/browser/api/socket/socket_api.cc socket_ = GetSocket(socket_id_); socket_ 191 extensions/browser/api/socket/socket_api.cc if (!socket_) { socket_ 199 extensions/browser/api/socket/socket_api.cc switch (socket_->GetSocketType()) { socket_ 234 extensions/browser/api/socket/socket_api.cc socket_->Connect(resolved_address_, socket_ 502 extensions/browser/api/socket/socket_api.cc socket_ = GetSocket(socket_id_); socket_ 503 extensions/browser/api/socket/socket_api.cc if (!socket_) { socket_ 510 extensions/browser/api/socket/socket_api.cc if (socket_->GetSocketType() == Socket::TYPE_UDP) { socket_ 535 extensions/browser/api/socket/socket_api.cc socket_->SendTo(io_buffer_, socket_ 195 extensions/browser/api/socket/socket_api.h Socket* socket_; socket_ 350 extensions/browser/api/socket/socket_api.h Socket* socket_; socket_ 49 extensions/browser/api/socket/tcp_socket.cc socket_(tcp_client_socket), socket_ 101 extensions/browser/api/socket/tcp_socket.cc socket_.reset( socket_ 105 extensions/browser/api/socket/tcp_socket.cc result = socket_->Connect( socket_ 115 extensions/browser/api/socket/tcp_socket.cc if (socket_.get()) socket_ 116 extensions/browser/api/socket/tcp_socket.cc socket_->Disconnect(); socket_ 146 extensions/browser/api/socket/tcp_socket.cc if (!socket_.get() || !IsConnected()) { socket_ 153 extensions/browser/api/socket/tcp_socket.cc int result = socket_->Read( socket_ 177 extensions/browser/api/socket/tcp_socket.cc if (!socket_.get()) socket_ 179 extensions/browser/api/socket/tcp_socket.cc return socket_->SetKeepAlive(enable, delay); socket_ 183 extensions/browser/api/socket/tcp_socket.cc if (!socket_.get()) socket_ 185 extensions/browser/api/socket/tcp_socket.cc return socket_->SetNoDelay(no_delay); socket_ 196 extensions/browser/api/socket/tcp_socket.cc DCHECK(!socket_.get()); socket_ 243 extensions/browser/api/socket/tcp_socket.cc if (!socket_.get()) socket_ 245 extensions/browser/api/socket/tcp_socket.cc return !socket_->GetPeerAddress(address); socket_ 249 extensions/browser/api/socket/tcp_socket.cc if (socket_.get()) { socket_ 250 extensions/browser/api/socket/tcp_socket.cc return !socket_->GetLocalAddress(address); socket_ 265 extensions/browser/api/socket/tcp_socket.cc else if (!socket_.get() || !IsConnected()) socket_ 268 extensions/browser/api/socket/tcp_socket.cc return socket_->Write(io_buffer, io_buffer_size, callback); socket_ 276 extensions/browser/api/socket/tcp_socket.cc if (!socket_->IsConnected()) { socket_ 81 extensions/browser/api/socket/tcp_socket.h scoped_ptr<net::TCPClientSocket> socket_; socket_ 51 extensions/browser/api/socket/udp_socket.cc result = socket_.Connect(ip_end_point); socket_ 66 extensions/browser/api/socket/udp_socket.cc return socket_.Bind(ip_end_point); socket_ 71 extensions/browser/api/socket/udp_socket.cc socket_.Close(); socket_ 96 extensions/browser/api/socket/udp_socket.cc if (!socket_.is_connected()) { socket_ 102 extensions/browser/api/socket/udp_socket.cc result = socket_.Read( socket_ 116 extensions/browser/api/socket/udp_socket.cc if (!socket_.is_connected()) socket_ 119 extensions/browser/api/socket/udp_socket.cc return socket_.Write(io_buffer, io_buffer_size, callback); socket_ 142 extensions/browser/api/socket/udp_socket.cc if (!socket_.is_connected()) { socket_ 149 extensions/browser/api/socket/udp_socket.cc result = socket_.RecvFrom(io_buffer.get(), socket_ 186 extensions/browser/api/socket/udp_socket.cc if (!socket_.is_connected()) { socket_ 191 extensions/browser/api/socket/udp_socket.cc result = socket_.SendTo( socket_ 205 extensions/browser/api/socket/udp_socket.cc return !socket_.GetPeerAddress(address); socket_ 209 extensions/browser/api/socket/udp_socket.cc return !socket_.GetLocalAddress(address); socket_ 240 extensions/browser/api/socket/udp_socket.cc bool UDPSocket::IsBound() { return socket_.is_connected(); } socket_ 253 extensions/browser/api/socket/udp_socket.cc int rv = socket_.JoinGroup(ip); socket_ 270 extensions/browser/api/socket/udp_socket.cc int rv = socket_.LeaveGroup(ip); socket_ 277 extensions/browser/api/socket/udp_socket.cc return socket_.SetMulticastTimeToLive(ttl); socket_ 281 extensions/browser/api/socket/udp_socket.cc return socket_.SetMulticastLoopbackMode(loopback); socket_ 66 extensions/browser/api/socket/udp_socket.h net::UDPSocket socket_; socket_ 23 google_apis/gcm/base/socket_stream.cc : socket_(socket), socket_ 97 google_apis/gcm/base/socket_stream.cc if (!socket_->IsConnected()) { socket_ 104 google_apis/gcm/base/socket_stream.cc int result = socket_->Read( socket_ 209 google_apis/gcm/base/socket_stream.cc : socket_(socket), socket_ 252 google_apis/gcm/base/socket_stream.cc if (!socket_->IsConnected()) { socket_ 259 google_apis/gcm/base/socket_stream.cc int result = socket_->Write( socket_ 110 google_apis/gcm/base/socket_stream.h net::StreamSocket* const socket_; socket_ 183 google_apis/gcm/base/socket_stream.h net::StreamSocket* const socket_; socket_ 52 google_apis/gcm/base/socket_stream_unittest.cc net::StreamSocket* socket() { return socket_.get(); } socket_ 69 google_apis/gcm/base/socket_stream_unittest.cc scoped_ptr<net::StreamSocket> socket_; socket_ 176 google_apis/gcm/base/socket_stream_unittest.cc socket_ = socket_factory_.CreateTransportClientSocket( socket_ 178 google_apis/gcm/base/socket_stream_unittest.cc socket_->Connect( socket_ 187 google_apis/gcm/base/socket_stream_unittest.cc DCHECK(socket_.get()); socket_ 188 google_apis/gcm/base/socket_stream_unittest.cc socket_input_stream_.reset(new SocketInputStream(socket_.get())); socket_ 192 google_apis/gcm/base/socket_stream_unittest.cc DCHECK(socket_.get()); socket_ 193 google_apis/gcm/base/socket_stream_unittest.cc socket_output_stream_.reset(new SocketOutputStream(socket_.get())); socket_ 40 google_apis/gcm/engine/connection_handler_impl.cc socket_(NULL), socket_ 66 google_apis/gcm/engine/connection_handler_impl.cc socket_ = socket; socket_ 67 google_apis/gcm/engine/connection_handler_impl.cc input_stream_.reset(new SocketInputStream(socket_)); socket_ 68 google_apis/gcm/engine/connection_handler_impl.cc output_stream_.reset(new SocketOutputStream(socket_)); socket_ 402 google_apis/gcm/engine/connection_handler_impl.cc if (socket_) socket_ 403 google_apis/gcm/engine/connection_handler_impl.cc socket_->Disconnect(); socket_ 404 google_apis/gcm/engine/connection_handler_impl.cc socket_ = NULL; socket_ 100 google_apis/gcm/engine/connection_handler_impl.h net::StreamSocket* socket_; socket_ 149 google_apis/gcm/engine/connection_handler_impl_unittest.cc scoped_ptr<net::StreamSocket> socket_; socket_ 178 google_apis/gcm/engine/connection_handler_impl_unittest.cc socket_ = socket_factory_.CreateTransportClientSocket( socket_ 180 google_apis/gcm/engine/connection_handler_impl_unittest.cc socket_->Connect(net::CompletionCallback()); socket_ 185 google_apis/gcm/engine/connection_handler_impl_unittest.cc DCHECK(socket_->IsConnected()); socket_ 186 google_apis/gcm/engine/connection_handler_impl_unittest.cc return socket_.get(); socket_ 208 google_apis/gcm/engine/connection_handler_impl_unittest.cc socket_.get()); socket_ 128 ipc/sync_socket_unittest.cc socket_ = socket; socket_ 148 ipc/sync_socket_unittest.cc EXPECT_EQ(kHelloStringLength, socket_->Peek()); socket_ 150 ipc/sync_socket_unittest.cc socket_->Receive(static_cast<void*>(buf), kHelloStringLength); socket_ 153 ipc/sync_socket_unittest.cc EXPECT_EQ(0U, socket_->Peek()); socket_ 159 ipc/sync_socket_unittest.cc base::SyncSocket* socket_; socket_ 85 jingle/glue/pseudotcp_adapter.cc scoped_ptr<net::Socket> socket_; socket_ 115 jingle/glue/pseudotcp_adapter.cc socket_(socket), socket_ 341 jingle/glue/pseudotcp_adapter.cc socket_.reset(); socket_ 362 jingle/glue/pseudotcp_adapter.cc if (socket_.get()) { socket_ 363 jingle/glue/pseudotcp_adapter.cc result = socket_->Write( socket_ 387 jingle/glue/pseudotcp_adapter.cc while (socket_.get() && result > 0) { socket_ 388 jingle/glue/pseudotcp_adapter.cc result = socket_->Read( socket_ 55 media/audio/audio_device_thread.cc base::CancelableSyncSocket socket_; socket_ 101 media/audio/audio_device_thread.cc socket_(socket), socket_ 122 media/audio/audio_device_thread.cc socket_.Shutdown(); socket_ 168 media/audio/audio_device_thread.cc size_t bytes_read = socket_.Receive(&pending_data, sizeof(pending_data)); socket_ 185 media/audio/audio_device_thread.cc size_t bytes_sent = socket_.Send(&buffer_index, sizeof(buffer_index)); socket_ 569 media/audio/win/audio_output_win_unittest.cc : socket_(socket) { socket_ 581 media/audio/win/audio_output_win_unittest.cc socket_->Send(&buffers_state, sizeof(buffers_state)); socket_ 582 media/audio/win/audio_output_win_unittest.cc uint32 size = socket_->Receive(data_.get(), data_size_); socket_ 598 media/audio/win/audio_output_win_unittest.cc base::SyncSocket* socket_; socket_ 426 media/cast/test/utility/udp_proxy.cc socket_.reset(new net::UDPSocket(net::DatagramSocket::DEFAULT_BIND, socket_ 430 media/cast/test/utility/udp_proxy.cc BuildPipe(&to_dest_pipe_, new PacketSender(socket_.get(), &destination_)); socket_ 432 media/cast/test/utility/udp_proxy.cc new PacketSender(socket_.get(), &return_address_)); socket_ 439 media/cast/test/utility/udp_proxy.cc CHECK_GE(socket_->Bind(local_port_), 0); socket_ 478 media/cast/test/utility/udp_proxy.cc int len = socket_->RecvFrom( socket_ 497 media/cast/test/utility/udp_proxy.cc scoped_ptr<net::UDPSocket> socket_; socket_ 78 net/dns/dns_session.cc session_->FreeSocket(server_index_, socket_.Pass()); socket_ 50 net/dns/dns_session.h DatagramClientSocket* socket() { return socket_.get(); } socket_ 55 net/dns/dns_session.h scoped_ptr<DatagramClientSocket> socket_; socket_ 303 net/dns/dns_transaction.cc socket_(socket.Pass()), socket_ 314 net/dns/dns_transaction.cc int rv = socket_->Connect(base::Bind(&DnsTCPAttempt::OnIOComplete, socket_ 333 net/dns/dns_transaction.cc return socket_->NetLog(); socket_ 407 net/dns/dns_transaction.cc return socket_->Write( socket_ 426 net/dns/dns_transaction.cc return socket_->Write( socket_ 445 net/dns/dns_transaction.cc return socket_->Read( socket_ 469 net/dns/dns_transaction.cc return socket_->Read( socket_ 496 net/dns/dns_transaction.cc scoped_ptr<StreamSocket> socket_; socket_ 55 net/dns/mdns_client_impl.cc : socket_(socket.Pass()), socket_ 65 net/dns/mdns_client_impl.cc int rv = socket_->GetLocalAddress(&end_point); socket_ 79 net/dns/mdns_client_impl.cc rv = socket_->RecvFrom( socket_ 102 net/dns/mdns_client_impl.cc return socket_->SendTo(buffer, size, multicast_addr_, socket_ 74 net/dns/mdns_client_impl.h scoped_ptr<DatagramServerSocket> socket_; socket_ 129 net/quic/quic_client_session.cc socket_(socket.Pass()), socket_ 522 net/quic/quic_client_session.cc socket_->Close(); socket_ 569 net/quic/quic_client_session.cc int rv = socket_->Read(read_buffer_.get(), socket_ 677 net/quic/quic_client_session.cc socket_->GetLocalAddress(&local_address); socket_ 678 net/quic/quic_client_session.cc socket_->GetPeerAddress(&peer_address); socket_ 219 net/quic/quic_client_session.h scoped_ptr<DatagramClientSocket> socket_; socket_ 20 net/quic/quic_default_packet_writer.cc socket_(socket), socket_ 33 net/quic/quic_default_packet_writer.cc int rv = socket_->Write(buf.get(), socket_ 44 net/quic/quic_default_packet_writer.h DatagramClientSocket* socket_; socket_ 17 net/server/http_connection.cc if (!socket_.get()) socket_ 19 net/server/http_connection.cc socket_->Send(data); socket_ 23 net/server/http_connection.cc if (!socket_.get()) socket_ 25 net/server/http_connection.cc socket_->Send(bytes, len); socket_ 41 net/server/http_connection.h scoped_ptr<StreamListenSocket> socket_; socket_ 88 net/server/http_server.cc DidClose(connection->socket_.get()); socket_ 102 net/server/http_server.cc socket_to_connection_[connection->socket_.get()] = connection; socket_ 180 net/server/http_server.cc socket_to_connection_.erase(connection->socket_.get()); socket_ 69 net/server/http_server_unittest.cc socket_.reset(new TCPClientSocket(addresses, NULL, source)); socket_ 72 net/server/http_server_unittest.cc connect_result_ = socket_->Connect(base::Bind(&TestHttpClient::OnConnect, socket_ 96 net/server/http_server_unittest.cc int result = socket_->Write( socket_ 112 net/server/http_server_unittest.cc scoped_ptr<TCPClientSocket> socket_; socket_ 36 net/socket/buffered_write_stream_socket_unittest.cc socket_.reset(new BufferedWriteStreamSocket( socket_ 38 net/socket/buffered_write_stream_socket_unittest.cc socket_->Connect(callback_.callback()); socket_ 44 net/socket/buffered_write_stream_socket_unittest.cc socket_->Write(buf.get(), buf->size(), callback_.callback())); socket_ 47 net/socket/buffered_write_stream_socket_unittest.cc scoped_ptr<BufferedWriteStreamSocket> socket_; socket_ 42 net/socket/client_socket_handle.cc if (socket_) { socket_ 43 net/socket/client_socket_handle.cc socket_->NetLog().EndEvent(NetLog::TYPE_SOCKET_IN_USE); socket_ 46 net/socket/client_socket_handle.cc pool_->ReleaseSocket(group_name_, socket_.Pass(), pool_id_); socket_ 59 net/socket/client_socket_handle.cc socket_.reset(); socket_ 121 net/socket/client_socket_handle.cc if (!socket_) socket_ 124 net/socket/client_socket_handle.cc load_timing_info->socket_log_id = socket_->NetLog().source().id; socket_ 136 net/socket/client_socket_handle.cc socket_ = s.Pass(); socket_ 147 net/socket/client_socket_handle.cc return socket_.Pass(); socket_ 155 net/socket/client_socket_handle.cc if (!socket_.get()) socket_ 185 net/socket/client_socket_handle.cc DCHECK(socket_.get()); socket_ 186 net/socket/client_socket_handle.cc socket_->NetLog().BeginEvent( socket_ 142 net/socket/client_socket_handle.h DCHECK(socket_.get() == NULL); socket_ 155 net/socket/client_socket_handle.h StreamSocket* socket() { return socket_.get(); } socket_ 193 net/socket/client_socket_handle.h scoped_ptr<StreamSocket> socket_; socket_ 65 net/socket/client_socket_pool_base.cc return socket_.Pass(); socket_ 91 net/socket/client_socket_pool_base.cc socket_ = socket.Pass(); socket_ 118 net/socket/client_socket_pool_base.h StreamSocket* socket() { return socket_.get(); } socket_ 141 net/socket/client_socket_pool_base.h scoped_ptr<StreamSocket> socket_; socket_ 1688 net/socket/socket_test_util.cc : socket_(socket.Pass()), socket_ 1696 net/socket/socket_test_util.cc int rv = socket_->Connect(base::Bind(&MockConnectJob::OnConnect, socket_ 1709 net/socket/socket_test_util.cc socket_.reset(); socket_ 1716 net/socket/socket_test_util.cc if (!socket_.get()) socket_ 1719 net/socket/socket_test_util.cc handle_->SetSocket(socket_.Pass()); socket_ 1731 net/socket/socket_test_util.cc socket_.reset(); socket_ 198 net/socket/socket_test_util.h SocketDataProvider() : socket_(NULL) {} 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_ 219 net/socket/socket_test_util.h AsyncSocket* socket_; socket_ 1153 net/socket/socket_test_util.h scoped_ptr<StreamSocket> socket_; socket_ 144 net/socket/socks_client_socket_pool.cc socket_.reset(new SOCKS5ClientSocket(transport_socket_handle_.Pass(), socket_ 147 net/socket/socks_client_socket_pool.cc socket_.reset(new SOCKSClientSocket(transport_socket_handle_.Pass(), socket_ 152 net/socket/socks_client_socket_pool.cc return socket_->Connect( socket_ 158 net/socket/socks_client_socket_pool.cc socket_->Disconnect(); socket_ 162 net/socket/socks_client_socket_pool.cc SetSocket(socket_.Pass()); socket_ 102 net/socket/socks_client_socket_pool.h scoped_ptr<StreamSocket> socket_; socket_ 475 net/socket/ssl_client_socket_unittest.cc : socket_(socket), socket_ 484 net/socket/ssl_client_socket_unittest.cc if (socket_) { socket_ 485 net/socket/ssl_client_socket_unittest.cc delete socket_; socket_ 486 net/socket/ssl_client_socket_unittest.cc socket_ = NULL; socket_ 493 net/socket/ssl_client_socket_unittest.cc StreamSocket* socket_; socket_ 55 net/socket/stream_listen_socket.cc socket_(s), socket_ 90 net/socket/stream_listen_socket.cc if (getsockname(socket_, storage.addr, &storage.addr_len)) { socket_ 105 net/socket/stream_listen_socket.cc if (getpeername(socket_, storage.addr, &storage.addr_len)) { socket_ 121 net/socket/stream_listen_socket.cc SocketDescriptor conn = HANDLE_EINTR(accept(socket_, NULL, NULL)); socket_ 133 net/socket/stream_listen_socket.cc int sent = HANDLE_EINTR(send(socket_, send_buf, len_left, 0)); socket_ 161 net/socket/stream_listen_socket.cc if (listen(socket_, backlog) == -1) { socket_ 175 net/socket/stream_listen_socket.cc len = HANDLE_EINTR(recv(socket_, buf, kReadBufSize, 0)); socket_ 215 net/socket/stream_listen_socket.cc if (socket_ != kInvalidSocket) { socket_ 218 net/socket/stream_listen_socket.cc closesocket(socket_); socket_ 220 net/socket/stream_listen_socket.cc close(socket_); socket_ 227 net/socket/stream_listen_socket.cc WSAEventSelect(socket_, socket_event_, FD_ACCEPT | FD_CLOSE | FD_READ); socket_ 232 net/socket/stream_listen_socket.cc socket_, true, base::MessageLoopForIO::WATCH_READ, &watcher_, this); socket_ 250 net/socket/stream_listen_socket.cc if (kSocketError == WSAEnumNetworkEvents(socket_, socket_event_, &ev)) { socket_ 130 net/socket/stream_listen_socket.h const SocketDescriptor socket_; socket_ 19 net/socket/tcp_client_socket.cc : socket_(new TCPSocket(net_log, source)), socket_ 28 net/socket/tcp_client_socket.cc : socket_(connected_socket.Pass()), socket_ 33 net/socket/tcp_client_socket.cc DCHECK(socket_); socket_ 35 net/socket/tcp_client_socket.cc socket_->SetDefaultOptionsForClient(); socket_ 50 net/socket/tcp_client_socket.cc if (!socket_->IsValid()) { socket_ 56 net/socket/tcp_client_socket.cc result = socket_->Bind(address); socket_ 68 net/socket/tcp_client_socket.cc if (socket_->IsValid() && current_address_index_ >= 0) socket_ 71 net/socket/tcp_client_socket.cc socket_->StartLoggingMultipleConnectAttempts(addresses_); socket_ 82 net/socket/tcp_client_socket.cc socket_->EndLoggingMultipleConnectAttempts(rv); socket_ 126 net/socket/tcp_client_socket.cc if (socket_->IsValid()) { socket_ 134 net/socket/tcp_client_socket.cc result = socket_->Bind(*bind_address_); socket_ 136 net/socket/tcp_client_socket.cc socket_->Close(); socket_ 144 net/socket/tcp_client_socket.cc return socket_->Connect(endpoint, socket_ 178 net/socket/tcp_client_socket.cc previously_disconnected_ = socket_->IsValid() && current_address_index_ >= 0; socket_ 179 net/socket/tcp_client_socket.cc socket_->Close(); socket_ 183 net/socket/tcp_client_socket.cc return socket_->IsConnected(); socket_ 187 net/socket/tcp_client_socket.cc return socket_->IsConnectedAndIdle(); socket_ 191 net/socket/tcp_client_socket.cc return socket_->GetPeerAddress(address); socket_ 197 net/socket/tcp_client_socket.cc if (!socket_->IsValid()) { socket_ 205 net/socket/tcp_client_socket.cc return socket_->GetLocalAddress(address); socket_ 209 net/socket/tcp_client_socket.cc return socket_->net_log(); socket_ 225 net/socket/tcp_client_socket.cc return socket_->UsingTCPFastOpen(); socket_ 249 net/socket/tcp_client_socket.cc int result = socket_->Read(buf, buf_len, read_callback); socket_ 265 net/socket/tcp_client_socket.cc int result = socket_->Write(buf, buf_len, write_callback); socket_ 273 net/socket/tcp_client_socket.cc return socket_->SetReceiveBufferSize(size); socket_ 277 net/socket/tcp_client_socket.cc return socket_->SetSendBufferSize(size); socket_ 281 net/socket/tcp_client_socket.cc return socket_->SetKeepAlive(enable, delay); socket_ 285 net/socket/tcp_client_socket.cc return socket_->SetNoDelay(no_delay); socket_ 295 net/socket/tcp_client_socket.cc socket_->EndLoggingMultipleConnectAttempts(result); socket_ 309 net/socket/tcp_client_socket.cc DCHECK(!socket_->IsValid()); socket_ 311 net/socket/tcp_client_socket.cc int result = socket_->Open(family); socket_ 315 net/socket/tcp_client_socket.cc socket_->SetDefaultOptionsForClient(); socket_ 91 net/socket/tcp_client_socket.h scoped_ptr<TCPSocket> socket_; socket_ 16 net/socket/tcp_server_socket.cc : socket_(net_log, source), socket_ 24 net/socket/tcp_server_socket.cc int result = socket_.Open(address.GetFamily()); socket_ 28 net/socket/tcp_server_socket.cc result = socket_.SetDefaultOptionsForServer(); socket_ 30 net/socket/tcp_server_socket.cc socket_.Close(); socket_ 34 net/socket/tcp_server_socket.cc result = socket_.Bind(address); socket_ 36 net/socket/tcp_server_socket.cc socket_.Close(); socket_ 40 net/socket/tcp_server_socket.cc result = socket_.Listen(backlog); socket_ 42 net/socket/tcp_server_socket.cc socket_.Close(); socket_ 50 net/socket/tcp_server_socket.cc return socket_.GetLocalAddress(address); socket_ 68 net/socket/tcp_server_socket.cc int result = socket_.Accept(&accepted_socket_, &accepted_address_, socket_ 42 net/socket/tcp_server_socket.h TCPSocket socket_; socket_ 30 net/socket/tcp_server_socket_unittest.cc : socket_(NULL, NetLog::Source()) { socket_ 36 net/socket/tcp_server_socket_unittest.cc ASSERT_EQ(OK, socket_.Listen(address, kListenBacklog)); socket_ 37 net/socket/tcp_server_socket_unittest.cc ASSERT_EQ(OK, socket_.GetLocalAddress(&local_address_)); socket_ 44 net/socket/tcp_server_socket_unittest.cc if (socket_.Listen(address, kListenBacklog) != 0) { socket_ 49 net/socket/tcp_server_socket_unittest.cc ASSERT_EQ(OK, socket_.GetLocalAddress(&local_address_)); socket_ 71 net/socket/tcp_server_socket_unittest.cc TCPServerSocket socket_; socket_ 85 net/socket/tcp_server_socket_unittest.cc int result = socket_.Accept(&accepted_socket, accept_callback.callback()); socket_ 107 net/socket/tcp_server_socket_unittest.cc socket_.Accept(&accepted_socket, accept_callback.callback())); socket_ 132 net/socket/tcp_server_socket_unittest.cc socket_.Accept(&accepted_socket, accept_callback.callback())); socket_ 148 net/socket/tcp_server_socket_unittest.cc int result = socket_.Accept(&accepted_socket2, accept_callback2.callback()); socket_ 178 net/socket/tcp_server_socket_unittest.cc int result = socket_.Accept(&accepted_socket, accept_callback.callback()); socket_ 202 net/socket/tcp_server_socket_unittest.cc int result = socket_.Accept(&accepted_socket, accept_callback.callback()); socket_ 140 net/socket/tcp_socket_libevent.cc : socket_(kInvalidSocket), socket_ 176 net/socket/tcp_socket_libevent.cc DCHECK_EQ(socket_, kInvalidSocket); socket_ 178 net/socket/tcp_socket_libevent.cc socket_ = CreatePlatformSocket(ConvertAddressFamily(family), SOCK_STREAM, socket_ 180 net/socket/tcp_socket_libevent.cc if (socket_ < 0) { socket_ 185 net/socket/tcp_socket_libevent.cc if (SetNonBlocking(socket_)) { socket_ 197 net/socket/tcp_socket_libevent.cc DCHECK_EQ(socket_, kInvalidSocket); socket_ 199 net/socket/tcp_socket_libevent.cc socket_ = socket; socket_ 201 net/socket/tcp_socket_libevent.cc if (SetNonBlocking(socket_)) { socket_ 214 net/socket/tcp_socket_libevent.cc DCHECK_NE(socket_, kInvalidSocket); socket_ 220 net/socket/tcp_socket_libevent.cc int result = bind(socket_, storage.addr, storage.addr_len); socket_ 232 net/socket/tcp_socket_libevent.cc DCHECK_NE(socket_, kInvalidSocket); socket_ 234 net/socket/tcp_socket_libevent.cc int result = listen(socket_, backlog); socket_ 258 net/socket/tcp_socket_libevent.cc socket_, true, base::MessageLoopForIO::WATCH_READ, socket_ 275 net/socket/tcp_socket_libevent.cc DCHECK_NE(socket_, kInvalidSocket); socket_ 308 net/socket/tcp_socket_libevent.cc if (socket_ == kInvalidSocket || waiting_connect_) socket_ 319 net/socket/tcp_socket_libevent.cc int rv = HANDLE_EINTR(recv(socket_, &c, 1, MSG_PEEK)); socket_ 331 net/socket/tcp_socket_libevent.cc if (socket_ == kInvalidSocket || waiting_connect_) socket_ 340 net/socket/tcp_socket_libevent.cc int rv = HANDLE_EINTR(recv(socket_, &c, 1, MSG_PEEK)); socket_ 353 net/socket/tcp_socket_libevent.cc DCHECK_NE(kInvalidSocket, socket_); socket_ 360 net/socket/tcp_socket_libevent.cc int nread = HANDLE_EINTR(read(socket_, buf->data(), buf_len)); socket_ 377 net/socket/tcp_socket_libevent.cc socket_, true, base::MessageLoopForIO::WATCH_READ, socket_ 393 net/socket/tcp_socket_libevent.cc DCHECK_NE(kInvalidSocket, socket_); socket_ 416 net/socket/tcp_socket_libevent.cc socket_, true, base::MessageLoopForIO::WATCH_WRITE, socket_ 433 net/socket/tcp_socket_libevent.cc if (getsockname(socket_, storage.addr, &storage.addr_len) < 0) socket_ 460 net/socket/tcp_socket_libevent.cc SetTCPNoDelay(socket_, true); // If SetTCPNoDelay fails, we don't care. socket_ 476 net/socket/tcp_socket_libevent.cc SetTCPKeepAlive(socket_, true, kTCPKeepAliveSeconds); socket_ 497 net/socket/tcp_socket_libevent.cc int rv = setsockopt(socket_, SOL_SOCKET, SO_REUSEADDR, &boolean_value, socket_ 506 net/socket/tcp_socket_libevent.cc int rv = setsockopt(socket_, SOL_SOCKET, SO_RCVBUF, socket_ 513 net/socket/tcp_socket_libevent.cc int rv = setsockopt(socket_, SOL_SOCKET, SO_SNDBUF, socket_ 520 net/socket/tcp_socket_libevent.cc return SetTCPKeepAlive(socket_, enable, delay); socket_ 525 net/socket/tcp_socket_libevent.cc return SetTCPNoDelay(socket_, no_delay); socket_ 538 net/socket/tcp_socket_libevent.cc if (socket_ != kInvalidSocket) { socket_ 539 net/socket/tcp_socket_libevent.cc if (IGNORE_EINTR(close(socket_)) < 0) socket_ 541 net/socket/tcp_socket_libevent.cc socket_ = kInvalidSocket; socket_ 595 net/socket/tcp_socket_libevent.cc int new_socket = HANDLE_EINTR(accept(socket_, socket_ 640 net/socket/tcp_socket_libevent.cc if (!HANDLE_EINTR(connect(socket_, storage.addr, storage.addr_len))) { socket_ 658 net/socket/tcp_socket_libevent.cc socket_, true, base::MessageLoopForIO::WATCH_WRITE, socket_ 701 net/socket/tcp_socket_libevent.cc int rv = getsockname(socket_, storage.addr, &storage.addr_len); socket_ 720 net/socket/tcp_socket_libevent.cc bytes_transferred = HANDLE_EINTR(read(socket_, read_buf_->data(), socket_ 752 net/socket/tcp_socket_libevent.cc bytes_transferred = HANDLE_EINTR(write(socket_, write_buf_->data(), socket_ 784 net/socket/tcp_socket_libevent.cc if (getsockopt(socket_, SOL_SOCKET, SO_ERROR, &os_error, &len) < 0) socket_ 838 net/socket/tcp_socket_libevent.cc nwrite = HANDLE_EINTR(sendto(socket_, socket_ 864 net/socket/tcp_socket_libevent.cc nwrite = HANDLE_EINTR(write(socket_, buf->data(), buf_len)); socket_ 881 net/socket/tcp_socket_libevent.cc getsockopt(socket_, IPPROTO_TCP, TCP_INFO, &info, &info_len) == 0 && socket_ 72 net/socket/tcp_socket_libevent.h bool IsValid() const { return socket_ != kInvalidSocket; } socket_ 179 net/socket/tcp_socket_libevent.h int socket_; socket_ 30 net/socket/tcp_socket_unittest.cc TCPSocketTest() : socket_(NULL, NetLog::Source()) { socket_ 37 net/socket/tcp_socket_unittest.cc ASSERT_EQ(OK, socket_.Open(ADDRESS_FAMILY_IPV4)); socket_ 38 net/socket/tcp_socket_unittest.cc ASSERT_EQ(OK, socket_.Bind(address)); socket_ 39 net/socket/tcp_socket_unittest.cc ASSERT_EQ(OK, socket_.Listen(kListenBacklog)); socket_ 40 net/socket/tcp_socket_unittest.cc ASSERT_EQ(OK, socket_.GetLocalAddress(&local_address_)); socket_ 48 net/socket/tcp_socket_unittest.cc if (socket_.Open(ADDRESS_FAMILY_IPV6) != OK || socket_ 49 net/socket/tcp_socket_unittest.cc socket_.Bind(address) != OK || socket_ 50 net/socket/tcp_socket_unittest.cc socket_.Listen(kListenBacklog) != OK) { socket_ 55 net/socket/tcp_socket_unittest.cc ASSERT_EQ(OK, socket_.GetLocalAddress(&local_address_)); socket_ 71 net/socket/tcp_socket_unittest.cc TCPSocket socket_; socket_ 89 net/socket/tcp_socket_unittest.cc int result = socket_.Accept(&accepted_socket, &accepted_address, socket_ 111 net/socket/tcp_socket_unittest.cc socket_.Accept(&accepted_socket, &accepted_address, socket_ 137 net/socket/tcp_socket_unittest.cc socket_.Accept(&accepted_socket, &accepted_address, socket_ 156 net/socket/tcp_socket_unittest.cc int result = socket_.Accept(&accepted_socket2, &accepted_address2, socket_ 188 net/socket/tcp_socket_unittest.cc int result = socket_.Accept(&accepted_socket, &accepted_address, socket_ 214 net/socket/tcp_socket_unittest.cc result = socket_.Accept(&accepted_socket, &accepted_address, socket_ 140 net/socket/tcp_socket_win.cc void Detach() { socket_ = NULL; } socket_ 186 net/socket/tcp_socket_win.cc TCPSocketWin* socket_; socket_ 205 net/socket/tcp_socket_win.cc socket_(socket), socket_ 242 net/socket/tcp_socket_win.cc if (core_->socket_) { socket_ 243 net/socket/tcp_socket_win.cc if (core_->socket_->waiting_connect_) socket_ 244 net/socket/tcp_socket_win.cc core_->socket_->DidCompleteConnect(); socket_ 246 net/socket/tcp_socket_win.cc core_->socket_->DidSignalRead(); socket_ 255 net/socket/tcp_socket_win.cc if (core_->socket_) socket_ 256 net/socket/tcp_socket_win.cc core_->socket_->DidCompleteWrite(); socket_ 265 net/socket/tcp_socket_win.cc : socket_(INVALID_SOCKET), socket_ 287 net/socket/tcp_socket_win.cc DCHECK_EQ(socket_, INVALID_SOCKET); socket_ 289 net/socket/tcp_socket_win.cc socket_ = CreatePlatformSocket(ConvertAddressFamily(family), SOCK_STREAM, socket_ 291 net/socket/tcp_socket_win.cc if (socket_ == INVALID_SOCKET) { socket_ 296 net/socket/tcp_socket_win.cc if (SetNonBlocking(socket_)) { socket_ 308 net/socket/tcp_socket_win.cc DCHECK_EQ(socket_, INVALID_SOCKET); socket_ 311 net/socket/tcp_socket_win.cc socket_ = socket; socket_ 313 net/socket/tcp_socket_win.cc if (SetNonBlocking(socket_)) { socket_ 327 net/socket/tcp_socket_win.cc DCHECK_NE(socket_, INVALID_SOCKET); socket_ 333 net/socket/tcp_socket_win.cc int result = bind(socket_, storage.addr, storage.addr_len); socket_ 345 net/socket/tcp_socket_win.cc DCHECK_NE(socket_, INVALID_SOCKET); socket_ 354 net/socket/tcp_socket_win.cc int result = listen(socket_, backlog); socket_ 378 net/socket/tcp_socket_win.cc WSAEventSelect(socket_, accept_event_, FD_ACCEPT); socket_ 392 net/socket/tcp_socket_win.cc DCHECK_NE(socket_, INVALID_SOCKET); socket_ 426 net/socket/tcp_socket_win.cc if (socket_ == INVALID_SOCKET || waiting_connect_) socket_ 434 net/socket/tcp_socket_win.cc int rv = recv(socket_, &c, 1, MSG_PEEK); socket_ 446 net/socket/tcp_socket_win.cc if (socket_ == INVALID_SOCKET || waiting_connect_) socket_ 455 net/socket/tcp_socket_win.cc int rv = recv(socket_, &c, 1, MSG_PEEK); socket_ 468 net/socket/tcp_socket_win.cc DCHECK_NE(socket_, INVALID_SOCKET); socket_ 480 net/socket/tcp_socket_win.cc DCHECK_NE(socket_, INVALID_SOCKET); socket_ 496 net/socket/tcp_socket_win.cc int rv = WSASend(socket_, &write_buffer, 1, &num, 0, socket_ 536 net/socket/tcp_socket_win.cc if (getsockname(socket_, storage.addr, &storage.addr_len)) socket_ 570 net/socket/tcp_socket_win.cc SetSocketReceiveBufferSize(socket_, kSocketBufferSize); socket_ 571 net/socket/tcp_socket_win.cc SetSocketSendBufferSize(socket_, kSocketBufferSize); socket_ 574 net/socket/tcp_socket_win.cc DisableNagle(socket_, true); socket_ 575 net/socket/tcp_socket_win.cc SetTCPKeepAlive(socket_, true, kTCPKeepAliveSeconds); socket_ 596 net/socket/tcp_socket_win.cc int rv = setsockopt(socket_, SOL_SOCKET, SO_EXCLUSIVEADDRUSE, socket_ 606 net/socket/tcp_socket_win.cc return SetSocketReceiveBufferSize(socket_, size); socket_ 611 net/socket/tcp_socket_win.cc return SetSocketSendBufferSize(socket_, size); socket_ 615 net/socket/tcp_socket_win.cc return SetTCPKeepAlive(socket_, enable, delay); socket_ 619 net/socket/tcp_socket_win.cc return DisableNagle(socket_, no_delay); socket_ 625 net/socket/tcp_socket_win.cc if (socket_ != INVALID_SOCKET) { socket_ 633 net/socket/tcp_socket_win.cc shutdown(socket_, SD_SEND); socket_ 636 net/socket/tcp_socket_win.cc if (closesocket(socket_) < 0) socket_ 638 net/socket/tcp_socket_win.cc socket_ = INVALID_SOCKET; socket_ 703 net/socket/tcp_socket_win.cc int new_socket = accept(socket_, storage.addr, &storage.addr_len); socket_ 736 net/socket/tcp_socket_win.cc if (WSAEnumNetworkEvents(socket_, accept_event_, &ev) == SOCKET_ERROR) { socket_ 754 net/socket/tcp_socket_win.cc WSAEventSelect(socket_, accept_event_, FD_ACCEPT); socket_ 769 net/socket/tcp_socket_win.cc WSAEventSelect(socket_, core_->read_overlapped_.hEvent, FD_CONNECT); socket_ 774 net/socket/tcp_socket_win.cc if (!connect(socket_, storage.addr, storage.addr_len)) { socket_ 839 net/socket/tcp_socket_win.cc socket_, reinterpret_cast<struct sockaddr*>(&source_address), &addrlen); socket_ 858 net/socket/tcp_socket_win.cc WSAEventSelect(socket_, core_->read_overlapped_.hEvent, socket_ 862 net/socket/tcp_socket_win.cc int rv = recv(socket_, buf->data(), buf_len, 0); socket_ 895 net/socket/tcp_socket_win.cc int rv = WSAEnumNetworkEvents(socket_, core_->read_overlapped_.hEvent, socket_ 923 net/socket/tcp_socket_win.cc BOOL ok = WSAGetOverlappedResult(socket_, &core_->write_overlapped_, socket_ 962 net/socket/tcp_socket_win.cc int rv = WSAEnumNetworkEvents(socket_, core_->read_overlapped_.hEvent, socket_ 74 net/socket/tcp_socket_win.h bool IsValid() const { return socket_ != INVALID_SOCKET; } socket_ 111 net/socket/tcp_socket_win.h SOCKET socket_; socket_ 157 net/socket/unix_domain_socket_posix_unittest.cc socket_ = UnixDomainSocket::CreateAndListen( socket_ 175 net/socket/unix_domain_socket_posix_unittest.cc socket_.reset(); socket_ 224 net/socket/unix_domain_socket_posix_unittest.cc scoped_ptr<UnixDomainSocket> socket_; socket_ 248 net/socket/unix_domain_socket_posix_unittest.cc EXPECT_FALSE(socket_.get() == NULL); socket_ 253 net/socket/unix_domain_socket_posix_unittest.cc EXPECT_TRUE(socket_.get() == NULL); socket_ 261 net/socket/unix_domain_socket_posix_unittest.cc socket_ = UnixDomainSocket::CreateAndListenWithAbstractNamespace( socket_ 263 net/socket/unix_domain_socket_posix_unittest.cc EXPECT_FALSE(socket_.get() == NULL); socket_ 272 net/socket/unix_domain_socket_posix_unittest.cc socket_ = socket_ 275 net/socket/unix_domain_socket_posix_unittest.cc EXPECT_TRUE(socket_.get() == NULL); socket_ 278 net/socket/unix_domain_socket_posix_unittest.cc socket_ = UnixDomainSocket::CreateAndListenWithAbstractNamespace( socket_ 283 net/socket/unix_domain_socket_posix_unittest.cc EXPECT_FALSE(socket_.get() == NULL); socket_ 48 net/socket_stream/socket_stream_job.cc return socket_->GetUserData(key); socket_ 53 net/socket_stream/socket_stream_job.cc socket_->SetUserData(key, data); socket_ 57 net/socket_stream/socket_stream_job.cc socket_->Connect(); socket_ 61 net/socket_stream/socket_stream_job.cc return socket_->SendData(data, len); socket_ 65 net/socket_stream/socket_stream_job.cc socket_->Close(); socket_ 69 net/socket_stream/socket_stream_job.cc socket_->RestartWithAuth(credentials); socket_ 73 net/socket_stream/socket_stream_job.cc socket_->CancelWithError(error); socket_ 77 net/socket_stream/socket_stream_job.cc socket_->CancelWithSSLError(ssl_info); socket_ 81 net/socket_stream/socket_stream_job.cc socket_->ContinueDespiteError(); socket_ 85 net/socket_stream/socket_stream_job.cc socket_->DetachDelegate(); socket_ 89 net/socket_stream/socket_stream_job.cc if (socket_.get()) socket_ 90 net/socket_stream/socket_stream_job.cc socket_->DetachContext(); socket_ 51 net/socket_stream/socket_stream_job.h socket_ = socket; socket_ 58 net/socket_stream/socket_stream_job.h return socket_.get() ? socket_->context() : 0; socket_ 61 net/socket_stream/socket_stream_job.h return socket_.get() ? socket_->cookie_store() : 0; socket_ 87 net/socket_stream/socket_stream_job.h scoped_refptr<SocketStream> socket_; socket_ 240 net/test/embedded_test_server/embedded_test_server.cc connections_.erase(connection->socket_.get()); socket_ 271 net/test/embedded_test_server/embedded_test_server.cc connections_[http_connection->socket_.get()] = http_connection; socket_ 15 net/test/embedded_test_server/http_connection.cc : socket_(socket.Pass()), socket_ 24 net/test/embedded_test_server/http_connection.cc socket_->Send(response_string.c_str(), response_string.length()); socket_ 47 net/test/embedded_test_server/http_connection.h scoped_ptr<StreamListenSocket> socket_; socket_ 15 net/udp/udp_client_socket.cc : socket_(bind_type, rand_int_cb, net_log, source) { socket_ 22 net/udp/udp_client_socket.cc return socket_.Connect(address); socket_ 28 net/udp/udp_client_socket.cc return socket_.Read(buf, buf_len, callback); socket_ 34 net/udp/udp_client_socket.cc return socket_.Write(buf, buf_len, callback); socket_ 38 net/udp/udp_client_socket.cc socket_.Close(); socket_ 42 net/udp/udp_client_socket.cc return socket_.GetPeerAddress(address); socket_ 46 net/udp/udp_client_socket.cc return socket_.GetLocalAddress(address); socket_ 50 net/udp/udp_client_socket.cc return socket_.SetReceiveBufferSize(size); socket_ 54 net/udp/udp_client_socket.cc return socket_.SetSendBufferSize(size); socket_ 58 net/udp/udp_client_socket.cc return socket_.NetLog(); socket_ 40 net/udp/udp_client_socket.h UDPSocket socket_; socket_ 13 net/udp/udp_server_socket.cc : socket_(DatagramSocket::DEFAULT_BIND, socket_ 23 net/udp/udp_server_socket.cc return socket_.Bind(address); socket_ 30 net/udp/udp_server_socket.cc return socket_.RecvFrom(buf, buf_len, address, callback); socket_ 37 net/udp/udp_server_socket.cc return socket_.SendTo(buf, buf_len, address, callback); socket_ 41 net/udp/udp_server_socket.cc return socket_.SetReceiveBufferSize(size); socket_ 45 net/udp/udp_server_socket.cc return socket_.SetSendBufferSize(size); socket_ 49 net/udp/udp_server_socket.cc socket_.Close(); socket_ 53 net/udp/udp_server_socket.cc return socket_.GetPeerAddress(address); socket_ 57 net/udp/udp_server_socket.cc return socket_.GetLocalAddress(address); socket_ 61 net/udp/udp_server_socket.cc return socket_.NetLog(); socket_ 65 net/udp/udp_server_socket.cc socket_.AllowAddressReuse(); socket_ 69 net/udp/udp_server_socket.cc socket_.AllowBroadcast(); socket_ 73 net/udp/udp_server_socket.cc return socket_.JoinGroup(group_address); socket_ 77 net/udp/udp_server_socket.cc return socket_.LeaveGroup(group_address); socket_ 81 net/udp/udp_server_socket.cc return socket_.SetMulticastInterface(interface_index); socket_ 85 net/udp/udp_server_socket.cc return socket_.SetMulticastTimeToLive(time_to_live); socket_ 89 net/udp/udp_server_socket.cc return socket_.SetMulticastLoopbackMode(loopback); socket_ 93 net/udp/udp_server_socket.cc return socket_.SetDiffServCodePoint(dscp); socket_ 97 net/udp/udp_server_socket.cc socket_.DetachFromThread(); socket_ 51 net/udp/udp_server_socket.h UDPSocket socket_; socket_ 67 net/udp/udp_socket_libevent.cc : socket_(kInvalidSocket), socket_ 112 net/udp/udp_socket_libevent.cc if (IGNORE_EINTR(close(socket_)) < 0) socket_ 115 net/udp/udp_socket_libevent.cc socket_ = kInvalidSocket; socket_ 127 net/udp/udp_socket_libevent.cc if (getpeername(socket_, storage.addr, &storage.addr_len)) socket_ 147 net/udp/udp_socket_libevent.cc if (getsockname(socket_, storage.addr, &storage.addr_len)) socket_ 172 net/udp/udp_socket_libevent.cc DCHECK_NE(kInvalidSocket, socket_); socket_ 183 net/udp/udp_socket_libevent.cc socket_, true, base::MessageLoopForIO::WATCH_READ, socket_ 216 net/udp/udp_socket_libevent.cc DCHECK_NE(kInvalidSocket, socket_); socket_ 226 net/udp/udp_socket_libevent.cc socket_, true, base::MessageLoopForIO::WATCH_WRITE, socket_ 285 net/udp/udp_socket_libevent.cc rv = HANDLE_EINTR(connect(socket_, storage.addr, storage.addr_len)); socket_ 320 net/udp/udp_socket_libevent.cc int rv = setsockopt(socket_, SOL_SOCKET, SO_RCVBUF, socket_ 329 net/udp/udp_socket_libevent.cc int rv = setsockopt(socket_, SOL_SOCKET, SO_SNDBUF, socket_ 351 net/udp/udp_socket_libevent.cc if (!socket_->read_callback_.is_null()) socket_ 352 net/udp/udp_socket_libevent.cc socket_->DidCompleteRead(); socket_ 356 net/udp/udp_socket_libevent.cc if (!socket_->write_callback_.is_null()) socket_ 357 net/udp/udp_socket_libevent.cc socket_->DidCompleteWrite(); socket_ 421 net/udp/udp_socket_libevent.cc socket_ = CreatePlatformSocket(addr_family_, SOCK_DGRAM, 0); socket_ 422 net/udp/udp_socket_libevent.cc if (socket_ == kInvalidSocket) socket_ 424 net/udp/udp_socket_libevent.cc if (SetNonBlocking(socket_)) { socket_ 471 net/udp/udp_socket_libevent.cc HANDLE_EINTR(recvfrom(socket_, socket_ 505 net/udp/udp_socket_libevent.cc int result = HANDLE_EINTR(sendto(socket_, socket_ 521 net/udp/udp_socket_libevent.cc int rv = setsockopt(socket_, SOL_SOCKET, SO_REUSEADDR, &true_value, socket_ 532 net/udp/udp_socket_libevent.cc rv = setsockopt(socket_, SOL_SOCKET, SO_REUSEPORT, &true_value, socket_ 535 net/udp/udp_socket_libevent.cc rv = setsockopt(socket_, SOL_SOCKET, SO_BROADCAST, &true_value, socket_ 546 net/udp/udp_socket_libevent.cc rv = setsockopt(socket_, IPPROTO_IP, IP_MULTICAST_LOOP, socket_ 550 net/udp/udp_socket_libevent.cc rv = setsockopt(socket_, IPPROTO_IPV6, IPV6_MULTICAST_LOOP, socket_ 560 net/udp/udp_socket_libevent.cc rv = setsockopt(socket_, IPPROTO_IP, IP_MULTICAST_TTL, socket_ 565 net/udp/udp_socket_libevent.cc rv = setsockopt(socket_, IPPROTO_IPV6, IPV6_MULTICAST_HOPS, socket_ 580 net/udp/udp_socket_libevent.cc int error = GetIPv4AddressFromIndex(socket_, multicast_interface_, socket_ 585 net/udp/udp_socket_libevent.cc int rv = setsockopt(socket_, IPPROTO_IP, IP_MULTICAST_IF, socket_ 593 net/udp/udp_socket_libevent.cc int rv = setsockopt(socket_, IPPROTO_IPV6, IPV6_MULTICAST_IF, socket_ 612 net/udp/udp_socket_libevent.cc int rv = bind(socket_, storage.addr, storage.addr_len); socket_ 655 net/udp/udp_socket_libevent.cc int error = GetIPv4AddressFromIndex(socket_, multicast_interface_, socket_ 661 net/udp/udp_socket_libevent.cc int rv = setsockopt(socket_, IPPROTO_IP, IP_ADD_MEMBERSHIP, socket_ 673 net/udp/udp_socket_libevent.cc int rv = setsockopt(socket_, IPPROTO_IPV6, IPV6_JOIN_GROUP, socket_ 698 net/udp/udp_socket_libevent.cc int rv = setsockopt(socket_, IPPROTO_IP, IP_DROP_MEMBERSHIP, socket_ 710 net/udp/udp_socket_libevent.cc int rv = setsockopt(socket_, IPPROTO_IPV6, IPV6_LEAVE_GROUP, socket_ 760 net/udp/udp_socket_libevent.cc rv = setsockopt(socket_, IPPROTO_IP, IP_TOS, socket_ 763 net/udp/udp_socket_libevent.cc rv = setsockopt(socket_, IPPROTO_IPV6, IPV6_TCLASS, socket_ 103 net/udp/udp_socket_libevent.h bool is_connected() const { return socket_ != kInvalidSocket; } socket_ 178 net/udp/udp_socket_libevent.h explicit ReadWatcher(UDPSocketLibevent* socket) : socket_(socket) {} socket_ 187 net/udp/udp_socket_libevent.h UDPSocketLibevent* const socket_; socket_ 194 net/udp/udp_socket_libevent.h explicit WriteWatcher(UDPSocketLibevent* socket) : socket_(socket) {} socket_ 203 net/udp/udp_socket_libevent.h UDPSocketLibevent* const socket_; socket_ 243 net/udp/udp_socket_libevent.h int socket_; socket_ 50 net/udp/udp_socket_win.cc void Detach() { socket_ = NULL; } socket_ 93 net/udp/udp_socket_win.cc UDPSocketWin* socket_; socket_ 109 net/udp/udp_socket_win.cc : socket_(socket), socket_ 146 net/udp/udp_socket_win.cc if (core_->socket_) socket_ 147 net/udp/udp_socket_win.cc core_->socket_->DidCompleteRead(); socket_ 154 net/udp/udp_socket_win.cc if (core_->socket_) socket_ 155 net/udp/udp_socket_win.cc core_->socket_->DidCompleteWrite(); socket_ 166 net/udp/udp_socket_win.cc : socket_(INVALID_SOCKET), socket_ 199 net/udp/udp_socket_win.cc closesocket(socket_); socket_ 202 net/udp/udp_socket_win.cc socket_ = INVALID_SOCKET; socket_ 218 net/udp/udp_socket_win.cc if (getpeername(socket_, storage.addr, &storage.addr_len)) socket_ 239 net/udp/udp_socket_win.cc if (getsockname(socket_, storage.addr, &storage.addr_len)) socket_ 264 net/udp/udp_socket_win.cc DCHECK_NE(INVALID_SOCKET, socket_); socket_ 297 net/udp/udp_socket_win.cc DCHECK_NE(INVALID_SOCKET, socket_); socket_ 351 net/udp/udp_socket_win.cc rv = connect(socket_, storage.addr, storage.addr_len); socket_ 384 net/udp/udp_socket_win.cc socket_ = CreatePlatformSocket(addr_family_, SOCK_DGRAM, IPPROTO_UDP); socket_ 385 net/udp/udp_socket_win.cc if (socket_ == INVALID_SOCKET) socket_ 393 net/udp/udp_socket_win.cc int rv = setsockopt(socket_, SOL_SOCKET, SO_RCVBUF, socket_ 402 net/udp/udp_socket_win.cc rv = getsockopt(socket_, SOL_SOCKET, SO_RCVBUF, socket_ 415 net/udp/udp_socket_win.cc int rv = setsockopt(socket_, SOL_SOCKET, SO_SNDBUF, socket_ 423 net/udp/udp_socket_win.cc rv = getsockopt(socket_, SOL_SOCKET, SO_SNDBUF, socket_ 470 net/udp/udp_socket_win.cc BOOL ok = WSAGetOverlappedResult(socket_, &core_->read_overlapped_, socket_ 508 net/udp/udp_socket_win.cc BOOL ok = WSAGetOverlappedResult(socket_, &core_->write_overlapped_, socket_ 549 net/udp/udp_socket_win.cc CHECK_NE(INVALID_SOCKET, socket_); socket_ 551 net/udp/udp_socket_win.cc int rv = WSARecvFrom(socket_, &read_buffer, 1, &num, &flags, storage.addr, socket_ 601 net/udp/udp_socket_win.cc int rv = WSASendTo(socket_, &write_buffer, 1, &num, flags, socket_ 626 net/udp/udp_socket_win.cc int rv = setsockopt(socket_, SOL_SOCKET, SO_REUSEADDR, socket_ 633 net/udp/udp_socket_win.cc int rv = setsockopt(socket_, SOL_SOCKET, SO_BROADCAST, socket_ 645 net/udp/udp_socket_win.cc int rv = setsockopt(socket_, protocol_level, option, socket_ 656 net/udp/udp_socket_win.cc int rv = setsockopt(socket_, protocol_level, option, socket_ 666 net/udp/udp_socket_win.cc int rv = setsockopt(socket_, IPPROTO_IP, IP_MULTICAST_IF, socket_ 675 net/udp/udp_socket_win.cc int rv = setsockopt(socket_, IPPROTO_IPV6, IPV6_MULTICAST_IF, socket_ 694 net/udp/udp_socket_win.cc int rv = bind(socket_, storage.addr, storage.addr_len); socket_ 740 net/udp/udp_socket_win.cc int rv = setsockopt(socket_, IPPROTO_IP, IP_ADD_MEMBERSHIP, socket_ 753 net/udp/udp_socket_win.cc int rv = setsockopt(socket_, IPPROTO_IPV6, IPV6_ADD_MEMBERSHIP, socket_ 779 net/udp/udp_socket_win.cc int rv = setsockopt(socket_, IPPROTO_IP, IP_DROP_MEMBERSHIP, socket_ 791 net/udp/udp_socket_win.cc int rv = setsockopt(socket_, IPPROTO_IPV6, IP_DROP_MEMBERSHIP, socket_ 106 net/udp/udp_socket_win.h bool is_connected() const { return socket_ != INVALID_SOCKET; } socket_ 215 net/udp/udp_socket_win.h SOCKET socket_; socket_ 93 net/websockets/websocket_job.cc DCHECK(!socket_.get()); socket_ 97 net/websockets/websocket_job.cc DCHECK(socket_.get()); socket_ 100 net/websockets/websocket_job.cc socket_->Connect(); socket_ 146 net/websockets/websocket_job.cc socket_->RestartWithAuth(credentials); socket_ 158 net/websockets/websocket_job.cc if (socket_.get()) socket_ 159 net/websockets/websocket_job.cc socket_->DetachDelegate(); socket_ 160 net/websockets/websocket_job.cc socket_ = NULL; socket_ 259 net/websockets/websocket_job.cc socket_ = NULL; socket_ 288 net/websockets/websocket_job.cc DCHECK(socket_.get()); socket_ 310 net/websockets/websocket_job.cc delegate_->OnSentData(socket_.get(), original_length); socket_ 333 net/websockets/websocket_job.cc OnSentData(socket_.get(), static_cast<int>(bytes_sent)); socket_ 345 net/websockets/websocket_job.cc socket_.get(), buffer->GetRemainingData(), buffer->GetRemainingSize()); socket_ 347 net/websockets/websocket_job.cc OnReceivedData(socket_.get(), NULL, 0); socket_ 353 net/websockets/websocket_job.cc OnClose(socket_.get()); socket_ 369 net/websockets/websocket_job.cc if (delegate_ && !delegate_->CanGetCookies(socket_.get(), GetURLForCookies())) socket_ 372 net/websockets/websocket_job.cc if (socket_.get() && delegate_ && state_ == CONNECTING) { socket_ 375 net/websockets/websocket_job.cc if (allow && socket_->cookie_store()) { socket_ 379 net/websockets/websocket_job.cc socket_->cookie_store()->GetCookiesWithOptionsAsync( socket_ 403 net/websockets/websocket_job.cc socket_->url(), headers.get(), &challenge_, spdy_protocol_version_); socket_ 409 net/websockets/websocket_job.cc socket_->net_log()->AddEvent( socket_ 412 net/websockets/websocket_job.cc socket_->SendData(handshake_request.data(), socket_ 454 net/websockets/websocket_job.cc socket_->net_log()->AddEvent( socket_ 499 net/websockets/websocket_job.cc socket_.get(), &received_data.front(), received_data.size()); socket_ 505 net/websockets/websocket_job.cc if (!socket_.get() || !delegate_ || state_ != CONNECTING) socket_ 511 net/websockets/websocket_job.cc if (socket_->cookie_store()) { socket_ 528 net/websockets/websocket_job.cc socket_.get(), url_for_cookies, cookie, &options)) socket_ 532 net/websockets/websocket_job.cc socket_->cookie_store()->SetCookieWithOptionsAsync( socket_ 567 net/websockets/websocket_job.cc GURL url = socket_->url(); socket_ 568 net/websockets/websocket_job.cc std::string scheme = socket_->is_secure() ? "https" : "http"; socket_ 580 net/websockets/websocket_job.cc if (!socket_.get()) socket_ 588 net/websockets/websocket_job.cc socket_->context()->http_transaction_factory(); socket_ 595 net/websockets/websocket_job.cc PrivacyMode privacy_mode = socket_->privacy_mode(); socket_ 596 net/websockets/websocket_job.cc const SpdySessionKey key(HostPortPair::FromURL(socket_->url()), socket_ 597 net/websockets/websocket_job.cc socket_->proxy_server(), privacy_mode); socket_ 601 net/websockets/websocket_job.cc spdy_pool->FindAvailableSession(key, *socket_->net_log()); socket_ 610 net/websockets/websocket_job.cc if (socket_->is_secure() && !use_ssl) socket_ 618 net/websockets/websocket_job.cc socket_->url(), MEDIUM, *socket_->net_log()); socket_ 620 net/websockets/websocket_job.cc OnConnected(socket_.get(), kMaxPendingSendAllowed); socket_ 672 net/websockets/websocket_job.cc if (socket_.get()) socket_ 673 net/websockets/websocket_job.cc return socket_->SendData(data, length); socket_ 680 net/websockets/websocket_job.cc if (socket_.get()) socket_ 681 net/websockets/websocket_job.cc socket_->Close(); socket_ 403 net/websockets/websocket_job_test.cc socket_ = NULL; socket_ 442 net/websockets/websocket_job_test.cc socket_ = new MockSocketStream(url, websocket_.get(), context_.get(), socket_ 459 net/websockets/websocket_job_test.cc socket_ = new SocketStream(url, websocket_.get(), context_.get(), NULL); socket_ 463 net/websockets/websocket_job_test.cc socket_->SetClientSocketFactory(socket_factory_.get()); socket_ 466 net/websockets/websocket_job_test.cc websocket_->InitSocketStream(socket_.get()); socket_ 483 net/websockets/websocket_job_test.cc if (websocket_->socket_.get()) { socket_ 484 net/websockets/websocket_job_test.cc websocket_->socket_->DetachDelegate(); socket_ 489 net/websockets/websocket_job_test.cc websocket_->socket_ = NULL; socket_ 492 net/websockets/websocket_job_test.cc return job->socket_.get(); socket_ 497 net/websockets/websocket_job_test.cc static_cast<MockSocketStream*>(socket_.get()); socket_ 524 net/websockets/websocket_job_test.cc scoped_refptr<SocketStream> socket_; socket_ 564 net/websockets/websocket_job_test.cc socket_ = new MockSocketStream( socket_ 567 net/websockets/websocket_job_test.cc websocket->InitSocketStream(socket_.get()); socket_ 576 net/websockets/websocket_job_test.cc scoped_refptr<SocketStream> socket_; socket_ 660 net/websockets/websocket_job_test.cc websocket_->OnSentData(socket_.get(), socket_ 664 net/websockets/websocket_job_test.cc websocket_->OnReceivedData(socket_.get(), socket_ 685 net/websockets/websocket_job_test.cc websocket_->OnSentData(socket_.get(), socket_ 694 net/websockets/websocket_job_test.cc websocket_->OnReceivedData(socket_.get(), line.c_str(), line.size()); socket_ 699 net/websockets/websocket_job_test.cc websocket_->OnReceivedData(socket_.get(), "\r\n", 2); socket_ 740 net/websockets/websocket_job_test.cc websocket_->OnSentData(socket_.get(), socket_ 745 net/websockets/websocket_job_test.cc websocket_->OnReceivedData(socket_.get(), socket_ 775 net/websockets/websocket_job_test.cc websocket_->OnSentData(socket_.get(), socket_ 780 net/websockets/websocket_job_test.cc websocket_->OnReceivedData(socket_.get(), socket_ 819 net/websockets/websocket_job_test.cc websocket_->OnSentData(socket_.get(), kHandshakeRequestWithoutCookieLength); socket_ 822 net/websockets/websocket_job_test.cc websocket_->OnReceivedData(socket_.get(), socket_ 868 net/websockets/websocket_job_test.cc websocket_->OnSentData(socket_.get(), socket_ 1223 net/websockets/websocket_job_test.cc job()->OnClose(socket_.get()); socket_ 1229 net/websockets/websocket_job_test.cc socket_->DetachDelegate(); socket_ 1235 net/websockets/websocket_job_test.cc job()->OnAuthRequired(socket_.get(), NULL); socket_ 1242 net/websockets/websocket_job_test.cc job()->OnSSLCertificateError(socket_.get(), ssl_info, true); socket_ 1248 net/websockets/websocket_job_test.cc job()->OnError(socket_.get(), ERR_CONNECTION_RESET); socket_ 1273 net/websockets/websocket_job_test.cc job()->OnSentData(socket_.get(), kMinimalRequestSize); socket_ 1287 net/websockets/websocket_job_test.cc socket_.get(), kMinimalResponse, arraysize(kMinimalResponse) - 1); socket_ 181 ppapi/proxy/audio_input_resource.cc socket_.reset(new base::CancelableSyncSocket(socket_handle)); socket_ 205 ppapi/proxy/audio_input_resource.cc !socket_.get() || !capturing_ || !shared_memory_->memory()) { socket_ 216 ppapi/proxy/audio_input_resource.cc if (socket_.get()) socket_ 217 ppapi/proxy/audio_input_resource.cc socket_->Shutdown(); socket_ 233 ppapi/proxy/audio_input_resource.cc while (sizeof(pending_data) == socket_->Receive(&pending_data, socket_ 102 ppapi/proxy/audio_input_resource.h scoped_ptr<base::CancelableSyncSocket> socket_; socket_ 65 ppapi/shared_impl/ppb_audio_shared.cc if (socket_.get()) socket_ 66 ppapi/shared_impl/ppb_audio_shared.cc socket_->Shutdown(); socket_ 105 ppapi/shared_impl/ppb_audio_shared.cc socket_.reset(new base::CancelableSyncSocket(socket_handle)); socket_ 132 ppapi/shared_impl/ppb_audio_shared.cc if (!playing_ || !callback_.IsValid() || !socket_.get() || socket_ 201 ppapi/shared_impl/ppb_audio_shared.cc socket_->Receive(&pending_data, sizeof(pending_data))) { socket_ 221 ppapi/shared_impl/ppb_audio_shared.cc size_t bytes_sent = socket_->Send(&buffer_index_, sizeof(buffer_index_)); socket_ 103 ppapi/shared_impl/ppb_audio_shared.h scoped_ptr<base::CancelableSyncSocket> socket_; socket_ 37 ppapi/tests/extensions/socket/test_socket.cc socket_(InstanceHandle(instance)), socket_ 104 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Create( socket_ 116 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Listen( socket_ 129 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Create( socket_ 141 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Connect( socket_ 153 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Accept(socket_id, callback.GetCallback())); socket_ 167 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Write(client_socket_id, array_buffer, socket_ 180 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Read( socket_ 193 ppapi/tests/extensions/socket/test_socket.cc socket_.Destroy(client_socket_id); socket_ 194 ppapi/tests/extensions/socket/test_socket.cc socket_.Destroy(accepted_socket_id); socket_ 195 ppapi/tests/extensions/socket/test_socket.cc socket_.Destroy(socket_id); socket_ 204 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Create( socket_ 216 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.SetMulticastTimeToLive( socket_ 224 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.SetMulticastTimeToLive( socket_ 234 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.SetMulticastLoopbackMode( socket_ 242 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.SetMulticastLoopbackMode( socket_ 248 ppapi/tests/extensions/socket/test_socket.cc socket_.Destroy(socket_id); socket_ 255 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Create( socket_ 267 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Bind( socket_ 275 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.JoinGroup( socket_ 284 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.GetJoinedGroups( socket_ 299 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Create( socket_ 311 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.SetMulticastTimeToLive( socket_ 319 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Connect( socket_ 335 ppapi/tests/extensions/socket/test_socket.cc int32_t recv_from_result = socket_.RecvFrom( socket_ 342 ppapi/tests/extensions/socket/test_socket.cc write_callback.WaitForResult(socket_.Write( socket_ 373 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.LeaveGroup( socket_ 379 ppapi/tests/extensions/socket/test_socket.cc socket_.Destroy(server_socket_id); socket_ 380 ppapi/tests/extensions/socket/test_socket.cc socket_.Destroy(client_socket_id); socket_ 393 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Create( socket_ 406 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.GetInfo(socket_id, socket_ 427 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Connect( socket_ 435 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.Bind( socket_ 447 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.GetInfo(socket_id, socket_ 485 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.SetNoDelay( socket_ 500 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.SetKeepAlive( socket_ 521 ppapi/tests/extensions/socket/test_socket.cc int32_t read_result = socket_.Read(socket_id, Optional<int32_t>(), socket_ 528 ppapi/tests/extensions/socket/test_socket.cc write_callback.WaitForResult(socket_.Write( socket_ 544 ppapi/tests/extensions/socket/test_socket.cc int32_t recv_from_result = socket_.RecvFrom( socket_ 551 ppapi/tests/extensions/socket/test_socket.cc send_to_callback.WaitForResult(socket_.SendTo( socket_ 588 ppapi/tests/extensions/socket/test_socket.cc callback.WaitForResult(socket_.GetNetworkList(callback.GetCallback())); socket_ 595 ppapi/tests/extensions/socket/test_socket.cc socket_.Destroy(socket_id); socket_ 629 ppapi/tests/extensions/socket/test_socket.cc socket::Socket_Dev socket_; socket_ 22 remoting/base/socket_reader.cc : socket_(NULL), socket_ 32 remoting/base/socket_reader.cc DCHECK(!socket_); socket_ 34 remoting/base/socket_reader.cc socket_ = socket; socket_ 42 remoting/base/socket_reader.cc int result = socket_->Read( socket_ 44 remoting/base/socket_reader.h net::Socket* socket_; socket_ 77 remoting/client/plugin/pepper_packet_socket_factory.cc pp::UDPSocket socket_; socket_ 111 remoting/client/plugin/pepper_packet_socket_factory.cc socket_(instance), socket_ 128 remoting/client/plugin/pepper_packet_socket_factory.cc if (socket_.is_null()) { socket_ 144 remoting/client/plugin/pepper_packet_socket_factory.cc int result = socket_.Bind(pp_local_address, callback); socket_ 160 remoting/client/plugin/pepper_packet_socket_factory.cc pp::NetAddress address = socket_.GetBoundAddress(); socket_ 176 remoting/client/plugin/pepper_packet_socket_factory.cc int result = socket_.Bind(pp_local_address, callback); socket_ 233 remoting/client/plugin/pepper_packet_socket_factory.cc socket_.Close(); socket_ 265 remoting/client/plugin/pepper_packet_socket_factory.cc int result = socket_.SendTo( socket_ 316 remoting/client/plugin/pepper_packet_socket_factory.cc socket_.RecvFrom(&receive_buffer_[0], receive_buffer_.size(), callback); socket_ 44 remoting/host/gnubby_auth_handler_posix.cc explicit CompareSocket(net::StreamListenSocket* socket) : socket_(socket) {} socket_ 47 remoting/host/gnubby_auth_handler_posix.cc return element.second->IsSocket(socket_); socket_ 51 remoting/host/gnubby_auth_handler_posix.cc net::StreamListenSocket* socket_; socket_ 26 remoting/host/gnubby_socket.cc : socket_(socket.Pass()) { socket_ 71 remoting/host/gnubby_socket.cc socket_->Send(GetResponseLengthAsBytes(response_data)); socket_ 72 remoting/host/gnubby_socket.cc socket_->Send(response_data); socket_ 83 remoting/host/gnubby_socket.cc return socket == socket_.get(); socket_ 67 remoting/host/gnubby_socket.h scoped_ptr<net::StreamListenSocket> socket_; socket_ 80 remoting/jingle_glue/chromium_socket_factory.cc scoped_ptr<net::UDPServerSocket> socket_; socket_ 127 remoting/jingle_glue/chromium_socket_factory.cc socket_.reset(new net::UDPServerSocket(NULL, net::NetLog::Source())); socket_ 128 remoting/jingle_glue/chromium_socket_factory.cc int result = socket_->Listen( socket_ 133 remoting/jingle_glue/chromium_socket_factory.cc socket_.reset(); socket_ 137 remoting/jingle_glue/chromium_socket_factory.cc if (!socket_.get()) { socket_ 142 remoting/jingle_glue/chromium_socket_factory.cc if (socket_->GetLocalAddress(&local_endpoint) != net::OK || socket_ 202 remoting/jingle_glue/chromium_socket_factory.cc socket_.reset(); socket_ 228 remoting/jingle_glue/chromium_socket_factory.cc int net_error = socket_->SetReceiveBufferSize(value); socket_ 233 remoting/jingle_glue/chromium_socket_factory.cc int net_error = socket_->SetSendBufferSize(value); socket_ 272 remoting/jingle_glue/chromium_socket_factory.cc int result = socket_->SendTo( socket_ 306 remoting/jingle_glue/chromium_socket_factory.cc result = socket_->RecvFrom( socket_ 22 remoting/jingle_glue/chromium_socket_factory_unittest.cc socket_.reset(socket_factory_->CreateUdpSocket( socket_ 24 remoting/jingle_glue/chromium_socket_factory_unittest.cc ASSERT_TRUE(socket_.get() != NULL); socket_ 25 remoting/jingle_glue/chromium_socket_factory_unittest.cc EXPECT_EQ(socket_->GetState(), talk_base::AsyncPacketSocket::STATE_BOUND); socket_ 26 remoting/jingle_glue/chromium_socket_factory_unittest.cc socket_->SignalReadPacket.connect( socket_ 34 remoting/jingle_glue/chromium_socket_factory_unittest.cc EXPECT_EQ(socket, socket_.get()); socket_ 45 remoting/jingle_glue/chromium_socket_factory_unittest.cc scoped_ptr<talk_base::AsyncPacketSocket> socket_; socket_ 71 remoting/jingle_glue/chromium_socket_factory_unittest.cc socket_->GetLocalAddress(), options); socket_ 81 remoting/jingle_glue/chromium_socket_factory_unittest.cc EXPECT_EQ(0, socket_->SetOption(talk_base::Socket::OPT_SNDBUF, 4096)); socket_ 82 remoting/jingle_glue/chromium_socket_factory_unittest.cc EXPECT_EQ(0, socket_->SetOption(talk_base::Socket::OPT_RCVBUF, 4096)); socket_ 88 remoting/jingle_glue/chromium_socket_factory_unittest.cc socket_.reset(socket_factory_->CreateUdpSocket( socket_ 90 remoting/jingle_glue/chromium_socket_factory_unittest.cc ASSERT_TRUE(socket_.get() != NULL); socket_ 91 remoting/jingle_glue/chromium_socket_factory_unittest.cc EXPECT_EQ(socket_->GetState(), talk_base::AsyncPacketSocket::STATE_BOUND); socket_ 92 remoting/jingle_glue/chromium_socket_factory_unittest.cc EXPECT_GE(socket_->GetLocalAddress().port(), kMinPort); socket_ 93 remoting/jingle_glue/chromium_socket_factory_unittest.cc EXPECT_LE(socket_->GetLocalAddress().port(), kMaxPort); socket_ 30 remoting/protocol/buffered_socket_writer.cc socket_(NULL), socket_ 40 remoting/protocol/buffered_socket_writer.cc socket_ = socket; socket_ 47 remoting/protocol/buffered_socket_writer.cc DCHECK(socket_); socket_ 65 remoting/protocol/buffered_socket_writer.cc DCHECK(socket_); socket_ 84 remoting/protocol/buffered_socket_writer.cc int result = socket_->Write( socket_ 94 remoting/protocol/buffered_socket_writer.h net::Socket* socket_; socket_ 38 remoting/protocol/buffered_socket_writer_unittest.cc written_data_ = socket_->written_data(); socket_ 40 remoting/protocol/buffered_socket_writer_unittest.cc socket_.reset(); socket_ 51 remoting/protocol/buffered_socket_writer_unittest.cc socket_.reset(new FakeSocket()); socket_ 53 remoting/protocol/buffered_socket_writer_unittest.cc writer_->Init(socket_.get(), base::Bind( socket_ 75 remoting/protocol/buffered_socket_writer_unittest.cc socket_->written_data().size()); socket_ 76 remoting/protocol/buffered_socket_writer_unittest.cc EXPECT_EQ(0, memcmp(test_buffer_->data(), socket_->written_data().data(), socket_ 79 remoting/protocol/buffered_socket_writer_unittest.cc socket_->written_data().data() + test_buffer_->size(), socket_ 92 remoting/protocol/buffered_socket_writer_unittest.cc socket_->written_data().size()); socket_ 93 remoting/protocol/buffered_socket_writer_unittest.cc EXPECT_EQ(0, memcmp(test_buffer_->data(), socket_->written_data().data(), socket_ 96 remoting/protocol/buffered_socket_writer_unittest.cc socket_->written_data().data() + test_buffer_->size(), socket_ 101 remoting/protocol/buffered_socket_writer_unittest.cc scoped_ptr<FakeSocket> socket_; socket_ 116 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_write_limit(kWriteChunkSize); socket_ 122 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_async_write(true); socket_ 123 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_write_limit(kWriteChunkSize); socket_ 134 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_async_write(true); socket_ 135 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_write_limit(kWriteChunkSize); socket_ 141 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_async_write(true); socket_ 148 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_async_write(false); socket_ 158 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_write_limit(kWriteChunkSize); socket_ 160 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_async_write(true); socket_ 164 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_next_write_error(net::ERR_FAILED); socket_ 165 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_async_write(false); socket_ 169 remoting/protocol/buffered_socket_writer_unittest.cc socket_->written_data().size()); socket_ 174 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_write_limit(kWriteChunkSize); socket_ 176 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_async_write(true); socket_ 180 remoting/protocol/buffered_socket_writer_unittest.cc socket_->set_next_write_error(net::ERR_FAILED); socket_ 184 remoting/protocol/buffered_socket_writer_unittest.cc socket_->written_data().size()); socket_ 96 remoting/protocol/channel_multiplexer.cc MuxSocket* socket_; socket_ 209 remoting/protocol/channel_multiplexer.cc DCHECK(!socket_); socket_ 214 remoting/protocol/channel_multiplexer.cc DCHECK(!socket_); // Can't create more than one socket per channel. socket_ 216 remoting/protocol/channel_multiplexer.cc socket_ = result.get(); socket_ 226 remoting/protocol/channel_multiplexer.cc if (socket_) { socket_ 228 remoting/protocol/channel_multiplexer.cc socket_->OnPacketReceived(); socket_ 234 remoting/protocol/channel_multiplexer.cc if (socket_) socket_ 235 remoting/protocol/channel_multiplexer.cc socket_->OnWriteFailed(); socket_ 239 remoting/protocol/channel_multiplexer.cc DCHECK(socket_); socket_ 240 remoting/protocol/channel_multiplexer.cc socket_ = NULL; socket_ 32 remoting/protocol/fake_authenticator.cc socket_ = socket.Pass(); socket_ 40 remoting/protocol/fake_authenticator.cc socket_->Write(write_buf.get(), socket_ 52 remoting/protocol/fake_authenticator.cc socket_->Read(read_buf.get(), socket_ 60 remoting/protocol/fake_authenticator.cc socket_.reset(); socket_ 61 remoting/protocol/fake_authenticator.cc done_callback.Run(result_, socket_.Pass()); socket_ 70 remoting/protocol/fake_authenticator.cc done_callback_.Run(result_, socket_.Pass()); socket_ 78 remoting/protocol/fake_authenticator.cc done_callback_.Run(result_, socket_.Pass()); socket_ 37 remoting/protocol/fake_authenticator.h scoped_ptr<net::StreamSocket> socket_; socket_ 118 remoting/protocol/libjingle_transport_factory.cc scoped_ptr<jingle_glue::PseudoTcpAdapter> socket_; socket_ 141 remoting/protocol/libjingle_transport_factory.cc DCHECK(!is_connected() || socket_.get() == NULL); socket_ 230 remoting/protocol/libjingle_transport_factory.cc socket_.reset( socket_ 232 remoting/protocol/libjingle_transport_factory.cc socket_->SetSendBufferSize(kTcpSendBufferSize); socket_ 233 remoting/protocol/libjingle_transport_factory.cc socket_->SetReceiveBufferSize(kTcpReceiveBufferSize); socket_ 234 remoting/protocol/libjingle_transport_factory.cc socket_->SetNoDelay(true); socket_ 235 remoting/protocol/libjingle_transport_factory.cc socket_->SetAckDelay(kTcpAckDelayMilliseconds); socket_ 241 remoting/protocol/libjingle_transport_factory.cc socket_->SetWriteWaitsForSend(true); socket_ 243 remoting/protocol/libjingle_transport_factory.cc int result = socket_->Connect( socket_ 339 remoting/protocol/libjingle_transport_factory.cc socket_.PassAs<net::StreamSocket>(), socket_ 391 remoting/protocol/libjingle_transport_factory.cc socket_.reset(); socket_ 25 remoting/protocol/message_reader.cc : socket_(NULL), socket_ 37 remoting/protocol/message_reader.cc socket_ = socket; socket_ 50 remoting/protocol/message_reader.cc int result = socket_->Read( socket_ 56 remoting/protocol/message_reader.h net::Socket* socket_; socket_ 79 remoting/protocol/message_reader_unittest.cc reader_->Init(&socket_, base::Bind( socket_ 87 remoting/protocol/message_reader_unittest.cc socket_.AppendInputData(std::vector<char>(data.begin(), data.end())); socket_ 104 remoting/protocol/message_reader_unittest.cc FakeSocket socket_; socket_ 124 remoting/protocol/message_reader_unittest.cc Mock::VerifyAndClearExpectations(&socket_); socket_ 130 remoting/protocol/message_reader_unittest.cc EXPECT_FALSE(socket_.read_pending()); socket_ 134 remoting/protocol/message_reader_unittest.cc EXPECT_TRUE(socket_.read_pending()); socket_ 148 remoting/protocol/message_reader_unittest.cc EXPECT_TRUE(socket_.read_pending()); socket_ 169 remoting/protocol/message_reader_unittest.cc Mock::VerifyAndClearExpectations(&socket_); socket_ 176 remoting/protocol/message_reader_unittest.cc EXPECT_FALSE(socket_.read_pending()); socket_ 181 remoting/protocol/message_reader_unittest.cc EXPECT_FALSE(socket_.read_pending()); socket_ 186 remoting/protocol/message_reader_unittest.cc EXPECT_TRUE(socket_.read_pending()); socket_ 206 remoting/protocol/message_reader_unittest.cc Mock::VerifyAndClearExpectations(&socket_); socket_ 212 remoting/protocol/message_reader_unittest.cc EXPECT_FALSE(socket_.read_pending()); socket_ 216 remoting/protocol/message_reader_unittest.cc EXPECT_TRUE(socket_.read_pending()); socket_ 233 remoting/protocol/message_reader_unittest.cc EXPECT_TRUE(socket_.read_pending()); socket_ 250 remoting/protocol/message_reader_unittest.cc Mock::VerifyAndClearExpectations(&socket_); socket_ 256 remoting/protocol/message_reader_unittest.cc EXPECT_FALSE(socket_.read_pending()); socket_ 261 remoting/protocol/message_reader_unittest.cc EXPECT_TRUE(socket_.read_pending()); socket_ 274 remoting/protocol/message_reader_unittest.cc EXPECT_FALSE(socket_.read_pending()); socket_ 278 remoting/protocol/message_reader_unittest.cc EXPECT_TRUE(socket_.read_pending()); socket_ 283 remoting/protocol/message_reader_unittest.cc socket_.set_next_read_error(net::ERR_FAILED); socket_ 306 remoting/protocol/message_reader_unittest.cc EXPECT_TRUE(socket_.read_pending()); socket_ 85 remoting/protocol/ssl_hmac_channel_authenticator.cc socket_ = server_socket.Pass(); socket_ 112 remoting/protocol/ssl_hmac_channel_authenticator.cc socket_ = socket_ 116 remoting/protocol/ssl_hmac_channel_authenticator.cc result = socket_->Connect( socket_ 140 remoting/protocol/ssl_hmac_channel_authenticator.cc socket_.get(), is_ssl_server() ? socket_ 167 remoting/protocol/ssl_hmac_channel_authenticator.cc int result = socket_->Write( socket_ 208 remoting/protocol/ssl_hmac_channel_authenticator.cc socket_->Read(auth_read_buf_.get(), socket_ 255 remoting/protocol/ssl_hmac_channel_authenticator.cc socket_.get(), is_ssl_server() ? socket_ 266 remoting/protocol/ssl_hmac_channel_authenticator.cc DCHECK(socket_.get() != NULL); socket_ 269 remoting/protocol/ssl_hmac_channel_authenticator.cc done_callback_.Run(net::OK, socket_.PassAs<net::StreamSocket>()); socket_ 95 remoting/protocol/ssl_hmac_channel_authenticator.h scoped_ptr<net::SSLSocket> socket_; socket_ 155 tools/android/forwarder/forwarder.cc if (socket_ >= 0) socket_ 156 tools/android/forwarder/forwarder.cc shutdown(socket_, SHUT_RDWR); socket_ 183 tools/android/forwarder/forwarder.cc int socket_; socket_ 267 tools/android/forwarder/forwarder.cc int socket = HANDLE_EINTR(accept(server->socket_, socket_ 301 tools/android/forwarder/forwarder.cc CloseSocket(server->socket_); socket_ 302 tools/android/forwarder/forwarder.cc server->socket_ = -1; socket_ 319 tools/android/forwarder/forwarder.cc socket_ = socket(AF_INET, SOCK_STREAM, 0); socket_ 320 tools/android/forwarder/forwarder.cc if (socket_ < 0) { socket_ 324 tools/android/forwarder/forwarder.cc tools::DisableNagle(socket_); socket_ 332 tools/android/forwarder/forwarder.cc setsockopt(socket_, SOL_SOCKET, SO_REUSEADDR, socket_ 334 tools/android/forwarder/forwarder.cc tools::DeferAccept(socket_); socket_ 335 tools/android/forwarder/forwarder.cc if (HANDLE_EINTR(bind(socket_, reinterpret_cast<sockaddr*>(&addr), socket_ 337 tools/android/forwarder/forwarder.cc HANDLE_EINTR(listen(socket_, 5)) < 0) { socket_ 339 tools/android/forwarder/forwarder.cc CloseSocket(socket_); socket_ 340 tools/android/forwarder/forwarder.cc socket_ = -1; socket_ 346 tools/android/forwarder/forwarder.cc if (getsockname(socket_, reinterpret_cast<sockaddr*>(&addr), &addrlen) socket_ 349 tools/android/forwarder/forwarder.cc CloseSocket(socket_); socket_ 350 tools/android/forwarder/forwarder.cc socket_ = -1; socket_ 71 tools/android/forwarder2/socket.cc : socket_(-1), socket_ 86 tools/android/forwarder2/socket.cc PRESERVE_ERRNO_HANDLE_EINTR(shutdown(socket_, SHUT_RDWR)); socket_ 92 tools/android/forwarder2/socket.cc CloseFD(socket_); socket_ 93 tools/android/forwarder2/socket.cc socket_ = -1; socket_ 98 tools/android/forwarder2/socket.cc socket_ = socket(family_, SOCK_STREAM, 0); socket_ 99 tools/android/forwarder2/socket.cc if (socket_ < 0) { socket_ 103 tools/android/forwarder2/socket.cc tools::DisableNagle(socket_); socket_ 105 tools/android/forwarder2/socket.cc setsockopt(socket_, SOL_SOCKET, SO_REUSEADDR, &reuse_addr, socket_ 113 tools/android/forwarder2/socket.cc const int flags = fcntl(socket_, F_GETFL); socket_ 120 tools/android/forwarder2/socket.cc if (fcntl(socket_, F_SETFL, flags | O_NONBLOCK) < 0) { socket_ 174 tools/android/forwarder2/socket.cc if (HANDLE_EINTR(bind(socket_, addr_ptr_, addr_len_)) < 0 || socket_ 175 tools/android/forwarder2/socket.cc HANDLE_EINTR(listen(socket_, SOMAXCONN)) < 0) { socket_ 196 tools/android/forwarder2/socket.cc if (getsockname(socket_, addr_ptr, &addrlen) != 0) { socket_ 213 tools/android/forwarder2/socket.cc int new_socket_fd = HANDLE_EINTR(accept(socket_, NULL, NULL)); socket_ 219 tools/android/forwarder2/socket.cc new_socket->socket_ = new_socket_fd; socket_ 226 tools/android/forwarder2/socket.cc DCHECK(fcntl(socket_, F_GETFL) & O_NONBLOCK); socket_ 228 tools/android/forwarder2/socket.cc if (HANDLE_EINTR(connect(socket_, addr_ptr_, addr_len_)) < 0 && socket_ 240 tools/android/forwarder2/socket.cc if (getsockopt(socket_, SOL_SOCKET, SO_ERROR, &socket_errno, &opt_len) < 0) { socket_ 316 tools/android/forwarder2/socket.cc int ret = HANDLE_EINTR(read(socket_, buffer, buffer_size)); socket_ 325 tools/android/forwarder2/socket.cc DCHECK(fcntl(socket_, F_GETFL) & O_NONBLOCK); socket_ 326 tools/android/forwarder2/socket.cc int ret = HANDLE_EINTR(read(socket_, buffer, buffer_size)); socket_ 339 tools/android/forwarder2/socket.cc int ret = HANDLE_EINTR(send(socket_, buffer, count, MSG_NOSIGNAL)); socket_ 348 tools/android/forwarder2/socket.cc DCHECK(fcntl(socket_, F_GETFL) & O_NONBLOCK); socket_ 349 tools/android/forwarder2/socket.cc int ret = HANDLE_EINTR(send(socket_, buffer, count, MSG_NOSIGNAL)); socket_ 395 tools/android/forwarder2/socket.cc if (socket_ == -1) socket_ 397 tools/android/forwarder2/socket.cc DCHECK(fcntl(socket_, F_GETFL) & O_NONBLOCK); socket_ 403 tools/android/forwarder2/socket.cc FD_SET(socket_, &read_fds); socket_ 405 tools/android/forwarder2/socket.cc FD_SET(socket_, &write_fds); socket_ 415 tools/android/forwarder2/socket.cc int max_fd = socket_; socket_ 441 tools/android/forwarder2/socket.cc if (getsockopt(socket.socket_, SOL_SOCKET, SO_PEERCRED, &ucred, &len) == -1) { socket_ 38 tools/android/forwarder2/socket.h bool IsClosed() const { return socket_ < 0; } socket_ 40 tools/android/forwarder2/socket.h int fd() const { return socket_; } socket_ 129 tools/android/forwarder2/socket.h int socket_;