- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for haon (0.15 sec)
-
cmd/metacache.go
if m.status == scanStateStarted && update.status != scanStateStarted { m.status = update.status } if m.status == scanStateStarted && time.Since(m.lastHandout) > metacacheMaxClientWait { // Drop if client hasn't been seen for 3 minutes. m.status = scanStateError m.error = "client not seen" } if m.error == "" && update.error != "" { m.error = update.error m.status = scanStateError m.ended = UTCNow()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5K bytes - Viewed (0) -
cmd/metacache-set.go
return r, resErr } } } // findFirstPart will find the part with 0 being the first that corresponds to the marker in the options. // io.ErrUnexpectedEOF is returned if the place containing the marker hasn't been scanned yet. // io.EOF indicates the marker is beyond the end of the stream and does not exist. func (o *listPathOptions) findFirstPart(fi FileInfo) (int, error) { search := o.Marker if search == "" {
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) -
istioctl/pkg/analyze/analyze.go
return nil } else if err != nil { return err } } } // If we've explicitly asked for all namespaces, blank the selectedNamespace var out // If the user hasn't specified a namespace, use the default namespace if allNamespaces { selectedNamespace = "" } else if selectedNamespace == "" { selectedNamespace = metav1.NamespaceDefault }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 17K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
} // UpdateWorkers at the end of this function leaves n goroutines waiting for // transition tasks func (t *transitionState) UpdateWorkers(n int) { t.mu.Lock() defer t.mu.Unlock() if t.objAPI == nil { // Init hasn't been called yet. return } t.updateWorkers(n) } func (t *transitionState) updateWorkers(n int) { for t.numWorkers < n { go t.worker(t.objAPI) t.numWorkers++ }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/license-update.go
if r.Index == 0 { internalLogIf(ctx, fmt.Errorf("license not found in response from %s", url)) return } lic := r.String() if lic == globalSubnetConfig.License { // license hasn't changed. return } kv := "subnet license=" + lic result, err := setConfigKV(ctx, objectAPI, []byte(kv)) if err != nil { internalLogIf(ctx, fmt.Errorf("error setting subnet license config: %w", err))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/tier-journal.go
jd.WalkEntries(ctx, deleteObjectFromRemoteTier) case <-ctx.Done(): jd.Close() return } } } func (jd *tierDiskJournal) addEntry(je jentry) error { // Open journal if it hasn't been err := jd.Open() if err != nil { return err } b, err := je.MarshalMsg(nil) if err != nil { return err } jd.Lock() defer jd.Unlock() _, err = jd.file.Write(b)
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
internal/crypto/key.go
mac.Write(bin[:]) mac.Sum(partKey[:0]) return partKey } // SealETag seals the etag using the object key. // It does not encrypt empty ETags because such ETags indicate // that the S3 client hasn't sent an ETag = MD5(object) and // the backend can pick an ETag value. func (key ObjectKey) SealETag(etag []byte) []byte { if len(etag) == 0 { // don't encrypt empty ETag - only if client sent ETag = MD5(object)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 19 20:28:10 GMT 2024 - 6.4K bytes - Viewed (0) -
src/bytes/example_test.go
fmt.Println(bytes.IndexByte([]byte("chicken"), byte('g'))) // Output: // 4 // -1 } func ExampleIndexFunc() { f := func(c rune) bool { return unicode.Is(unicode.Han, c) } fmt.Println(bytes.IndexFunc([]byte("Hello, 世界"), f)) fmt.Println(bytes.IndexFunc([]byte("Hello, world"), f)) // Output: // 7 // -1 } func ExampleIndexAny() {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Mar 04 15:54:40 GMT 2024 - 15K bytes - Viewed (1)