ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-02-20 17:33:15 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Merge pull request #2653 from corda/aslemmer-fix-rpc-server-sender

Browse Source 
Fix rpc sender thread busy looping
This commit is contained in:
Andras Slemmer 2018-02-27 11:49:21 +00:00 committed by GitHub
commit 48da1c3ebf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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) {
var deduplicationSequenceNumber = 0L
while (true) {
val job = sendJobQueue.poll()
val job = sendJobQueue.take()
when (job) {
is RpcSendJob.Send -> handleSendJob(deduplicationSequenceNumber++, job)
RpcSendJob.Stop -> return@thread