Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for globalServiceSignalCh (0.12 sec)

  1. cmd/signals.go

    		case osSignal := <-globalOSSignalCh:
    			logger.Info("Exiting on signal: %s", strings.ToUpper(osSignal.String()))
    			daemon.SdNotify(false, daemon.SdNotifyStopping)
    			exit(stopProcess())
    		case signal := <-globalServiceSignalCh:
    			switch signal {
    			case serviceRestart:
    				logger.Info("Restarting on service signal")
    				daemon.SdNotify(false, daemon.SdNotifyReloading)
    				stop := stopProcess()
    				rerr := restartProcess()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 04 17:02:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  2. cmd/service.go

    	serviceUnFreeze                           // Un-Freeze previously frozen S3 API calls.
    	// Add new service requests here.
    )
    
    // Global service signal channel.
    var globalServiceSignalCh = make(chan serviceSignal)
    
    // GlobalContext context that is canceled when server is requested to shut down.
    // cancelGlobalContext can be used to indicate server shutdown.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 28 07:02:14 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
Back to top