]> Sergey Matveev's repositories - btrtrc.git/commitdiff
Update dht logging
authorMatt Joiner <anacrolix@gmail.com>
Thu, 17 Mar 2022 03:58:32 +0000 (14:58 +1100)
committerMatt Joiner <anacrolix@gmail.com>
Thu, 17 Mar 2022 03:58:32 +0000 (14:58 +1100)
client.go

index 31329ff344db1b8d4e8c38bd922d5eec2c844416..4b6f1a24b12162587943afca64bbaa48b9f1a2ce 100644 (file)
--- a/client.go
+++ b/client.go
@@ -380,6 +380,7 @@ func (cl *Client) listenNetworks() (ns []network) {
 
 // Creates an anacrolix/dht Server, as would be done internally in NewClient, for the given conn.
 func (cl *Client) NewAnacrolixDhtServer(conn net.PacketConn) (s *dht.Server, err error) {
+       logger := cl.logger.WithNames("dht", conn.LocalAddr().String())
        cfg := dht.ServerConfig{
                IPBlocklist:    cl.ipBlockList,
                Conn:           conn,
@@ -392,7 +393,7 @@ func (cl *Client) NewAnacrolixDhtServer(conn net.PacketConn) (s *dht.Server, err
                }(),
                StartingNodes: cl.config.DhtStartingNodes(conn.LocalAddr().Network()),
                OnQuery:       cl.config.DHTOnQuery,
-               Logger:        cl.logger.WithContextText(fmt.Sprintf("dht server on %v", conn.LocalAddr().String())),
+               Logger:        logger,
        }
        if f := cl.config.ConfigureAnacrolixDhtServer; f != nil {
                f(&cfg)
@@ -402,9 +403,9 @@ func (cl *Client) NewAnacrolixDhtServer(conn net.PacketConn) (s *dht.Server, err
                go func() {
                        ts, err := s.Bootstrap()
                        if err != nil {
-                               cl.logger.Printf("error bootstrapping dht: %s", err)
+                               logger.Levelf(log.Warning, "error bootstrapping dht: %s", err)
                        }
-                       log.Fstr("%v completed bootstrap (%+v)", s, ts).AddValues(s, ts).Log(cl.logger)
+                       logger.Levelf(log.Debug, "completed bootstrap: %+v", ts)
                }()
        }
        return