mirrors/versitygw
1
0
Fork 0
mirror of https://github.com/versity/versitygw.git synced 2026-09-22 07:54:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2360 from potatogim/rdma-shutdown-entry

Browse Source
This commit is contained in:
Ben McClelland
2026-09-04 21:21:32 -07:00
committed by GitHub
parent fd04bc1df2 e7edb71166
commit 7f0a793150
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/vgwrdma/main.go
+9 -9
View File
@@ -965,6 +965,15 @@ func debugLogLevel() debuglogger.Level {
}
func runGateway(ctx context.Context, be backend.Backend) error {
// The gateway command owns the input backend from here on:
// every failure path below must close the whole chain it
// has built so far, exactly once. The closure reads be at
// run time, so the rollback covers the v1 chain and the RC
// wrapper once those layers are added; the once guard keeps
// the shared close with the RunVersityGW lifecycle single.
be = rdmamode.WrapShutdownOnce(be)
defer func() { be.Shutdown() }()
if pprof != "" {
// Listen on the specified address for pprof debug endpoints.
// Point a browser to http://<host:port>/debug/pprof/
@@ -998,15 +1007,6 @@ func runGateway(ctx context.Context, be backend.Backend) error {
}
}
// The gateway command owns the input backend from here on:
// every later failure path must close the whole chain it has
// built so far, exactly once. The closure reads be at run
// time, so the rollback covers the v1 chain and the RC
// wrapper once those layers are added; the once guard keeps
// the shared close with the RunVersityGW lifecycle single.
be = rdmamode.WrapShutdownOnce(be)
defer func() { be.Shutdown() }()
var s3Opts []s3api.Option
if v1On {
rdma.ConfigureTelemetry(debug)