dorkbox/Network
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

WIP Rmi object serialization

Browse Source
This commit is contained in:
nathan 2020-08-25 20:52:37 +02:00
parent 977929d2a9
commit 570aeee52c
3 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/dorkbox/network/rmi/messages/ObjectResponseSerializer.kt → src/dorkbox/network/rmi/messages/RmiObjectSerializer.kt
View File

@ -51,7 +51,7 @@ import dorkbox.network.serialization.KryoExtra
*
* @author Nathan Sweet <misc></misc>@n4te.com>
*/
class ObjectResponseSerializer(private val rmiImplToIface: IdentityMap<Class<*>, Class<*>>) : Serializer<Any>(false) {
class RmiObjectSerializer(private val rmiImplToIface: IdentityMap<Class<*>, Class<*>>) : Serializer<Any>(false) {
override fun write(kryo: Kryo, output: Output, `object`: Any) {
println(" FIX ObjectResponseSerializer ")
val kryoExtra = kryo as KryoExtra

7
src/dorkbox/network/serialization/ClassRegistrationIfaceAndImpl.kt
View File

@ -15,12 +15,13 @@
*/
package dorkbox.network.serialization
import dorkbox.network.rmi.messages.ObjectResponseSerializer
import dorkbox.network.rmi.messages.RmiObjectSerializer
internal class ClassRegistrationIfaceAndImpl(ifaceClass: Class<*>, val implClass: Class<*>, objectResponseSerializer: ObjectResponseSerializer) : ClassRegistration(ifaceClass) {
internal class ClassRegistrationIfaceAndImpl(ifaceClass: Class<*>, val implClass: Class<*>, rmiObjectSerializer: RmiObjectSerializer) :
ClassRegistration(implClass) {
init {
this.serializer = objectResponseSerializer
this.serializer = rmiObjectSerializer
}
override fun register(kryo: KryoExtra) {

4
src/dorkbox/network/serialization/Serialization.kt
View File

@ -36,8 +36,8 @@ import dorkbox.network.rmi.messages.MethodRequest
import dorkbox.network.rmi.messages.MethodRequestSerializer
import dorkbox.network.rmi.messages.MethodResponse
import dorkbox.network.rmi.messages.MethodResponseSerializer
import dorkbox.network.rmi.messages.ObjectResponseSerializer
import dorkbox.network.rmi.messages.RmiClientRequestSerializer
import dorkbox.network.rmi.messages.RmiObjectSerializer
import dorkbox.os.OS
import dorkbox.util.serialization.SerializationDefaults
import kotlinx.coroutines.channels.Channel
@ -133,7 +133,7 @@ class Serialization(private val references: Boolean,
private val methodRequestSerializer = MethodRequestSerializer()
private val methodResponseSerializer = MethodResponseSerializer()
private val objectRequestSerializer = RmiClientRequestSerializer()
private val objectResponseSerializer = ObjectResponseSerializer(rmiImplToIface)
private val objectResponseSerializer = RmiObjectSerializer(rmiImplToIface)
private val continuationRequestSerializer = ContinuationSerializer()