Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 96 for flags (0.17 sec)

  1. internal/grid/msg.go

    	}
    	if f&FlagSubroute != 0 {
    		res = append(res, "SUB")
    	}
    	return "[" + strings.Join(res, ",") + "]"
    }
    
    // Set one or more flags on f.
    func (f *Flags) Set(flags Flags) {
    	*f |= flags
    }
    
    // Clear one or more flags on f.
    func (f *Flags) Clear(flags Flags) {
    	*f &^= flags
    }
    
    // parse an incoming message.
    func (m *message) parse(b []byte) (*subHandlerID, []byte, error) {
    	var sub *subHandlerID
    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)
  2. internal/mountinfo/mountinfo_linux_test.go

    // and success cases.
    func TestCrossDeviceMountPaths(t *testing.T) {
    	successCase := `/dev/0 /path/to/0/1 type0 flags 0 0
    		/dev/1    /path/to/1   type1	flags 1 1
    		/dev/2 /path/to/1/2 type2 flags,1,2=3 2 2
                    /dev/3 /path/to/1.1 type3 flags,1,2=3 3 3
    		`
    	var err error
    	dir := t.TempDir()
    	mountsPath := filepath.Join(dir, "mounts")
    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)
  3. cmd/batch-rotate.go

    		}
    
    		if r.Flags.Filter.NewerThan > 0 && time.Since(info.ModTime) >= r.Flags.Filter.NewerThan {
    			// skip all objects that are older than specified newer duration
    			return false
    		}
    
    		if !r.Flags.Filter.CreatedAfter.IsZero() && r.Flags.Filter.CreatedAfter.Before(info.ModTime) {
    			// skip all objects that are created before the specified time.
    			return false
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  4. operator/cmd/mesh/manifest_shared_test.go

    	return err
    }
    
    // runManifestCommand runs the given manifest command. If filenames is set, passes the given filenames as -f flag,
    // flags is passed to the command verbatim. If you set both flags and path, make sure to not use -f in flags.
    func runManifestCommand(command string, filenames []string, flags string, chartSource chartSourceType, fileSelect []string) (string, error) {
    	var args string
    	if command == "install" {
    		args = "install"
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Feb 20 22:39:28 GMT 2024
    - 11.7K bytes
    - Viewed (1)
  5. internal/grid/muxclient.go

    	}
    	m.init = true
    	m.singleResp = true
    	msg := message{
    		Op:         OpRequest,
    		MuxID:      m.MuxID,
    		Handler:    h,
    		Flags:      m.BaseFlags | FlagEOF,
    		Payload:    req,
    		DeadlineMS: uint32(m.deadline.Milliseconds()),
    	}
    	if m.subroute != nil {
    		msg.Flags |= FlagSubroute
    	}
    	ch := make(chan Response, 1)
    	m.respMu.Lock()
    	if m.closed {
    		m.respMu.Unlock()
    		return nil, ErrDisconnected
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  6. cmd/admin-router.go

    // this behavior.
    func adminMiddleware(f http.HandlerFunc, flags ...hFlag) http.HandlerFunc {
    	// Collect all flags with bitwise-OR and assign operator
    	var handlerFlags hFlag
    	for _, flag := range flags {
    		handlerFlags |= flag
    	}
    
    	// Get name of the handler using reflection.
    	handlerName := getHandlerName(f, "adminAPIHandlers")
    
    	var handler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  7. cmd/api-router.go

    // `traceHdrsS3HFlag`, otherwise both headers and body will be traced, causing
    // high memory usage!
    func s3APIMiddleware(f http.HandlerFunc, flags ...s3HFlag) http.HandlerFunc {
    	// Collect all flags with bitwise-OR and assign operator
    	var handlerFlags s3HFlag
    	for _, flag := range flags {
    		handlerFlags |= flag
    	}
    
    	// Get name of the handler using reflection.
    	handlerName := getHandlerName(f, "objectAPIHandlers")
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 22.8K bytes
    - Viewed (0)
  8. internal/grid/connection.go

    // queueMsg queues a message, with an optional payload.
    // sender should not reference msg.Payload
    func (c *Connection) queueMsg(msg message, payload sender) error {
    	// Add baseflags.
    	msg.Flags.Set(c.baseFlags)
    	// This cannot encode subroute.
    	msg.Flags.Clear(FlagSubroute)
    	if payload != nil {
    		if sz := payload.Msgsize(); cap(msg.Payload) < sz {
    			PutByteBuffer(msg.Payload)
    			msg.Payload = GetByteBufferCap(sz)
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  9. operator/cmd/mesh/profile-dump.go

    	// manifestsPath is a path to a charts and profiles directory in the local filesystem with a release tgz.
    	manifestsPath string
    }
    
    const (
    	jsonOutput  = "json"
    	yamlOutput  = "yaml"
    	flagsOutput = "flags"
    )
    
    const (
    	istioOperatorTreeString = `
    apiVersion: install.istio.io/v1alpha1
    kind: IstioOperator
    `
    )
    
    func addProfileDumpFlags(cmd *cobra.Command, args *profileDumpArgs) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  10. cmd/batch-replicate_gen.go

    					err = z.Flags.Filter.DecodeMsg(dc)
    					if err != nil {
    						err = msgp.WrapError(err, "Flags", "Filter")
    						return
    					}
    				case "Notify":
    					err = z.Flags.Notify.DecodeMsg(dc)
    					if err != nil {
    						err = msgp.WrapError(err, "Flags", "Notify")
    						return
    					}
    				case "Retry":
    					err = z.Flags.Retry.DecodeMsg(dc)
    					if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Nov 22 18:51:46 GMT 2023
    - 40.6K bytes
    - Viewed (0)
Back to top