Home
last modified time | relevance | path

Searched refs:request_id (Results 1 – 25 of 161) sorted by relevance

1234567

/external/openscreen/cast/sender/
Dcast_app_discovery_service_impl_unittest.cc62 int* request_id, in StartSourceA1Query() argument
68 *request_id = -1; in StartSourceA1Query()
71 .WillOnce([request_id, sender_id](CastSocket*, CastMessage message) { in StartSourceA1Query()
72 VerifyAppAvailabilityRequest(message, "AAA", request_id, sender_id); in StartSourceA1Query()
99 int request_id; in TEST_F() local
101 auto subscription1 = StartSourceA1Query(&receivers1, &request_id, &sender_id); in TEST_F()
109 CreateAppAvailableResponseChecked(request_id, sender_id, "AAA"); in TEST_F()
127 int request_id; in TEST_F() local
129 auto subscription1 = StartSourceA1Query(&receivers1, &request_id, &sender_id); in TEST_F()
132 CreateAppAvailableResponseChecked(request_id, sender_id, "AAA"); in TEST_F()
[all …]
Dcast_platform_client.cc60 int request_id = GetNextRequestId(); in RequestAppAvailability() local
62 CreateAppAvailabilityRequest(sender_id_, request_id, app_id); in RequestAppAvailability()
69 [this, request_id]() { CancelAppAvailabilityRequest(request_id); }, in RequestAppAvailability()
72 request_id, app_id, std::move(timeout), std::move(callback)}); in RequestAppAvailability()
83 return request_id; in RequestAppAvailability()
105 void CastPlatformClient::CancelRequest(int request_id) { in CancelRequest() argument
111 [request_id](const AvailabilityRequest& request) { in CancelRequest()
112 return request.request_id == request_id; in CancelRequest()
136 absl::optional<int> request_id = in OnMessage() local
138 if (request_id) { in OnMessage()
[all …]
Dcast_platform_client_unittest.cc58 int request_id = -1; in TEST_F() local
61 .WillOnce([&request_id, &sender_id](CastSocket* socket, in TEST_F()
63 VerifyAppAvailabilityRequest(message, "AAA", &request_id, &sender_id); in TEST_F()
75 CreateAppAvailableResponseChecked(request_id, sender_id, "AAA"); in TEST_F()
86 int request_id = -1; in TEST_F() local
89 .WillOnce([&request_id, &sender_id](CastSocket* socket, in TEST_F()
91 VerifyAppAvailabilityRequest(message, "AAA", &request_id, &sender_id); in TEST_F()
104 CreateAppAvailableResponseChecked(request_id, sender_id, "AAA"); in TEST_F()
Dcast_platform_client.h54 void CancelRequest(int request_id);
58 int request_id; member
74 int request_id,
77 void CancelAppAvailabilityRequest(int request_id);
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_response_cache.cc22 bool GrpcResponseCache::QueueRequest(int64_t request_id, int64_t step_id, in QueueRequest() argument
24 VLOG(1) << "GrpcResponseCache Lookup " << request_id; in QueueRequest()
28 ResponseCacheEntry& entry = response_cache_[request_id]; in QueueRequest()
31 VLOG(1) << "Reuse cached response for " << request_id; in QueueRequest()
45 VLOG(1) << "Found active request for " << request_id in QueueRequest()
50 VLOG(2) << "No cache entry for " << request_id in QueueRequest()
59 void GrpcResponseCache::OnRequestFinished(int64_t request_id, in OnRequestFinished() argument
67 auto it = response_cache_.find(request_id); in OnRequestFinished()
70 << request_id; in OnRequestFinished()
75 VLOG(1) << "Operation for " << request_id << " finished. " in OnRequestFinished()
[all …]
Dgrpc_worker_service.cc236 VLOG(3) << "Clean cache entry for request " << call->request.request_id(); in MarkRecvFinishedHandler()
237 worker_->RemoveCacheEntryForId(call->request.request_id()); in MarkRecvFinishedHandler()
446 const int64_t request_id = request->request_id(); in GrpcRecvTensorAsync() local
449 bool cache_enabled = (response_cache_ != nullptr && request_id != 0); in GrpcRecvTensorAsync()
465 response_cache_->QueueRequest(request_id, step_id, do_response)) { in GrpcRecvTensorAsync()
469 auto rendezvous_done = [this, request_id, do_response, cache_enabled]( in GrpcRecvTensorAsync()
474 response_cache_->OnRequestFinished(request_id, tensor, is_dead, status); in GrpcRecvTensorAsync()
485 request_id, "RecvTensor (GrpcWorker)", *request); in GrpcRecvTensorAsync()
593 const int64_t request_id = request->request_id(); in RecvBufAsync() local
595 bool cache_enabled = (response_cache_ != nullptr && request_id != 0); in RecvBufAsync()
[all …]
/external/openscreen/osp/impl/presentation/
Dpresentation_receiver.cc126 response.request_id = request.request_id; in OnStreamMessage()
155 response.request_id = request.request_id; in OnStreamMessage()
172 /* .request_id = */ request.request_id, in OnStreamMessage()
186 response.request_id = request.request_id; in OnStreamMessage()
221 response.request_id = request.request_id; in OnStreamMessage()
241 QueuedResponse{QueuedResponse::Type::kConnection, request.request_id, in OnStreamMessage()
244 request.request_id, presentation_id, endpoint_id); in OnStreamMessage()
253 response.request_id = request.request_id; in OnStreamMessage()
291 presentation_entry->second.terminate_request_id = request.request_id; in OnStreamMessage()
295 response.request_id = request.request_id; in OnStreamMessage()
[all …]
Dpresentation_controller.cc75 void CancelStartRequest(uint64_t request_id);
82 void CancelConnectionOpenRequest(uint64_t request_id);
102 uint64_t request_id,
104 void OnConnectionFailed(uint64_t request_id) override;
145 uint64_t request_id = GetNextInternalRequestId(); in SendStartRequest() local
153 initiation_handler_.WriteMessage(request_id, std::move(request)); in SendStartRequest()
154 return request_id; in SendStartRequest()
157 void Controller::MessageGroupStreams::CancelStartRequest(uint64_t request_id) { in CancelStartRequest() argument
160 initiation_handler_.CancelMessage(request_id); in CancelStartRequest()
199 uint64_t request_id = GetNextInternalRequestId(); in SendConnectionOpenRequest() local
[all …]
Dpresentation_controller_unittest.cc280 response.request_id = request.request_id; in StartPresentation()
325 uint64_t request_id = 7; in TEST_F() local
328 request_id); in TEST_F()
349 response.request_id = request.request_id; in TEST_F()
370 response.request_id = request.request_id; in TEST_F()
425 termination_response.request_id = termination_request.request_id; in TEST_F()
464 close_response.request_id = close_request.request_id; in TEST_F()
484 close_response.request_id = close_request.request_id; in TEST_F()
517 open_response.request_id = open_request.request_id; in TEST_F()
/external/perfetto/src/ipc/
Dclient_impl.cc90 RequestID request_id = ++last_request_id_; in BindService() local
92 frame.set_request_id(request_id); in BindService()
102 qr.request_id = request_id; in BindService()
104 queued_requests_.emplace(request_id, std::move(qr)); in BindService()
118 RequestID request_id = ++last_request_id_; in BeginInvoke() local
120 frame.set_request_id(request_id); in BeginInvoke()
134 qr.request_id = request_id; in BeginInvoke()
137 queued_requests_.emplace(request_id, std::move(qr)); in BeginInvoke()
138 return request_id; in BeginInvoke()
237 auto queued_requests_it = queued_requests_.find(frame.request_id()); in OnFrameReceived()
[all …]
Dservice_proxy.cc61 RequestID request_id = 0; in BeginInvoke() local
64 request_id = in BeginInvoke()
74 PERFETTO_DCHECK(!drop_reply || !request_id); in BeginInvoke()
76 if (!request_id) in BeginInvoke()
78 PERFETTO_DCHECK(pending_callbacks_.count(request_id) == 0); in BeginInvoke()
79 pending_callbacks_.emplace(request_id, std::move(reply)); in BeginInvoke()
82 void ServiceProxy::EndInvoke(RequestID request_id, in EndInvoke() argument
85 auto callback_it = pending_callbacks_.find(request_id); in EndInvoke()
/external/tensorflow/tensorflow/core/distributed_runtime/
Drecent_request_ids.cc31 bool RecentRequestIds::Insert(int64_t request_id) { in Insert() argument
32 if (request_id == 0) { in Insert()
38 const bool inserted = set_.insert(request_id).second; in Insert()
51 circular_buffer_[next_index_] = request_id; in Insert()
56 Status RecentRequestIds::TrackUnique(int64_t request_id, in TrackUnique() argument
59 if (Insert(request_id)) { in TrackUnique()
Drecent_request_ids.h60 Status TrackUnique(int64_t request_id, const string& method_name,
64 Status TrackUnique(int64_t request_id, const string& method_name,
68 bool Insert(int64_t request_id);
82 Status RecentRequestIds::TrackUnique(int64_t request_id, in TrackUnique() argument
85 if (Insert(request_id)) { in TrackUnique()
Drequest_id.cc23 int64_t request_id = 0; in GetUniqueRequestId() local
24 while (request_id == 0) { in GetUniqueRequestId()
25 request_id = random::New64(); in GetUniqueRequestId()
27 return request_id; in GetUniqueRequestId()
/external/openscreen/osp/impl/quic/
Dquic_client.cc181 uint64_t request_id = StartConnectionRequest(endpoint, request); in CreatePendingConnection() local
182 return ConnectRequest(this, request_id); in CreatePendingConnection()
184 uint64_t request_id = next_request_id_++; in CreatePendingConnection() local
185 pending_entry->second.callbacks.emplace_back(request_id, request); in CreatePendingConnection()
186 return ConnectRequest(this, request_id); in CreatePendingConnection()
207 uint64_t request_id = next_request_id_++; in StartConnectionRequest() local
208 pending_result.first->second.callbacks.emplace_back(request_id, request); in StartConnectionRequest()
209 return request_id; in StartConnectionRequest()
230 void QuicClient::CancelConnectRequest(uint64_t request_id) { in CancelConnectRequest() argument
231 auto request_entry = request_map_.find(request_id); in CancelConnectRequest()
[all …]
/external/openscreen/cast/receiver/channel/
Dmessage_util.cc19 int request_id, in CreateAppAvailabilityResponse() argument
25 dict[kMessageKeyRequestId] = request_id; in CreateAppAvailabilityResponse()
50 ErrorOr<CastMessage> CreateAppAvailableResponse(int request_id, in CreateAppAvailableResponse() argument
53 return CreateAppAvailabilityResponse(request_id, sender_id, app_id, in CreateAppAvailableResponse()
57 ErrorOr<CastMessage> CreateAppUnavailableResponse(int request_id, in CreateAppUnavailableResponse() argument
60 return CreateAppAvailabilityResponse(request_id, sender_id, app_id, in CreateAppUnavailableResponse()
/external/libchrome/mojo/public/cpp/bindings/lib/
Dinterface_endpoint_client.cc262 uint64_t request_id = next_request_id_++; in AcceptWithResponder() local
263 if (request_id == 0) in AcceptWithResponder()
264 request_id = next_request_id_++; in AcceptWithResponder()
266 message->set_request_id(request_id); in AcceptWithResponder()
273 async_responders_[request_id] = std::move(responder); in AcceptWithResponder()
281 request_id, std::make_unique<SyncResponseInfo>(&response_received))); in AcceptWithResponder()
288 DCHECK(base::ContainsKey(sync_responses_, request_id)); in AcceptWithResponder()
289 auto iter = sync_responses_.find(request_id); in AcceptWithResponder()
398 uint64_t request_id = message->request_id(); in HandleValidatedMessage() local
401 auto it = sync_responses_.find(request_id); in HandleValidatedMessage()
[all …]
/external/libbrillo/brillo/http/
Dhttp_transport_curl.cc99 RequestID request_id; member
238 RequestID request_id = ++last_request_id_; in StartAsyncTransfer() local
249 request_data->request_id = request_id; in StartAsyncTransfer()
251 request_id_map_.emplace(request_id, curl_connection); in StartAsyncTransfer()
262 request_id_map_.erase(request_id); in StartAsyncTransfer()
265 VLOG(1) << "Started asynchronous HTTP request with ID " << request_id; in StartAsyncTransfer()
266 return request_id; in StartAsyncTransfer()
269 bool Transport::CancelRequest(RequestID request_id) { in CancelRequest() argument
270 auto p = request_id_map_.find(request_id); in CancelRequest()
274 LOG(WARNING) << "HTTP request #" << request_id << " not found"; in CancelRequest()
[all …]
/external/libchrome/mojo/public/cpp/bindings/tests/
Drouter_test_util.cc28 uint64_t request_id, in AllocResponseMessage() argument
32 message->set_request_id(request_id); in AllocResponseMessage()
63 bool result = SendResponse(message->name(), message->request_id(), in AcceptWithResponder()
71 uint64_t request_id, in SendResponse() argument
77 AllocResponseMessage(name, response_string.c_str(), request_id, &response); in SendResponse()
91 request_id_ = message->request_id(); in AcceptWithResponder()
/external/libcups/scheduler/
Dcups-driverd.cxx153 static int cat_drv(const char *name, int request_id);
154 static void cat_ppd(const char *name, int request_id);
155 static int cat_static(const char *name, int request_id);
156 static int cat_tar(const char *name, int request_id);
166 static cups_file_t *get_file(const char *name, int request_id,
169 static void list_ppds(int request_id, int limit, const char *opt);
311 int request_id) /* I - Request ID for response? */ in cat_drv() argument
334 if (request_id) in cat_drv()
338 cupsdSendIPPHeader(IPP_NOT_FOUND, request_id); in cat_drv()
350 …if ((fp = get_file(resource, request_id, "drv", filename, sizeof(filename), &pc_file_name)) == NUL… in cat_drv()
[all …]
/external/openscreen/osp/public/
Dprotocol_connection_client.h38 uint64_t request_id,
40 virtual void OnConnectionFailed(uint64_t request_id) = 0;
46 ConnectRequest(ProtocolConnectionClient* parent, uint64_t request_id);
53 uint64_t request_id() const { return request_id_; } in request_id() function
107 virtual void CancelConnectRequest(uint64_t request_id) = 0;
/external/autotest/utils/frozen_chromite/third_party/googleapiclient/
Dhttp.py1264 def add(self, request, callback=None, request_id=None): argument
1292 if request_id is None:
1293 request_id = self._new_id()
1296 if request_id in self._requests:
1297 raise KeyError("A request with this ID already exists: %s" % request_id)
1298 self._requests[request_id] = request
1299 self._callbacks[request_id] = callback
1300 self._order.append(request_id)
1320 for request_id in order:
1321 request = requests[request_id]
[all …]
/external/openscreen/osp/msgs/
Dmessages_unittest.cc31 EXPECT_EQ(3u, decoded_request.request_id); in TEST()
47 EXPECT_EQ(7u, decoded_request.request_id); in TEST()
65 EXPECT_EQ(7u, decoded_request.request_id); in TEST()
117 EXPECT_EQ(13u, decoded_request.request_id); in TEST()
138 EXPECT_EQ(13u, decoded_request.request_id); in TEST()
199 EXPECT_EQ(request.request_id, decoded_request.request_id); in TEST()
219 EXPECT_EQ(request.request_id, decoded_request.request_id); in TEST()
/external/python/google-api-python-client/googleapiclient/
Dhttp.py1410 def add(self, request, callback=None, request_id=None): argument
1444 if request_id is None:
1445 request_id = self._new_id()
1448 if request_id in self._requests:
1449 raise KeyError("A request with this ID already exists: %s" % request_id)
1450 self._requests[request_id] = request
1451 self._callbacks[request_id] = callback
1452 self._order.append(request_id)
1472 for request_id in order:
1473 request = requests[request_id]
[all …]
/external/tcpdump/
Dprint-someip.c87 uint32_t request_id; in someip_print() local
114 request_id = GET_BE_U_4(bp); in someip_print()
115 client_id = request_id >> 16; in someip_print()
116 session_id = request_id & 0x0000FFFF; in someip_print()

1234567