libcamera3/common_v2/Pipes2/ExynosCameraPipeFlite.h - LeafOS-Devices/android_hardware_samsung_slsi-linaro_exynos - Gitiles

 /*
 **
 ** Copyright 2017, Samsung Electronics Co. LTD
 **
 ** Licensed under the Apache License, Version 2.0 (the "License");
 ** you may not use this file except in compliance with the License.
 ** You may obtain a copy of the License at
 **
 **     http://www.apache.org/licenses/LICENSE-2.0
 **
 ** Unless required by applicable law or agreed to in writing, software
 ** distributed under the License is distributed on an "AS IS" BASIS,
 ** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 ** See the License for the specific language governing permissions and
 ** limitations under the License.
 */

 #ifndef EXYNOS_CAMERA_PIPE_FLITE_H
 #define EXYNOS_CAMERA_PIPE_FLITE_H

 #include "ExynosCameraPipe.h"

 namespace android {

 typedef ExynosCameraList<ExynosCameraFrameSP_sptr_t> frame_queue_t;

 #define FLITE_CNTS  ( FIMC_IS_VIDEO_SS3_NUM - FIMC_IS_VIDEO_SS0_NUM + 2) /* HACK : because of 4 cameras , wide tele front iris , 1->2 */
 #ifdef SUPPORT_DEPTH_MAP
 #define VC_CNTS     (FIMC_IS_VIDEO_SS3VC3_NUM - FIMC_IS_VIDEO_SS0VC0_NUM + 1)
 #endif

 class ExynosCameraPipeFlite : public ExynosCameraPipe {
 public:
     ExynosCameraPipeFlite()
     {
         m_init();
     }

     ExynosCameraPipeFlite(
         int cameraId,
         ExynosCameraConfigurations *configurations,
         ExynosCameraParameters *obj_param,
         bool isReprocessing,
         int32_t *nodeNums)  : ExynosCameraPipe(cameraId, configurations, obj_param, isReprocessing, nodeNums)
     {
         m_init();
     }

     virtual ~ExynosCameraPipeFlite();

     virtual status_t        create(int32_t *sensorIds = NULL);
     virtual status_t        destroy(void);
 #ifdef SUPPORT_DEPTH_MAP
     virtual status_t        start(void);
     virtual status_t        stop(void);
 #endif

     virtual status_t        setupPipe(camera_pipe_info_t *pipeInfos, int32_t *sensorIds = NULL);

     virtual status_t        sensorStream(bool on);

 protected:
     virtual bool            m_mainThreadFunc(void);
     virtual status_t        m_getBuffer(void);
     virtual status_t        m_setPipeInfo(camera_pipe_info_t *pipeInfos);

     /*
      * Multi-singleton :
      * User must call createInstance to get PipeLite obj.
      * because 4 flites must be open once.
      *
      */
     static ExynosCameraNode *m_createNode(int cameraId, int nodeNum)
     {
         Mutex::Autolock lock(g_nodeInstanceMutex);

         status_t ret = NO_ERROR;

         int index = nodeNum - FIMC_IS_VIDEO_SS0_NUM + 1;

         if (index < 0 || FLITE_CNTS <= index)
         {
             ALOGE("[CAM_ID(%d)]-ERR(%s[%d]):invalid Index(%d) fail", cameraId, __FUNCTION__, __LINE__, index);
             return NULL;
         }

         if (g_node[index] == NULL) {
             if (g_nodeRefCount[index] != 0) {
                 ALOGW("[CAM_ID(%d)]-WARN(%s[%d]):invalid g_nodeRefCount[%d](%d). so, set 0",
                     cameraId, __FUNCTION__, __LINE__, index, g_nodeRefCount[index]);

                 g_nodeRefCount[index] = 0;
             }

             g_node[index] = new ExynosCameraNode();

             ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]): new g_node[%d]",
                 cameraId, __FUNCTION__, __LINE__, index);

             ret = g_node[index]->create("FLITE", cameraId);
             if (ret < 0) {
                 ALOGE("[CAM_ID(%d)]-ERR(%s[%d]): create(FLITE) fail, ret(%d)",
                     cameraId, __FUNCTION__, __LINE__, ret);

                 SAFE_DELETE(g_node[index]);
                 return NULL;
             }

             ret = g_node[index]->open(nodeNum);
             if (ret < 0) {
                 ALOGE("[CAM_ID(%d)]-ERR(%s[%d]): open(%d) fail, ret(%d)",
                     cameraId, __FUNCTION__, __LINE__, nodeNum, ret);

                 SAFE_DELETE(g_node[index]);
                 return NULL;
             }

             ALOGV("[CAM_ID(%d)]-DEBUG(%s[%d]):Node(%d) opened",
                 cameraId, __FUNCTION__, __LINE__, nodeNum);
         } else {
             ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]): skip new g_nodeRefCount[%d] : (%d)",
                 cameraId, __FUNCTION__, __LINE__, index, g_nodeRefCount[index]);
         }

         /* when calll this, increase ref */
         g_nodeRefCount[index]++;

         return g_node[index];
     }

 #ifdef SUPPORT_DEPTH_MAP
     static ExynosCameraNode *m_createVcNode(int cameraId, int nodeNum)
     {
         Mutex::Autolock lock(g_vcNodeInstanceMutex);

         status_t ret = NO_ERROR;
         char vcNodeName[8] = {'\0',};

         int index = nodeNum - FIMC_IS_VIDEO_SS0VC0_NUM + 1;
         if (index < 0 || VC_CNTS <= index) {
             ALOGE("[CAM_ID(%d)]-ERR(%s[%d]):Invalid index %d",
                     cameraId, __FUNCTION__, __LINE__, index);
             return NULL;
         }

         if (g_vcNode[index] == NULL) {
             if (g_vcNodeRefCount[index] != 0) {
                 ALOGW("[CAM_ID(%d)]-WARN(%s[%d]):Invalid g_vcNodeRefCount %d index %d",
                         cameraId, __FUNCTION__, __LINE__, g_vcNodeRefCount[index], index);

                 g_vcNodeRefCount[index] = 0;
             }

             g_vcNode[index] = new ExynosCameraNode();

             ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]):new g_vcNode[%d]",
                     cameraId, __FUNCTION__, __LINE__, index);

             snprintf(vcNodeName, sizeof(vcNodeName), "CAM%dVC%d", cameraId, (index%FLITE_CNTS) - 1);

             ret = g_vcNode[index]->create(vcNodeName, cameraId);
             if (ret < 0) {
                 ALOGE("[CAM_ID(%d)]-ERR(%s[%d]):Failed to create %s, ret %d",
                         cameraId, __FUNCTION__, __LINE__, vcNodeName, ret);

                 SAFE_DELETE(g_vcNode[index]);
                 return NULL;
             }

             ret = g_vcNode[index]->open(nodeNum);
             if (ret < 0) {
                 ALOGE("[CAM_ID(%d)]-ERR(%s[%d]):Failed to open node %d ret %d",
                         cameraId, __FUNCTION__, __LINE__, nodeNum, ret);

                 SAFE_DELETE(g_vcNode[index]);
                 return NULL;
             }

             ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]):Node %d opened",
                     cameraId, __FUNCTION__, __LINE__, nodeNum);

         } else {
             ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]):Skip new g_vcNodeRefCount[%d] : %d",
                     cameraId, __FUNCTION__, __LINE__, index, g_vcNodeRefCount[index]);
         }

         g_vcNodeRefCount[index]++;

         return g_vcNode[index];
     }
 #endif
     /*
      * Multi-singleton :
      * User must call DestoryInstance to delete PipeLite obj.
      * This will destroy obj, when only g_nodeRefCount == 0.
      */
     static void  m_destroyNode(int cameraId, ExynosCameraNode * obj)
     {
         if (obj == NULL) {
             ALOGE("[CAM_ID(%d)]-ERR(%s[%d]):obj == NULL. so fail",
                 cameraId, __FUNCTION__, __LINE__);
             return;
         }

         Mutex::Autolock lock(g_nodeInstanceMutex);

         for (int index = 0; index < FLITE_CNTS; index++)
         {
             if (obj == g_node[index]) {
                 if (1 < g_nodeRefCount[index]) {
                     ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]): skip delete g_nodeRefCount[%d] : (%d)",
                         cameraId, __FUNCTION__, __LINE__, index, g_nodeRefCount[index]);

                     g_nodeRefCount[index]--;
                 } else if (g_nodeRefCount[index] == 1) {
                     ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]): delete g_nodeRefCount[%d] : (%d)",
                         cameraId, __FUNCTION__, __LINE__, index, g_nodeRefCount[index]);

                     if (g_node[index]->close() != NO_ERROR) {
                         ALOGE("[CAM_ID(%d)]-DEBUG(%s[%d]): close fail",
                             cameraId, __FUNCTION__, __LINE__);
                     }

                     SAFE_DELETE(g_node[index]);
                     g_nodeRefCount[index]--;
                 } else { /* g_nodeRefCount[index] < 1) */
                     ALOGW("[CAM_ID(%d)]-WARN(%s[%d]):invalid g_nodeRefCount[%d](%d). so, set 0",
                         cameraId, __FUNCTION__, __LINE__, index, g_nodeRefCount[index]);

                     g_nodeRefCount[index] = 0;
                 }
             }
         }
     }

 #ifdef SUPPORT_DEPTH_MAP
     static void m_destroyVcNode(int cameraId, ExynosCameraNode *obj)
     {
         if (obj == NULL) {
             ALOGE("[CAM_ID(%d)]-ERR(%s[%d]):obj == NULL. so fail",
                     cameraId, __FUNCTION__, __LINE__);
             return;
         }

         Mutex::Autolock lock(g_vcNodeInstanceMutex);

         for (int index = 0; index < VC_CNTS; index++) {
             if (obj == g_vcNode[index]) {
                 if (1 < g_vcNodeRefCount[index]) {
                     ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]):skip delete g_vcNodeRefCount[%d] : %d",
                             cameraId, __FUNCTION__, __LINE__, index, g_vcNodeRefCount[index]);

                     g_vcNodeRefCount[index]--;
                 } else if (g_vcNodeRefCount[index] == 1) {
                     ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]):delete g_vcNodeRefCount[%d] : %d",
                             cameraId, __FUNCTION__, __LINE__, index, g_vcNodeRefCount[index]);

                     if (g_vcNode[index]->close() != NO_ERROR) {
                         ALOGE("[CAM_ID(%d)]-DEBUG(%s[%d]):close fail",
                                 cameraId, __FUNCTION__, __LINE__);
                     }

                     SAFE_DELETE(g_vcNode[index]);
                     g_vcNodeRefCount[index]--;
                 } else {
                     ALOGW("[CAM_ID(%d)]-WARN(%s[%d]):invalid g_vcNodeRefCount[%d] %d. so, set 0",
                             cameraId, __FUNCTION__, __LINE__, index, g_vcNodeRefCount[index]);

                     g_vcNodeRefCount[index] = 0;
                 }
             }
         }
     }
 #endif

 private:
     void     m_init(void);

     /* Override */
     status_t m_updateMetadataToFrame(void *metadata, int index);

 private:
 //#ifdef SHOT_RECOVERY
     int                     retryGetBufferCount;
 //#endif

     /* global variable for multi-singleton */
     static Mutex             g_nodeInstanceMutex;
     static ExynosCameraNode *g_node[FLITE_CNTS];
     static int               g_nodeRefCount[FLITE_CNTS];
 #ifdef SUPPORT_DEPTH_MAP
     static Mutex             g_vcNodeInstanceMutex;
     static ExynosCameraNode *g_vcNode[VC_CNTS];
     static int               g_vcNodeRefCount[VC_CNTS];
 #endif
 };

 }; /* namespace android */

 #endif
	/*
	**
	** Copyright 2017, Samsung Electronics Co. LTD
	**
	** Licensed under the Apache License, Version 2.0 (the "License");
	** you may not use this file except in compliance with the License.
	** You may obtain a copy of the License at
	**
	** http://www.apache.org/licenses/LICENSE-2.0
	**
	** Unless required by applicable law or agreed to in writing, software
	** distributed under the License is distributed on an "AS IS" BASIS,
	** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	** See the License for the specific language governing permissions and
	** limitations under the License.
	*/

	#ifndef EXYNOS_CAMERA_PIPE_FLITE_H
	#define EXYNOS_CAMERA_PIPE_FLITE_H

	#include "ExynosCameraPipe.h"

	namespace android {

	typedef ExynosCameraList<ExynosCameraFrameSP_sptr_t> frame_queue_t;

	#define FLITE_CNTS ( FIMC_IS_VIDEO_SS3_NUM - FIMC_IS_VIDEO_SS0_NUM + 2) /* HACK : because of 4 cameras , wide tele front iris , 1->2 */
	#ifdef SUPPORT_DEPTH_MAP
	#define VC_CNTS (FIMC_IS_VIDEO_SS3VC3_NUM - FIMC_IS_VIDEO_SS0VC0_NUM + 1)
	#endif

	class ExynosCameraPipeFlite : public ExynosCameraPipe {
	public:
	ExynosCameraPipeFlite()
	{
	m_init();
	}

	ExynosCameraPipeFlite(
	int cameraId,
	ExynosCameraConfigurations *configurations,
	ExynosCameraParameters *obj_param,
	bool isReprocessing,
	int32_t *nodeNums) : ExynosCameraPipe(cameraId, configurations, obj_param, isReprocessing, nodeNums)
	{
	m_init();
	}

	virtual ~ExynosCameraPipeFlite();

	virtual status_t create(int32_t *sensorIds = NULL);
	virtual status_t destroy(void);
	#ifdef SUPPORT_DEPTH_MAP
	virtual status_t start(void);
	virtual status_t stop(void);
	#endif

	virtual status_t setupPipe(camera_pipe_info_t pipeInfos, int32_t sensorIds = NULL);

	virtual status_t sensorStream(bool on);

	protected:
	virtual bool m_mainThreadFunc(void);
	virtual status_t m_getBuffer(void);
	virtual status_t m_setPipeInfo(camera_pipe_info_t *pipeInfos);

	/*
	* Multi-singleton :
	* User must call createInstance to get PipeLite obj.
	* because 4 flites must be open once.
	*
	*/
	static ExynosCameraNode *m_createNode(int cameraId, int nodeNum)
	{
	Mutex::Autolock lock(g_nodeInstanceMutex);

	status_t ret = NO_ERROR;

	int index = nodeNum - FIMC_IS_VIDEO_SS0_NUM + 1;

	if (index < 0 \|\| FLITE_CNTS <= index)
	{
	ALOGE("[CAM_ID(%d)]-ERR(%s[%d]):invalid Index(%d) fail", cameraId, __FUNCTION__, __LINE__, index);
	return NULL;
	}

	if (g_node[index] == NULL) {
	if (g_nodeRefCount[index] != 0) {
	ALOGW("[CAM_ID(%d)]-WARN(%s[%d]):invalid g_nodeRefCount[%d](%d). so, set 0",
	cameraId, __FUNCTION__, __LINE__, index, g_nodeRefCount[index]);

	g_nodeRefCount[index] = 0;
	}

	g_node[index] = new ExynosCameraNode();

	ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]): new g_node[%d]",
	cameraId, __FUNCTION__, __LINE__, index);

	ret = g_node[index]->create("FLITE", cameraId);
	if (ret < 0) {
	ALOGE("[CAM_ID(%d)]-ERR(%s[%d]): create(FLITE) fail, ret(%d)",
	cameraId, __FUNCTION__, __LINE__, ret);

	SAFE_DELETE(g_node[index]);
	return NULL;
	}

	ret = g_node[index]->open(nodeNum);
	if (ret < 0) {
	ALOGE("[CAM_ID(%d)]-ERR(%s[%d]): open(%d) fail, ret(%d)",
	cameraId, __FUNCTION__, __LINE__, nodeNum, ret);

	SAFE_DELETE(g_node[index]);
	return NULL;
	}

	ALOGV("[CAM_ID(%d)]-DEBUG(%s[%d]):Node(%d) opened",
	cameraId, __FUNCTION__, __LINE__, nodeNum);
	} else {
	ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]): skip new g_nodeRefCount[%d] : (%d)",
	cameraId, __FUNCTION__, __LINE__, index, g_nodeRefCount[index]);
	}

	/* when calll this, increase ref */
	g_nodeRefCount[index]++;

	return g_node[index];
	}

	#ifdef SUPPORT_DEPTH_MAP
	static ExynosCameraNode *m_createVcNode(int cameraId, int nodeNum)
	{
	Mutex::Autolock lock(g_vcNodeInstanceMutex);

	status_t ret = NO_ERROR;
	char vcNodeName[8] = {'\0',};

	int index = nodeNum - FIMC_IS_VIDEO_SS0VC0_NUM + 1;
	if (index < 0 \|\| VC_CNTS <= index) {
	ALOGE("[CAM_ID(%d)]-ERR(%s[%d]):Invalid index %d",
	cameraId, __FUNCTION__, __LINE__, index);
	return NULL;
	}

	if (g_vcNode[index] == NULL) {
	if (g_vcNodeRefCount[index] != 0) {
	ALOGW("[CAM_ID(%d)]-WARN(%s[%d]):Invalid g_vcNodeRefCount %d index %d",
	cameraId, __FUNCTION__, __LINE__, g_vcNodeRefCount[index], index);

	g_vcNodeRefCount[index] = 0;
	}

	g_vcNode[index] = new ExynosCameraNode();

	ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]):new g_vcNode[%d]",
	cameraId, __FUNCTION__, __LINE__, index);

	snprintf(vcNodeName, sizeof(vcNodeName), "CAM%dVC%d", cameraId, (index%FLITE_CNTS) - 1);

	ret = g_vcNode[index]->create(vcNodeName, cameraId);
	if (ret < 0) {
	ALOGE("[CAM_ID(%d)]-ERR(%s[%d]):Failed to create %s, ret %d",
	cameraId, __FUNCTION__, __LINE__, vcNodeName, ret);

	SAFE_DELETE(g_vcNode[index]);
	return NULL;
	}

	ret = g_vcNode[index]->open(nodeNum);
	if (ret < 0) {
	ALOGE("[CAM_ID(%d)]-ERR(%s[%d]):Failed to open node %d ret %d",
	cameraId, __FUNCTION__, __LINE__, nodeNum, ret);

	SAFE_DELETE(g_vcNode[index]);
	return NULL;
	}

	ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]):Node %d opened",
	cameraId, __FUNCTION__, __LINE__, nodeNum);

	} else {
	ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]):Skip new g_vcNodeRefCount[%d] : %d",
	cameraId, __FUNCTION__, __LINE__, index, g_vcNodeRefCount[index]);
	}

	g_vcNodeRefCount[index]++;

	return g_vcNode[index];
	}
	#endif
	/*
	* Multi-singleton :
	* User must call DestoryInstance to delete PipeLite obj.
	* This will destroy obj, when only g_nodeRefCount == 0.
	*/
	static void m_destroyNode(int cameraId, ExynosCameraNode * obj)
	{
	if (obj == NULL) {
	ALOGE("[CAM_ID(%d)]-ERR(%s[%d]):obj == NULL. so fail",
	cameraId, __FUNCTION__, __LINE__);
	return;
	}

	Mutex::Autolock lock(g_nodeInstanceMutex);

	for (int index = 0; index < FLITE_CNTS; index++)
	{
	if (obj == g_node[index]) {
	if (1 < g_nodeRefCount[index]) {
	ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]): skip delete g_nodeRefCount[%d] : (%d)",
	cameraId, __FUNCTION__, __LINE__, index, g_nodeRefCount[index]);

	g_nodeRefCount[index]--;
	} else if (g_nodeRefCount[index] == 1) {
	ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]): delete g_nodeRefCount[%d] : (%d)",
	cameraId, __FUNCTION__, __LINE__, index, g_nodeRefCount[index]);

	if (g_node[index]->close() != NO_ERROR) {
	ALOGE("[CAM_ID(%d)]-DEBUG(%s[%d]): close fail",
	cameraId, __FUNCTION__, __LINE__);
	}

	SAFE_DELETE(g_node[index]);
	g_nodeRefCount[index]--;
	} else { /* g_nodeRefCount[index] < 1) */
	ALOGW("[CAM_ID(%d)]-WARN(%s[%d]):invalid g_nodeRefCount[%d](%d). so, set 0",
	cameraId, __FUNCTION__, __LINE__, index, g_nodeRefCount[index]);

	g_nodeRefCount[index] = 0;
	}
	}
	}
	}

	#ifdef SUPPORT_DEPTH_MAP
	static void m_destroyVcNode(int cameraId, ExynosCameraNode *obj)
	{
	if (obj == NULL) {
	ALOGE("[CAM_ID(%d)]-ERR(%s[%d]):obj == NULL. so fail",
	cameraId, __FUNCTION__, __LINE__);
	return;
	}

	Mutex::Autolock lock(g_vcNodeInstanceMutex);

	for (int index = 0; index < VC_CNTS; index++) {
	if (obj == g_vcNode[index]) {
	if (1 < g_vcNodeRefCount[index]) {
	ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]):skip delete g_vcNodeRefCount[%d] : %d",
	cameraId, __FUNCTION__, __LINE__, index, g_vcNodeRefCount[index]);

	g_vcNodeRefCount[index]--;
	} else if (g_vcNodeRefCount[index] == 1) {
	ALOGD("[CAM_ID(%d)]-DEBUG(%s[%d]):delete g_vcNodeRefCount[%d] : %d",
	cameraId, __FUNCTION__, __LINE__, index, g_vcNodeRefCount[index]);

	if (g_vcNode[index]->close() != NO_ERROR) {
	ALOGE("[CAM_ID(%d)]-DEBUG(%s[%d]):close fail",
	cameraId, __FUNCTION__, __LINE__);
	}

	SAFE_DELETE(g_vcNode[index]);
	g_vcNodeRefCount[index]--;
	} else {
	ALOGW("[CAM_ID(%d)]-WARN(%s[%d]):invalid g_vcNodeRefCount[%d] %d. so, set 0",
	cameraId, __FUNCTION__, __LINE__, index, g_vcNodeRefCount[index]);

	g_vcNodeRefCount[index] = 0;
	}
	}
	}
	}
	#endif

	private:
	void m_init(void);

	/* Override */
	status_t m_updateMetadataToFrame(void *metadata, int index);

	private:
	//#ifdef SHOT_RECOVERY
	int retryGetBufferCount;
	//#endif

	/* global variable for multi-singleton */
	static Mutex g_nodeInstanceMutex;
	static ExynosCameraNode *g_node[FLITE_CNTS];
	static int g_nodeRefCount[FLITE_CNTS];
	#ifdef SUPPORT_DEPTH_MAP
	static Mutex g_vcNodeInstanceMutex;
	static ExynosCameraNode *g_vcNode[VC_CNTS];
	static int g_vcNodeRefCount[VC_CNTS];
	#endif
	};

	}; /* namespace android */

	#endif