true if the current low_token is valid.
| 224 | |
| 225 | //! true if the current low_token is valid. |
| 226 | bool has_item() { spin_mutex::scoped_lock lock(array_mutex); return array[low_token&(array_size -1)].is_valid; } |
| 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; } |
no outgoing calls
no test coverage detected