Ticket - Code Search

okhttp/src/test/java/okhttp3/URLConnectionTest.kt

        .socketFactory(
          object : DelegatingSocketFactory(getDefault()) {
            override fun configureSocket(socket: Socket): Socket {
              socket.receiveBufferSize = socketBufferSize
              socket.sendBufferSize = socketBufferSize
              return socket
            }
          },
        )
        .writeTimeout(Duration.ofMillis(500))
        .build()
    server.start()

Registered: Sun Jun 16 04:42:17 UTC 2024

- Last Modified: Sat Jan 20 10:30:28 UTC 2024

- 131.7K bytes

- Viewed (0)

github.com/istio/istio

operator/cmd/mesh/testdata/manifest-generate/output/pilot_default.golden.yaml

              {{- end }}
              {{- end }}
            resources:
          {{ template "resources" . }}
            volumeMounts:
            - name: workload-socket
              mountPath: /var/run/secrets/workload-spiffe-uds
            - name: credential-socket
              mountPath: /var/run/secrets/credential-uds
            {{- if eq .Values.global.caName "GkeWorkloadCertificate" }}
            - name: gke-workload-certificate

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Wed Jan 10 05:10:03 UTC 2024

- 102.6K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/es/log/cbean/ca/bs/BsSearchLogCA.java

import org.opensearch.search.aggregations.bucket.range.IpRangeAggregationBuilder;
import org.opensearch.search.aggregations.bucket.range.RangeAggregationBuilder;
import org.opensearch.search.aggregations.bucket.sampler.SamplerAggregationBuilder;
import org.opensearch.search.aggregations.bucket.terms.SignificantTermsAggregationBuilder;
import org.opensearch.search.aggregations.bucket.terms.TermsAggregationBuilder;

Registered: Wed Jun 12 13:08:18 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 115.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/storage-datatypes_gen.go

		field, err = dc.ReadMapKeyPtr()
		if err != nil {
			err = msgp.WrapError(err)
			return
		}
		switch msgp.UnsafeString(field) {
		case "Bucket":
			z.Bucket, err = dc.ReadString()
			if err != nil {
				err = msgp.WrapError(err, "Bucket")
				return
			}
		case "Prefix":
			z.Prefix, err = dc.ReadString()
			if err != nil {
				err = msgp.WrapError(err, "Prefix")
				return

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Mon Jun 10 15:51:27 UTC 2024

- 130.6K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsFileConfigCA.java

import org.opensearch.search.aggregations.bucket.filter.FilterAggregationBuilder;
import org.opensearch.search.aggregations.bucket.global.GlobalAggregationBuilder;
import org.opensearch.search.aggregations.bucket.histogram.HistogramAggregationBuilder;
import org.opensearch.search.aggregations.bucket.missing.MissingAggregationBuilder;
import org.opensearch.search.aggregations.bucket.range.IpRangeAggregationBuilder;

Registered: Wed Jun 12 13:08:18 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 144.6K bytes

- Viewed (0)

github.com/minio/minio

cmd/admin-handlers.go

	if hip.bucket == "" {
		if hip.objPrefix != "" {
			// Bucket is required if object-prefix is given
			err = ErrHealMissingBucket
			return
		}
	} else if isReservedOrInvalidBucket(hip.bucket, false) {
		err = ErrInvalidBucketName
		return
	}

	// empty prefix is valid.
	if !IsValidObjectPrefix(hip.objPrefix) {
		err = ErrInvalidObjectName
		return
	}

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Fri May 24 23:05:23 UTC 2024

- 98K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsWebConfigCA.java

import org.opensearch.search.aggregations.bucket.filter.FilterAggregationBuilder;
import org.opensearch.search.aggregations.bucket.global.GlobalAggregationBuilder;
import org.opensearch.search.aggregations.bucket.histogram.HistogramAggregationBuilder;
import org.opensearch.search.aggregations.bucket.missing.MissingAggregationBuilder;
import org.opensearch.search.aggregations.bucket.range.IpRangeAggregationBuilder;

Registered: Wed Jun 12 13:08:18 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 149K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/CallTest.kt

    callback.await(server.url("/a")).assertFailure("Canceled", "Socket closed", "Socket is closed")
  }

  @Test
  fun cancelAll() {
    val call = client.newCall(Request(server.url("/")))
    call.enqueue(callback)
    client.dispatcher.cancelAll()
    callback.await(server.url("/")).assertFailure("Canceled", "Socket closed", "Socket is closed")
  }

  @Test

Registered: Sun Jun 16 04:42:17 UTC 2024

- Last Modified: Wed Apr 10 19:46:48 UTC 2024

- 142.5K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/es/user/cbean/ca/bs/BsUserCA.java

import org.opensearch.search.aggregations.bucket.filter.FilterAggregationBuilder;
import org.opensearch.search.aggregations.bucket.global.GlobalAggregationBuilder;
import org.opensearch.search.aggregations.bucket.histogram.HistogramAggregationBuilder;
import org.opensearch.search.aggregations.bucket.missing.MissingAggregationBuilder;
import org.opensearch.search.aggregations.bucket.range.IpRangeAggregationBuilder;

Registered: Wed Jun 12 13:08:18 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 212.4K bytes

- Viewed (0)

github.com/istio/istio

pkg/config/validation/validation.go

func ValidateUnixAddress(addr string) error {
	if len(addr) == 0 {
		return errors.New("unix address must not be empty")
	}

	// Allow unix abstract domain sockets whose names start with @
	if strings.HasPrefix(addr, "@") {
		return nil
	}

	// Note that we use path, not path/filepath even though a domain socket path is a file path.  We don't want the

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Wed Jun 12 04:03:33 UTC 2024

- 107.2K bytes

- Viewed (0)

Search Options