Searched refs:new_worker_state (Results 1 – 1 of 1) sorted by relevance
31 struct new_worker_state : public std::enable_shared_from_this<new_worker_state> struct38 virtual ~new_worker_state() in ~new_worker_state() argument42 explicit new_worker_state(composite_subscription cs) in new_worker_state() function55 std::shared_ptr<new_worker_state> state;62 explicit new_worker(std::shared_ptr<new_worker_state> ws) in new_worker()68 : state(std::make_shared<new_worker_state>(cs)) in new_worker()75 keepAlive->q = new_worker_state::queue_item_time{}; in new_worker()136 state->q.push(new_worker_state::item_type(when, scbl)); in schedule()