Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 1,214 for Func (0.05 sec)

  1. cmd/xl-storage-format-v2_string.go

    var _VersionType_index = [...]uint8{0, 18, 28, 38, 48, 63}
    
    func (i VersionType) String() string {
    	if i >= VersionType(len(_VersionType_index)-1) {
    		return "VersionType(" + strconv.FormatInt(int64(i), 10) + ")"
    	}
    	return _VersionType_name[_VersionType_index[i]:_VersionType_index[i+1]]
    }
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Dec 02 19:29:16 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  2. internal/config/dns/operator_dns.go

    type OperatorOption func(*OperatorDNS)
    
    // Authentication - custom username and password for authenticating at the endpoint
    func Authentication(username, password string) OperatorOption {
    	return func(args *OperatorDNS) {
    		args.username = username
    		args.password = password
    	}
    }
    
    // RootCAs - add custom trust certs pool
    func RootCAs(certPool *x509.CertPool) OperatorOption {
    	return func(args *OperatorDNS) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  3. cmd/iam-store.go

    			r = append(r, v)
    		}
    	}
    
    	sort.Slice(r, func(i, j int) bool {
    		return r[i].User < r[j].User
    	})
    
    	return r
    }
    
    // Assumes store is locked by caller. If groups is empty, returns all group mappings.
    func (store *IAMStoreSys) listGroupPolicyMappings(cache *iamCache, groupsSet set.StringSet,
    	groupPredicate func(string) bool, decodeFunc func(string) string,
    ) []madmin.GroupPolicyEntities {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  4. internal/dsync/utils.go

    package dsync
    
    import (
    	"math/rand"
    	"time"
    )
    
    func backoffWait(min, unit, cap time.Duration) func(*rand.Rand, uint) time.Duration {
    	if unit > time.Hour {
    		// Protect against integer overflow
    		panic("unit cannot exceed one hour")
    	}
    	return func(r *rand.Rand, attempt uint) time.Duration {
    		sleep := min
    		sleep += unit * time.Duration(attempt)
    		if sleep > cap {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 13 15:42:21 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  5. cmd/leak-detect_test.go

    // function to be run at the end of tests to see whether any
    // goroutines leaked.
    // Usage: `defer DetectTestLeak(t)()` in beginning line of benchmarks or unit tests.
    func DetectTestLeak(t TestErrHandler) func() {
    	initialStackSnapShot := NewLeakDetect()
    	return func() {
    		initialStackSnapShot.DetectLeak(t)
    	}
    }
    
    // list of functions to be ignored from the stack trace.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. cmd/generic-handlers_test.go

    }
    
    func TestSSETLSHandler(t *testing.T) {
    	defer func(isSSL bool) { globalIsTLS = isSSL }(globalIsTLS) // reset globalIsTLS after test
    
    	var okHandler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
    		w.WriteHeader(http.StatusOK)
    	}
    	for i, test := range sseTLSHandlerTests {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. tensorflow/c/eager/c_api_unified_experimental.cc

    void TF_DeleteAbstractFunction(TF_AbstractFunction* func) {
      unwrap(func)->Unref();
    }
    
    void TF_ExecutionContextRegisterFunction(TF_ExecutionContext* ctx,
                                             TF_AbstractFunction* func,
                                             TF_Status* s) {
      tsl::Set_TF_Status_from_Status(s,
                                     unwrap(ctx)->RegisterFunction(unwrap(func)));
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 9K bytes
    - Viewed (0)
  8. cmd/bitrot-whole.go

    	hash.Hash       // For bitrot hash
    }
    
    func (b *wholeBitrotWriter) Write(p []byte) (int, error) {
    	err := b.disk.AppendFile(context.TODO(), b.volume, b.filePath, p)
    	if err != nil {
    		return 0, err
    	}
    	_, err = b.Hash.Write(p)
    	if err != nil {
    		return 0, err
    	}
    	return len(p), nil
    }
    
    func (b *wholeBitrotWriter) Close() error {
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  9. cmd/etcd.go

    func etcdErrToErr(err error, etcdEndpoints []string) error {
    	if err == nil {
    		return nil
    	}
    	switch err {
    	case context.DeadlineExceeded:
    		return fmt.Errorf("%w %s", errEtcdUnreachable, etcdEndpoints)
    	default:
    		return fmt.Errorf("unexpected error %w from etcd, please check your endpoints %s", err, etcdEndpoints)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  10. internal/lock/lock.go

    	*LockedFile
    	mutex sync.Mutex
    	refs  int // Holds read lock refs.
    }
    
    // IsClosed - Check if the rlocked file is already closed.
    func (r *RLockedFile) IsClosed() bool {
    	r.mutex.Lock()
    	defer r.mutex.Unlock()
    	return r.refs == 0
    }
    
    // IncLockRef - is used by called to indicate lock refs.
    func (r *RLockedFile) IncLockRef() {
    	r.mutex.Lock()
    	r.refs++
    	r.mutex.Unlock()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 2.5K bytes
    - Viewed (0)
Back to top