Skip to content

Commit bb1a3cd

Browse files
update log message
1 parent 1a10e2d commit bb1a3cd

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

src/Ydb.Sdk/src/Services/Topic/Reader/Reader.cs

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -557,16 +557,22 @@ protected override MessageFromClient GetSendUpdateTokenRequest(string token)
557557

558558
public override async ValueTask DisposeAsync()
559559
{
560+
Logger.LogInformation("ReaderSession[{SessionId}]: start dispose process", SessionId);
561+
560562
_channelFromClientMessageSending.Writer.Complete();
561563

562564
try
563565
{
564566
await _runProcessingStreamRequest;
565567
await Stream.RequestStreamComplete();
566568
await _runProcessingStreamResponse; // waiting all ack's commits
567-
569+
568570
_lifecycleReaderSessionCts.Cancel();
569571
}
572+
catch (Exception e)
573+
{
574+
Logger.LogError(e, "ReaderSession[{SessionId}]: error on disposing", SessionId);
575+
}
570576
finally
571577
{
572578
Stream.Dispose();

src/Ydb.Sdk/src/Services/Topic/Writer/Writer.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -596,7 +596,7 @@ protected override MessageFromClient GetSendUpdateTokenRequest(string token)
596596

597597
public override async ValueTask DisposeAsync()
598598
{
599-
Logger.LogInformation("TopicSession[{SessionId}] is being deleted", SessionId);
599+
Logger.LogInformation("WriterSession[{SessionId}]: start dispose process", SessionId);
600600

601601
await Stream.RequestStreamComplete();
602602

0 commit comments

Comments
 (0)