- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 68 for Slough (0.26 sec)
-
src/bufio/scan_test.go
numSplits := 0 const okCount = 7 errorSplit := func(data []byte, atEOF bool) (advance int, token []byte, err error) { if atEOF { panic("didn't get enough data") } if numSplits >= okCount { return 0, nil, testError } numSplits++ return 1, data[0:1], nil } // Read the data. const text = "abcdefghijklmnopqrstuvwxyz"
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Sep 22 16:22:42 GMT 2023 - 14.3K bytes - Viewed (0) -
src/cmd/addr2line/main.go
// Copyright 2012 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Addr2line is a minimal simulation of the GNU addr2line tool, // just enough to support pprof. // // Usage: // // go tool addr2line binary // // Addr2line reads hexadecimal addresses, one per line and with optional 0x prefix,
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 2.3K bytes - Viewed (0) -
src/bufio/bufio.go
} const minReadBufferSize = 16 const maxConsecutiveEmptyReads = 100 // NewReaderSize returns a new [Reader] whose buffer has at least the specified // size. If the argument io.Reader is already a [Reader] with large enough // size, it returns the underlying [Reader]. func NewReaderSize(rd io.Reader, size int) *Reader { // Is it already a Reader? b, ok := rd.(*Reader) if ok && len(b.buf) >= size { return b } r := new(Reader)
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Thu Oct 12 14:39:08 GMT 2023 - 21.8K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle.go
if obj.IsLatest && rule.Expiration.DeleteAll.val { if !rule.Expiration.IsDaysNull() { // Specifying the Days tag will automatically perform all versions cleanup // once the latest object is old enough to satisfy the age criteria. // This is a MinIO only extension. if expectedExpiry := ExpectedExpiryTime(obj.ModTime, int(rule.Expiration.Days)); now.IsZero() || now.After(expectedExpiry) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 06:41:22 GMT 2024 - 17K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
s.pods.AddEventHandler(controllers.FromEventHandler(func(o controllers.Event) { s.queue.Add(o) })) // Namespaces could be anything though, so we watch all of those // // NOTE that we are requeueing namespaces here explicitly to work around // test flakes with the fake kube client in `pkg/kube/client.go` -
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 9.9K bytes - Viewed (0) -
cmd/perf-tests.go
r.buf = make([]byte, 128*humanize.KiByte) rand.Read(r.buf) connectionsPerPeer := 16 if len(globalNotificationSys.peerClients) > 16 { // For a large cluster it's enough to have 1 connection per peer to saturate the network. connectionsPerPeer = 1 } errStr := "" var wg sync.WaitGroup for index := range globalNotificationSys.peerClients {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
cmd/metacache-set.go
// to the options or to the current bucket ILM expiry rules. // Caller should close the channel when done. // The returned function will return the results once there is enough or input is closed, // or the context is canceled. func (o *listPathOptions) gatherResults(ctx context.Context, in <-chan metaCacheEntry) func() (metaCacheEntriesSorted, error) { resultsDone := make(chan metaCacheEntriesSorted)
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) -
misc/go_android_exec/main.go
if err := syscall.Flock(int(lock.Fd()), syscall.LOCK_EX); err != nil { return 0, err } // In case we're booting a device or emulator alongside all.bash, wait for // it to be ready. adb wait-for-device is not enough, we have to // wait for sys.boot_completed. if err := adb("wait-for-device", "exec-out", "while [[ -z $(getprop sys.boot_completed) ]]; do sleep 1; done;"); err != nil { return 0, err }
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Mon Aug 21 17:46:57 GMT 2023 - 15.3K bytes - Viewed (0) -
cmd/generic-handlers.go
"github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/mcontext" ) const ( // Maximum allowed form data field values. 64MiB is a guessed practical value // which is more than enough to accommodate any form data fields and headers. requestFormDataSize = 64 * humanize.MiByte // For any HTTP request, request body should be not more than 16GiB + requestFormDataSize
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
internal/dsync/drwmutex.go
}(index, c) } wg.Wait() } type refreshResult struct { offline bool refreshed bool } // Refresh the given lock in all nodes, return true to indicate if a lock // does not exist in enough quorum nodes. func refreshLock(ctx context.Context, ds *Dsync, id, source string, quorum int) (bool, error) { restClnts, _ := ds.GetLockers() // Create buffered channel of size equal to total number of nodes.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0)