Search Options

Results per page
Sort
Preferred Languages
Advance

Results 521 - 530 of 859 for err (0.07 sec)

  1. cmd/erasure-coding.go

    	if len(data) == 0 {
    		return make([][]byte, e.dataBlocks+e.parityBlocks), nil
    	}
    	encoded, err := e.encoder().Split(data)
    	if err != nil {
    		return nil, err
    	}
    	if err = e.encoder().Encode(encoded); err != nil {
    		return nil, err
    	}
    	return encoded, nil
    }
    
    // DecodeDataBlocks decodes the given erasure-coded data.
    // It only decodes the data blocks but does not verify them.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  2. internal/config/subnet/subnet.go

    	client := &http.Client{
    		Timeout:   10 * time.Second,
    		Transport: c.transport,
    	}
    
    	resp, err := client.Do(r)
    	if err != nil {
    		return "", err
    	}
    	defer xhttp.DrainBody(resp.Body)
    
    	respBytes, err := io.ReadAll(io.LimitReader(resp.Body, respBodyLimit))
    	if err != nil {
    		return "", err
    	}
    	respStr := string(respBytes)
    
    	if resp.StatusCode == http.StatusOK {
    		return respStr, nil
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Feb 27 16:35:36 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  3. cmd/bucket-listobjects-handlers.go

    	// marshaled into S3 compatible XML header.
    	listObjectVersionsInfo, err := listObjectVersions(ctx, bucket, prefix, marker, versionIDMarker, delimiter, maxkeys)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	if err = DecryptETags(ctx, GlobalKMS, listObjectVersionsInfo.Objects); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  4. internal/bucket/encryption/bucket-sse-config_test.go

    	for i, tc := range testCases {
    		ssec, err := ParseBucketSSEConfig(bytes.NewReader([]byte(tc.inputXML)))
    		if tc.shouldPass && err != nil {
    			t.Errorf("Test case %d: Expected to succeed but got %s", i+1, err)
    		}
    
    		if !tc.shouldPass {
    			if err == nil || err != nil && err.Error() != tc.expectedErr.Error() {
    				t.Errorf("Test case %d: Expected %s but got %s", i+1, tc.expectedErr, err)
    			}
    			continue
    		}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 16 18:28:30 UTC 2022
    - 6.1K bytes
    - Viewed (0)
  5. internal/arn/arn_test.go

    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			gotArn, err := Parse(tt.args.arnStr)
    			if err == nil && tt.wantErr {
    				t.Errorf("Parse() error = %v, wantErr %v", err, tt.wantErr)
    			}
    			if err != nil && !tt.wantErr {
    				t.Errorf("Parse() error = %v, wantErr %v", err, tt.wantErr)
    			}
    			if err == nil {
    				if !reflect.DeepEqual(gotArn, tt.wantArn) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 04 08:31:34 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  6. cmd/metrics-v3-cluster-usage.go

    //
    // This is a `MetricsLoaderFn`.
    func loadClusterUsageObjectMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	dataUsageInfo, err := c.dataUsageInfo.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    		return nil
    	}
    
    	// data usage has not captured any data yet.
    	if dataUsageInfo.LastUpdate.IsZero() {
    		return nil
    	}
    
    	var (
    		clusterSize               uint64
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Jul 14 18:11:42 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  7. cmd/handler-utils_test.go

    func TestIsValidLocationConstraint(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		t.Fatal(err)
    	}
    
    	// Corrupted XML
    	malformedReq := &http.Request{
    		Body:          io.NopCloser(bytes.NewReader([]byte("<>"))),
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  8. internal/etag/etag.go

    	}
    	if len(suffix) <= 1 {
    		return nil, errors.New("etag: suffix is not a part number")
    	}
    
    	etag, err := hex.DecodeString(prefix)
    	if err != nil {
    		return nil, err
    	}
    	partNumber, err := strconv.Atoi(suffix[1:]) // suffix[0] == '-' Therefore, we start parsing at suffix[1]
    	if err != nil {
    		return nil, err
    	}
    	if strict && (partNumber == 0 || partNumber > 10000) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Mar 10 21:09:36 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/lifecycle.go

    				break
    			}
    			return err
    		}
    
    		if se, ok := t.(xml.StartElement); ok {
    			switch se.Name.Local {
    			case "Rule":
    				var r Rule
    				if err = d.DecodeElement(&r, &se); err != nil {
    					return err
    				}
    				lc.Rules = append(lc.Rules, r)
    			case "ExpiryUpdatedAt":
    				var t time.Time
    				if err = d.DecodeElement(&t, &start); err != nil {
    					return err
    				}
    				lc.ExpiryUpdatedAt = &t
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  10. src/archive/zip/register.go

    func (w *pooledFlateWriter) Write(p []byte) (n int, err error) {
    	w.mu.Lock()
    	defer w.mu.Unlock()
    	if w.fw == nil {
    		return 0, errors.New("Write after Close")
    	}
    	return w.fw.Write(p)
    }
    
    func (w *pooledFlateWriter) Close() error {
    	w.mu.Lock()
    	defer w.mu.Unlock()
    	var err error
    	if w.fw != nil {
    		err = w.fw.Close()
    		flateWriterPool.Put(w.fw)
    		w.fw = nil
    	}
    	return err
    }
    
    var flateReaderPool sync.Pool
    
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Oct 13 18:36:46 UTC 2023
    - 3.7K bytes
    - Viewed (0)
Back to top