Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for globalServiceSignalCh (0.07 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top