Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for qsub (0.17 sec)

  1. internal/grid/trace.go

    	if p := handlerPrefixes[h]; p != "" {
    		prefix = p
    	}
    	trace := madmin.TraceInfo{
    		TraceType: t.TraceType,
    		FuncName:  prefix + "." + h.String(),
    		NodeName:  remote,
    		Time:      start,
    		Duration:  end.Sub(start),
    		Path:      t.Subroute,
    		Error:     errString,
    		HTTP: &madmin.TraceHTTPStats{
    			ReqInfo: madmin.TraceRequestInfo{
    				Time:    start,
    				Proto:   "grid",
    				Method:  "REQ",
    				Client:  local,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 02 22:54:54 GMT 2024
    - 4K bytes
    - Viewed (0)
  2. internal/config/browser/browser.go

    package browser
    
    import (
    	"fmt"
    	"strconv"
    	"sync"
    
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/pkg/v2/env"
    )
    
    // Browser sub-system constants
    const (
    	// browserCSPPolicy setting name for Content-Security-Policy response header value
    	browserCSPPolicy = "csp_policy"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  3. cmd/tier-last-day-stats.go

    }
    
    // forwardTo moves time to t, clearing entries between last update and t.
    func (l *lastDayTierStats) forwardTo(t time.Time) {
    	if t.IsZero() {
    		t = time.Now()
    	}
    
    	since := t.Sub(l.UpdatedAt).Hours()
    	// within the hour since l.UpdatedAt
    	if since < 1 {
    		return
    	}
    
    	idx, lastIdx := t.Hour(), l.UpdatedAt.Hour()
    
    	l.UpdatedAt = t // update to the latest time index
    
    	if since >= 24 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  4. cmd/mrf.go

    					continue
    				}
    				if wildcard.Match("multipart/*", u.object) {
    					continue
    				}
    				if wildcard.Match("tmp-old/*", u.object) {
    					continue
    				}
    			}
    
    			now := time.Now()
    			if now.Sub(u.queued) < time.Second {
    				// let recently failed networks to reconnect
    				// making MRF wait for 1s before retrying,
    				// i.e 4 reconnect attempts.
    				time.Sleep(time.Second)
    			}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  5. internal/grid/msg.go

    		if len(h) < 32 {
    			return nil, nil, fmt.Errorf("want subroute len 32, got %v", len(h))
    		}
    		subID := (*[32]byte)(h[len(h)-32:])
    		sub = (*subHandlerID)(subID)
    		// Add if more modifications to h is needed
    		h = h[:len(h)-32]
    	}
    	return sub, h, nil
    }
    
    // setZeroPayloadFlag will clear or set the FlagPayloadIsZero if
    // m.Payload is length 0, but not nil.
    func (m *message) setZeroPayloadFlag() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 28 19:22:29 GMT 2023
    - 7.3K bytes
    - Viewed (0)
  6. internal/handlers/proxy.go

    	// e.g. Forwarded: for=192.0.2.60;proto=https;by=203.0.113.43
    	forwarded = http.CanonicalHeaderKey("Forwarded")
    	// Allows for a sub-match of the first value after 'for=' to the next
    	// comma, semi-colon or space. The match is case-insensitive.
    	forRegex = regexp.MustCompile(`(?i)(?:for=)([^(;|,| )]+)(.*)`)
    	// Allows for a sub-match for the first instance of scheme (http|https)
    	// prefixed by 'proto='. The match is case-insensitive.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 22 00:56:55 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  7. internal/mountinfo/mountinfo_linux_test.go

    		mp := []mountInfo{
    			{"/dev/2", "/path/to/1/2", "type2", []string{"flags"}, "2", "2"},
    		}
    		msg := fmt.Sprintf("Cross-device mounts detected on path (/path/to/1) at following locations %s. Export path should not have any sub-mounts, refusing to start.", mp)
    		if err.Error() != msg {
    			t.Fatalf("Expected msg %s, got %s", msg, err)
    		}
    	}
    	// Failure case when input path is not absolute.
    	{
    		absPaths := []string{"."}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.3K bytes
    - Viewed (0)
  8. cmd/typed-errors.go

    // error returned in IAM service account
    var errIAMServiceAccountNotAllowed = errors.New("Specified service account action is not allowed")
    
    // error returned in IAM subsystem when IAM sub-system is still being initialized.
    var errIAMNotInitialized = errors.New("IAM sub-system is being initialized, please try again")
    
    // error returned when upload id not found
    var errUploadIDNotFound = errors.New("Specified Upload ID is not found")
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.3K bytes
    - Viewed (0)
  9. cmd/consolelogger.go

    	console  *console.Target
    	nodeName string
    	logBuf   *ring.Ring
    }
    
    // NewConsoleLogger - creates new HTTPConsoleLoggerSys with all nodes subscribed to
    // the console logging pub sub system
    func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys {
    	return &HTTPConsoleLoggerSys{
    		pubsub:  pubsub.New[log.Info, madmin.LogMask](8),
    		console: console.New(w),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  10. docs/distributed/CONFIG.md

    > NOTE: MinIO environmental variables still take precedence over the `config.yaml` file, however `config.yaml` is preferred over MinIO internal config KV settings via `mc admin config set alias/ <sub-system>`.
    
    ### TODO
    
    In subsequent releases we are planning to extend this to provide things like
    
    - Reload() of MinIO server arguments without fully restarting the process.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 4.2K bytes
    - Viewed (0)
Back to top