Skip to content

Commit 64026dc

Browse files
ildar-khisambeevGazizonoki
authored andcommitted
Moved "fix implicit cast offset to bool" commit from ydb repo
1 parent c11b1c2 commit 64026dc

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

include/ydb-cpp-sdk/client/topic/read_events.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -267,7 +267,7 @@ struct TReadSessionEvent {
267267
//! Server can destroy partition session gracefully
268268
//! for rebalancing among all topic clients.
269269
struct TStopPartitionSessionEvent: public TPartitionSessionAccessor, public TPrintable<TStopPartitionSessionEvent> {
270-
TStopPartitionSessionEvent(TPartitionSession::TPtr partitionSession, bool committedOffset);
270+
TStopPartitionSessionEvent(TPartitionSession::TPtr partitionSession, ui64 committedOffset);
271271

272272
//! Last offset of the partition session that was committed.
273273
ui64 GetCommittedOffset() const {

src/client/persqueue_public/impl/read_session.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -560,7 +560,7 @@ void TReadSessionEvent::TCreatePartitionStreamEvent::Confirm(std::optional<ui64>
560560
}
561561
}
562562

563-
TReadSessionEvent::TDestroyPartitionStreamEvent::TDestroyPartitionStreamEvent(TPartitionStream::TPtr partitionStream, bool committedOffset)
563+
TReadSessionEvent::TDestroyPartitionStreamEvent::TDestroyPartitionStreamEvent(TPartitionStream::TPtr partitionStream, ui64 committedOffset)
564564
: PartitionStream(std::move(partitionStream))
565565
, CommittedOffset(committedOffset)
566566
{

src/client/persqueue_public/include/read_events.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -352,7 +352,7 @@ struct TReadSessionEvent {
352352

353353
std::string DebugString() const;
354354

355-
TDestroyPartitionStreamEvent(TPartitionStream::TPtr partitionStream, bool committedOffset);
355+
TDestroyPartitionStreamEvent(TPartitionStream::TPtr partitionStream, ui64 committedOffset);
356356

357357
private:
358358
TPartitionStream::TPtr PartitionStream;

src/client/topic/impl/read_session_event.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -320,7 +320,7 @@ void TPrintable<TStartPartitionSessionEvent>::DebugString(TStringBuilder& ret, b
320320
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
321321
// NTopic::TReadSessionEvent::TStopPartitionSessionEvent
322322

323-
TStopPartitionSessionEvent::TStopPartitionSessionEvent(TPartitionSession::TPtr partitionSession, bool committedOffset)
323+
TStopPartitionSessionEvent::TStopPartitionSessionEvent(TPartitionSession::TPtr partitionSession, ui64 committedOffset)
324324
: TPartitionSessionAccessor(std::move(partitionSession))
325325
, CommittedOffset(committedOffset) {
326326
}

0 commit comments

Comments
 (0)