@@ -384,9 +384,10 @@ namespace NKikimr {
384
384
const bool fromVPutCommand = true ;
385
385
const TLogoBlobID id = LogoBlobIDFromLogoBlobID (PutMsg.GetBlobID ());
386
386
const TString &buf = PutMsg.GetBuffer ();
387
- TIngress ingress = *TIngress::CreateIngressWithLocal (LocRecCtx->VCtx ->Top .get (), LocRecCtx->VCtx ->ShortSelfVDisk , id);
387
+ TMaybe<TIngress> ingress = TIngress::CreateIngressWithLocal (LocRecCtx->VCtx ->Top .get (), LocRecCtx->VCtx ->ShortSelfVDisk , id);
388
+ Y_VERIFY_S (ingress, " Failed to create ingress, VDiskId# " << LocRecCtx->VCtx ->ShortSelfVDisk << " , BlobId# " << id);
388
389
389
- PutLogoBlobToHullAndSyncLog (ctx, record.Lsn , id, ingress, buf, fromVPutCommand);
390
+ PutLogoBlobToHullAndSyncLog (ctx, record.Lsn , id, * ingress, buf, fromVPutCommand);
390
391
return EDispatchStatus::Success;
391
392
}
392
393
@@ -396,10 +397,12 @@ namespace NKikimr {
396
397
return EDispatchStatus::Error;
397
398
398
399
const bool fromVPutCommand = true ;
399
- TIngress ingress = * TIngress::CreateIngressWithLocal (LocRecCtx->VCtx ->Top .get (), LocRecCtx->VCtx ->ShortSelfVDisk ,
400
+ TMaybe< TIngress> ingress = TIngress::CreateIngressWithLocal (LocRecCtx->VCtx ->Top .get (), LocRecCtx->VCtx ->ShortSelfVDisk ,
400
401
PutMsgOpt.Id );
402
+ Y_VERIFY_S (ingress, " Failed to create ingress, VDiskId# " << LocRecCtx->VCtx ->ShortSelfVDisk <<
403
+ " , BlobId# " << PutMsgOpt.Id );
401
404
402
- PutLogoBlobToHullAndSyncLog (ctx, record.Lsn , PutMsgOpt.Id , ingress, PutMsgOpt.Data , fromVPutCommand);
405
+ PutLogoBlobToHullAndSyncLog (ctx, record.Lsn , PutMsgOpt.Id , * ingress, PutMsgOpt.Data , fromVPutCommand);
403
406
return EDispatchStatus::Success;
404
407
}
405
408
0 commit comments