use memcpy to copy the framebuffer

Author: JasperGeurtz

src/main/java/bwapi/FrameBuffer.java

@@ -25,6 +25,7 @@ of this software and associated documentation files (the "Software"), to deal
 
 package bwapi;
 
+import sun.nio.ch.DirectBuffer;
 import java.nio.ByteBuffer;
 import java.util.ArrayList;
 import java.util.concurrent.locks.Condition;
@@ -35,6 +36,7 @@ of this software and associated documentation files (the "Software"), to deal
  * Circular buffer of game states.
  */
 class FrameBuffer {
+    private static final int BUFFER_SIZE = ClientData.GameData.SIZE;
 
     private ByteBuffer dataSource;
     private PerformanceMetrics performanceMetrics;
@@ -51,7 +53,7 @@ class FrameBuffer {
     FrameBuffer(int size) {
         this.size = size;
         while(dataBuffer.size() < size) {
-            dataBuffer.add(ByteBuffer.allocateDirect(ClientData.GameData.SIZE));
+            dataBuffer.add(ByteBuffer.allocateDirect(BUFFER_SIZE));
         }
     }
 
@@ -122,9 +124,7 @@ void enqueueFrame() {
 
             performanceMetrics.copyingToBuffer.time(() -> {
                 ByteBuffer dataTarget = dataBuffer.get(indexGame());
-                dataSource.rewind();
-                dataTarget.rewind();
-                dataTarget.put(dataSource);
+                copyBuffer(dataSource, dataTarget, BUFFER_SIZE);
             });
 
             lockSize.lock();
@@ -135,6 +135,17 @@ void enqueueFrame() {
         } finally { lockWrite.unlock(); }
     }
 
+    private void copyBufferOld(ByteBuffer source, ByteBuffer dest, int size) {
+        source.rewind();
+        dest.rewind();
+        dest.put(dataSource);
+    }
+    private void copyBuffer(ByteBuffer source, ByteBuffer dest, int size) {
+        long destAddr = ((DirectBuffer)dest).address();
+        long sourceAddr = ((DirectBuffer)source).address();
+        MSVCRT.INSTANCE.memcpy(destAddr, sourceAddr, size);
+    }
+
     /**
      * Peeks the front-most value in the buffer.
      */

src/main/java/bwapi/MSVCRT.java

@@ -0,0 +1,10 @@
+package bwapi;
+
+import com.sun.jna.Library;
+import com.sun.jna.Native;
+
+interface MSVCRT extends Library {
+    MSVCRT INSTANCE = Native.load("msvcrt.dll", MSVCRT.class);
+
+    long memcpy(long dest, long src, int count);
+}

src/test/java/bwapi/SynchronizationTest.java

@@ -0,0 +1,53 @@
+package bwapi;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.Assert.assertNull;
+import static org.mockito.BDDMockito.given;
+import static org.mockito.Mockito.mock;
+
+import java.io.IOException;
+import java.nio.ByteBuffer;
+import java.util.ArrayList;
+import java.util.List;
+
+import net.bytebuddy.implementation.bytecode.Addition;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.experimental.theories.DataPoints;
+import org.junit.experimental.theories.FromDataPoints;
+import org.junit.experimental.theories.Theories;
+import org.junit.experimental.theories.Theory;
+import org.junit.runner.RunWith;
+import org.mockito.AdditionalAnswers;
+import org.mockito.Mock;
+import org.mockito.Mockito;
+
+public class SynchronizationTest {
+
+    class Environment {
+        BWClientConfiguration configuration = new BWClientConfiguration();
+        BWEventListener listener = mock(BWEventListener.class);
+        Client client = mock(Client.class);
+
+        Game game;
+        public Environment() {
+            try {
+                game = GameBuilder.createGame();
+            } catch (IOException exception) {
+                throw new RuntimeException(exception);
+            }
+            Mockito.doAnswer(answer -> { stepFrame(); return null; }).when(client).update();
+        }
+
+        public void stepFrame() {
+            game.clientData().gameData().setFrameCount(game.clientData().gameData().getFrameCount() + 1);
+        }
+    }
+
+    @Test
+    public void synchronizedRuns() {
+        Environment environment = new Environment();
+        environment.configuration.async = false;
+    }
+
+}