mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-20 10:52:25 +00:00
Update rlpx.go
remove useless parameter
This commit is contained in:
parent
98e0bedcd7
commit
2a7e5ddc18
1 changed files with 2 additions and 2 deletions
|
|
@ -128,7 +128,7 @@ func (t *rlpx) doProtoHandshake(our *protoHandshake) (their *protoHandshake, err
|
||||||
// as the error so it can be tracked elsewhere.
|
// as the error so it can be tracked elsewhere.
|
||||||
werr := make(chan error, 1)
|
werr := make(chan error, 1)
|
||||||
go func() { werr <- Send(t.rw, handshakeMsg, our) }()
|
go func() { werr <- Send(t.rw, handshakeMsg, our) }()
|
||||||
if their, err = readProtocolHandshake(t.rw, our); err != nil {
|
if their, err = readProtocolHandshake(t.rw); err != nil {
|
||||||
<-werr // make sure the write terminates too
|
<-werr // make sure the write terminates too
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
@ -141,7 +141,7 @@ func (t *rlpx) doProtoHandshake(our *protoHandshake) (their *protoHandshake, err
|
||||||
return their, nil
|
return their, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func readProtocolHandshake(rw MsgReader, our *protoHandshake) (*protoHandshake, error) {
|
func readProtocolHandshake(rw MsgReader) (*protoHandshake, error) {
|
||||||
msg, err := rw.ReadMsg()
|
msg, err := rw.ReadMsg()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue