fix ringbuffer expand() code

vespa-engine · Sep 26, 2024 · 00eeec2 · 00eeec2
1 parent dda7caa
commit 00eeec2
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 5 deletions.
diff --git a/vespa-feed-client-api/src/main/java/ai/vespa/feed/client/JsonFeeder.java b/vespa-feed-client-api/src/main/java/ai/vespa/feed/client/JsonFeeder.java
@@ -302,9 +302,11 @@ private void expand() {
             int offset = (int) (tail % size);
             int newOffset = (int) (tail % newSize);
             int toWrite = size - offset;
+            // exactly doubling the buffer size ensures there is room in the new buffer
             System.arraycopy(data, offset, newData, newOffset, toWrite);
-            if (toWrite < size)
-                System.arraycopy(data, 0, newData, newOffset + toWrite, size - toWrite);
+            // the wrapped data ends up either after the first part, or at the start of the new buffer
+            newOffset = (newOffset + toWrite) % newSize;
+            System.arraycopy(data, 0, newData, newOffset, offset);
             size = newSize;
             data = newData;
             lock.notify();

diff --git a/vespa-feed-client-api/src/test/java/ai/vespa/feed/client/JsonFeederTest.java b/vespa-feed-client-api/src/test/java/ai/vespa/feed/client/JsonFeederTest.java
@@ -34,16 +34,25 @@
 
 class JsonFeederTest {
 
+    static String lulVal(int i) {
+        var buf = new StringBuilder();
+        while (i-- > 0) {
+            buf.append("lal");
+            i = (int) (i/1.005);
+        }
+        return buf.toString();
+    }
+
     @Test
     void test() throws IOException {
-        int docs = 1 << 14;
+        int docs = 1 << 12;
         String json = "[\n" +
 
                       IntStream.range(0, docs).mapToObj(i ->
                                                                 "  {\n" +
                                                                 "    \"id\": \"id:ns:type::abc" + i + "\",\n" +
                                                                 "    \"fields\": {\n" +
-                                                                "      \"lul\":\"lal\"\n" +
+                                                                "      \"lul\":\"" + lulVal(i) + "\"\n" +
                                                                 "    }\n" +
                                                                 "  },\n"
                       ).collect(joining()) +
@@ -64,7 +73,7 @@ void test() throws IOException {
             long startNanos = System.nanoTime();
             MockClient feedClient = new MockClient();
             JsonFeeder.builder(feedClient).build()
-                    .feedMany(in, 1 << 10,
+                    .feedMany(in, 1 << 7,
                             new JsonFeeder.ResultCallback() {
                                 @Override
                                 public void onNextResult(Result result, FeedException error) { resultsReceived.incrementAndGet(); }