Files
opencv-MIRROR/modules/videoio/src/cap_obsensor_capture.cpp
zzuliys 2b9d1a2ff8 Merge pull request #24877 from zzuliys:feature/mac
Orbbec Camera supports MacOS,Gemini2 and Gemini2L support Y16 format #24877

note:
1.Gemini2 and Gemini2L must use the latest firmware -- https://github.com/orbbec/OrbbecFirmware;
2.Administrator privileges are necessary to run on MacOS.
2024-03-29 11:23:41 +03:00

224 lines
8.7 KiB
C++

// This file is part of OpenCV project.
// It is subject to the license terms in the LICENSE file found in the top-level directory
// of this distribution and at http://opencv.org/license.html.
/*
* Copyright(C) 2022 by ORBBEC Technology., Inc.
* Authors:
* Huang Zhenchang <yufeng@orbbec.com>
*
* 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.
*/
#include "precomp.hpp"
#include "cap_obsensor_capture.hpp"
#include "cap_obsensor/obsensor_stream_channel_interface.hpp"
#if defined(HAVE_OBSENSOR) && !defined(HAVE_OBSENSOR_ORBBEC_SDK)
namespace cv {
Ptr<IVideoCapture> create_obsensor_capture(int index)
{
return makePtr<VideoCapture_obsensor>(index);
}
VideoCapture_obsensor::VideoCapture_obsensor(int index) : isOpened_(false)
{
static const obsensor::StreamProfile colorProfile = { 640, 480, 30, obsensor::FRAME_FORMAT_MJPG };
static const obsensor::StreamProfile depthProfile = {640, 480, 30, obsensor::FRAME_FORMAT_Y16};
static const obsensor::StreamProfile gemini2DepthProfile = {1280, 800, 30, obsensor::FRAME_FORMAT_Y16};
static const obsensor::StreamProfile astra2ColorProfile = {800, 600, 30, obsensor::FRAME_FORMAT_MJPG};
static const obsensor::StreamProfile astra2DepthProfile = {800, 600, 30, obsensor::FRAME_FORMAT_Y14};
static const obsensor::StreamProfile megaColorProfile = {1280, 720, 30, obsensor::FRAME_FORMAT_MJPG};
static const obsensor::StreamProfile megaDepthProfile = {640, 576, 30, obsensor::FRAME_FORMAT_Y16};
static const obsensor::StreamProfile gemini2lColorProfile = { 1280, 720, 30, obsensor::FRAME_FORMAT_MJPG};
static const obsensor::StreamProfile gemini2lDepthProfile = {1280, 800, 30, obsensor::FRAME_FORMAT_Y16};
static const obsensor::StreamProfile gemini2XlColorProfile = { 1280, 800, 10, obsensor::FRAME_FORMAT_MJPG};
static const obsensor::StreamProfile gemini2XlDepthProfile = {1280, 800, 10, obsensor::FRAME_FORMAT_Y16};
streamChannelGroup_ = obsensor::getStreamChannelGroup(index);
if (!streamChannelGroup_.empty())
{
for (auto& channel : streamChannelGroup_)
{
auto streamType = channel->streamType();
switch (streamType)
{
case obsensor::OBSENSOR_STREAM_COLOR:
{
auto profile = colorProfile;
if(OBSENSOR_FEMTO_MEGA_PID == channel->getPid()){
profile = megaColorProfile;
}else if(OBSENSOR_GEMINI2L_PID == channel->getPid()){
profile = gemini2lColorProfile;
}else if(OBSENSOR_ASTRA2_PID == channel->getPid()){
profile = astra2ColorProfile;
}else if(OBSENSOR_GEMINI2XL_PID == channel->getPid()){
profile = gemini2XlColorProfile;
}
channel->start(profile, [&](obsensor::Frame* frame) {
std::unique_lock<std::mutex> lk(frameMutex_);
colorFrame_ = Mat(1, frame->dataSize, CV_8UC1, frame->data).clone();
frameCv_.notify_all();
});
}
break;
case obsensor::OBSENSOR_STREAM_DEPTH:
{
uint8_t data = 1;
channel->setProperty(obsensor::DEPTH_TO_COLOR_ALIGN, &data, 1);
obsensor::StreamProfile profile = depthProfile;
if(OBSENSOR_GEMINI2_PID == channel->getPid()){
profile = gemini2DepthProfile;
}
else if(OBSENSOR_ASTRA2_PID == channel->getPid()){
profile = astra2DepthProfile;
}
else if(OBSENSOR_FEMTO_MEGA_PID == channel->getPid()){
profile = megaDepthProfile;
}else if(OBSENSOR_GEMINI2L_PID == channel->getPid()){
profile = gemini2lDepthProfile;
}else if(OBSENSOR_GEMINI2XL_PID == channel->getPid()){
profile = gemini2XlDepthProfile;
}
channel->start(profile, [&](obsensor::Frame* frame) {
std::unique_lock<std::mutex> lk(frameMutex_);
depthFrame_ = Mat(frame->height, frame->width, CV_16UC1, frame->data, frame->width * 2).clone();
frameCv_.notify_all();
});
uint32_t len;
memset(&camParam_, 0, sizeof(camParam_));
channel->getProperty(obsensor::CAMERA_PARAM, (uint8_t*)&camParam_, &len);
camParamScale_ = (int)(camParam_.p1[2] * 2 / 640 + 0.5);
}
break;
default:
break;
}
}
isOpened_ = true;
}
}
VideoCapture_obsensor::~VideoCapture_obsensor(){
for (auto& channel : streamChannelGroup_)
{
channel->stop();
}
streamChannelGroup_.clear();
}
bool VideoCapture_obsensor::grabFrame()
{
std::unique_lock<std::mutex> lk(frameMutex_);
// Try waiting for 33 milliseconds to ensure that both depth and color frame have been received!
frameCv_.wait_for(lk, std::chrono::milliseconds(33), [&](){ return !depthFrame_.empty() && !colorFrame_.empty(); });
grabbedDepthFrame_ = depthFrame_;
grabbedColorFrame_ = colorFrame_;
depthFrame_.release();
colorFrame_.release();
return !grabbedDepthFrame_.empty() || !grabbedColorFrame_.empty();
}
bool VideoCapture_obsensor::retrieveFrame(int outputType, OutputArray frame)
{
std::unique_lock<std::mutex> lk(frameMutex_);
switch (outputType)
{
case CAP_OBSENSOR_DEPTH_MAP:
if (!grabbedDepthFrame_.empty())
{
if(OBSENSOR_GEMINI2_PID == streamChannelGroup_.front()->getPid()){
const double DepthValueScaleGemini2 = 0.2;
grabbedDepthFrame_ = grabbedDepthFrame_*DepthValueScaleGemini2;
Rect rect(320, 160, 640, 480);
grabbedDepthFrame_(rect).copyTo(frame);
}
else if(OBSENSOR_ASTRA2_PID == streamChannelGroup_.front()->getPid()){
const double DepthValueScaleAstra2 = 0.8;
grabbedDepthFrame_ = grabbedDepthFrame_*DepthValueScaleAstra2;
grabbedDepthFrame_.copyTo(frame);
}
else if(OBSENSOR_FEMTO_MEGA_PID == streamChannelGroup_.front()->getPid()){
Rect rect(0, 0, 640, 360);
grabbedDepthFrame_(rect).copyTo(frame);
}else if(OBSENSOR_GEMINI2L_PID == streamChannelGroup_.front()->getPid()){
const double DepthValueScaleGemini2L = 0.2;
grabbedDepthFrame_ = grabbedDepthFrame_*DepthValueScaleGemini2L;
Rect rect(0, 40, 1280, 720);
grabbedDepthFrame_(rect).copyTo(frame);
}else if(OBSENSOR_GEMINI2XL_PID == streamChannelGroup_.front()->getPid()){
grabbedDepthFrame_.copyTo(frame);
}else{
grabbedDepthFrame_.copyTo(frame);
}
grabbedDepthFrame_.release();
return true;
}
break;
case CAP_OBSENSOR_BGR_IMAGE:
if (!grabbedColorFrame_.empty())
{
auto mat = imdecode(grabbedColorFrame_, IMREAD_COLOR);
grabbedColorFrame_.release();
if (!mat.empty())
{
mat.copyTo(frame);
return true;
}
}
break;
default:
break;
}
return false;
}
double VideoCapture_obsensor::getProperty(int propIdx) const {
double rst = 0.0;
propIdx = propIdx & (~CAP_OBSENSOR_GENERATORS_MASK);
// int gen = propIdx & CAP_OBSENSOR_GENERATORS_MASK;
switch (propIdx)
{
case CAP_PROP_OBSENSOR_INTRINSIC_FX:
rst = camParam_.p1[0] / camParamScale_;
break;
case CAP_PROP_OBSENSOR_INTRINSIC_FY:
rst = camParam_.p1[1] / camParamScale_;
break;
case CAP_PROP_OBSENSOR_INTRINSIC_CX:
rst = camParam_.p1[2] / camParamScale_;
break;
case CAP_PROP_OBSENSOR_INTRINSIC_CY:
rst = camParam_.p1[3] / camParamScale_;
break;
}
return rst;
}
bool VideoCapture_obsensor::setProperty(int propIdx, double /*propVal*/)
{
CV_LOG_WARNING(NULL, "Unsupported or read only property, id=" << propIdx);
return false;
}
} // namespace cv::
#endif // HAVE_OBSENSOR