NvV4l2ElementPlane.h

跳转至此文件的文档。

/*
 * 版权所有 (c) 2016, NVIDIA CORPORATION。保留所有权利。
 *
 * 只要满足以下条件，就允许以源代码和二进制形式重新发布和使用，无论是否经过
 * 修改：
 *
 * * 源代码的重新发布必须保留上述版权声明、
 *   条件列表和以下免责声明。
 *
 * * 二进制形式的重新发布必须在
 *   文档和/或随发行版提供的其他材料中复制上述版权声明、条件列表和以下免责声明。
 *
 * * 未经事先书面许可，不得使用 NVIDIA CORPORATION 的名称或其
 *   贡献者的姓名来认可或推广源自本软件的产品。
 *
 * 本软件由版权所有者“按原样”提供，并且不作任何明示或暗示的担保，包括但不限于
 * 适销性和针对特定用途的适用性的暗示担保。在任何情况下，版权所有者或
 * 贡献者均不对任何直接、间接、附带、特殊、
 * 惩戒性或后果性损害（包括但不限于
 * 替代商品或服务的采购；使用、数据或
 * 利润损失；或业务中断）承担任何责任，无论其原因和任何责任理论，
 * 无论是合同、严格责任还是侵权行为
 * （包括疏忽或其他原因）以任何方式因使用本软件而引起，即使已被告知可能发生此类损害。
 *
 * 除非适用法律要求或书面同意，否则本软件按“原样”分发，
 * 不提供任何形式的担保或条件，无论是明示的还是暗示的。
 */

#ifndef __NV_V4L2_ELELMENT_PLANE_H__
#define __NV_V4L2_ELELMENT_PLANE_H__

#include <pthread.h>
#include "NvElement.h"
#include "NvLogging.h"
#include "NvBuffer.h"

#define PLANE_DEBUG_MSG(str) COMP_DEBUG_MSG(plane_name << ":" << str);

#define PLANE_INFO_MSG(str) COMP_INFO_MSG(plane_name << ":" << str);

#define PLANE_WARN_MSG(str) COMP_WARN_MSG(plane_name << ":" << str);

#define PLANE_ERROR_MSG(str) COMP_ERROR_MSG(plane_name << ":" << str);

#define PLANE_SYS_ERROR_MSG(str) COMP_SYS_ERROR_MSG(plane_name << ":" << str);

class NvV4l2ElementPlane
{

public
 int getFormat(struct v4l2_format & format);
 int setFormat(struct v4l2_format & format);

 int mapOutputBuffers(struct v4l2_buffer &v4l2_buf, int dmabuff_fd);

 int unmapOutputBuffers(int index, int dmabuff_fd);

 int getCrop(struct v4l2_crop & crop);

 int setSelection(uint32_t target, uint32_t flags, struct v4l2_rect & rect);

 int reqbufs(enum v4l2_memory mem_type, uint32_t num);
 int queryBuffer(uint32_t buf_index);
 int exportBuffer(uint32_t buf_index);

 int setStreamStatus(bool status);

 bool getStreamStatus();

 int setStreamParms(struct v4l2_streamparm & parm);

 int setupPlane(enum v4l2_memory mem_type, uint32_t num_buffers, bool map, bool allocate);
 void deinitPlane();

 inline enum v4l2_buf_type getBufType()
 {
 return buf_type;
 }

 NvBuffer *getNthBuffer(uint32_t n);

 int dqBuffer(struct v4l2_buffer &v4l2_buf, NvBuffer ** buffer,
 NvBuffer ** shared_buffer, uint32_t num_retries);
 int qBuffer(struct v4l2_buffer &v4l2_buf, NvBuffer * shared_buffer);

 inline uint32_t getNumBuffers()
 {
 return num_buffers;
 }

 inline uint32_t getNumPlanes()
 {
 return n_planes;
 }

 void setBufferPlaneFormat(int n_planes, NvBuffer::NvBufferPlaneFormat * planefmts);

 inline uint32_t getNumQueuedBuffers()
 {
 return num_queued_buffers;
 }

 inline uint32_t getTotalDequeuedBuffers()
 {
 return total_dequeued_buffers;
 }

 inline uint32_t getTotalQueuedBuffers()
 {
 return total_queued_buffers;
 }

 int waitAllBuffersQueued(uint32_t max_wait_ms);
 int waitAllBuffersDequeued(uint32_t max_wait_ms);

typedef bool(*dqThreadCallback) (struct v4l2_buffer * v4l2_buf,
 NvBuffer * buffer, NvBuffer * shared_buffer,
 void *data);

 bool setDQThreadCallback(dqThreadCallback callback);
 int startDQThread(void *data);
 int stopDQThread();
 int waitForDQThread(uint32_t max_wait_ms);

 pthread_mutex_t plane_lock;
 pthread_cond_t plane_cond;
private
 int &fd;
 const char *plane_name;
 enum v4l2_buf_type buf_type;
 bool blocking;
 uint32_t num_buffers;
 NvBuffer **buffers;
 uint8_t n_planes;
 NvBuffer::NvBufferPlaneFormat planefmts[MAX_PLANES];
 enum v4l2_memory memory_type;
 uint32_t num_queued_buffers;
 uint32_t total_queued_buffers;
 uint32_t total_dequeued_buffers;
 bool streamon;
 bool dqthread_running;
 bool stop_dqthread;
 pthread_t dq_thread;
 dqThreadCallback callback;
 void *dqThread_data;
 static void *dqThread(void *v4l2_element_plane);

 NvElementProfiler &v4l2elem_profiler;
 inline int isInError()
 {
 return is_in_error;
 }

 NvV4l2ElementPlane(enum v4l2_buf_type buf_type, const char *device_name,
 int &fd, bool blocking, NvElementProfiler &profiler);

 NvV4l2ElementPlane(const NvV4l2ElementPlane& that);
 void operator=(NvV4l2ElementPlane const&);

 ~NvV4l2ElementPlane();

 int is_in_error;
 const char *comp_name;
 friend class NvV4l2Element;
};
#endif