all_data_received | cgv::os::queued_input_thread | protected |
close() override | cgv::os::named_pipe_input_thread | protectedvirtual |
connect_to_source() override | cgv::os::named_pipe_input_thread | protectedvirtual |
data_blocks | cgv::os::queued_input_thread | protected |
delete_after_termination (defined in cgv::os::thread) | cgv::os::thread | protected |
done() | cgv::os::queued_input_thread | |
execute() | cgv::os::thread | protected |
execute_s(void *args) (defined in cgv::os::thread) | cgv::os::thread | protectedstatic |
get_current_thread_id() | cgv::os::thread | static |
get_id() const | cgv::os::thread | |
get_nr_blocks() const | cgv::os::queued_input_thread | |
get_pipe_path() const (defined in cgv::os::named_pipe_input_thread) | cgv::os::named_pipe_input_thread | |
have_stop_request() | cgv::os::thread | inline |
is_binary | cgv::os::queued_input_thread | protected |
is_running() | cgv::os::thread | inline |
kill() | cgv::os::thread | |
move_packages_to_data_blocks() | cgv::os::queued_input_thread | protectedvirtual |
ms_to_wait | cgv::os::queued_input_thread | protected |
mutex_data_blocks | cgv::os::queued_input_thread | mutableprotected |
mutex_packages | cgv::os::queued_input_thread | mutableprotected |
named_pipe_input_thread(const std::string &_pipe_name, bool is_binary, size_t _package_size, size_t _packeges_per_block, unsigned _ms_to_wait) (defined in cgv::os::named_pipe_input_thread) | cgv::os::named_pipe_input_thread | |
package_index | cgv::os::queued_input_thread | protected |
package_size | cgv::os::queued_input_thread | protected |
packages | cgv::os::queued_input_thread | protected |
packages_per_block | cgv::os::queued_input_thread | protected |
pipe_name (defined in cgv::os::named_pipe_input_thread) | cgv::os::named_pipe_input_thread | protected |
pipe_ptr (defined in cgv::os::named_pipe_input_thread) | cgv::os::named_pipe_input_thread | protected |
pop_data_block(char *buffer) | cgv::os::queued_input_thread | |
queued_input_thread(bool _is_binary, size_t _package_size, size_t _packeges_per_block, unsigned _ms_to_wait) | cgv::os::queued_input_thread | |
read_package_from_pipe(char *buffer, size_t package_size) override | cgv::os::named_pipe_input_thread | protectedvirtual |
run() | cgv::os::queued_input_thread | virtual |
running (defined in cgv::os::thread) | cgv::os::thread | protected |
start(bool _delete_after_termination=false) | cgv::os::thread | |
stop() | cgv::os::thread | |
stop_request (defined in cgv::os::thread) | cgv::os::thread | protected |
thread() | cgv::os::thread | |
thread_ptr (defined in cgv::os::thread) | cgv::os::thread | protected |
wait(unsigned millisec) | cgv::os::thread | static |
wait_for_completion() | cgv::os::thread | |
wait_for_signal(condition_mutex &cm) | cgv::os::thread | static |
wait_for_signal_or_timeout(condition_mutex &cm, unsigned millisec) | cgv::os::thread | static |
wait_for_signal_or_timeout_with_lock(condition_mutex &cm, unsigned millisec) | cgv::os::thread | static |
wait_for_signal_with_lock(condition_mutex &cm) | cgv::os::thread | static |
~thread() | cgv::os::thread | virtual |