Searched refs:PendingRequestPool (Results 1 – 10 of 10) sorted by relevance
| /hardware/interfaces/automotive/vehicle/aidl/impl/utils/common/src/ |
| D | PendingRequestPool.cpp | 42 PendingRequestPool::PendingRequestPool(int64_t timeoutInNano) : mTimeoutInNano(timeoutInNano) { in PendingRequestPool() function in android::hardware::automotive::vehicle::PendingRequestPool
55 PendingRequestPool::~PendingRequestPool() { in ~PendingRequestPool()
81 VhalResult<void> PendingRequestPool::addRequests( in addRequests()
120 bool PendingRequestPool::isRequestPending(const void* clientId, int64_t requestId) const { in isRequestPending()
126 size_t PendingRequestPool::countPendingRequests() const { in countPendingRequests()
138 size_t PendingRequestPool::countPendingRequests(const void* clientId) const { in countPendingRequests()
154 bool PendingRequestPool::isRequestPendingLocked(const void* clientId, int64_t requestId) const { in isRequestPendingLocked()
168 void PendingRequestPool::checkTimeout() { in checkTimeout()
203 std::unordered_set<int64_t> PendingRequestPool::tryFinishRequests( in tryFinishRequests()
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/vhal/include/ |
| D | ConnectedClient.h | 49 ConnectedClient(std::shared_ptr<PendingRequestPool> requestPool, CallbackType callback);
69 virtual std::shared_ptr<const PendingRequestPool::TimeoutCallbackFunc> getTimeoutCallback() = 0;
71 const std::shared_ptr<PendingRequestPool> mRequestPool;
80 GetSetValuesClient(std::shared_ptr<PendingRequestPool> requestPool, CallbackType callback);
94 std::shared_ptr<const PendingRequestPool::TimeoutCallbackFunc> getTimeoutCallback() override;
98 std::shared_ptr<const PendingRequestPool::TimeoutCallbackFunc> mTimeoutCallback;
|
| D | DefaultVehicleHal.h | 128 std::shared_ptr<PendingRequestPool> mPendingRequestPool;
226 const CallbackType& callback, std::shared_ptr<PendingRequestPool> pendingRequestPool);
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/utils/common/test/ |
| D | PendingRequestPoolTest.cpp | 41 void SetUp() override { mPool = std::make_unique<PendingRequestPool>(TEST_TIMEOUT); } in SetUp()
50 PendingRequestPool* getPool() { return mPool.get(); } in getPool()
62 std::unique_ptr<PendingRequestPool> mPool;
74 auto callback = std::make_shared<PendingRequestPool::TimeoutCallbackFunc>( in TEST_F()
107 auto callback = std::make_shared<PendingRequestPool::TimeoutCallbackFunc>( in TEST_F()
147 auto callback = std::make_shared<PendingRequestPool::TimeoutCallbackFunc>( in TEST_F()
167 auto callback = std::make_shared<PendingRequestPool::TimeoutCallbackFunc>( in TEST_F()
190 auto callback = std::make_shared<PendingRequestPool::TimeoutCallbackFunc>( in TEST_F()
210 auto callback = std::make_shared<PendingRequestPool::TimeoutCallbackFunc>( in TEST_F()
228 auto callback = std::make_shared<PendingRequestPool::TimeoutCallbackFunc>( in TEST_F()
[all …]
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/utils/common/include/ |
| D | PendingRequestPool.h | 36 class PendingRequestPool final {
40 explicit PendingRequestPool(int64_t timeoutInNano);
42 ~PendingRequestPool();
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/vhal/src/ |
| D | ConnectedClient.cpp | 133 std::vector<ResultType>&& results, std::shared_ptr<PendingRequestPool> requestPool) { in getOrSetValuesCallback()
185 std::vector<GetValueResult>&& results, std::shared_ptr<PendingRequestPool> requestPool);
189 std::vector<SetValueResult>&& results, std::shared_ptr<PendingRequestPool> requestPool);
193 ConnectedClient::ConnectedClient(std::shared_ptr<PendingRequestPool> requestPool, in ConnectedClient()
212 std::shared_ptr<PendingRequestPool> requestPool, std::shared_ptr<IVehicleCallback> callback) in GetSetValuesClient()
214 mTimeoutCallback = std::make_shared<const PendingRequestPool::TimeoutCallbackFunc>( in GetSetValuesClient()
234 std::shared_ptr<const PendingRequestPool::TimeoutCallbackFunc>
|
| D | DefaultVehicleHal.cpp | 106 mPendingRequestPool(std::make_shared<PendingRequestPool>(TIMEOUT_IN_NANO)), in DefaultVehicleHal()
232 const CallbackType& callback, std::shared_ptr<PendingRequestPool> pendingRequestPool) { in getOrCreateClient()
311 const CallbackType& callback, std::shared_ptr<PendingRequestPool> pendingRequestPool);
315 const CallbackType& callback, std::shared_ptr<PendingRequestPool> pendingRequestPool);
318 mPendingRequestPool = std::make_unique<PendingRequestPool>(timeoutInNano); in setTimeout()
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/vhal/test/ |
| D | ConnectedClientTest.cpp | 44 mPool = std::make_shared<PendingRequestPool>(timeout); in SetUp()
51 std::shared_ptr<PendingRequestPool> getPool() { return mPool; } in getPool()
60 std::shared_ptr<PendingRequestPool> mPool;
|
| D | DefaultVehicleHalTest.cpp | 446 std::shared_ptr<PendingRequestPool> getPool() { return mVhal->mPendingRequestPool; } in getPool()
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/utils/ |
| D | README.md | 29 ### PendingRequestPool subsection
|