initially - 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/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/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)

github.com/codelibs/fess

src/main/webapp/WEB-INF/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-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

    tester.testFailedFuture("failure");
  }

  public void testCancel() throws Exception {
    assertTrue(future.cancel(true));
    tester.testCancelledFuture();
  }

  /** Tests the initial state of the future. */
  public void testCreate() throws Exception {
    SettableFuture<Integer> future = SettableFuture.create();
    assertFalse(future.isDone());
    assertFalse(future.isCancelled());
  }

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

- Last Modified: Fri Oct 18 22:10:29 UTC 2024

- 7.3K bytes

- Viewed (0)

github.com/google/guava

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

  private static final int DEFAULT_VALUES_PER_KEY = 2;

  @VisibleForTesting transient int expectedValuesPerKey = DEFAULT_VALUES_PER_KEY;

  /**
   * Creates a new, empty {@code HashMultimap} with the default initial capacities.
   *
   * <p>You may also consider the equivalent {@code
   * MultimapBuilder.hashKeys().hashSetValues().build()}, which provides more control over the
   * underlying data structure.
   */

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

- Last Modified: Fri Aug 02 10:02:49 UTC 2024

- 6.1K bytes

- Viewed (0)

github.com/google/guava

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

  /**
   * Returns the next element. <b>Note:</b> the implementation must call {@link #endOfData()} when
   * there are no elements left in the iteration. Failure to do so could result in an infinite loop.
   *
   * <p>The initial invocation of {@link #hasNext()} or {@link #next()} calls this method, as does
   * the first invocation of {@code hasNext} or {@code next} following each successful call to

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

- Last Modified: Fri Mar 18 02:04:10 UTC 2022

- 6.4K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/eager/c_api_test_util.h

// Return a tensor handle containing a 3x2 matrix of floats
TFE_TensorHandle* TestMatrixTensorHandle3X2(TFE_Context* ctx);

// Return a variable handle referring to a variable with the given initial value
// on the given device.
TFE_TensorHandle* TestVariable(TFE_Context* ctx, float value,
                               const tensorflow::string& device_name = "");

// Return an add op multiplying `a` by `b`.

Registered: Tue Nov 05 12:39:12 UTC 2024

- Last Modified: Mon Jul 17 23:43:59 UTC 2023

- 7.7K bytes

- Viewed (0)

Search Options