Refactor LOG macroses in dsproxy (#8287)

Co-authored-by: Vlad Kuznecov <va-kuznecov@nebius.com>

Author: va-kuznecov

ydb/core/blobstorage/dsproxy/dsproxy_assimilate.cpp

@@ -276,7 +276,7 @@ class TBlobStorageGroupAssimilateRequest : public TBlobStorageGroupRequestActor
     }
 
     void Bootstrap() override {
-        A_LOG_INFO_S("BPA01", "bootstrap"
+        DSP_LOG_INFO_S("BPA01", "bootstrap"
             << " ActorId# " << SelfId()
             << " Group# " << Info->GroupID
             << " RestartCounter# " << RestartCounter);
@@ -289,7 +289,7 @@ class TBlobStorageGroupAssimilateRequest : public TBlobStorageGroupRequestActor
     }
 
     void HandleWakeup() {
-        A_LOG_NOTICE_S("BPA25", "assimilation is way too long");
+        DSP_LOG_NOTICE_S("BPA25", "assimilation is way too long");
     }
 
     STATEFN(StateWork) {
@@ -315,7 +315,7 @@ class TBlobStorageGroupAssimilateRequest : public TBlobStorageGroupRequestActor
             maxOpt(SkipBarriersUpTo, info.LastProcessedBarrier),
             maxOpt(SkipBlobsUpTo, info.LastProcessedBlob)), 0);
 
-        A_LOG_DEBUG_S("BPA03", "Request orderNumber# " << orderNumber << " VDiskId# " << Info->GetVDiskId(orderNumber));
+        DSP_LOG_DEBUG_S("BPA03", "Request orderNumber# " << orderNumber << " VDiskId# " << Info->GetVDiskId(orderNumber));
 
         ++RequestsInFlight;
     }
@@ -328,7 +328,7 @@ class TBlobStorageGroupAssimilateRequest : public TBlobStorageGroupRequestActor
         const ui32 orderNumber = Info->GetTopology().GetOrderNumber(vdiskId);
         Y_ABORT_UNLESS(orderNumber < PerVDiskInfo.size());
 
-        A_LOG_DEBUG_S("BPA02", "Handle TEvVAssimilateResult"
+        DSP_LOG_DEBUG_S("BPA02", "Handle TEvVAssimilateResult"
                 << " Status# " << NKikimrProto::EReplyStatus_Name(record.GetStatus())
                 << " ErrorReason# '" << record.GetErrorReason() << "'"
                 << " VDiskId# " << vdiskId
@@ -379,14 +379,14 @@ class TBlobStorageGroupAssimilateRequest : public TBlobStorageGroupRequestActor
                 ReplyAndDie(NKikimrProto::ERROR);
             } else {
                 // answer with what we have already collected
-                A_LOG_DEBUG_S("BPA06", "SendResponseAndDie (no items to merge)");
+                DSP_LOG_DEBUG_S("BPA06", "SendResponseAndDie (no items to merge)");
                 SendResponseAndDie(std::move(Result));
             }
             return;
         }
         while (requests.empty()) {
             if (Heap.empty()) {
-                A_LOG_DEBUG_S("BPA07", "SendResponseAndDie (heap empty)");
+                DSP_LOG_DEBUG_S("BPA07", "SendResponseAndDie (heap empty)");
                 SendResponseAndDie(std::move(Result));
                 return;
             }
@@ -429,7 +429,7 @@ class TBlobStorageGroupAssimilateRequest : public TBlobStorageGroupRequestActor
         }
 
         if (Result->Blocks.size() + Result->Barriers.size() + Result->Blobs.size() >= 10'000) {
-            A_LOG_DEBUG_S("BPA05", "SendResponseAndDie (10k)");
+            DSP_LOG_DEBUG_S("BPA05", "SendResponseAndDie (10k)");
             SendResponseAndDie(std::move(Result));
         } else {
             for (const ui32 orderNumber : requests) {
@@ -446,7 +446,7 @@ class TBlobStorageGroupAssimilateRequest : public TBlobStorageGroupRequestActor
     }
 
     void ReplyAndDie(NKikimrProto::EReplyStatus status) override {
-        A_LOG_DEBUG_S("BPA04", "ReplyAndDie status# " << NKikimrProto::EReplyStatus_Name(status));
+        DSP_LOG_DEBUG_S("BPA04", "ReplyAndDie status# " << NKikimrProto::EReplyStatus_Name(status));
         for (const auto& item : PerVDiskInfo) {
             if (item.ErrorReason) {
                 if (ErrorReason) {

ydb/core/blobstorage/dsproxy/dsproxy_block.cpp

@@ -38,7 +38,7 @@ class TBlobStorageGroupBlockRequest : public TBlobStorageGroupRequestActor {
         // You can't call GetActorId before calling IsValidId
         Y_ABORT_UNLESS(Info->IsValidId(shortId), "Invalid VDiskId VDiskId# %s", shortId.ToString().c_str());
 
-        A_LOG_LOG_S(false, PriorityForStatusInbound(status), "DSPB01", "Handle TEvVBlockResult"
+        DSP_LOG_LOG_S(PriorityForStatusInbound(status), "DSPB01", "Handle TEvVBlockResult"
             << " status# " << NKikimrProto::EReplyStatus_Name(status).data()
             << " From# " << vdisk.ToString()
             << " NodeId# " << Info->GetActorId(vdisk).NodeId());
@@ -98,15 +98,15 @@ class TBlobStorageGroupBlockRequest : public TBlobStorageGroupRequestActor {
     void ReplyAndDie(NKikimrProto::EReplyStatus status) override {
         std::unique_ptr<TEvBlobStorage::TEvBlockResult> result(new TEvBlobStorage::TEvBlockResult(status));
         result->ErrorReason = ErrorReason;
-        A_LOG_LOG_S(true, PriorityForStatusResult(status), "DSPB04", "Result# " << result->Print(false));
+        DSP_LOG_LOG_S(PriorityForStatusResult(status), "DSPB04", "Result# " << result->Print(false));
         Mon->CountBlockResponseTime(TActivationContext::Now() - StartTime);
         return SendResponseAndDie(std::move(result));
     }
 
     void SendBlockRequest(const TVDiskID& vdiskId) {
         const ui64 cookie = TVDiskIdShort(vdiskId).GetRaw();
 
-        A_LOG_DEBUG_S("DSPB03", "Sending TEvVBlock Tablet# " << TabletId
+        DSP_LOG_DEBUG_S("DSPB03", "Sending TEvVBlock Tablet# " << TabletId
             << " Generation# " << Generation
             << " vdiskId# " << vdiskId
             << " node# " << Info->GetActorId(vdiskId).NodeId());
@@ -143,7 +143,7 @@ class TBlobStorageGroupBlockRequest : public TBlobStorageGroupRequestActor {
     {}
 
     void Bootstrap() override {
-        A_LOG_DEBUG_S("DSPB05", "bootstrap"
+        DSP_LOG_DEBUG_S("DSPB05", "bootstrap"
             << " ActorId# " << SelfId()
             << " Group# " << Info->GroupID
             << " TabletId# " << TabletId

ydb/core/blobstorage/dsproxy/dsproxy_collect.cpp

@@ -41,7 +41,7 @@ class TBlobStorageGroupCollectGarbageRequest : public TBlobStorageGroupRequestAc
         Y_ABORT_UNLESS(record.HasVDiskID());
         const TVDiskID vdisk = VDiskIDFromVDiskID(record.GetVDiskID());
 
-        A_LOG_LOG_S(false, PriorityForStatusInbound(status), "DSPC01", "received"
+        DSP_LOG_LOG_S(PriorityForStatusInbound(status), "DSPC01", "received"
                << " TEvVCollectGarbageResult# " << ev->Get()->ToString());
 
         Process(status, vdisk, record.HasIncarnationGuid() ? std::make_optional(record.GetIncarnationGuid()) : std::nullopt);
@@ -110,7 +110,7 @@ class TBlobStorageGroupCollectGarbageRequest : public TBlobStorageGroupRequestAc
         auto result = std::make_unique<TEvBlobStorage::TEvCollectGarbageResult>(status, TabletId, RecordGeneration,
             PerGenerationCounter, Channel);
         result->ErrorReason = ErrorReason;
-        A_LOG_LOG_S(true, status == NKikimrProto::OK ? NLog::PRI_INFO : NLog::PRI_NOTICE, "DSPC02", "Result# " << result->Print(false));
+        DSP_LOG_LOG_S(status == NKikimrProto::OK ? NLog::PRI_INFO : NLog::PRI_NOTICE, "DSPC02", "Result# " << result->Print(false));
         SendResponseAndDie(std::move(result));
     }
 
@@ -159,7 +159,7 @@ class TBlobStorageGroupCollectGarbageRequest : public TBlobStorageGroupRequestAc
     {}
 
     void Bootstrap() override {
-        A_LOG_INFO_S("DSPC03", "bootstrap"
+        DSP_LOG_INFO_S("DSPC03", "bootstrap"
             << " ActorId# " << SelfId()
             << " Group# " << Info->GroupID
             << " TabletId# " << TabletId
@@ -174,11 +174,11 @@ class TBlobStorageGroupCollectGarbageRequest : public TBlobStorageGroupRequestAc
             << " RestartCounter# " << RestartCounter);
 
         for (const auto& item : Keep ? *Keep : TVector<TLogoBlobID>()) {
-            A_LOG_INFO_S("DSPC04", "Keep# " << item);
+            DSP_LOG_INFO_S("DSPC04", "Keep# " << item);
         }
 
         for (const auto& item : DoNotKeep ? *DoNotKeep : TVector<TLogoBlobID>()) {
-            A_LOG_INFO_S("DSPC05", "DoNotKeep# " << item);
+            DSP_LOG_INFO_S("DSPC05", "DoNotKeep# " << item);
         }
 
         for (const auto& vdisk : Info->GetVDisks()) {