KinesisManagerStatus KinesisStreamManager::PutFrame()

in kinesis_manager/src/kinesis_stream_manager.cpp [279:293]

• 15 lines of code
• 5 McCabe index (conditional complexity)

KinesisManagerStatus KinesisStreamManager::PutFrame(std::string stream_name, Frame & frame) const
{
  if (!video_producer_) {
    return KINESIS_MANAGER_STATUS_VIDEO_PRODUCER_NOT_INITIALIZED;
  }
  if (0 == video_streams_.count(stream_name)) {
    return KINESIS_MANAGER_STATUS_PUTFRAME_STREAM_NOT_FOUND;
  }
  if (!video_streams_.at(stream_name)->IsReady()) {
    AWS_LOG_WARN(__func__, "Stream not ready yet, skipping putFrame.");
    return KINESIS_MANAGER_STATUS_PUTFRAME_FAILED;
  }
  bool result = video_streams_.at(stream_name)->PutFrame(frame);
  return result ? KINESIS_MANAGER_STATUS_SUCCESS : KINESIS_MANAGER_STATUS_PUTFRAME_FAILED;
};