convbufmanager.h

Go to the documentation of this file.

 
#ifndef _CONVBUFMANAGER_H
#define _CONVBUFMANAGER_H
 
#include <vector>
#include <queue>
#include <mutex>
#include <condition_variable>
#include <cuda.h>
#include <cuda_runtime.h>
 
#include "nvbufsurface.h"
#include "nvbufsurftransform.h"
 
#define MAX_BUFFER_POOL_SIZE 2 // Set surface buffer pool size as a fixed number.
 
class ConvBufManager
{
public:
  ConvBufManager();
  ~ConvBufManager();
 
  bool init(uint32_t batchSize, int32_t gpuId, int32_t compute_hw,
        NvBufSurfaceCreateParams& bufferParam, const bool empty);
  void deInit();
 
  NvBufSurface *convertBatchAsync(NvBufSurface *pBatchIn, NvBufSurfTransformSyncObj_t *bufSetSyncObjs);
  void returnBuffer(NvBufSurface *pBufferSet);
  void syncBuffer(NvBufSurface *pBufferSet, NvBufSurfTransformSyncObj_t *bufSetSyncObjs);
  bool isQueueFull() {
    return (m_FreeQueue.size() == MAX_BUFFER_POOL_SIZE);
  }
  bool isQueueEmpty() {
    return (m_FreeQueue.empty());
  }
  int getMaxPoolSize() {
    return MAX_BUFFER_POOL_SIZE;
  }
 
private:
  std::vector<NvBufSurface *> m_BufferSet;
 
  bool m_Running;
  bool m_Initialized;
  bool m_IntentionallyEmpty;
  NvBufSurfTransformParams m_TransformParams;
  NvBufSurfTransformConfigParams m_TransformConfigParams;
  std::queue<NvBufSurface *> m_FreeQueue;
};
 
#endif