| /hardware/interfaces/automotive/remoteaccess/test_grpc_server/impl/src/ |
| D | TestWakeupClientServiceImpl.cpp | 54 GetRemoteTasksResponse FakeTaskGenerator::generateTask(const std::string& clientId) { in generateTask() argument
57 response.set_clientid(clientId); in generateTask()
180 void ServiceImpl::injectTask(const std::string& taskData, const std::string& clientId) { in injectTask() argument
183 response.set_clientid(clientId); in injectTask()
195 void ServiceImpl::startGeneratingFakeTask(const std::string& clientId) { in startGeneratingFakeTask() argument
202 mFakeTaskThread = std::thread([this, clientId] { fakeTaskGenerateLoop(clientId); }); in startGeneratingFakeTask()
222 void ServiceImpl::fakeTaskGenerateLoop(const std::string& clientId) { in fakeTaskGenerateLoop() argument
226 injectTaskResponse(mFakeTaskGenerator.generateTask(clientId)); in fakeTaskGenerateLoop()
298 void ServiceImpl::cleanupScheduledTaskLocked(const std::string& clientId, in cleanupScheduledTaskLocked() argument
300 mInfoByScheduleIdByClientId[clientId].erase(scheduleId); in cleanupScheduledTaskLocked()
[all …]
|
| D | main.cpp | 180 std::string clientId; in parseCommand() local
184 while (std::getline(ss, clientId, ' ')) { in parseCommand()
194 service->startGeneratingFakeTask(clientId); in parseCommand()
211 std::string clientId; in parseCommand() local
216 clientId = data; in parseCommand()
222 if (taskData == "" || clientId == "") { in parseCommand()
226 service->injectTask(taskData, clientId); in parseCommand()
227 printf("Remote task with client ID: %s, data: %s injected\n", clientId.c_str(), in parseCommand()
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/utils/common/src/ |
| D | PendingRequestPool.cpp | 82 const void* clientId, const std::unordered_set<int64_t>& requestIds, in addRequests() argument
87 if (mPendingRequestsByClient.find(clientId) != mPendingRequestsByClient.end()) { in addRequests()
88 pendingRequests = &mPendingRequestsByClient[clientId]; in addRequests()
101 pendingRequests = &mPendingRequestsByClient[clientId]; in addRequests()
120 bool PendingRequestPool::isRequestPending(const void* clientId, int64_t requestId) const { in isRequestPending() argument
123 return isRequestPendingLocked(clientId, requestId); in isRequestPending()
130 for (const auto& [clientId, requests] : mPendingRequestsByClient) { in countPendingRequests()
138 size_t PendingRequestPool::countPendingRequests(const void* clientId) const { in countPendingRequests()
141 auto it = mPendingRequestsByClient.find(clientId); in countPendingRequests()
154 bool PendingRequestPool::isRequestPendingLocked(const void* clientId, int64_t requestId) const { in isRequestPendingLocked() argument
[all …]
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/vhal/src/ |
| D | SubscriptionManager.cpp | 119 void ContSubConfigs::addClient(const ClientIdType& clientId, const SubConfig& subConfig) { in addClient() argument
120 mConfigByClient[clientId] = subConfig; in addClient()
124 void ContSubConfigs::removeClient(const ClientIdType& clientId) { in removeClient() argument
125 mConfigByClient.erase(clientId); in removeClient()
141 bool ContSubConfigs::isVurEnabledForClient(const ClientIdType& clientId) const { in isVurEnabledForClient()
142 if (mConfigByClient.find(clientId) == mConfigByClient.end()) { in isVurEnabledForClient()
145 return mConfigByClient.at(clientId).enableVur; in isVurEnabledForClient()
148 float ContSubConfigs::getResolutionForClient(const ClientIdType& clientId) const { in getResolutionForClient()
149 if (mConfigByClient.find(clientId) == mConfigByClient.end()) { in getResolutionForClient()
152 return mConfigByClient.at(clientId).resolution; in getResolutionForClient()
[all …]
|
| D | DefaultVehicleHal.cpp | 233 const AIBinder* clientId = callback->asBinder().get(); in getOrCreateClient() local
234 if (clients->find(clientId) == clients->end()) { in getOrCreateClient()
235 (*clients)[clientId] = std::make_shared<T>(pendingRequestPool, callback); in getOrCreateClient()
237 return (*clients)[clientId]; in getOrCreateClient()
240 bool DefaultVehicleHal::monitorBinderLifeCycleLocked(const AIBinder* clientId) { in monitorBinderLifeCycleLocked() argument
242 if (mOnBinderDiedContexts.find(clientId) != mOnBinderDiedContexts.end()) { in monitorBinderLifeCycleLocked()
243 return mBinderLifecycleHandler->isAlive(clientId); in monitorBinderLifeCycleLocked()
246 OnBinderDiedContext{.vhal = this, .clientId = clientId}); in monitorBinderLifeCycleLocked()
251 mOnBinderDiedContexts[clientId] = std::move(context); in monitorBinderLifeCycleLocked()
256 const_cast<AIBinder*>(clientId), mDeathRecipient.get(), static_cast<void*>(contextPtr)); in monitorBinderLifeCycleLocked()
[all …]
|
| D | ConnectedClient.cpp | 131 const void* clientId, in getOrSetValuesCallback() argument
139 auto finishedRequests = requestPool->tryFinishRequests(clientId, requestIds); in getOrSetValuesCallback()
183 const void* clientId,
187 const void* clientId,
219 const void* clientId = id(); in GetSetValuesClient() local
221 [clientId, callback, requestPoolCopy](std::vector<ResultType> results) { in GetSetValuesClient()
223 clientId, callback, std::move(results), requestPoolCopy); in GetSetValuesClient()
|
| /hardware/interfaces/automotive/remoteaccess/hal/default/src/ |
| D | RemoteAccessService.cpp | 119 std::string clientId = std::string(buffer); in RemoteAccessService() local
126 ALOGD("Task for client: %s, data: [%s], latency: %d\n", clientId.c_str(), taskData.c_str(), in RemoteAccessService()
129 mInjectDebugTaskThread = std::thread([this, clientId, taskData, latencyInSec] { in RemoteAccessService()
131 if (auto result = deliverRemoteTaskThroughCallback(clientId, taskData); !result.ok()) { in RemoteAccessService()
133 clientId.c_str(), taskData.c_str(), result.error().message().c_str()); in RemoteAccessService()
136 ALOGD("Task for client: %s, data: [%s] successfully injected\n", clientId.c_str(), in RemoteAccessService()
189 Result<void> RemoteAccessService::deliverRemoteTaskThroughCallback(const std::string& clientId, in deliverRemoteTaskThroughCallback() argument
195 mClientIdToTaskCount[clientId] += 1; in deliverRemoteTaskThroughCallback()
200 ALOGD("Calling onRemoteTaskRequested callback for client ID: %s", clientId.c_str()); in deliverRemoteTaskThroughCallback()
202 callback->onRemoteTaskRequested(clientId, stringToBytes(taskData)); in deliverRemoteTaskThroughCallback()
[all …]
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/utils/common/include/ |
| D | PendingRequestPool.h | 52 VhalResult<void> addRequests(const void* clientId,
57 bool isRequestPending(const void* clientId, int64_t requestId) const;
63 std::unordered_set<int64_t> tryFinishRequests(const void* clientId,
67 size_t countPendingRequests(const void* clientId) const;
91 bool isRequestPendingLocked(const void* clientId, int64_t requestId) const REQUIRES(mLock);
|
| /hardware/ril/rild/ |
| D | rild.c | 123 const char *clientId = NULL; in main() local
138 clientId = argv[i+1]; in main()
145 if (clientId == NULL) { in main()
146 clientId = "0"; in main()
147 } else if (atoi(clientId) >= MAX_RILDS) { in main()
151 if (strncmp(clientId, "0", MAX_CLIENT_ID_LENGTH)) { in main()
153 clientId); in main()
207 rilArgv[argc++] = (char*)clientId; in main()
|
| /hardware/interfaces/automotive/remoteaccess/aidl_api/android.hardware.automotive.remoteaccess/2/android/hardware/automotive/remoteaccess/ |
| D | IRemoteAccess.aidl | 46 void unscheduleTask(String clientId, String scheduleId); in unscheduleTask() argument
47 void unscheduleAllTasks(String clientId); in unscheduleAllTasks() argument
48 boolean isTaskScheduled(String clientId, String scheduleId); in isTaskScheduled() argument
49 …ndroid.hardware.automotive.remoteaccess.ScheduleInfo> getAllPendingScheduledTasks(String clientId); in getAllPendingScheduledTasks() argument
|
| D | IRemoteTaskCallback.aidl | 37 oneway void onRemoteTaskRequested(String clientId, in byte[] data); in onRemoteTaskRequested() argument
|
| /hardware/interfaces/automotive/remoteaccess/aidl_api/android.hardware.automotive.remoteaccess/current/android/hardware/automotive/remoteaccess/ |
| D | IRemoteAccess.aidl | 46 void unscheduleTask(String clientId, String scheduleId); in unscheduleTask() argument
47 void unscheduleAllTasks(String clientId); in unscheduleAllTasks() argument
48 boolean isTaskScheduled(String clientId, String scheduleId); in isTaskScheduled() argument
49 …ndroid.hardware.automotive.remoteaccess.ScheduleInfo> getAllPendingScheduledTasks(String clientId); in getAllPendingScheduledTasks() argument
|
| D | IRemoteTaskCallback.aidl | 37 oneway void onRemoteTaskRequested(String clientId, in byte[] data); in onRemoteTaskRequested() argument
|
| /hardware/interfaces/automotive/remoteaccess/android/hardware/automotive/remoteaccess/ |
| D | IRemoteAccess.aidl | 184 void unscheduleTask(String clientId, String scheduleId); in unscheduleTask() argument
191 void unscheduleAllTasks(String clientId); in unscheduleAllTasks() argument
198 boolean isTaskScheduled(String clientId, String scheduleId); in isTaskScheduled() argument
207 List<ScheduleInfo> getAllPendingScheduledTasks(String clientId); in getAllPendingScheduledTasks() argument
|
| D | IRemoteTaskCallback.aidl | 34 oneway void onRemoteTaskRequested(String clientId, in byte[] data); in onRemoteTaskRequested() argument
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/vhal/include/ |
| D | SubscriptionManager.h | 53 void addClient(const ClientIdType& clientId, const SubConfig& subConfig);
54 void removeClient(const ClientIdType& clientId);
58 bool isVurEnabledForClient(const ClientIdType& clientId) const;
59 float getResolutionForClient(const ClientIdType& clientId) const;
165 VhalResult<void> addContinuousSubscriberLocked(const ClientIdType& clientId,
171 VhalResult<void> removeContinuousSubscriberLocked(const ClientIdType& clientId,
181 VhalResult<void> unsubscribePropIdAreaIdLocked(SubscriptionManager::ClientIdType clientId,
|
| D | DefaultVehicleHal.h | 108 const AIBinder* clientId; member
115 const AIBinder* clientId; member
189 void onBinderDiedWithContext(const AIBinder* clientId);
191 void onBinderUnlinkedWithContext(const AIBinder* clientId);
195 bool monitorBinderLifeCycleLocked(const AIBinder* clientId) REQUIRES(mLock);
|
| /hardware/interfaces/automotive/vehicle/2.0/default/common/src/ |
| D | SubscriptionManager.cpp | 87 ClientId clientId, in addOrUpdateSubscription() argument
97 const sp<HalClient>& client = getOrCreateHalClientLocked(clientId, callback); in addOrUpdateSubscription()
211 ClientId clientId, const sp<IVehicleCallback>& callback) { in getOrCreateHalClientLocked() argument
212 auto it = mClients.find(clientId); in getOrCreateHalClientLocked()
215 uint64_t cookie = reinterpret_cast<uint64_t>(clientId); in getOrCreateHalClientLocked()
225 mClients.insert({clientId, client}); in getOrCreateHalClientLocked()
232 void SubscriptionManager::unsubscribe(ClientId clientId, in unsubscribe() argument
236 auto clientIter = mClients.find(clientId); in unsubscribe()
276 ClientId clientId = cookie; in onCallbackDead() local
281 const auto& it = mClients.find(clientId); in onCallbackDead()
[all …]
|
| /hardware/interfaces/automotive/remoteaccess/hal/default/include/ |
| D | RemoteAccessService.h | 44 ndk::ScopedAStatus onRemoteTaskRequested(const std::string& clientId,
50 std::string clientId; member
91 ndk::ScopedAStatus unscheduleTask(const std::string& clientId,
94 ndk::ScopedAStatus unscheduleAllTasks(const std::string& clientId) override;
96 ndk::ScopedAStatus isTaskScheduled(const std::string& clientId, const std::string& scheduleId,
100 const std::string& clientId,
|
| /hardware/interfaces/automotive/remoteaccess/hal/default/proto/ |
| D | wakeup_client.proto | 82 * <p>Does nothing if a pending schedule with {@code clientId} and {@code scheduleId} does not
109 string clientId = 1; field
133 string clientId = 1; field
143 string clientId = 1; field
150 string clientId = 1; field
156 string clientId = 1; field
165 string clientId = 1; field
|
| /hardware/google/pixel/usb/ |
| D | I2cHelper.cpp | 75 string getI2cClientPath(const string hsi2cPath, const string devName, const string clientId) { in getI2cClientPath() argument
88 string i2cClientDevice = strBusNumber + "-" + clientId; in getI2cClientPath()
|
| D | UsbBusHelper.cpp | 78 const string clientId) { in getBusClientPath() argument
91 string busClientDevice = strBusNumber + "-" + clientId; in getBusClientPath()
|
| /hardware/interfaces/keymaster/4.1/support/include/keymasterV4_1/ |
| D | Keymaster4.h | 78 const hidl_vec<uint8_t>& clientId, in getKeyCharacteristics() argument
81 return km4_0_dev_->getKeyCharacteristics(keyBlob, clientId, appData, _hidl_cb); in getKeyCharacteristics()
100 const hidl_vec<uint8_t>& clientId, const hidl_vec<uint8_t>& appData, in exportKey() argument
102 return km4_0_dev_->exportKey(exportFormat, keyBlob, clientId, appData, _hidl_cb); in exportKey()
|
| /hardware/interfaces/automotive/remoteaccess/hal/default/test/ |
| D | RemoteAccessServiceUnitTest.cpp | 212 ScopedAStatus onRemoteTaskRequested(const std::string& clientId, in onRemoteTaskRequested() argument
215 mDataByClientId[clientId] = data; in onRemoteTaskRequested()
221 std::vector<uint8_t> getData(const std::string& clientId) { return mDataByClientId[clientId]; } in getData() argument
457 .clientId = kTestClientId, in TEST_F()
478 .clientId = kTestClientId, in TEST_F()
494 .clientId = kTestClientId, in TEST_F()
510 .clientId = kTestClientId, in TEST_F()
526 .clientId = kTestClientId, in TEST_F()
549 .clientId = kTestClientId, in TEST_F()
572 .clientId = kTestClientId, in TEST_F()
[all …]
|
| /hardware/interfaces/automotive/remoteaccess/test_grpc_server/impl/include/ |
| D | TestWakeupClientServiceImpl.h | 42 GetRemoteTasksResponse generateTask(const std::string& clientId);
164 void startGeneratingFakeTask(const std::string& clientId);
184 void injectTask(const std::string& taskData, const std::string& clientId);
197 void cleanupScheduledTaskLocked(const std::string& clientId, const std::string& scheduleId)
251 void fakeTaskGenerateLoop(const std::string& clientId);
|