diff options
author | gluk47 <gluk47@yandex-team.com> | 2023-06-26 23:42:46 +0300 |
---|---|---|
committer | gluk47 <gluk47@yandex-team.com> | 2023-06-26 23:42:46 +0300 |
commit | 268c3f3234d59de05f78c688e44373df8de99c6a (patch) | |
tree | b215f2cfc1e8c9cdfb37b766328caf736e0771c8 /library/cpp/unified_agent_client/client_impl.cpp | |
parent | 8717374e6aa88bca6d801486f4bc1fe6efdee5c4 (diff) | |
download | ydb-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.cpp | 26 |
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; |