From 5eda0e066e2b8e6d731914e78395206dd786903a Mon Sep 17 00:00:00 2001 From: Mike Hearn Date: Tue, 8 Mar 2016 15:18:01 +0100 Subject: [PATCH] Minor: add a TODO about a little rpc framework to StateMachineManager --- src/main/kotlin/core/messaging/StateMachineManager.kt | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/kotlin/core/messaging/StateMachineManager.kt b/src/main/kotlin/core/messaging/StateMachineManager.kt index 2783a12f55..369c76c7a5 100644 --- a/src/main/kotlin/core/messaging/StateMachineManager.kt +++ b/src/main/kotlin/core/messaging/StateMachineManager.kt @@ -15,9 +15,9 @@ import com.esotericsoftware.kryo.io.Input import com.google.common.base.Throwables import com.google.common.util.concurrent.ListenableFuture import com.google.common.util.concurrent.MoreExecutors -import core.node.services.ServiceHub import core.crypto.SecureHash import core.crypto.sha256 +import core.node.services.ServiceHub import core.protocols.ProtocolLogic import core.protocols.ProtocolStateMachine import core.serialization.THREAD_LOCAL_KRYO @@ -54,6 +54,7 @@ import javax.annotation.concurrent.ThreadSafe * TODO: Ability to control checkpointing explicitly, for cases where you know replaying a message can't hurt * TODO: Make Kryo (de)serialize markers for heavy objects that are currently in the service hub. This avoids mistakes * where services are temporarily put on the stack. + * TODO: Implement stub/skel classes that provide a basic RPC framework on top of this. */ @ThreadSafe class StateMachineManager(val serviceHub: ServiceHub, val runInThread: Executor) {