Commit f485609c authored by Levin Zimmermann's avatar Levin Zimmermann

fixup! fixup! X on msgpack support

parent c19abad1
...@@ -269,14 +269,14 @@ func rxHello(errctx string, rx *xbufReader) (enc proto.Encoding, version uint32, ...@@ -269,14 +269,14 @@ func rxHello(errctx string, rx *xbufReader) (enc proto.Encoding, version uint32,
peerEnc = 'N' peerEnc = 'N'
peerVer = uint32(b[3]) peerVer = uint32(b[3])
case bytes.Equal(b, []byte{0x92, 0xc4, 3, 'N'}): // start of "fixarray<2> bin8 'N | EO' ... case bytes.Equal(b, []byte{0x92, 0xa3, 'N', 'E'}): // start of "fixarray<2> bin8 'NE | O' ...
b = append(b, []byte{0,0}...) b = append(b, []byte{0,0}...)
_, err = io.ReadFull(rx, b[4:]) _, err = io.ReadFull(rx, b[4:])
err = xio.NoEOF(err) err = xio.NoEOF(err)
if err != nil { if err != nil {
return 0, 0, err return 0, 0, err
} }
if !bytes.Equal(b[4:], []byte{'E','O'}) { if !bytes.Equal(b[4:], []byte{'O', 0}) {
badMagic = true badMagic = true
break break
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment