2017-12-24 00:25:18 +00:00
|
|
|
#include "queue_manager.h"
|
2017-05-22 05:54:27 +00:00
|
|
|
|
2018-01-30 05:34:28 +00:00
|
|
|
#include "cache_manager.h"
|
2018-02-24 00:12:39 +00:00
|
|
|
#include "lsp.h"
|
2017-12-05 07:57:41 +00:00
|
|
|
#include "query.h"
|
2017-12-04 08:13:35 +00:00
|
|
|
|
|
|
|
#include <sstream>
|
|
|
|
|
2018-02-22 07:34:32 +00:00
|
|
|
Index_Request::Index_Request(
|
|
|
|
const std::string& path,
|
|
|
|
const std::vector<std::string>& args,
|
|
|
|
bool is_interactive,
|
|
|
|
const std::string& contents,
|
|
|
|
lsRequestId id)
|
2017-12-05 07:57:41 +00:00
|
|
|
: path(path),
|
|
|
|
args(args),
|
|
|
|
is_interactive(is_interactive),
|
2018-01-20 07:56:49 +00:00
|
|
|
contents(contents),
|
|
|
|
id(id) {}
|
2017-12-05 07:57:41 +00:00
|
|
|
|
2018-02-06 07:22:44 +00:00
|
|
|
Index_OnIndexed::Index_OnIndexed(IndexUpdate&& update,
|
2017-12-05 07:57:41 +00:00
|
|
|
PerformanceImportFile perf)
|
2018-02-22 07:34:32 +00:00
|
|
|
: update(std::move(update)), perf(perf) {}
|
2017-12-05 07:57:41 +00:00
|
|
|
|
2018-03-10 23:40:27 +00:00
|
|
|
std::unique_ptr<QueueManager> QueueManager::instance_;
|
2017-12-24 00:25:18 +00:00
|
|
|
|
|
|
|
// static
|
2018-03-10 23:40:27 +00:00
|
|
|
void QueueManager::Init(MultiQueueWaiter* querydb_waiter,
|
|
|
|
MultiQueueWaiter* indexer_waiter,
|
|
|
|
MultiQueueWaiter* stdout_waiter) {
|
|
|
|
instance_ = std::unique_ptr<QueueManager>(
|
|
|
|
new QueueManager(querydb_waiter, indexer_waiter, stdout_waiter));
|
2017-12-24 00:25:18 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
// static
|
2018-03-22 04:05:25 +00:00
|
|
|
void QueueManager::WriteStdout(MethodType method, lsBaseOutMessage& response) {
|
2017-12-24 00:25:18 +00:00
|
|
|
std::ostringstream sstream;
|
|
|
|
response.Write(sstream);
|
|
|
|
|
|
|
|
Stdout_Request out;
|
|
|
|
out.content = sstream.str();
|
2018-03-22 04:05:25 +00:00
|
|
|
out.method = method;
|
2018-02-05 06:03:22 +00:00
|
|
|
instance()->for_stdout.PushBack(std::move(out));
|
2017-12-24 00:25:18 +00:00
|
|
|
}
|
|
|
|
|
2018-01-02 07:40:36 +00:00
|
|
|
QueueManager::QueueManager(MultiQueueWaiter* querydb_waiter,
|
|
|
|
MultiQueueWaiter* indexer_waiter,
|
|
|
|
MultiQueueWaiter* stdout_waiter)
|
|
|
|
: for_stdout(stdout_waiter),
|
|
|
|
for_querydb(querydb_waiter),
|
2018-05-02 05:52:19 +00:00
|
|
|
on_indexed(querydb_waiter),
|
2018-05-05 22:29:17 +00:00
|
|
|
index_request(indexer_waiter) {}
|