Fix stucking donor queries (merge from main ydb-platform#10470) (ydb-platform#10555)

alexvru · uzhastik · commit a01556050df1 · 2024-10-25T00:43:14.000+03:00
diff --git a/ydb/core/blobstorage/vdisk/repl/query_donor.h b/ydb/core/blobstorage/vdisk/repl/query_donor.h
@@ -68,10 +68,9 @@ namespace NKikimr {
             }
 
             if (action) {
-                const TActorId temp(actorId);
                 LOG_DEBUG_S(*TlsActivationContext, NKikimrServices::BS_VDISK_GET, SelfId() << " sending " << query->ToString()
-                    << " to " << temp);
-                Send(actorId, query.release());
+                    << " to " << actorId);
+                Send(actorId, query.release(), IEventHandle::FlagTrackDelivery);
             } else {
                 PassAway();
             }
@@ -116,6 +115,7 @@ namespace NKikimr {
 
         STRICT_STFUNC(StateFunc,
             hFunc(TEvBlobStorage::TEvVGetResult, Handle);
+            cFunc(TEvents::TSystem::Undelivered, Step);
             cFunc(TEvents::TSystem::Poison, PassAway);
         )
     };

Original file line number	Diff line number	Diff line change
`@@ -68,10 +68,9 @@ namespace NKikimr {`
`68`	`68`	`}`
`69`	`69`
`70`	`70`	`if (action) {`
`71`		`- const TActorId temp(actorId);`
`72`	`71`	`LOG_DEBUG_S(*TlsActivationContext, NKikimrServices::BS_VDISK_GET, SelfId() << " sending " << query->ToString()`
`73`		`- << " to " << temp);`
`74`		`- Send(actorId, query.release());`
	`72`	`+ << " to " << actorId);`
	`73`	`+ Send(actorId, query.release(), IEventHandle::FlagTrackDelivery);`
`75`	`74`	`} else {`
`76`	`75`	`PassAway();`
`77`	`76`	`}`
`@@ -116,6 +115,7 @@ namespace NKikimr {`
`116`	`115`
`117`	`116`	`STRICT_STFUNC(StateFunc,`
`118`	`117`	`hFunc(TEvBlobStorage::TEvVGetResult, Handle);`
	`118`	`+ cFunc(TEvents::TSystem::Undelivered, Step);`
`119`	`119`	`cFunc(TEvents::TSystem::Poison, PassAway);`
`120`	`120`	`)`
`121`	`121`	`};`