- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 515 for block (0.14 sec)
-
docs/metrics/healthcheck/README.md
HTTP/1.1 503 Service Unavailable Accept-Ranges: bytes Content-Length: 0 Server: MinIO Vary: Origin X-Amz-Bucket-Region: us-east-1 X-Minio-Write-Quorum: 3 X-Amz-Request-Id: 16239D6AB80EBECF X-Xss-Protection: 1; mode=block Date: Tue, 21 Jul 2020 00:36:14 GMT ``` ### Cluster-readable probe The reply is '200 OK' if cluster has read quorum if not it returns '503 Service Unavailable'. ```
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jul 06 16:18:38 GMT 2023 - 2.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/hash/MacHashFunctionTest.java
byte[] key = fillByteArray(80, 0xaa); String data = "Test Using Larger Than Block-Size Key - Hash Key First"; checkSha1("aa4ae5e15272d00e95705637ce8a3b55ed402112", key, data); } public void testRfc2202_hmacSha1_case7() { byte[] key = fillByteArray(80, 0xaa); String data = "Test Using Larger Than Block-Size Key and Larger Than One Block-Size Data";
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 13.8K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
return DerHeader(tagClass, tag, constructed, length) } /** * Consume a header and execute [block], which should consume the entire value described by the * header. It is an error to not consume a full value in [block]. */ internal inline fun <T> read( name: String?, block: (DerHeader) -> T, ): T { if (!hasNext()) throw ProtocolException("expected a value")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
internal/grid/muxclient.go
} m.addResponse(Response{Err: ErrIncorrectSequence}) return false } m.RecvSeq++ return true } // response will send handleIncoming response to client. // may never block. // Should return whether the next call would block. func (m *muxClient) response(seq uint32, r Response) { if debugReqs { fmt.Println(m.MuxID, m.parent.String(), "RESP") } if debugPrint {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/MediaTypeJvmTest.kt
assertEquals("jpeg", mediaType.subtype) } } private fun <T> withLocale( locale: Locale, block: () -> T, ): T { val previous = Locale.getDefault() try { Locale.setDefault(locale) return block() } finally { Locale.setDefault(previous) } } @Test fun testIllegalCharsetName() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskLogger.kt
internal inline fun <T> Logger.logElapsed( task: Task, queue: TaskQueue, block: () -> T, ): T { var startNs = -1L val loggingEnabled = isLoggable(Level.FINE) if (loggingEnabled) { startNs = queue.taskRunner.backend.nanoTime() log(task, queue, "starting") } var completedNormally = false try { val result = block() completedNormally = true return result } finally {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
internal/disk/stat_linux.go
// e.g. if the mount is based on /dev/nvme0n1p1, let's calculate the // real device name (nvme0n1) to get its sysfs information parentDevPath, e := os.Readlink("/sys/class/block/" + devName) if e == nil { parentDev := filepath.Base(filepath.Dir(parentDevPath)) qst, err = bfs.SysBlockDeviceQueueStats(parentDev) } } if err == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/handler-api.go
// ram_per_request is (1MiB+32KiB) * driveCount \ // + 2 * 10MiB (default erasure block size v1) + 2 * 1MiB (default erasure block size v2) apiRequestsMaxPerNode = int(maxMem / uint64(maxSetDrives*blockSize+int(blockSizeV1*2+blockSizeV2*2))) } else { // ram_per_request is (1MiB+32KiB) * driveCount \ // + 2 * 1MiB (default erasure block size v2) apiRequestsMaxPerNode = int(maxMem / uint64(maxSetDrives*blockSize+int(blockSizeV2*2)))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 10K bytes - Viewed (0) -
internal/config/cache/cache.go
"github.com/tinylib/msgp/msgp" ) // Cache related keys const ( Enable = "enable" Endpoint = "endpoint" BlockSize = "block_size" EnvEnable = "MINIO_CACHE_ENABLE" EnvEndpoint = "MINIO_CACHE_ENDPOINT" EnvBlockSize = "MINIO_CACHE_BLOCK_SIZE" ) // DefaultKVS - default KV config for cache settings var DefaultKVS = config.KVS{ config.KV{ Key: Enable, Value: "off", },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.6K bytes - Viewed (0) -
buildscripts/verify-healing-with-root-disks.sh
while [ "$(curl -m 1 -s -o /dev/null -w "%{http_code}" http://localhost:$((start_port + i)))" -ne "403" ]; do echo -n "." sleep 1 done done } # Prepare fake disks with losetup function prepare_block_devices() { set -e mkdir -p ${WORK_DIR}/disks/ ${WORK_DIR}/mnt/ sudo modprobe loop for i in 1 2 3 4; do dd if=/dev/zero of=${WORK_DIR}/disks/img.${i} bs=1M count=2000
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 26 05:07:25 GMT 2023 - 2.2K bytes - Viewed (0)