From 984ec1cdc637569b847936f6769cf93ff0122dfe Mon Sep 17 00:00:00 2001 From: Vignesh Babu Date: Tue, 12 Mar 2024 18:06:57 +0000 Subject: [PATCH] fix per comments --- src/core/ext/transport/chaotic_good/server_transport.cc | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/core/ext/transport/chaotic_good/server_transport.cc b/src/core/ext/transport/chaotic_good/server_transport.cc index b28f4f9f8fa..50e6ee3f9dd 100644 --- a/src/core/ext/transport/chaotic_good/server_transport.cc +++ b/src/core/ext/transport/chaotic_good/server_transport.cc @@ -441,7 +441,7 @@ absl::optional ChaoticGoodServerTransport::ExtractStream( absl::Status ChaoticGoodServerTransport::NewStream( uint32_t stream_id, CallInitiator call_initiator) { - ReleasableMutexLock lock(&mu_); + MutexLock lock(&mu_); auto it = stream_map_.find(stream_id); if (it != stream_map_.end()) { return absl::InternalError("Stream already exists"); @@ -450,7 +450,6 @@ absl::Status ChaoticGoodServerTransport::NewStream( return absl::InternalError("Stream id is not increasing"); } stream_map_.emplace(stream_id, call_initiator); - lock.Release(); call_initiator.OnDone([this, stream_id]() { MutexLock lock(&mu_); stream_map_.erase(stream_id);