| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| request_id.cc | 16 #include "tensorflow/core/distributed_runtime/request_id.h"
23 int64 request_id = 0; local
24 while (request_id == 0) {
25 request_id = random::New64();
27 return request_id;
|
| recent_request_ids.cc | 29 Status RecentRequestIds::TrackUnique(int64 request_id,
33 if (request_id == 0) {
34 // For backwards compatibility, allow all requests with request_id 0.
37 if (set_.count(request_id) > 0) {
39 // request_id's age in the circular_buffer_ if it's tracked again. Strict
47 // Remove the oldest request_id from the set_. circular_buffer_ is
51 circular_buffer_[next_index_] = request_id;
52 set_.insert(request_id);
|
| recent_request_ids.h | 31 // reached, the oldest request_id is evicted. Thread safe.
42 // buffer tracks the oldest request_id. When the buffer is full, the new
43 // request_id replaces the oldest request_id in the circular buffer, and the
44 // oldest request_id is removed from the set.
53 // Returns OK iff request_id has not been seen in the last
55 // always returns OK for request_id 0. The method_name and the request's
57 Status TrackUnique(int64 request_id, const string& method_name,
64 // request_id.
|
| recent_request_ids_test.cc | 27 Status TrackUnique(int64 request_id, RecentRequestIds* recent_request_ids) {
29 request.set_request_id(request_id);
30 return recent_request_ids->TrackUnique(request_id, "recent_request_ids_test",
34 // request_id 0 is always valid.
74 // Check that the oldest request_id is evicted.
|
| /system/bt/service/common/android/bluetooth/ |
| IBluetoothGattServerCallback.aidl | 27 int request_id, int offset, boolean is_long, int handle);
30 int request_id, int offset, boolean is_long, int handle);
33 int request_id, int offset, boolean is_prepare_write, boolean need_response,
37 int request_id, int offset, boolean is_prepare_write, boolean need_response,
41 int request_id, boolean is_execute);
|
| IBluetoothGattServer.aidl | 34 int request_id,
|
| /system/bt/service/doc/ |
| IBluetoothGattServerCallback.txt | 46 * |request_id| and the appropriate characteristic value.
53 void onCharacteristicReadRequest(in String device_address, in int request_id,
64 * |request_id| and the appropriate descriptor value.
71 void onDescriptorReadRequest(in String device_address, in int request_id,
80 * |request_id|. |offset| is the index of the characteristic value that the
90 void onCharacteristicWriteRequest(in String device_address, in int request_id,
100 * |request_id|. |offset| is the index of the descriptor value that the
110 void onDescriptorWriteRequest(in String device_address, in int request_id,
121 * with the given |request_id|.
123 void onExecuteWriteRequest(in String device_address, in int request_id,
[all...] |
| IBluetoothGattServer.txt | 52 * a unique |request_id| which must be passed to this method along with the
60 in int request_id, in int status,
|
| /external/perfetto/src/ipc/ |
| service_proxy.cc | 60 RequestID request_id = 0; local
63 request_id =
72 // When passing |drop_reply| == true, the returned |request_id| should be 0.
73 PERFETTO_DCHECK(!drop_reply || !request_id);
75 if (!request_id)
77 PERFETTO_DCHECK(pending_callbacks_.count(request_id) == 0);
78 pending_callbacks_.emplace(request_id, std::move(reply));
81 void ServiceProxy::EndInvoke(RequestID request_id,
84 auto callback_it = pending_callbacks_.find(request_id);
|
| client_impl.cc | 61 RequestID request_id = ++last_request_id_;
63 frame.set_request_id(request_id);
73 qr.request_id = request_id;
75 queued_requests_.emplace(request_id, std::move(qr));
90 RequestID request_id = ++last_request_id_; local
92 frame.set_request_id(request_id);
107 qr.request_id = request_id;
110 queued_requests_.emplace(request_id, std::move(qr))
257 const RequestID request_id = req.request_id; local
[all...] |
| /external/ltp/testcases/network/rpc/basic_tests/rpc01/lib/ |
| librpc01.h | 26 long request_id; member in struct:data
|
| librpc01.c | 30 rc = rc && xdr_long(xdrs, &bp->request_id);
44 rc = rc && xdr_long(xdrs, &buffer->request_id);
|
| /external/libmojo/mojo/public/cpp/bindings/tests/ |
| router_test_util.cc | 28 uint64_t request_id,
31 internal::ResponseMessageBuilder builder(name, payload_size, request_id);
63 bool result = SendResponse(message->name(), message->request_id(),
72 uint64_t request_id,
78 AllocResponseMessage(name, response_string.c_str(), request_id, &response);
94 request_id_ = message->request_id();
|
| router_test_util.h | 23 uint64_t request_id,
49 uint64_t request_id,
|
| /hardware/qcom/wlan/qcwcn/wifi_hal/ |
| wifihal_internal.h | 60 int (*rtt_range_request)(u32 request_id,
65 int (*rtt_range_cancel)(u32 request_id,
83 wifi_error (*start_gscan)(wifi_request_id request_id,
88 wifi_error (*stop_gscan)(wifi_request_id request_id,
97 wifi_error (*set_bssid_hotlist)(wifi_request_id request_id,
102 wifi_error (*reset_bssid_hotlist)(wifi_request_id request_id,
|
| /system/bt/service/ipc/binder/ |
| bluetooth_gatt_server_binder_server.h | 59 int32_t request_id, int32_t status, int32_t offset,
70 int request_id, int offset, bool is_long,
74 int request_id, int offset, bool is_long,
78 int request_id, int offset,
84 int request_id, int offset,
89 const std::string& device_address, int request_id,
|
| bluetooth_gatt_server_binder_server.cc | 111 int server_id, const String16& device_address, int request_id, int status,
124 std::string(String8(device_address).string()), request_id,
178 int request_id, int offset, bool is_long, uint16_t handle) {
189 String16(device_address.c_str(), device_address.length()), request_id, local
195 int request_id, int offset, bool is_long, uint16_t handle) {
206 String16(device_address.c_str(), device_address.length()), request_id, local
241 int request_id, int offset, bool is_prepare_write, bool need_response,
253 String16(device_address.c_str(), device_address.length()), request_id, local
259 int request_id, int offset, bool is_prepare_write, bool need_response,
271 String16(device_address.c_str(), device_address.length()), request_id, local
288 String16(device_address.c_str(), device_address.length()), request_id, local
[all...] |
| /frameworks/base/core/proto/android/net/ |
| networkrequest.proto | 71 optional int32 request_id = 2;
|
| /system/update_engine/ |
| chrome_browser_proxy_resolver.h | 43 void OnGetChromeProxyServers(ProxyRequestId request_id,
47 // Finds the callback identified by |request_id| in |pending_callbacks_|,
50 void RunCallback(ProxyRequestId request_id,
|
| chrome_browser_proxy_resolver.cc | 52 ProxyRequestId request_id, bool success,
56 auto it = pending_callbacks_.find(request_id);
|
| /system/bt/service/example/heart_rate/ |
| heart_rate_server.h | 63 int request_id, int offset, bool is_long,
65 Status OnDescriptorReadRequest(const String16& device_address, int request_id,
68 int request_id, int offset,
73 int request_id, int offset,
77 Status OnExecuteWriteRequest(const String16& device_address, int request_id,
|
| heart_rate_server.cc | 314 const String16& device_address, int request_id, int offset,
330 gatt_->SendResponse(server_if_, device_address, request_id, error, offset,
336 int request_id, int offset,
346 gatt_->SendResponse(server_if_, device_address, request_id,
364 gatt_->SendResponse(server_if_, device_address, request_id, error, offset,
370 const String16& device_address, int request_id, int offset,
382 gatt_->SendResponse(server_if_, device_address, request_id,
395 gatt_->SendResponse(server_if_, device_address, request_id,
407 gatt_->SendResponse(server_if_, device_address, request_id,
413 const String16& device_address, int request_id, int offset
[all...] |
| /tools/test/connectivity/acts/tests/google/ble/gatt/ |
| GattReadTest.py | 62 request_id = event['data']['requestId']
70 bt_device_id, request_id,
131 request_id = event['data']['requestId']
139 self.gatt_server, bt_device_id, request_id, status, offset,
181 request_id = event['data']['requestId']
189 bt_device_id, request_id,
|
| /external/libmojo/mojo/public/cpp/bindings/lib/ |
| interface_endpoint_client.cc | 253 uint64_t request_id = next_request_id_++; local
254 if (request_id == 0)
255 request_id = next_request_id_++;
257 message->set_request_id(request_id);
265 async_responders_[request_id] = base::WrapUnique(responder);
274 request_id, base::MakeUnique<SyncResponseInfo>(&response_received)));
281 DCHECK(base::ContainsKey(sync_responses_, request_id));
282 auto iter = sync_responses_.find(request_id);
390 uint64_t request_id = message->request_id(); local
[all...] |
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.15-4.8/sysroot/usr/include/linux/ |
| uinput.h | 41 int request_id; member in struct:uinput_ff_upload
48 int request_id; member in struct:uinput_ff_erase
89 * 2. Allocate a uinput_ff_upload struct, fill in request_id with
103 * 2. Allocate a uinput_ff_erase struct, fill in request_id with
|
