ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-01-03 11:44:16 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Fix rpc sender thread busy looping

Browse Source
This commit is contained in:
Andras Slemmer 2018-02-27 10:23:48 +00:00
parent 3391810101
commit cd569577d2
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
node/src/main/kotlin/net/corda/node/services/messaging/RPCServer.kt
View File

@ -210,7 +210,7 @@ class RPCServer(
return thread(name = "rpc-server-sender", isDaemon = true) { return thread(name = "rpc-server-sender", isDaemon = true) {
var deduplicationSequenceNumber = 0L var deduplicationSequenceNumber = 0L
while (true) { while (true) {
val job = sendJobQueue.poll() val job = sendJobQueue.take()
when (job) { when (job) {
is RpcSendJob.Send -> handleSendJob(deduplicationSequenceNumber++, job) is RpcSendJob.Send -> handleSendJob(deduplicationSequenceNumber++, job)
RpcSendJob.Stop -> return@thread RpcSendJob.Stop -> return@thread