- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for unfreezeServices (0.24 sec)
-
cmd/service.go
globalServiceFreezeCnt++ if globalServiceFreezeCnt == 1 { globalServiceFreeze.Store(make(chan struct{})) } globalServiceFreezeMu.Unlock() } // unfreezeServices will unfreeze all incoming S3 API calls. // For each call, unfreezeServices must be called once. func unfreezeServices() { // We need a lock since we need the 2 atomic values to remain in sync. globalServiceFreezeMu.Lock() // Close when we reach 0 globalServiceFreezeCnt--
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
cmd/server-main.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 33K bytes - Viewed (1) -
cmd/notification.go
ng.Go(GlobalContext, func() error { return client.SignalService(serviceSig, "", false) }, idx, *client.host) } nerrs := ng.Wait() if freeze { freezeServices() } else { unfreezeServices() } return nerrs } // Netperf - perform mesh style network throughput test func (sys *NotificationSys) Netperf(ctx context.Context, duration time.Duration) []madmin.NetperfNodeResult {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/admin-handlers.go
} // 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 { Host string `json:"host"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/peer-rest-server.go
} 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) } srvCfg, err := getValidConfig(objAPI) if err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0)