Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 674 for mocked (0.21 sec)

  1. maven-artifact/src/main/java/org/apache/maven/artifact/repository/ArtifactRepository.java

        @Deprecated
        void setBlacklisted(boolean blackListed);
    
        /**
         * @return whether the repository is blocked
         * @since 3.8.1
         **/
        boolean isBlocked();
    
        /**
         * @param blocked block the repository?
         * @since 3.8.1
         **/
        void setBlocked(boolean blocked);
    
        //
        // New interface methods for the repository system.
        //
        /**
         *
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Thu Feb 23 17:14:45 GMT 2023
    - 4.2K bytes
    - Viewed (0)
  2. docs/bucket/lifecycle/DESIGN.md

    # ILM Tiering Design [![slack](https://slack.min.io/slack?type=svg)](https://slack.min.io) [![Docker Pulls](https://img.shields.io/docker/pulls/minio/minio.svg?maxAge=604800)](https://hub.docker.com/r/minio/minio/)
    
    Lifecycle transition functionality provided in [bucket lifecycle guide](https://github.com/minio/minio/master/docs/bucket/lifecycle/README.md) allows tiering of content from MinIO object store to public clouds or other MinIO clusters.
    
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 4.3K bytes
    - Viewed (0)
  3. cmd/local-locker_test.go

    	}
    	// A UID is added for every resource.
    	// We removed Add Rlocked entries
    	if len(l.lockUID) != len(wResources)*m {
    		t.Fatalf("lockUID len, got %d, want %d + %d", len(l.lockUID), 0, len(wResources)*m)
    	}
    
    	// Remove write locked
    	for i, names := range wResources {
    		arg := dsync.LockArgs{
    			UID:       wUIDs[i],
    			Resources: names[:],
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Mar 05 04:57:35 GMT 2023
    - 11.8K bytes
    - Viewed (0)
  4. internal/lock/lock_test.go

    	}
    
    	// blocking on locked file
    	locked := make(chan struct{}, 1)
    	go func() {
    		bl, blerr := LockedOpenFile(f.Name(), os.O_WRONLY, 0o600)
    		if blerr != nil {
    			t.Error(blerr)
    			return
    		}
    		locked <- struct{}{}
    		if blerr = bl.Close(); blerr != nil {
    			t.Error(blerr)
    			return
    		}
    	}()
    
    	select {
    	case <-locked:
    		t.Error("unexpected unblocking")
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 3.6K bytes
    - Viewed (0)
  5. 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--
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Jun 05 23:56:35 GMT 2023
    - 9.2K bytes
    - Viewed (0)
  6. internal/grid/README.md

    Returning any error will also cancel the stream remotely.
    
    CAREFUL: When utilizing two-way communication, it is important to ensure that the remote handler is not blocked on a send.
    If the remote handler is blocked on a send, and the client is trying to send without the remote receiving, 
    the operation would become deadlocked if the channels are full.
    
    ### Typed handlers
    
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  7. tests/docker-compose.yml

    Jinzhu <******@****.***> 1710750526 +0800
    Others
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Mon Mar 18 08:28:46 GMT 2024
    - 862 bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.30.md

    conformance:v1.30.0](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/conformance) | [amd64](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/conformance-amd64), [arm64](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/conformance-arm64), [ppc64le](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/conformance-ppc64le),...
    Plain Text
    - Registered: Fri Apr 26 09:05:10 GMT 2024
    - Last Modified: Wed Apr 17 17:56:15 GMT 2024
    - 227.9K bytes
    - Viewed (0)
  9. istioctl/pkg/cli/mock_test.go

    Xiaopeng Han <******@****.***> 1686841337 +0800
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 1.3K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                throw new RejectedExecutionException();
              }
            };
        final SequentialExecutor executor = new SequentialExecutor(delegate);
        final ExecutorService blocked = Executors.newCachedThreadPool();
        Future<?> first =
            blocked.submit(
                new Runnable() {
                  @Override
                  public void run() {
                    executor.execute(Runnables.doNothing());
                  }
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 11.4K bytes
    - Viewed (0)
Back to top