- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for PayloadSerializer (0.26 sec)
-
platforms/core-runtime/daemon-protocol/src/main/java/org/gradle/tooling/internal/provider/serialization/PayloadSerializer.java
import java.io.ObjectOutputStream; import java.util.Collections; import java.util.HashMap; import java.util.Map; @ThreadSafe public class PayloadSerializer { private final PayloadClassLoaderRegistry classLoaderRegistry; public PayloadSerializer(PayloadClassLoaderRegistry registry) { classLoaderRegistry = registry; } public SerializedPayload serialize(@Nullable Object payload) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 14 00:13:09 UTC 2024 - 3K bytes - Viewed (0) -
platforms/ide/tooling-api-builders/src/main/java/org/gradle/tooling/internal/provider/runner/BuildModelActionRunner.java
import org.gradle.tooling.internal.provider.serialization.PayloadSerializer; import org.gradle.tooling.internal.provider.serialization.SerializedPayload; import org.gradle.tooling.provider.model.UnknownModelException; import org.gradle.tooling.provider.model.internal.ToolingModelScope; public class BuildModelActionRunner implements BuildActionRunner { private final PayloadSerializer payloadSerializer;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 3.7K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/InterHubMessageSerializer.java
private final StatefulSerializer<Object> payloadSerializer; public InterHubMessageSerializer(StatefulSerializer<Object> payloadSerializer) { this.payloadSerializer = payloadSerializer; } @Override public ObjectReader<InterHubMessage> newReader(Decoder decoder) { return new MessageReader(decoder, payloadSerializer.newReader(decoder)); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 5K bytes - Viewed (0) -
platforms/ide/tooling-api-builders/src/test/groovy/org/gradle/tooling/internal/provider/runner/ClientProvidedPhasedActionRunnerTest.groovy
} def payloadSerializer = Mock(PayloadSerializer) { deserialize(serializedAction) >> phasedAction } def buildController = Mock(BuildTreeLifecycleController) def modelController = Stub(BuildTreeModelController) def runner = new ClientProvidedPhasedActionRunner(Stub(BuildControllerFactory), payloadSerializer, buildEventConsumer, sideEffectExecutor)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 05 08:56:14 UTC 2024 - 6.6K bytes - Viewed (0) -
platforms/ide/tooling-api-builders/src/main/java/org/gradle/tooling/internal/provider/runner/AbstractClientProvidedBuildActionRunner.java
private final ClientAction clientAction; private final PayloadSerializer payloadSerializer; RuntimeException actionFailure; ActionAdapter(ClientAction clientAction, PayloadSerializer payloadSerializer) { this.clientAction = clientAction; this.payloadSerializer = payloadSerializer; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 05 08:55:55 UTC 2024 - 4.8K bytes - Viewed (0) -
platforms/core-runtime/build-state/src/main/java/org/gradle/internal/buildprocess/execution/BuildSessionLifecycleBuildActionExecutor.java
} @Override public BuildActionResult apply(BuildSessionContext context) { result = context.execute(action); PayloadSerializer payloadSerializer = context.getServices().get(PayloadSerializer.class); if (result.getBuildFailure() == null) { if (result.getClientResult() instanceof SerializedPayload) { // Already serialized
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 5.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/ProviderConnection.java
@ServiceScope(Scope.Global.class) public class ProviderConnection { private static final Logger LOGGER = LoggerFactory.getLogger(ProviderConnection.class); private final PayloadSerializer payloadSerializer; private final BuildLayoutFactory buildLayoutFactory; private final DaemonClientFactory daemonClientFactory; private final BuildActionExecutor<BuildActionParameters, BuildRequestContext> embeddedExecutor;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 05:33:15 UTC 2024 - 30.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/StreamedValueConsumer.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 19 08:15:25 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/ide/tooling-api-builders/src/main/java/org/gradle/tooling/internal/provider/runner/ClientProvidedBuildActionRunner.java
PayloadSerializer payloadSerializer) { super(buildControllerFactory, payloadSerializer); this.payloadSerializer = payloadSerializer; } @Override public Result run(BuildAction action, BuildTreeLifecycleController buildController) { if (!(action instanceof ClientProvidedBuildAction)) { return Result.nothing(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 3.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/PhasedActionEventConsumer.java
PhasedActionEventConsumer(PhasedActionResultListener phasedActionResultListener, PayloadSerializer payloadSerializer, BuildEventConsumer delegate) { this.phasedActionResultListener = phasedActionResultListener; this.payloadSerializer = payloadSerializer; this.delegate = delegate; } @Override public void dispatch(final Object event) { if (event instanceof PhasedBuildActionResult) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.3K bytes - Viewed (0)