Searched refs:pending_processes_ (Results 1 – 2 of 2) sorted by relevance
624 auto it = producer_->pending_processes_.find(self->peer_pid()); in OnDisconnect()625 if (it == producer_->pending_processes_.end()) { in OnDisconnect()631 producer_->pending_processes_.erase(it); in OnDisconnect()647 auto it = producer_->pending_processes_.find(self->peer_pid()); in OnDataAvailable()648 if (it == producer_->pending_processes_.end()) { in OnDataAvailable()664 producer_->pending_processes_.erase(it); in OnDataAvailable()690 producer_->pending_processes_.erase(it); in OnDataAvailable()693 producer_->pending_processes_.erase(it); in OnDataAvailable()751 pending_processes_.emplace(peer_pid, std::move(pending_process)); in HandleClientConnection()
239 std::map<pid_t, PendingProcess> pending_processes_; variable