|
|
@ -286,8 +286,10 @@ static void http_request_cb(struct evhttp_request* req, void* arg)
|
|
|
|
assert(workQueue);
|
|
|
|
assert(workQueue);
|
|
|
|
if (workQueue->Enqueue(item.get()))
|
|
|
|
if (workQueue->Enqueue(item.get()))
|
|
|
|
item.release(); /* if true, queue took ownership */
|
|
|
|
item.release(); /* if true, queue took ownership */
|
|
|
|
else
|
|
|
|
else {
|
|
|
|
|
|
|
|
LogPrintf("WARNING: request rejected because http work queue depth exceeded, it can be increased with the -rpcworkqueue= setting\n");
|
|
|
|
item->req->WriteReply(HTTP_INTERNAL, "Work queue depth exceeded");
|
|
|
|
item->req->WriteReply(HTTP_INTERNAL, "Work queue depth exceeded");
|
|
|
|
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
hreq->WriteReply(HTTP_NOTFOUND);
|
|
|
|
hreq->WriteReply(HTTP_NOTFOUND);
|
|
|
|
}
|
|
|
|
}
|
|
|
|