remove snappy & flatbuffer source code , modf dub.json : "dlang-snapp…

…y": "~>0.0.1", "flatbuffers": "~>0.1.1", "kiss" : "~>0.0.7",

dub.json

@@ -7,12 +7,10 @@
  ],
 
  "dependencies": {
- "kiss":{
-  "path" :"../kiss/"
- }
+ "dlang-snappy": "~>0.0.1",
+ "flatbuffers": "~>0.1.1",
+ "kiss" : "~>0.0.7",
  },
 
- "license": "Apache-2.0",
- "lflags":["-L/usr/local/lib"],
- "libs":["snappy"]
+ "license": "Apache-2.0"
 }

source/KissRpc/RpcBinaryPackage.d

@@ -4,7 +4,7 @@ import KissRpc.Endian;
 import KissRpc.Unit;
 import KissRpc.Logs;
 
-import util.snappy;
+import snappy.snappy;
 import std.stdio;
 
 enum RPC_PACKAGE_STATUS_CODE

source/KissRpc/RpcClientSocket.d

@@ -36,20 +36,21 @@ public:
  return true;
  }
  override void onConnectCompleted(void* attachment) {
- _socketEventDelegate.socketEvent(this, SOCKET_STATUS.SE_CONNECTD, "connect to server is ok!");
  doRead();
+ _socketEventDelegate.socketEvent(this, SOCKET_STATUS.SE_CONNECTD, "connect to server is ok!");
  }
  override void onConnectFailed(void* attachment) {
  writeln("onConnectFailed");
  }
  override void onWriteCompleted(void* attachment, size_t count , ByteBuffer buffer) {
- // writeln("write success index ",index++);
+ // writeln("write success index ",index);
  }
  override void onWriteFailed(void* attachment) {
- // writeln("onWriteFailed");
+ writeln("onWriteFailed");
  _socketEventDelegate.socketEvent(this, SOCKET_STATUS.SE_WRITE_FAILED, "write data to server is failed");
  }
  override void onReadCompleted(void* attachment, size_t count , ByteBuffer buffer) {
+
  _packageManage.add(cast(ubyte[])(buffer.getCurBuffer()));
  _readBuffer.clear();
  }