Search Options

Results per page
Sort
Preferred Languages
Advance

Results 621 - 630 of 2,442 for okhttp (0.07 sec)

  1. internal/etag/etag.go

    	return strconv.AppendInt(etag, n, 10)
    }
    
    // Set adds the ETag to the HTTP headers. It overwrites any
    // existing ETag entry.
    //
    // Due to legacy S3 clients, that make incorrect assumptions
    // about HTTP headers, Set should be used instead of
    // http.Header.Set(...). Otherwise, some S3 clients will not
    // able to extract the ETag.
    func Set(etag ETag, h http.Header) {
    	// Some (broken) S3 clients expect the ETag header to
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 21:09:36 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  2. cmd/perf-tests.go

    	}
    	result.Endpoint = rp.String()
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost, reqURL.String(), reader)
    	if err != nil {
    		result.Error = err.Error()
    		return
    	}
    	client := &http.Client{
    		Transport: globalRemoteTargetTransport,
    	}
    	resp, err := client.Do(req)
    	if err != nil {
    		result.Error = err.Error()
    		return
    	}
    	defer xhttp.DrainBody(resp.Body)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. cmd/streaming-signature-v4.go

    // out of HTTP "chunked" format before returning it.
    // The s3ChunkedReader returns io.EOF when the final 0-length chunk is read.
    //
    // NewChunkedReader is not needed by normal applications. The http package
    // automatically decodes chunking when reading response bodies.
    func newSignV4ChunkedReader(req *http.Request, trailer bool) (io.ReadCloser, APIErrorCode) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  4. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.tls.internal.der
    
    import java.math.BigInteger
    import java.net.ProtocolException
    import okio.Buffer
    import okio.BufferedSource
    import okio.ByteString
    import okio.ForwardingSource
    import okio.Source
    import okio.buffer
    
    /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.internal.idn
    
    import okio.BufferedSink
    
    /**
     * An IDNA mapping table optimized for small code and data size.
     *
     * Code Points in Sections
     * =======================
     *
     * The full range of code points is 0..0x10fffe. We can represent any of these code points with 21
     * bits.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Apr 02 11:39:58 UTC 2024
    - 9K bytes
    - Viewed (0)
  6. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Adapters.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.tls.internal.der
    
    import java.math.BigInteger
    import java.net.ProtocolException
    import java.text.ParseException
    import java.text.SimpleDateFormat
    import java.util.Date
    import java.util.TimeZone
    import kotlin.reflect.KClass
    import okio.ByteString
    
    /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 15K bytes
    - Viewed (0)
  7. cmd/encryption-v1.go

    	switch r.Method {
    	case http.MethodGet, http.MethodHead:
    		if crypto.S3.IsRequested(headers) || crypto.S3KMS.IsRequested(headers) {
    			return false, errInvalidEncryptionParameters
    		}
    	}
    
    	_, encrypted = crypto.IsEncrypted(info.UserDefined)
    	if !encrypted && crypto.SSEC.IsRequested(headers) && r.Header.Get(xhttp.AmzCopySource) == "" {
    		return false, errInvalidEncryptionParameters
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-v2_test.go

    	toBeRestored := make(map[string]string)
    	toBeRestored[xhttp.AmzRestore] = ongoingRestoreObj().String()
    
    	restored := make(map[string]string)
    	restored[xhttp.AmzRestore] = completedRestoreObj(time.Now().UTC().Add(time.Hour)).String()
    
    	restoredExpired := make(map[string]string)
    	restoredExpired[xhttp.AmzRestore] = completedRestoreObj(time.Now().UTC().Add(-time.Hour)).String()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  9. cmd/erasure-object.go

    		userDefined["content-type"] = mimedb.TypeByExtension(path.Ext(object))
    	}
    
    	// if storageClass is standard no need to save it as part of metadata.
    	if userDefined[xhttp.AmzStorageClass] == storageclass.STANDARD {
    		delete(userDefined, xhttp.AmzStorageClass)
    	}
    
    	// Fill all the necessary metadata.
    	// Update `xl.meta` content on each disks.
    	for index := range partsMetadata {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  10. cmd/iam.go

    		NewHTTPTransport(), xhttp.DrainBody, globalSite.Region())
    	if err != nil {
    		iamLogIf(ctx, fmt.Errorf("Unable to initialize AuthNPlugin: %w", err), logger.WarningKind)
    	}
    
    	setGlobalAuthNPlugin(idplugin.New(GlobalContext, authNPluginCfg))
    
    	authZPluginCfg, err := polplugin.LookupConfig(s, GetDefaultConnSettings(), xhttp.DrainBody)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
Back to top