- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 80 for Graves (0.35 sec)
-
cmd/metacache-set.go
if askDisks == -1 { newDisks := getQuorumDisks(disks, infos, (len(disks)+1)/2) if newDisks != nil { // If we found disks signature in quorum, we proceed to list // from a single drive, shuffling of the drives is subsequently. disks = newDisks askDisks = 1 } else { // If we did not find suitable disks, perform strict quorum listing // as no disk agrees on quorum anymore.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
compresses messages of size 1 KiB and larger. (Inbound messages are compressed or not based on the web socket server's configuration.) * New: Defer constructing `Inflater` and `Deflater` instances until they are needed. This saves memory if web socket compression is negotiated but not used. ## Version 4.5.0-RC1 _2020-03-17_ **This release candidate turns on web socket compression.**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
| `minio_cluster_health_status` | Get current cluster health status | | `minio_cluster_health_erasure_set_healing_drives` | Count of healing drives in the erasure set | | `minio_cluster_health_erasure_set_online_drives` | Count of online drives in the erasure set | | `minio_cluster_health_erasure_set_read_quorum` | Get read quorum of the erasure set |
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 43.4K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/http2/flowcontrol/WindowCounter.kt
class WindowCounter( val streamId: Int, ) { /** The total number of bytes consumed. */ var total: Long = 0L private set /** The total number of bytes acknowledged by outgoing `WINDOW_UPDATE` frames. */ var acknowledged: Long = 0L private set val unacknowledged: Long @Synchronized get() = total - acknowledged @Synchronized fun update( total: Long = 0, acknowledged: Long = 0,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 1.4K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
shuffledPartsMetadata = make([]FileInfo, len(disks)) distribution := fi.Erasure.Distribution var inconsistent int for i, meta := range metaArr { if disks[i] == nil { // Assuming offline drives as inconsistent, // to be safe and fallback to original // distribution order. inconsistent++ continue } if !meta.IsValid() { inconsistent++ continue }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 11.3K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Preconditions.java
* which are <i>not the caller's fault</i>. Doing so is <b>not recommended</b> because it is * misleading to future readers of the code and of stack traces. See <a * href="https://github.com/google/guava/wiki/ConditionalFailuresExplained">Conditional failures * explained</a> in the Guava User Guide for more advice. Notably, {@link Verify} offers assertions
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 11 11:52:14 GMT 2024 - 52.9K bytes - Viewed (0) -
cmd/erasure-sets.go
beforeDrives := formatsToDrivesInfo(s.endpoints.Endpoints, formats, sErrs) res.After.Drives = make([]madmin.HealDriveInfo, len(beforeDrives)) res.Before.Drives = make([]madmin.HealDriveInfo, len(beforeDrives)) // Copy "after" drive state too from before. for k, v := range beforeDrives { res.Before.Drives[k] = v res.After.Drives[k] = v } if countErrs(sErrs, errUnformattedDisk) == 0 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 37.5K bytes - Viewed (5) -
cmd/admin-handlers.go
// if a "restart/stop" was successful or not. Service signal now supports // a dry-run that helps skip the nodes that may have hung drives. By default // restart/stop will ignore the servers that are hung on drives. You can use // 'force' param to force restart even with hung drives if needed. func (a adminAPIHandlers) ServiceV2Handler(w http.ResponseWriter, r *http.Request) { ctx := r.Context() vars := mux.Vars(r)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
docs/es/docs/async.md
* los datos de cliente que se envían a través de la red * los datos enviados por tu programa para ser recibidos por el cliente a través de la red * el contenido de un archivo en disco para ser leído por el sistema y entregado al programa * los contenidos que tu programa da al sistema para ser escritos en disco
Plain Text - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 24.9K bytes - Viewed (0) -
cmd/erasure-server-pool.go
if errors.Is(err, errNoHealRequired) { countNoHeal++ } r.DiskCount += result.DiskCount r.SetCount += result.SetCount r.Before.Drives = append(r.Before.Drives, result.Before.Drives...) r.After.Drives = append(r.After.Drives, result.After.Drives...) } // No heal returned by all serverPools, return errNoHealRequired if countNoHeal == len(z.serverPools) { return r, errNoHealRequired }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 80.1K bytes - Viewed (0)