Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for prefilter (0.27 sec)

  1. cmd/signals.go

    	"github.com/minio/minio/internal/logger"
    )
    
    func handleSignals() {
    	// Custom exit function
    	exit := func(success bool) {
    		if globalLoggerOutput != nil {
    			globalLoggerOutput.Close()
    		}
    
    		// If global profiler is set stop before we exit.
    		globalProfilerMu.Lock()
    		defer globalProfilerMu.Unlock()
    		for _, p := range globalProfiler {
    			p.Stop()
    		}
    
    		if success {
    			os.Exit(0)
    		}
    
    		os.Exit(1)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  2. cmd/peer-rest-server.go

    				v.Stop()
    				delete(globalProfiler, k)
    			}
    		}
    	}
    
    	for _, profiler := range profiles {
    		prof, err := startProfiler(profiler)
    		if err != nil {
    			s.writeErrorResponse(w, err)
    			return
    		}
    		globalProfiler[profiler] = prof
    	}
    }
    
    // DownloadProfilingDataHandler - returns profiled data.
    func (s *peerRESTServer) DownloadProfilingDataHandler(w http.ResponseWriter, r *http.Request) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  3. cmd/peer-rest-client.go

    	return resp.ValueOrZero(), err
    }
    
    // StartProfiling - Issues profiling command on the peer node.
    func (client *peerRESTClient) StartProfiling(profiler string) error {
    	values := make(url.Values)
    	values.Set(peerRESTProfiler, profiler)
    	respBody, err := client.call(peerRESTMethodStartProfiling, values, nil, -1)
    	if err != nil {
    		return err
    	}
    	defer xhttp.DrainBody(respBody)
    	return nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    	}
    
    	// Stop profiler of all types if already running
    	for k, v := range globalProfiler {
    		v.Stop()
    		delete(globalProfiler, k)
    	}
    
    	// Start profiling on remote servers.
    	for _, profiler := range profiles {
    		globalNotificationSys.StartProfiling(profiler)
    
    		// Start profiling locally as well.
    		prof, err := startProfiler(profiler)
    		if err == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  5. cmd/utils_test.go

    // Add tests for starting and stopping different profilers.
    func TestStartProfiler(t *testing.T) {
    	_, err := startProfiler("")
    	if err == nil {
    		t.Fatal("Expected a non nil error, but nil error returned for invalid profiler.")
    	}
    }
    
    // checkURL - checks if passed address correspond
    func checkURL(urlStr string) (*url.URL, error) {
    	if urlStr == "" {
    		return nil, errors.New("Address cannot be empty")
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 23 21:28:14 GMT 2024
    - 10.2K bytes
    - Viewed (0)
  6. cmd/utils.go

    	runtime.SetBlockProfileRate(0)     // Disable until needed
    }
    
    // Starts a profiler returns nil if profiler is not enabled, caller needs to handle this.
    func startProfiler(profilerType string) (minioProfiler, error) {
    	var prof profilerWrapper
    	prof.ext = "pprof"
    	// Enable profiler and set the name of the file that pkg/pprof
    	// library creates to store profiling data.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  7. cmd/notification.go

    func (sys *NotificationSys) StartProfiling(profiler string) []NotificationPeerErr {
    	ng := WithNPeers(len(sys.peerClients))
    	for idx, client := range sys.peerClients {
    		if client == nil {
    			continue
    		}
    		client := client
    		ng.Go(GlobalContext, func() error {
    			return client.StartProfiling(profiler)
    		}, idx, *client.host)
    	}
    	return ng.Wait()
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  8. cmd/peer-rest-common.go

    	peerRESTUserOrGroup    = "user-or-group"
    	peerRESTUserType       = "user-type"
    	peerRESTIsGroup        = "is-group"
    	peerRESTSignal         = "signal"
    	peerRESTSubSys         = "sub-sys"
    	peerRESTProfiler       = "profiler"
    	peerRESTSize           = "size"
    	peerRESTConcurrent     = "concurrent"
    	peerRESTDuration       = "duration"
    	peerRESTStorageClass   = "storage-class"
    	peerRESTEnableSha256   = "enableSha256"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 2.7K bytes
    - Viewed (0)
Back to top