Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 90 for Blocker (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  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. 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)
  6. 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)
  7. 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)
  8. .github/workflows/multipart/docker-compose-site1.yaml

    x-minio-common: &minio-common
      image: quay.io/minio/minio:${RELEASE}
      command: server http://site1-minio{1...4}/data{1...2}
      environment:
        - MINIO_PROMETHEUS_AUTH_TYPE=public
        - CI=true
    
    # starts 4 docker containers running minio server instances.
    # using nginx reverse proxy, load balancing, you can access
    # it through port 9000.
    services:
      site1-minio1:
        <<: *minio-common
        hostname: site1-minio1
        volumes:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Sep 30 10:13:56 GMT 2023
    - 1.5K bytes
    - Click Count (0)
  9. internal/lock/lock.go

    // open file descriptor.
    package lock
    
    import (
    	"errors"
    	"os"
    	"sync"
    )
    
    // ErrAlreadyLocked is returned if the underlying fd is already locked.
    var ErrAlreadyLocked = errors.New("file already locked")
    
    // RLockedFile represents a read locked file, implements a special
    // closer which only closes the associated *os.File when the ref count.
    // has reached zero, i.e when all the readers have given up their locks.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 2.5K bytes
    - Click Count (0)
  10. .github/workflows/multipart/docker-compose-site2.yaml

    x-minio-common: &minio-common
      image: quay.io/minio/minio:${RELEASE}
      command: server http://site2-minio{1...4}/data{1...2}
      environment:
        - MINIO_PROMETHEUS_AUTH_TYPE=public
        - CI=true
    
    # starts 4 docker containers running minio server instances.
    # using nginx reverse proxy, load balancing, you can access
    # it through port 9000.
    services:
      site2-minio1:
        <<: *minio-common
        hostname: site2-minio1
        volumes:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Sep 30 10:13:56 GMT 2023
    - 1.5K bytes
    - Click Count (0)
Back to Top