- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for DaemonStartupCommunication (0.39 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonStartupCommunication.java
import java.io.File; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.PrintStream; public class DaemonStartupCommunication { private static final Logger LOGGER = Logging.getLogger(DaemonStartupCommunication.class); @SuppressWarnings("DefaultCharset") public void printDaemonStarted(PrintStream target, Long pid, String uid, Address address, File daemonLog) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 4.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonGreeter.java
this.documentationRegistry = documentationRegistry; } public DaemonStartupInfo parseDaemonOutput(String output, List<String> startupArgs) { DaemonStartupCommunication startupCommunication = new DaemonStartupCommunication(); if (!startupCommunication.containsGreeting(output)) { throw new GradleException(prepareMessage(output, startupArgs)); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 05 22:24:02 UTC 2024 - 2.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonOutputConsumer.java
import java.util.concurrent.Executor; public class DaemonOutputConsumer implements StreamsHandler { private final static Logger LOGGER = Logging.getLogger(DaemonOutputConsumer.class); DaemonStartupCommunication startupCommunication = new DaemonStartupCommunication(); private String processOutput; private InputStream processStdOutput; @Override public void connectStreams(Process process, String processName, Executor executor) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 2.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/bootstrap/DaemonStartupCommunicationSpec.groovy
import org.gradle.internal.remote.internal.inet.MultiChoiceAddress import spock.lang.Specification class DaemonStartupCommunicationSpec extends Specification { def comm = new DaemonStartupCommunication() def dummyFile = new File("C:\\foo;;\\daemon-123.log\n\r\n\u03b1") def uuid = UUID.randomUUID() def addresses = [InetAddress.getByName(null)] def "can simply communicate diagnostics"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/bootstrap/DaemonOutputConsumerTest.groovy
Hey! Come visit Krakow It's nice !!! """ def process = process(output) given: consumer.startupCommunication = Mock(DaemonStartupCommunication) consumer.startupCommunication.containsGreeting({ it.contains "Come visit Krakow" }) >> true when: consumer.connectStreams(process, "cool process", executor) consumer.start()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/bootstrap/DaemonGreeterTest.groovy
def outputStream = new ByteArrayOutputStream() def printStream = new PrintStream(outputStream) printStream.print("""hey joe! another line of output... """) new DaemonStartupCommunication().printDaemonStarted(printStream, 12, "uid", address, new File("12.log")) def output = new String(outputStream.toByteArray()) when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.7K bytes - Viewed (0) -
platforms/core-runtime/daemon-server/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonMain.java
System.exit(1); } protected void daemonStarted(Long pid, String uid, Address address, File daemonLog) { // directly printing to the stream to avoid log level filtering. new DaemonStartupCommunication().printDaemonStarted(originalOut, pid, uid, address, daemonLog); try { originalOut.close(); originalErr.close(); } finally { originalOut = null;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 9.8K 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)