| 23 | } |
| 24 | |
| 25 | int MockDecoder::process(Task &task) { |
| 26 | BMFLOG_NODE(BMF_INFO, node_id_) << "process"; |
| 27 | number_++; |
| 28 | for (auto output_queue : task.get_outputs()) { |
| 29 | std::string data = "hello world"; |
| 30 | auto packet = Packet(data); |
| 31 | packet.set_timestamp(number_); |
| 32 | BMFLOG_NODE(BMF_INFO, node_id_) |
| 33 | << packet.timestamp() << "data type:" << packet.type_info().name; |
| 34 | task.fill_output_packet(output_queue.first, packet); |
| 35 | |
| 36 | sleep(1); |
| 37 | if (number_ == 10) { |
| 38 | task.fill_output_packet(output_queue.first, |
| 39 | Packet::generate_eof_packet()); |
| 40 | task.set_timestamp(DONE); |
| 41 | } |
| 42 | } |
| 43 | BMFLOG_NODE(BMF_INFO, node_id_) |
| 44 | << "MockDecoder process result output queue size: " |
| 45 | << task.get_outputs()[0]->size() << std::endl; |
| 46 | return 0; |
| 47 | } |
| 48 | |
| 49 | int MockDecoder::reset() { return 0; } |
| 50 | |