initially - Code Search

okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt

    for (i in 0 until COUNT) {
      if (!other.isSet(i)) continue
      set(i, other[i])
    }
  }

  companion object {
    /**
     * From the HTTP/2 specs, the default initial window size for all streams is 64 KiB. (Chrome 25
     * uses 10 MiB).
     */
    const val DEFAULT_INITIAL_WINDOW_SIZE = 65535

    /** HTTP/2: Size in bytes of the table used to decode the sender's header blocks. */

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

- Last Modified: Mon Jan 08 01:13:22 UTC 2024

- 3.8K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/ServerMessageBlock.java

     * but an implemantation that encorporates the transport header(for
     * efficiency) might use a different initial bufferIndex. For example,
     * to eliminate copying data when writing NbtSession data one might
     * manage that 4 byte header specifically and therefore the initial
     * bufferIndex, and thus headerStart, would be 4).(NOTE: If one where

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Fri Mar 22 21:10:40 UTC 2019

- 21K bytes

- Viewed (0)

github.com/istio/istio

licenses/github.com/hashicorp/go-version/LICENSE

1.4. “Covered Software”

     means Source Code Form to which the initial Contributor has attached the
     notice in Exhibit A, the Executable Form of such Source Code Form, and
     Modifications of such Source Code Form, in each case including portions
     thereof.

1.5. “Incompatible With Secondary Licenses”
     means

     a. that the initial Contributor has attached the notice described in

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Thu Jun 06 15:59:40 UTC 2024

- 15.6K bytes

- Viewed (0)

github.com/istio/istio

licenses/github.com/hashicorp/golang-lru/v2/LICENSE

1.4. "Covered Software"

     means Source Code Form to which the initial Contributor has attached the
     notice in Exhibit A, the Executable Form of such Source Code Form, and
     Modifications of such Source Code Form, in each case including portions
     thereof.

1.5. "Incompatible With Secondary Licenses"
     means

     a. that the initial Contributor has attached the notice described in

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Fri Feb 03 20:21:32 UTC 2023

- 15.6K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/resources/plugin/repo3/index.html

<!DOCTYPE html>
<html>

<head>
	<title>Central Repository: org/codelibs/fess</title>
	<meta name="viewport" content="width=device-width, initial-scale=1.0">
	<style>
body {
	background: #fff;
}
	</style>
</head>

<body>
	<header>
		<h1>org/codelibs/fess</h1>
	</header>
	<hr/>
	<main>
		<pre id="contents">
<a href="../">../</a>

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

- Last Modified: Mon Jun 17 13:30:41 UTC 2024

- 6.2K bytes

- Viewed (0)

github.com/istio/istio

cni/pkg/nodeagent/server.go

	log.Info("CNI ambient server kubeclient started")
	pods := s.handlers.GetActiveAmbientPodSnapshot()
	err := s.dataplane.ConstructInitialSnapshot(pods)
	if err != nil {
		log.Warnf("failed to construct initial snapshot: %v", err)
	}

	log.Info("CNI ambient server marking ready")
	s.Ready()
	s.dataplane.Start(s.ctx)
	s.handlers.Start()
}

func (s *Server) Stop() {
	s.cniServerStopFunc()

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Wed Sep 25 20:54:34 UTC 2024

- 13.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-replication-metrics.go

	startTime            time.Time // Start time for window
	expMovingAvg         float64   // Previously calculated exponential moving average
}

// newRateMeasurement creates a new instance of the measurement with the initial start time.
func newRateMeasurement(initTime time.Time) *rateMeasurement {
	return &rateMeasurement{
		startTime: initTime,
	}
}

// incrementBytes add bytes reported for a bucket/target.

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

- Last Modified: Thu Aug 15 12:04:40 UTC 2024

- 14.2K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt

 * the following strategies:
 *
 *  1. If the current call already has a connection that can satisfy the request it is used. Using
 *     the same connection for an initial exchange and its follow-ups may improve locality.
 *
 *  2. If there is a connection in the pool that can satisfy the request it is used. Note that it is

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

- Last Modified: Wed Dec 20 23:27:07 UTC 2023

- 4.2K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/escape/UnicodeEscaperTest.java

            + "0189["
            + Character.MAX_CODE_POINT
            + "]";
    assertEquals(expected, escapeAsString(e, TEST_STRING));
  }

  public void testGrowBuffer() { // need to grow past an initial 1024 byte buffer
    StringBuilder input = new StringBuilder();
    StringBuilder expected = new StringBuilder();
    for (int i = 256; i < 1024; i++) {
      input.append((char) i);
      expected.append("[" + i + "]");

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

- Last Modified: Fri Oct 18 15:00:32 UTC 2024

- 5.9K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/escape/UnicodeEscaperTest.java

            + "0189["
            + Character.MAX_CODE_POINT
            + "]";
    assertEquals(expected, escapeAsString(e, TEST_STRING));
  }

  public void testGrowBuffer() { // need to grow past an initial 1024 byte buffer
    StringBuilder input = new StringBuilder();
    StringBuilder expected = new StringBuilder();
    for (int i = 256; i < 1024; i++) {
      input.append((char) i);
      expected.append("[" + i + "]");

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

- Last Modified: Fri Oct 18 15:00:32 UTC 2024

- 5.9K bytes

- Viewed (0)

Search Options