Skip to content

Commit c4bcce0

Browse files
authored
feat(storage): Remove unnecessary code which was causing race condition (#15551)
1 parent 19f9509 commit c4bcce0

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

google/cloud/storage/internal/async/writer_connection_resumed.cc

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -429,9 +429,6 @@ class AsyncWriterConnectionResumedState
429429

430430
void SetFlushed(std::unique_lock<std::mutex> lk, Status const& result) {
431431
if (!result.ok()) return SetError(std::move(lk), std::move(result));
432-
// This flush step completed. We are no longer actively writing this chunk.
433-
// WriteLoop will determine if another flush/write is needed.
434-
writing_ = false;
435432
flush_ = false; // Reset flush flag; WriteLoop may set it again.
436433
// Do NOT reset finalize_ or finalizing_ here.
437434
auto handlers = ClearHandlers(lk);

0 commit comments

Comments
 (0)