Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 81 for qsub (0.15 sec)

  1. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Nov 28 19:22:29 GMT 2023
    - 7.3K bytes
    - Viewed (0)
  2. cmd/config-current.go

    		}
    	}
    	return nil
    }
    
    // Help - return sub-system level help
    type Help struct {
    	SubSys          string         `json:"subSys"`
    	Description     string         `json:"description"`
    	MultipleTargets bool           `json:"multipleTargets"`
    	KeysHelp        config.HelpKVS `json:"keysHelp"`
    }
    
    // GetHelp - returns help for sub-sys, a key for a sub-system or all the help.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 30.9K bytes
    - Viewed (0)
  3. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Dec 22 00:56:55 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  4. internal/mountinfo/mountinfo_windows.go

    package mountinfo
    
    import (
    	"path/filepath"
    	"sync"
    
    	"golang.org/x/sys/windows"
    )
    
    // CheckCrossDevice - check if any input path has multiple sub-mounts.
    // this is a dummy function and returns nil for now.
    func CheckCrossDevice(paths []string) error {
    	return nil
    }
    
    // mountPointCache contains results of IsLikelyMountPoint
    var mountPointCache sync.Map
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Aug 19 01:35:22 GMT 2021
    - 2K bytes
    - Viewed (0)
  5. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.3K bytes
    - Viewed (0)
  6. cmd/sts-datatypes.go

    	// the user and the application that acquired the WebIdentityToken (pairwise identifier).
    	// For OpenID Connect ID tokens, this field contains the value returned by the identity
    	// provider as the token's sub (Subject) claim.
    	SubjectFromWebIdentityToken string `xml:",omitempty"`
    }
    
    // AssumeRoleWithClientGrantsResponse contains the result of successful AssumeRoleWithClientGrants request.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri May 27 00:58:09 GMT 2022
    - 9.9K bytes
    - Viewed (0)
  7. internal/grid/grid_test.go

    	register := func(manager *Manager) {
    		errFatal(handler.Register(manager, func(ctx context.Context, pp *testRequest, in <-chan *testRequest, out chan<- *testResponse) *RemoteErr {
    			sub := GetSubroute(ctx)
    			if sub != "subroute/1" {
    				t.Fatal("expected subroute/1, got", sub)
    			}
    			n := 0
    			for i := range in {
    				if n > payloads {
    					panic("too many requests")
    				}
    
    				// t.Log("Got request:", *i)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 08 18:15:27 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  8. docs/sts/web-identity.go

    				if !oauth2Token.Valid() {
    					return nil, errors.New("invalid token")
    				}
    
    				return &credentials.WebIdentityToken{
    					Token:  oauth2Token.Extra("id_token").(string),
    					Expiry: int(oauth2Token.Expiry.Sub(time.Now().UTC()).Seconds()),
    				}, nil
    			}
    		}
    
    		sts, err := credentials.NewSTSWebIdentity(stsEndpoint, getWebTokenExpiry)
    		if err != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri May 19 09:13:33 GMT 2023
    - 7.8K bytes
    - Viewed (3)
  9. cmd/common-main.go

    	var downloadURL string
    	if lrTime.After(currentReleaseTime) {
    		older = lrTime.Sub(currentReleaseTime)
    		downloadURL = getDownloadURL(releaseTimeToReleaseTag(lrTime))
    	}
    
    	updateMsg := prepareUpdateMessage(downloadURL, older)
    	if updateMsg == "" {
    		return
    	}
    
    	logger.Info(prepareUpdateMessage("Run `mc admin update ALIAS`", lrTime.Sub(currentReleaseTime)))
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Apr 17 00:34:45 GMT 2024
    - 35.5K bytes
    - Viewed (2)
  10. cmd/bucket-object-lock.go

    	}
    
    	// Pass in relative days from current time, to additionally
    	// to verify "object-lock-remaining-retention-days" policy if any.
    	days := int(math.Ceil(math.Abs(objRetention.RetainUntilDate.Sub(t).Hours()) / 24))
    
    	ret := objectlock.GetObjectRetentionMeta(oi.UserDefined)
    	if ret.Mode.Valid() {
    		// Retention has expired you may change whatever you like.
    		if ret.RetainUntilDate.Before(t) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.3K bytes
    - Viewed (0)
Back to top