Skip to content

Commit ab7a125

Browse files
The message field is not used (#16910)
1 parent 0e810ef commit ab7a125

File tree

2 files changed

+4
-7
lines changed

2 files changed

+4
-7
lines changed

ydb/core/persqueue/events/internal.h

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -492,15 +492,13 @@ struct TEvPQ {
492492
};
493493

494494
struct TEvBlobRequest : public TEventLocal<TEvBlobRequest, EvBlobRequest> {
495-
TEvBlobRequest(const TString& user, const ui64 cookie, const NPQ::TPartitionId& partition,
495+
TEvBlobRequest(const ui64 cookie, const NPQ::TPartitionId& partition,
496496
TVector<NPQ::TRequestedBlob>&& blobs)
497-
: User(user)
498-
, Cookie(cookie)
497+
: Cookie(cookie)
499498
, Partition(partition)
500499
, Blobs(std::move(blobs))
501500
{}
502501

503-
TString User;
504502
ui64 Cookie;
505503
NPQ::TPartitionId Partition;
506504
TVector<NPQ::TRequestedBlob> Blobs;

ydb/core/persqueue/partition_read.cpp

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1065,13 +1065,12 @@ void TPartition::ProcessRead(const TActorContext& ctx, TReadInfo&& info, const u
10651065
return;
10661066
}
10671067

1068-
const TString user = info.User;
10691068
bool res = ReadInfo.emplace(cookie, std::move(info)).second;
10701069
PQ_LOG_D("Reading cookie " << cookie << ". Send blob request.");
10711070
Y_ABORT_UNLESS(res);
10721071

1073-
THolder<TEvPQ::TEvBlobRequest> request(new TEvPQ::TEvBlobRequest(user, cookie, Partition,
1074-
std::move(blobs)));
1072+
auto request = MakeHolder<TEvPQ::TEvBlobRequest>(cookie, Partition,
1073+
std::move(blobs));
10751074

10761075
ctx.Send(BlobCache, request.Release());
10771076
}

0 commit comments

Comments
 (0)