search

OpenHFT / Chronicle-Decentred

Framework for building Secure Scalable Microservices on Distributed Ledger Technology
Other
49 stars 16 forks source link

RPCServer throws exception due to thread check #7

Open alamar opened 2 years ago

alamar commented 2 years ago 
java.lang.IllegalStateException: net.openhft.chronicle.decentred.remote.rpc.RPCServer component which is not thread safes used by Thread[main,5,main] and Thread[main/test-1,1,main]
    at net.openhft.chronicle.core.io.AbstractCloseable.threadSafetyCheck(AbstractCloseable.java:339)
    at net.openhft.chronicle.core.io.AbstractCloseable.throwExceptionIfClosed(AbstractCloseable.java:254)
    at net.openhft.chronicle.decentred.remote.rpc.RPCServer$XCLConnectionListener.onMessage(RPCServer.java:222)
    at net.openhft.chronicle.decentred.remote.net.VanillaTCPServerConnection.onMessage(VanillaTCPServerConnection.java:59)
    at net.openhft.chronicle.decentred.remote.net.AbstractTCPConnection.processOneMessage(AbstractTCPConnection.java:131)
    at net.openhft.chronicle.decentred.remote.net.AbstractTCPConnection.readChannel(AbstractTCPConnection.java:108)
    at net.openhft.chronicle.decentred.remote.net.VanillaTCPServerConnection.run(VanillaTCPServerConnection.java:38)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)
    at net.openhft.chronicle.core.threads.CleaningThread.run(CleaningThread.java:104)

in test net.openhft.chronicle.decentred.server.DecentredClientServerTest#test

alamar commented 2 years ago

Also net.openhft.chronicle.decentred.server.RPCGatewayTest#endToEnd