Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for globalServiceSignalCh (0.23 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()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 2.7K 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.
    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)
  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
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	writeSuccessResponseJSON(w, jsonBytes)
    
    	if !dryRun {
    		if lrTime.Sub(currentReleaseTime) > 0 {
    			globalServiceSignalCh <- serviceRestart
    		}
    	}
    }
    
    // ServerUpdateHandler - POST /minio/admin/v3/update?updateURL={updateURL}
    // ----------
    // updates all minio servers and restarts them gracefully.
    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)
  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 {
    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)
Back to top