- Sort Score
- Result 10 results
- Languages All
Results 481 - 490 of 710 for jconst (0.14 sec)
-
cmd/dummy-data-generator_test.go
if totalLength < 0 { panic("Negative length passed to DummyDataGen!") } if skipOffset < 0 { panic("Negative rotations are not allowed") } skipOffset %= int64(len(alphabets)) const multiply = 100 as := bytes.Repeat(alphabets, multiply) b := as[skipOffset : skipOffset+int64(len(alphabets)*(multiply-1))] return &DummyDataGen{ length: totalLength, b: b, } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 02 15:13:05 UTC 2024 - 4.7K bytes - Viewed (0) -
cmd/metacache-set.go
} if err == nil { *mc.meta = meta if meta.status == scanStateError { cancel() exit = true } } metaMu.Unlock() } }() const retryDelay = 200 * time.Millisecond const maxTries = 5 // Keep destination... // Write results to disk. bw := newMetacacheBlockWriter(entries, func(b *metacacheBlock) error { // if the block is 0 bytes and its a first block skip it.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 30.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
threadToCancel!!.interrupt() } latch.countDown() }.apply { start() } return latch } companion object { // The size of the socket buffers in bytes. private const val SOCKET_BUFFER_SIZE = 256 * 1024 } } class CancelModelParamProvider : SimpleProvider() { override fun arguments() = CancelTest.CancelMode.values().flatMap { c ->
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.9K bytes - Viewed (0) -
internal/s3select/json/preader.go
dst = append(dst, in...) return dst, err } // jsonSplitSize is the size of each block. // Blocks will read this much and find the first following newline. // 128KB appears to be a very reasonable default. const jsonSplitSize = 128 << 10 // startReaders will read the header if needed and spin up a parser // and a number of workers based on GOMAXPROCS.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 6.5K bytes - Viewed (0) -
internal/event/name.go
// for most basic values we have since extend this and its not really much applicable other than a reference point. // "s3:Replication:OperationCompletedReplication" is a MinIO extension. type Name int // Values of event Name const ( // Single event types (does not require expansion) ObjectAccessedGet Name = 1 + iota ObjectAccessedGetRetention ObjectAccessedGetLegalHold ObjectAccessedHead ObjectAccessedAttributes
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 01 01:11:10 UTC 2024 - 10.4K bytes - Viewed (0) -
doc/go_spec.html
constant, even if the literal's fractional part is zero. </p> <pre> const Pi float64 = 3.14159265358979323846 const zero = 0.0 // untyped floating-point constant const ( size int64 = 1024 eof = -1 // untyped integer constant ) const a, b, c = 3, 4, "foo" // a = 3, b = 4, c = "foo", untyped integer and string constants const u, v float32 = 0, 3 // u = 0.0, v = 3.0 </pre> <p>
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Oct 02 00:58:01 UTC 2024 - 282.5K bytes - Viewed (0) -
internal/crypto/key.go
} var nonce [32]byte if _, err := io.ReadFull(random, nonce[:]); err != nil { logger.CriticalIf(context.Background(), errOutOfEntropy) } const Context = "object-encryption-key generation" mac := hmac.New(sha256.New, extKey) mac.Write([]byte(Context)) mac.Write(nonce[:]) mac.Sum(key[:0]) return key }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 19 20:28:10 UTC 2024 - 6.4K bytes - Viewed (0) -
internal/event/target/kafka.go
"github.com/minio/minio/internal/store" xnet "github.com/minio/pkg/v3/net" "github.com/IBM/sarama" saramatls "github.com/IBM/sarama/tools/tls" ) // Kafka input constants const ( KafkaBrokers = "brokers" KafkaTopic = "topic" KafkaQueueDir = "queue_dir" KafkaQueueLimit = "queue_limit" KafkaTLS = "tls"
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.6K bytes - Viewed (0) -
internal/dsync/dsync_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync import ( "context" "math/rand" "os" "sync" "testing" "time" "github.com/google/uuid" ) const ( testDrwMutexAcquireTimeout = 250 * time.Millisecond testDrwMutexRefreshCallTimeout = 250 * time.Millisecond testDrwMutexUnlockCallTimeout = 250 * time.Millisecond
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 19 14:35:19 UTC 2024 - 11.1K bytes - Viewed (0) -
cmd/os-instrumented.go
"github.com/minio/minio/internal/disk" ioutilx "github.com/minio/minio/internal/ioutil" ) //go:generate stringer -type=osMetric -trimprefix=osMetric $GOFILE type osMetric uint8 const ( osMetricRemoveAll osMetric = iota osMetricMkdirAll osMetricMkdir osMetricRename osMetricOpenFileW osMetricOpenFileR osMetricOpenFileWFd osMetricOpenFileRFd osMetricOpen osMetricOpenFileDirectIO
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 15 01:09:38 UTC 2024 - 6.3K bytes - Viewed (0)