Skip to content

bug: Unhandled exception. System.Net.Http.HttpIOException #452

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 4 commits into from
Jun 11, 2025
Merged

bug: Unhandled exception. System.Net.Http.HttpIOException #452

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
4f69883
bug: Unhandled exception. System.Net.Http.HttpIOException
KirillKurdyukov Jun 11, 2025
bde7227
fix log message
KirillKurdyukov Jun 11, 2025
3283c68
delete continue on error
KirillKurdyukov Jun 11, 2025
ff0820a
update CHANGELOG.md
KirillKurdyukov Jun 11, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 5 additions & 5 deletions src/Ydb.Sdk/src/Services/Topic/Reader/Reader.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -198,9 +198,9 @@ await stream.AuthToken(),
_deserializer
);
}
catch (Driver.TransportException e)
catch (Exception e)
{
_logger.LogError(e, "Transport error on executing ReaderSession");
_logger.LogError(e, "Error on executing ReaderSession");

_ = Task.Run(Initialize, _disposeCts.Token);
}
Expand Down Expand Up @@ -338,9 +338,9 @@ private async Task RunProcessingStreamResponse()

Logger.LogInformation("ReaderSession[{SessionId}]: ResponseStream is closed", SessionId);
}
catch (Driver.TransportException e)
catch (Exception e)
{
Logger.LogError(e, "ReaderSession[{SessionId}] have transport error on processing server messages",
Logger.LogError(e, "ReaderSession[{SessionId}] have error on processing server messages",
SessionId);
}
finally
Expand All @@ -360,7 +360,7 @@ private async Task RunProcessingStreamRequest()
await SendMessage(messageFromClient);
}
}
catch (Driver.TransportException e)
catch (Exception e)
{
Logger.LogError(e, "ReaderSession[{SessionId}] have transport error on Write", SessionId);

Expand Down
16 changes: 8 additions & 8 deletions src/Ydb.Sdk/src/Services/Topic/Writer/Writer.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -314,16 +314,16 @@ await stream.AuthToken(),
_sendInFlightMessagesSemaphoreSlim.Release();
}
}
catch (Driver.TransportException e)
{
_logger.LogError(e, "Transport error on creating WriterSession");

_ = Task.Run(Initialize);
}
catch (OperationCanceledException)
{
_logger.LogInformation("Initialize writer is canceled because it has been disposed");
}
catch (Exception e)
{
_logger.LogError(e, "Error on creating WriterSession");

_ = Task.Run(Initialize);
}
}

public async ValueTask DisposeAsync()
Expand Down Expand Up @@ -493,7 +493,7 @@ public async Task Write(ConcurrentQueue<MessageSending> toSendBuffer)
Volatile.Write(ref _seqNum, currentSeqNum);
await SendMessage(new MessageFromClient { WriteRequest = writeMessage });
}
catch (Driver.TransportException e)
catch (Exception e)
{
Logger.LogError(e, "WriterSession[{SessionId}] have transport error on Write, last SeqNo={SeqNo}",
SessionId, Volatile.Read(ref _seqNum));
Expand Down Expand Up @@ -564,7 +564,7 @@ Completing task on exception...

Logger.LogInformation("WriterSession[{SessionId}]: ResponseStream is closed", SessionId);
}
catch (Driver.TransportException e)
catch (Exception e)
{
Logger.LogError(e, "WriterSession[{SessionId}] have error on processing writeAck", SessionId);
}
Expand Down
Loading