prevent race condition on starting an already running service

ocis-pkg/sync/trap.go

@@ -16,7 +16,6 @@ func Trap(gr *run.Group, cancel context.CancelFunc) {
 		<-stop
 		return nil
 	}, func(err error) {
-		close(stop)
 		cancel()
 	})
 }

storage/pkg/command/authbasic.go

@@ -78,7 +78,7 @@ func AuthBasic(cfg *config.Config) *cli.Command {
 				cancel()
 			})
 
-			if !cfg.Reva.StorageMetadata.Supervised {
+			if !cfg.Reva.AuthBasic.Supervised {
 				sync.Trap(&gr, cancel)
 			}
 

storage/pkg/command/authbearer.go

@@ -73,7 +73,7 @@ func AuthBearer(cfg *config.Config) *cli.Command {
 				cancel()
 			})
 
-			if !cfg.Reva.StorageMetadata.Supervised {
+			if !cfg.Reva.AuthBearer.Supervised {
 				sync.Trap(&gr, cancel)
 			}
 

storage/pkg/command/gateway.go

@@ -96,7 +96,7 @@ func Gateway(cfg *config.Config) *cli.Command {
 				cancel()
 			})
 
-			if !cfg.Reva.StorageMetadata.Supervised {
+			if !cfg.Reva.Gateway.Supervised {
 				sync.Trap(&gr, cancel)
 			}
 

storage/pkg/command/groups.go

@@ -84,7 +84,7 @@ func Groups(cfg *config.Config) *cli.Command {
 				cancel()
 			})
 
-			if !cfg.Reva.StorageMetadata.Supervised {
+			if !cfg.Reva.Groups.Supervised {
 				sync.Trap(&gr, cancel)
 			}
 

storage/pkg/command/sharing.go

@@ -92,7 +92,7 @@ func Sharing(cfg *config.Config) *cli.Command {
 				cancel()
 			})
 
-			if !cfg.Reva.StorageMetadata.Supervised {
+			if !cfg.Reva.Sharing.Supervised {
 				sync.Trap(&gr, cancel)
 			}
 

storage/pkg/command/storagehome.go

@@ -86,7 +86,7 @@ func StorageHome(cfg *config.Config) *cli.Command {
 				cancel()
 			})
 
-			if !cfg.Reva.StorageMetadata.Supervised {
+			if !cfg.Reva.StorageHome.Supervised {
 				sync.Trap(&gr, cancel)
 			}
 

storage/pkg/command/storagepubliclink.go

@@ -68,7 +68,7 @@ func StoragePublicLink(cfg *config.Config) *cli.Command {
 				cancel()
 			})
 
-			if !cfg.Reva.StorageMetadata.Supervised {
+			if !cfg.Reva.StoragePublicLink.Supervised {
 				sync.Trap(&gr, cancel)
 			}
 

storage/pkg/command/storageusers.go

@@ -86,7 +86,7 @@ func StorageUsers(cfg *config.Config) *cli.Command {
 				cancel()
 			})
 
-			if !cfg.Reva.StorageMetadata.Supervised {
+			if !cfg.Reva.StorageUsers.Supervised {
 				sync.Trap(&gr, cancel)
 			}
 

storage/pkg/command/users.go

@@ -85,7 +85,7 @@ func Users(cfg *config.Config) *cli.Command {
 				cancel()
 			})
 
-			if !cfg.Reva.StorageMetadata.Supervised {
+			if !cfg.Reva.Users.Supervised {
 				sync.Trap(&gr, cancel)
 			}