#include "../../nodes/vp_image_src_node.h" #include "../../nodes/infers/vp_trt_vehicle_detector.h" #include "../../nodes/infers/vp_trt_vehicle_feature_encoder.h" #include "../../nodes/broker/vp_embeddings_socket_broker_node.h" #include "../../nodes/osd/vp_osd_node.h" #include "../../nodes/vp_screen_des_node.h" #include "../../utils/analysis_board/vp_analysis_board.h" /* * ## vehicle encoding pipeline ## * generate embedding data for vehicles using VideoPipe, then send them via socket. */ int main(int argc, char* argv[]) { // get directory for test video and models assert(argc == 2); std::string data_dir(argv[1]); if (!vp_utils::ends_with(data_dir, "/")) { data_dir += "/"; } VP_SET_LOG_LEVEL(vp_utils::vp_log_level::INFO); VP_LOGGER_INIT(); // create nodes auto image_src_0 = std::make_shared("image_src_0", 0, data_dir + "vp_data/test_images/vehicle/%d.jpg"); auto trt_vehicle_detector = std::make_shared("trt_detector", data_dir + "vp_data/models/trt/vehicle/vehicle_v8.5.trt"); auto trt_vehicle_feature_encoder = std::make_shared("trt_encoder", data_dir + "vp_data/models/trt/vehicle/vehicle_embedding_v8.5.trt", std::vector{0, 1, 2}); auto embedding_broker = std::make_shared("embedding_broker", "192.168.77.68", 8888, "static/cropped_images"); auto osd_0 = std::make_shared("osd_0"); auto screen_des_0 = std::make_shared("screen_des_0", 0); // construct pipeline trt_vehicle_detector->attach_to({image_src_0}); trt_vehicle_feature_encoder->attach_to({trt_vehicle_detector}); embedding_broker->attach_to({trt_vehicle_feature_encoder}); osd_0->attach_to({embedding_broker}); screen_des_0->attach_to({osd_0}); // start pipeline image_src_0->start(); // visualize pipeline for debug vp_utils::vp_analysis_board board({image_src_0}); board.display(); }