@@ -74,7 +74,7 @@ seastar::future<> tri_mutex::lock_for_read()
7474 return seastar::now ();
7575 }
7676 DEBUGDPP (" can't lock_for_read, adding to waiters" , *this );
77- waiters.emplace_back (seastar::promise<>(), type_t ::read);
77+ waiters.emplace_back (seastar::promise<>(), type_t ::read, name );
7878 return waiters.back ().pr .get_future ();
7979}
8080
@@ -127,7 +127,7 @@ seastar::future<> tri_mutex::lock_for_write()
127127 return seastar::now ();
128128 }
129129 DEBUGDPP (" can't lock_for_write, adding to waiters" , *this );
130- waiters.emplace_back (seastar::promise<>(), type_t ::write);
130+ waiters.emplace_back (seastar::promise<>(), type_t ::write, name );
131131 return waiters.back ().pr .get_future ();
132132}
133133
@@ -182,7 +182,7 @@ seastar::future<> tri_mutex::lock_for_excl()
182182 return seastar::now ();
183183 }
184184 DEBUGDPP (" can't lock_for_excl, adding to waiters" , *this );
185- waiters.emplace_back (seastar::promise<>(), type_t ::exclusive);
185+ waiters.emplace_back (seastar::promise<>(), type_t ::exclusive, name );
186186 return waiters.back ().pr .get_future ();
187187}
188188
@@ -251,7 +251,7 @@ void tri_mutex::wake()
251251 default :
252252 assert (0 );
253253 }
254- // TODO: DEBUGDPP("waking up {} ", *this);
254+ DEBUGDPP (" waking up {}" , *this , waiter. waiter_name );
255255 waiter.pr .set_value ();
256256 waiters.pop_front ();
257257 }
0 commit comments