Also report work queue threads in rpcinfo

This commit is contained in:
Duke Leto
2021-08-09 11:51:25 -04:00
parent 89a4226965
commit 63e1ede162
3 changed files with 14 additions and 0 deletions

View File

@@ -162,6 +162,11 @@ public:
boost::unique_lock<boost::mutex> lock(cs); boost::unique_lock<boost::mutex> lock(cs);
return maxDepth; return maxDepth;
} }
int NumThreads()
{
boost::unique_lock<boost::mutex> lock(cs);
return numThreads;
}
}; };
struct HTTPPathHandler struct HTTPPathHandler
@@ -196,11 +201,17 @@ int getWorkQueueDepth()
{ {
return workQueue->Depth(); return workQueue->Depth();
} }
int getWorkQueueMaxDepth() int getWorkQueueMaxDepth()
{ {
return workQueue->MaxDepth(); return workQueue->MaxDepth();
} }
int getWorkQueueNumThreads()
{
return workQueue->NumThreads();
}
/** Check if a network address is allowed to access the HTTP server */ /** Check if a network address is allowed to access the HTTP server */
static bool ClientAllowed(const CNetAddr& netaddr) static bool ClientAllowed(const CNetAddr& netaddr)
{ {

View File

@@ -26,6 +26,7 @@ class HTTPRequest;
int getWorkQueueDepth(); int getWorkQueueDepth();
int getWorkQueueMaxDepth(); int getWorkQueueMaxDepth();
int getWorkQueueNumThreads();
/** Initialize HTTP server. /** Initialize HTTP server.
* Call this before RegisterHTTPHandler or EventBase(). * Call this before RegisterHTTPHandler or EventBase().

View File

@@ -180,6 +180,7 @@ UniValue geterablockheights(const UniValue& params, bool fHelp, const CPubKey& m
extern int getWorkQueueDepth(); extern int getWorkQueueDepth();
extern int getWorkQueueMaxDepth(); extern int getWorkQueueMaxDepth();
extern int getWorkQueueNumThreads();
UniValue rpcinfo(const UniValue& params, bool fHelp, const CPubKey& mypk) UniValue rpcinfo(const UniValue& params, bool fHelp, const CPubKey& mypk)
{ {
@@ -195,6 +196,7 @@ UniValue rpcinfo(const UniValue& params, bool fHelp, const CPubKey& mypk)
result.push_back(Pair("work_queue_depth", depth)); result.push_back(Pair("work_queue_depth", depth));
result.push_back(Pair("work_queue_max_depth", getWorkQueueMaxDepth() )); result.push_back(Pair("work_queue_max_depth", getWorkQueueMaxDepth() ));
result.push_back(Pair("work_queue_num_threads", getWorkQueueNumThreads() ));
return result; return result;
} }