Searched refs:op_queue_ (Results 1 – 4 of 4) sorted by relevance
45 task_io_service_->op_queue_.push(this_thread_->private_op_queue);46 task_io_service_->op_queue_.push(&task_io_service_->task_operation_);73 task_io_service_->op_queue_.push(this_thread_->private_op_queue);103 while (!op_queue_.empty())105 operation* o = op_queue_.front();106 op_queue_.pop();121 op_queue_.push(&task_operation_);186 op_queue_.push(outer_thread_info->private_op_queue);215 op_queue_.push(outer_thread_info->private_op_queue);253 op_queue_.push(op);[all …]
54 op_queue_[i].get_all_operations(ops);84 op_queue_[op_type].enqueue_operation(descriptor, op);108 bool first = op_queue_[op_type].enqueue_operation(descriptor, op);134 op_queue_[i].cancel_operations(descriptor, ops);150 have_work_to_do = have_work_to_do || !op_queue_[i].empty();151 fd_sets_[i].set(op_queue_[i], ops);189 fd_sets_[i].perform(op_queue_[i], ops);228 need_interrupt = op_queue_[i].cancel_operations(
173 op_queue<operation> op_queue_; member in asio::detail::task_io_service
161 reactor_op_queue<socket_type> op_queue_[max_ops]; member in asio::detail::select_reactor