Searched refs:read_queue_ (Results 1 – 7 of 7) sorted by relevance
209 std::find(read_queue_.begin(), read_queue_.end(), tab_id) == in Get()210 read_queue_.end()) { in Get()211 read_queue_.push_back(tab_id); in Get()289 read_queue_.clear(); in UpdateVisibleIds()297 std::find(read_queue_.begin(), read_queue_.end(), tab_id) == in UpdateVisibleIds()298 read_queue_.end()) { in UpdateVisibleIds()299 read_queue_.push_back(tab_id); in UpdateVisibleIds()407 if (read_queue_.empty() || read_in_progress_) in ReadNextThumbnail()410 TabId tab_id = read_queue_.front(); in ReadNextThumbnail()467 std::find(read_queue_.begin(), read_queue_.end(), tab_id); in RemoveFromReadQueue()[all …]
159 TabIdList read_queue_; variable
198 read_queue_.clear(); in Close()227 read_queue_.push_back(data); in DidRecvMsg()322 if (read_queue_.empty()) in ReadData()324 while (!read_queue_.empty() && *bytes_read < buffer_len) { in ReadData()325 linked_ptr<std::vector<char> > vec(read_queue_.front()); in ReadData()331 read_queue_.pop_front(); in ReadData()
104 std::deque<linked_ptr<std::vector<char> > > read_queue_; variable
82 read_queue_.reset(new WebSocketReadQueue(receive_stream_.get())); in DidConnect()95 read_queue_->Read(num_bytes, in DidReceiveData()140 scoped_ptr<WebSocketReadQueue> read_queue_; member in mojo::WebSocketClientImpl
50 scoped_ptr<WebSocketReadQueue> read_queue_; variable
198 read_queue_.reset(new WebSocketReadQueue(send_stream_.get())); in Connect()212 read_queue_->Read(num_bytes, in Send()