Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 84 for runHook (0.12 sec)

  1. internal/config/lambda/event/targetlist.go

    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    
    	targets := make([]Target, 0, len(list.targets))
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    	}
    
    	return targets
    }
    
    // Empty returns true if targetList is empty.
    func (list *TargetList) Empty() bool {
    	list.RLock()
    	defer list.RUnlock()
    
    	return len(list.targets) == 0
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  2. internal/dsync/drwmutex_test.go

    	}
    	// fmt.Println("2nd read lock acquired, waiting...")
    
    	go func() {
    		time.Sleep(2 * testDrwMutexAcquireTimeout)
    		drwm1.RUnlock(context.Background())
    		// fmt.Println("1st read lock released, waiting...")
    	}()
    
    	go func() {
    		time.Sleep(3 * testDrwMutexAcquireTimeout)
    		drwm2.RUnlock(context.Background())
    		// fmt.Println("2nd read lock released, waiting...")
    	}()
    
    	drwm3 := NewDRWMutex(ds, "simplelock")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 24 03:49:07 UTC 2022
    - 9.7K bytes
    - Viewed (0)
  3. cmd/bucket-targets.go

    // healthCheck map if missing and default to online status
    func (sys *BucketTargetSys) isOffline(ep *url.URL) bool {
    	sys.hMutex.RLock()
    	defer sys.hMutex.RUnlock()
    	if h, ok := sys.hc[ep.Host]; ok {
    		return !h.Online
    	}
    	go sys.initHC(ep)
    	return false
    }
    
    // markOffline sets endpoint to offline if network i/o timeout seen.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  4. cmd/namespace-lock.go

    	}
    	timeout.LogSuccess(UTCNow().Sub(start))
    	return LockContext{ctx: newCtx, cancel: cancel}, nil
    }
    
    // RUnlock - block until read lock is released.
    func (di *distLockInstance) RUnlock(lc LockContext) {
    	if lc.cancel != nil {
    		lc.cancel()
    	}
    	di.rwMutex.RUnlock(lc.ctx)
    }
    
    // localLockInstance - frontend/top-level interface for namespace locks.
    type localLockInstance struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  5. internal/store/queuestore.go

    }
    
    // GetRaw - gets an item from the store.
    func (store *QueueStore[I]) GetRaw(key Key) (raw []byte, err error) {
    	store.RLock()
    
    	defer func(store *QueueStore[I]) {
    		store.RUnlock()
    		if err != nil && !os.IsNotExist(err) {
    			// Upon error we remove the entry.
    			store.Del(key)
    		}
    	}(store)
    
    	raw, err = os.ReadFile(filepath.Join(store.directory, key.String()))
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  6. internal/lsync/lrwmutex_test.go

    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("2nd read lock acquired, waiting...")
    
    	go func() {
    		time.Sleep(2 * time.Second)
    		lrwm.RUnlock()
    		// fmt.Println("1st read lock released, waiting...")
    	}()
    
    	go func() {
    		time.Sleep(3 * time.Second)
    		lrwm.RUnlock()
    		// fmt.Println("2nd read lock released, waiting...")
    	}()
    
    	// fmt.Println("Trying to acquire write lock, waiting...")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  7. cmd/handler-api.go

    	}
    }
    
    func (t *apiConfig) odirectEnabled() bool {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	return t.enableODirect
    }
    
    func (t *apiConfig) shouldGzipObjects() bool {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	return t.gzipObjects
    }
    
    func (t *apiConfig) permitRootAccess() bool {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	return t.rootAccess
    }
    
    func (t *apiConfig) getListQuorum() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  8. internal/bucket/bandwidth/monitor.go

    }
    
    // GetReport gets the report for all bucket bandwidth details.
    func (m *Monitor) GetReport(selectBucket SelectionFunction) *BucketBandwidthReport {
    	m.mlock.RLock()
    	defer m.mlock.RUnlock()
    	return m.getReport(selectBucket)
    }
    
    func (m *Monitor) getReport(selectBucket SelectionFunction) *BucketBandwidthReport {
    	report := &BucketBandwidthReport{
    		BucketStats: make(map[BucketOptions]Details),
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. cmd/lock-rest-client.go

    }
    
    // Lock calls lock REST API.
    func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCLock, &args)
    }
    
    // RUnlock calls read unlock REST API.
    func (c *lockRESTClient) RUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCRUnlock, &args)
    }
    
    // Refresh calls Refresh REST API.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  10. internal/lsync/lrwmutex.go

    	if !success {
    		panic("Trying to Unlock() while no Lock() is active")
    	}
    }
    
    // RUnlock releases a read lock held on lm.
    //
    // It is a run-time error if lm is not locked on entry to RUnlock.
    func (lm *LRWMutex) RUnlock() {
    	isWriteLock := false
    	success := lm.unlock(isWriteLock)
    	if !success {
    		panic("Trying to RUnlock() while no RLock() is active")
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
Back to top