manually insert C++ packet to graph
| 928 | |
| 929 | // manually insert C++ packet to graph |
| 930 | int 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 |
| 948 | Packet Graph::poll_output_stream_packet(std::string const &stream_name, |
no test coverage detected