1

a8/orderbuffer.cc

@@ -23,7 +23,10 @@ namespace a8
 
     char* OrderBuffer::Alloc(int len)
     {
-
+        if (len <= 0) {
+            abort();
+        }
+        int real_len = len + 4;
     }
 
     void OrderBuffer::Free(char* p)

a8/orderbuffer.h

@@ -1,5 +1,7 @@
 #pragma once
 
+#include <atomic>
+
 namespace a8
 {
 
@@ -14,8 +16,12 @@ namespace a8
         void Free(char* p);
 
     private:
+
         char* buf_ = nullptr;
         int buf_len_ = 0;
+        std::atomic<int> start_ = 0;
+        std::atomic<int> end_ = 0;
+
     };
 
 }