Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

A thread safe way to take a free port #485

Merged
merged 12 commits into from
Aug 16, 2022
36 changes: 36 additions & 0 deletions common/network/port.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,36 @@
package network

import (
"errors"
"fmt"
"net"
)

const (
maxPortCheck = 100

emptyPort = "127.0.0.1:0"
)

var (
ErrCantFindAPort = errors.New("no available port found")
)

// FindAvailablePort returns the an available port
func FindAvailablePort() (int, net.Listener, error) {
var (
listener net.Listener
err error
)

for i := uint(0); i < maxPortCheck; i++ {
listener, err = net.Listen("tcp", emptyPort)
if err != nil {
continue
}

return listener.Addr().(*net.TCPAddr).Port, listener, nil
}

return 0, nil, fmt.Errorf("%w: %s", ErrCantFindAPort, err)
}
44 changes: 14 additions & 30 deletions consensus/bor/heimdall/client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,18 +9,16 @@ import (
"net"
"net/http"
"sync"
"sync/atomic"
"testing"
"time"

"github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/common/network"
"github.com/ethereum/go-ethereum/consensus/bor/heimdall/checkpoint"

"github.com/stretchr/testify/require"
)

var maxPortCheck int32 = 100

// HttpHandlerFake defines the handler functions required to serve
// requests to the mock heimdal server for specific functions. Add more handlers
// according to requirements.
Expand All @@ -34,7 +32,7 @@ func (h *HttpHandlerFake) GetCheckpointHandler() http.HandlerFunc {
}
}

func CreateMockHeimdallServer(wg *sync.WaitGroup, port int32, handler *HttpHandlerFake) (*http.Server, error) {
func CreateMockHeimdallServer(wg *sync.WaitGroup, port int, listener net.Listener, handler *HttpHandlerFake) (*http.Server, error) {
// Create a new server mux
mux := http.NewServeMux()

Expand All @@ -51,6 +49,12 @@ func CreateMockHeimdallServer(wg *sync.WaitGroup, port int32, handler *HttpHandl
Handler: mux,
}

// Close the listener using the port and immediately consume it below
err := listener.Close()
if err != nil {
return nil, err
}

go func() {
defer wg.Done()

Expand Down Expand Up @@ -93,12 +97,12 @@ func TestFetchCheckpointFromMockHeimdall(t *testing.T) {
}
}

// Fetch available port starting from 50000
port, err := findAvailablePort(50000, 0)
// Fetch available port
port, listener, err := network.FindAvailablePort()
require.NoError(t, err, "expect no error in finding available port")

// Create mock heimdall server and pass handler instance for setting up the routes
srv, err := CreateMockHeimdallServer(wg, port, handler)
srv, err := CreateMockHeimdallServer(wg, port, listener, handler)
require.NoError(t, err, "expect no error in starting mock heimdall server")

// Create a new heimdall client and use same port for connection
Expand Down Expand Up @@ -150,12 +154,12 @@ func TestFetchShutdown(t *testing.T) {
}
}

// Fetch available port starting from 50000
port, err := findAvailablePort(50000, 0)
// Fetch available port
port, listener, err := network.FindAvailablePort()
require.NoError(t, err, "expect no error in finding available port")

// Create mock heimdall server and pass handler instance for setting up the routes
srv, err := CreateMockHeimdallServer(wg, port, handler)
srv, err := CreateMockHeimdallServer(wg, port, listener, handler)
require.NoError(t, err, "expect no error in starting mock heimdall server")

// Create a new heimdall client and use same port for connection
Expand Down Expand Up @@ -216,26 +220,6 @@ func TestFetchShutdown(t *testing.T) {
wg.Wait()
}

// findAvailablePort returns the next available port starting from `from`
func findAvailablePort(from int32, count int32) (int32, error) {
if count == maxPortCheck {
return 0, fmt.Errorf("no available port found")
}

port := atomic.AddInt32(&from, 1)
addr := fmt.Sprintf("localhost:%d", port)

count++

lis, err := net.Listen("tcp", addr)
if err == nil {
lis.Close()
return port, nil
} else {
return findAvailablePort(from, count)
}
}

// TestContext includes bunch of simple tests to verify the working of timeout
// based context and cancellation.
func TestContext(t *testing.T) {
Expand Down

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion internal/cli/debug_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ import (
"github.com/ethereum/go-ethereum/internal/cli/server"
)

var currentDir string = ""
var currentDir string

func TestCommand_DebugBlock(t *testing.T) {
t.Parallel()
Expand Down
4 changes: 2 additions & 2 deletions internal/cli/server/command.go
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ func (c *Command) extractFlags(args []string) error {
}
// read if config file is provided, this will overwrite the cli flags, if provided
if c.configFile != "" {
log.Warn("Config File provided, this will overwrite the cli flags.", "configFile:", c.configFile)
log.Warn("Config File provided, this will overwrite the cli flags", "path", c.configFile)
cfg, err := readConfigFile(c.configFile)
if err != nil {
c.UI.Error(err.Error())
Expand Down Expand Up @@ -101,7 +101,7 @@ func (c *Command) Run(args []string) int {
return 1
}

srv, err := NewServer(c.config)
srv, err := NewServer(c.config, WithGRPCAddress())
if err != nil {
c.UI.Error(err.Error())
return 1
Expand Down
59 changes: 10 additions & 49 deletions internal/cli/server/helper.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,75 +2,36 @@ package server

import (
"fmt"
"math/rand"
"net"
"os"
"sync/atomic"
"time"
)

var maxPortCheck int32 = 100

// findAvailablePort returns the next available port starting from `from`
func findAvailablePort(from int32, count int32) (int32, error) {
if count == maxPortCheck {
return 0, fmt.Errorf("no available port found")
}

port := atomic.AddInt32(&from, 1)
addr := fmt.Sprintf("localhost:%d", port)

count++

lis, err := net.Listen("tcp", addr)
if err == nil {
lis.Close()
return port, nil
} else {
return findAvailablePort(from, count)
}
}
"github.com/ethereum/go-ethereum/common/network"
)

func CreateMockServer(config *Config) (*Server, error) {
if config == nil {
config = DefaultConfig()
}

// find available port for grpc server
rand.Seed(time.Now().UnixNano())

var (
from int32 = 60000 // the min port to start checking from
to int32 = 61000 // the max port to start checking from
)

//nolint: gosec
port, err := findAvailablePort(rand.Int31n(to-from+1)+from, 0)
// get grpc port and listener
grpcPort, gRPCListener, err := network.FindAvailablePort()
if err != nil {
return nil, err
}

// grpc port
config.GRPC.Addr = fmt.Sprintf(":%d", port)
// The test uses grpc port from config so setting it here.
config.GRPC.Addr = fmt.Sprintf(":%d", grpcPort)

// datadir
datadir, _ := os.MkdirTemp("/tmp", "bor-cli-test")
config.DataDir = datadir

// find available port for http server
from = 8545
to = 9545

//nolint: gosec
port, err = findAvailablePort(rand.Int31n(to-from+1)+from, 0)
datadir, err := os.MkdirTemp("", "bor-cli-test")
if err != nil {
return nil, err
}

config.JsonRPC.Http.Port = uint64(port)
config.DataDir = datadir
config.JsonRPC.Http.Port = 0 // It will choose a free/available port

// start the server
return NewServer(config)
return NewServer(config, WithGRPCListener(gRPCListener))
}

func CloseMockServer(server *Server) {
Expand Down
54 changes: 41 additions & 13 deletions internal/cli/server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -50,20 +50,40 @@ type Server struct {
tracerAPI *tracers.API
}

func NewServer(config *Config) (*Server, error) {
type serverOption func(srv *Server, config *Config) error

func WithGRPCAddress() serverOption {
return func(srv *Server, config *Config) error {
return srv.gRPCServerByAddress(config.GRPC.Addr)
}
}

func WithGRPCListener(lis net.Listener) serverOption {
return func(srv *Server, _ *Config) error {
return srv.gRPCServerByListener(lis)
}
}

//nolint:gocognit
func NewServer(config *Config, opts ...serverOption) (*Server, error) {
srv := &Server{
config: config,
}

// start the logger
setupLogger(config.LogLevel)

if err := srv.setupGRPCServer(config.GRPC.Addr); err != nil {
return nil, err
var err error

for _, opt := range opts {
JekaMas marked this conversation as resolved.
Show resolved Hide resolved
err = opt(srv, config)
if err != nil {
return nil, err
}
}

// load the chain genesis
if err := config.loadChain(); err != nil {
if err = config.loadChain(); err != nil {
return nil, err
}

Expand Down Expand Up @@ -151,7 +171,6 @@ func NewServer(config *Config) (*Server, error) {
wallet, err := accountManager.Find(accounts.Account{Address: eb})
if wallet == nil || err != nil {
log.Error("Etherbase account unavailable locally", "err", err)

return nil, fmt.Errorf("signer missing: %v", err)
}

Expand Down Expand Up @@ -217,8 +236,13 @@ func NewServer(config *Config) (*Server, error) {
}

func (s *Server) Stop() {
s.node.Close()
s.grpcServer.Stop()
if s.node != nil {
s.node.Close()
}

if s.grpcServer != nil {
s.grpcServer.Stop()
}

// shutdown the tracer
if s.tracer != nil {
Expand Down Expand Up @@ -327,22 +351,26 @@ func (s *Server) setupMetrics(config *TelemetryConfig, serviceName string) error
return nil
}

func (s *Server) setupGRPCServer(addr string) error {
s.grpcServer = grpc.NewServer(s.withLoggingUnaryInterceptor())
proto.RegisterBorServer(s.grpcServer, s)

func (s *Server) gRPCServerByAddress(addr string) error {
lis, err := net.Listen("tcp", addr)
if err != nil {
return err
}

return s.gRPCServerByListener(lis)
}

func (s *Server) gRPCServerByListener(listener net.Listener) error {
s.grpcServer = grpc.NewServer(s.withLoggingUnaryInterceptor())
proto.RegisterBorServer(s.grpcServer, s)

go func() {
if err := s.grpcServer.Serve(lis); err != nil {
if err := s.grpcServer.Serve(listener); err != nil {
JekaMas marked this conversation as resolved.
Show resolved Hide resolved
log.Error("failed to serve grpc server", "err", err)
}
}()

log.Info("GRPC Server started", "addr", addr)
log.Info("GRPC Server started", "addr", listener.Addr())

return nil
}
Expand Down
Loading