Skip to content

Class cuvis::Worker

ClassList > cuvis > Worker

  • #include <cuvis.hpp>

Classes

Type Name
struct worker_return_t
struct worker_state_t

Public Types

Type Name
typedef std::function< void(worker_return_t)> worker_callback_t

Public Functions

Type Name
Worker (WorkerArgs const & args)
void drop_all_queued ()
bool get_can_drop_results ()
bool get_can_skip_measurements ()
bool get_can_skip_supplementary ()
size_t get_input_queue_limit () const
size_t get_mandatory_queue_limit () const
worker_return_t get_next_result (std::chrono::milliseconds timeout) const
size_t get_output_queue_limit () const
size_t get_queue_used () const
worker_state_t get_state () const
size_t get_supplementary_queue_limit () const
int32_t get_threads_busy () const
bool has_next_result () const
void ingest_measurement (Measurement const & measurement)
void ingest_session_file (SessionFile const & session, std::string frame_selection)
bool is_processing () const
bool is_processing_mandatory () const
double query_session_progress ()
void register_worker_callback (worker_callback_t callback, unsigned concurrency=1, size_t measurement_timeout_ms=1000)
void reset_worker_callback ()
void set_acq_cont (AcquisitionContext const * acqCont)
void set_exporter (Exporter const * exporter)
void set_proc_cont (ProcessingContext const * procCont)
void set_viewer (Viewer const * viewer)
void start_processing ()
void stop_processing ()

Public Types Documentation

typedef worker_callback_t

using cuvis::Worker::worker_callback_t =  std::function<void(worker_return_t)>;

Public Functions Documentation

function Worker

cuvis::Worker::Worker (
    WorkerArgs  const & args
) 

function drop_all_queued

void cuvis::Worker::drop_all_queued () 

function get_can_drop_results

bool cuvis::Worker::get_can_drop_results () 

function get_can_skip_measurements

bool cuvis::Worker::get_can_skip_measurements () 

function get_can_skip_supplementary

bool cuvis::Worker::get_can_skip_supplementary () 

function get_input_queue_limit

size_t cuvis::Worker::get_input_queue_limit () const

function get_mandatory_queue_limit

size_t cuvis::Worker::get_mandatory_queue_limit () const

function get_next_result

worker_return_t cuvis::Worker::get_next_result (
    std::chrono::milliseconds timeout
) const

function get_output_queue_limit

size_t cuvis::Worker::get_output_queue_limit () const

function get_queue_used

size_t cuvis::Worker::get_queue_used () const

function get_state

worker_state_t cuvis::Worker::get_state () const

function get_supplementary_queue_limit

size_t cuvis::Worker::get_supplementary_queue_limit () const

function get_threads_busy

int32_t cuvis::Worker::get_threads_busy () const

function has_next_result

bool cuvis::Worker::has_next_result () const

function ingest_measurement

void cuvis::Worker::ingest_measurement (
    Measurement  const & measurement
) 

function ingest_session_file

void cuvis::Worker::ingest_session_file (
    SessionFile  const & session,
    std::string frame_selection
) 

function is_processing

bool cuvis::Worker::is_processing () const

function is_processing_mandatory

bool cuvis::Worker::is_processing_mandatory () const

function query_session_progress

double cuvis::Worker::query_session_progress () 

function register_worker_callback

void cuvis::Worker::register_worker_callback (
    worker_callback_t callback,
    unsigned concurrency=1,
    size_t measurement_timeout_ms=1000
) 

function reset_worker_callback

void cuvis::Worker::reset_worker_callback () 

function set_acq_cont

void cuvis::Worker::set_acq_cont (
    AcquisitionContext  const * acqCont
) 

function set_exporter

void cuvis::Worker::set_exporter (
    Exporter  const * exporter
) 

function set_proc_cont

void cuvis::Worker::set_proc_cont (
    ProcessingContext  const * procCont
) 

function set_viewer

void cuvis::Worker::set_viewer (
    Viewer  const * viewer
) 

function start_processing

void cuvis::Worker::start_processing () 

function stop_processing

void cuvis::Worker::stop_processing () 


The documentation for this class was generated from the following file cuvis.cpp/interface/cuvis.hpp