- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for EncodedOutput (0.41 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/stream/EncodedStreamTest.groovy
import spock.lang.Specification class EncodedStreamTest extends Specification { def "can encode and decode an empty stream"() { def outputStream = new ByteArrayOutputStream() def encoder = new EncodedStream.EncodedOutput(outputStream) when: encoder.flush() then: def inputStream = new ByteArrayInputStream(outputStream.toByteArray()) def decoder = new EncodedStream.EncodedInput(inputStream)
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
} } public static class EncodedOutput extends OutputStream { private final OutputStream delegate; public EncodedOutput(OutputStream delegate) { this.delegate = delegate; } @Override public void write(int b) 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/workers/src/test/groovy/org/gradle/process/internal/worker/child/BootstrapSecurityManagerTest.groovy
def "fails with proper error message if System.in is not delivering all expected data"() { given: def incompleteStream = new ByteArrayOutputStream() def dataOut = new DataOutputStream(new EncodedStream.EncodedOutput(incompleteStream)) dataOut.writeInt(1) // expect one classpath entry dataOut.write(1234) // but the entry is not a complete UTF-8 encoded String
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 4.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonStartupCommunication.java
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); try { byteArrayOutputStream.write(daemonGreeting().getBytes()); OutputStream outputStream = new EncodedStream.EncodedOutput(byteArrayOutputStream); FlushableEncoder encoder = new OutputStreamBackedEncoder(outputStream); encoder.writeNullableString(pid == null ? null : pid.toString()); encoder.writeString(uid);
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/ApplicationClassesInSystemClassLoaderWorkerImplementationFactory.java
// Serialize configuration for the worker process to it stdin StreamByteBuffer buffer = new StreamByteBuffer(); try { DataOutputStream outstr = new DataOutputStream(new EncodedStream.EncodedOutput(buffer.getOutputStream())); if (!useOptionsFile) { // Serialize the application classpath, this is consumed by BootstrapSecurityManager outstr.writeInt(applicationClasspath.size());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 20 10:09:51 UTC 2024 - 9.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DefaultDaemonStarter.java
// Serialize configuration to daemon via the process' stdin StreamByteBuffer buffer = new StreamByteBuffer(); FlushableEncoder encoder = new KryoBackedEncoder(new EncodedStream.EncodedOutput(buffer.getOutputStream())); try { encoder.writeString(daemonParameters.getGradleUserHomeDir().getAbsolutePath()); encoder.writeString(daemonDir.getBaseDir().getAbsolutePath());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 10.7K bytes - Viewed (0)