diff --git a/cmd/cli.go b/cmd/cli.go index 2885b991..6ff3109a 100644 --- a/cmd/cli.go +++ b/cmd/cli.go @@ -115,13 +115,13 @@ func cmdRollback(c *cli.Context) { //-------------------------------------------------------------------------------- func write(conn net.Conn, req types.Request) (types.Response, error) { - var n int64 + var n int var err error wire.WriteBinary(req, conn, &n, &err) if err != nil { return nil, err } var res types.Response - wire.ReadBinaryPtr(&res, conn, &n, &err) + wire.ReadBinaryPtr(&res, conn, 0, &n, &err) return res, err } diff --git a/example/main_test.go b/example/main_test.go index 0a5b53d6..a5475240 100644 --- a/example/main_test.go +++ b/example/main_test.go @@ -27,10 +27,10 @@ func TestStream(t *testing.T) { // Read response data go func() { for { - var n int64 + var n int var err error var res types.Response - wire.ReadBinaryPtr(&res, conn, &n, &err) + wire.ReadBinaryPtr(&res, conn, 0, &n, &err) if err != nil { Exit(err.Error()) } @@ -40,7 +40,7 @@ func TestStream(t *testing.T) { // Write requests for { - var n int64 + var n int var err error var req types.Request = types.RequestAppendTx{TxBytes: []byte("test")} wire.WriteBinary(req, conn, &n, &err) diff --git a/server/server.go b/server/server.go index 38f25c91..73c27d0e 100644 --- a/server/server.go +++ b/server/server.go @@ -53,10 +53,10 @@ func handleRequests(app types.Application, connClosed chan struct{}, conn net.Co var count int var bufReader = bufio.NewReader(conn) for { - var n int64 + var n int var err error var req types.Request - wire.ReadBinaryPtr(&req, bufReader, &n, &err) + wire.ReadBinaryPtr(&req, bufReader, 0, &n, &err) if err != nil { fmt.Println("Error in handleRequests:", err.Error()) connClosed <- struct{}{} @@ -119,7 +119,7 @@ func handleResponses(connClosed chan struct{}, responses <-chan types.Response, var bufWriter = bufio.NewWriter(conn) for { var res = <-responses - var n int64 + var n int var err error wire.WriteBinary(res, bufWriter, &n, &err) if err != nil {