end_of_input signal for parallel_pipeline, parallel input filters with 0 tokens allowed.
| 227 | |
| 228 | // end_of_input signal for parallel_pipeline, parallel input filters with 0 tokens allowed. |
| 229 | void create_my_tls() { int status = end_of_input_tls.create(); if(status) handle_perror(status, "TLS not allocated for filter"); end_of_input_tls_allocated = true; } |
| 230 | void destroy_my_tls() { int status = end_of_input_tls.destroy(); if(status) handle_perror(status, "Failed to destroy filter TLS"); } |
| 231 | bool my_tls_end_of_input() { return end_of_input_tls.get() != 0; } |
| 232 | void set_my_tls_end_of_input() { end_of_input_tls.set(1); } |
no test coverage detected