- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for addUnrecoverableErrorHandler (0.43 sec)
-
platforms/software/testing-base/src/test/groovy/org/gradle/api/internal/tasks/testing/worker/ForkingTestClassProcessorTest.groovy
when: processor.processTestClass(Mock(TestClassRunInfo)) then: 1 * workerProcess.getConnection() >> Stub(ObjectConnection) { addUnrecoverableErrorHandler(_) >> { args -> handler = args[0] } addOutgoing(_) >> Stub(RemoteTestClassProcessor) } when: def unexpectedException = new Throwable('BOOM!')
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 6.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnection.java
} } } }; this.hub = new MessageHub(completion.toString(), executorFactory, errorHandler); this.completion = completion; this.addUnrecoverableErrorHandler(new Action<Throwable>() { @Override public void execute(Throwable throwable) { if (!aborted && !Thread.currentThread().isInterrupted()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 7.5K bytes - Viewed (0) -
platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/child/ActionExecutionWorker.java
LOGGER.debug("Starting {}.", workerContext.getDisplayName()); ObjectConnection clientConnection = workerContext.getServerConnection(); clientConnection.addUnrecoverableErrorHandler(new Action<Throwable>() { @Override public void execute(Throwable throwable) { if (action instanceof Stoppable) { ((Stoppable) action).stop();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:58:56 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/ObjectConnection.java
/** * Add a callback upon unrecoverable errors, e.g. broken connection. Should not throw any exceptions because * this is the last line of defense. * @param handler the callback */ void addUnrecoverableErrorHandler(Action<Throwable> handler);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 2.1K bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/internal/tasks/testing/worker/ForkingTestClassProcessor.java
workerProcess.start(); ObjectConnection connection = workerProcess.getConnection(); connection.useParameterSerializers(TestEventSerializer.create()); connection.addUnrecoverableErrorHandler(new Action<Throwable>() { @Override public void execute(Throwable throwable) { lock.lock(); try { if (!stoppedNow) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 12:13:32 UTC 2024 - 7.6K bytes - Viewed (0) -
platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/child/SystemApplicationClassLoaderWorker.java
try { // Read server address and start connecting connection = basicWorkerServices.get(MessagingClient.class).getConnection(config.getServerAddress()); connection.addUnrecoverableErrorHandler(unrecoverableErrorHandler); configureLogging(loggingManager, connection, workerLogEventListener); // start logging now that the logging manager is connected loggingManager.start();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 11.9K bytes - Viewed (0)