/external/chromium_org/third_party/webrtc/base/ |
H A D | asyncsocket.cc | 21 AsyncSocketAdapter::AsyncSocketAdapter(AsyncSocket* socket) : socket_(NULL) { 26 delete socket_; 30 ASSERT(!socket_); 31 socket_ = socket; 32 if (socket_) { 33 socket_->SignalConnectEvent.connect(this, 35 socket_->SignalReadEvent.connect(this, 37 socket_->SignalWriteEvent.connect(this, 39 socket_->SignalCloseEvent.connect(this,
|
H A D | socketstream.cc | 15 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) { 20 delete socket_; 24 if (socket_) 25 delete socket_; 26 socket_ = socket; 27 if (socket_) { 28 socket_->SignalConnectEvent.connect(this, &SocketStream::OnConnectEvent); 29 socket_->SignalReadEvent.connect(this, &SocketStream::OnReadEvent); 30 socket_->SignalWriteEvent.connect(this, &SocketStream::OnWriteEvent); 31 socket_ [all...] |
H A D | asynctcpsocket_unittest.cc | 28 socket_(vss_->CreateAsyncSocket(SOCK_STREAM)), 29 tcp_socket_(new AsyncTCPSocket(socket_, true)), 42 AsyncSocket* socket_; member in class:rtc::AsyncTCPSocketTest 49 socket_->SignalWriteEvent(socket_);
|
H A D | asyncudpsocket_unittest.cc | 28 socket_(vss_->CreateAsyncSocket(SOCK_DGRAM)), 29 udp_socket_(new AsyncUDPSocket(socket_)), 42 AsyncSocket* socket_; member in class:rtc::AsyncUdpSocketTest 49 socket_->SignalWriteEvent(socket_);
|
H A D | asyncsocket.h | 54 return socket_->GetLocalAddress(); 57 return socket_->GetRemoteAddress(); 60 return socket_->Bind(addr); 63 return socket_->Connect(addr); 66 return socket_->Send(pv, cb); 69 return socket_->SendTo(pv, cb, addr); 72 return socket_->Recv(pv, cb); 75 return socket_->RecvFrom(pv, cb, paddr); 78 return socket_->Listen(backlog); 81 return socket_ 119 AsyncSocket* socket_; member in class:rtc::AsyncSocketAdapter [all...] |
H A D | asyncudpsocket.cc | 39 : socket_(socket) { 40 ASSERT(socket_); 45 socket_->SignalReadEvent.connect(this, &AsyncUDPSocket::OnReadEvent); 46 socket_->SignalWriteEvent.connect(this, &AsyncUDPSocket::OnWriteEvent); 54 return socket_->GetLocalAddress(); 58 return socket_->GetRemoteAddress(); 63 return socket_->Send(pv, cb); 69 return socket_->SendTo(pv, cb, addr); 73 return socket_->Close(); 81 return socket_ [all...] |
H A D | asynctcpsocket.cc | 53 : socket_(socket), 62 ASSERT(socket_.get() != NULL); 63 socket_->SignalConnectEvent.connect( 65 socket_->SignalReadEvent.connect(this, &AsyncTCPSocketBase::OnReadEvent); 66 socket_->SignalWriteEvent.connect(this, &AsyncTCPSocketBase::OnWriteEvent); 67 socket_->SignalCloseEvent.connect(this, &AsyncTCPSocketBase::OnCloseEvent); 70 if (socket_->Listen(kListenBacklog) < 0) { 71 LOG(LS_ERROR) << "Listen() failed with error " << socket_->GetError(); 82 return socket_->GetLocalAddress(); 86 return socket_ [all...] |
H A D | natsocketfactory.cc | 72 socket_(NULL), buf_(NULL), size_(0) { 76 delete socket_; 81 return (socket_) ? socket_->GetLocalAddress() : SocketAddress(); 89 if (socket_) { // already bound, bubble up error 94 socket_ = sf_->CreateInternalSocket(family_, type_, addr, &server_addr_); 95 result = (socket_) ? socket_->Bind(addr) : -1; 97 socket_->SignalConnectEvent.connect(this, &NATSocket::OnConnectEvent); 98 socket_ 301 AsyncSocket* socket_; member in class:rtc::NATSocket [all...] |
/external/chromium_org/net/udp/ |
H A D | udp_server_socket.cc | 13 : socket_(DatagramSocket::DEFAULT_BIND, 23 return socket_.Bind(address); 30 return socket_.RecvFrom(buf, buf_len, address, callback); 37 return socket_.SendTo(buf, buf_len, address, callback); 41 return socket_.SetReceiveBufferSize(size); 45 return socket_.SetSendBufferSize(size); 49 socket_.Close(); 53 return socket_.GetPeerAddress(address); 57 return socket_.GetLocalAddress(address); 61 return socket_ [all...] |
H A D | udp_client_socket.cc | 15 : socket_(bind_type, rand_int_cb, net_log, source) { 22 return socket_.Connect(address); 28 return socket_.Read(buf, buf_len, callback); 34 return socket_.Write(buf, buf_len, callback); 38 socket_.Close(); 42 return socket_.GetPeerAddress(address); 46 return socket_.GetLocalAddress(address); 50 return socket_.SetReceiveBufferSize(size); 54 return socket_.SetSendBufferSize(size); 58 return socket_ [all...] |
/external/chromium_org/extensions/browser/api/cast_channel/ |
H A D | cast_socket_unittest.cc | 369 if (socket_.get()) { 371 socket_->Close(base::Bind(&CompleteHandler::OnCloseComplete, 395 socket_ = TestCastSocket::Create(&mock_delegate_, logger_.get()); 399 socket_ = TestCastSocket::CreateSecure(&mock_delegate_, logger_.get()); 406 socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK); 407 socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::OK); 408 socket_->AddReadResult(net::ASYNC, net::ERR_IO_PENDING); 411 socket_->Connect(base::Bind(&CompleteHandler::OnConnectComplete, 426 scoped_ptr<TestCastSocket> socket_; member in class:extensions::core_api::cast_channel::CastSocketTest 440 EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_ [all...] |
/external/chromium_org/net/socket/ |
H A D | unix_domain_client_socket_posix.cc | 27 socket_(socket.Pass()) { 70 DCHECK(!socket_); 79 socket_.reset(new SocketLibevent); 80 int rv = socket_->Open(AF_UNIX); 85 return socket_->Connect(address, callback); 89 socket_.reset(); 93 return socket_ && socket_->IsConnected(); 97 return socket_ && socket_ [all...] |
H A D | tcp_client_socket.cc | 19 : socket_(new TCPSocket(net_log, source)), 28 : socket_(connected_socket.Pass()), 33 DCHECK(socket_); 35 socket_->SetDefaultOptionsForClient(); 50 if (!socket_->IsValid()) { 56 result = socket_->Bind(address); 68 if (socket_->IsValid() && current_address_index_ >= 0) 71 socket_->StartLoggingMultipleConnectAttempts(addresses_); 82 socket_->EndLoggingMultipleConnectAttempts(rv); 126 if (socket_ [all...] |
H A D | tcp_server_socket.cc | 16 : socket_(net_log, source), 24 int result = socket_.Open(address.GetFamily()); 28 result = socket_.SetDefaultOptionsForServer(); 30 socket_.Close(); 34 result = socket_.Bind(address); 36 socket_.Close(); 40 result = socket_.Listen(backlog); 42 socket_.Close(); 50 return socket_.GetLocalAddress(address); 63 // It is safe to use base::Unretained(this). |socket_| i [all...] |
H A D | tcp_socket_libevent.cc | 149 DCHECK(!socket_); 150 socket_.reset(new SocketLibevent); 151 int rv = socket_->Open(ConvertAddressFamily(family)); 153 socket_.reset(); 159 DCHECK(!socket_); 168 socket_.reset(new SocketLibevent); 169 int rv = socket_->AdoptConnectedSocket(socket_fd, storage); 171 socket_.reset(); 176 DCHECK(socket_); 182 return socket_ [all...] |
/external/chromium_org/net/socket_stream/ |
H A D | socket_stream_job.cc | 45 return socket_->GetUserData(key); 50 socket_->SetUserData(key, data); 54 socket_->Connect(); 58 return socket_->SendData(data, len); 62 socket_->Close(); 66 socket_->RestartWithAuth(credentials); 70 socket_->CancelWithError(error); 74 socket_->CancelWithSSLError(ssl_info); 78 socket_->ContinueDespiteError(); 82 socket_ [all...] |
H A D | socket_stream_job.h | 51 socket_ = socket; 58 return socket_.get() ? socket_->context() : 0; 61 return socket_.get() ? socket_->cookie_store() : 0; 87 scoped_refptr<SocketStream> socket_; member in class:net::SocketStreamJob
|
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
H A D | teststunserver.h | 42 : socket_(thread->socketserver()->CreateAsyncSocket(addr.family(), 44 udp_socket_(rtc::AsyncUDPSocket::Create(socket_, addr)), 48 rtc::AsyncSocket* socket_; member in class:cricket::TestStunServer
|
H A D | tcpport.cc | 45 socket_(NULL), 55 socket_ = socket_factory()->CreateServerTcpSocket( 58 if (!socket_) { 62 socket_->SignalNewConnection.connect(this, &TCPPort::OnNewConnection); 63 socket_->SignalAddressReady.connect(this, &TCPPort::OnAddressReady); 69 delete socket_; 122 if (socket_) { 127 << socket_->GetState(); 128 if (socket_->GetState() == rtc::AsyncPacketSocket::STATE_BOUND || 129 socket_ [all...] |
/external/chromium_org/base/ |
H A D | async_socket_io_handler_posix.cc | 14 : socket_(base::SyncSocket::kInvalidHandle), 26 DCHECK_EQ(socket, socket_); 30 int bytes_read = HANDLE_EINTR(read(socket_, pending_buffer_, 52 int bytes_read = HANDLE_EINTR(read(socket_, buffer, buffer_len)); 69 DCHECK_EQ(socket_, base::SyncSocket::kInvalidHandle); 73 socket_ = socket; 91 if (!is_watching_ && socket_ != base::SyncSocket::kInvalidHandle) { 93 socket_, true, base::MessageLoopForIO::WATCH_READ,
|
H A D | async_socket_io_handler_win.cc | 10 : socket_(base::SyncSocket::kInvalidHandle), 45 DCHECK_NE(socket_, base::SyncSocket::kInvalidHandle); 48 BOOL ok = ::ReadFile(socket_, buffer, buffer_len, &bytes_read, 61 DCHECK_EQ(socket_, base::SyncSocket::kInvalidHandle); 65 socket_ = socket;
|
/external/chromium_org/remoting/protocol/ |
H A D | chromium_socket_factory_unittest.cc | 23 socket_.reset(socket_factory_->CreateUdpSocket( 25 ASSERT_TRUE(socket_.get() != NULL); 26 EXPECT_EQ(socket_->GetState(), rtc::AsyncPacketSocket::STATE_BOUND); 27 socket_->SignalReadPacket.connect( 35 EXPECT_EQ(socket, socket_.get()); 50 socket_->GetLocalAddress(), options); 64 scoped_ptr<rtc::AsyncPacketSocket> socket_; member in class:remoting::protocol::ChromiumSocketFactoryTest 82 EXPECT_EQ(0, socket_->SetOption(rtc::Socket::OPT_SNDBUF, 4096)); 83 EXPECT_EQ(0, socket_->SetOption(rtc::Socket::OPT_RCVBUF, 4096)); 89 socket_ [all...] |
H A D | buffered_socket_writer_unittest.cc | 38 written_data_ = socket_->written_data(); 40 socket_.reset(); 51 socket_.reset(new FakeStreamSocket()); 53 writer_->Init(socket_.get(), base::Bind( 75 socket_->written_data().size()); 76 EXPECT_EQ(0, memcmp(test_buffer_->data(), socket_->written_data().data(), 79 socket_->written_data().data() + test_buffer_->size(), 92 socket_->written_data().size()); 93 EXPECT_EQ(0, memcmp(test_buffer_->data(), socket_->written_data().data(), 96 socket_ 101 scoped_ptr<FakeStreamSocket> socket_; member in class:remoting::protocol::BufferedSocketWriterTest [all...] |
H A D | message_reader_unittest.cc | 79 reader_->Init(&socket_, base::Bind( 87 socket_.AppendInputData(data); 104 FakeStreamSocket socket_; member in class:remoting::protocol::MessageReaderTest 124 Mock::VerifyAndClearExpectations(&socket_); 130 EXPECT_FALSE(socket_.read_pending()); 134 EXPECT_TRUE(socket_.read_pending()); 148 EXPECT_TRUE(socket_.read_pending()); 169 Mock::VerifyAndClearExpectations(&socket_); 176 EXPECT_FALSE(socket_.read_pending()); 181 EXPECT_FALSE(socket_ [all...] |
/external/chromium_org/extensions/browser/api/bluetooth_socket/ |
H A D | bluetooth_api_socket.cc | 47 socket_(socket), 59 if (socket_.get()) 60 socket_->Close(); 69 if (socket_.get()) 70 socket_->Close(); 72 socket_ = socket; 83 if (socket_.get()) 84 socket_->Close(); 86 socket_ = socket; 95 if (!socket_ [all...] |