Search Options

Display Count
Sort
Preferred Language
Advanced Search

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

  1. android/guava/src/com/google/common/util/concurrent/OverflowAvoidingLockSupport.java

      private OverflowAvoidingLockSupport() {}
    
      static void parkNanos(@Nullable Object blocker, long nanos) {
        // Even in the extremely unlikely event that a thread unblocks itself early after only 68 years,
        // this is indistinguishable from a spurious wakeup, which LockSupport allows.
        LockSupport.parkNanos(blocker, min(nanos, MAX_NANOSECONDS_THRESHOLD));
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 1.6K bytes
    - Click Count (0)
  2. 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 Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  3. 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 Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  4. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  5. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jan 18 20:44:38 GMT 2022
    - 2.7K 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 Apr 05 19:28:12 GMT 2026
    - 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 Apr 05 19:28:12 GMT 2026
    - 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 Apr 05 19:28:12 GMT 2026
    - 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Dec 21 04:24:45 GMT 2024
    - 2.2K bytes
    - Click Count (0)
  10. .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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Sep 30 10:13:56 GMT 2023
    - 1.5K bytes
    - Click Count (0)
Back to Top