diff --git a/src/xrpld/net/detail/RPCCall.cpp b/src/xrpld/net/detail/RPCCall.cpp index c91005a66db..d0ce065adae 100644 --- a/src/xrpld/net/detail/RPCCall.cpp +++ b/src/xrpld/net/detail/RPCCall.cpp @@ -1665,7 +1665,7 @@ fromNetwork( constexpr auto RPC_REPLY_MAX_BYTES = megabytes(256); using namespace std::chrono_literals; - auto constexpr RPC_NOTIFY = 10min; + auto constexpr RPC_WEBHOOK_TIMEOUT = 30s; HTTPClient::request( bSSL, @@ -1682,7 +1682,7 @@ fromNetwork( std::placeholders::_2, j), RPC_REPLY_MAX_BYTES, - RPC_NOTIFY, + RPC_WEBHOOK_TIMEOUT, std::bind( &RPCCallImp::onResponse, callbackFuncP, diff --git a/src/xrpld/net/detail/RPCSub.cpp b/src/xrpld/net/detail/RPCSub.cpp index 13bdf9119b4..c684a279bbc 100644 --- a/src/xrpld/net/detail/RPCSub.cpp +++ b/src/xrpld/net/detail/RPCSub.cpp @@ -78,13 +78,6 @@ class RPCSubImp : public RPCSub { std::lock_guard sl(mLock); - if (mDeque.size() >= eventQueueMax) - { - // Drop the previous event. - JLOG(j_.warn()) << "RPCCall::fromNetwork drop"; - mDeque.pop_back(); - } - auto jm = broadcast ? j_.debug() : j_.info(); JLOG(jm) << "RPCCall::fromNetwork push: " << jvObj; @@ -182,8 +175,6 @@ class RPCSubImp : public RPCSub } private: - enum { eventQueueMax = 32 }; - boost::asio::io_service& m_io_service; JobQueue& m_jobQueue;