Skip to content
Snippets Groups Projects
Select Git revision
  • 56d2760dc669b67ea5d018f472a5a97f77f2f7eb
  • 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

server.go

Blame
  • user avatar
    capossele authored
    0ac0ba45
    History
    server.go 1.16 KiB
    package tcp
    
    import (
    	"net"
    	"strconv"
    
    	"github.com/iotaledger/goshimmer/packages/events"
    	"github.com/iotaledger/goshimmer/packages/network"
    )
    
    type Server struct {
    	Socket net.Listener
    	Events serverEvents
    }
    
    func (this *Server) Shutdown() {
    	if this.Socket != nil {
    		socket := this.Socket
    		this.Socket = nil
    
    		socket.Close()
    	}
    }
    
    func (this *Server) Listen(port int) *Server {
    	socket, err := net.Listen("tcp4", "0.0.0.0:"+strconv.Itoa(port))
    	if err != nil {
    		this.Events.Error.Trigger(err)
    
    		return this
    	} else {
    		this.Socket = socket
    	}
    
    	this.Events.Start.Trigger()
    	defer this.Events.Shutdown.Trigger()
    
    	for this.Socket != nil {
    		if socket, err := this.Socket.Accept(); err != nil {
    			if this.Socket != nil {
    				this.Events.Error.Trigger(err)
    			}
    		} else {
    			peer := network.NewManagedConnection(socket)
    
    			go this.Events.Connect.Trigger(peer)
    		}
    	}
    
    	return this
    }
    
    func NewServer() *Server {
    	return &Server{
    		Events: serverEvents{
    			Start:    events.NewEvent(events.CallbackCaller),
    			Shutdown: events.NewEvent(events.CallbackCaller),
    			Connect:  events.NewEvent(managedConnectionCaller),
    			Error:    events.NewEvent(events.ErrorCaller),
    		},
    	}
    }