Skip to content

Commit f693523

Browse files
nshestakovGazizonoki
authored andcommitted
Moved commit "Fix lost grpc messages after write error" from ydb repo
1 parent 12b392e commit f693523

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

include/ydb-cpp-sdk/library/grpc/client/grpc_client_low.h

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1075,7 +1075,7 @@ class TStreamRequestReadWriteProcessor
10751075
Y_ABORT_UNLESS(ReadActive, "Unexpected Read done callback");
10761076
Y_ABORT_UNLESS(!ReadFinished, "Unexpected ReadFinished flag");
10771077

1078-
if (!ok || Cancelled || WriteFinished) {
1078+
if (!ok || Cancelled) {
10791079
ReadFinished = true;
10801080
if (!WriteActive) {
10811081
WriteFinished = true;
@@ -1124,9 +1124,6 @@ class TStreamRequestReadWriteProcessor
11241124
if (!ok || Cancelled) {
11251125
WriteActive = false;
11261126
WriteFinished = true;
1127-
if (!ReadActive) {
1128-
ReadFinished = true;
1129-
}
11301127
if (ReadFinished) {
11311128
Stream->Finish(&Status, OnFinishedTag.Prepare());
11321129
}

0 commit comments

Comments
 (0)