40   std::lock_guard rlock(reader.mutex_);  in CreateMpscStream()
42   std::lock_guard wlock(writer.mutex_);  in CreateMpscStream()
60   other.mutex_.lock();  in operator =()
65   other.mutex_.unlock();  in operator =()
68   mutex_.lock();  in operator =()
73   mutex_.unlock();  in operator =()
78     std::lock_guard lock(reader->mutex_);  in operator =()
98   std::lock_guard lock(mutex_);  in connected()
103   std::lock_guard lock(mutex_);  in last_write()
108   std::lock_guard lock(mutex_);  in SetTimeout()
113   std::lock_guard lock(mutex_);  in SetLimit()
125   std::lock_guard lock(mutex_);  in ConservativeLimit()
134   std::lock_guard lock(mutex_);  in DoWrite()
156     mutex_.unlock();  in DoWrite()
158     mutex_.lock();  in DoWrite()
191   std::lock_guard lock(mutex_);  in Close()
197     std::lock_guard lock(reader_->mutex_);  in CloseLocked()
219   std::lock_guard lock(mutex_);  in connected()
224   std::lock_guard lock(mutex_);  in SetBuffer()
231   std::lock_guard lock(mutex_);  in SetTimeout()
236   std::lock_guard lock(mutex_);  in IncreaseLimit()
251   std::lock_guard lock(mutex_);  in DecreaseLimit()
266   std::lock_guard lock(mutex_);  in ConservativeLimit()
280   std::lock_guard lock(mutex_);  in RequestWrite()
297   std::lock_guard lock(mutex_);  in WriteData()
338   std::lock_guard lock(mutex_);  in CompleteWrite()
367   mutex_.lock();  in DoRead()
420         mutex_.unlock();  in DoRead()
422         mutex_.lock();  in DoRead()
443   mutex_.unlock();  in DoRead()
448   mutex_.lock();  in ReadAll()
450     mutex_.unlock();  in ReadAll()
477     mutex_.unlock();  in ReadAll()
479     mutex_.lock();  in ReadAll()
489   mutex_.unlock();  in ReadAll()
494   mutex_.lock();  in Close()
496     mutex_.unlock();  in Close()
508     mutex_.unlock();  in Close()
511     mutex_.lock();  in Close()
519   mutex_.unlock();  in Close()