|
@@ -67,7 +67,7 @@ int DefaultKafkaHandler::UpdateFrame(const std::shared_ptr<cnstream::CNFrameInfo
|
|
|
writer_.String("FrameCount");
|
|
writer_.String("FrameCount");
|
|
|
writer_.Uint64(frame_count);
|
|
writer_.Uint64(frame_count);
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
cnstream::CNDataFramePtr frame = data->collection.Get<cnstream::CNDataFramePtr>(cnstream::kCNDataFrameTag);
|
|
cnstream::CNDataFramePtr frame = data->collection.Get<cnstream::CNDataFramePtr>(cnstream::kCNDataFrameTag);
|
|
|
|
|
|
|
|
if (frame->width < 0 || frame->height < 0) {
|
|
if (frame->width < 0 || frame->height < 0) {
|
