| /external/chromium_org/third_party/webrtc/base/ |
| 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,
|
| 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_->SignalCloseEvent.connect(this, &SocketStream::OnCloseEvent)
[all...] |
| 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_);
|
| 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_);
|
| 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_->Accept(paddr)
119 AsyncSocket* socket_; member in class:rtc::AsyncSocketAdapter
[all...] |
| 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_->GetOption(opt, value)
[all...] |
| 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_->GetRemoteAddress()
[all...] |
| 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_->SignalReadEvent.connect(this, &NATSocket::OnReadEvent)
301 AsyncSocket* socket_; member in class:rtc::NATSocket
[all...] |
| /external/chromium_org/net/udp/ |
| 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_.NetLog()
[all...] |
| 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_.NetLog()
[all...] |
| /external/chromium_org/extensions/browser/api/cast_channel/ |
| 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_->ready_state())
[all...] |
| /external/chromium_org/net/socket/ |
| 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_->IsConnectedAndIdle()
[all...] |
| 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_->IsValid())
[all...] |
| 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_| is owned by this class
[all...] |
| 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_->Bind(storage)
[all...] |
| /external/chromium_org/net/socket_stream/ |
| 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_->DetachDelegate()
[all...] |
| 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/ |
| 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
|
| 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_->GetState() == rtc::AsyncPacketSocket::STATE_CLOSED
[all...] |
| /external/chromium_org/base/ |
| 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,
|
| /external/chromium_org/remoting/protocol/ |
| 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_.reset(socket_factory_->CreateUdpSocket
[all...] |
| 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_->written_data().data() + test_buffer_->size()
101 scoped_ptr<FakeStreamSocket> socket_; member in class:remoting::protocol::BufferedSocketWriterTest
[all...] |
| 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_.read_pending())
[all...] |
| /external/chromium_org/extensions/browser/api/bluetooth_socket/ |
| 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_.get())
[all...] |
| /external/chromium_org/device/bluetooth/ |
| bluetooth_channel_mac.h | 53 BluetoothSocketMac* socket() { return socket_; }
57 BluetoothSocketMac* socket_; member in class:device::BluetoothChannelMac
|
