held - Code Search

okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

    assertThat(server.takeRequest().sequenceNumber).isEqualTo(1)
    assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)

    // Let the first request proceed. It should discard the the held HTTP/2 connection and get a new
    // one.
    latch.countDown()
    val response3 = responses.take()
    assertThat(response3).isEqualTo("ABC")
    assertThat(server.takeRequest().sequenceNumber).isEqualTo(1)

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Thu Apr 11 22:09:35 UTC 2024

- 75.3K bytes

- Viewed (0)

github.com/square/okhttp

docs/changelogs/changelog_3x.md

    closing it doesn't also close the underlying stream. We had a bug where
    OkHttp would attempt to reuse a connection but couldn't because it was still
    held by a prior request.
 *  Fix: Ensure network interceptors always have access to the underlying
    connection.
 *  Fix: Use `X509TrustManagerExtensions` on Android 17+.

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Sun Feb 06 14:55:54 UTC 2022

- 50.8K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/collect/MapMakerInternalMap.java

        // proceed. So we cannot yet null out each bin.
        E head = oldTable.get(oldIndex);

        if (head != null) {
          E next = head.getNext();
          int headIndex = head.getHash() & newMask;

          // Single node on list
          if (next == null) {
            newTable.set(headIndex, head);
          } else {

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri Oct 18 20:24:49 UTC 2024

- 90.8K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/help.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
<html>
<head profile="http://a9.com/-/spec/opensearch/1.1/">
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<title><la:message key="labels.search_title" /></title>
<link href="${fe:url('/css/bootstrap.min.css')}" rel="stylesheet"
	type="text/css" />

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Sat Oct 26 01:07:52 UTC 2024

- 1.4K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/help.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
<html>
<head profile="http://a9.com/-/spec/opensearch/1.1/">
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<title><la:message key="labels.search_title" /></title>
<link href="${fe:url('/css/bootstrap.min.css')}" rel="stylesheet"
	type="text/css" />

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Sat Oct 26 01:07:52 UTC 2024

- 1.4K bytes

- Viewed (0)

github.com/minio/minio

internal/config/help.go

	Secret bool `json:"-"`

	// Indicates if sub-sys supports multiple targets.
	MultipleTargets bool `json:"multipleTargets"`
}

// HelpKVS - implement order of keys help messages.
type HelpKVS []HelpKV

// Lookup - lookup a key from help kvs.
func (hkvs HelpKVS) Lookup(key string) (HelpKV, bool) {
	for _, hkv := range hkvs {
		if hkv.Key == key {
			return hkv, true
		}
	}
	return HelpKV{}, false
}

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Fri Jun 23 14:45:27 UTC 2023

- 2.8K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/collect/MapMakerInternalMap.java

        // proceed. So we cannot yet null out each bin.
        E head = oldTable.get(oldIndex);

        if (head != null) {
          E next = head.getNext();
          int headIndex = head.getHash() & newMask;

          // Single node on list
          if (next == null) {
            newTable.set(headIndex, head);
          } else {

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri Oct 18 20:24:49 UTC 2024

- 90.8K bytes

- Viewed (0)

github.com/minio/minio

internal/config/ilm/help.go

)

var (
	defaultHelpPostfix = func(key string) string {
		return config.DefaultHelpPostfix(DefaultKVS, key)
	}

	// Help holds configuration keys and their default values for the ILM
	// subsystem
	Help = config.HelpKVS{
		config.HelpKV{
			Key:         transitionWorkers,
			Type:        "number",

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Thu May 30 08:14:58 UTC 2024

- 1.8K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure-server-pool.go

	if err := checkPutObjectPartArgs(ctx, bucket, object, uploadID); err != nil {
		return PartInfo{}, err
	}

	// Read lock for upload id.
	// Only held while reading the upload metadata.
	uploadIDRLock := z.NewNSLock(bucket, pathJoin(object, uploadID))
	rlkctx, err := uploadIDRLock.GetRLock(ctx, globalOperationTimeout)
	if err != nil {
		return PartInfo{}, err
	}

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Sun Sep 29 22:40:36 UTC 2024

- 89.8K bytes

- Viewed (0)

github.com/minio/minio

internal/config/compress/help.go

package compress

import "github.com/minio/minio/internal/config"

// Help template for compress feature.
var (
	defaultHelpPostfix = func(key string) string {
		return config.DefaultHelpPostfix(DefaultKVS, key)
	}

	Help = config.HelpKVS{
		config.HelpKV{
			Key:         config.Enable,
			Description: "Enable or disable object compression",

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Sun Jul 17 15:43:14 UTC 2022

- 1.8K bytes

- Viewed (0)

Search Options