initial commit

wangrong

2025-01-03 2c4b8838f89bebca97615c5f0bac2c58e0349771

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
#include "vp_message_broker_node.h" 
 
namespace vp_nodes { 
         
    vp_message_broker_node::vp_message_broker_node(std::string node_name): vp_node(node_name) { 
        this->initialized(); 
    } 
     
    vp_message_broker_node::~vp_message_broker_node() { 
 
    } 
 
    std::shared_ptr<vp_objects::vp_meta> vp_message_broker_node::handle_control_meta(std::shared_ptr<vp_objects::vp_control_meta> meta) { 
        return meta; 
    } 
 
    std::shared_ptr<vp_objects::vp_meta> vp_message_broker_node::handle_frame_meta(std::shared_ptr<vp_objects::vp_frame_meta> meta) { 
        /* 
        if (meta->frame_index % 15 == 0) {           
            std::this_thread::sleep_for(std::chrono::milliseconds(28)); 
        } 
        if (meta->frame_index % 73 == 0) {           
            std::this_thread::sleep_for(std::chrono::milliseconds(64)); 
        }*/ 
        return meta; 
    } 
}