aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/unified_agent_client/client_impl.cpp
diff options
context:
space:
mode:
authorgluk47 <gluk47@yandex-team.com>2023-06-26 23:42:46 +0300
committergluk47 <gluk47@yandex-team.com>2023-06-26 23:42:46 +0300
commit268c3f3234d59de05f78c688e44373df8de99c6a (patch)
treeb215f2cfc1e8c9cdfb37b766328caf736e0771c8 /library/cpp/unified_agent_client/client_impl.cpp
parent8717374e6aa88bca6d801486f4bc1fe6efdee5c4 (diff)
downloadydb-268c3f3234d59de05f78c688e44373df8de99c6a.tar.gz
[unified agent] fix printf specifiers for 32 bit arch /
Diffstat (limited to 'library/cpp/unified_agent_client/client_impl.cpp')
-rw-r--r--library/cpp/unified_agent_client/client_impl.cpp26
1 files changed, 13 insertions, 13 deletions
diff --git a/library/cpp/unified_agent_client/client_impl.cpp b/library/cpp/unified_agent_client/client_impl.cpp
index ec003df948..f702cd4930 100644
--- a/library/cpp/unified_agent_client/client_impl.cpp
+++ b/library/cpp/unified_agent_client/client_impl.cpp
@@ -44,7 +44,7 @@ namespace NUnifiedAgent::NPrivate {
, Counters(parameters.Counters ? parameters.Counters : MakeIntrusive<TClientCounters>())
, Log(parameters.Log)
, MainLogger(Log, MakeFMaybe(Parameters.LogRateLimitBytes))
- , Logger(MainLogger.Child(Sprintf("ua_%lu", Id.fetch_add(1))))
+ , Logger(MainLogger.Child(Sprintf("ua_%" PRIu64, Id.fetch_add(1))))
, Channel(nullptr)
, Stub(nullptr)
, ActiveCompletionQueue(nullptr)
@@ -489,11 +489,11 @@ namespace NUnifiedAgent::NPrivate {
}
void TClientSession::Send(TClientMessage&& message) {
- const auto messageSize = SizeOf(message);
+ const size_t messageSize = SizeOf(message);
++Counters->ReceivedMessages;
Counters->ReceivedBytes += messageSize;
if (messageSize > Client->GetParameters().GrpcMaxMessageSize) {
- YLOG_ERR(Sprintf("message size [%lu] is greater than max grpc message size [%lu], message dropped",
+ YLOG_ERR(Sprintf("message size [%zu] is greater than max grpc message size [%zu], message dropped",
messageSize, Client->GetParameters().GrpcMaxMessageSize));
++Counters->DroppedMessages;
Counters->DroppedBytes += messageSize;
@@ -521,7 +521,7 @@ namespace NUnifiedAgent::NPrivate {
if (CloseRequested) {
g.Release();
- YLOG_ERR(Sprintf("session is closing, message dropped, [%lu] bytes", messageSize));
+ YLOG_ERR(Sprintf("session is closing, message dropped, [%zu] bytes", messageSize));
--Counters->InflightMessages;
Counters->InflightBytes -= messageSize;
++Counters->DroppedMessages;
@@ -531,7 +531,7 @@ namespace NUnifiedAgent::NPrivate {
}
if (InflightBytes.load() + messageSize > MaxInflightBytes) {
g.Release();
- YLOG_ERR(Sprintf("max inflight of [%lu] bytes reached, [%lu] bytes dropped",
+ YLOG_ERR(Sprintf("max inflight of [%zu] bytes reached, [%zu] bytes dropped",
MaxInflightBytes, messageSize));
--Counters->InflightMessages;
Counters->InflightBytes -= messageSize;
@@ -803,9 +803,9 @@ namespace NUnifiedAgent::NPrivate {
}
const auto addResult = requestBuilder.TryAddMessage(queueItem, *AckSeqNo + i + 1);
- const auto serializedLimitToLog = AgentMaxReceiveMessage.Defined() ? *AgentMaxReceiveMessage : 0;
+ const size_t serializedLimitToLog = AgentMaxReceiveMessage.Defined() ? *AgentMaxReceiveMessage : 0;
if (addResult.LimitExceeded && target.GetDataBatch().SeqNoSize() == 0) {
- YLOG_ERR(Sprintf("single serialized message is too large [%lu] > [%lu], dropping it",
+ YLOG_ERR(Sprintf("single serialized message is too large [%zu] > [%zu], dropping it",
addResult.NewSerializedRequestSize, serializedLimitToLog));
queueItem.Skipped = true;
++Counters->DroppedMessages;
@@ -817,8 +817,8 @@ namespace NUnifiedAgent::NPrivate {
}
if (addResult.LimitExceeded) {
YLOG_DEBUG(Sprintf(
- "batch limit exceeded: [%lu] > [%lu] (limit for serialized batch)"
- "OR [%lu] > [%lu] (limit for raw batch)",
+ "batch limit exceeded: [%zu] > [%zu] (limit for serialized batch)"
+ "OR [%zu] > [%zu] (limit for raw batch)",
addResult.NewSerializedRequestSize, serializedLimitToLog,
addResult.NewRequestPayloadSize, Client->GetParameters().GrpcMaxMessageSize));
break;
@@ -834,7 +834,7 @@ namespace NUnifiedAgent::NPrivate {
"failed to calculate size for message [%s]", target.ShortDebugString().c_str());
GrpcInflightMessages += messagesCount;
GrpcInflightBytes += requestBuilder.GetRequestPayloadSize();
- YLOG_DEBUG(Sprintf("new write batch, [%lu] messages, [%lu] bytes, first seq_no [%lu], serialized size [%lu]",
+ YLOG_DEBUG(Sprintf("new write batch, [%zu] messages, [%zu] bytes, first seq_no [%" PRIu64 "], serialized size [%zu]",
messagesCount, requestBuilder.GetRequestPayloadSize(),
*target.GetDataBatch().GetSeqNo().begin(), requestBuilder.GetSerializedRequestSize()));
++Counters->GrpcWriteBatchRequests;
@@ -876,7 +876,7 @@ namespace NUnifiedAgent::NPrivate {
GrpcInflightMessages -= messagesCount;
GrpcInflightBytes -= bytesCount;
- YLOG_DEBUG(Sprintf("ack [%lu], [%lu] messages, [%lu] bytes", seqNo, messagesCount, bytesCount));
+ YLOG_DEBUG(Sprintf("ack [%" PRIu64 "], [%zu] messages, [%zu] bytes", seqNo, messagesCount, bytesCount));
}
void TClientSession::OnGrpcCallInitialized(const TString& sessionId, ui64 lastSeqNo) {
@@ -888,7 +888,7 @@ namespace NUnifiedAgent::NPrivate {
Counters->GrpcInflightBytes -= GrpcInflightBytes;
GrpcInflightMessages = 0;
GrpcInflightBytes = 0;
- YLOG_INFO(Sprintf("grpc call initialized, session_id [%s], last_seq_no [%lu]",
+ YLOG_INFO(Sprintf("grpc call initialized, session_id [%s], last_seq_no [%" PRIu64 "]",
sessionId.c_str(), lastSeqNo));
}
@@ -937,7 +937,7 @@ namespace NUnifiedAgent::NPrivate {
if (!ForkInProgressLocal && WriteQueue.size() > 0) {
const auto stats = PurgeWriteQueue();
++Counters->ErrorsCount;
- YLOG_ERR(Sprintf("DoClose, dropped [%lu] messages, [%lu] bytes",
+ YLOG_ERR(Sprintf("DoClose, dropped [%zu] messages, [%zu] bytes",
stats.PurgedMessages, stats.PurgedBytes));
}
--Client->GetCounters()->ActiveSessionsCount;