1
0
Fork 0

Debug test

master
Philip O'Toole 1 year ago
parent 4bed497072
commit 7c753d42da

@ -2,6 +2,7 @@ package cluster
import ( import (
"encoding/binary" "encoding/binary"
"fmt"
"io" "io"
"net" "net"
"testing" "testing"
@ -53,20 +54,24 @@ func Test_ClientGetNodeAPIAddr(t *testing.T) {
} }
func readCommand(conn net.Conn) *Command { func readCommand(conn net.Conn) *Command {
fmt.Println(">>>>readCommmand called")
b := make([]byte, protoBufferLengthSize) b := make([]byte, protoBufferLengthSize)
_, err := io.ReadFull(conn, b) _, err := io.ReadFull(conn, b)
if err != nil { if err != nil {
fmt.Println(">>>>>> readCommand1: ", err)
return nil return nil
} }
sz := binary.LittleEndian.Uint64(b[0:]) sz := binary.LittleEndian.Uint64(b[0:])
p := make([]byte, sz) p := make([]byte, sz)
_, err = io.ReadFull(conn, p) _, err = io.ReadFull(conn, p)
if err != nil { if err != nil {
fmt.Println(">>>>>> readCommand2: ", err)
return nil return nil
} }
c := &Command{} c := &Command{}
err = proto.Unmarshal(p, c) err = proto.Unmarshal(p, c)
if err != nil { if err != nil {
fmt.Println(">>>>>> readCommand3: ", err)
return nil return nil
} }
return c return c

Loading…
Cancel
Save