- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 674 for mocked (0.21 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)