- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for globalServiceSignalCh (1.78 sec)
-
cmd/admin-handlers_test.go
// testServiceSignalReceiver - Helper function that simulates a // go-routine waiting on service signal. func testServiceSignalReceiver(cmd cmdType, t *testing.T) { expectedCmd := cmd.toServiceSignal() serviceCmd := <-globalServiceSignalCh if serviceCmd != expectedCmd { t.Errorf("Expected service command %v but received %v", expectedCmd, serviceCmd) } } // getServiceCmdRequest - Constructs a management REST API request for service
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.9K bytes - Viewed (0) -
cmd/admin-handlers.go
return } writeSuccessResponseJSON(w, jsonBytes) if !dryRun { prs, ok := peerResults[local] // We restart only on success, not for any failures. if ok && prs.Err == "" { globalServiceSignalCh <- serviceRestart } } } // ServerUpdateHandler - POST /minio/admin/v3/update?updateURL={updateURL} // ---------- // updates all minio servers and restarts them gracefully.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 99.6K bytes - Viewed (0) -
cmd/peer-rest-server.go
buf, err := json.Marshal(waitingDisks) 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 {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 53.4K bytes - Viewed (0)