- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for CH (0.85 sec)
-
cmd/signature-v4-parser.go
if !isValidRegion(sRegion, region) { return ch, ErrAuthorizationHeaderMalformed } if credElements[2] != string(stype) { if stype == serviceSTS { return ch, ErrInvalidServiceSTS } return ch, ErrInvalidServiceS3 } cred.scope.service = credElements[2] if credElements[3] != "aws4_request" { return ch, ErrInvalidRequestVersion } cred.scope.request = credElements[3]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/speedtest.go
enableSha256 bool } // Get the max throughput and iops numbers. func objectSpeedTest(ctx context.Context, opts speedTestOpts) chan madmin.SpeedTestResult { ch := make(chan madmin.SpeedTestResult, 1) go func() { defer xioutil.SafeClose(ch) concurrency := opts.concurrencyStart if opts.autotune { // if we have less drives than concurrency then choose
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 9K bytes - Viewed (0) -
docs/debugging/s3-verify/main.go
log.Fatalln(err) } maxObjectModTime := time.Now().Add(-ageDelta) // Next object is used to ignore new objects in the source & target nextObject := func(ch <-chan minio.ObjectInfo) (ctnt minio.ObjectInfo, ok bool) { for { ctnt, ok := <-ch if !ok { return minio.ObjectInfo{}, false } if ctnt.LastModified.Before(maxObjectModTime) { return ctnt, ok } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jun 22 15:12:47 GMT 2022 - 8.4K bytes - Viewed (0) -
cmd/service.go
// Close when we reach 0 globalServiceFreezeCnt-- if globalServiceFreezeCnt <= 0 { // Set to a nil channel. var _ch chan struct{} if val := globalServiceFreeze.Swap(_ch); val != nil { if ch, ok := val.(chan struct{}); ok && ch != nil { // Close previous non-nil channel. xioutil.SafeClose(ch) } } globalServiceFreezeCnt = 0 // Don't risk going negative. } globalServiceFreezeMu.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
internal/grid/grid.go
// The context both allows returning errors on writes and to ensure that // this isn't abandoned if the channel is no longer being read from. func WriterToChannel(ctx context.Context, ch chan<- []byte) io.Writer { return &writerWrapper{ch: ch, ctx: ctx} } // bytesOrLength returns small (<=100b) byte slices as string, otherwise length. func bytesOrLength(b []byte) string { if len(b) > 100 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0) -
internal/pubsub/pubsub.go
"sync/atomic" ) // GetByteBuffer returns a byte buffer from the pool. var GetByteBuffer = func() []byte { return make([]byte, 0, 4096) } // Sub - subscriber entity. type Sub[T Maskable] struct { ch chan T types Mask filter func(entry T) bool } // PubSub holds publishers and subscribers type PubSub[T Maskable, M Maskable] struct { // atomics, keep at top: types uint64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
r.readerWg.Add(1) go r.startReader() return &r } // NewElementReader - creates new JSON reader using readCloser. func NewElementReader(ch chan simdjson.Object, err *error, args *json.ReaderArgs) *Reader { return &Reader{ args: args, decoded: ch, err: err, readCloser: nil, } } // safeCloser will wrap a Reader as a ReadCloser.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0)