blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-11-02 01:12:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: remove port reuse

Browse Source
This commit is contained in:
icey-yu 2024-09-07 15:30:49 +08:00
parent 59987f57a9
commit 35c6dc2706
3 changed files with 1 additions and 60 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
pkg/common/startrpc/socket_posix.go
View File

@ -1,26 +0,0 @@
//go:build linux || darwin
package startrpc
import (
"context"
"github.com/openimsdk/tools/log"
"net"
"syscall"
)
func createListener() net.ListenConfig {
lc := net.ListenConfig{
Control: func(network, address string, conn syscall.RawConn) error {
return conn.Control(func(fd uintptr) {
err := syscall.SetsockoptInt(int(fd), syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1)
if err != nil {
log.ZError(context.Background(), "Failed to set socket flag to SO_REUSEADDR", err)
return
}
})
},
}
return lc
}

26
pkg/common/startrpc/socket_windows.go
View File

@ -1,26 +0,0 @@
//go:build windows
package startrpc
import (
"context"
"github.com/openimsdk/tools/log"
"net"
"syscall"
)
func createListener() net.ListenConfig {
lc := net.ListenConfig{
Control: func(network, address string, conn syscall.RawConn) error {
return conn.Control(func(fd uintptr) {
err := syscall.SetsockoptInt(syscall.Handle(fd), syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1)
if err != nil {
log.ZError(context.Background(), "Failed to set socket flag to SO_REUSEADDR", err)
return
}
})
},
}
return lc
}

9
pkg/common/startrpc/start.go
View File

@ -55,17 +55,10 @@ func Start[T any](ctx context.Context, discovery *config.Discovery, prometheusCo
"prometheusPorts", prometheusConfig.Ports)
rpcTcpAddr := net.JoinHostPort(network.GetListenIP(listenIP), strconv.Itoa(rpcPort))
lc := createListener()
listener, err := lc.Listen(
ctx,
listener, err := net.Listen(
"tcp",
rpcTcpAddr,
)
if err != nil {
return errs.WrapMsg(err, "listen err", "rpcTcpAddr", rpcTcpAddr)
}
defer listener.Close()
client, err := kdisc.NewDiscoveryRegister(discovery, share)
if err != nil {
return err