@@ -253,7 +253,7 @@ func (pm *ProtocolManager) removePeer(id string) {
253253 if peer == nil {
254254 return
255255 }
256- log .Debug ("Removing Ethereum peer" , "peer" , id )
256+ log .Debug ("Removing Nexty peer" , "peer" , id )
257257
258258 // Unregister the peer from the downloader and Ethereum peer set
259259 pm .downloader .UnregisterPeer (id )
@@ -284,7 +284,7 @@ func (pm *ProtocolManager) Start(maxPeers int) {
284284}
285285
286286func (pm * ProtocolManager ) Stop () {
287- log .Info ("Stopping Ethereum protocol" )
287+ log .Info ("Stopping Nexty protocol" )
288288
289289 pm .txsSub .Unsubscribe () // quits txBroadcastLoop
290290 pm .minedBlockSub .Unsubscribe () // quits blockBroadcastLoop
@@ -305,7 +305,7 @@ func (pm *ProtocolManager) Stop() {
305305 // Wait for all peer handler goroutines and the loops to come down.
306306 pm .wg .Wait ()
307307
308- log .Info ("Ethereum protocol stopped" )
308+ log .Info ("Nexty protocol stopped" )
309309}
310310
311311func (pm * ProtocolManager ) newPeer (pv int , p * p2p.Peer , rw p2p.MsgReadWriter ) * peer {
@@ -319,7 +319,7 @@ func (pm *ProtocolManager) handle(p *peer) error {
319319 if pm .peers .Len () >= pm .maxPeers && ! p .Peer .Info ().Network .Trusted {
320320 return p2p .DiscTooManyPeers
321321 }
322- p .Log ().Debug ("Ethereum peer connected" , "name" , p .Name ())
322+ p .Log ().Debug ("Nexty peer connected" , "name" , p .Name ())
323323
324324 // Execute the Ethereum handshake
325325 var (
@@ -330,15 +330,15 @@ func (pm *ProtocolManager) handle(p *peer) error {
330330 td = pm .blockchain .GetTd (hash , number )
331331 )
332332 if err := p .Handshake (pm .networkID , td , hash , genesis .Hash ()); err != nil {
333- p .Log ().Debug ("Ethereum handshake failed" , "err" , err )
333+ p .Log ().Debug ("Nexty handshake failed" , "err" , err )
334334 return err
335335 }
336336 if rw , ok := p .rw .(* meteredMsgReadWriter ); ok {
337337 rw .Init (p .version )
338338 }
339339 // Register the peer locally
340340 if err := pm .peers .Register (p ); err != nil {
341- p .Log ().Error ("Ethereum peer registration failed" , "err" , err )
341+ p .Log ().Error ("Nexty peer registration failed" , "err" , err )
342342 return err
343343 }
344344 defer pm .removePeer (p .id )
@@ -379,7 +379,7 @@ func (pm *ProtocolManager) handle(p *peer) error {
379379 // Handle incoming messages until the connection is torn down
380380 for {
381381 if err := pm .handleMsg (p ); err != nil {
382- p .Log ().Debug ("Ethereum message handling failed" , "err" , err )
382+ p .Log ().Debug ("Nexty message handling failed" , "err" , err )
383383 return err
384384 }
385385 }
0 commit comments