Skip to content

Commit 86413a0

Browse files
committed
Merge mistakes
1 parent c50eac9 commit 86413a0

File tree

7 files changed

+8
-11
lines changed

7 files changed

+8
-11
lines changed

ydb/core/blobstorage/dsproxy/dsproxy.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -718,7 +718,7 @@ struct TBlobStorageGroupMultiPutParameters {
718718
return maxRestarts;
719719
}
720720
};
721-
IActor* CreateBlobStorageGroupPutRequest(TBlobStorageGroupMultiPutParameters params, NWilson::TTraceId traceId);
721+
IActor* CreateBlobStorageGroupPutRequest(TBlobStorageGroupMultiPutParameters params);
722722

723723
struct TBlobStorageGroupGetParameters {
724724
TBlobStorageGroupRequestActor<TEvBlobStorage::TEvGet>::TCommonParameters Common;

ydb/core/blobstorage/dsproxy/dsproxy_block.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -172,7 +172,7 @@ class TBlobStorageGroupBlockRequest : public TBlobStorageGroupRequestActor<TBlob
172172
IActor* CreateBlobStorageGroupBlockRequest(TBlobStorageGroupBlockParameters params, NWilson::TTraceId traceId) {
173173
NWilson::TSpan span(TWilson::BlobStorage, std::move(traceId), "DSProxy.Block");
174174
if (span) {
175-
span.Attribute("event", ev->ToString());
175+
span.Attribute("event", params.Common.Event->ToString());
176176
}
177177
params.Common.Span = std::move(span);
178178
return new TBlobStorageGroupBlockRequest(params);

ydb/core/blobstorage/dsproxy/dsproxy_get.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -468,7 +468,7 @@ class TBlobStorageGroupGetRequest : public TBlobStorageGroupRequestActor<TBlobSt
468468
IActor* CreateBlobStorageGroupGetRequest(TBlobStorageGroupGetParameters params, NWilson::TTraceId traceId) {
469469
NWilson::TSpan span(TWilson::BlobStorage, std::move(traceId), "DSProxy.Get");
470470
if (span) {
471-
span.Attribute("event", ev->ToString());
471+
span.Attribute("event", params.Common.Event->ToString());
472472
}
473473
params.Common.Span = std::move(span);
474474
return new TBlobStorageGroupGetRequest(params);

ydb/core/blobstorage/dsproxy/dsproxy_indexrestoreget.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -391,7 +391,7 @@ class TBlobStorageGroupIndexRestoreGetRequest
391391
IActor* CreateBlobStorageGroupIndexRestoreGetRequest(TBlobStorageGroupRestoreGetParameters params, NWilson::TTraceId traceId) {
392392
NWilson::TSpan span(TWilson::BlobStorage, std::move(traceId), "DSProxy.IndexRestoreGet");
393393
if (span) {
394-
span.Attribute("event", ev->ToString());
394+
span.Attribute("event", params.Common.Event->ToString());
395395
}
396396
params.Common.Span = std::move(span);
397397
return new TBlobStorageGroupIndexRestoreGetRequest(params);

ydb/core/blobstorage/dsproxy/dsproxy_patch.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1041,7 +1041,7 @@ class TBlobStorageGroupPatchRequest : public TBlobStorageGroupRequestActor<TBlob
10411041
IActor* CreateBlobStorageGroupPatchRequest(TBlobStorageGroupPatchParameters params, NWilson::TTraceId traceId) {
10421042
NWilson::TSpan span(TWilson::BlobStorage, std::move(traceId), "DSProxy.Patch");
10431043
if (span) {
1044-
span.Attribute("event", ev->ToString());
1044+
span.Attribute("event", params.Common.Event->ToString());
10451045
}
10461046
params.Common.Span = std::move(span);
10471047
return new TBlobStorageGroupPatchRequest(params);

ydb/core/blobstorage/dsproxy/dsproxy_put.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -752,7 +752,7 @@ class TBlobStorageGroupPutRequest : public TBlobStorageGroupRequestActor<TBlobSt
752752
IActor* CreateBlobStorageGroupPutRequest(TBlobStorageGroupPutParameters params, NWilson::TTraceId traceId) {
753753
NWilson::TSpan span(TWilson::BlobStorage, std::move(traceId), "DSProxy.Put");
754754
if (span) {
755-
span.Attribute("event", ev->ToString());
755+
span.Attribute("event", params.Common.Event->ToString());
756756
}
757757
params.Common.Span = std::move(span);
758758
return new TBlobStorageGroupPutRequest(params);

ydb/core/blobstorage/dsproxy/dsproxy_request.cpp

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -126,12 +126,11 @@ namespace NKikimr {
126126
.Now = TActivationContext::Now(),
127127
.StoragePoolCounters = StoragePoolCounters,
128128
.RestartCounter = ev->Get()->RestartCounter,
129-
.TraceId = std::move(ev->TraceId),
130129
.Event = ev->Get(),
131130
.ExecutionRelay = ev->Get()->ExecutionRelay,
132131
.LatencyQueueKind = kind,
133132
},
134-
}),
133+
}, std::move(ev->TraceId)),
135134
ev->Get()->Deadline
136135
);
137136
}
@@ -217,7 +216,6 @@ namespace NKikimr {
217216
.Now = TActivationContext::Now(),
218217
.StoragePoolCounters = StoragePoolCounters,
219218
.RestartCounter = ev->Get()->RestartCounter,
220-
.TraceId = std::move(ev->TraceId),
221219
.Event = ev->Get(),
222220
.ExecutionRelay = ev->Get()->ExecutionRelay,
223221
.LatencyQueueKind = kind
@@ -364,11 +362,10 @@ namespace NKikimr {
364362
.Now = TActivationContext::Now(),
365363
.StoragePoolCounters = StoragePoolCounters,
366364
.RestartCounter = ev->Get()->RestartCounter,
367-
.TraceId = std::move(ev->TraceId),
368365
.Event = ev->Get(),
369366
.ExecutionRelay = ev->Get()->ExecutionRelay
370367
}
371-
}),
368+
}, std::move(ev->TraceId)),
372369
ev->Get()->Deadline
373370
);
374371
} else {

0 commit comments

Comments
 (0)