- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for EncodedInput (0.24 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/stream/EncodedStreamTest.groovy
when: encoder.flush() then: def inputStream = new ByteArrayInputStream(outputStream.toByteArray()) def decoder = new EncodedStream.EncodedInput(inputStream) decoder.read() < 0 } def "can encode and decode a string"() { def outputStream = new ByteArrayOutputStream() def encoder = new EncodedStream.EncodedOutput(outputStream)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/stream/EncodedStream.java
}; @SuppressWarnings("InputStreamSlowMultibyteRead") public static class EncodedInput extends InputStream { private final InputStream delegate; public EncodedInput(java.io.InputStream delegate) { this.delegate = delegate; } @Override public int read() throws IOException {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 2.9K bytes - Viewed (0) -
platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/child/BootstrapSecurityManager.java
Method addUrlMethod = URLClassLoader.class.getDeclaredMethod("addURL", URL.class); addUrlMethod.setAccessible(true); DataInputStream inputStream = new DataInputStream(new EncodedStream.EncodedInput(System.in)); int count = inputStream.readInt(); StringBuilder classpathStr = new StringBuilder(); for (int i = 0; i < count; i++) { String entry = inputStream.readUTF();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:58:56 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/GradleWorkerMain.java
*/ public class GradleWorkerMain { public void run() throws Exception { DataInputStream instr = new DataInputStream(new EncodedStream.EncodedInput(System.in)); // Read shared packages int sharedPackagesCount = instr.readInt(); List<String> sharedPackages = new ArrayList<String>(sharedPackagesCount);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:58:56 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonStartupCommunication.java
} try { String encoded = message.substring(daemonGreeting().length()).trim(); InputStream inputStream = new EncodedStream.EncodedInput(new ByteArrayInputStream(encoded.getBytes())); Decoder decoder = new InputStreamBackedDecoder(inputStream); String pidString = decoder.readNullableString(); String uid = decoder.readString();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 4.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/child/WorkerProcessClassPathProvider.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 11.1K bytes - Viewed (0) -
platforms/core-runtime/daemon-server/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonMain.java
String daemonUid; DaemonParameters.Priority priority; List<File> additionalClassPath; KryoBackedDecoder decoder = new KryoBackedDecoder(new EncodedStream.EncodedInput(System.in)); try { gradleHomeDir = new File(decoder.readString()); daemonBaseDir = new File(decoder.readString()); idleTimeoutMs = decoder.readSmallInt();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 9.8K bytes - Viewed (0)