Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 212 for newHeader (0.11 sec)

  1. cni/pkg/nodeagent/podcgroupns.go

    //   - http://man7.org/linux/man-pages/man7/cgroups.7.html
    //   - https://www.kernel.org/doc/Documentation/cgroup-v2.txt
    func GetCgroups(procCgroupData bytes.Buffer) ([]Cgroup, error) {
    	reader := bytes.NewReader(procCgroupData.Bytes())
    	var cgroups []Cgroup
    	scanner := bufio.NewScanner(reader)
    
    	for scanner.Scan() {
    		token := scanner.Text()
    		substrings := strings.SplitN(token, ":", 3)
    		if len(substrings) < 3 {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 11K bytes
    - Viewed (0)
  2. cmd/metacache-stream.go

    				return err
    			}
    			return s2w.Close()
    		}
    		return nil
    	}
    }
    
    var s2DecPool = sync.Pool{New: func() interface{} {
    	// Default alloc block for network transfer.
    	return s2.NewReader(nil, s2.ReaderAllocBlock(16<<10))
    }}
    
    // metacacheReader allows reading a cache stream.
    type metacacheReader struct {
    	mr      *msgp.Reader
    	current metaCacheEntry
    	err     error // stateful error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  3. cmd/bucket-handlers.go

    	}
    	if d != "multipart/form-data" {
    		return nil, http.ErrNotMultipart
    	}
    	boundary, ok := params["boundary"]
    	if !ok {
    		return nil, http.ErrMissingBoundary
    	}
    	return multipart.NewReader(r.Body, boundary), nil
    }
    
    // PostPolicyBucketHandler - POST policy
    // ----------
    // This implementation of the POST operation handles object creation with a specified
    // signature policy in multipart/form-data
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  4. cmd/sftp-server-driver.go

    		}
    
    		dirPath := buildMinioDir(prefix)
    
    		_, err = clnt.PutObject(context.Background(), bucket, dirPath, bytes.NewReader([]byte("")), 0,
    			minio.PutObjectOptions{DisableContentSha256: true},
    		)
    		return err
    	}
    
    	return NotImplemented{}
    }
    
    type listerAt []os.FileInfo
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  5. internal/config/identity/plugin/config.go

    	RolePolicy string
    	RoleARN    arn.ARN
    }
    
    // Validate - validate configuration params.
    func (a *Args) Validate() error {
    	req, err := http.NewRequest(http.MethodPost, a.URL.String(), bytes.NewReader([]byte("")))
    	if err != nil {
    		return err
    	}
    
    	req.Header.Set("Content-Type", "application/json")
    	if a.AuthToken != "" {
    		req.Header.Set("Authorization", a.AuthToken)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. cmd/admin-handlers.go

    					CurrentVersion: Version,
    					UpdatedVersion: lrTime.Format(MinioReleaseTagTimeLayout),
    				}
    			}
    		}
    	}
    
    	if err = verifyBinary(u, sha256Sum, releaseInfo, mode, bytes.NewReader(bin)); err != nil {
    		peerResults[local] = madmin.ServerPeerUpdateStatus{
    			Host:           local,
    			Err:            err.Error(),
    			CurrentVersion: Version,
    		}
    	} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  7. internal/bucket/object/lock/lock.go

    	buf, err := io.ReadAll(io.LimitReader(reader, maxObjectLockConfigSize))
    	if err != nil {
    		return nil, err
    	}
    
    	hold = &ObjectLegalHold{}
    	if err = xml.NewDecoder(bytes.NewReader(buf)).Decode(hold); err != nil {
    		return nil, err
    	}
    
    	if !hold.Status.Valid() {
    		return nil, ErrMalformedXML
    	}
    	return
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  8. istioctl/pkg/validate/validate.go

    }
    
    func (v *validator) validateFile(path string, istioNamespace *string, defaultNamespace string, reader io.Reader, writer io.Writer,
    ) (validation.Warning, error) {
    	yamlReader := kubeyaml.NewYAMLReader(bufio.NewReader(reader))
    	var errs error
    	var warnings validation.Warning
    	for {
    		doc, err := yamlReader.Read()
    		if err == io.EOF {
    			return warnings, errs
    		}
    		if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 22:27:47 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  9. cmd/iam.go

    	if ptok && spok && pt == embeddedPolicyType {
    		policyBytes, err := base64.StdEncoding.DecodeString(sp)
    		if err != nil {
    			return UserIdentity{}, nil, err
    		}
    		embeddedPolicy, err = policy.ParseConfig(bytes.NewReader(policyBytes))
    		if err != nil {
    			return UserIdentity{}, nil, err
    		}
    	}
    
    	return sa, embeddedPolicy, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  10. cmd/metacache-set.go

    		if len(b.data) == 0 && b.n == 0 && o.Transient {
    			return nil
    		}
    		o.debugln(color.Green("saveMetaCacheStream:")+" saving block", b.n, "to", o.objectPath(b.n))
    		r, err := hash.NewReader(ctx, bytes.NewReader(b.data), int64(len(b.data)), "", "", int64(len(b.data)))
    		bugLogIf(ctx, err)
    		custom := b.headerKV()
    		_, err = er.putMetacacheObject(ctx, o.objectPath(b.n), NewPutObjReader(r), ObjectOptions{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
Back to top