Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1061 - 1070 of 1,341 for varr (0.04 sec)

  1. cmd/warm-backend.go

    type tierPermErr struct {
    	Op  tierOp
    	Err error
    }
    
    func (te tierPermErr) Error() string {
    	return fmt.Sprintf("failed to perform %s: %v", te.Op, te.Err)
    }
    
    func errIsTierPermError(err error) bool {
    	var tpErr tierPermErr
    	return errors.As(err, &tpErr)
    }
    
    // remoteVersionID represents the version id of an object in the remote tier.
    // Its usage is remote tier cloud implementation specific.
    type remoteVersionID string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. internal/logger/logonce.go

    		l.Unlock()
    	}
    }
    
    // Returns logOnceType
    func newLogOnceType() *logOnceType {
    	l := &logOnceType{IDMap: make(map[string]onceErr)}
    	go l.cleanupRoutine()
    	return l
    }
    
    var logOnce = newLogOnceType()
    
    // LogOnceIf - Logs notification errors - once per error.
    // id is a unique identifier for related log messages, refer to cmd/notification.go
    // on how it is used.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  3. internal/logger/reqinfo.go

    }
    
    // SetTags - sets key/val to ReqInfo.tags
    func (r *ReqInfo) SetTags(key, val string) *ReqInfo {
    	if r == nil {
    		return nil
    	}
    	r.Lock()
    	defer r.Unlock()
    	// Search of tag key already exists in tags
    	var updated bool
    	for _, tag := range r.tags {
    		if tag.Key == key {
    			tag.Val = val
    			updated = true
    			break
    		}
    	}
    	if !updated {
    		// Append to the end of tags list
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  4. internal/dsync/dsync-client_test.go

    }
    
    func (restClient *ReconnectRESTClient) IsLocal() bool {
    	return false
    }
    
    // Close closes the underlying socket file descriptor.
    func (restClient *ReconnectRESTClient) Close() error {
    	return nil
    }
    
    var (
    	errLockConflict = errors.New("lock conflict")
    	errLockNotFound = errors.New("lock not found")
    )
    
    func toLockError(err error) error {
    	if err == nil {
    		return nil
    	}
    
    	switch err.Error() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  5. src/bytes/iter.go

    // If s does not end in a newline, the final yielded line will not end in a newline.
    // It returns a single-use iterator.
    func Lines(s []byte) iter.Seq[[]byte] {
    	return func(yield func([]byte) bool) {
    		for len(s) > 0 {
    			var line []byte
    			if i := IndexByte(s, '\n'); i >= 0 {
    				line, s = s[:i+1], s[i+1:]
    			} else {
    				line, s = s, nil
    			}
    			if !yield(line[:len(line):len(line)]) {
    				return
    			}
    		}
    		return
    	}
    }
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 14 18:23:13 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  6. cni/pkg/log/uds_test.go

    		strings.TrimSuffix(string(out), "\n"), "\n")
    	if want, got := len(cases)*2, len(gotLogs); want != got {
    		t.Fatalf("Number of logs want %v, got %v logs: %v", want, got, gotLogs)
    	}
    	i := 0
    	for _, l := range gotLogs {
    		var parsedLog map[string]any
    		assert.NoError(t, json.Unmarshal([]byte(l), &parsedLog))
    		if parsedLog["scope"] != "cni-plugin" {
    			// Each log is 2x: one direct, and one over UDS. Just test the UDS one
    			continue
    		}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jun 12 16:26:28 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/pod_cache_test.go

    	}
    	if nil != p.Take(string(pod.UID)) {
    		// expect nil because we already took it
    		t.Fatal("Expected nil Netns for the same uid twice")
    	}
    }
    
    var counter atomic.Int64
    
    func inc() uintptr {
    	return uintptr(counter.Add(1))
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 14 19:36:19 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  8. build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/classanalysis/AnalyzeAndShade.kt

            Files.walkFileTree(
                dir,
                object : FileVisitor<Path> {
    
                    private
                    var seenManifest: Boolean = false
    
                    override fun preVisitDirectory(dir: Path?, attrs: BasicFileAttributes?) =
                        FileVisitResult.CONTINUE
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Oct 28 12:55:30 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  9. internal/config/bool-flag.go

    func (bf BoolFlag) MarshalJSON() ([]byte, error) {
    	return json.Marshal(bf.String())
    }
    
    // UnmarshalJSON - parses given data into BoolFlag.
    func (bf *BoolFlag) UnmarshalJSON(data []byte) (err error) {
    	var s string
    	if err = json.Unmarshal(data, &s); err == nil {
    		b := BoolFlag(true)
    		if s == "" {
    			// Empty string is treated as valid.
    			*bf = b
    		} else if b, err = ParseBoolFlag(s); err == nil {
    			*bf = b
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 07 15:10:40 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  10. internal/crypto/header.go

    	h.Del(xhttp.AmzMetaUnencryptedContentLength)
    	h.Del(xhttp.AmzMetaUnencryptedContentMD5)
    }
    
    // SSECopy represents AWS SSE-C for copy requests. It provides
    // functionality to handle SSE-C copy requests.
    var SSECopy = ssecCopy{}
    
    type ssecCopy struct{}
    
    // IsRequested returns true if the HTTP headers contains
    // at least one SSE-C copy header. Regular SSE-C headers
    // are ignored.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top