- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for OutgoingQueue (0.16 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/OutgoingQueue.java
import org.gradle.internal.remote.internal.hub.protocol.RejectedMessage; import java.util.ArrayList; import java.util.List; import java.util.concurrent.locks.Lock; class OutgoingQueue extends MultiEndPointQueue { private final IncomingQueue incomingQueue; OutgoingQueue(IncomingQueue incomingQueue, Lock lock) { super(lock); this.incomingQueue = incomingQueue; } void endOutput() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/ConnectionSet.java
private final IncomingQueue incomingQueue; private final OutgoingQueue outgoingQueue; private boolean stopping; ConnectionSet(IncomingQueue incomingQueue, OutgoingQueue outgoingQueue) { this.incomingQueue = incomingQueue; this.outgoingQueue = outgoingQueue; } /** * Adds a new incoming connection. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/ConnectionSetTest.groovy
class ConnectionSetTest extends AbstractQueueTest { final IncomingQueue incomingQueue = new IncomingQueue(lock) final OutgoingQueue outgoingQueue = new OutgoingQueue(incomingQueue, lock) final ConnectionSet connections = new ConnectionSet(incomingQueue, outgoingQueue) def "discards queued outgoing messages when stop requested and no connections"() { def channel = new ChannelIdentifier("channel")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 3K bytes - Viewed (0)