Home
last modified time | relevance | path

Searched refs:requestIds (Results 1 – 6 of 6) sorted by relevance

/hardware/interfaces/automotive/vehicle/aidl/impl/utils/common/src/
DPendingRequestPool.cpp74 (*request.callback)(request.requestIds); in ~PendingRequestPool()
82 const void* clientId, const std::unordered_set<int64_t>& requestIds, in addRequests() argument
90 const auto& pendingRequestIds = pendingRequest.requestIds; in addRequests()
91 for (int64_t requestId : requestIds) { in addRequests()
104 if (requestIds.size() > MAX_PENDING_REQUEST_PER_CLIENT - pendingRequestCount) { in addRequests()
112 .requestIds = std::unordered_set<int64_t>(requestIds.begin(), requestIds.end()), in addRequests()
132 count += request.requestIds.size(); in countPendingRequests()
148 count += pendingRequest.requestIds.size(); in countPendingRequests()
160 const auto& requestIds = pendingRequest.requestIds; in isRequestPendingLocked() local
161 if (requestIds.find(requestId) != requestIds.end()) { in isRequestPendingLocked()
[all …]
/hardware/interfaces/automotive/vehicle/aidl/impl/utils/common/test/
DPendingRequestPoolTest.cpp69 std::unordered_set<int64_t> requestIds; in TEST_F() local
71 requestIds.insert(i); in TEST_F()
82 ASSERT_RESULT_OK(getPool()->addRequests(getTestClientId(), requestIds, callback)); in TEST_F()
102 std::unordered_set<int64_t> requestIds; in TEST_F() local
104 requestIds.insert(i); in TEST_F()
115 ASSERT_RESULT_OK(getPool()->addRequests(getTestClientId(), requestIds, callback)); in TEST_F()
122 requestIds.clear(); in TEST_F()
124 requestIds.insert(i); in TEST_F()
127 ASSERT_EQ(getPool()->tryFinishRequests(getTestClientId(), requestIds), requestIds); in TEST_F()
/hardware/interfaces/automotive/vehicle/aidl/impl/utils/common/include/
DPendingRequestPool.h53 const std::unordered_set<int64_t>& requestIds,
64 const std::unordered_set<int64_t>& requestIds);
77 std::unordered_set<int64_t> requestIds; member
/hardware/interfaces/automotive/vehicle/aidl/impl/vhal/src/
DConnectedClient.cpp134 std::unordered_set<int64_t> requestIds; in getOrSetValuesCallback() local
136 requestIds.insert(result.requestId); in getOrSetValuesCallback()
139 auto finishedRequests = requestPool->tryFinishRequests(clientId, requestIds); in getOrSetValuesCallback()
201 VhalResult<void> ConnectedClient::addRequests(const std::unordered_set<int64_t>& requestIds) { in addRequests() argument
202 return mRequestPool->addRequests(id(), requestIds, getTimeoutCallback()); in addRequests()
206 const std::unordered_set<int64_t>& requestIds) { in tryFinishRequests() argument
207 return mRequestPool->tryFinishRequests(id(), requestIds); in tryFinishRequests()
DDefaultVehicleHal.cpp633 std::vector<int64_t> requestIds; \
642 requestIds.push_back(request.requestId); \
644 return requestIds; \
/hardware/interfaces/automotive/vehicle/aidl/impl/vhal/include/
DConnectedClient.h61 VhalResult<void> addRequests(const std::unordered_set<int64_t>& requestIds);
65 std::unordered_set<int64_t> tryFinishRequests(const std::unordered_set<int64_t>& requestIds);