- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 93 for Hevery (0.22 sec)
-
cmd/xl-storage-disk-id-check.go
func (e *lockedLastMinuteLatency) add(value time.Duration) { e.addSize(value, 0) } // addSize will add a duration and size. func (e *lockedLastMinuteLatency) addSize(value time.Duration, sz int64) { // alloc on every call, so we have a clean entry to swap in. t := time.Now().Unix() e.init.Do(func() { e.cached.Store(&AccElem{}) atomic.StoreInt64(&e.cachedSec, t) }) acc := e.cached.Load()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cni/pkg/nodeagent/options.go
// // It doesn't matter what this IP is, so long as it's not routable and doesn't collide with anything else. // // IPv6 link local ranges are designed to be collision-resistant by default, and so probably never need to be overridden DefaultHostProbeSNATIP = "169.254.7.127" DefaultHostProbeSNATIPV6 = "fd16:9254:7127:1337:ffff:ffff:ffff:ffff" ) type AmbientArgs struct { SystemNamespace string Revision string
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 2K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
} // GetCGroups returns a slice of cgroups for pid using fs for filesystem calls. // // The expected cgroup format is "hierarchy-ID:controller-list:cgroup-path", and // this function will return an error if every cgroup does not meet that format. // // For more information, see: // - http://man7.org/linux/man-pages/man7/cgroups.7.html // - https://www.kernel.org/doc/Documentation/cgroup-v2.txt
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
if err != nil { return err } x.ClientConversation = x.Client.NewConversation() return nil } // Step takes a string provided from a server (or just an empty string for the // very first conversation step) and attempts to move the authentication // conversation forward. It returns a string to be sent to the server or an // error if the server message is invalid. Calling Step after a conversation
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.3K bytes - Viewed (1) -
internal/http/server.go
DefaultShutdownTimeout = 5 * time.Second // DefaultIdleTimeout for idle inactive connections DefaultIdleTimeout = 30 * time.Second // DefaultReadHeaderTimeout for very slow inactive connections DefaultReadHeaderTimeout = 30 * time.Second // DefaultMaxHeaderBytes - default maximum HTTP header size in bytes. DefaultMaxHeaderBytes = 1 * humanize.MiByte )
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/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 {
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) -
src/builtin/builtin.go
func clear[T ~[]Type | ~map[Type]Type1](t T) // The close built-in function closes a channel, which must be either // bidirectional or send-only. It should be executed only by the sender, // never the receiver, and has the effect of shutting down the channel after // the last sent value is received. After the last value has been received // from a closed channel c, any receive from c will succeed without
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 11 20:22:45 GMT 2024 - 12.7K bytes - Viewed (0) -
finisher_api.go
return } } } } // FirstOrInit finds the first matching record, otherwise if not found initializes a new instance with given conds. // Each conds must be a struct or map. // // FirstOrInit never modifies the database. It is often used with Assign and Attrs. // // // assign an email if the record is not found // db.Where(User{Name: "non_existing"}).Attrs(User{Email: "******@****.***"}).FirstOrInit(&user)
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Jan 12 08:42:21 GMT 2024 - 22.7K bytes - Viewed (0) -
internal/grid/types.go
// call Recycle() when the object is no longer needed. // The recycler should handle nil pointers. type Recycler interface { Recycle() } // MSS is a map[string]string that can be serialized. // It is not very efficient, but it is only used for easy parameter passing. type MSS map[string]string // Get returns the value for the given key. func (m *MSS) Get(key string) string { if m == nil { return "" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
src/cmd/asm/internal/asm/parse.go
return } // General address (with a few exceptions) looks like // $sym±offset(SB)(reg)(index*scale) // Exceptions are: // // R1 // offset // $offset // Every piece is optional, so we scan left to right and what // we discover tells us where we are. // Prefix: $. var prefix rune switch tok := p.peek(); tok { case '$', '*': prefix = rune(tok) p.next()
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 14:34:57 GMT 2024 - 36.9K bytes - Viewed (0)