Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 212 for newHeader (0.18 sec)

  1. cmd/erasure-server-pool-decom.go

    		parts := make([]CompletePart, len(objInfo.Parts))
    		for i, part := range objInfo.Parts {
    			hr, err := hash.NewReader(ctx, io.LimitReader(gr, part.Size), part.Size, "", "", part.ActualSize)
    			if err != nil {
    				return fmt.Errorf("decommissionObject: hash.NewReader() %w", err)
    			}
    			pi, err := z.PutObjectPart(ctx, bucket, objInfo.Name, res.UploadID,
    				part.Number,
    				NewPutObjReader(hr),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  2. cmd/streaming-signature-v4.go

    		for _, key := range trailers {
    			req.Trailer.Add(key, "")
    		}
    	} else {
    		req.Trailer = nil
    	}
    	return &s3ChunkedReader{
    		trailers:          req.Trailer,
    		reader:            bufio.NewReader(req.Body),
    		cred:              cred,
    		seedSignature:     seedSignature,
    		seedDate:          seedDate,
    		region:            region,
    		chunkSHA256Writer: sha256.New(),
    		buffer:            make([]byte, 64*1024),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  3. cmd/erasure-heal_test.go

    		for i, disk := range disks {
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "testobject", erasure.ShardFileSize(test.size), test.algorithm, erasure.ShardSize())
    		}
    		_, err = erasure.Encode(context.Background(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1)
    		closeBitrotWriters(writers)
    		if err != nil {
    			t.Fatalf("Test %d: failed to create random test data: %v", i, err)
    		}
    
    		readers := make([]io.ReaderAt, len(disks))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  4. cmd/batch-handlers.go

    	if err != nil {
    		return err
    	}
    
    	ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
    	defer cancel()
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost, endpoint, bytes.NewReader(buf))
    	if err != nil {
    		return err
    	}
    
    	if token != "" {
    		req.Header.Set("Authorization", token)
    	}
    	req.Header.Set("Content-Type", "application/json")
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  5. cmd/encryption-v1_test.go

    		},
    	},
    }
    
    func TestEncryptRequest(t *testing.T) {
    	defer func(flag bool) { globalIsTLS = flag }(globalIsTLS)
    	globalIsTLS = true
    	for i, test := range encryptRequestTests {
    		content := bytes.NewReader(make([]byte, 64))
    		req := &http.Request{Header: http.Header{}}
    		for k, v := range test.header {
    			req.Header.Set(k, v)
    		}
    		_, _, err := EncryptRequest(content, req, "bucket", "object", test.metadata)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 24 04:17:08 UTC 2022
    - 19.9K bytes
    - Viewed (0)
  6. cmd/bucket-lifecycle-handlers_test.go

    		rec := httptest.NewRecorder()
    		// construct HTTP request
    		req, err := newTestSignedRequestV4(testCase.method, getBucketLifecycleURL("", testCase.bucketName),
    			int64(len(testCase.body)), bytes.NewReader(testCase.body), testCase.accessKey, testCase.secretKey, nil)
    		if err != nil {
    			t.Fatalf("Test %d: %s: Failed to create HTTP request for GetBucketLocationHandler: <ERROR> %v", i+1, instanceType, err)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  7. cmd/object-handlers.go

    		compressMetadata[ReservedMetadataPrefix+"compression"] = compressionAlgorithmV2
    		compressMetadata[ReservedMetadataPrefix+"actual-size"] = strconv.FormatInt(actualSize, 10)
    
    		reader = etag.NewReader(ctx, reader, nil, nil)
    		wantEncryption := crypto.Requested(r.Header)
    		s2c, cb := newS2CompressReader(reader, actualSize, wantEncryption)
    		dstOpts.IndexCB = cb
    		defer s2c.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  8. cmd/signature-v4-utils.go

    		payload, err := io.ReadAll(io.LimitReader(r.Body, stsRequestBodyLimit))
    		if err != nil {
    			logger.CriticalIf(GlobalContext, err)
    		}
    		sum256 := sha256.Sum256(payload)
    		r.Body = io.NopCloser(bytes.NewReader(payload))
    		return hex.EncodeToString(sum256[:])
    	}
    
    	var (
    		defaultSha256Cksum string
    		v                  []string
    		ok                 bool
    	)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  9. src/archive/tar/tar_test.go

    	}
    	if _, err := tw.Write(data); err != nil {
    		t.Fatalf("tw.Write: %v", err)
    	}
    	if err := tw.Close(); err != nil {
    		t.Fatalf("tw.Close: %v", err)
    	}
    
    	// Read it back.
    	tr := NewReader(&b)
    	rHdr, err := tr.Next()
    	if err != nil {
    		t.Fatalf("tr.Next: %v", err)
    	}
    	if !reflect.DeepEqual(rHdr, hdr) {
    		t.Errorf("Header mismatch.\n got %+v\nwant %+v", rHdr, hdr)
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  10. docs/debugging/xl-meta/main.go

    			}
    			filemap[file] = make(map[string]string)
    			buf := bytes.NewBuffer(nil)
    			v0 := ""
    			var data xlMetaInlineData
    			switch minor {
    			case 0:
    				_, err = msgp.CopyToJSON(buf, bytes.NewReader(b))
    				if err != nil {
    					return nil, err
    				}
    			case 1, 2:
    				v, b, err := msgp.ReadBytesZC(b)
    				if err != nil {
    					return nil, err
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
Back to top