Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 208 for newHeader (0.08 sec)

  1. cmd/object-multipart-handlers.go

    		encodedSuccessResponse := encodeResponse(response)
    
    		// Write success response.
    		writeSuccessResponseXML(w, encodedSuccessResponse)
    		return
    	}
    
    	actualPartSize = length
    	var reader io.Reader = etag.NewReader(ctx, gr, nil, nil)
    
    	mi, err := objectAPI.GetMultipartInfo(ctx, dstBucket, dstObject, uploadID, dstOpts)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  2. cmd/erasure-decode_test.go

    		for i, disk := range disks {
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(test.data), writeAlgorithm, erasure.ShardSize())
    		}
    		n, 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 erasure test file: %v", i, err)
    		}
    		if n != test.data {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  3. internal/s3select/select_benchmark_test.go

    `)
    
    	csvData := genSampleCSVData(count)
    
    	b.ResetTimer()
    	b.ReportAllocs()
    	b.SetBytes(int64(count))
    
    	b.RunParallel(func(pb *testing.PB) {
    		for pb.Next() {
    			s3Select, err := NewS3Select(bytes.NewReader(requestXML))
    			if err != nil {
    				b.Fatal(err)
    			}
    
    			if err = s3Select.Open(newBytesRSC(csvData)); err != nil {
    				b.Fatal(err)
    			}
    
    			s3Select.Evaluate(&nullResponseWriter{})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 14 13:54:47 UTC 2022
    - 5K bytes
    - Viewed (0)
  4. cmd/bucket-policy-handlers.go

    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	bucketPolicy, err := policy.ParseBucketPolicyConfig(bytes.NewReader(bucketPolicyBytes), bucket)
    	if err != nil {
    		writeErrorResponse(ctx, w, APIError{
    			Code:           "MalformedPolicy",
    			HTTPStatusCode: http.StatusBadRequest,
    			Description:    err.Error(),
    		}, r.URL)
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-rebalance.go

    		parts := make([]CompletePart, len(oi.Parts))
    		for i, part := range oi.Parts {
    			hr, err := hash.NewReader(ctx, io.LimitReader(gr, part.Size), part.Size, "", "", part.ActualSize)
    			if err != nil {
    				return fmt.Errorf("rebalanceObject: hash.NewReader() %w", err)
    			}
    			pi, err := z.PutObjectPart(ctx, bucket, oi.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
    - 28.4K bytes
    - Viewed (0)
  6. src/cmd/asm/internal/lex/lex.go

    	tokens []Token  // Body of macro.
    }
    
    // Tokenize turns a string into a list of Tokens; used to parse the -D flag and in tests.
    func Tokenize(str string) []Token {
    	t := NewTokenizer("command line", strings.NewReader(str), nil)
    	var tokens []Token
    	for {
    		tok := t.Next()
    		if tok == scanner.EOF {
    			break
    		}
    		tokens = append(tokens, Make(tok, t.Text()))
    	}
    	return tokens
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 18:31:05 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  7. src/bufio/bufio.go

    	b, ok := rd.(*Reader)
    	if ok && len(b.buf) >= size {
    		return b
    	}
    	r := new(Reader)
    	r.reset(make([]byte, max(size, minReadBufferSize)), rd)
    	return r
    }
    
    // NewReader returns a new [Reader] whose buffer has the default size.
    func NewReader(rd io.Reader) *Reader {
    	return NewReaderSize(rd, defaultBufSize)
    }
    
    // Size returns the size of the underlying buffer in bytes.
    func (b *Reader) Size() int { return len(b.buf) }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
  8. cmd/bucket-lifecycle_test.go

    			expectedErr: nil,
    		},
    	}
    	for i, tc := range testCases {
    		lc, err := lifecycle.ParseLifecycleConfig(bytes.NewReader(tc.xml))
    		if err != nil {
    			t.Fatalf("Test %d: Failed to parse lifecycle config %v", i+1, err)
    		}
    
    		err = validateTransitionTier(lc)
    		if err != tc.expectedErr {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 31 09:57:57 UTC 2022
    - 7K bytes
    - Viewed (0)
  9. internal/disk/stat_linux.go

    	}
    	return
    }
    
    func readStat(fileName string) (stats []uint64, err error) {
    	file, err := os.Open(fileName)
    	if err != nil {
    		return nil, err
    	}
    	defer file.Close()
    
    	s, err := bufio.NewReader(file).ReadString('\n')
    	if err != nil && !errors.Is(err, io.EOF) {
    		return nil, err
    	}
    	statLine := strings.TrimSpace(s)
    	for _, token := range strings.Fields(statLine) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  10. cmd/erasure-healing-common_test.go

    		t.Fatal(err)
    	}
    
    	for i, test := range testCases {
    		test := test
    		t.Run(fmt.Sprintf("case-%d", i), func(t *testing.T) {
    			_, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(data), int64(len(data)), "", ""), ObjectOptions{})
    			if err != nil {
    				t.Fatalf("Failed to putObject %v", err)
    			}
    
    			partsMetadata, errs := readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
Back to top