meat - Code Search

okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

    this.cancelMode = mode.first
    this.connectionType = mode.second

    if (connectionType == H2) {
      platform.assumeHttp2Support()
    }

    // Sockets on some platforms can have large buffers that mean writes do not block when
    // required. These socket factories explicitly set the buffer sizes on sockets created.
    server = MockWebServer()
    server.serverSocketFactory =

Registered: Fri Nov 01 11:42:11 UTC 2024

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

- 9.9K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/mylasta/mail/CrawlerPostcard.java

        return postcard;
    }

    // ===================================================================================
    //                                                                           Meta Data
    //                                                                           =========
    @Override
    protected String getBodyFile() {
        return PATH;
    }

    @Override

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

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

- 10K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/hash/Hashing.java

   *   <li>{@code consistentHash(h, n - 1)}, otherwise (probability {@code 1 - 1/n})
   * </ul>
   *
   * <p>This method is suitable for the common use case of dividing work among buckets that meet the
   * following conditions:
   *
   * <ul>
   *   <li>You want to assign the same fraction of inputs to each bucket.
   *   <li>When you reduce the number of buckets, you can accept that the most recently added

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

- Last Modified: Fri Jul 19 16:02:36 UTC 2024

- 29.3K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

        statusLine.code == HTTP_CONTINUE -> {
          state = STATE_READ_RESPONSE_HEADERS
          responseBuilder
        }
        statusLine.code in (102 until 200) -> {
          // Processing and Early Hints will mean a second headers are coming.
          // Treat others the same for now
          state = STATE_READ_RESPONSE_HEADERS
          responseBuilder
        }
        else -> {
          state = STATE_OPEN_RESPONSE_BODY

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Mon Jan 08 01:13:22 UTC 2024

- 16.2K bytes

- Viewed (0)

github.com/minio/minio

docs/metrics/prometheus/grafana/bucket/minio-bucket.json

        "maxVizHeight": 300,
        "minVizHeight": 10,
        "minVizWidth": 0,
        "namePlacement": "auto",
        "orientation": "horizontal",
        "reduceOptions": {
          "calcs": [
            "mean"
          ],
          "fields": "",
          "values": false
        },
        "showUnfilled": false,
        "sizing": "auto",
        "text": {},
        "valueMode": "color"
      },

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

- Last Modified: Fri May 24 11:11:51 UTC 2024

- 101.8K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/webconfig/admin_webconfig_edit.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8" %><!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title><la:message key="labels.admin_brand_title"/> | <la:message
            key="labels.web_crawling_configuration"/></title>
    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">

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

- Last Modified: Thu Feb 13 07:47:04 UTC 2020

- 15.9K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/storage/admin_storage.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8" %><!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title><la:message key="labels.admin_brand_title"/> | <la:message
            key="labels.storage_configuration"/></title>
    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">

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

- Last Modified: Thu May 26 01:48:41 UTC 2022

- 20.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/api-errors.go

		HTTPStatusCode: http.StatusRequestedRangeNotSatisfiable,
	},
	ErrInvalidPolicyDocument: {
		Code:           "InvalidPolicyDocument",
		Description:    "The content of the form does not meet the conditions specified in the policy document.",
		HTTPStatusCode: http.StatusBadRequest,
	},
	ErrAccessDenied: {
		Code:           "AccessDenied",
		Description:    "Access Denied.",

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

- Last Modified: Tue Oct 01 22:13:18 UTC 2024

- 92.1K bytes

- Viewed (0)

github.com/minio/minio

cmd/globals.go

	globalNetPerfRX              netPerfRX
	globalSiteNetPerfRX          netPerfRX
	globalObjectPerfBucket       = "minio-perf-test-tmp-bucket"
	globalObjectPerfUserMetadata = "X-Amz-Meta-Minio-Object-Perf" // Clients can set this to bypass S3 API service freeze. Used by object pref tests.

	// MinIO version unix timestamp
	globalVersionUnix uint64

	// MinIO client
	globalMinioClient *minio.Client

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

- Last Modified: Tue Sep 03 18:23:41 UTC 2024

- 16.2K bytes

- Viewed (0)

github.com/google/guava

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

      ListenableFuture<? extends O> outputFuture = function.apply(input);
      checkNotNull(
          outputFuture,
          "AsyncFunction.apply returned null instead of a Future. "
              + "Did you mean to return immediateFuture(null)? %s",
          function);
      return outputFuture;
    }

    @Override
    void setResult(ListenableFuture<? extends O> result) {
      setFuture(result);
    }
  }

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

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

- 11K bytes

- Viewed (0)

Search Options