Update transport

fixed writeValue fixed writeUnique
VKCOM · Jul 13, 2024 · 33e4705 · 33e4705
1 parent 956322f
commit 33e4705
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/vk/statshouse/Transport.java b/src/main/java/com/vk/statshouse/Transport.java
@@ -104,7 +104,7 @@ synchronized void writeCount(boolean hasEnv, String name, String[] tagsNames, St
     synchronized void writeValue(boolean hasEnv, String name, String[] tagsNames, String[] tags, double[] values, long ts) throws IOException {
         int fieldMask = VALUE_FIELDS_MASK | NEW_SEMANTIC_FIELDS_MASK;
         var now = Instant.now();
-        for (int i = 0; i < values.length; i++) {
+        for (int i = 0; i < values.length;) {
             var needWriteCount = values.length - i;
             var spaceLeft = writeHeader(fieldMask, hasEnv, name, tagsNames, tags, 0, ts, TL_INT_32_SIZE + TL_FLOAT_64_SIZE);
             if (spaceLeft < 0) {
@@ -125,7 +125,7 @@ synchronized void writeValue(boolean hasEnv, String name, String[] tagsNames, St
     synchronized void writeUnique(boolean hasEnv, String name, String[] tagsNames, String[] tags, long[] values, long ts) throws IOException {
         var fieldMask =  UNIQUE_FIELDS_MASK | NEW_SEMANTIC_FIELDS_MASK;
         var now = Instant.now();
-        for (int i = 0; i < values.length; i++) {
+        for (int i = 0; i < values.length;) {
             var needWriteCount = values.length - i;
             var spaceLeft = writeHeader(fieldMask, hasEnv, name, tagsNames, tags, 0, ts, TL_INT_32_SIZE + TL_INT_64_SIZE);
             if (spaceLeft < 0) {