ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-02-21 17:56:54 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Minor: add a TODO about a little rpc framework to StateMachineManager

Browse Source
This commit is contained in:
Mike Hearn 2016-03-08 15:18:01 +01:00
parent 9069a80bc3
commit 5eda0e066e
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/kotlin/core/messaging/StateMachineManager.kt
View File

@ -15,9 +15,9 @@ import com.esotericsoftware.kryo.io.Input
import com.google.common.base.Throwables import com.google.common.base.Throwables
import com.google.common.util.concurrent.ListenableFuture import com.google.common.util.concurrent.ListenableFuture
import com.google.common.util.concurrent.MoreExecutors import com.google.common.util.concurrent.MoreExecutors
import core.node.services.ServiceHub
import core.crypto.SecureHash import core.crypto.SecureHash
import core.crypto.sha256 import core.crypto.sha256
import core.node.services.ServiceHub
import core.protocols.ProtocolLogic import core.protocols.ProtocolLogic
import core.protocols.ProtocolStateMachine import core.protocols.ProtocolStateMachine
import core.serialization.THREAD_LOCAL_KRYO 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: 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 * 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. * where services are temporarily put on the stack.
* TODO: Implement stub/skel classes that provide a basic RPC framework on top of this.
*/ */
@ThreadSafe @ThreadSafe
class StateMachineManager(val serviceHub: ServiceHub, val runInThread: Executor) { class StateMachineManager(val serviceHub: ServiceHub, val runInThread: Executor) {