ClientGarbageCollector.h

Go to the documentation of this file.

// Copyright (c) Qualcomm Technologies, Inc. and/or its subsidiaries.
// SPDX-License-Identifier: BSD-3-Clause-Clear
 
#ifndef CLIENT_GARBAGE_COLLECTOR_H
#define CLIENT_GARBAGE_COLLECTOR_H
 
#include <cstdint>
#include <memory>
#include <queue>
#include <mutex>
 
#include "Timer.h"
#include "RequestQueue.h"
#include "RequestManager.h"
 
class ClientGarbageCollector {
private:
    static std::shared_ptr<ClientGarbageCollector> mClientGarbageCollectorInstance;
 
    Timer* mTimer;
    std::mutex mGcQueueMutex;
    std::queue<int32_t> mGcQueue;
    uint32_t mGarbageCollectionDuration;
 
    ClientGarbageCollector();
 
    void performCleanup();
 
public:
    ~ClientGarbageCollector();
 
    ErrCode startClientGarbageCollectorDaemon();
 
    void stopClientGarbageCollectorDaemon();
    void submitClientThreadsForCleanup(int32_t clientTid);
 
    static std::shared_ptr<ClientGarbageCollector> getInstance() {
        if(mClientGarbageCollectorInstance == nullptr) {
            mClientGarbageCollectorInstance = std::shared_ptr<ClientGarbageCollector> (new ClientGarbageCollector());
        }
        return mClientGarbageCollectorInstance;
    }
};
 
ErrCode startClientGarbageCollectorDaemon();
void stopClientGarbageCollectorDaemon();
 
#endif