Lines Matching defs:queue
109 static void CloseAndFree(RequestQueueData* queue);
160 Mutex state_lock_; // Locked before mutating the queue.
194 explicit IoSessionDelegate(std::shared_ptr<RequestQueue> queue, int id)
195 : request_queue_(queue), id_(id) { }
210 InspectorIoDelegate(std::shared_ptr<RequestQueueData> queue,
289 std::shared_ptr<RequestQueueData> queue(new RequestQueueData(&loop),
293 new InspectorIoDelegate(queue, main_thread_, id_,
307 request_queue_ = queue->handle();
309 queue.reset();
328 std::shared_ptr<RequestQueueData> queue,
333 : request_queue_(queue), main_thread_(main_thread),
372 void RequestQueueData::CloseAndFree(RequestQueueData* queue) {
373 queue->handle_->Reset();
374 queue->handle_.reset();
375 uv_close(reinterpret_cast<uv_handle_t*>(&queue->async_),