From 6eee7a1c831786483f2b157309d56773523e2a3c Mon Sep 17 00:00:00 2001 From: Yakov Olkhovskiy Date: Tue, 1 Oct 2024 02:48:50 +0000 Subject: [PATCH] increment profile event in WriteBufferFromPocoSocket::nextImpl() --- src/IO/WriteBufferFromPocoSocket.cpp | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/IO/WriteBufferFromPocoSocket.cpp b/src/IO/WriteBufferFromPocoSocket.cpp index ffb38a384a06..2bc07c5f104f 100644 --- a/src/IO/WriteBufferFromPocoSocket.cpp +++ b/src/IO/WriteBufferFromPocoSocket.cpp @@ -136,6 +136,8 @@ void WriteBufferFromPocoSocket::nextImpl() SCOPE_EXIT({ ProfileEvents::increment(ProfileEvents::NetworkSendElapsedMicroseconds, watch.elapsedMicroseconds()); ProfileEvents::increment(ProfileEvents::NetworkSendBytes, bytes_written); + if (write_event != ProfileEvents::end()) + ProfileEvents::increment(write_event, bytes_written); }); while (bytes_written < offset())