- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 95 for isMatching (0.23 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClientConnection.java
dispatchLock.unlock(); } } catch (MessageIOException e) { if (suspect) { LOG.debug("Problem dispatching message to the daemon.", e); } else { LOG.debug("Problem dispatching message to the daemon. Performing 'on failure' operation..."); if (!hasReceived && staleAddressDetector.maybeStaleAddress(e)) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 30 06:43:50 UTC 2024 - 4.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/interface.go
// Complete returns a QueueSet configured by the given // dispatching configuration. Complete(DispatchingConfig) QueueSet } // QueueSet is the abstraction for the queuing and dispatching // functionality of one non-exempt priority level. It covers the // functionality described in the "Assignment to a Queue", "Queuing", // and "Dispatching" sections of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 6.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/DispatchFailureHandler.java
*/ package org.gradle.internal.dispatch; public interface DispatchFailureHandler<T> { /** * Called when a message could not be dispatched. This method can throw an exception to abort further dispatching. */ void dispatchFailed(T message, Throwable failure);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 892 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
dispatching bool // watchersBuffer is a list of watchers potentially interested in currently // dispatched event. watchersBuffer []*cacheWatcher // blockedWatchers is a list of watchers whose buffer is currently full. blockedWatchers []*cacheWatcher // watchersToStop is a list of watchers that were supposed to be stopped // during current dispatching, but stopping was deferred to the end of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/ReturnResult.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/StartBuildOrRespondWithBusy.java
try { Runnable command = new Runnable() { @Override public void run() { LOGGER.info("Daemon is about to start building {}. Dispatching build started information...", build); execution.getConnection().buildStarted(new BuildStarted(diagnostics)); execution.proceed(); } };
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.8K bytes - Viewed (0) -
internal/hash/reader_test.go
src: mustReader(t, bytes.NewReader([]byte("abcd")), 4, "", "", 4), size: 4, actualSize: 4, success: true, }, { desc: "Mismatching sha256", src: mustReader(t, bytes.NewReader([]byte("abcd")), 4, "", "88d4266fd4e6338d13b845fcf289579d209c897823b9217da3e161936f031589", 4), size: 4, actualSize: 4,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 18 17:00:54 UTC 2023 - 10.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/actor/Actor.java
/** * Stops accepting new method calls, and blocks until all method calls have been executed by the target object. * * @throws DispatchException When there were any failures dispatching method calls to the target object. */ @Override void stop() throws DispatchException;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/ir/tf_ops_tensor_helper.h
// Verifies that the given types are cast compatible. If not, emits appropriate // error for the given op. If mask_one_dim is set to true, then the types are // allowed to have one mismatching dimension. Masking one of the dimensions is // useful for ops like Concat that requires all ranked inputs to have the same // rank and match dimension sizes for all but one of the dimensions.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubTest.groovy
then: new ArrayList<String>(messages).sort() == 0..19 cleanup: connection1.stop() connection2.stop() } def "stops dispatching outgoing messages to failed connection"() { RemoteConnection<InterHubMessage> outgoing = Mock() def connection = new MockOutgoingConnection(outgoing) def dispatch = hub.getOutgoing("channel", String)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 21.8K bytes - Viewed (0)