Home
last modified time | relevance | path

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

1234

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_response_cache.cc22 bool GrpcResponseCache::QueueRequest(int64 request_id, int64 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 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.cc235 VLOG(1) << "Clean cache entry for request " << call->request.request_id(); in MarkRecvFinishedHandler()
236 worker_->RemoveCacheEntryForId(call->request.request_id()); in MarkRecvFinishedHandler()
445 const int64 request_id = request->request_id(); in GrpcRecvTensorAsync() local
448 bool cache_enabled = (response_cache_ != nullptr && request_id != 0); in GrpcRecvTensorAsync()
464 response_cache_->QueueRequest(request_id, step_id, do_response)) { in GrpcRecvTensorAsync()
468 auto rendezvous_done = [this, request_id, do_response, cache_enabled]( in GrpcRecvTensorAsync()
473 response_cache_->OnRequestFinished(request_id, tensor, is_dead, status); in GrpcRecvTensorAsync()
484 request_id, "RecvTensor (GrpcWorker)", *request); in GrpcRecvTensorAsync()
588 const int64 request_id = request->request_id(); in RecvBufAsync() local
590 bool cache_enabled = (response_cache_ != nullptr && request_id != 0); in RecvBufAsync()
[all …]
Dgrpc_response_cache.h53 bool QueueRequest(int64 request_id, int64 step_id,
58 void OnRequestFinished(int64 request_id, const Tensor& tensor, bool is_dead,
62 void EraseRequestId(int64 request_id);
/external/perfetto/src/ipc/
Dclient_impl.cc67 RequestID request_id = ++last_request_id_; in BindService() local
69 frame.set_request_id(request_id); in BindService()
79 qr.request_id = request_id; in BindService()
81 queued_requests_.emplace(request_id, std::move(qr)); in BindService()
95 RequestID request_id = ++last_request_id_; in BeginInvoke() local
97 frame.set_request_id(request_id); in BeginInvoke()
111 qr.request_id = request_id; in BeginInvoke()
114 queued_requests_.emplace(request_id, std::move(qr)); in BeginInvoke()
115 return request_id; in BeginInvoke()
180 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()
Dhost_impl.cc136 reply_frame.set_request_id(req_frame.request_id()); in OnReceivedFrame()
146 reply_frame.set_request_id(req_frame.request_id()); in OnBindService()
166 RequestID request_id = req_frame.request_id(); in OnInvokeMethod() local
167 reply_frame.set_request_id(request_id); in OnInvokeMethod()
192 request_id](AsyncResult<ProtoMessage> reply) { in OnInvokeMethod()
195 host_weak_ptr->ReplyToMethodInvocation(client_id, request_id, in OnInvokeMethod()
208 RequestID request_id, in ReplyToMethodInvocation() argument
216 reply_frame.set_request_id(request_id); in ReplyToMethodInvocation()
Dhost_impl_unittest.cc102 uint64_t request_id = requests_.empty() ? 1 : requests_.rbegin()->first + 1; in BindService() local
103 requests_.emplace(request_id, 0); in BindService()
104 frame.set_request_id(request_id); in BindService()
115 uint64_t request_id = requests_.empty() ? 1 : requests_.rbegin()->first + 1; in InvokeMethod() local
116 requests_.emplace(request_id, 0); in InvokeMethod()
117 frame.set_request_id(request_id); in InvokeMethod()
142 ASSERT_EQ(1u, requests_.count(frame->request_id())); in OnDataAvailable()
143 EXPECT_EQ(0, requests_[frame->request_id()]++); in OnDataAvailable()
/external/tensorflow/tensorflow/core/distributed_runtime/
Drecent_request_ids.cc31 bool RecentRequestIds::Insert(int64 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 request_id, in TrackUnique() argument
59 if (Insert(request_id)) { in TrackUnique()
Drecent_request_ids.h60 Status TrackUnique(int64 request_id, const string& method_name,
64 Status TrackUnique(int64 request_id, const string& method_name,
68 bool Insert(int64 request_id);
82 Status RecentRequestIds::TrackUnique(int64 request_id, in TrackUnique() argument
85 if (Insert(request_id)) { in TrackUnique()
Drequest_id.cc23 int64 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()
Drecent_request_ids_test.cc29 Status TrackUnique(int64 request_id, RecentRequestIds* recent_request_ids) { in TrackUnique() argument
31 request.set_request_id(request_id); in TrackUnique()
32 return recent_request_ids->TrackUnique(request_id, "recent_request_ids_test", in TrackUnique()
Dmessage_wrappers.cc102 int64 InMemoryRunStepRequest::request_id() const { in request_id() function in tensorflow::InMemoryRunStepRequest
219 int64 MutableProtoRunStepRequest::request_id() const { in request_id() function in tensorflow::MutableProtoRunStepRequest
220 return request_.request_id(); in request_id()
285 int64 ProtoRunStepRequest::request_id() const { return request_->request_id(); } in request_id() function in tensorflow::ProtoRunStepRequest
397 int64 InMemoryRunGraphRequest::request_id() const { return request_id_; } in request_id() function in tensorflow::InMemoryRunGraphRequest
399 void InMemoryRunGraphRequest::set_request_id(int64 request_id) { in set_request_id() argument
400 request_id_ = request_id; in set_request_id()
546 int64 MutableProtoRunGraphRequest::request_id() const { in request_id() function in tensorflow::MutableProtoRunGraphRequest
547 return request_.request_id(); in request_id()
550 void MutableProtoRunGraphRequest::set_request_id(int64 request_id) { in set_request_id() argument
[all …]
Dmessage_wrappers.h93 virtual int64 request_id() const = 0;
135 int64 request_id() const override;
186 int64 request_id() const override;
227 int64 request_id() const override;
298 virtual int64 request_id() const = 0;
328 virtual void set_request_id(int64 request_id) = 0;
348 int64 request_id() const override;
366 void set_request_id(int64 request_id) override;
407 int64 request_id() const override;
426 void set_request_id(int64 request_id) override;
[all …]
/external/libbrillo/brillo/http/
Dhttp_transport_curl.cc98 RequestID request_id; member
225 RequestID request_id = ++last_request_id_; in StartAsyncTransfer() local
236 request_data->request_id = request_id; in StartAsyncTransfer()
238 request_id_map_.emplace(request_id, curl_connection); in StartAsyncTransfer()
249 request_id_map_.erase(request_id); in StartAsyncTransfer()
252 VLOG(1) << "Started asynchronous HTTP request with ID " << request_id; in StartAsyncTransfer()
253 return request_id; in StartAsyncTransfer()
256 bool Transport::CancelRequest(RequestID request_id) { in CancelRequest() argument
257 auto p = request_id_map_.find(request_id); in CancelRequest()
261 LOG(WARNING) << "HTTP request #" << request_id << " not found"; in CancelRequest()
[all …]
/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/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/python/google-api-python-client/googleapiclient/
Dhttp.py1304 def add(self, request, callback=None, request_id=None): argument
1336 if request_id is None:
1337 request_id = self._new_id()
1340 if request_id in self._requests:
1341 raise KeyError("A request with this ID already exists: %s" % request_id)
1342 self._requests[request_id] = request
1343 self._callbacks[request_id] = callback
1344 self._order.append(request_id)
1364 for request_id in order:
1365 request = requests[request_id]
[all …]
/external/tensorflow/tensorflow/core/protobuf/
Dmaster.proto145 // have a unique request_id, and retried RunStepRequest must have
146 // the same request_id. If request_id is zero, retry detection is disabled.
147 int64 request_id = 8; field
195 // have a unique request_id, and retried PartialRunSetupRequest must have
196 // the same request_id. If request_id is zero, retry detection is disabled.
197 int64 request_id = 5; field
294 // have a unique request_id, and retried MakeCallableRequest must have
295 // the same request_id. If request_id is zero, retry detection is disabled.
296 int64 request_id = 3; field
323 // have a unique request_id, and retried RunCallableRequest must have
[all …]
/external/python/apitools/apitools/base/py/
Dbatch.py279 def _ConvertIdToHeader(self, request_id): argument
291 return '<%s+%s>' % (self.__base_id, urllib_parse.quote(request_id))
315 _, request_id = header[1:-1].rsplit('+', 1)
317 return urllib_parse.unquote(request_id)
469 request_id = self._ConvertHeaderToId(part['Content-ID'])
475 self.__request_response_handlers[request_id] = (
476 self.__request_response_handlers[request_id]._replace(
/external/libchrome/mojo/public/cpp/bindings/
Dmessage.h143 uint64_t request_id() const { return header_v1()->request_id; } in COMPONENT_EXPORT()
144 void set_request_id(uint64_t request_id) { in COMPONENT_EXPORT()
145 header_v1()->request_id = request_id; in COMPONENT_EXPORT()
/external/perfetto/protos/perfetto/ipc/
Dwire_protocol.proto60 // request_id. The host will match the request_id sent from the client.
62 // several InvokeMethodReply with the same request_id.
63 optional uint64 request_id = 2; field
/external/ltp/testcases/network/rpc/basic_tests/rpc01/lib/
Dlibrpc01.c30 rc = rc && xdr_long(xdrs, &bp->request_id); in xdr_receive_data()
44 rc = rc && xdr_long(xdrs, &buffer->request_id); in xdr_send_data()
/external/libcups/cups/
Dsnmp.c558 unsigned request_id = 0; /* Current request ID */ in _cupsSNMPWalk() local
589 request_id ++; in _cupsSNMPWalk()
592 CUPS_ASN1_GET_NEXT_REQUEST, request_id, in _cupsSNMPWalk()
644 const unsigned request_id, /* I - Request ID */ in _cupsSNMPWrite() argument
661 fd, address, version, community, request_type, request_id, oid)); in _cupsSNMPWrite()
665 request_type != CUPS_ASN1_GET_NEXT_REQUEST) || request_id < 1 || !oid) in _cupsSNMPWrite()
680 packet.request_id = request_id; in _cupsSNMPWrite()
977 packet->request_id = (unsigned)asn1_get_integer(&bufptr, bufend, length); in asn1_decode_snmp()
1137 reqlen = 2 + asn1_size_integer((int)packet->request_id) + in asn1_encode_snmp()
1173 asn1_set_integer(&bufptr, (int)packet->request_id); in asn1_encode_snmp()
/external/python/google-api-python-client/docs/
Dbatch.md43 method also allows you to supply a <code>request_id</code> parameter for each request.
55 def list_animals(request_id, response, exception):
63 def list_farmers(request_id, response):
78 def insert_animal(request_id, response, exception):
/external/kernel-headers/original/uapi/linux/
Duinput.h50 __u32 request_id; member
57 __u32 request_id; member

1234