- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 138 for Graves (0.16 sec)
-
cmd/metrics.go
"Total number of offline drives in current MinIO server instance", nil, nil), prometheus.GaugeValue, float64(offlineDisks.Sum()), ) // MinIO Total Disks per node ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(minioNamespace, "drives", "total"), "Total number of drives for current MinIO server instance", nil, nil),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/erasure.go
} rootDiskCount := 0 for _, di := range disksInfo { if di.RootDisk { rootDiskCount++ } } // Count offline disks as well to ensure consistent // reportability of offline drives on local setups. if len(disksInfo) == (rootDiskCount + offlineDisks.Sum()) { // Success. return onlineDisks, offlineDisks } // Root disk should be considered offline for i := range disksInfo {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
frame.writeByte(FLAG_NONE) frame.writeInt(expectedStreamId and 0x7fffffff) frame.write(headerBlock, Http2.INITIAL_MAX_FRAME_SIZE.toLong()) // Write the continuation frame, specifying no more frames are expected. writeMedium(frame, headerBlock.size.toInt()) frame.writeByte(Http2.TYPE_CONTINUATION) frame.writeByte(FLAG_END_HEADERS) frame.writeInt(expectedStreamId and 0x7fffffff)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 28.1K bytes - Viewed (0) -
cmd/prepare-storage.go
// Fresh setup, wait for first server to be up. logger.Info("Waiting for the first server to format the drives (elapsed %s)\n", getElapsedTime()) case errFirstDiskWait: // Fresh setup, wait for other servers to come up. logger.Info("Waiting for all other servers to be online to format the drives (elapses %s)\n", getElapsedTime()) case errErasureReadQuorum:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
} @Test fun clientCloseCancelsConnectionAfterTimeout() { client.webSocket!!.close(1000, "Hello!") taskFaker.runTasks() // Note: we don't process server frames so our client 'close' doesn't receive a server 'close'. assertThat(client.canceled).isFalse() taskFaker.advanceUntil(ns(RealWebSocket.CANCEL_AFTER_CLOSE_MILLIS - 1)) assertThat(client.canceled).isFalse()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
/** * HTTP/2 only. Send a push promise header block. * * A push promise contains all the headers that pertain to a server-initiated request, and a * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as * a part of the response to `streamId`. The `promisedStreamId` has a priority of one greater than * `streamId`. * * @param streamId client-initiated stream ID. Must be an odd number.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
docs/pt/docs/features.md
second_user_data = { "id": 4, "name": "Mary", "joined": "2018-11-30", } my_second_user: User = User(**second_user_data) ``` !!! info `**second_user_data` quer dizer: Passe as chaves e valores do dicionĂ¡rio `second_user_data` diretamente como argumentos chave-valor, equivalente a: `User(id=4, name="Mary", joined="2018-11-30")` ### Suporte de editores
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 10.4K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
build-logic/kotlin-dsl-shared-runtime/src/main/kotlin/org/gradle/kotlin/dsl/internal/sharedruntime/codegen/ApiTypeProvider.kt
import org.objectweb.asm.AnnotationVisitor import org.objectweb.asm.Attribute import org.objectweb.asm.ClassReader import org.objectweb.asm.ClassReader.SKIP_CODE import org.objectweb.asm.ClassReader.SKIP_FRAMES import org.objectweb.asm.FieldVisitor import org.objectweb.asm.Opcodes.ACC_ABSTRACT import org.objectweb.asm.Opcodes.ACC_PUBLIC import org.objectweb.asm.Opcodes.ACC_STATIC import org.objectweb.asm.Opcodes.ACC_SYNTHETIC
Plain Text - Registered: Wed Feb 28 11:36:09 GMT 2024 - Last Modified: Tue Feb 06 19:56:10 GMT 2024 - 20.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
assertThat(expected.message) .isEqualTo("Client-sent frames must be masked.") } } @Test fun serverSentFramesMustNotBeMasked() { data.write("8180".decodeHex()) assertFailsWith<ProtocolException> { clientReader.processNextFrame() }.also { expected -> assertThat(expected.message) .isEqualTo("Server-sent frames must not be masked.") } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.4K bytes - Viewed (0)