Lines Matching refs:TaskQueueLibevent
108 class TaskQueueLibevent final : public TaskQueueBase { class
110 TaskQueueLibevent(absl::string_view queue_name, rtc::ThreadPriority priority);
121 ~TaskQueueLibevent() override = default;
140 struct TaskQueueLibevent::TimerEvent {
141 TimerEvent(TaskQueueLibevent* task_queue, std::unique_ptr<QueuedTask> task) in TimerEvent()
146 TaskQueueLibevent* task_queue;
150 class TaskQueueLibevent::SetTimerTask : public QueuedTask {
162 TaskQueueLibevent::Current()->PostDelayedTask( in Run()
173 TaskQueueLibevent::TaskQueueLibevent(absl::string_view queue_name, in TaskQueueLibevent() function in webrtc::__anond79c7f5c0111::TaskQueueLibevent
176 thread_(&TaskQueueLibevent::ThreadMain, this, queue_name, priority) { in TaskQueueLibevent()
190 void TaskQueueLibevent::Delete() { in Delete()
217 void TaskQueueLibevent::PostTask(std::unique_ptr<QueuedTask> task) { in PostTask()
240 void TaskQueueLibevent::PostDelayedTask(std::unique_ptr<QueuedTask> task, in PostDelayedTask()
244 EventAssign(&timer->ev, event_base_, -1, 0, &TaskQueueLibevent::RunTimer, in PostDelayedTask()
256 void TaskQueueLibevent::ThreadMain(void* context) { in ThreadMain()
257 TaskQueueLibevent* me = static_cast<TaskQueueLibevent*>(context); in ThreadMain()
270 void TaskQueueLibevent::OnWakeup(int socket, in OnWakeup()
273 TaskQueueLibevent* me = static_cast<TaskQueueLibevent*>(context); in OnWakeup()
306 void TaskQueueLibevent::RunTimer(int fd, in RunTimer()
322 new TaskQueueLibevent(name, in CreateTaskQueue()