- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for OutgoingQueue (0.15 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) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHub.java
private State state = State.Running; private final IncomingQueue incomingQueue = new IncomingQueue(lock); private final OutgoingQueue outgoingQueue = new OutgoingQueue(incomingQueue, lock); private final ConnectionSet connections = new ConnectionSet(incomingQueue, outgoingQueue); /** * @param errorHandler Notified when some async activity fails. Must be thread-safe. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 16.2K bytes - Viewed (0) -
testing/architecture-test/src/changes/archunit-store/internal-api-nullability.txt
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 967.9K bytes - Viewed (0)