add serial code

connection.cc

@@ -8,7 +8,7 @@ Connection::Connection(int fd_) : fd(fd_) {
 	out = new BipBuffer(BUFFER_SIZE);
 }
 
-void Connection::handle(RingBuffer<Order> *ring) {
+void Connection::handle(RingBuffer<Order> *ring, Train *train) {
 	char *index_in, *index_out;
 	int n;
 	Order *order;
@@ -48,13 +48,34 @@ void Connection::handle(RingBuffer<Order> *ring) {
 			}
 			order->connection = this;
 			/* // test-start */
-			/* index_out = out->reserve(end - start + 1); */
+			/* switch (order->operation) { */
+			/* case 0x01: */
+			/* 	train->query(order); */
+			/* 	break; */
+			/* case 0x02: */
+			/* 	train->book(order); */
+			/* 	break; */
+			/* case 0x03: */
+			/* 	train->check(order); */
+			/* 	break; */
+			/* case 0x04: */
+			/* 	train->refund(order); */
+			/* 	break; */
+			/* default: */
+			/* 	cout << "unknown operation " << hex << order->operation << endl; */
+			/* 	exit(1); */
+			/* } */
+			/* if (order->dump() == -1) { */
+			/* 	cout << "order dump fail" << endl; */
+			/* 	exit(1); */
+			/* } */
+			/* index_out = out->reserve(order->rsize); */
 			/* if (index_out == nullptr) { */
 			/* 	perror("in reserve error"); */
 			/* 	exit(1); */
 			/* } */
-			/* memcpy(index_out, index_in + start, end - start + 1); */
-			/* out->commit(end - start + 1); */
+			/* memcpy(index_out, order->raw, order->rsize); */
+			/* out->commit(order->rsize); */
 			/* // test-end */
 			in->release(end);
 			count++;

connection.h

@@ -10,14 +10,15 @@
 #include "bipbuffer.h"
 #include "ringbuffer.h"
 #include "order.h"
+#include "train.h"
 
 using namespace std;
 
 class Connection {
 public:
 	Connection(int fd);
 	BipBuffer *in, *out;
-	void handle(RingBuffer<Order> *ring);
+	void handle(RingBuffer<Order> *ring, Train *train);
 	void flush();
 	void close_connection();
 private:

server.cc

@@ -102,7 +102,7 @@ void Server::receive_data(int fd) {
 		exit(1);
 	}
 	Connection *connection = pair->second;
-	connection->handle(ring);
+	connection->handle(ring, train);
 }
 
 void Server::handle_orders() {