- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 471 for Initial (0.14 sec)
-
pkg/registry/core/service/portallocator/allocator_test.go
if err != nil { t.Fatal(err) } a, err := NewInMemory(*pr) if err != nil { t.Fatalf("unexpected error creating nodeport allocator: %v", err) } a.EnableMetrics() // Check initial state em := testMetrics{ free: 0, used: 0, allocated: 0, errors: 0, } expectMetrics(t, em) // allocate 2 ports found := sets.NewInt() for i := 0; i < 2; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 07:15:02 UTC 2024 - 14K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java
Serialization.getFieldSetter(ConcurrentHashMultiset.class, "countMap"); } /** * Creates a new, empty {@code ConcurrentHashMultiset} using the default initial capacity, load * factor, and concurrency settings. */ public static <E> ConcurrentHashMultiset<E> create() { // TODO(schmoe): provide a way to use this class with other (possibly arbitrary)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 20.9K bytes - Viewed (0) -
cluster/gce/gci/configure-kubeapiserver.sh
params+=" --audit-log-batch-throttle-burst=${ADVANCED_AUDIT_LOG_THROTTLE_BURST}" fi if [[ -n "${ADVANCED_AUDIT_LOG_INITIAL_BACKOFF:-}" ]]; then params+=" --audit-log-initial-backoff=${ADVANCED_AUDIT_LOG_INITIAL_BACKOFF}" fi # Truncating backend parameters if [[ -n "${ADVANCED_AUDIT_TRUNCATING_BACKEND:-}" ]]; then
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 11:08:30 UTC 2024 - 25.8K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/backoff.go
import ( "context" "math" "sync" "time" "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/utils/clock" ) // Backoff holds parameters applied to a Backoff function. type Backoff struct { // The initial duration. Duration time.Duration // Duration is multiplied by factor each iteration, if factor is not zero // and the limits imposed by Steps and Cap have not been reached. // Should not be negative.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 16.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/tensorflow/passes/quantized_function_library_uniform_quantized.mlir
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Aug 29 01:13:58 UTC 2023 - 19.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/plugin/prefix/internal/DefaultPluginPrefixResolver.java
for (RemoteRepository repository : request.getRepositories()) { requests.add(new MetadataRequest(metadata, repository, REPOSITORY_CONTEXT).setTrace(trace)); } } // initial try, use locally cached metadata List<MetadataResult> results = repositorySystem.resolveMetadata(request.getRepositorySession(), requests); requests.clear();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Sep 22 09:07:17 UTC 2023 - 10.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/continuous/ContinuousBuildActionExecutor.java
CancellableOperationManager cancellableOperationManager ) { if (!deploymentRegistry.getRunningDeployments().isEmpty()) { // Deployments are considered outOfDate until initial execution with file watching for (Deployment deployment : deploymentRegistry.getRunningDeployments()) { ((DeploymentInternal) deployment).outOfDate(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 17:41:07 UTC 2024 - 11.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/ConcurrentHashMultiset.java
Serialization.getFieldSetter(ConcurrentHashMultiset.class, "countMap"); } /** * Creates a new, empty {@code ConcurrentHashMultiset} using the default initial capacity, load * factor, and concurrency settings. */ public static <E> ConcurrentHashMultiset<E> create() { // TODO(schmoe): provide a way to use this class with other (possibly arbitrary)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 20.9K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
// 3. Envoy sends CDS request and we respond with clusters. // 4. Envoy detects a change in cluster state and tries to warm those clusters but never sends // an EDS request for them. // 5. Therefore, any initial CDS request should always trigger an EDS response // to let Envoy finish cluster warming. // Refer to https://github.com/envoyproxy/envoy/issues/13009 for some more details on this type of issues.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0)