- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for freezeServices (0.08 sec)
-
cmd/service.go
// Re-uses the same pid. This preserves the pid over multiple server-respawns. return syscall.Exec(argv0, os.Args, os.Environ()) } // freezeServices will freeze all incoming S3 API calls. // For each call, unfreezeServices must be called once. func freezeServices() { // Use atomics for globalServiceFreeze, so we can read without locking. // We need a lock since we are need the 2 atomic values to remain in sync.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Feb 28 07:02:14 UTC 2024 - 3.8K bytes - Viewed (0) -
cmd/server-main.go
logger.Fatal(err, "Unable to start the server") } }) } if globalEnableSyncBoot { // Freeze the services until the bucket notification subsystem gets initialized. bootstrapTrace("freezeServices", freezeServices) } var newObject ObjectLayer bootstrapTrace("newObjectLayer", func() { var err error newObject, err = newObjectLayer(GlobalContext, globalEndpoints) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 21:50:11 UTC 2024 - 35.2K bytes - Viewed (1) -
cmd/admin-handlers.go
adminLogIf(ctx, nerr.Err) } } // Reply to the client before restarting, stopping MinIO server. writeSuccessResponseHeadersOnly(w) switch serviceSig { case serviceFreeze: freezeServices() case serviceUnFreeze: unfreezeServices() case serviceRestart, serviceStop: globalServiceSignalCh <- serviceSig } } type servicePeerResult struct {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 99.7K bytes - Viewed (0) -
cmd/notification.go
} client := client ng.Go(GlobalContext, func() error { return client.SignalService(serviceSig, "", false, nil) }, idx, *client.host) } nerrs := ng.Wait() if freeze { freezeServices() } else { unfreezeServices() } return nerrs } // Netperf - perform mesh style network throughput test
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
cmd/peer-rest-server.go
if err != nil { return np, grid.NewRemoteErr(err) } return np, grid.NewRemoteErrString(string(buf)) } if !dryRun { globalServiceSignalCh <- signal } case serviceFreeze: freezeServices() case serviceUnFreeze: unfreezeServices() case serviceReloadDynamic: objAPI := newObjectLayerFn() if objAPI == nil { return np, grid.NewRemoteErr(errServerNotInitialized) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 53.2K bytes - Viewed (0)