Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 189 for lockers (0.62 sec)

  1. cmd/namespace-lock.go

    	}
    	nsLk.ref++
    	n.lockMap[resource] = nsLk
    	n.lockMapMutex.Unlock()
    
    	// Locking here will block (until timeout).
    	if readLock {
    		locked = nsLk.GetRLock(ctx, opsID, lockSource, timeout)
    	} else {
    		locked = nsLk.GetLock(ctx, opsID, lockSource, timeout)
    	}
    
    	if !locked { // We failed to get the lock
    		// Decrement ref count since we failed to get the lock
    		n.lockMapMutex.Lock()
    		n.lockMap[resource].ref--
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  2. cmd/erasure-sets.go

    		}
    	}
    }
    
    func (s *erasureSets) GetLockers(setIndex int) func() ([]dsync.NetLocker, string) {
    	return func() ([]dsync.NetLocker, string) {
    		lockers := make([]dsync.NetLocker, len(s.erasureLockers[setIndex]))
    		copy(lockers, s.erasureLockers[setIndex])
    		return lockers, s.erasureLockOwner
    	}
    }
    
    func (s *erasureSets) GetEndpointStrings(setIndex int) func() []string {
    	return func() []string {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  3. cmd/namespace-lock_test.go

    		// Unlock the 1st lock; ref=1 after this line
    		nsLk.unlock("volume", "path", false)
    
    		// Taking another lockMapMutex here allows queuing up additional lockers. This should
    		// not be required but makes reproduction much easier.
    		nsLk.lockMapMutex.Lock()
    
    		// lk3 blocks.
    		lk3ch := make(chan bool)
    		go func() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3K bytes
    - Viewed (0)
  4. cmd/erasure.go

    	// getLockers returns list of remote and local lockers.
    	getLockers func() ([]dsync.NetLocker, string)
    
    	// getEndpoints returns list of endpoint belonging this set.
    	// some may be local and some remote.
    	getEndpoints func() []Endpoint
    
    	// getEndpoints returns list of endpoint strings belonging this set.
    	// some may be local and some remote.
    	getEndpointStrings func() []string
    
    	// Locker mutex map.
    	nsMutex *nsLockMap
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    	vars := mux.Vars(r)
    
    	var args dsync.LockArgs
    	var lockers []dsync.NetLocker
    	for path := range strings.SplitSeq(vars["paths"], ",") {
    		if path == "" {
    			continue
    		}
    		args.Resources = append(args.Resources, path)
    	}
    
    	for _, lks := range z.serverPools[0].erasureLockers {
    		lockers = append(lockers, lks...)
    	}
    
    	for _, locker := range lockers {
    		locker.ForceUnlock(ctx, args)
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  6. cmd/local-locker.go

    func (l *localLocker) Close() error {
    	return nil
    }
    
    // IsOnline - local locker is always online.
    func (l *localLocker) IsOnline() bool {
    	return true
    }
    
    // IsLocal - local locker returns true.
    func (l *localLocker) IsLocal() bool {
    	return true
    }
    
    func (l *localLocker) ForceUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	if ctx.Err() != nil {
    		return false, ctx.Err()
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  7. cmd/lock-rest-client.go

    func (c *lockRESTClient) String() string {
    	return c.connection.Remote
    }
    
    func (c *lockRESTClient) call(ctx context.Context, h *grid.SingleHandler[*dsync.LockArgs, *dsync.LockResp], args *dsync.LockArgs) (ok bool, err error) {
    	r, err := h.Call(ctx, c.connection, args)
    	if err != nil {
    		return false, err
    	}
    	defer h.PutResponse(r)
    	ok = r.Code == dsync.RespOK
    	switch r.Code {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  8. docs/en/docs/deployment/docker.md

    And if you need to have multiple workers, you can simply use the `--workers` command line option.
    
    /// note | Technical Details
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 29.5K bytes
    - Viewed (1)
  9. docs/pt/docs/deployment/server-workers.md

    /// info | Informação
    
    Se você estiver usando contêineres, por exemplo com Docker ou Kubernetes, falarei mais sobre isso no próximo capítulo: [FastAPI em contêineres - Docker](docker.md){.internal-link target=_blank}.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Thu Jan 09 20:41:07 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  10. docs/ja/docs/deployment/server-workers.md

    * 起動時の実行
    * 再起動
    * レプリケーション(実行中のプロセス数)
    * メモリー
    * 開始前の事前のステップ
    
    
    ## コンテナとDocker
    <!-- NOTE: the current version of docker.md is outdated compared to English one.  -->
    次章の[コンテナ内のFastAPI - Docker](docker.md){.internal-link target=_blank}では、その他の**デプロイのコンセプト**を扱うために実施するであろう戦略をいくつか紹介します。
    
    また、**GunicornとUvicornワーカー**を含む**公式Dockerイメージ**と、簡単なケースに役立ついくつかのデフォルト設定も紹介します。
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 11.2K bytes
    - Viewed (0)
Back to top