Locale - Code Search

build-logic/cleanup/src/test/groovy/gradlebuild/cleanup/services/LeakingProcessKillPatternTest.groovy

-D$java.rmi.server.hostname=127.0.0.1 -Xmx1024m -XX:MaxMetaspaceSize=512m -Dkotlin.environment.keepalive -ea --add-exports java.base/sun.nio.ch=ALL-UNNAMED org.jetbrains.kotlin.daemon.KotlinCompileDaemon --daemon-runFilesPath C:\\Users\\tcagent1\\AppData\\Local\\kotlin\\daemon --daemon-autoshutdownIdleSeconds=7200 --daemon-compilerClasspath C:\\tcagent1\\work\\f63322e10dd6b396\\intTestHomeDir\\distributions-full\\caches\\modules-2\\files-2.1\\org.jetbrains.kotlin\\kotlin-compiler-embeddable\\1.9.10\\57ca...

Registered: Wed Nov 06 11:36:14 UTC 2024

- Last Modified: Fri Jul 12 03:42:46 UTC 2024

- 14.8K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/Futures.java

    }

    final ImmutableList<AbstractFuture<T>> delegates = delegatesBuilder.build();
    for (int i = 0; i < copy.length; i++) {
      final int localI = i;
      copy[i].addListener(() -> state.recordInputCompletion(delegates, localI), directExecutor());
    }

    @SuppressWarnings("unchecked")
    ImmutableList<ListenableFuture<T>> delegatesCast = (ImmutableList) delegates;
    return delegatesCast;

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

- Last Modified: Fri Oct 25 13:13:32 UTC 2024

- 64.4K bytes

- Viewed (0)

github.com/minio/minio

internal/kms/config.go

// environment and returns a:
//
//   - connection to MinIO KMS if the "MINIO_KMS_SERVER" variable is present.
//   - connection to MinIO KES if the "MINIO_KMS_KES_ENDPOINT" is present.
//   - connection to a "local" KMS implementation using a static key if the
//     "MINIO_KMS_SECRET_KEY" or "MINIO_KMS_SECRET_KEY_FILE" is present.
//
// It returns an error if connecting to the KMS implementation fails,

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

- Last Modified: Thu Aug 15 11:46:39 UTC 2024

- 14.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/advance.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

- 14.9K bytes

- Viewed (0)

github.com/istio/istio

architecture/networking/pilot.md

#### Endpoints

Endpoints have an optimized code path, as they are by far the most frequently updated resource - in a steady cluster, this will often be the *only* change, caused by scale up/down.

As a result, they do not go through `PushContext`, and changes do not trigger a `PushContext` recomputation. Instead, the current state is incrementally computed based on events from `ServiceDiscovery`.

#### Conclusion

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

- Last Modified: Wed Feb 07 17:53:24 UTC 2024

- 19.1K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-lifecycle.go

// UnmarshalXML - decodes XML data.
func (sp *SelectParameters) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
	// Essentially the same as S3Select barring the xml name.
	if start.Name.Local == selectParamsXMLName {
		start.Name = xml.Name{Space: "", Local: "SelectRequest"}
	}
	return sp.S3Select.UnmarshalXML(d, start)
}

// RestoreObjectRequest - xml to restore a transitioned object
type RestoreObjectRequest struct {

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

- Last Modified: Wed Oct 23 15:35:37 UTC 2024

- 33.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/encryption-v1.go

	//
	// 2. the (decrypted) start offset `off` and (decrypted)
	//    length to read `length`
	//
	// These are the inputs to the rest of the algorithm below.

	// Locate the part containing the start of the required range
	var partEnd int
	var cumulativeSum, encCumulativeSum int64
	for i, size := range sizes {
		if off < cumulativeSum+size {
			partStart = i
			break
		}

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

- Last Modified: Sun Oct 13 13:06:08 UTC 2024

- 37.2K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/Futures.java

    }

    final ImmutableList<AbstractFuture<T>> delegates = delegatesBuilder.build();
    for (int i = 0; i < copy.length; i++) {
      final int localI = i;
      copy[i].addListener(() -> state.recordInputCompletion(delegates, localI), directExecutor());
    }

    @SuppressWarnings("unchecked")
    ImmutableList<ListenableFuture<T>> delegatesCast = (ImmutableList) delegates;
    return delegatesCast;

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

- Last Modified: Fri Oct 25 13:13:32 UTC 2024

- 64.7K bytes

- Viewed (0)

github.com/minio/minio

internal/rest/client.go

	switch atomic.LoadInt32(&c.connected) {
	case closed:
		// client closed, this is usually a manual process
		// so return a local error as client is closed
		return nil, &NetworkError{Err: ErrClientClosed}
	case offline:
		// client offline, return last error captured.
		return nil, &NetworkError{Err: c.LastError()}
	}

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

- Last Modified: Fri Jul 26 12:55:01 UTC 2024

- 14.7K bytes

- Viewed (0)

github.com/istio/istio

manifests/addons/dashboards/istio-service-dashboard.json

        "skipUrlSync": false,
        "type": "datasource"
      },
      {
        "current": {
          "selected": false,
          "text": "details.default.svc.cluster.local",
          "value": "details.default.svc.cluster.local"
        },
        "datasource": {
          "type": "prometheus",
          "uid": "${datasource}"
        },
        "definition": "",
        "hide": 0,

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

- Last Modified: Wed Mar 27 03:47:04 UTC 2024

- 111.8K bytes

- Viewed (0)

Search Options