highperfocused/bitcoin
1
0
Fork 0
mirror of https://github.com/bitcoin/bitcoin.git synced 2025-03-17 13:22:03 +01:00
Code Issues Packages Projects Releases Wiki Activity

use CScheduler for HTTPRPCTimer

Browse Source 
This removes the dependency on libevent for scheduled events,
like re-locking a wallet some time after decryption.
This commit is contained in:
Matthew Zipkin 2025-01-17 10:04:59 -05:00 committed by Matthew Zipkin
parent f82c717327
commit abde6936e1
No known key found for this signature in database
GPG Key ID: E7E2984B6289C93A
1 changed files with 9 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/httprpc.cpp
View File

@ -9,8 +9,10 @@
#include <httpserver.h>
#include <logging.h>
#include <netaddress.h>
#include <node/context.h>
#include <rpc/protocol.h>
#include <rpc/server.h>
#include <scheduler.h>
#include <util/fs.h>
#include <util/fs_helpers.h>
#include <util/strencodings.h>
@ -27,6 +29,7 @@
#include <vector>
using http_libevent::HTTPRequest;
using node::NodeContext;
using util::SplitString;
using util::TrimStringView;
@ -39,22 +42,16 @@ static const char* WWW_AUTH_HEADER_DATA = "Basic realm=\"jsonrpc\"";
class HTTPRPCTimer : public RPCTimerBase
{
public:
HTTPRPCTimer(struct event_base* eventBase, std::function<void()>& func, int64_t millis) :
ev(eventBase, false, func)
HTTPRPCTimer(NodeContext* context, std::function<void()>& func, int64_t millis)
{
struct timeval tv;
tv.tv_sec = millis/1000;
tv.tv_usec = (millis%1000)*1000;
ev.trigger(&tv);
context->scheduler->scheduleFromNow(func, std::chrono::milliseconds(millis));
}
private:
HTTPEvent ev;
};
class HTTPRPCTimerInterface : public RPCTimerInterface
{
public:
explicit HTTPRPCTimerInterface(struct event_base* _base) : base(_base)
explicit HTTPRPCTimerInterface(const std::any& context) : m_context(std::any_cast<NodeContext*>(context))
{
}
const char* Name() override
@ -63,10 +60,10 @@ public:
}
RPCTimerBase* NewTimer(std::function<void()>& func, int64_t millis) override
{
return new HTTPRPCTimer(base, func, millis);
return new HTTPRPCTimer(m_context, func, millis);
}
private:
struct event_base* base;
NodeContext* m_context;
};
@ -371,9 +368,7 @@ bool StartHTTPRPC(const std::any& context)
if (g_wallet_init_interface.HasWalletSupport()) {
RegisterHTTPHandler("/wallet/", false, handle_rpc);
}
struct event_base* eventBase = EventBase();
assert(eventBase);
httpRPCTimerInterface = std::make_unique<HTTPRPCTimerInterface>(eventBase);
httpRPCTimerInterface = std::make_unique<HTTPRPCTimerInterface>(context);
RPCSetTimerInterface(httpRPCTimerInterface.get());
return true;
}