Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for WithDecoderConcurrency (0.19 sec)

  1. cmd/data-usage-cache.go

    	switch ver {
    	case dataUsageCacheVerV1:
    		return errors.New("cache version deprecated (will autoupdate)")
    	case dataUsageCacheVerV2:
    		// Zstd compressed.
    		dec, err := zstd.NewReader(r, zstd.WithDecoderConcurrency(2))
    		if err != nil {
    			return err
    		}
    		defer dec.Close()
    
    		dold := &dataUsageCacheV2{}
    		if err = dold.DecodeMsg(msgp.NewReader(dec)); err != nil {
    			return err
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  2. internal/s3select/progress.go

    			pbzip2.BZConcurrencyPool(bz2Limiter),
    		))
    		pr.closer = &nopReadCloser{fn: cancel}
    	case zstdType:
    		// Set a max window of 64MB. More than reasonable.
    		zr, err := zstd.NewReader(scannedReader, zstd.WithDecoderConcurrency(2), zstd.WithDecoderMaxWindow(64<<20))
    		if err != nil {
    			return nil, errInvalidCompression(err, compType)
    		}
    		r = zr
    		pr.closer = zr.IOReadCloser()
    	case lz4Type:
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Oct 18 15:44:36 GMT 2021
    - 4.2K bytes
    - Viewed (0)
Back to top