MCPcopy Create free account
hub / github.com/BabitMF/bmf / add_input_stream_packet

Method add_input_stream_packet

bmf/engine/c_engine/src/graph.cpp:930–945  ·  view source on GitHub ↗

manually insert C++ packet to graph

Source from the content-addressed store, hash-verified

928
929// manually insert C++ packet to graph
930int Graph::add_input_stream_packet(std::string const &stream_name,
931 Packet &packet, bool block) {
932 if (input_streams_.count(stream_name) > 0) {
933 if (block) {
934
935 while (input_streams_[stream_name]
936 ->manager_->any_of_downstream_full()) {
937 {
938 usleep(1000);
939 }
940 }
941 }
942 input_streams_[stream_name]->add_packet(packet);
943 }
944 return 0;
945}
946
947// manually poll output packet and return C++ packet
948Packet Graph::poll_output_stream_packet(std::string const &stream_name,

Callers 1

fill_packetMethod · 0.45

Calls 3

add_packetMethod · 0.80
countMethod · 0.45

Tested by

no test coverage detected