p2p: remove unused code (#20325)
This commit is contained in:
parent
ac5e28ea38
commit
9e8cc00b73
10
p2p/rlpx.go
10
p2p/rlpx.go
@ -422,16 +422,6 @@ func (h *encHandshake) makeAuthResp() (msg *authRespV4, err error) {
|
|||||||
return msg, nil
|
return msg, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (msg *authMsgV4) sealPlain(h *encHandshake) ([]byte, error) {
|
|
||||||
buf := make([]byte, authMsgLen)
|
|
||||||
n := copy(buf, msg.Signature[:])
|
|
||||||
n += copy(buf[n:], crypto.Keccak256(exportPubkey(&h.randomPrivKey.PublicKey)))
|
|
||||||
n += copy(buf[n:], msg.InitiatorPubkey[:])
|
|
||||||
n += copy(buf[n:], msg.Nonce[:])
|
|
||||||
buf[n] = 0 // token-flag
|
|
||||||
return ecies.Encrypt(rand.Reader, h.remote, buf, nil, nil)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (msg *authMsgV4) decodePlain(input []byte) {
|
func (msg *authMsgV4) decodePlain(input []byte) {
|
||||||
n := copy(msg.Signature[:], input)
|
n := copy(msg.Signature[:], input)
|
||||||
n += shaLen // skip sha3(initiator-ephemeral-pubk)
|
n += shaLen // skip sha3(initiator-ephemeral-pubk)
|
||||||
|
@ -199,7 +199,6 @@ type Server struct {
|
|||||||
checkpointAddPeer chan *conn
|
checkpointAddPeer chan *conn
|
||||||
|
|
||||||
// State of run loop and listenLoop.
|
// State of run loop and listenLoop.
|
||||||
lastLookup time.Time
|
|
||||||
inboundHistory expHeap
|
inboundHistory expHeap
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -410,7 +409,7 @@ type sharedUDPConn struct {
|
|||||||
func (s *sharedUDPConn) ReadFromUDP(b []byte) (n int, addr *net.UDPAddr, err error) {
|
func (s *sharedUDPConn) ReadFromUDP(b []byte) (n int, addr *net.UDPAddr, err error) {
|
||||||
packet, ok := <-s.unhandled
|
packet, ok := <-s.unhandled
|
||||||
if !ok {
|
if !ok {
|
||||||
return 0, nil, errors.New("Connection was closed")
|
return 0, nil, errors.New("connection was closed")
|
||||||
}
|
}
|
||||||
l := len(packet.Data)
|
l := len(packet.Data)
|
||||||
if l > len(b) {
|
if l > len(b) {
|
||||||
|
11
p2p/util.go
11
p2p/util.go
@ -40,17 +40,6 @@ func (h *expHeap) add(item string, exp time.Time) {
|
|||||||
heap.Push(h, expItem{item, exp})
|
heap.Push(h, expItem{item, exp})
|
||||||
}
|
}
|
||||||
|
|
||||||
// remove removes an item.
|
|
||||||
func (h *expHeap) remove(item string) bool {
|
|
||||||
for i, v := range *h {
|
|
||||||
if v.item == item {
|
|
||||||
heap.Remove(h, i)
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
// contains checks whether an item is present.
|
// contains checks whether an item is present.
|
||||||
func (h expHeap) contains(item string) bool {
|
func (h expHeap) contains(item string) bool {
|
||||||
for _, v := range h {
|
for _, v := range h {
|
||||||
|
Loading…
Reference in New Issue
Block a user