Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 100 for lockers (0.37 sec)

  1. internal/dsync/locker.go

    package dsync
    
    import "context"
    
    // NetLocker is dsync compatible locker interface.
    type NetLocker interface {
    	// Do read lock for given LockArgs.  It should return
    	// * a boolean to indicate success/failure of the operation
    	// * an error on failure of lock request operation.
    	RLock(ctx context.Context, args LockArgs) (bool, error)
    
    	// Do write lock for given LockArgs. It should return
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jan 18 20:44:38 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  2. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 3.1K bytes
    - Viewed (0)
  3. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 05 23:56:35 UTC 2023
    - 9.2K bytes
    - Viewed (0)
  4. cmd/lock-rest-server-common_test.go

    		TimeLastRefresh: UTCNow(),
    	}
    
    	locker.ll.lockMap["name"] = []lockRequesterInfo{
    		lockRequesterInfo1,
    		lockRequesterInfo2,
    	}
    
    	lri := locker.ll.lockMap["name"]
    
    	// test unknown uid
    	if locker.ll.removeEntry("name", dsync.LockArgs{
    		Owner: "owner",
    		UID:   "unknown-uid",
    	}, &lri) {
    		t.Errorf("Expected %#v, got %#v", false, true)
    	}
    
    	if !locker.ll.removeEntry("name", dsync.LockArgs{
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Mar 23 17:26:21 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  5. tools/istio-docker.mk

    docker.all: docker
    	@:
    dockerx.save: docker.save
    	@:
    dockerx.push: docker.push
    	@:
    dockerx.pushx: docker.push
    	@:
    dockerx: docker
    	@:
    
    # Support individual images like `dockerx.pilot`
    
    # Docker commands defines some convenience targets
    # Build individual docker image and push it. Ex: push.docker.pilot
    push.docker.%:
    	DOCKER_TARGETS=docker.$* ./tools/docker --push
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 31 21:56:36 UTC 2022
    - 2.1K bytes
    - Viewed (0)
  6. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Nov 24 17:07:14 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  7. tools/docker

      fi
    else
      GOOS=${LOCAL_GO_OS} GOARCH=${LOCAL_GO_ARCH} ./common/scripts/gobuild.sh ${LOCAL_OUT}/docker-builder ./tools/docker-builder
    fi
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 07 22:50:06 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  8. src/runtime/lock_js.go

    		// observe this.
    		throw("self deadlock")
    	}
    	gp := getg()
    	if gp.m.locks < 0 {
    		throw("lock count")
    	}
    	gp.m.locks++
    	l.key = mutex_locked
    }
    
    func unlock(l *mutex) {
    	unlockWithRank(l)
    }
    
    func unlock2(l *mutex) {
    	if l.key == mutex_unlocked {
    		throw("unlock of unlocked lock")
    	}
    	gp := getg()
    	gp.m.locks--
    	if gp.m.locks < 0 {
    		throw("lock count")
    	}
    	l.key = mutex_unlocked
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 21 21:02:20 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  9. tools/docker.yaml

      dockerfile: samples/extauthz/docker/Dockerfile
      targets:
        - ${TARGET_OUT_LINUX}/extauthz
    
    # TODO(https://github.com/istio/istio/issues/38224)
    - name: app_sidecar_rockylinux_9
      dockerfile: pkg/test/echo/docker/Dockerfile.app_sidecar_centos_8
      files:
      - tools/packaging/common/envoy_bootstrap.json
      - tests/testdata/certs
      - pkg/test/echo/docker/echo-start.sh
      - pkg/test/echo/docker/sudoers
      targets:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 12:26:52 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. docs/fr/docs/deployment/docker.md

    Vous pouvez utiliser <a href="https://www.docker.com/" class="external-link" target="_blank">**Docker**</a> pour le déploiement. Il présente plusieurs avantages comme la sécurité, la réplicabilité, la simplicité de développement, etc.
    
    Si vous utilisez Docker, vous pouvez utiliser l'image Docker officielle :
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Thu May 12 00:06:16 UTC 2022
    - 7.5K bytes
    - Viewed (0)
Back to top