Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 162 for newLoader (0.05 sec)

  1. cmd/erasure-healing-common.go

    		}
    
    		// Always check data, if we got it.
    		if (len(meta.Data) > 0 || meta.Size == 0) && len(meta.Parts) > 0 {
    			checksumInfo := meta.Erasure.GetChecksumInfo(meta.Parts[0].Number)
    			verifyErr := bitrotVerify(bytes.NewReader(meta.Data),
    				int64(len(meta.Data)),
    				meta.Erasure.ShardFileSize(meta.Size),
    				checksumInfo.Algorithm,
    				checksumInfo.Hash, meta.Erasure.ShardSize())
    			dataErrsByPart[0][i] = convPartErrToInt(verifyErr)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 12K bytes
    - Viewed (0)
  2. cmd/main.go

    	fmt.Fprintln(banner, color.Blue("License:")+color.Bold(" GNU AGPLv3 - https://www.gnu.org/licenses/agpl-3.0.html"))
    	fmt.Fprintln(banner, color.Blue("Copyright:")+color.Bold(" 2015-%s MinIO, Inc.", CopyrightYear))
    	return strings.NewReader(banner.String())
    }
    
    func printMinIOVersion(c *cli.Context) {
    	io.Copy(c.App.Writer, versionBanner(c))
    }
    
    var debugNoExit = env.Get("_MINIO_DEBUG_NO_EXIT", "") != ""
    
    // Main main for minio server.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Jul 30 22:59:48 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  4. cmd/common-main.go

    		logger.Fatal(err, "Unable to generate root secret key using KMS")
    	}
    
    	accessKey, err := auth.GenerateAccessKey(20, bytes.NewReader(aKey))
    	if err != nil {
    		logger.Fatal(err, "Unable to generate root access key")
    	}
    	secretKey, err := auth.GenerateSecretKey(32, bytes.NewReader(sKey))
    	if err != nil {
    		logger.Fatal(err, "Unable to generate root secret key")
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (3)
  5. cmd/bitrot-streaming.go

    		if len(b.data) == 0 && b.tillOffset != streamOffset {
    			b.rc, err = b.disk.ReadFileStream(context.TODO(), b.volume, b.filePath, streamOffset, b.tillOffset-streamOffset)
    		} else {
    			b.rc = io.NewSectionReader(bytes.NewReader(b.data), streamOffset, b.tillOffset-streamOffset)
    		}
    		if err != nil {
    			return 0, err
    		}
    	}
    	if offset != b.currOffset {
    		// Can never happen unless there are programmer bugs
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 17 19:19:30 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  6. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
  7. cmd/ftp-server-driver.go

    		return clnt.MakeBucket(context.Background(), bucket, minio.MakeBucketOptions{Region: globalSite.Region()})
    	}
    
    	dirPath := buildMinioDir(prefix)
    
    	_, err = clnt.PutObject(context.Background(), bucket, dirPath, bytes.NewReader([]byte("")), 0, minio.PutObjectOptions{
    		DisableContentSha256: true,
    	})
    	return err
    }
    
    // GetFile implements ftpDriver
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.3K bytes
    - Viewed (0)
  8. cmd/admin-handlers_test.go

    	// Test all combinations!
    	for pIdx, params := range qParamsArr {
    		for vIdx, vars := range varsArr {
    			_, err := extractHealInitParams(vars, params, bytes.NewReader([]byte(body)))
    			isErrCase := false
    			if pIdx < 4 || vIdx < 1 {
    				isErrCase = true
    			}
    
    			if err != ErrNone && !isErrCase {
    				t.Errorf("Got unexpected error: %v %v %v", pIdx, vIdx, err)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  9. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Nov 25 17:10:22 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  10. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 18.2K bytes
    - Viewed (0)
Back to top