Skip to content
Snippets Groups Projects
Select Git revision
  • 9eaead509e7f1b49b0018ba58f38b7a9c12f2cde
  • without_tipselection default
  • develop protected
  • fix/grafana-local-dashboard
  • wasp
  • fix/dashboard-explorer-freeze
  • master
  • feat/timerqueue
  • test/sync_debug_and_650
  • feat/sync_revamp_inv
  • wip/sync
  • tool/db-recovery
  • portcheck/fix
  • fix/synchronization
  • feat/new-dashboard-analysis
  • feat/refactored-analysis-dashboard
  • feat/new-analysis-dashboard
  • test/demo-prometheus-fpc
  • prometheus_metrics
  • wip/analysis-server
  • merge/fpc-test-value-transfer
  • v0.2.2
  • v0.2.1
  • v0.2.0
  • v0.1.3
  • v0.1.2
  • v0.1.1
  • v0.1.0
28 results

incoming_ping_processor.go

Blame
  • user avatar
    capossele authored
    0ac0ba45
    History
    incoming_ping_processor.go 605 B
    package protocol
    
    import (
    	"github.com/iotaledger/goshimmer/packages/events"
    	"github.com/iotaledger/goshimmer/packages/node"
    	"github.com/iotaledger/goshimmer/plugins/autopeering/instances/knownpeers"
    	"github.com/iotaledger/goshimmer/plugins/autopeering/types/ping"
    )
    
    func createIncomingPingProcessor(plugin *node.Plugin) *events.Closure {
    	return events.NewClosure(func(ping *ping.Ping) {
    		plugin.LogDebug("received ping from " + ping.Issuer.String())
    
    		knownpeers.INSTANCE.AddOrUpdate(ping.Issuer)
    		for _, neighbor := range ping.Neighbors {
    			knownpeers.INSTANCE.AddOrUpdate(neighbor)
    		}
    	})
    }