Hi Noctarius, I'm by your side - that (In|Out)put objects have to be instantiated each (de)serialize invocation. Feel free to fill an issue and fix it - unfortunately I am with almost 0 spare time during these months :(
Have a nice day, all the best! -Simo http://people.apache.org/~simonetripodi/ http://simonetripodi.livejournal.com/ http://twitter.com/simonetripodi http://www.99soft.org/ On Mon, Oct 29, 2012 at 8:56 PM, Christoph Engelbert <[email protected]> wrote: > Hey guys, > > while having a look how to implement the Lightning Serializer > adapter I recognized that maybe the current implementation of the > KryoSerializer and maybe some more could be absolutely thread unsafe. > > private final byte[] buffer = new byte[ BUFFER_SIZE ]; > private final Output output = new Output( buffer, -1 ); > private final Input input = new Input( buffer ); > > Only one byte[] buffer is used for serialization and > deserialization. Is somewhere deep in DM an instantiater hidden that > generates new instances of the serializer or will there be a problem > if different threads read / write at the same time? > > Cheers Chris
