| /external/chromium/third_party/libjingle/source/talk/base/ |
| asyncsocket.cc | 38 AsyncSocketAdapter::AsyncSocketAdapter(AsyncSocket* socket) : socket_(NULL) {
43 delete socket_;
47 ASSERT(!socket_);
48 socket_ = socket;
49 if (socket_) {
50 socket_->SignalConnectEvent.connect(this,
52 socket_->SignalReadEvent.connect(this,
54 socket_->SignalWriteEvent.connect(this,
56 socket_->SignalCloseEvent.connect(this,
|
| socketstream.cc | 32 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) {
37 delete socket_;
41 if (socket_)
42 delete socket_;
43 socket_ = socket;
44 if (socket_) {
45 socket_->SignalConnectEvent.connect(this, &SocketStream::OnConnectEvent);
46 socket_->SignalReadEvent.connect(this, &SocketStream::OnReadEvent);
47 socket_->SignalWriteEvent.connect(this, &SocketStream::OnWriteEvent);
48 socket_->SignalCloseEvent.connect(this, &SocketStream::OnCloseEvent)
[all...] |
| asyncsocket.h | 63 return socket_->GetLocalAddress();
66 return socket_->GetRemoteAddress();
69 return socket_->Bind(addr);
72 return socket_->Connect(addr);
75 return socket_->Send(pv, cb);
78 return socket_->SendTo(pv, cb, addr);
81 return socket_->Recv(pv, cb);
84 return socket_->RecvFrom(pv, cb, paddr);
87 return socket_->Listen(backlog);
90 return socket_->Accept(paddr)
128 AsyncSocket* socket_; member in class:talk_base::AsyncSocketAdapter
[all...] |
| asyncudpsocket.cc | 52 : socket_(socket) {
53 ASSERT(socket_.get() != NULL);
58 socket_->SignalReadEvent.connect(this, &AsyncUDPSocket::OnReadEvent);
68 return socket_->GetLocalAddress();
72 return socket_->GetRemoteAddress();
76 return socket_->Send(pv, cb);
81 return socket_->SendTo(pv, cb, addr);
85 return socket_->Close();
89 return socket_->GetState();
93 return socket_->GetOption(opt, value)
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| asyncsocket.cc | 38 AsyncSocketAdapter::AsyncSocketAdapter(AsyncSocket* socket) : socket_(NULL) {
43 delete socket_;
47 ASSERT(!socket_);
48 socket_ = socket;
49 if (socket_) {
50 socket_->SignalConnectEvent.connect(this,
52 socket_->SignalReadEvent.connect(this,
54 socket_->SignalWriteEvent.connect(this,
56 socket_->SignalCloseEvent.connect(this,
|
| socketstream.cc | 32 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) {
37 delete socket_;
41 if (socket_)
42 delete socket_;
43 socket_ = socket;
44 if (socket_) {
45 socket_->SignalConnectEvent.connect(this, &SocketStream::OnConnectEvent);
46 socket_->SignalReadEvent.connect(this, &SocketStream::OnReadEvent);
47 socket_->SignalWriteEvent.connect(this, &SocketStream::OnWriteEvent);
48 socket_->SignalCloseEvent.connect(this, &SocketStream::OnCloseEvent)
[all...] |
| asynctcpsocket_unittest.cc | 45 socket_(vss_->CreateAsyncSocket(SOCK_STREAM)),
46 tcp_socket_(new AsyncTCPSocket(socket_, true)),
59 AsyncSocket* socket_; member in class:talk_base::AsyncTCPSocketTest
66 socket_->SignalWriteEvent(socket_);
|
| asyncudpsocket_unittest.cc | 45 socket_(vss_->CreateAsyncSocket(SOCK_DGRAM)),
46 udp_socket_(new AsyncUDPSocket(socket_)),
59 AsyncSocket* socket_; member in class:talk_base::AsyncUdpSocketTest
66 socket_->SignalWriteEvent(socket_);
|
| asyncsocket.h | 71 return socket_->GetLocalAddress();
74 return socket_->GetRemoteAddress();
77 return socket_->Bind(addr);
80 return socket_->Connect(addr);
83 return socket_->Send(pv, cb);
86 return socket_->SendTo(pv, cb, addr);
89 return socket_->Recv(pv, cb);
92 return socket_->RecvFrom(pv, cb, paddr);
95 return socket_->Listen(backlog);
98 return socket_->Accept(paddr)
136 AsyncSocket* socket_; member in class:talk_base::AsyncSocketAdapter
[all...] |
| asyncudpsocket.cc | 56 : socket_(socket) {
57 ASSERT(socket_);
62 socket_->SignalReadEvent.connect(this, &AsyncUDPSocket::OnReadEvent);
63 socket_->SignalWriteEvent.connect(this, &AsyncUDPSocket::OnWriteEvent);
71 return socket_->GetLocalAddress();
75 return socket_->GetRemoteAddress();
80 return socket_->Send(pv, cb);
86 return socket_->SendTo(pv, cb, addr);
90 return socket_->Close();
98 return socket_->GetOption(opt, value)
[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/net/udp/ |
| udp_client_socket.cc | 14 : socket_(net_log, source) {
21 return socket_.Connect(address);
27 return socket_.Read(buf, buf_len, callback);
33 return socket_.Write(buf, buf_len, callback);
37 socket_.Close();
41 return socket_.GetPeerAddress(address);
45 return socket_.GetLocalAddress(address);
|
| udp_server_socket.cc | 11 : socket_(net_log, source) {
18 return socket_.Bind(address);
25 return socket_.RecvFrom(buf, buf_len, address, callback);
32 return socket_.SendTo(buf, buf_len, address, callback);
36 socket_.Close();
40 return socket_.GetPeerAddress(address);
44 return socket_.GetLocalAddress(address);
|
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| teststunserver.h | 42 : socket_(thread->socketserver()->CreateAsyncSocket(addr.family(),
44 udp_socket_(talk_base::AsyncUDPSocket::Create(socket_, addr)),
48 talk_base::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_;
115 if (socket_) {
120 << socket_->GetState();
121 if (socket_->GetState() == talk_base::AsyncPacketSocket::STATE_BOUND ||
122 socket_->GetState() == talk_base::AsyncPacketSocket::STATE_CLOSED
[all...] |
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| udpport.cc | 43 socket_(NULL),
48 socket_ = factory_->CreateUdpSocket(
50 if (!socket_) {
54 socket_->SignalReadPacket.connect(this, &UDPPort::OnReadPacket);
59 delete socket_;
64 talk_base::SocketAddress address = socket_->GetLocalAddress(&allocated);
68 socket_->SignalAddressReady.connect(this, &UDPPort::OnAddresReady);
84 int sent = socket_->SendTo(data, size, addr);
86 error_ = socket_->GetError();
94 return socket_->SetOption(opt, value)
[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/net/socket/ |
| 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...] |
| /external/chromium_org/remoting/jingle_glue/ |
| chromium_socket_factory_unittest.cc | 22 socket_.reset(socket_factory_->CreateUdpSocket(
24 ASSERT_TRUE(socket_.get() != NULL);
25 EXPECT_EQ(socket_->GetState(), talk_base::AsyncPacketSocket::STATE_BOUND);
26 socket_->SignalReadPacket.connect(
34 EXPECT_EQ(socket, socket_.get());
45 scoped_ptr<talk_base::AsyncPacketSocket> socket_; member in class:remoting::ChromiumSocketFactoryTest
70 socket_->GetLocalAddress(),
81 EXPECT_EQ(0, socket_->SetOption(talk_base::Socket::OPT_SNDBUF, 4096));
82 EXPECT_EQ(0, socket_->SetOption(talk_base::Socket::OPT_RCVBUF, 4096));
88 socket_.reset(socket_factory_->CreateUdpSocket
[all...] |
| /external/chromium_org/net/server/ |
| http_connection.cc | 17 if (!socket_.get())
19 socket_->Send(data);
23 if (!socket_.get())
25 socket_->Send(bytes, len);
35 socket_(sock.Pass()) {
|
| /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...] |
| /external/chromium/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();
67 socket_->RestartWithAuth(username, password);
71 socket_->DetachDelegate();
|
| /external/chromium_org/remoting/protocol/ |
| buffered_socket_writer_unittest.cc | 37 written_data_ = socket_->written_data();
39 socket_.reset();
50 socket_.reset(new FakeSocket());
52 writer_->Init(socket_.get(), base::Bind(
74 socket_->written_data().size());
75 EXPECT_EQ(0, memcmp(test_buffer_->data(), socket_->written_data().data(),
78 socket_->written_data().data() + test_buffer_->size(),
91 socket_->written_data().size());
92 EXPECT_EQ(0, memcmp(test_buffer_->data(), socket_->written_data().data(),
95 socket_->written_data().data() + test_buffer_->size()
100 scoped_ptr<FakeSocket> socket_; member in class:remoting::protocol::BufferedSocketWriterTest
[all...] |
