- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 235 for headers (0.77 sec)
-
cmd/erasure-server-pool-rebalance.go
doneCh := make(chan error, 1) defer xioutil.SafeClose(doneCh) // Save rebalance.bin periodically. go func() { // Update rebalance.bin periodically once every 5-10s, chosen randomly // to avoid multiple pool leaders herding to update around the same // time. r := rand.New(rand.NewSource(time.Now().UnixNano())) randSleepFor := func() time.Duration { return 5*time.Second + time.Duration(float64(5*time.Second)*r.Float64()) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/erasure-object.go
readers[index] = newBitrotReader(disk, metaArr[index].Data, bucket, partPath, tillOffset, checksumInfo.Algorithm, checksumInfo.Hash, erasure.ShardSize()) // Prefer local disks prefer[index] = disk.Hostname() == "" } written, err := erasure.Decode(ctx, writer, readers, partOffset, partLength, partSize, prefer)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/generic-handlers_test.go
} } var isHTTPHeaderSizeTooLargeTests = []struct { header http.Header shouldFail bool }{ {header: generateHeader(0, 0), shouldFail: false}, {header: generateHeader(1024, 0), shouldFail: false}, {header: generateHeader(2048, 0), shouldFail: false}, {header: generateHeader(8*1024+1, 0), shouldFail: true}, {header: generateHeader(0, 1024), shouldFail: false}, {header: generateHeader(0, 2048), shouldFail: true},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 5.4K bytes - Viewed (0) -
cmd/untar.go
) var magicHeaders = []struct { header []byte f format }{ { header: []byte{0x1f, 0x8b, 8}, f: formatGzip, }, { // Zstd default header. header: []byte{0x28, 0xb5, 0x2f, 0xfd}, f: formatZstd, }, { // Zstd skippable frame header. header: []byte{0x2a, 0x4d, 0x18}, f: formatZstd, }, { // LZ4 header: []byte{0x4, 0x22, 0x4d, 0x18},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
internal/hash/checksum.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.9K bytes - Viewed (0) -
cmd/bucket-replication.go
} if err != nil { return err } cHeader := http.Header{} cHeader.Add(xhttp.MinIOSourceReplicationRequest, "true") popts := minio.PutObjectPartOptions{ SSE: opts.ServerSideEncryption, CustomHeader: cHeader, } if crypto.SSEC.IsEncrypted(objInfo.UserDefined) { objectSize += partInfo.Size
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/erasure-heal_test.go
closeBitrotWriters(writers) if err != nil { t.Fatalf("Test %d: failed to create random test data: %v", i, err) } readers := make([]io.ReaderAt, len(disks)) for i, disk := range disks { shardFilesize := erasure.ShardFileSize(test.size) readers[i] = newBitrotReader(disk, nil, "testbucket", "testobject", shardFilesize, test.algorithm, bitrotWriterSum(writers[i]), erasure.ShardSize()) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.9K bytes - Viewed (0) -
internal/http/server.go
// If server is in shutdown. if atomic.LoadUint32(&srv.inShutdown) != 0 { // To indicate disable keep-alive, server is shutting down. w.Header().Set("Connection", "close") // Add 1 minute retry header, incase-client wants to honor it w.Header().Set(RetryAfter, "60") w.WriteHeader(http.StatusServiceUnavailable) w.Write([]byte(http.ErrServerClosed.Error())) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
cmd/signature-v2_test.go
}, } for i, testCase := range testCases { t.Run(fmt.Sprintf("Case %d AuthStr \"%s\".", i+1, testCase.authString), func(t *testing.T) { req := &http.Request{ Header: make(http.Header), URL: &url.URL{}, } req.Header.Set("Authorization", testCase.authString) _, actualErrCode := validateV2AuthHeader(req) if testCase.expectedError != actualErrCode {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Oct 14 10:08:40 GMT 2022 - 8K bytes - Viewed (0) -
internal/config/browser/browser.go
const ( // browserCSPPolicy setting name for Content-Security-Policy response header value browserCSPPolicy = "csp_policy" // browserHSTSSeconds setting name for Strict-Transport-Security response header, amount of seconds for 'max-age' browserHSTSSeconds = "hsts_seconds" // browserHSTSIncludeSubdomains setting name for Strict-Transport-Security response header 'includeSubDomains' flag (true or false)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 5.8K bytes - Viewed (0)