From 6773f102920154350154cf44cb96a68ad29bcf25 Mon Sep 17 00:00:00 2001 From: Dmitry Vyukov Date: Wed, 22 May 2024 09:32:53 +0200 Subject: [PATCH] syz-ci: use unique ports for test instances Currently they can collide with the main instance and fail. Use unique ports for test instances. --- syz-ci/manager.go | 3 +++ syz-ci/syz-ci.go | 10 ++++++++++ 2 files changed, 13 insertions(+) diff --git a/syz-ci/manager.go b/syz-ci/manager.go index 65b5385efc1b..2f4e872f8976 100644 --- a/syz-ci/manager.go +++ b/syz-ci/manager.go @@ -549,6 +549,9 @@ func (mgr *Manager) createTestConfig(imageDir string, info *BuildInfo) (*mgrconf *mgrcfg = *mgr.managercfg mgrcfg.Name += "-test" mgrcfg.Tag = info.KernelCommit + // Use random free ports to not collide with the actual manager. + mgrcfg.HTTP = fmt.Sprintf("localhost:%v", mgr.mgrcfg.testHTTPPort) + mgrcfg.RPC = fmt.Sprintf("localhost:%v", mgr.mgrcfg.testRPCPort) mgrcfg.Workdir = filepath.Join(imageDir, "workdir") if err := instance.SetConfigImage(mgrcfg, imageDir, true); err != nil { return nil, err diff --git a/syz-ci/syz-ci.go b/syz-ci/syz-ci.go index e9e12e0e6401..d27db6c6c0dc 100644 --- a/syz-ci/syz-ci.go +++ b/syz-ci/syz-ci.go @@ -86,8 +86,10 @@ type Config struct { Name string `json:"name"` HTTP string `json:"http"` // If manager http address is not specified, give it an address starting from this port. Optional. + // This is also used to auto-assign ports for test instances. ManagerPort int `json:"manager_port_start"` // If manager rpc address is not specified, give it addresses starting from this port. By default 30000. + // This is also used to auto-assign ports for test instances. RPCPort int `json:"rpc_port_start"` DashboardAddr string `json:"dashboard_addr"` // Optional. DashboardClient string `json:"dashboard_client"` // Optional. @@ -208,6 +210,10 @@ type ManagerConfig struct { // By default it's 30 days. MaxKernelLagDays int `json:"max_kernel_lag_days"` managercfg *mgrconfig.Config + + // Auto-assigned ports used by test instances. + testHTTPPort int + testRPCPort int } type ManagerJobs struct { @@ -440,6 +446,10 @@ func loadManagerConfig(cfg *Config, mgr *ManagerConfig) error { managercfg.RPC = fmt.Sprintf(":%v", cfg.RPCPort) cfg.RPCPort++ } + mgr.testHTTPPort = cfg.ManagerPort + cfg.ManagerPort++ + mgr.testRPCPort = cfg.RPCPort + cfg.RPCPort++ // Note: we don't change Compiler/Ccache because it may be just "gcc" referring // to the system binary, or pkg/build/netbsd.go uses "g++" and "clang++" as special marks. mgr.Userspace = osutil.Abs(mgr.Userspace)