peer+server: log pubkey@addr
This commit is contained in:
parent
60467bef7b
commit
7358535725
2
peer.go
2
peer.go
@ -638,7 +638,7 @@ func (p *peer) Disconnect(reason error) {
|
|||||||
|
|
||||||
// String returns the string representation of this peer.
|
// String returns the string representation of this peer.
|
||||||
func (p *peer) String() string {
|
func (p *peer) String() string {
|
||||||
return p.conn.RemoteAddr().String()
|
return fmt.Sprintf("%x@%s", p.pubKeyBytes, p.conn.RemoteAddr())
|
||||||
}
|
}
|
||||||
|
|
||||||
// readNextMessage reads, and returns the next message on the wire along with
|
// readNextMessage reads, and returns the next message on the wire along with
|
||||||
|
27
server.go
27
server.go
@ -2161,9 +2161,9 @@ func (s *server) InboundPeerConnected(conn net.Conn) {
|
|||||||
// the new connection s.t there's only a single connection between us.
|
// the new connection s.t there's only a single connection between us.
|
||||||
localPub := s.identityPriv.PubKey()
|
localPub := s.identityPriv.PubKey()
|
||||||
if !connectedPeer.inbound && !shouldDropLocalConnection(localPub, nodePub) {
|
if !connectedPeer.inbound && !shouldDropLocalConnection(localPub, nodePub) {
|
||||||
srvrLog.Warnf("Received inbound connection from peer %x, "+
|
srvrLog.Warnf("Received inbound connection from peer %v, "+
|
||||||
"but already have outbound connection, dropping conn",
|
"but already have outbound connection, dropping conn",
|
||||||
nodePub.SerializeCompressed())
|
connectedPeer)
|
||||||
conn.Close()
|
conn.Close()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@ -2236,7 +2236,8 @@ func (s *server) OutboundPeerConnected(connReq *connmgr.ConnReq, conn net.Conn)
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
srvrLog.Infof("Established connection to: %v", conn.RemoteAddr())
|
srvrLog.Infof("Established connection to: %x@%v", pubStr,
|
||||||
|
conn.RemoteAddr())
|
||||||
|
|
||||||
if connReq != nil {
|
if connReq != nil {
|
||||||
// A successful connection was returned by the connmgr.
|
// A successful connection was returned by the connmgr.
|
||||||
@ -2268,9 +2269,9 @@ func (s *server) OutboundPeerConnected(connReq *connmgr.ConnReq, conn net.Conn)
|
|||||||
// the new connection s.t there's only a single connection between us.
|
// the new connection s.t there's only a single connection between us.
|
||||||
localPub := s.identityPriv.PubKey()
|
localPub := s.identityPriv.PubKey()
|
||||||
if connectedPeer.inbound && shouldDropLocalConnection(localPub, nodePub) {
|
if connectedPeer.inbound && shouldDropLocalConnection(localPub, nodePub) {
|
||||||
srvrLog.Warnf("Established outbound connection to peer %x, "+
|
srvrLog.Warnf("Established outbound connection to peer %v, "+
|
||||||
"but already have inbound connection, dropping conn",
|
"but already have inbound connection, dropping conn",
|
||||||
nodePub.SerializeCompressed())
|
connectedPeer)
|
||||||
if connReq != nil {
|
if connReq != nil {
|
||||||
s.connMgr.Remove(connReq.ID())
|
s.connMgr.Remove(connReq.ID())
|
||||||
}
|
}
|
||||||
@ -2355,8 +2356,8 @@ func (s *server) peerConnected(conn net.Conn, connReq *connmgr.ConnReq,
|
|||||||
addr := conn.RemoteAddr()
|
addr := conn.RemoteAddr()
|
||||||
pubKey := brontideConn.RemotePub()
|
pubKey := brontideConn.RemotePub()
|
||||||
|
|
||||||
srvrLog.Infof("Finalizing connection to %x, inbound=%v",
|
srvrLog.Infof("Finalizing connection to %x@%s, inbound=%v",
|
||||||
pubKey.SerializeCompressed(), inbound)
|
pubKey.SerializeCompressed(), addr, inbound)
|
||||||
|
|
||||||
peerAddr := &lnwire.NetAddress{
|
peerAddr := &lnwire.NetAddress{
|
||||||
IdentityKey: pubKey,
|
IdentityKey: pubKey,
|
||||||
@ -2473,7 +2474,7 @@ func (s *server) peerInitializer(p *peer) {
|
|||||||
defer s.mu.Unlock()
|
defer s.mu.Unlock()
|
||||||
|
|
||||||
// Check if there are listeners waiting for this peer to come online.
|
// Check if there are listeners waiting for this peer to come online.
|
||||||
srvrLog.Debugf("Notifying that peer %x is online", p.PubKey())
|
srvrLog.Debugf("Notifying that peer %v is online", p)
|
||||||
for _, peerChan := range s.peerConnectedListeners[pubStr] {
|
for _, peerChan := range s.peerConnectedListeners[pubStr] {
|
||||||
select {
|
select {
|
||||||
case peerChan <- p:
|
case peerChan <- p:
|
||||||
@ -2527,8 +2528,7 @@ func (s *server) peerTerminationWatcher(p *peer, ready chan struct{}) {
|
|||||||
// TODO(roasbeef): instead add a PurgeInterfaceLinks function?
|
// TODO(roasbeef): instead add a PurgeInterfaceLinks function?
|
||||||
links, err := p.server.htlcSwitch.GetLinksByInterface(p.pubKeyBytes)
|
links, err := p.server.htlcSwitch.GetLinksByInterface(p.pubKeyBytes)
|
||||||
if err != nil && err != htlcswitch.ErrNoLinksFound {
|
if err != nil && err != htlcswitch.ErrNoLinksFound {
|
||||||
srvrLog.Errorf("Unable to get channel links for %x: %v",
|
srvrLog.Errorf("Unable to get channel links for %v: %v", p, err)
|
||||||
p.PubKey(), err)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, link := range links {
|
for _, link := range links {
|
||||||
@ -2540,7 +2540,7 @@ func (s *server) peerTerminationWatcher(p *peer, ready chan struct{}) {
|
|||||||
|
|
||||||
// If there were any notification requests for when this peer
|
// If there were any notification requests for when this peer
|
||||||
// disconnected, we can trigger them now.
|
// disconnected, we can trigger them now.
|
||||||
srvrLog.Debugf("Notifying that peer %x is offline", p.PubKey())
|
srvrLog.Debugf("Notifying that peer %x is offline", p)
|
||||||
pubStr := string(pubKey.SerializeCompressed())
|
pubStr := string(pubKey.SerializeCompressed())
|
||||||
for _, offlineChan := range s.peerDisconnectedListeners[pubStr] {
|
for _, offlineChan := range s.peerDisconnectedListeners[pubStr] {
|
||||||
close(offlineChan)
|
close(offlineChan)
|
||||||
@ -2736,13 +2736,14 @@ func (s *server) ConnectToPeer(addr *lnwire.NetAddress, perm bool) error {
|
|||||||
// connection.
|
// connection.
|
||||||
if reqs, ok := s.persistentConnReqs[targetPub]; ok {
|
if reqs, ok := s.persistentConnReqs[targetPub]; ok {
|
||||||
srvrLog.Warnf("Already have %d persistent connection "+
|
srvrLog.Warnf("Already have %d persistent connection "+
|
||||||
"requests for %v, connecting anyway.", len(reqs), addr)
|
"requests for %x@%v, connecting anyway.", len(reqs),
|
||||||
|
targetPub, addr)
|
||||||
}
|
}
|
||||||
|
|
||||||
// If there's not already a pending or active connection to this node,
|
// If there's not already a pending or active connection to this node,
|
||||||
// then instruct the connection manager to attempt to establish a
|
// then instruct the connection manager to attempt to establish a
|
||||||
// persistent connection to the peer.
|
// persistent connection to the peer.
|
||||||
srvrLog.Debugf("Connecting to %v", addr)
|
srvrLog.Debugf("Connecting to %x@%v", targetPub, addr)
|
||||||
if perm {
|
if perm {
|
||||||
connReq := &connmgr.ConnReq{
|
connReq := &connmgr.ConnReq{
|
||||||
Addr: addr,
|
Addr: addr,
|
||||||
|
Loading…
Reference in New Issue
Block a user