| /external/webrtc/webrtc/base/ |
| D | httprequest.cc | 56 client_(user_agent.c_str(), NULL), in HttpRequest()
71 SslSocketFactory factory(ss, client_.agent()); in Send()
79 client_.set_pool(&pool); in Send()
85 client_.set_proxy(proxy_); in Send()
87 client_.set_redirect_action(HttpClient::REDIRECT_ALWAYS); in Send()
90 client_.set_server(server); in Send()
92 LOG(LS_INFO) << "HttpRequest start: " << host_ + client_.request().path; in Send()
95 monitor.Connect(&client_); in Send()
96 client_.start(); in Send()
100 client_.reset(); in Send()
[all …]
|
| D | ssladapter_unittest.cc | 278 client_(new SSLAdapterTestDummyClient(ssl_mode_)), in SSLAdapterTestBase()
289 ASSERT_EQ(rtc::AsyncSocket::CS_CLOSED, client_->GetState()); in TestHandshake()
291 rv = client_->Connect(server_->GetHostname(), server_->GetAddress()); in TestHandshake()
295 ASSERT_EQ(rtc::AsyncSocket::CS_CONNECTING, client_->GetState()); in TestHandshake()
299 server_->AcceptConnection(client_->GetAddress()); in TestHandshake()
305 EXPECT_EQ_WAIT(rtc::AsyncSocket::CS_CONNECTED, client_->GetState(), in TestHandshake()
312 EXPECT_EQ_WAIT(rtc::AsyncSocket::CS_CLOSED, client_->GetState(), in TestHandshake()
322 rv = client_->Send(message); in TestTransfer()
332 EXPECT_EQ_WAIT(message, client_->GetReceivedData(), kTimeout); in TestTransfer()
343 rtc::scoped_ptr<SSLAdapterTestDummyClient> client_; member in SSLAdapterTestBase
|
| D | httprequest.h | 67 HttpRequestData& request() { return client_.request(); } in request()
68 HttpResponseData& response() { return client_.response(); } in response()
82 HttpClient client_; variable
|
| D | nat_unittest.cc | 346 client_->SignalConnectEvent.connect(this, &NatTcpTest::OnConnectEvent); in ConnectEvents()
360 rtc::scoped_ptr<AsyncSocket> client_; member in NatTcpTest
370 client_.reset(natsf_->CreateAsyncSocket(SOCK_STREAM)); in TEST_F()
371 EXPECT_GE(0, client_->Bind(int_addr_)); in TEST_F()
372 EXPECT_GE(0, client_->Connect(server_->GetLocalAddress())); in TEST_F()
377 EXPECT_EQ(client_->GetRemoteAddress(), server_->GetLocalAddress()); in TEST_F()
380 rtc::scoped_ptr<rtc::TestClient> in(CreateTCPTestClient(client_.release())); in TEST_F()
|
| /external/webrtc/webrtc/examples/peerconnection/client/ |
| D | conductor.cc | 58 client_(client), in Conductor()
60 client_->RegisterObserver(this); in Conductor()
73 client_->SignOut(); in Close()
203 main_wnd_->SwitchToPeerList(client_->peers()); in OnSignedIn()
219 main_wnd_->SwitchToPeerList(client_->peers()); in OnPeerConnected()
230 main_wnd_->SwitchToPeerList(client_->peers()); in OnPeerDisconnected()
244 client_->SignOut(); in OnMessageFromPeer()
271 client_->SignOut(); in OnMessageFromPeer()
342 if (client_->is_connected()) in StartLogin()
345 client_->Connect(server, port, GetPeerName()); in StartLogin()
[all …]
|
| D | conductor.h | 121 PeerConnectionClient* client_; variable
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | xmpppump.cc | 20 client_ = new buzz::XmppClient(this); // NOTE: deleted by TaskRunner in XmppPump()
28 client_->SignalStateChange.connect(this, &XmppPump::OnStateChange); in DoLogin()
29 client_->Connect(xcs, "", socket, auth); in DoLogin()
30 client_->Start(); in DoLogin()
36 client_->Disconnect(); in DoDisconnect()
62 return client_->SendStanza(stanza); in SendStanza()
|
| D | pubsubstateclient.h | 97 client_(client), in PubSubStateClient()
102 client_->SignalItems.connect( in PubSubStateClient()
104 client_->SignalPublishResult.connect( in PubSubStateClient()
106 client_->SignalPublishError.connect( in PubSubStateClient()
108 client_->SignalRetractResult.connect( in PubSubStateClient()
110 client_->SignalRetractError.connect( in PubSubStateClient()
122 client_->RetractItem(itemid, task_id_out); in Publish()
126 client_->PublishItem(itemid, state_elem, task_id_out); in Publish()
150 client_->GetPublisherNickFromPubSubItem(item.elem); in ParseStateItem()
160 PubSubClient* client() { return client_; } in client()
[all …]
|
| D | xmppclient.cc | 32 client_(client), in Private()
48 XmppClient* const client_; member in buzz::XmppClient::Private
366 client_->SignalLogInput(bytes, static_cast<int>(bytes_read)); in OnSocketRead()
380 client_->EnsureClosed(); in OnStateChange()
383 client_->SignalStateChange((XmppEngine::State)state); in OnStateChange()
385 client_->Wake(); in OnStateChange()
390 client_->SignalLogOutput(bytes, static_cast<int>(len)); in WriteOutput()
|
| D | xmpppump.h | 36 buzz::XmppClient *client() { return client_; } in client()
54 buzz::XmppClient *client_;
|
| /external/webrtc/webrtc/examples/peerconnection/client/linux/ |
| D | main.cc | 24 : thread_(thread), wnd_(wnd), conductor_(NULL), client_(NULL) {} in CustomSocketServer()
27 void set_client(PeerConnectionClient* client) { client_ = client; } in set_client()
41 client_ != NULL && !client_->is_connected()) { in Wait()
52 PeerConnectionClient* client_; member in CustomSocketServer
|
| /external/webrtc/webrtc/p2p/base/ |
| D | stunserver_unittest.cc | 36 client_.reset(new rtc::TestClient( in SetUp()
47 client_->SendTo(buf, len, server_addr); in Send()
50 return(client_->CheckNoPacket()); in ReceiveFails()
55 client_->NextPacket(rtc::TestClient::kTimeoutMs); in Receive()
69 rtc::scoped_ptr<rtc::TestClient> client_; member in StunServerTest
|
| /external/libweave/examples/provider/ |
| D | avahi_client.cc | 36 client_.reset(avahi_client_new(avahi_threaded_poll_get(thread_pool_.get()), in AvahiClient()
38 CHECK(client_) << "failed to connect to avahi-daemon: " in AvahiClient()
43 group_.reset(avahi_entry_group_new(client_.get(), GroupCallback, nullptr)); in AvahiClient()
44 CHECK(group_) << avahi_strerror(avahi_client_errno(client_.get())) in AvahiClient()
|
| D | avahi_client.h | 37 std::unique_ptr< ::AvahiClient, decltype(&avahi_client_free)> client_{
|
| /external/libchrome/base/ |
| D | logging.cc | 601 : client_(asl_open(nullptr, in ~LogMessage()
604 ~ASLClient() { asl_close(client_); } in ~LogMessage()
606 aslclient get() const { return client_; } in ~LogMessage()
609 aslclient client_; in ~LogMessage()
|