| /external/perfetto/src/ipc/ |
| D | client_impl.cc | 61 RequestID request_id = ++last_request_id_; in BindService() local
63 frame.set_request_id(request_id); in BindService()
73 qr.request_id = request_id; in BindService()
75 queued_requests_.emplace(request_id, std::move(qr)); in BindService()
90 RequestID request_id = ++last_request_id_; in BeginInvoke() local
92 frame.set_request_id(request_id); in BeginInvoke()
107 qr.request_id = request_id; in BeginInvoke()
110 queued_requests_.emplace(request_id, std::move(qr)); in BeginInvoke()
111 return request_id; in BeginInvoke()
177 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 | 134 reply_frame.set_request_id(req_frame.request_id()); in OnReceivedFrame()
144 reply_frame.set_request_id(req_frame.request_id()); in OnBindService()
164 RequestID request_id = req_frame.request_id(); in OnInvokeMethod() local
165 reply_frame.set_request_id(request_id); in OnInvokeMethod()
190 request_id](AsyncResult<ProtoMessage> reply) { in OnInvokeMethod()
193 host_weak_ptr->ReplyToMethodInvocation(client_id, request_id, in OnInvokeMethod()
206 RequestID request_id, in ReplyToMethodInvocation() argument
214 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 | 98 uint64_t request_id = requests_.empty() ? 1 : requests_.rbegin()->first + 1; in BindService() local
99 requests_.emplace(request_id, 0); in BindService()
100 frame.set_request_id(request_id); in BindService()
111 uint64_t request_id = requests_.empty() ? 1 : requests_.rbegin()->first + 1; in InvokeMethod() local
112 requests_.emplace(request_id, 0); in InvokeMethod()
113 frame.set_request_id(request_id); in InvokeMethod()
138 ASSERT_EQ(1u, requests_.count(frame->request_id())); in OnDataAvailable()
139 EXPECT_EQ(0, requests_[frame->request_id()]++); in OnDataAvailable()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | recent_request_ids.cc | 29 Status RecentRequestIds::TrackUnique(int64 request_id, in TrackUnique() argument
33 if (request_id == 0) { in TrackUnique()
37 if (set_.count(request_id) > 0) { in TrackUnique()
51 circular_buffer_[next_index_] = request_id; in TrackUnique()
52 set_.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_test.cc | 27 Status TrackUnique(int64 request_id, RecentRequestIds* recent_request_ids) { in TrackUnique() argument
29 request.set_request_id(request_id); in TrackUnique()
30 return recent_request_ids->TrackUnique(request_id, "recent_request_ids_test", in TrackUnique()
|
| /external/libbrillo/brillo/http/ |
| D | http_transport_curl.cc | 98 RequestID request_id; member
221 RequestID request_id = ++last_request_id_; in StartAsyncTransfer() local
232 request_data->request_id = request_id; in StartAsyncTransfer()
234 request_id_map_.emplace(request_id, curl_connection); in StartAsyncTransfer()
245 request_id_map_.erase(request_id); in StartAsyncTransfer()
248 LOG(INFO) << "Started asynchronous HTTP request with ID " << request_id; in StartAsyncTransfer()
249 return request_id; in StartAsyncTransfer()
252 bool Transport::CancelRequest(RequestID request_id) { in CancelRequest() argument
253 auto p = request_id_map_.find(request_id); in CancelRequest()
257 LOG(WARNING) << "HTTP request #" << request_id << " not found"; in CancelRequest()
[all …]
|
| /external/syslinux/core/lwip/src/core/snmp/ |
| D | msg_in.c | 147 snmp_msg_get_event(u8_t request_id, struct snmp_msg_pstat *msg_ps) in snmp_msg_get_event() argument
161 en->get_object_def_a(request_id, np.ident_len, np.ident, &msg_ps->ext_object_def); in snmp_msg_get_event()
166 en->get_value_q(request_id, &msg_ps->ext_object_def); in snmp_msg_get_event()
170 en->get_object_def_pc(request_id, np.ident_len, np.ident); in snmp_msg_get_event()
208 en->get_value_a(request_id, &msg_ps->ext_object_def, vb->value_len, vb->value); in snmp_msg_get_event()
216 en->get_value_pc(request_id, &msg_ps->ext_object_def); in snmp_msg_get_event()
227 en->get_value_a(request_id, &msg_ps->ext_object_def, 0, NULL); in snmp_msg_get_event()
237 en->get_value_pc(request_id, &msg_ps->ext_object_def); in snmp_msg_get_event()
274 en->get_object_def_q(en->addr_inf, request_id, np.ident_len, np.ident); in snmp_msg_get_event()
380 snmp_msg_getnext_event(u8_t request_id, struct snmp_msg_pstat *msg_ps) in snmp_msg_getnext_event() argument
[all …]
|
| /external/libmojo/mojo/public/cpp/bindings/lib/ |
| D | interface_endpoint_client.cc | 253 uint64_t request_id = next_request_id_++; in AcceptWithResponder() local
254 if (request_id == 0) in AcceptWithResponder()
255 request_id = next_request_id_++; in AcceptWithResponder()
257 message->set_request_id(request_id); in AcceptWithResponder()
265 async_responders_[request_id] = base::WrapUnique(responder); in AcceptWithResponder()
274 request_id, base::MakeUnique<SyncResponseInfo>(&response_received))); in AcceptWithResponder()
281 DCHECK(base::ContainsKey(sync_responses_, request_id)); in AcceptWithResponder()
282 auto iter = sync_responses_.find(request_id); in AcceptWithResponder()
390 uint64_t request_id = message->request_id(); in HandleValidatedMessage() local
393 auto it = sync_responses_.find(request_id); in HandleValidatedMessage()
[all …]
|
| /external/libmojo/mojo/public/cpp/bindings/tests/ |
| D | router_test_util.cc | 28 uint64_t request_id, in AllocResponseMessage() argument
31 internal::ResponseMessageBuilder builder(name, payload_size, request_id); in AllocResponseMessage()
63 bool result = SendResponse(message->name(), message->request_id(), in AcceptWithResponder()
72 uint64_t request_id, in SendResponse() argument
78 AllocResponseMessage(name, response_string.c_str(), request_id, &response); in SendResponse()
94 request_id_ = message->request_id(); in AcceptWithResponder()
|
| D | router_test_util.h | 23 uint64_t request_id,
49 uint64_t request_id,
|
| /external/libmojo/mojo/public/cpp/bindings/ |
| D | message.h | 110 uint64_t request_id() const { return header_v1()->request_id; } in request_id() function
111 void set_request_id(uint64_t request_id) { in set_request_id() argument
112 header_v1()->request_id = request_id; in set_request_id()
|
| /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/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()
|
| D | librpc01.h | 26 long request_id; member
|
| /external/kernel-headers/original/uapi/linux/ |
| D | uinput.h | 50 __u32 request_id; member
57 __u32 request_id; member
|
| /external/libmojo/mojo/public/interfaces/bindings/tests/data/validation/ |
| D | integration_msghdr_invalid_flags.data | 7 [u8]1 // request_id
|
| D | conformance_msghdr_invalid_flag_combo.data | 7 [u8]1 // request_id
|
| D | resp_conformance_msghdr_invalid_response_flags2.data | 7 [u8]1 // request_id
|
| D | conformance_mthd12_invalid_request_flags.data | 8 [u8]1 // request_id
|
| D | conformance_mthd0_invalid_request_flags.data | 7 [u8]1 // request_id
|
| D | resp_conformance_msghdr_invalid_response_flags1.data | 7 [u8]1 // request_id
|