| /external/libbrillo/brillo/http/ |
| D | http_request.cc | 136 if (!SendRequestIfNeeded(error) || !connection_->FinishRequest(error)) in GetResponseAndBlock()
138 std::unique_ptr<Response> response(new Response(connection_)); in GetResponseAndBlock()
139 connection_.reset(); in GetResponseAndBlock()
153 connection_->FinishRequestAsync(success_callback, error_callback); in GetResponse()
154 connection_.reset(); in GetResponse()
193 return stream && connection_->SetRequestData(std::move(stream), error); in AddRequestBody()
198 connection_->SetRequestData(std::move(stream), error); in AddRequestBody()
206 return connection_->SetRequestData(form_data->ExtractDataStream(), error); in AddRequestBodyAsFormData()
212 connection_->SetResponseData(std::move(stream)); in AddResponseStream()
244 if (!connection_) { in SendRequestIfNeeded()
[all …]
|
| D | http_request_unittest.cc | 46 connection_ = std::make_shared<MockConnection>(transport_); in SetUp()
57 testing::Mock::VerifyAndClearExpectations(connection_.get()); in TearDown()
58 connection_.reset(); in TearDown()
65 std::shared_ptr<MockConnection> connection_; member in brillo::http::HttpRequestTest
135 nullptr)).WillOnce(Return(connection_)); in TEST_F()
137 EXPECT_CALL(*connection_, MockSetRequestData(ContainsStringData(req_body), _)) in TEST_F()
143 EXPECT_CALL(*connection_, FinishRequest(_)).WillOnce(Return(true)); in TEST_F()
164 EXPECT_CALL(*test->connection_, GetResponseStatusCode()) in TEST_F()
168 EXPECT_CALL(*test->connection_, GetResponseStatusText()) in TEST_F()
172 EXPECT_CALL(*test->connection_, in TEST_F()
[all …]
|
| D | http_connection_curl_unittest.cc | 157 connection_ = std::make_shared<Connection>( in SetUp()
159 performer_.connection = connection_.get(); in SetUp()
164 connection_.reset(); in TearDown()
174 std::shared_ptr<Connection> connection_; member in brillo::http::curl::HttpCurlConnectionTest
180 EXPECT_TRUE(connection_->SetRequestData(std::move(stream), nullptr)); in TEST_F()
181 EXPECT_TRUE(connection_->SendHeaders({{"X-Foo", "bar"}}, nullptr)); in TEST_F()
215 EXPECT_CALL(*transport_, StartAsyncTransfer(connection_.get(), _, _)) in TEST_F()
217 connection_->FinishRequestAsync({}, {}); in TEST_F()
241 connection_->SetResponseData(std::move(response_stream)); in TEST_F()
242 EXPECT_TRUE(connection_->SetRequestData(std::move(stream), nullptr)); in TEST_F()
[all …]
|
| D | http_request.h | 303 std::shared_ptr<Connection> connection_; variable
373 std::shared_ptr<Connection> connection_; variable
|
| /external/webrtc/webrtc/base/ |
| D | dbus.cc | 135 connection_(NULL), in DBusMonitoringThread()
150 ASSERT(NULL == connection_); in Run()
189 connection_)); in RegisterAllFilters()
200 GetSymbols()->dbus_g_connection_get_connection()(connection_), in RegisterAllFilters()
204 GetSymbols()->dbus_g_connection_get_connection()(connection_), in RegisterAllFilters()
216 connection_)); in UnRegisterAllFilters()
226 GetSymbols()->dbus_g_connection_get_connection()(connection_), in UnRegisterAllFilters()
237 connection_ = GetSymbols()->dbus_g_bus_get_private()(monitor_->type_, in Setup()
239 if (NULL == connection_) { in Setup()
243 if (NULL == GetSymbols()->dbus_g_connection_get_connection()(connection_)) { in Setup()
[all …]
|
| /external/libchrome/dbus/ |
| D | bus.cc | 190 connection_(NULL), in Bus()
206 DCHECK(!connection_); in ~Bus()
410 if (connection_) in Connect()
416 connection_ = dbus_connection_open_private(address_.c_str(), error.get()); in Connect()
418 connection_ = dbus_connection_open(address_.c_str(), error.get()); in Connect()
423 connection_ = dbus_bus_get_private(dbus_bus_type, error.get()); in Connect()
425 connection_ = dbus_bus_get(dbus_bus_type, error.get()); in Connect()
428 if (!connection_) { in Connect()
440 if (!dbus_bus_register(connection_, error.get())) { in Connect()
455 dbus_connection_close(connection_); in ClosePrivateConnection()
[all …]
|
| D | bus.h | 596 bool is_connected() { return connection_ != NULL; } in is_connected()
703 DBusConnection* connection_; variable
|
| /external/webrtc/webrtc/p2p/base/ |
| D | port.cc | 673 connection_(connection) { in ConnectionRequest()
682 connection_->port()->CreateStunUsername( in Prepare()
683 connection_->remote_candidate().username(), &username); in Prepare()
688 if (connection_->port()->send_retransmit_count_attribute()) { in Prepare()
691 static_cast<uint32_t>(connection_->pings_since_last_response_.size() - in Prepare()
696 if (connection_->port()->GetIceRole() == ICEROLE_CONTROLLING) { in Prepare()
698 STUN_ATTR_ICE_CONTROLLING, connection_->port()->IceTiebreaker())); in Prepare()
704 if (connection_->use_candidate_attr()) { in Prepare()
708 } else if (connection_->port()->GetIceRole() == ICEROLE_CONTROLLED) { in Prepare()
710 STUN_ATTR_ICE_CONTROLLED, connection_->port()->IceTiebreaker())); in Prepare()
[all …]
|
| D | relayport.cc | 177 RelayConnection* connection_; member in cricket::AllocateRequest
781 connection_(connection) { in AllocateRequest()
819 entry_->OnConnect(addr, connection_); in OnResponse()
843 entry_->HandleConnectFailure(connection_->socket()); in OnTimeout()
|
| D | turnport_unittest.cc | 106 TestConnectionWrapper(Connection* conn) : connection_(conn) { in TestConnectionWrapper()
111 Connection* connection() { return connection_; } in connection()
115 ASSERT_TRUE(conn == connection_); in OnConnectionDestroyed()
116 connection_ = nullptr; in OnConnectionDestroyed()
119 Connection* connection_; member in TestConnectionWrapper
|
| /external/vulkan-validation-layers/include/vulkan/ |
| D | vulkan.hpp | 8055 …faceCreateFlagsKHR flags_ = MirSurfaceCreateFlagsKHR(), MirConnection* connection_ = nullptr, MirS… in MirSurfaceCreateInfoKHR()
8059 , connection( connection_ ) in MirSurfaceCreateInfoKHR()
8093 MirSurfaceCreateInfoKHR& setConnection( MirConnection* connection_ ) in setConnection()
8095 connection = connection_; in setConnection()
8391 …eCreateFlagsKHR flags_ = XcbSurfaceCreateFlagsKHR(), xcb_connection_t* connection_ = nullptr, xcb_… in XcbSurfaceCreateInfoKHR()
8395 , connection( connection_ ) in XcbSurfaceCreateInfoKHR()
8429 XcbSurfaceCreateInfoKHR& setConnection( xcb_connection_t* connection_ ) in setConnection()
8431 connection = connection_; in setConnection()
|