Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 208 for newHeader (0.1 sec)

  1. 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)
  2. internal/rest/client.go

    	if body != nil {
    		switch v := body.(type) {
    		case *bytes.Buffer:
    			req.ContentLength = int64(v.Len())
    			buf := v.Bytes()
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := bytes.NewReader(buf)
    				return io.NopCloser(r), nil
    			}
    		case *bytes.Reader:
    			req.ContentLength = int64(v.Len())
    			snapshot := *v
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := snapshot
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  3. cmd/metacache-stream_test.go

    func loadMetacacheSample(t testing.TB) *metacacheReader {
    	b, err := os.ReadFile("testdata/metacache.s2")
    	if err != nil {
    		t.Fatal(err)
    	}
    	return newMetacacheReader(bytes.NewReader(b))
    }
    
    func loadMetacacheSampleEntries(t testing.TB) metaCacheEntriesSorted {
    	r := loadMetacacheSample(t)
    	defer r.Close()
    	entries, err := r.readN(-1, false, true, false, "")
    	if err != io.EOF {
    		t.Fatal(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 15K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    	)
    
    	var objectSize int64
    	for _, partInfo := range objInfo.Parts {
    		if isSSEC {
    			hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.Size), partInfo.Size, "", "", partInfo.ActualSize)
    		} else {
    			hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.ActualSize), partInfo.ActualSize, "", "", partInfo.ActualSize)
    		}
    		if err != nil {
    			return err
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  5. cmd/object-api-utils.go

    			var dopts []s2.ReaderOption
    			if off > 0 || decOff > 0 {
    				// We are not starting at the beginning, so ignore stream identifiers.
    				dopts = append(dopts, s2.ReaderIgnoreStreamIdentifier())
    			}
    			s2Reader := s2.NewReader(inputReader, dopts...)
    			// Apply the skipLen and limit on the decompressed stream.
    			if decOff > 0 {
    				if err = s2Reader.Skip(decOff); err != nil {
    					// Call the cleanup funcs
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  6. doc/godebug.md

    ### Go 1.20
    
    Go 1.20 introduced support for rejecting insecure paths in tar and zip archives,
    controlled by the [`tarinsecurepath` setting](/pkg/archive/tar/#Reader.Next)
    and the [`zipinsecurepath` setting](/pkg/archive/zip/#NewReader).
    These default to `tarinsecurepath=1` and `zipinsecurepath=1`,
    preserving the behavior of earlier versions of Go.
    A future version of Go may change the defaults to
    `tarinsecurepath=0` and `zipinsecurepath=0`.
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 28 14:46:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  7. cmd/bucket-replication-handlers.go

    			return
    		}
    		if sameTarget && bucket == clnt.Bucket {
    			writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrBucketRemoteIdenticalToSource), r.URL)
    			return
    		}
    
    		reader := bytes.NewReader(buf)
    		// fake a PutObject and RemoveObject call to validate permissions
    		c := &minio.Core{Client: clnt.Client}
    		putOpts := minio.PutObjectOptions{
    			Internal: minio.AdvancedPutOptions{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  8. cmd/kms-handlers_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	testKMSPolicyName := "testKMSPolicy"
    	if p != "" {
    		p = `{"Version":"2012-10-17","Statement":[` + p + `]}`
    		policyData, err := policy.ParseConfig(strings.NewReader(p))
    		if err != nil {
    			t.Fatal(err)
    		}
    		_, err = globalIAMSys.SetPolicy(ctx, testKMSPolicyName, *policyData)
    		if err != nil {
    			t.Fatal(err)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  9. cmd/batch-expire.go

    	xioutil.SafeClose(saverQuitCh)
    
    	// Notify expire jobs final status to the configured endpoint
    	buf, _ := json.Marshal(ri)
    	if err := r.Notify(context.Background(), bytes.NewReader(buf)); err != nil {
    		batchLogIf(context.Background(), fmt.Errorf("unable to notify %v", err))
    	}
    
    	return nil
    }
    
    //msgp:ignore batchExpireJobError
    type batchExpireJobError struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  10. cmd/erasure-object.go

    			return &GetObjectReader{
    				ObjInfo: objInfo,
    			}, err
    		}
    
    		// Zero byte objects don't even need to further initialize pipes etc.
    		return NewGetObjectReaderFromReader(bytes.NewReader(nil), objInfo, opts)
    	}
    
    	if objInfo.IsRemote() {
    		gr, err := getTransitionedObjectReader(ctx, bucket, object, rs, h, objInfo, opts)
    		if err != nil {
    			return nil, err
    		}
    		unlockOnDefer = false
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top