From 125c5273a68c16dfd5ce41efec56b81e4d86aa2a Mon Sep 17 00:00:00 2001 From: JoelKatz Date: Mon, 18 Mar 2013 03:10:20 -0700 Subject: [PATCH] Dispatch transaction from job queue, not I/O service. Mark a FIXME where we don't do this. --- src/cpp/ripple/NetworkOPs.cpp | 1 + src/cpp/ripple/Peer.cpp | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/src/cpp/ripple/NetworkOPs.cpp b/src/cpp/ripple/NetworkOPs.cpp index 67c2a8908e..db8a28c0d5 100644 --- a/src/cpp/ripple/NetworkOPs.cpp +++ b/src/cpp/ripple/NetworkOPs.cpp @@ -210,6 +210,7 @@ void NetworkOPs::submitTransaction(Job&, SerializedTransaction::pointer iTrans, } } + // FIXME: Should submit to job queue theApp->getIOService().post(boost::bind(&NetworkOPs::processTransaction, this, boost::make_shared(trans, false), callback)); } diff --git a/src/cpp/ripple/Peer.cpp b/src/cpp/ripple/Peer.cpp index 752b9c0e13..e4a418f0f7 100644 --- a/src/cpp/ripple/Peer.cpp +++ b/src/cpp/ripple/Peer.cpp @@ -830,7 +830,7 @@ static void checkTransaction(Job&, int flags, SerializedTransaction::pointer stx else tx = boost::make_shared(stx, false); - theApp->getIOService().post(boost::bind(&NetworkOPs::processTransaction, &theApp->getOPs(), tx)); + theApp->getOPs().processTransaction(tx); #ifndef TRUST_NETWORK }