diff --git a/cmd/clusterd/main.go b/cmd/clusterd/main.go index ee4beb3..a7e99e4 100644 --- a/cmd/clusterd/main.go +++ b/cmd/clusterd/main.go @@ -164,7 +164,7 @@ func main() { log.Panic("failed to create syncer", zap.Error(err)) } defer s.Close() - go s.Run(ctx) + go s.Run() nm := nodes.NewManager(dir, cm, s, nodes.WithLog(log.Named("cluster")), nodes.WithSharedConsensus(true)) defer nm.Close() diff --git a/go.mod b/go.mod index d50d6d2..2049db8 100644 --- a/go.mod +++ b/go.mod @@ -6,10 +6,10 @@ toolchain go1.23.2 require ( go.sia.tech/core v0.9.1 - go.sia.tech/coreutils v0.10.1 + go.sia.tech/coreutils v0.10.2-0.20250124134251-3a96ba4fb39c go.sia.tech/hostd v1.1.3-0.20250117061650-943b1da7f33a go.sia.tech/jape v0.12.1 - go.sia.tech/renterd v1.1.2-0.20250122122913-5c7099d77dea + go.sia.tech/renterd v1.1.2-0.20250124142450-4c7858d8f9db go.sia.tech/walletd v0.9.0-beta.1.0.20250116183850-24b3faed5183 go.uber.org/zap v1.27.0 lukechampine.com/frand v1.5.1 diff --git a/go.sum b/go.sum index 4a5de40..2a5e80e 100644 --- a/go.sum +++ b/go.sum @@ -57,8 +57,8 @@ go.etcd.io/bbolt v1.3.11 h1:yGEzV1wPz2yVCLsD8ZAiGHhHVlczyC9d1rP43/VCRJ0= go.etcd.io/bbolt v1.3.11/go.mod h1:dksAq7YMXoljX0xu6VF5DMZGbhYYoLUalEiSySYAS4I= go.sia.tech/core v0.9.1 h1:p65iVQP4OnLRvPHBbZDhUR0LFserNIY82M/4de/gNPo= go.sia.tech/core v0.9.1/go.mod h1:7buI+3k5xO+9PdzBQJlogOAc5h+twDUxEpV6EuXWZ5A= -go.sia.tech/coreutils v0.10.1 h1:qs6JIUhzQGcWYdMoE0KURz8g+Wt+OI65KMmyc4or/DA= -go.sia.tech/coreutils v0.10.1/go.mod h1:99k+BlLKYsKHNdZAr5KqYIhoamPEbwhKZdq4FDV4HtU= +go.sia.tech/coreutils v0.10.2-0.20250124134251-3a96ba4fb39c h1:FhGQWlWJ0G2PVjaDO4vM5vcHCJZHph6qo1D5hvKLqEY= +go.sia.tech/coreutils v0.10.2-0.20250124134251-3a96ba4fb39c/go.mod h1:99k+BlLKYsKHNdZAr5KqYIhoamPEbwhKZdq4FDV4HtU= go.sia.tech/gofakes3 v0.0.5 h1:vFhVBUFbKE9ZplvLE2w4TQxFMQyF8qvgxV4TaTph+Vw= go.sia.tech/gofakes3 v0.0.5/go.mod h1:LXEzwGw+OHysWLmagleCttX93cJZlT9rBu/icOZjQ54= go.sia.tech/hostd v1.1.3-0.20250117061650-943b1da7f33a h1:R0OVTc+MuPqLvso0Ocki+itPnKAYsWgcIte7WSopOzs= @@ -67,8 +67,8 @@ go.sia.tech/jape v0.12.1 h1:xr+o9V8FO8ScRqbSaqYf9bjj1UJ2eipZuNcI1nYousU= go.sia.tech/jape v0.12.1/go.mod h1:wU+h6Wh5olDjkPXjF0tbZ1GDgoZ6VTi4naFw91yyWC4= go.sia.tech/mux v1.3.0 h1:hgR34IEkqvfBKUJkAzGi31OADeW2y7D6Bmy/Jcbop9c= go.sia.tech/mux v1.3.0/go.mod h1:I46++RD4beqA3cW9Xm9SwXbezwPqLvHhVs9HLpDtt58= -go.sia.tech/renterd v1.1.2-0.20250122122913-5c7099d77dea h1:BiMnUj71hkHSzCdJqD9DWnDiu4B2VuHHgiDqpdpK7M8= -go.sia.tech/renterd v1.1.2-0.20250122122913-5c7099d77dea/go.mod h1:Kh/j9XEucpj9ZyBwheBuPD9fJVHsiKnxyvE0SItjC5M= +go.sia.tech/renterd v1.1.2-0.20250124142450-4c7858d8f9db h1:evQLysRIueHhS8DE21b0zXAsJcFyVtpylX/TKkqpkeA= +go.sia.tech/renterd v1.1.2-0.20250124142450-4c7858d8f9db/go.mod h1:txIRoVGJ9uGs347R+zY3bq3a7KHDBFFBnihqx/d2Zlg= go.sia.tech/walletd v0.9.0-beta.1.0.20250116183850-24b3faed5183 h1:8AF/Kv4hBmaUrnCFBLfdvXhvQYGP3TFxsgqMVV4zP8k= go.sia.tech/walletd v0.9.0-beta.1.0.20250116183850-24b3faed5183/go.mod h1:UkgEBiPktkb6Zws8ghtRTa1WMxIInlvqC0f6EozDSFU= go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto= diff --git a/nodes/hostd.go b/nodes/hostd.go index 79b6199..5731166 100644 --- a/nodes/hostd.go +++ b/nodes/hostd.go @@ -137,7 +137,7 @@ func (m *Manager) StartHostd(ctx context.Context, sk types.PrivateKey, ready cha syncer.WithMaxInboundPeers(10000), syncer.WithMaxOutboundPeers(10000)) defer s.Close() - go s.Run(ctx) + go s.Run() node.SyncerAddress = syncerListener.Addr().String() // connect to the cluster syncer diff --git a/nodes/renterd.go b/nodes/renterd.go index 3e1d58e..63a8c7e 100644 --- a/nodes/renterd.go +++ b/nodes/renterd.go @@ -149,7 +149,7 @@ func (m *Manager) StartRenterd(ctx context.Context, sk types.PrivateKey, ready c syncer.WithMaxInboundPeers(10000), syncer.WithMaxOutboundPeers(10000)) defer s.Close() - go s.Run(ctx) + go s.Run() node.SyncerAddress = syncerListener.Addr().String() // connect to the cluster syncer diff --git a/nodes/walletd.go b/nodes/walletd.go index b3cfd3e..236973b 100644 --- a/nodes/walletd.go +++ b/nodes/walletd.go @@ -115,7 +115,7 @@ func (m *Manager) StartWalletd(ctx context.Context, ready chan<- struct{}) (err syncer.WithMaxInboundPeers(10000), syncer.WithMaxOutboundPeers(10000)) defer s.Close() - go s.Run(ctx) + go s.Run() node.SyncerAddress = syncerListener.Addr().String() // connect to the cluster syncer