Fix TEvDeliveryProblem in some edge cases (#4886)

snaury · web-flow · commit 2f7e2b402686 · 2024-05-27T17:22:59.000+03:00
diff --git a/ydb/core/tablet/tablet_pipecache.cpp b/ydb/core/tablet/tablet_pipecache.cpp
@@ -327,7 +327,7 @@ class TPipePeNodeCache : public TActor<TPipePeNodeCache> {
         // Don't create an empty tablet record that won't be used
         if (Y_UNLIKELY(!msg->Options.AutoConnect && !ByTablet.contains(tablet))) {
             if (subscribe) {
-                Send(peer, new TEvPipeCache::TEvDeliveryProblem(tablet, NKikimrProto::ERROR, true, false), 0, subscribeCookie);
+                Send(peer, new TEvPipeCache::TEvDeliveryProblem(tablet, false, true, false), 0, subscribeCookie);
             }
             return;
         }
@@ -353,7 +353,7 @@ class TPipePeNodeCache : public TActor<TPipePeNodeCache> {
                 // Note that this is not a typical use-case, implemented for completeness
                 clientState = tabletState->GetActive();
                 if (!clientState) {
-                    Send(peer, new TEvPipeCache::TEvDeliveryProblem(tablet, NKikimrProto::ERROR, true, false), 0, subscribeCookie);
+                    Send(peer, new TEvPipeCache::TEvDeliveryProblem(tablet, false, true, false), 0, subscribeCookie);
                     return;
                 }
             } else {

Original file line number	Diff line number	Diff line change
`@@ -327,7 +327,7 @@ class TPipePeNodeCache : public TActor<TPipePeNodeCache> {`
`327`	`327`	`// Don't create an empty tablet record that won't be used`
`328`	`328`	`if (Y_UNLIKELY(!msg->Options.AutoConnect && !ByTablet.contains(tablet))) {`
`329`	`329`	`if (subscribe) {`
`330`		`- Send(peer, new TEvPipeCache::TEvDeliveryProblem(tablet, NKikimrProto::ERROR, true, false), 0, subscribeCookie);`
	`330`	`+ Send(peer, new TEvPipeCache::TEvDeliveryProblem(tablet, false, true, false), 0, subscribeCookie);`
`331`	`331`	`}`
`332`	`332`	`return;`
`333`	`333`	`}`
`@@ -353,7 +353,7 @@ class TPipePeNodeCache : public TActor<TPipePeNodeCache> {`
`353`	`353`	`// Note that this is not a typical use-case, implemented for completeness`
`354`	`354`	`clientState = tabletState->GetActive();`
`355`	`355`	`if (!clientState) {`
`356`		`- Send(peer, new TEvPipeCache::TEvDeliveryProblem(tablet, NKikimrProto::ERROR, true, false), 0, subscribeCookie);`
	`356`	`+ Send(peer, new TEvPipeCache::TEvDeliveryProblem(tablet, false, true, false), 0, subscribeCookie);`
`357`	`357`	`return;`
`358`	`358`	`}`
`359`	`359`	`} else {`