- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,541 for Receive (1.18 sec)
-
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DefaultDaemonConnectionTest.groovy
def result = [] result << daemonConnection.receive(20, TimeUnit.SECONDS) result << daemonConnection.receive(20, TimeUnit.SECONDS) result << daemonConnection.receive(20, TimeUnit.SECONDS) daemonConnection.stop() then: result*.message == ["incoming1", "incoming2", "incoming3"] } def "receive blocks until message available"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 11.7K bytes - Viewed (0) -
platforms/core-configuration/declarative-dsl-provider/src/main/kotlin/org/gradle/internal/declarativedsl/conventions/conventions.kt
} } /** * A convention that applies a nested object access operation (e.g. foo { }). */ class NestedObjectAccessConvention(private val nestedObjectAccessRecord: NestedObjectAccessRecord) : Convention<NestedObjectAccessRecordConventionReceiver> { override fun apply(receiver: NestedObjectAccessRecordConventionReceiver) { receiver.receive(nestedObjectAccessRecord) } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 12:25:47 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/FileLockCommunicatorTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/proxy/util/utils_test.go
expectCorrect: nil, expectIncorrect: nil, }, { desc: "want IPv4 and receive IPv6", ipString: []string{"fd00:20::1"}, wantIPv6: false, expectCorrect: nil, expectIncorrect: []string{"fd00:20::1"}, }, { desc: "want IPv6 and receive IPv4", ipString: []string{"192.168.200.2"}, wantIPv6: true, expectCorrect: nil,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 17.1K bytes - Viewed (0) -
docs/en/docs/tutorial/request-forms-and-files.md
``` The files and form fields will be uploaded as form data and you will receive the files and form fields. And you can declare some of the files as `bytes` and some as `UploadFile`. !!! warning
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Mar 13 19:02:19 UTC 2024 - 2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonClientTest.groovy
1 * connection.dispatch({ it instanceof Build }) 1 * connection.receive() >> Stub(DaemonUnavailable) 1 * connection.dispatch({ it instanceof Finished }) 1 * connection.stop() _ * connection2.daemon >> Stub(DaemonConnectDetails) 2 * connection2.receive() >>> [Stub(BuildStarted), new Success(resultMessage)] 0 * connection._ }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 10K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/SynchronizedDispatchConnection.java
} finally { lock.unlock(); } } @Override public T receive() { //in case one wants to synchronize this method, //bear in mind that it is blocking so it cannot share the same lock as others T result = delegate.receive(); LOGGER.debug("thread {}: received {}", Thread.currentThread().getId(), result == null ? "null" : result.getClass()); return result; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClientConnection.java
} } } @Override @Nullable public Message receive() throws DaemonConnectionException { try { return connection.receive(); } catch (MessageIOException e) { LOG.debug("Problem receiving message to the daemon. Performing 'on failure' operation...");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 30 06:43:50 UTC 2024 - 4.2K bytes - Viewed (0) -
src/runtime/sigqueue.go
} } // Wait for updates to be available from signal sender. Receive: for { switch sig.state.Load() { default: throw("signal_recv: inconsistent state") case sigIdle: if sig.state.CompareAndSwap(sigIdle, sigReceiving) { if GOOS == "darwin" || GOOS == "ios" { sigNoteSleep(&sig.note) break Receive } notetsleepg(&sig.note, -1) noteclear(&sig.note)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultDaemonConnection.java
// 2. Stop the connection. This means that the thread receiving from the connection will receive a null and finish up. // 3. Stop receiving incoming messages. Blocks until the receive thread has finished. This will notify the stdin and receive queues to signal end of input. // 4. Stop the receive queue, to unblock any threads blocked in receive().
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 16K bytes - Viewed (0)