@@ -137,7 +137,9 @@ void TReadDataActor::DescribeData(const TActorContext& ctx)
137
137
LOG_DEBUG (
138
138
ctx,
139
139
TFileStoreComponents::SERVICE,
140
- " Executing DescribeData for %lu, %lu, %lu, %lu" ,
140
+ " %s executing DescribeData for node: %lu, "
141
+ " handle: %lu, offset: %lu, length: %lu" ,
142
+ LogTag.c_str (),
141
143
ReadRequest.GetNodeId (),
142
144
ReadRequest.GetHandle (),
143
145
ReadRequest.GetOffset (),
@@ -285,7 +287,8 @@ void TReadDataActor::HandleDescribeDataResponse(
285
287
LOG_DEBUG (
286
288
ctx,
287
289
TFileStoreComponents::SERVICE,
288
- " DescribeData succeeded %lu freshdata + %lu blobpieces" ,
290
+ " %s DescribeData succeeded %lu freshdata + %lu blobpieces" ,
291
+ LogTag.c_str (),
289
292
msg->Record .FreshDataRangesSize (),
290
293
msg->Record .BlobPiecesSize ());
291
294
@@ -379,22 +382,24 @@ void TReadDataActor::HandleReadBlobResponse(
379
382
const auto * msg = ev->Get ();
380
383
381
384
if (msg->Status != NKikimrProto::OK) {
382
- const auto errorReason = FormatError (
383
- MakeError (MAKE_KIKIMR_ERROR (msg->Status ), msg->ErrorReason ));
384
385
LOG_WARN (
385
386
ctx,
386
387
TFileStoreComponents::SERVICE,
387
- " ReadBlob error: %s" ,
388
- errorReason .c_str ());
389
- ReadData (ctx, errorReason );
388
+ " %s TEvBlobStorage::TEvGet failed: response %s" ,
389
+ LogTag .c_str (),
390
+ msg-> Print ( false ). c_str () );
390
391
392
+ const auto errorReason = FormatError (
393
+ MakeError (MAKE_KIKIMR_ERROR (msg->Status ), msg->ErrorReason ));
394
+ ReadData (ctx, errorReason);
391
395
return ;
392
396
}
393
397
394
398
LOG_DEBUG (
395
399
ctx,
396
400
TFileStoreComponents::SERVICE,
397
- " ReadBlobResponse count: %lu, status: %lu, cookie: %lu" ,
401
+ " %s ReadBlobResponse count: %lu, status: %lu, cookie: %lu" ,
402
+ LogTag.c_str (),
398
403
msg->ResponseSz ,
399
404
(ui64)(msg->Status ),
400
405
ev->Cookie );
@@ -409,15 +414,18 @@ void TReadDataActor::HandleReadBlobResponse(
409
414
const auto & blobRange = blobPiece.GetRanges (i);
410
415
const auto & response = msg->Responses [i];
411
416
if (response.Status != NKikimrProto::OK) {
412
- const auto errorReason = FormatError (
413
- MakeError (MAKE_KIKIMR_ERROR (response.Status ), " read error" ));
414
417
LOG_WARN (
415
418
ctx,
416
419
TFileStoreComponents::SERVICE,
417
- " ReadBlob error: %s" ,
418
- errorReason.c_str ());
419
- ReadData (ctx, errorReason);
420
+ " %s TEvBlobStorage::TEvGet query failed:"
421
+ " status %s, response %s" ,
422
+ LogTag.c_str (),
423
+ NKikimrProto::EReplyStatus_Name (response.Status ).c_str (),
424
+ msg->Print (false ).c_str ());
420
425
426
+ const auto errorReason = FormatError (
427
+ MakeError (MAKE_KIKIMR_ERROR (response.Status ), " read error" ));
428
+ ReadData (ctx, errorReason);
421
429
return ;
422
430
}
423
431
@@ -438,7 +446,8 @@ void TReadDataActor::HandleReadBlobResponse(
438
446
LOG_WARN (
439
447
ctx,
440
448
TFileStoreComponents::SERVICE,
441
- " ReadBlob error: %s" ,
449
+ " %s ReadBlob error: %s" ,
450
+ LogTag.c_str (),
442
451
error.c_str ());
443
452
ReadData (ctx, error);
444
453
@@ -503,7 +512,9 @@ void TReadDataActor::ReadData(
503
512
LOG_WARN (
504
513
ctx,
505
514
TFileStoreComponents::SERVICE,
506
- " Falling back to ReadData for %lu, %lu, %lu, %lu. Message: %s" ,
515
+ " %s falling back to ReadData: "
516
+ " node: %lu, handle: %lu, offset: %lu, length: %lu. Message: %s" ,
517
+ LogTag.c_str (),
507
518
ReadRequest.GetNodeId (),
508
519
ReadRequest.GetHandle (),
509
520
ReadRequest.GetOffset (),
@@ -567,7 +578,8 @@ void TReadDataActor::ReplyAndDie(const TActorContext& ctx)
567
578
LOG_DEBUG (
568
579
ctx,
569
580
TFileStoreComponents::SERVICE,
570
- " processed fresh data range size: %lu, offset: %lu" ,
581
+ " %s processed fresh data range size: %lu, offset: %lu" ,
582
+ LogTag.c_str (),
571
583
content.size (),
572
584
offset);
573
585
}
0 commit comments