MCPcopy Create free account
hub / github.com/WaykiChain/WaykiChain / Enqueue

Method Enqueue

src/rpc/core/httpserver.cpp:108–116  ·  view source on GitHub ↗

Enqueue a work item */

Source from the content-addressed store, hash-verified

106 ~WorkQueue() {}
107 /** Enqueue a work item */
108 bool Enqueue(WorkItem* item) {
109 STD_LOCK(cs);
110 if (queue.size() >= maxDepth) {
111 return false;
112 }
113 queue.emplace_back(std::unique_ptr<WorkItem>(item));
114 cond.notify_one();
115 return true;
116 }
117 /** Thread function */
118 void Run() {
119 while (true) {

Callers 1

http_request_cbFunction · 0.80

Calls 2

emplace_backMethod · 0.80
sizeMethod · 0.45

Tested by

no test coverage detected