in kinesis_manager/src/kinesis_stream_manager.cpp [295:311]
KinesisManagerStatus KinesisStreamManager::PutMetadata(std::string stream_name,
const std::string & name,
const std::string & value) const
{
if (!video_producer_) {
return KINESIS_MANAGER_STATUS_VIDEO_PRODUCER_NOT_INITIALIZED;
}
if (0 == video_streams_.count(stream_name)) {
return KINESIS_MANAGER_STATUS_PUTMETADATA_STREAM_NOT_FOUND;
}
if (!video_streams_.at(stream_name)->IsReady()) {
AWS_LOG_WARN(__func__, "Stream not ready yet, skipping putFragmentMetadata.");
return KINESIS_MANAGER_STATUS_PUTMETADATA_FAILED;
}
bool result = video_streams_.at(stream_name)->PutFragmentMetadata(name, value, false);
return result ? KINESIS_MANAGER_STATUS_SUCCESS : KINESIS_MANAGER_STATUS_PUTMETADATA_FAILED;
};