| 746 | } |
| 747 | |
| 748 | flow_file_record *invoke_file(standalone_processor* proc, const char* path) { |
| 749 | NULL_CHECK(nullptr, path, proc); |
| 750 | auto fb = file_to_buffer(path); |
| 751 | NULL_CHECK(nullptr, fb.buffer); |
| 752 | |
| 753 | flow_file_record* ffr = invoke_chunk(proc, fb.buffer, fb.file_len); |
| 754 | free(fb.buffer); |
| 755 | return ffr; |
| 756 | } |
| 757 | |
| 758 | int transfer(processor_session* session, flow *flow, const char *rel) { |
| 759 | if (nullptr == session || nullptr == flow || rel == nullptr) { |
no test coverage detected