#include "G330NetVideoSensor.hpp"
#include "stream/StreamProfileFactory.hpp"
#include "exception/ObException.hpp"
#include "InternalTypes.hpp"
#include "utils/BufferParser.hpp"
#include "frame/Frame.hpp"
#include "IProperty.hpp"
#include "ethernet/RTPStreamPort.hpp"
#include "G330DeviceInfo.hpp"
namespace libobsensor {
G330NetVideoSensor::G330NetVideoSensor(IDevice *owner, OBSensorType sensorType, const std::shared_ptr<ISourcePort> &backend, uint32_t linkSpeed)
: VideoSensor(owner, sensorType, backend),
streamSwitchPropertyId_(OB_PROP_START_COLOR_STREAM_BOOL),
profilesSwitchPropertyId_(OB_STRUCT_COLOR_STREAM_PROFILE),
linkSpeed_(linkSpeed) {
initStreamPropertyId();
}
void G330NetVideoSensor::start(std::shared_ptr<const StreamProfile> sp, FrameCallback callback) {
if(linkSpeed_ <= G335LE_10M_NET_BAND_WIDTH) {
throw libobsensor::unsupported_operation_exception(utils::string::to_string()
<< "Failed to start " << sensorType_ << " stream: the ethernet link speed is limited to "
<< linkSpeed_ << "Mb/s! Please check the ethernet connection and reconnect the device.");
}
auto backendIter = streamProfileBackendMap_.find(sp);
if(backendIter == streamProfileBackendMap_.end()) {
throw invalid_value_exception("Can not find backend stream profile for activated stream profile");
}
auto currentVSP = sp->as<VideoStreamProfile>();
OBFormat format = sp->getFormat();
currentFormatFilterConfig_ = backendIter->second.second;
if(currentFormatFilterConfig_ && currentFormatFilterConfig_->converter) {
format = currentFormatFilterConfig_->srcFormat;
}
auto rtpStreamPort = std::dynamic_pointer_cast<RTPStreamPort>(backend_);
uint16_t port = rtpStreamPort->getStreamPort();
LOG_DEBUG("Start {} stream port: {}", utils::obSensorToStr(sensorType_), port);
OBInternalVideoStreamProfile vsp = { 0 };
vsp.sensorType = (uint16_t)utils::mapStreamTypeToSensorType(sp->getType());
vsp.formatFourcc = utils::obFormatToUvcFourcc(format);
vsp.width = currentVSP->getWidth();
vsp.height = currentVSP->getHeight();
vsp.fps = currentVSP->getFps();
vsp.port = port;
auto propServer = owner_->getPropertyServer();
propServer->setStructureDataT<OBInternalVideoStreamProfile>(profilesSwitchPropertyId_, vsp);
VideoSensor::start(sp, callback);
BEGIN_TRY_EXECUTE({
propServer->setPropertyValueT<bool>(streamSwitchPropertyId_, true);
})
CATCH_EXCEPTION_AND_EXECUTE({
LOG_ERROR("Start {} stream failed!", utils::obSensorToStr(sensorType_));
VideoSensor::stop();
propServer->setPropertyValueT<bool>(streamSwitchPropertyId_, false);
})
}
void G330NetVideoSensor::stop() {
auto propServer = owner_->getPropertyServer();
BEGIN_TRY_EXECUTE({
propServer->setPropertyValueT<bool>(streamSwitchPropertyId_, false);
})
CATCH_EXCEPTION_AND_EXECUTE({ LOG_ERROR("Failed to send the {} stream stop command!", utils::obSensorToStr(sensorType_)); })
VideoSensor::stop();
}
void G330NetVideoSensor::initStreamPropertyId() {
if(sensorType_ == OB_SENSOR_COLOR) {
streamSwitchPropertyId_ = OB_PROP_START_COLOR_STREAM_BOOL;
profilesSwitchPropertyId_ = OB_STRUCT_COLOR_STREAM_PROFILE;
}
if(sensorType_ == OB_SENSOR_IR_LEFT) {
streamSwitchPropertyId_ = OB_PROP_START_IR_STREAM_BOOL;
profilesSwitchPropertyId_ = OB_STRUCT_IR_STREAM_PROFILE;
}
if(sensorType_ == OB_SENSOR_IR_RIGHT) {
streamSwitchPropertyId_ = OB_PROP_START_IR_RIGHT_STREAM_BOOL;
profilesSwitchPropertyId_ = OB_STRUCT_IR_RIGHT_STREAM_PROFILE;
}
}
G330NetVideoSensor::~G330NetVideoSensor() noexcept {
}
}