| /system/chre/core/ |
| D | sensor_request_multiplexer.cc | 25 const DynamicVector<SensorRequest> &requests = getRequests(); in findRequest() local
26 for (size_t i = 0; i < requests.size(); i++) { in findRequest()
27 const SensorRequest &sensorRequest = requests[i]; in findRequest()
|
| D | audio_request_manager.cc | 135 for (const auto &request : mAudioRequestLists[i].requests) { in logStateToBuffer()
188 size_t lastNumRequests = requestList.requests.size(); in doConfigureSource()
206 requestList.requests.erase(requestIndex); in doConfigureSource()
231 size_t numRequests = mAudioRequestLists[handle].requests.size(); in updatePlatformHandleEnabled()
259 if (!requestList.requests.emplace_back(numSamples, deliveryInterval, in createAudioRequest()
262 } else if (!requestList.requests.back().instanceIds.push_back(instanceId)) { in createAudioRequest()
263 requestList.requests.pop_back(); in createAudioRequest()
306 auto &requests = mAudioRequestLists[handle].requests; in findAudioRequestByInstanceId() local
307 for (size_t i = 0; i < requests.size(); i++) { in findAudioRequestByInstanceId()
308 auto &audioRequest = requests[i]; in findAudioRequestByInstanceId()
[all …]
|
| D | sensor_request_manager.cc | 118 const DynamicVector<SensorRequest> &requests = in postSamplingStatus() local
121 for (const auto &req : requests) { in postSamplingStatus()
|
| /system/server_configurable_flags/aconfigd/ |
| D | aconfigd_main.cpp | 86 auto requests = StorageRequestMessages{}; in receiveMessage()
87 if (!requests.ParseFromString(msg)) { in receiveMessage()
90 return requests; in receiveMessage()
171 auto requests = receiveMessage(client_fd.get()); in aconfigd_start() local
172 if (!requests.ok()) { in aconfigd_start()
173 LOG(ERROR) << requests.error(); in aconfigd_start()
178 for (auto& request : requests->msgs()) { in aconfigd_start()
|
| /system/server_configurable_flags/aconfigd/srcs/ |
| D | AconfigdJavaUtils.java | 134 ProtoOutputStream requests = new ProtoOutputStream(); in stageFlagsInNewStorage() local
147 writeFlagOverrideRequest(requests, packageName, flagName, stagedValue, isLocal); in stageFlagsInNewStorage()
157 InputStream returns = localSocket.send(requests.getBytes()); in stageFlagsInNewStorage()
171 ProtoOutputStream requests = new ProtoOutputStream(); in listFlagsValueInNewStorage() local
172 long msgsToken = requests.start(StorageRequestMessages.MSGS); in listFlagsValueInNewStorage()
173 long msgToken = requests.start(StorageRequestMessage.LIST_STORAGE_MESSAGE); in listFlagsValueInNewStorage()
174 requests.write(StorageRequestMessage.ListStorageMessage.ALL, 1); in listFlagsValueInNewStorage()
175 requests.end(msgToken); in listFlagsValueInNewStorage()
176 requests.end(msgsToken); in listFlagsValueInNewStorage()
178 InputStream inputStream = localSocket.send(requests.getBytes()); in listFlagsValueInNewStorage()
|
| D | AconfigdClientSocketImpl.java | 62 public InputStream send(byte[] requests) { in send() argument
84 outputStream.writeInt(requests.length); in send()
85 outputStream.write(requests); in send()
|
| D | AconfigdClientSocket.java | 30 public InputStream send(byte[] requests); in send() argument
|
| /system/chre/java/test/utils/src/com/google/android/utils/chre/ |
| D | ChreApiTestUtil.java | 204 @NonNull List<RequestType> requests) throws Exception { in callConcurrentUnaryRpcMethodSync() argument
207 Objects.requireNonNull(requests); in callConcurrentUnaryRpcMethodSync()
208 if (rpcClients.size() != requests.size()) { in callConcurrentUnaryRpcMethodSync()
215 Iterator<RequestType> requestsIter = requests.iterator(); in callConcurrentUnaryRpcMethodSync()
261 List<RequestType> requests = new ArrayList<RequestType>(); in callConcurrentUnaryRpcMethodSync() local
263 requests.add(request); in callConcurrentUnaryRpcMethodSync()
265 return callConcurrentUnaryRpcMethodSync(rpcClients, method, requests); in callConcurrentUnaryRpcMethodSync()
614 @NonNull List<RequestType> requests, in callConcurrentServerStreamingRpcMethodAsync() argument
618 Objects.requireNonNull(requests); in callConcurrentServerStreamingRpcMethodAsync()
619 if (rpcClients.size() != requests.size()) { in callConcurrentServerStreamingRpcMethodAsync()
[all …]
|
| /system/core/libappfuse/tests/ |
| D | FuseAppLoopTest.cc | 42 std::vector<CallbackRequest> requests; member in android::fuse::__anon7435ee890111::Callback
56 requests.push_back({.code = FUSE_FSYNC, .inode = inode}); in OnFsync()
62 requests.push_back({.code = FUSE_WRITE, .inode = inode}); in OnWrite()
68 requests.push_back({.code = FUSE_READ, .inode = inode}); in OnRead()
73 requests.push_back({.code = FUSE_OPEN, .inode = inode}); in OnOpen()
78 requests.push_back({.code = FUSE_RELEASE, .inode = inode}); in OnRelease()
115 ASSERT_EQ(1u, callback_.requests.size()); in CheckCallback()
116 EXPECT_EQ(code, callback_.requests[0].code); in CheckCallback()
117 EXPECT_EQ(10u, callback_.requests[0].inode); in CheckCallback()
|
| /system/chre/chpp/ |
| D | RELEASE_NOTES.md | 111 - Correct responses generated at clients when async requests fail at services
161 …correctly implement the close() PAL API so that it disables any ongoing requests and returns to a …
270 Services can now send requests and receive responses from clients.
285 … to make code clearer as both clients and services now support both incoming and outgoing requests,
292 …YPE_CLIENT_RESPONSE` to the message types (`ChppMessageType`). Used for requests sent by the servi…
294 …holding the number of commands supported by the service (0 when the service can not send requests),
295 - Added `ChppClient.requestDispatchFunctionPtr` to handle service requests,
327 …ct ChppOutgoingRequestState *` to track outgoing requests. `NULL` when the service do not send req…
331 …questFixed` and `chppAllocServiceRequestTypedArray` to allocate service requests. They call the ad…
332 - Added `ChppServiceState.outReqStates` to track outgoing requests,
[all …]
|
| /system/libsysprop/srcs/android/sysprop/ |
| D | CarProperties.sysprop | 63 # Timeout (in ms) waiting for Vehicle HAL responses for user management requests.
72 # Timeout (in ms) waiting for Device Policy Manager responses for user management requests.
|
| /system/secretkeeper/ |
| D | README.md | 14 The requests (from the client) & responses (from Secretkeeper) must be encrypted using symmetric
34 able to detect it & return an error when clients requests for their secrets.
60 sessions with Secretkeeper, sending requests etc.
125 - Starts a thread pool to service requests.
136 which allows it to service Binder requests by forwarding the requests to the TA as request/response
170 - [ ] Implementation of `main` equivalent for TA, handling scheduling of incoming requests.
|
| /system/server_configurable_flags/aconfigd/tests/ |
| D | AconfigdJavaUtilsTest.java | 245 public InputStream send(byte[] requests) { in send() argument
246 return mSendFunc.apply(requests); in send()
|
| /system/chre/core/include/chre/core/ |
| D | audio_request_manager.h | 170 DynamicVector<AudioRequest> requests; member
|
| /system/keymint/ |
| D | README.md | 83 - Starts a thread pool to service requests.
94 types, which allows them to service Binder requests for the relevant interface by forwarding the
95 requests to the TA as request/response pairs.
127 - [ ] Implementation of `main` equivalent for TA, handling scheduling of incoming requests.
|
| /system/hardware/interfaces/net/netd/1.0/ |
| D | INetd.hal | 25 * Return values for INetd requests
|
| /system/nfc/tools/casimir/scripts/ |
| D | t4at.py | 25 import requests
|
| /system/hardware/interfaces/wifi/keystore/1.0/ |
| D | IKeystore.hal | 26 * Return values for Keystore requests.
|
| /system/sepolicy/private/ |
| D | snapuserd.te | 1 # snapuserd - Daemon for servicing dm-user requests for Virtual A/B snapshots.
|
| D | kernel.te | 121 # Needed because APEX uses the loopback driver, which issues requests from
|
| /system/sepolicy/microdroid/system/private/ |
| D | kernel.te | 78 # Needed because APEX uses the loopback driver, which issues requests from
|
| /system/extras/simpleperf/ |
| D | README.md | 20 "Submit build requests". You'll get emails keeping you up to date with the
|
| /system/chre/platform/shared/idl/ |
| D | host_messages.fbs | 148 /// meaning that load requests will be processed in the order they are sent
149 /// but multiple requests can be outstanding at any given time.
156 /// sequential requests, which will follow the following steps:
169 /// requests starting from the second fragment, all fields except
|
| /system/chre/doc/ |
| D | framework_overview.md | 95 5. The request is validated and combined with other nanoapp requests for the
151 functionality, such as multiplexing sensor requests from all clients into a
|
| D | porting_guide.md | 243 cancel active requests, and not invoke any CHRE callbacks from this point
255 requests as needed, by invoking the request functions in the Module API. The PAL
256 is expected to process these requests, and invoke the appropriate CHRE provided
|