diff options
| author | João Barbosa <[email protected]> | 2020-04-29 10:40:39 +0100 |
|---|---|---|
| committer | João Barbosa <[email protected]> | 2020-04-29 11:47:57 +0100 |
| commit | a2e6db5c4f1bb52a8814102b628e51652493d06a (patch) | |
| tree | 7c0ed0374e01c2f0902d295cd07ab1b9e3cd2192 /src | |
| parent | Merge #18038: P2P: Mempool tracks locally submitted transactions to improve w... (diff) | |
| download | discoin-a2e6db5c4f1bb52a8814102b628e51652493d06a.tar.xz discoin-a2e6db5c4f1bb52a8814102b628e51652493d06a.zip | |
rpc: Add mutex to guard deadlineTimers
Diffstat (limited to 'src')
| -rw-r--r-- | src/rpc/server.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rpc/server.cpp b/src/rpc/server.cpp index e2618c16d..219979f09 100644 --- a/src/rpc/server.cpp +++ b/src/rpc/server.cpp @@ -25,7 +25,8 @@ static std::string rpcWarmupStatus GUARDED_BY(cs_rpcWarmup) = "RPC server starte /* Timer-creating functions */ static RPCTimerInterface* timerInterface = nullptr; /* Map of name to timer. */ -static std::map<std::string, std::unique_ptr<RPCTimerBase> > deadlineTimers; +static Mutex g_deadline_timers_mutex; +static std::map<std::string, std::unique_ptr<RPCTimerBase> > deadlineTimers GUARDED_BY(g_deadline_timers_mutex); static bool ExecuteCommand(const CRPCCommand& command, const JSONRPCRequest& request, UniValue& result, bool last_handler); struct RPCCommandExecutionInfo @@ -298,7 +299,7 @@ void InterruptRPC() void StopRPC() { LogPrint(BCLog::RPC, "Stopping RPC\n"); - deadlineTimers.clear(); + WITH_LOCK(g_deadline_timers_mutex, deadlineTimers.clear()); DeleteAuthCookie(); g_rpcSignals.Stopped(); } @@ -486,6 +487,7 @@ void RPCRunLater(const std::string& name, std::function<void()> func, int64_t nS { if (!timerInterface) throw JSONRPCError(RPC_INTERNAL_ERROR, "No timer handler registered for RPC"); + LOCK(g_deadline_timers_mutex); deadlineTimers.erase(name); LogPrint(BCLog::RPC, "queue run of timer %s in %i seconds (using %s)\n", name, nSeconds, timerInterface->Name()); deadlineTimers.emplace(name, std::unique_ptr<RPCTimerBase>(timerInterface->NewTimer(func, nSeconds*1000))); |