libp2p/go-libp2p-core
1
0
Fork 0
mirror of https://github.com/libp2p/go-libp2p-core.git synced 2024-12-26 23:30:27 +08:00
Code Issues Projects Releases Wiki Activity

lower size limit, fix comment

Browse Source
This commit is contained in:
Yusef Napora 2019-11-12 11:44:36 -05:00
parent e664a6aa14
commit f8cfbaa574
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
sec/insecure/insecure.go
View File

@ -183,7 +183,7 @@ func (ic *Conn) runHandshakeSync() error {
// read and write a message at the same time.
func readWriteMsg(rw io.ReadWriter, out *pb.Exchange) (*pb.Exchange, error) {
const maxMsgSize = 1 << 32
const maxMsgSize = 1 << 16
r := gogoio.NewDelimitedReader(rw, maxMsgSize)
w := gogoio.NewDelimitedWriter(rw)
wresult := make(chan error)
@ -194,7 +194,7 @@ func readWriteMsg(rw io.ReadWriter, out *pb.Exchange) (*pb.Exchange, error) {
inMsg := pb.Exchange{}
err := r.ReadMsg(&inMsg)
// Always wait for the read to finish.
// Always wait for the write to finish.
err2 := <-wresult
if err != nil {