- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 120 for Delivery (0.14 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/MultiChannelQueue.java
if (message.getDelivery() == InterHubMessage.Delivery.Stateful) { initializer.onStatefulMessage(message); } if (message instanceof Routable) { Routable routableMessage = (Routable) message; getChannel(routableMessage.getChannel()).dispatch(message);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/AbstractQueueTest.groovy
} def unicast() { InterHubMessage message = Stub() { getDelivery() >> InterHubMessage.Delivery.SingleHandler } return message } def stateful() { InterHubMessage message = Stub() { getDelivery() >> InterHubMessage.Delivery.Stateful } return message } def broadcast() { InterHubMessage message = Stub() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/protocol/EndOfStream.java
public class EndOfStream extends InterHubMessage { @Override public String toString() { return "[" + getClass().getSimpleName() + "]"; } @Override public Delivery getDelivery() { return Delivery.Stateful; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 926 bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/protocol/RejectedMessage.java
} @Override public String toString() { return String.format("[%s channel:%s, payload:%s]", getClass().getSimpleName(), channel, payload); } @Override public Delivery getDelivery() { return Delivery.AllHandlers; } @Override public ChannelIdentifier getChannel() { return channel; } public Object getPayload() { return payload; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/protocol/InterHubMessage.java
* limitations under the License. */ package org.gradle.internal.remote.internal.hub.protocol; public abstract class InterHubMessage { /** * Specifies the delivery constraints for this message. */ public enum Delivery { /** * Message should be delivered to a single handler, and queued until a handler is available. */ SingleHandler, /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/protocol/ChannelMessage.java
public ChannelMessage(ChannelIdentifier channel, Object payload) { this.channel = channel; this.payload = payload; } @Override public Delivery getDelivery() { return Delivery.SingleHandler; } @Override public String toString() { return String.format("[%s channel: %s, payload: %s]", getClass().getSimpleName(), channel, payload); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/protocol/StreamFailureMessage.java
this.failure = failure; } @Override public Delivery getDelivery() { // TODO: This should actually be a Routable message with a single handler, // but we need some way to correlate a given request with a specific response channel return Delivery.AllHandlers; } public Throwable getFailure() { return failure; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.2K bytes - Viewed (0) -
src/log/syslog/syslog_unix.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 758 bytes - Viewed (0) -
src/runtime/sigqueue.go
sig.recv[i] = atomic.Xchg(&sig.mask[i], 0) } } } // signalWaitUntilIdle waits until the signal delivery mechanism is idle. // This is used to ensure that we do not drop a signal notification due // to a race between disabling a signal and receiving a signal. // This assumes that signal delivery has already been disabled for // the signal(s) in question, and here we are just waiting to make sure
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.6K bytes - Viewed (0) -
src/runtime/sigqueue_plan9.go
unlock(&sig.lock) notetsleepg(&sig.note, -1) } } // signalWaitUntilIdle waits until the signal delivery mechanism is idle. // This is used to ensure that we do not drop a signal notification due // to a race between disabling a signal and receiving a signal. // This assumes that signal delivery has already been disabled for // the signal(s) in question, and here we are just waiting to make sure
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 05 17:54:15 UTC 2022 - 3.3K bytes - Viewed (0)