Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 116 for Blocker (0.04 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        // after some period of time the runner thread should become blocked on the task because it is
        // waiting for the slow interrupting thread to complete Thread.interrupt
        awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class);
    
        Blocker blocker = (Blocker) LockSupport.getBlocker(runner);
        Thread owner = blocker.getOwner();
        assertThat(owner).isSameInstanceAs(interrupter);
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  2. internal/lsync/lrwmutex_test.go

    	wl := NewLRWMutex()
    	var rl sync.Locker
    	wlocked := make(chan bool, 1)
    	rlocked := make(chan bool, 1)
    	rl = wl.DRLocker()
    	n := 10
    	go func() {
    		for range n {
    			rl.Lock()
    			rl.Lock()
    			rlocked <- true
    			wl.Lock()
    			wlocked <- true
    		}
    	}()
    	for range n {
    		<-rlocked
    		rl.Unlock()
    		select {
    		case <-wlocked:
    			t.Fatal("RLocker() didn't read-lock it")
    		default:
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  3. internal/dsync/locker.go

    	String() string
    
    	// Close closes any underlying connection to the service endpoint
    	Close() error
    
    	// Is the underlying connection online? (is always true for any local lockers)
    	IsOnline() bool
    
    	// Is the underlying locker local to this server?
    	IsLocal() bool
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jan 18 20:44:38 GMT 2022
    - 2.7K bytes
    - Click Count (0)
  4. 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 :
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Nov 09 16:39:20 GMT 2024
    - 7.5K bytes
    - Click Count (0)
  5. internal/lsync/lrwmutex.go

    	lm.ref = 0
    	lm.isWriteLock = false
    }
    
    // DRLocker returns a sync.Locker interface that implements
    // the Lock and Unlock methods by calling drw.RLock and drw.RUnlock.
    func (lm *LRWMutex) DRLocker() sync.Locker {
    	return (*drlocker)(lm)
    }
    
    type drlocker LRWMutex
    
    func (dr *drlocker) Lock()   { (*LRWMutex)(dr).RLock() }
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.8K bytes
    - Click Count (0)
  6. cmd/namespace-lock.go

    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/lsync"
    )
    
    // local lock servers
    var globalLockServer *localLocker
    
    // RWLocker - locker interface to introduce GetRLock, RUnlock.
    type RWLocker interface {
    	GetLock(ctx context.Context, timeout *dynamicTimeout) (lkCtx LockContext, timedOutErr error)
    	Unlock(lkCtx LockContext)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  7. docker-buildx.sh

    		_build "${each_osarch}"
    	done
    
    	sudo sysctl net.ipv6.conf.all.disable_ipv6=0
    
    	docker buildx build --push --no-cache \
    		--build-arg RELEASE="${release}" \
    		-t "registry.min.dev/community/minio:latest" \
    		-t "registry.min.dev/community/minio:${release}" \
    		--platform=linux/arm64,linux/amd64,linux/ppc64le \
    		-f Dockerfile .
    
    	docker buildx prune -f
    
    	sudo sysctl net.ipv6.conf.all.disable_ipv6=0
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Oct 19 08:22:05 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  8. docs/orchestration/docker-compose/docker-compose.yaml

      # environment:
        # MINIO_ROOT_USER: minioadmin
        # MINIO_ROOT_PASSWORD: minioadmin
      healthcheck:
        test: ["CMD", "mc", "ready", "local"]
        interval: 5s
        timeout: 5s
        retries: 5
    
    # starts 4 docker containers running minio server instances.
    # using nginx reverse proxy, load balancing, you can access
    # it through port 9000.
    services:
      minio1:
        <<: *minio-common
        hostname: minio1
        volumes:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 07 05:14:10 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  9. docs/resiliency/docker-compose.yaml

      expose:
        - "9000"
        - "9001"
      environment:
        MINIO_CI_CD: 1
      healthcheck:
        test: ["CMD", "mc", "ready", "local"]
        interval: 5s
        timeout: 5s
        retries: 5
    
    # starts 4 docker containers running minio server instances.
    # using nginx reverse proxy, load balancing, you can access
    # it through port 9000.
    services:
      minio1:
        <<: *minio-common
        hostname: minio1
        volumes:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Dec 21 04:24:45 GMT 2024
    - 2.2K bytes
    - Click Count (0)
  10. internal/dsync/drwmutex_test.go

    	expected := true
    	if locked != expected {
    		t.Errorf("TestSimpleWriteLockAcquired(): \nexpected %#v\ngot      %#v", expected, locked)
    	}
    }
    
    func TestSimpleWriteLockTimedOut(t *testing.T) {
    	locked := testSimpleWriteLock(t, testDrwMutexAcquireTimeout)
    
    	expected := false
    	if locked != expected {
    		t.Errorf("TestSimpleWriteLockTimedOut(): \nexpected %#v\ngot      %#v", expected, locked)
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.4K bytes
    - Click Count (0)
Back to Top