aboutsummaryrefslogtreecommitdiff
path: root/src/zenutil/splitconsole
diff options
context:
space:
mode:
authorDan Engelbrecht <[email protected]>2026-04-13 19:17:09 +0200
committerGitHub Enterprise <[email protected]>2026-04-13 19:17:09 +0200
commit3d59b5d7036c35fe484d052ff32dbdc9d0a75cf7 (patch)
tree8d24babc8cd3d097800af0bd960c7ba1d72927d7 /src/zenutil/splitconsole
parentuse mimalloc by default (#952) (diff)
downloadarchived-zen-3d59b5d7036c35fe484d052ff32dbdc9d0a75cf7.tar.xz
archived-zen-3d59b5d7036c35fe484d052ff32dbdc9d0a75cf7.zip
fix utf characters in source code (#953)
Diffstat (limited to 'src/zenutil/splitconsole')
-rw-r--r--src/zenutil/splitconsole/logstreamlistener.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/zenutil/splitconsole/logstreamlistener.cpp b/src/zenutil/splitconsole/logstreamlistener.cpp
index 289bc73a2..df985a196 100644
--- a/src/zenutil/splitconsole/logstreamlistener.cpp
+++ b/src/zenutil/splitconsole/logstreamlistener.cpp
@@ -17,7 +17,7 @@ ZEN_THIRD_PARTY_INCLUDES_END
namespace zen {
//////////////////////////////////////////////////////////////////////////
-// LogStreamSession — reads CbObject-framed messages from a single TCP connection
+// LogStreamSession - reads CbObject-framed messages from a single TCP connection
class LogStreamSession : public RefCounted
{
@@ -34,7 +34,7 @@ private:
[Self](const asio::error_code& Ec, std::size_t BytesRead) {
if (Ec)
{
- return; // connection closed or error — session ends
+ return; // connection closed or error - session ends
}
Self->m_BufferUsed += BytesRead;
Self->ProcessBuffer();
@@ -119,7 +119,7 @@ private:
m_BufferUsed -= Consumed;
}
- // If buffer is full and we can't parse a message, the message is too large — drop connection
+ // If buffer is full and we can't parse a message, the message is too large - drop connection
if (m_BufferUsed == m_ReadBuf.size())
{
ZEN_WARN("LogStreamSession: buffer full with no complete message, dropping connection");
@@ -141,7 +141,7 @@ private:
struct LogStreamListener::Impl
{
- // Owned io_context mode — creates and runs its own thread
+ // Owned io_context mode - creates and runs its own thread
Impl(LogStreamTarget& Target, uint16_t Port)
: m_Target(Target)
, m_OwnedIoContext(std::make_unique<asio::io_context>())
@@ -154,7 +154,7 @@ struct LogStreamListener::Impl
});
}
- // External io_context mode — caller drives the io_context
+ // External io_context mode - caller drives the io_context
Impl(LogStreamTarget& Target, asio::io_context& IoContext, uint16_t Port) : m_Target(Target), m_Acceptor(IoContext)
{
SetupAcceptor(Port);
@@ -367,7 +367,7 @@ TEST_CASE("DroppedMessageDetection")
asio::ip::tcp::socket Socket(IoContext);
Socket.connect(asio::ip::tcp::endpoint(asio::ip::make_address("127.0.0.1"), Listener.GetPort()));
- // Send seq=0, then seq=5 — the listener should detect a gap of 4
+ // Send seq=0, then seq=5 - the listener should detect a gap of 4
for (uint64_t Seq : {uint64_t(0), uint64_t(5)})
{
CbObjectWriter Writer;