Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for newBuffer (0.06 sec)

  1. cmd/bucket-metadata.go

    	if err != nil {
    		return
    	}
    
    	outbuf := bytes.NewBuffer(nil)
    	objectKey := crypto.GenerateKey(key.Plaintext, rand.Reader)
    	sealedKey := objectKey.Seal(key.Plaintext, crypto.GenerateIV(rand.Reader), crypto.S3.String(), bucket, "")
    	crypto.S3.CreateMetadata(metadata, key.KeyID, key.Ciphertext, sealedKey)
    	_, err = sio.Encrypt(outbuf, bytes.NewBuffer(input), sio.Config{Key: objectKey[:], MinVersion: sio.Version20})
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 16 14:27:42 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  2. cmd/admin-handlers-users_test.go

    	_, err := client.PutObject(ctx, bucket, "some-object", bytes.NewBuffer([]byte("stuff")), 5, minio.PutObjectOptions{})
    	if err != nil {
    		c.Fatalf("upload did not succeed got %#v", err)
    	}
    }
    
    func (c *check) mustNotUpload(ctx context.Context, client *minio.Client, bucket string) {
    	c.Helper()
    	_, err := client.PutObject(ctx, bucket, "some-object", bytes.NewBuffer([]byte("stuff")), 5, minio.PutObjectOptions{})
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 47.4K bytes
    - Viewed (0)
  3. cmd/erasure-decode_test.go

    			bitrotReaders[index] = newBitrotReader(disk, nil, "testbucket", "object", tillOffset, writeAlgorithm, bitrotWriterSum(writers[index]), erasure.ShardSize())
    		}
    
    		writer := bytes.NewBuffer(nil)
    		_, err = erasure.Decode(t.Context(), writer, bitrotReaders, test.offset, test.length, test.data, nil)
    		closeBitrotReaders(bitrotReaders)
    		if err != nil && !test.shouldFail {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21K bytes
    - Viewed (0)
  4. docs/debugging/xl-meta/main.go

    			if err != nil {
    				return nil, err
    			}
    			b, _, minor, err := checkXL2V1(b)
    			if err != nil {
    				return nil, err
    			}
    			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:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 40.3K bytes
    - Viewed (0)
  5. cmd/object_api_suite_test.go

    	for i := 1; i <= 10; i++ {
    		expectedETaghex := getMD5Hash(data)
    
    		var calcPartInfo PartInfo
    		calcPartInfo, err = obj.PutObjectPart(context.Background(), "bucket", "key", uploadID, i, mustGetPutObjReader(t, bytes.NewBuffer(data), int64(len(data)), expectedETaghex, ""), opts)
    		if err != nil {
    			t.Errorf("%s: <ERROR> %s", instanceType, err)
    		}
    		if calcPartInfo.ETag != expectedETaghex {
    			t.Errorf("MD5 Mismatch")
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  6. cmd/object-api-utils.go

    		}
    	}
    	const skip = 2<<20 + 511
    	r, _ := newS2CompressReader(bytes.NewBuffer(data), int64(len(data)), true)
    	b, err := io.ReadAll(r)
    	failOnErr(err)
    	failOnErr(r.Close())
    	// Decompression reader.
    	s2Reader := s2.NewReader(bytes.NewBuffer(b))
    	// Apply the skipLen on the decompressed stream.
    	failOnErr(s2Reader.Skip(skip))
    	got, err := io.ReadAll(s2Reader)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jun 25 15:08:54 UTC 2025
    - 37.3K bytes
    - Viewed (0)
  7. cmd/erasure-healing.go

    				partPath := pathJoin(tmpID, dstDataDir, fmt.Sprintf("part.%d", partNumber))
    				if len(inlineBuffers) > 0 {
    					buf := grid.GetByteBufferCap(int(erasure.ShardFileSize(latestMeta.Size)) + 64)
    					inlineBuffers[i] = bytes.NewBuffer(buf[:0])
    					defer grid.PutByteBuffer(buf)
    
    					writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize())
    				} else {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  8. cmd/erasure-object_test.go

    		t.Fatal(err)
    	}
    	gr, err := obj.GetObjectNInfo(ctx, bucket, object, nil, nil, ObjectOptions{})
    	if err != nil {
    		t.Fatalf("Expected GetObject to succeed, but failed with %v", err)
    	}
    	output := bytes.NewBuffer([]byte{})
    	_, err = io.Copy(output, gr)
    	if err != nil {
    		t.Fatalf("Expected GetObject reading data to succeed, but failed with %v", err)
    	}
    	gr.Close()
    	if !bytes.Equal(output.Bytes(), smallData) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (0)
Back to top