KinesisManagerStatus KinesisStreamManagerInterface::KinesisVideoStreamSetup()

in kinesis_manager/src/kinesis_stream_manager.cpp [35:58]

• 23 lines of code
• 4 McCabe index (conditional complexity)

KinesisManagerStatus KinesisStreamManagerInterface::KinesisVideoStreamSetup(
  const uint16_t stream_idx, const PBYTE codec_private_data, const uint32_t codec_private_data_size,
  std::string * stream_name)
{
  KinesisManagerStatus status = KINESIS_MANAGER_STATUS_ERROR_BASE;
  unique_ptr<StreamDefinition> stream_definition = stream_definition_provider_->GetStreamDefinition(
    GetStreamParameterPrefix(stream_idx), *parameter_reader_, codec_private_data, codec_private_data_size);
  if (!stream_definition) {
    AWS_LOGSTREAM_ERROR(__func__, "Skipping stream id "
                                    << stream_idx << " due to failure to load stream definition.");
    return KINESIS_MANAGER_STATUS_GET_STREAM_DEFINITION_FAILED;
  }
  /* Stream initialization */
  if (nullptr != stream_name) {
    *stream_name = stream_definition->getStreamName();
  }
  status = InitializeVideoStream(std::move(stream_definition));
  if (KINESIS_MANAGER_STATUS_FAILED(status)) {
    AWS_LOGSTREAM_ERROR(
      __func__, "Skipping stream id "
                  << stream_idx << " due to failure initializing stream. Error code: " << status);
  }
  return status;
}