initCap - Code Search

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/google/guava

android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java

  }

  /** Tests a failure caused by fix to childless uncle issue. */
  public void testIteratorRegressionChildlessUncle() {
    final ArrayList<Integer> initial = Lists.newArrayList(1, 15, 13, 8, 9, 10, 11, 14);
    MinMaxPriorityQueue<Integer> q = MinMaxPriorityQueue.create(initial);
    assertIntact(q);
    q.remove(9);
    q.remove(11);
    q.remove(10);
    // Now we're in the critical state: [1, 15, 13, 8, 14]

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

- Last Modified: Wed Oct 30 16:15:19 UTC 2024

- 35.9K 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)

github.com/minio/minio

internal/grid/muxclient.go

func (m *muxClient) RequestStateless(h HandlerID, req []byte, out chan<- Response) {
	if m.init {
		out <- Response{Err: errors.New("mux client already used")}
	}
	m.init = true

	// Try to grab an initial block.
	m.singleResp = false
	msg := message{
		Op:         OpConnectMux,
		Handler:    h,
		Flags:      FlagEOF,
		Payload:    req,
		DeadlineMS: uint32(m.deadline.Milliseconds()),
	}

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

- Last Modified: Fri Jun 07 15:51:52 UTC 2024

- 15.9K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/spnego/NegTokenInit.java

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.util.Arrays;
import java.util.Enumeration;

import org.bouncycastle.asn1.*;

import jcifs.util.Hexdump;


/**
 * SPNEGO initial token
 */
@SuppressWarnings ( "javadoc" )
public class NegTokenInit extends SpnegoToken {

    public static final int DELEGATION = 0x80;
    public static final int MUTUAL_AUTHENTICATION = 0x40;

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

- Last Modified: Sun Oct 01 12:01:17 UTC 2023

- 7.9K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/index.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>
<c:if test="${osddLink}">
	<link rel="search" type="application/opensearchdescription+xml"
		href="${fe:url('/osdd')}"

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

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

- 6.9K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/cache/LongAdder.java

  /** Version of plus for use in retryUpdate */
  @Override
  final long fn(long v, long x) {
    return v + x;
  }

  /** Creates a new adder with initial sum of zero. */
  public LongAdder() {}

  /**
   * Adds the given value.
   *
   * @param x the value to add
   */
  @Override
  public void add(long x) {
    Cell[] as;
    long b, v;

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

- Last Modified: Tue Jun 15 18:00:07 UTC 2021

- 5.5K bytes

- Viewed (0)

github.com/minio/minio

docs/kms/README.md

### 1. Fetch the root identity

As the initial step, fetch the private key and certificate of the root identity:

```sh
curl -sSL --tlsv1.2 \
     -O 'https://raw.githubusercontent.com/minio/kes/master/root.key' \

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

- Last Modified: Thu Jan 18 07:03:17 UTC 2024

- 7.1K bytes

- Viewed (0)

Search Options