Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 27 for decompressor (0.08 sec)

  1. internal/s3select/errors.go

    		statusCode: 400,
    		cause:      err,
    	}
    }
    
    func errTruncatedInput(err error) *s3Error {
    	return &s3Error{
    		code:       "TruncatedInput",
    		message:    "Object decompression failed. Check that the object is properly compressed using the format specified in the request.",
    		statusCode: 400,
    		cause:      err,
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 14 16:48:36 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  2. docs/features/calls.md

    ## Rewriting Responses
    
    If transparent compression was used, OkHttp will drop the corresponding response headers `Content-Encoding` and `Content-Length` because they don’t apply to the decompressed response body.
    
    If a conditional GET was successful, responses from the network and cache are merged as directed by the spec.
    
    ## Follow-up Requests
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  3. docs/compression/README.md

    This algorithm is specifically optimized for machine generated content.
    Write throughput is typically at least 500MB/s per CPU core,
    and scales with the number of available CPU cores.
    Decompression speed is typically at least 1GB/s.
    
    This means that in cases where raw IO is below these numbers
    compression will not only reduce disk usage but also help increase system throughput.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 11 11:55:34 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  4. cmd/typed-errors.go

    // error returned by first disk waiting to initialize other servers.
    var errFirstDiskWait = errors.New("Waiting on other drives")
    
    // error returned for a negative actual size.
    var errInvalidDecompressedSize = errors.New("Invalid Decompressed Size")
    
    // error returned in IAM subsystem when user doesn't exist.
    var errNoSuchUser = errors.New("Specified user does not exist")
    
    // error returned by IAM when a use a builtin IDP command when they could mean
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 17:14:16 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  5. cmd/warm-backend-gcs.go

    	return gcs.PutWithMeta(ctx, key, data, length, map[string]string{})
    }
    
    func (gcs *warmBackendGCS) Get(ctx context.Context, key string, rv remoteVersionID, opts WarmBackendGetOpts) (r io.ReadCloser, err error) {
    	// GCS storage decompresses a gzipped object by default and returns the data.
    	// Refer to https://cloud.google.com/storage/docs/transcoding#decompressive_transcoding
    	// Need to set `Accept-Encoding` header to `gzip` when issuing a GetObject call, to be able
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. docs/tls/README.md

    ```
    
    ### 3.3 Use GnuTLS (for Windows) to Generate a Certificate
    
    This section describes how to use GnuTLS on Windows to generate a certificate.
    
    #### 3.3.1 Install and configure GnuTLS
    
    Download and decompress the Windows version of GnuTLS from [here](http://www.gnutls.org/download.html).
    
    Use PowerShell to add the path of the extracted GnuTLS binary to the system path:
    
    ```
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  7. docs/select/README.md

    Install `aws-sdk-python` from AWS SDK for Python official docs [here](https://aws.amazon.com/sdk-for-python/)
    
    ### 3. Example
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 6.5K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

            ),
          )
        }
        handler.windowUpdate(streamId, increment)
      }
    
      @Throws(IOException::class)
      override fun close() {
        source.close()
      }
    
      /**
       * Decompression of the header block occurs above the framing layer. This class lazily reads
       * continuation frames as they are needed by [Hpack.Reader.readHeaders].
       */
      internal class ContinuationSource(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-rebalance.go

    				NewPutObjReader(hr),
    				ObjectOptions{
    					PreserveETag: part.ETag, // Preserve original ETag to ensure same metadata.
    					IndexCB: func() []byte {
    						return part.Index // Preserve part Index to ensure decompression works.
    					},
    					NoAuditLog: true,
    				})
    			if err != nil {
    				return fmt.Errorf("rebalanceObject: PutObjectPart() %w", err)
    			}
    			parts[i] = CompletePart{
    				ETag:       pi.ETag,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  10. internal/s3select/select.go

    			s3Select.progressReader.Close()
    
    			var stErr bzip2.StructuralError
    			if errors.As(err, &stErr) {
    				return errInvalidCompression(err, s3Select.Input.CompressionType)
    			}
    			// Test these compressor errors
    			errs := []error{
    				gzip.ErrHeader, gzip.ErrChecksum,
    				s2.ErrCorrupt, s2.ErrUnsupported, s2.ErrCRC,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
Back to top