| /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/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/ |
| 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/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/libmojo/mojo/common/ |
| D | data_pipe_drainer.cc | 18 : client_(client), source_(std::move(source)), weak_factory_(this) { in DataPipeDrainer()
19 DCHECK(client_); in DataPipeDrainer()
33 client_->OnDataAvailable(buffer, num_bytes); in ReadData()
36 client_->OnDataComplete(); in ReadData()
|
| D | data_pipe_drainer.h | 37 Client* client_; variable
|
| /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/libmojo/mojo/public/cpp/bindings/lib/ |
| D | multiplex_router.cc | 39 client_(nullptr), in InterfaceEndpoint()
67 InterfaceEndpointClient* client() const { return client_; } in client()
72 DCHECK(!client_); in AttachClient()
77 client_ = client; in AttachClient()
84 DCHECK(client_); in DetachClient()
89 client_ = nullptr; in DetachClient()
137 DCHECK(!client_); in ~InterfaceEndpoint()
233 InterfaceEndpointClient* client_; member in mojo::internal::MultiplexRouter::InterfaceEndpoint
|
| /external/libchrome/base/ |
| D | logging.cc | 613 : client_(asl_open(nullptr, in ~LogMessage()
616 ~ASLClient() { asl_close(client_); } in ~LogMessage()
618 aslclient get() const { return client_; } in ~LogMessage()
621 aslclient client_; in ~LogMessage()
|
| /external/v4l2_codec2/vda/ |
| D | v4l2_slice_video_decode_accelerator.h | 334 base::WeakPtr<VideoDecodeAccelerator::Client> client_; variable
|
| D | v4l2_slice_video_decode_accelerator.cc | 469 if (client_) { in NotifyError()
470 client_->NotifyError(error); in NotifyError()
489 client_ = client_ptr_factory_->GetWeakPtr(); in Initialize()
496 decode_client_ = client_; in Initialize()
793 client_, num_pictures, pixel_format, coded_size_)); in CreateOutputBuffers()
840 client_->DismissPictureBuffer(picture_buffer_id); in DismissPictures()
1769 base::Bind(&Client::NotifyFlushDone, client_)); in FinishFlush()
1841 base::Bind(&Client::NotifyResetDone, client_)); in FinishReset()
3038 FROM_HERE, base::Bind(&Client::PictureReady, client_, picture), in SendPictureReady()
|