| /external/perfetto/src/ipc/ |
| D | client_impl.cc | 64 RequestID request_id = ++last_request_id_; in BindService() local
66 frame.set_request_id(request_id); in BindService()
76 qr.request_id = request_id; in BindService()
78 queued_requests_.emplace(request_id, std::move(qr)); in BindService()
93 RequestID request_id = ++last_request_id_; in BeginInvoke() local
95 frame.set_request_id(request_id); in BeginInvoke()
110 qr.request_id = request_id; in BeginInvoke()
113 queued_requests_.emplace(request_id, std::move(qr)); in BeginInvoke()
114 return request_id; in BeginInvoke()
180 auto queued_requests_it = queued_requests_.find(frame.request_id()); in OnFrameReceived()
[all …]
|
| D | service_proxy.cc | 60 RequestID request_id = 0; in BeginInvoke() local
63 request_id = in BeginInvoke()
73 PERFETTO_DCHECK(!drop_reply || !request_id); in BeginInvoke()
75 if (!request_id) in BeginInvoke()
77 PERFETTO_DCHECK(pending_callbacks_.count(request_id) == 0); in BeginInvoke()
78 pending_callbacks_.emplace(request_id, std::move(reply)); in BeginInvoke()
81 void ServiceProxy::EndInvoke(RequestID request_id, in EndInvoke() argument
84 auto callback_it = pending_callbacks_.find(request_id); in EndInvoke()
|
| D | host_impl.cc | 135 reply_frame.set_request_id(req_frame.request_id()); in OnReceivedFrame()
145 reply_frame.set_request_id(req_frame.request_id()); in OnBindService()
165 RequestID request_id = req_frame.request_id(); in OnInvokeMethod() local
166 reply_frame.set_request_id(request_id); in OnInvokeMethod()
191 request_id](AsyncResult<ProtoMessage> reply) { in OnInvokeMethod()
194 host_weak_ptr->ReplyToMethodInvocation(client_id, request_id, in OnInvokeMethod()
207 RequestID request_id, in ReplyToMethodInvocation() argument
215 reply_frame.set_request_id(request_id); in ReplyToMethodInvocation()
|
| D | wire_protocol.proto | 61 // request_id. The host will match the request_id sent from the client.
63 // several InvokeMethodReply with the same request_id.
64 optional uint64 request_id = 2; field
|
| D | host_impl_unittest.cc | 99 uint64_t request_id = requests_.empty() ? 1 : requests_.rbegin()->first + 1; in BindService() local
100 requests_.emplace(request_id, 0); in BindService()
101 frame.set_request_id(request_id); in BindService()
112 uint64_t request_id = requests_.empty() ? 1 : requests_.rbegin()->first + 1; in InvokeMethod() local
113 requests_.emplace(request_id, 0); in InvokeMethod()
114 frame.set_request_id(request_id); in InvokeMethod()
139 ASSERT_EQ(1u, requests_.count(frame->request_id())); in OnDataAvailable()
140 EXPECT_EQ(0, requests_[frame->request_id()]++); in OnDataAvailable()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | recent_request_ids.cc | 31 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()
67 Status RecentRequestIds::TrackUnique(int64 request_id, in TrackUnique() argument
70 if (Insert(request_id)) { in TrackUnique()
|
| D | request_id.cc | 23 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()
|
| D | recent_request_ids.h | 60 Status TrackUnique(int64 request_id, const string& method_name,
63 Status TrackUnique(int64 request_id, const string& method_name,
67 bool Insert(int64 request_id);
|
| D | recent_request_ids_test.cc | 29 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()
|
| D | BUILD | 300 ":request_id",
524 ":request_id",
743 name = "request_id",
744 srcs = ["request_id.cc"],
745 hdrs = ["request_id.h"],
757 ":request_id",
780 ":request_id",
|
| /external/libbrillo/brillo/http/ |
| D | http_transport_curl.cc | 98 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/ |
| D | interface_endpoint_client.cc | 262 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/ |
| D | router_test_util.cc | 28 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()
|
| D | router_test_util.h | 23 uint64_t request_id,
49 uint64_t request_id,
|
| /external/python/google-api-python-client/googleapiclient/ |
| D | http.py | 1299 def add(self, request, callback=None, request_id=None): argument
1331 if request_id is None:
1332 request_id = self._new_id()
1335 if request_id in self._requests:
1336 raise KeyError("A request with this ID already exists: %s" % request_id)
1337 self._requests[request_id] = request
1338 self._callbacks[request_id] = callback
1339 self._order.append(request_id)
1359 for request_id in order:
1360 request = requests[request_id]
[all …]
|
| /external/tensorflow/tensorflow/core/protobuf/ |
| D | master.proto | 145 // 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/ |
| D | batch.py | 271 def _ConvertIdToHeader(self, request_id): argument
283 return '<%s+%s>' % (self.__base_id, urllib_parse.quote(request_id))
307 _, request_id = header[1:-1].rsplit('+', 1)
309 return urllib_parse.unquote(request_id)
455 request_id = self._ConvertHeaderToId(part['Content-ID'])
461 self.__request_response_handlers[request_id] = (
462 self.__request_response_handlers[request_id]._replace(
|
| /external/libchrome/mojo/public/cpp/bindings/ |
| D | message.h | 143 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/libcups/cups/ |
| D | snmp.c | 558 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()
|
| D | snmp-private.h | 89 unsigned request_id; /* request-id value */ member
133 const unsigned request_id,
|
| /external/autotest/venv/skylab_suite/ |
| D | tko_test_views.py | 193 def _run_ids_for_request(request_id): argument
195 prefix = request_id[:len(request_id)-1]
|
| /external/ltp/testcases/network/rpc/basic_tests/rpc01/lib/ |
| D | librpc01.c | 30 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/syzkaller/vendor/google.golang.org/appengine/internal/log/ |
| D | log_service.proto | 34 optional bytes request_id = 1; field
47 required bytes request_id = 3; field
103 repeated bytes request_id = 6; field
|
| /external/kernel-headers/original/uapi/linux/ |
| D | uinput.h | 50 __u32 request_id; member
57 __u32 request_id; member
|
| /external/libchrome/ipc/ |
| D | ipc_sync_message.cc | 45 bool SyncMessage::IsMessageReplyTo(const Message& msg, int request_id) { in IsMessageReplyTo() argument
49 return GetMessageId(msg) == request_id; in IsMessageReplyTo()
|