mirror of
https://github.com/corda/corda.git
synced 2025-05-02 16:53:22 +00:00
CORDA-973 Allow deserialization of any checkpoint/storage encoding. (#2693)
This commit is contained in:
parent
91fd46f2c0
commit
26fe90c8e9
@ -35,14 +35,16 @@ val KRYO_STORAGE_CONTEXT = SerializationContextImpl(kryoMagic,
|
|||||||
emptyMap(),
|
emptyMap(),
|
||||||
true,
|
true,
|
||||||
SerializationContext.UseCase.Storage,
|
SerializationContext.UseCase.Storage,
|
||||||
null)
|
null,
|
||||||
|
AlwaysAcceptEncodingWhitelist)
|
||||||
val AMQP_STORAGE_CONTEXT = SerializationContextImpl(amqpMagic,
|
val AMQP_STORAGE_CONTEXT = SerializationContextImpl(amqpMagic,
|
||||||
SerializationDefaults.javaClass.classLoader,
|
SerializationDefaults.javaClass.classLoader,
|
||||||
AllButBlacklisted,
|
AllButBlacklisted,
|
||||||
emptyMap(),
|
emptyMap(),
|
||||||
true,
|
true,
|
||||||
SerializationContext.UseCase.Storage,
|
SerializationContext.UseCase.Storage,
|
||||||
null)
|
null,
|
||||||
|
AlwaysAcceptEncodingWhitelist)
|
||||||
val AMQP_RPC_SERVER_CONTEXT = SerializationContextImpl(amqpMagic,
|
val AMQP_RPC_SERVER_CONTEXT = SerializationContextImpl(amqpMagic,
|
||||||
SerializationDefaults.javaClass.classLoader,
|
SerializationDefaults.javaClass.classLoader,
|
||||||
GlobalTransientClassWhiteList(BuiltInExceptionsWhitelist()),
|
GlobalTransientClassWhiteList(BuiltInExceptionsWhitelist()),
|
||||||
|
@ -2,8 +2,10 @@
|
|||||||
|
|
||||||
package net.corda.nodeapi.internal.serialization
|
package net.corda.nodeapi.internal.serialization
|
||||||
|
|
||||||
|
import net.corda.core.serialization.EncodingWhitelist
|
||||||
import net.corda.core.serialization.SerializationContext
|
import net.corda.core.serialization.SerializationContext
|
||||||
import net.corda.core.serialization.SerializationDefaults
|
import net.corda.core.serialization.SerializationDefaults
|
||||||
|
import net.corda.core.serialization.SerializationEncoding
|
||||||
import net.corda.nodeapi.internal.serialization.amqp.amqpMagic
|
import net.corda.nodeapi.internal.serialization.amqp.amqpMagic
|
||||||
import net.corda.nodeapi.internal.serialization.kryo.kryoMagic
|
import net.corda.nodeapi.internal.serialization.kryo.kryoMagic
|
||||||
|
|
||||||
@ -28,7 +30,8 @@ val KRYO_CHECKPOINT_CONTEXT = SerializationContextImpl(kryoMagic,
|
|||||||
emptyMap(),
|
emptyMap(),
|
||||||
true,
|
true,
|
||||||
SerializationContext.UseCase.Checkpoint,
|
SerializationContext.UseCase.Checkpoint,
|
||||||
null)
|
null,
|
||||||
|
AlwaysAcceptEncodingWhitelist)
|
||||||
val AMQP_P2P_CONTEXT = SerializationContextImpl(amqpMagic,
|
val AMQP_P2P_CONTEXT = SerializationContextImpl(amqpMagic,
|
||||||
SerializationDefaults.javaClass.classLoader,
|
SerializationDefaults.javaClass.classLoader,
|
||||||
GlobalTransientClassWhiteList(BuiltInExceptionsWhitelist()),
|
GlobalTransientClassWhiteList(BuiltInExceptionsWhitelist()),
|
||||||
@ -36,3 +39,7 @@ val AMQP_P2P_CONTEXT = SerializationContextImpl(amqpMagic,
|
|||||||
true,
|
true,
|
||||||
SerializationContext.UseCase.P2P,
|
SerializationContext.UseCase.P2P,
|
||||||
null)
|
null)
|
||||||
|
|
||||||
|
internal object AlwaysAcceptEncodingWhitelist : EncodingWhitelist {
|
||||||
|
override fun acceptEncoding(encoding: SerializationEncoding) = true
|
||||||
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user