sont - Code Search

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

          "calcs": [
            "lastNotNull"
          ],
          "fields": "",
          "values": false
        },
        "tooltip": {
          "mode": "single",
          "sort": "none"
        }
      },
      "pluginVersion": "8.2.1",
      "targets": [
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${DS_PROMETHEUS}"
          },

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

- Last Modified: Wed Jul 24 14:51:03 UTC 2024

- 93K bytes

- Viewed (0)

github.com/minio/minio

cmd/api-headers.go

	"github.com/minio/minio/internal/crypto"
	xhttp "github.com/minio/minio/internal/http"
	xxml "github.com/minio/xxml"
)

// Returns a hexadecimal representation of time at the
// time response is sent to the client.
func mustGetRequestID(t time.Time) string {
	return fmt.Sprintf("%X", t.UnixNano())
}

// setEventStreamHeaders to allow proxies to avoid buffering proxy responses

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

- Last Modified: Tue May 28 04:44:00 UTC 2024

- 7K bytes

- Viewed (0)

github.com/google/guava

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

              workerRunningState = IDLE;
              return;
            }
          }
          // Remove the interrupt bit before each task. The interrupt is for the "current task" when
          // it is sent, so subsequent tasks in the queue should not be caused to be interrupted
          // by a previous one in the queue being interrupted.
          interruptedDuringTask |= Thread.interrupted();
          try {

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

- Last Modified: Thu Feb 01 21:46:34 UTC 2024

- 10.6K bytes

- Viewed (0)

github.com/google/guava

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

              workerRunningState = IDLE;
              return;
            }
          }
          // Remove the interrupt bit before each task. The interrupt is for the "current task" when
          // it is sent, so subsequent tasks in the queue should not be caused to be interrupted
          // by a previous one in the queue being interrupted.
          interruptedDuringTask |= Thread.interrupted();
          try {

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

- Last Modified: Thu Feb 01 21:46:34 UTC 2024

- 10.6K bytes

- Viewed (0)

github.com/minio/minio

internal/store/queuestore.go

	"errors"
	"os"
	"path/filepath"
	"sort"
	"sync"
	"time"

	"github.com/google/uuid"
	jsoniter "github.com/json-iterator/go"
	"github.com/klauspost/compress/s2"
	"github.com/valyala/bytebufferpool"
)

const (
	defaultLimit = 100000 // Default store limit.
	defaultExt   = ".unknown"
	compressExt  = ".snappy"
)

// errLimitExceeded error is sent when the maximum limit is reached.

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

- Last Modified: Fri Sep 06 23:06:30 UTC 2024

- 8.6K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/index.jsp

</c:if>
<link href="${fe:url('/css/bootstrap.min.css')}" rel="stylesheet"
	type="text/css" />
<link href="${fe:url('/css/style.css')}" rel="stylesheet" type="text/css" />
<link href="${fe:url('/css/font-awesome.min.css')}" rel="stylesheet"
	type="text/css" />
</head>
<body>
	<la:form action="/search" method="get" styleId="searchForm">
		${fe:facetForm()}${fe:geoForm()}
		<header>

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/square/okhttp

okhttp/src/main/kotlin/okhttp3/Request.kt

    /**
     * Override the [Request.url] for caching, if it is either polluted with
     * transient query params, or has a canonical URL possibly for a CDN.
     *
     * Note that POST requests will not be sent to the server if this URL is set
     * and matches a cached response.
     */
    fun cacheUrlOverride(cacheUrlOverride: HttpUrl?) =
      apply {
        this.cacheUrlOverride = cacheUrlOverride
      }

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

- Last Modified: Sat Apr 06 04:17:44 UTC 2024

- 10.5K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/io/CharStreams.java

   * writer will close the target if it is {@link Closeable}, and flushing the writer will flush the
   * target if it is {@link java.io.Flushable}.
   *
   * @param target the object to which output will be sent
   * @return a new Writer object, unless target is a Writer, in which case the target is returned
   */
  public static Writer asWriter(Appendable target) {
    if (target instanceof Writer) {

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

- Last Modified: Wed May 17 14:35:11 UTC 2023

- 10.9K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/eager/immediate_execution_context.h

  // Return the ParsedName of Host CPU device.
  virtual const DeviceNameUtils::ParsedName& HostCPUParsedName() const = 0;
  virtual const string& HostCPUName() const = 0;

  // Configure soft device placement policy.
  virtual void SetAllowSoftPlacement(bool enable) = 0;

  // Configure device placement policy logging.
  virtual void SetLogDevicePlacement(bool enable) = 0;

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

- Last Modified: Sat Oct 12 05:11:17 UTC 2024

- 12.3K bytes

- Viewed (0)

github.com/codelibs/fess-crawler

fess-crawler/src/main/resources/org/codelibs/fess/crawler/mime/tika-mimetypes.xml

  <mime-type type="application/x-font-bdf">
    <glob pattern="*.bdf"/>
  </mime-type>
  <mime-type type="application/x-font-dos"/>
  <mime-type type="application/x-font-framemaker"/>
  <mime-type type="application/x-font-ghostscript">
    <!-- conflict with portable sound format -->
    <glob pattern="*.gsf"/>
  </mime-type>
  <mime-type type="application/x-font-libgrx"/>

Registered: Sun Nov 10 03:50:12 UTC 2024

- Last Modified: Thu Sep 21 06:46:43 UTC 2023

- 298.5K bytes

- Viewed (0)

Search Options