ccls/command_line.cc

1143 lines
37 KiB
C++
Raw Normal View History

2017-02-25 23:59:09 +00:00
#include <iostream>
#include <string>
#include <unordered_map>
2017-03-05 02:16:23 +00:00
#include <thread>
2017-03-05 19:48:05 +00:00
#include <vector>
2017-02-25 23:59:09 +00:00
#include "compilation_database_loader.h"
#include "indexer.h"
2017-03-03 08:12:11 +00:00
#include "ipc.h"
2017-02-25 23:59:09 +00:00
#include "query.h"
2017-03-05 02:16:23 +00:00
#include "language_server_api.h"
2017-03-10 07:06:01 +00:00
#include "test.h"
2017-03-05 02:16:23 +00:00
2017-03-24 05:20:08 +00:00
#include "src/typed_bidi_message_queue.h"
2017-03-05 19:48:05 +00:00
#include "third_party/tiny-process-library/process.hpp"
2017-03-17 23:45:10 +00:00
#include "third_party/doctest/doctest/doctest.h"
2017-03-05 02:16:23 +00:00
#include <rapidjson/istreamwrapper.h>
#include <rapidjson/ostreamwrapper.h>
#ifdef _WIN32
#include <io.h>
#include <fcntl.h>
#endif
2017-02-25 23:59:09 +00:00
2017-03-15 04:59:05 +00:00
const char* kIpcIndexerName = "indexer";
const char* kIpcLanguageClientName = "language_client";
const int kNumIndexers = 8 - 1;
2017-03-17 07:58:41 +00:00
std::unordered_map<std::string, std::string> ParseOptions(int argc,
char** argv) {
2017-02-25 23:59:09 +00:00
std::unordered_map<std::string, std::string> output;
std::string previous_arg;
for (int i = 1; i < argc; ++i) {
std::string arg = argv[i];
if (arg[0] != '-') {
if (previous_arg.size() == 0) {
2017-03-17 07:58:41 +00:00
std::cerr << "Invalid arguments; switches must start with -"
<< std::endl;
2017-02-25 23:59:09 +00:00
exit(1);
}
output[previous_arg] = arg;
previous_arg = "";
2017-03-17 07:58:41 +00:00
} else {
2017-02-25 23:59:09 +00:00
output[arg] = "";
previous_arg = arg;
}
}
return output;
}
2017-03-17 07:58:41 +00:00
bool HasOption(const std::unordered_map<std::string, std::string>& options,
const std::string& option) {
2017-02-25 23:59:09 +00:00
return options.find(option) != options.end();
}
2017-03-10 07:06:01 +00:00
std::unique_ptr<InMessage> ParseMessage() {
2017-03-05 19:48:05 +00:00
int content_length = -1;
int iteration = 0;
while (true) {
if (++iteration > 10) {
assert(false && "bad parser state");
exit(1);
}
2017-03-05 19:48:05 +00:00
std::string line;
std::getline(std::cin, line);
2017-03-17 07:58:41 +00:00
// std::cin >> line;
2017-03-05 19:48:05 +00:00
if (line.compare(0, 14, "Content-Length") == 0) {
content_length = atoi(line.c_str() + 16);
}
if (line == "\r")
break;
}
// bad input that is not a message.
if (content_length < 0) {
2017-03-17 07:58:41 +00:00
std::cerr << "parsing command failed (no Content-Length header)"
<< std::endl;
2017-03-05 19:48:05 +00:00
return nullptr;
}
std::string content;
content.reserve(content_length);
for (int i = 0; i < content_length; ++i) {
char c;
std::cin >> c;
content += c;
}
2017-03-05 19:48:05 +00:00
rapidjson::Document document;
document.Parse(content.c_str(), content_length);
assert(!document.HasParseError());
2017-03-10 07:06:01 +00:00
return MessageRegistry::instance()->Parse(document);
}
2017-03-05 19:48:05 +00:00
2017-03-14 08:33:39 +00:00
std::string Join(const std::vector<std::string>& elements, std::string sep) {
bool first = true;
std::string result;
for (const auto& element : elements) {
if (!first)
result += ", ";
first = false;
result += element;
}
return result;
}
2017-03-05 19:48:05 +00:00
2017-03-17 07:58:41 +00:00
template <typename T>
2017-03-12 00:36:00 +00:00
struct BaseIpcMessage : public IpcMessage {
BaseIpcMessage() : IpcMessage(T::kIpcId) {}
2017-03-05 19:48:05 +00:00
2017-03-12 00:36:00 +00:00
// IpcMessage:
void Serialize(Writer& writer) override {
T& value = *static_cast<T*>(this);
Reflect(writer, value);
}
void Deserialize(Reader& reader) override {
T& value = *static_cast<T*>(this);
Reflect(reader, value);
}
};
2017-03-05 19:48:05 +00:00
struct IpcMessage_Quit : public BaseIpcMessage<IpcMessage_Quit> {
2017-03-12 00:36:00 +00:00
static constexpr IpcId kIpcId = IpcId::Quit;
2017-03-05 19:48:05 +00:00
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
2017-03-12 00:36:00 +00:00
void Reflect(TVisitor& visitor, IpcMessage_Quit& value) {}
2017-03-05 02:16:23 +00:00
struct IpcMessage_IsAlive : public BaseIpcMessage<IpcMessage_IsAlive> {
2017-03-12 00:36:00 +00:00
static constexpr IpcId kIpcId = IpcId::IsAlive;
2017-03-03 08:12:11 +00:00
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
2017-03-12 00:36:00 +00:00
void Reflect(TVisitor& visitor, IpcMessage_IsAlive& value) {}
2017-03-05 19:48:05 +00:00
struct IpcMessage_OpenProject : public BaseIpcMessage<IpcMessage_OpenProject> {
2017-03-12 00:36:00 +00:00
static constexpr IpcId kIpcId = IpcId::OpenProject;
2017-03-05 19:48:05 +00:00
std::string project_path;
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
2017-03-12 00:36:00 +00:00
void Reflect(TVisitor& visitor, IpcMessage_OpenProject& value) {
Reflect(visitor, value.project_path);
}
2017-03-17 07:58:41 +00:00
struct IpcMessage_IndexTranslationUnitRequest
: public BaseIpcMessage<IpcMessage_IndexTranslationUnitRequest> {
2017-03-14 08:33:39 +00:00
static constexpr IpcId kIpcId = IpcId::IndexTranslationUnitRequest;
std::string path;
std::vector<std::string> args;
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
2017-03-14 08:33:39 +00:00
void Reflect(TVisitor& visitor, IpcMessage_IndexTranslationUnitRequest& value) {
REFLECT_MEMBER_START();
REFLECT_MEMBER(path);
REFLECT_MEMBER(args);
REFLECT_MEMBER_END();
}
2017-03-17 07:58:41 +00:00
struct IpcMessage_IndexTranslationUnitResponse
: public BaseIpcMessage<IpcMessage_IndexTranslationUnitResponse> {
2017-03-14 08:33:39 +00:00
static constexpr IpcId kIpcId = IpcId::IndexTranslationUnitResponse;
IndexUpdate update;
2017-03-15 04:59:05 +00:00
IpcMessage_IndexTranslationUnitResponse() {}
2017-03-17 07:58:41 +00:00
explicit IpcMessage_IndexTranslationUnitResponse(IndexUpdate& update)
: update(update) {}
2017-03-14 08:33:39 +00:00
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
void Reflect(TVisitor& visitor,
IpcMessage_IndexTranslationUnitResponse& value) {
2017-03-14 08:33:39 +00:00
REFLECT_MEMBER_START();
REFLECT_MEMBER(update);
REFLECT_MEMBER_END();
}
2017-03-17 07:58:41 +00:00
struct IpcMessage_LanguageServerRequest
: public BaseIpcMessage<IpcMessage_LanguageServerRequest> {
2017-03-12 00:36:00 +00:00
static constexpr IpcId kIpcId = IpcId::LanguageServerRequest;
// TODO: provide a way to get the request state.
lsMethodId method_id;
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
2017-03-12 00:36:00 +00:00
void Reflect(TVisitor& visitor, IpcMessage_LanguageServerRequest& value) {
REFLECT_MEMBER_START();
REFLECT_MEMBER(method_id);
REFLECT_MEMBER_END();
}
2017-03-05 02:16:23 +00:00
2017-03-17 07:58:41 +00:00
struct IpcMessage_DocumentSymbolsRequest
: public BaseIpcMessage<IpcMessage_DocumentSymbolsRequest> {
2017-03-12 00:36:00 +00:00
static constexpr IpcId kIpcId = IpcId::DocumentSymbolsRequest;
RequestId request_id;
std::string document;
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
2017-03-12 00:36:00 +00:00
void Reflect(TVisitor& visitor, IpcMessage_DocumentSymbolsRequest& value) {
REFLECT_MEMBER_START();
REFLECT_MEMBER(request_id);
REFLECT_MEMBER(document);
REFLECT_MEMBER_END();
}
2017-03-17 07:58:41 +00:00
struct IpcMessage_DocumentSymbolsResponse
: public BaseIpcMessage<IpcMessage_DocumentSymbolsResponse> {
2017-03-12 00:36:00 +00:00
static constexpr IpcId kIpcId = IpcId::DocumentSymbolsResponse;
RequestId request_id;
2017-03-10 07:06:01 +00:00
std::vector<lsSymbolInformation> symbols;
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
2017-03-12 00:36:00 +00:00
void Reflect(TVisitor& visitor, IpcMessage_DocumentSymbolsResponse& value) {
REFLECT_MEMBER_START();
REFLECT_MEMBER(request_id);
REFLECT_MEMBER(symbols);
REFLECT_MEMBER_END();
}
2017-03-17 07:58:41 +00:00
struct IpcMessage_WorkspaceSymbolsRequest
: public BaseIpcMessage<IpcMessage_WorkspaceSymbolsRequest> {
2017-03-12 00:36:00 +00:00
static constexpr IpcId kIpcId = IpcId::WorkspaceSymbolsRequest;
RequestId request_id;
2017-03-06 08:48:51 +00:00
std::string query;
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
2017-03-12 00:36:00 +00:00
void Reflect(TVisitor& visitor, IpcMessage_WorkspaceSymbolsRequest& value) {
REFLECT_MEMBER_START();
REFLECT_MEMBER(request_id);
REFLECT_MEMBER(query);
REFLECT_MEMBER_END();
}
2017-03-17 07:58:41 +00:00
struct IpcMessage_DocumentCodeLensRequest
: public BaseIpcMessage<IpcMessage_DocumentCodeLensRequest> {
2017-03-15 07:14:44 +00:00
static constexpr IpcId kIpcId = IpcId::DocumentCodeLensRequest;
RequestId request_id;
std::string document;
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
2017-03-15 07:14:44 +00:00
void Reflect(TVisitor& visitor, IpcMessage_DocumentCodeLensRequest& value) {
REFLECT_MEMBER_START();
REFLECT_MEMBER(request_id);
REFLECT_MEMBER(document);
REFLECT_MEMBER_END();
}
2017-03-17 07:58:41 +00:00
struct IpcMessage_DocumentCodeLensResponse
: public BaseIpcMessage<IpcMessage_DocumentCodeLensResponse> {
2017-03-15 07:14:44 +00:00
static constexpr IpcId kIpcId = IpcId::DocumentCodeLensResponse;
RequestId request_id;
std::vector<TCodeLens> code_lens;
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
2017-03-15 07:14:44 +00:00
void Reflect(TVisitor& visitor, IpcMessage_DocumentCodeLensResponse& value) {
REFLECT_MEMBER_START();
REFLECT_MEMBER(request_id);
REFLECT_MEMBER(code_lens);
REFLECT_MEMBER_END();
}
2017-03-17 07:58:41 +00:00
struct IpcMessage_CodeLensResolveRequest
: public BaseIpcMessage<IpcMessage_CodeLensResolveRequest> {
2017-03-15 07:14:44 +00:00
static constexpr IpcId kIpcId = IpcId::CodeLensResolveRequest;
RequestId request_id;
TCodeLens code_lens;
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
2017-03-15 07:14:44 +00:00
void Reflect(TVisitor& visitor, IpcMessage_CodeLensResolveRequest& value) {
REFLECT_MEMBER_START();
REFLECT_MEMBER(request_id);
REFLECT_MEMBER(code_lens);
REFLECT_MEMBER_END();
}
2017-03-17 07:58:41 +00:00
struct IpcMessage_CodeLensResolveResponse
: public BaseIpcMessage<IpcMessage_CodeLensResolveResponse> {
2017-03-15 07:14:44 +00:00
static constexpr IpcId kIpcId = IpcId::CodeLensResolveResponse;
RequestId request_id;
TCodeLens code_lens;
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
2017-03-15 07:14:44 +00:00
void Reflect(TVisitor& visitor, IpcMessage_CodeLensResolveResponse& value) {
REFLECT_MEMBER_START();
REFLECT_MEMBER(request_id);
REFLECT_MEMBER(code_lens);
REFLECT_MEMBER_END();
}
2017-03-17 07:58:41 +00:00
struct IpcMessage_WorkspaceSymbolsResponse
: public BaseIpcMessage<IpcMessage_WorkspaceSymbolsResponse> {
2017-03-12 00:36:00 +00:00
static constexpr IpcId kIpcId = IpcId::WorkspaceSymbolsResponse;
RequestId request_id;
2017-03-10 07:06:01 +00:00
std::vector<lsSymbolInformation> symbols;
2017-03-06 08:48:51 +00:00
};
2017-03-17 07:58:41 +00:00
template <typename TVisitor>
2017-03-12 00:36:00 +00:00
void Reflect(TVisitor& visitor, IpcMessage_WorkspaceSymbolsResponse& value) {
REFLECT_MEMBER_START();
REFLECT_MEMBER(request_id);
REFLECT_MEMBER(symbols);
REFLECT_MEMBER_END();
}
2017-03-14 08:33:39 +00:00
struct Timer {
using Clock = std::chrono::high_resolution_clock;
std::chrono::time_point<Clock> start_;
2017-03-05 02:16:23 +00:00
2017-03-17 07:58:41 +00:00
Timer() { Reset(); }
2017-03-05 02:16:23 +00:00
2017-03-17 07:58:41 +00:00
void Reset() { start_ = Clock::now(); }
2017-03-05 02:16:23 +00:00
2017-03-14 08:33:39 +00:00
long long ElapsedMilliseconds() {
std::chrono::time_point<Clock> end = Clock::now();
2017-03-17 07:58:41 +00:00
return std::chrono::duration_cast<std::chrono::milliseconds>(end - start_)
.count();
2017-03-14 08:33:39 +00:00
}
};
2017-03-05 02:16:23 +00:00
2017-03-15 04:59:05 +00:00
void IndexMainLoop(IpcClient* client) {
std::vector<std::unique_ptr<IpcMessage>> messages = client->TakeMessages();
2017-03-14 08:33:39 +00:00
for (auto& message : messages) {
2017-03-17 07:58:41 +00:00
// std::cerr << "Processing message " << static_cast<int>(message->ipc_id)
// << std::endl;
2017-03-14 08:33:39 +00:00
switch (message->ipc_id) {
2017-03-17 07:58:41 +00:00
case IpcId::Quit: {
exit(0);
break;
}
2017-03-14 08:33:39 +00:00
2017-03-17 07:58:41 +00:00
case IpcId::IndexTranslationUnitRequest: {
IpcMessage_IndexTranslationUnitRequest* msg =
static_cast<IpcMessage_IndexTranslationUnitRequest*>(message.get());
2017-03-14 08:33:39 +00:00
2017-03-17 07:58:41 +00:00
std::cerr << "Parsing file " << msg->path << " with args "
<< Join(msg->args, ", ") << std::endl;
2017-03-14 08:33:39 +00:00
2017-03-17 07:58:41 +00:00
Timer time;
IndexedFile file = Parse(msg->path, msg->args);
std::cerr << "Parsing/indexing took " << time.ElapsedMilliseconds()
<< "ms" << std::endl;
2017-03-14 08:33:39 +00:00
2017-03-17 07:58:41 +00:00
time.Reset();
IndexUpdate update(file);
auto response = IpcMessage_IndexTranslationUnitResponse(update);
std::cerr << "Creating index update took " << time.ElapsedMilliseconds()
<< "ms" << std::endl;
2017-03-14 08:33:39 +00:00
2017-03-17 07:58:41 +00:00
time.Reset();
client->SendToServer(&response);
std::cerr << "Sending to server took " << time.ElapsedMilliseconds()
<< "ms" << std::endl;
2017-03-14 08:33:39 +00:00
2017-03-17 07:58:41 +00:00
break;
}
2017-03-14 08:33:39 +00:00
}
}
}
void IndexMain(int id) {
2017-03-15 04:59:05 +00:00
IpcClient client_ipc(kIpcIndexerName, id);
2017-03-14 08:33:39 +00:00
while (true) {
IndexMainLoop(&client_ipc);
std::this_thread::sleep_for(std::chrono::milliseconds(10));
}
}
2017-03-05 19:48:05 +00:00
2017-03-15 07:14:44 +00:00
QueryableFile* FindFile(QueryableDatabase* db, const std::string& filename) {
2017-03-17 07:58:41 +00:00
// std::cerr << "Wanted file " << msg->document << std::endl;
2017-03-15 07:14:44 +00:00
// TODO: hashmap lookup.
for (auto& file : db->files) {
2017-03-17 07:58:41 +00:00
// std::cerr << " - Have file " << file.file_id << std::endl;
2017-03-15 07:14:44 +00:00
if (file.file_id == filename) {
std::cerr << "Found file " << filename << std::endl;
return &file;
}
}
2017-03-15 04:59:05 +00:00
2017-03-15 07:14:44 +00:00
std::cerr << "Unable to find file " << filename << std::endl;
return nullptr;
}
2017-03-15 04:59:05 +00:00
2017-03-16 07:36:49 +00:00
lsLocation GetLsLocation(const QueryableLocation& location) {
2017-03-15 07:14:44 +00:00
return lsLocation(
2017-03-17 07:58:41 +00:00
lsDocumentUri::FromPath(location.path),
lsRange(lsPosition(location.line - 1, location.column - 1)));
2017-03-15 07:14:44 +00:00
}
2017-03-15 04:59:05 +00:00
2017-03-17 07:58:41 +00:00
void AddCodeLens(std::vector<TCodeLens>* result,
QueryableLocation loc,
const std::vector<QueryableLocation>& uses,
bool only_interesting,
const char* singular,
const char* plural) {
2017-03-16 07:36:49 +00:00
TCodeLens code_lens;
2017-03-17 07:58:41 +00:00
code_lens.range.start.line =
loc.line - 1; // TODO: cleanup indexer to negate by 1.
code_lens.range.start.character =
loc.column - 1; // TODO: cleanup indexer to negate by 1.
// TODO: store range information.
2017-03-16 07:36:49 +00:00
code_lens.range.end.line = code_lens.range.start.line;
code_lens.range.end.character = code_lens.range.start.character;
code_lens.command = lsCommand<lsCodeLensCommandArguments>();
code_lens.command->command = "superindex.showReferences";
code_lens.command->arguments.uri = lsDocumentUri::FromPath(loc.path);
code_lens.command->arguments.position = code_lens.range.start;
// Add unique uses.
std::unordered_set<lsLocation> unique_uses;
for (const QueryableLocation& use : uses) {
2017-03-17 07:58:41 +00:00
if (only_interesting && !use.interesting)
continue;
2017-03-16 07:36:49 +00:00
unique_uses.insert(GetLsLocation(use));
}
2017-03-17 07:58:41 +00:00
code_lens.command->arguments.locations.assign(unique_uses.begin(),
unique_uses.end());
2017-03-16 07:36:49 +00:00
// User visible label
int num_usages = unique_uses.size();
code_lens.command->title = std::to_string(num_usages) + " ";
if (num_usages == 1)
code_lens.command->title += singular;
else
code_lens.command->title += plural;
if (unique_uses.size() > 0)
result->push_back(code_lens);
}
2017-03-17 07:58:41 +00:00
void AddCodeLens(std::vector<TCodeLens>* result,
QueryableLocation loc,
const std::vector<UsrRef>& uses,
bool only_interesting,
const char* singular,
const char* plural) {
2017-03-16 07:36:49 +00:00
std::vector<QueryableLocation> uses0;
uses0.reserve(uses.size());
for (const UsrRef& use : uses)
uses0.push_back(use.loc);
AddCodeLens(result, loc, uses0, only_interesting, singular, plural);
}
2017-03-17 07:58:41 +00:00
void AddCodeLens(std::vector<TCodeLens>* result,
QueryableDatabase* db,
QueryableLocation loc,
const std::vector<Usr>& usrs,
bool only_interesting,
const char* singular,
const char* plural) {
2017-03-16 07:36:49 +00:00
std::vector<QueryableLocation> uses0;
uses0.reserve(usrs.size());
for (const Usr& usr : usrs) {
SymbolIdx symbol = db->usr_to_symbol[usr];
switch (symbol.kind) {
2017-03-17 07:58:41 +00:00
case SymbolKind::Type: {
QueryableTypeDef* def = &db->types[symbol.idx];
if (def->def.definition)
uses0.push_back(def->def.definition.value());
break;
}
case SymbolKind::Func: {
QueryableFuncDef* def = &db->funcs[symbol.idx];
if (def->def.definition)
uses0.push_back(def->def.definition.value());
break;
}
case SymbolKind::Var: {
2017-03-25 01:07:48 +00:00
QueryableVarDef* def = &db->vars[symbol.idx];
if (def->def.definition)
uses0.push_back(def->def.definition.value());
break;
}
case SymbolKind::File:
case SymbolKind::Invalid: {
2017-03-17 07:58:41 +00:00
assert(false && "unexpected");
break;
}
2017-03-16 07:36:49 +00:00
}
}
AddCodeLens(result, loc, uses0, only_interesting, singular, plural);
}
2017-03-17 07:58:41 +00:00
void QueryDbMainLoop(IpcServer* language_client,
IpcServer* indexers,
QueryableDatabase* db) {
std::vector<std::unique_ptr<IpcMessage>> messages =
language_client->TakeMessages();
2017-03-05 19:48:05 +00:00
for (auto& message : messages) {
2017-03-17 07:58:41 +00:00
// std::cerr << "Processing message " << static_cast<int>(message->ipc_id)
// << std::endl;
2017-03-05 19:48:05 +00:00
2017-03-12 00:36:00 +00:00
switch (message->ipc_id) {
2017-03-17 07:58:41 +00:00
case IpcId::Quit: {
break;
2017-03-05 19:48:05 +00:00
}
2017-03-17 07:58:41 +00:00
case IpcId::IsAlive: {
IpcMessage_IsAlive response;
language_client->SendToClient(0, &response); // todo: make non-blocking
break;
}
2017-03-15 07:14:44 +00:00
2017-03-17 07:58:41 +00:00
case IpcId::OpenProject: {
IpcMessage_OpenProject* msg =
static_cast<IpcMessage_OpenProject*>(message.get());
std::string path = msg->project_path;
std::vector<CompilationEntry> entries =
LoadCompilationEntriesFromDirectory(path);
for (int i = 0; i < entries.size(); ++i) {
const CompilationEntry& entry = entries[i];
std::string filepath = path + "/" + entry.filename;
std::cerr << "[" << i << "/" << (entries.size() - 1)
<< "] Dispatching index request for file " << filepath
<< std::endl;
// TODO: indexers should steal work and load balance.
IpcMessage_IndexTranslationUnitRequest request;
request.path = filepath;
request.args = entry.args;
indexers->SendToClient(i % indexers->num_clients(), &request);
// IndexedFile file = Parse(filepath, entry.args);
// IndexUpdate update(file);
// db->ApplyIndexUpdate(&update);
2017-03-15 07:14:44 +00:00
}
2017-03-17 07:58:41 +00:00
std::cerr << "Done" << std::endl;
break;
2017-03-15 07:14:44 +00:00
}
2017-03-17 07:58:41 +00:00
case IpcId::DocumentSymbolsRequest: {
auto msg =
static_cast<IpcMessage_DocumentSymbolsRequest*>(message.get());
IpcMessage_DocumentSymbolsResponse response;
response.request_id = msg->request_id;
QueryableFile* file = FindFile(db, msg->document);
if (file) {
for (UsrRef ref : file->outline) {
SymbolIdx symbol = db->usr_to_symbol[ref.usr];
lsSymbolInformation info;
info.location.range.start.line =
ref.loc.line - 1; // TODO: cleanup indexer to negate by 1.
info.location.range.start.character =
ref.loc.column - 1; // TODO: cleanup indexer to negate by 1.
// TODO: store range information.
info.location.range.end.line = info.location.range.start.line;
info.location.range.end.character =
info.location.range.start.character;
// TODO: cleanup namespace/naming so there is only one SymbolKind.
switch (symbol.kind) {
2017-03-25 01:07:48 +00:00
case SymbolKind::Type: {
2017-03-17 07:58:41 +00:00
QueryableTypeDef& def = db->types[symbol.idx];
info.name = def.def.qualified_name;
info.kind = lsSymbolKind::Class;
break;
}
case SymbolKind::Func: {
QueryableFuncDef& def = db->funcs[symbol.idx];
info.name = def.def.qualified_name;
if (def.def.declaring_type.has_value()) {
info.kind = lsSymbolKind::Method;
Usr declaring = def.def.declaring_type.value();
info.containerName =
db->types[db->usr_to_symbol[declaring].idx]
.def.qualified_name;
} else {
info.kind = lsSymbolKind::Function;
}
break;
}
2017-03-25 01:07:48 +00:00
case SymbolKind::Var: {
2017-03-17 07:58:41 +00:00
QueryableVarDef& def = db->vars[symbol.idx];
info.name = def.def.qualified_name;
info.kind = lsSymbolKind::Variable;
break;
}
2017-03-25 01:07:48 +00:00
case SymbolKind::File:
case SymbolKind::Invalid: {
assert(false && "unexpected");
break;
}
2017-03-17 07:58:41 +00:00
};
response.symbols.push_back(info);
2017-03-05 19:48:05 +00:00
}
2017-03-05 02:16:23 +00:00
}
2017-03-06 08:48:51 +00:00
2017-03-17 07:58:41 +00:00
language_client->SendToClient(0, &response);
break;
}
2017-03-06 08:48:51 +00:00
2017-03-17 07:58:41 +00:00
case IpcId::DocumentCodeLensRequest: {
auto msg =
static_cast<IpcMessage_DocumentCodeLensRequest*>(message.get());
IpcMessage_DocumentCodeLensResponse response;
response.request_id = msg->request_id;
lsDocumentUri file_as_uri;
file_as_uri.SetPath(msg->document);
QueryableFile* file = FindFile(db, msg->document);
if (file) {
for (UsrRef ref : file->outline) {
SymbolIdx symbol = db->usr_to_symbol[ref.usr];
switch (symbol.kind) {
case SymbolKind::Type: {
QueryableTypeDef& def = db->types[symbol.idx];
AddCodeLens(&response.code_lens, ref.loc, def.uses,
true /*only_interesting*/, "reference",
"references");
AddCodeLens(&response.code_lens, db, ref.loc, def.derived,
false /*only_interesting*/, "derived", "derived");
break;
}
case SymbolKind::Func: {
QueryableFuncDef& def = db->funcs[symbol.idx];
AddCodeLens(&response.code_lens, ref.loc, def.uses,
false /*only_interesting*/, "reference",
"references");
AddCodeLens(&response.code_lens, ref.loc, def.callers,
false /*only_interesting*/, "caller", "callers");
AddCodeLens(&response.code_lens, ref.loc, def.def.callees,
false /*only_interesting*/, "callee", "callees");
AddCodeLens(&response.code_lens, db, ref.loc, def.derived,
false /*only_interesting*/, "derived", "derived");
break;
}
case SymbolKind::Var: {
QueryableVarDef& def = db->vars[symbol.idx];
AddCodeLens(&response.code_lens, ref.loc, def.uses,
false /*only_interesting*/, "reference",
"references");
break;
}
2017-03-25 01:07:48 +00:00
case SymbolKind::File:
case SymbolKind::Invalid: {
assert(false && "unexpected");
break;
}
2017-03-17 07:58:41 +00:00
};
2017-03-06 08:48:51 +00:00
}
2017-03-17 07:58:41 +00:00
}
2017-03-06 08:48:51 +00:00
2017-03-17 07:58:41 +00:00
language_client->SendToClient(0, &response);
break;
}
2017-03-06 08:48:51 +00:00
2017-03-17 07:58:41 +00:00
case IpcId::WorkspaceSymbolsRequest: {
auto msg =
static_cast<IpcMessage_WorkspaceSymbolsRequest*>(message.get());
IpcMessage_WorkspaceSymbolsResponse response;
response.request_id = msg->request_id;
std::cerr << "- Considering " << db->qualified_names.size()
<< " candidates " << std::endl;
for (int i = 0; i < db->qualified_names.size(); ++i) {
const std::string& name = db->qualified_names[i];
// std::cerr << "- Considering " << name << std::endl;
if (name.find(msg->query) != std::string::npos) {
lsSymbolInformation info;
info.name = name;
SymbolIdx symbol = db->symbols[i];
// TODO: dedup this code w/ above (ie, add ctor to convert symbol to
// SymbolInformation)
switch (symbol.kind) {
// TODO: file
2017-03-25 01:07:48 +00:00
case SymbolKind::Type: {
2017-03-17 07:58:41 +00:00
QueryableTypeDef& def = db->types[symbol.idx];
info.name = def.def.qualified_name;
info.kind = lsSymbolKind::Class;
if (def.def.definition.has_value()) {
info.location.uri.SetPath(def.def.definition->path);
info.location.range.start.line = def.def.definition->line - 1;
info.location.range.start.character =
def.def.definition->column - 1;
}
break;
}
2017-03-25 01:07:48 +00:00
case SymbolKind::Func: {
2017-03-17 07:58:41 +00:00
QueryableFuncDef& def = db->funcs[symbol.idx];
info.name = def.def.qualified_name;
if (def.def.declaring_type.has_value()) {
info.kind = lsSymbolKind::Method;
Usr declaring = def.def.declaring_type.value();
info.containerName =
db->types[db->usr_to_symbol[declaring].idx]
.def.qualified_name;
} else {
info.kind = lsSymbolKind::Function;
}
if (def.def.definition.has_value()) {
info.location.uri.SetPath(def.def.definition->path);
info.location.range.start.line = def.def.definition->line - 1;
info.location.range.start.character =
def.def.definition->column - 1;
}
break;
}
2017-03-25 01:07:48 +00:00
case SymbolKind::Var: {
2017-03-17 07:58:41 +00:00
QueryableVarDef& def = db->vars[symbol.idx];
info.name = def.def.qualified_name;
info.kind = lsSymbolKind::Variable;
if (def.def.definition.has_value()) {
info.location.uri.SetPath(def.def.definition->path);
info.location.range.start.line = def.def.definition->line - 1;
info.location.range.start.character =
def.def.definition->column - 1;
}
2017-03-25 01:07:48 +00:00
break;
}
case SymbolKind::Invalid: {
assert(false && "unexpected");
2017-03-17 07:58:41 +00:00
break;
}
};
// TODO: store range information.
info.location.range.end.line = info.location.range.start.line;
info.location.range.end.character =
info.location.range.start.character;
response.symbols.push_back(info);
}
2017-03-06 08:48:51 +00:00
}
2017-03-17 07:58:41 +00:00
language_client->SendToClient(0, &response);
break;
}
2017-03-15 04:59:05 +00:00
2017-03-17 07:58:41 +00:00
default: {
std::cerr << "Unhandled IPC message with kind "
<< static_cast<int>(message->ipc_id) << std::endl;
exit(1);
}
2017-03-15 04:59:05 +00:00
}
}
messages = indexers->TakeMessages();
for (auto& message : messages) {
2017-03-17 07:58:41 +00:00
// std::cerr << "Processing message " << static_cast<int>(message->ipc_id)
// << std::endl;
2017-03-15 04:59:05 +00:00
switch (message->ipc_id) {
2017-03-17 07:58:41 +00:00
case IpcId::IndexTranslationUnitResponse: {
IpcMessage_IndexTranslationUnitResponse* msg =
static_cast<IpcMessage_IndexTranslationUnitResponse*>(
message.get());
Timer time;
db->ApplyIndexUpdate(&msg->update);
std::cerr << "Applying index update took " << time.ElapsedMilliseconds()
<< "ms" << std::endl;
break;
}
2017-03-15 04:59:05 +00:00
2017-03-17 07:58:41 +00:00
default: {
std::cerr << "Unhandled IPC message with kind "
<< static_cast<int>(message->ipc_id) << std::endl;
exit(1);
}
2017-03-12 00:36:00 +00:00
}
2017-03-05 02:16:23 +00:00
}
}
2017-03-15 04:59:05 +00:00
void QueryDbMain() {
std::cerr << "Running QueryDb" << std::endl;
IpcServer language_client(kIpcLanguageClientName, 1 /*num_clients*/);
IpcServer indexers(kIpcIndexerName, kNumIndexers);
QueryableDatabase db;
std::cerr << "!! starting processes" << std::endl;
// Start indexer processes.
for (int i = 0; i < kNumIndexers; ++i) {
2017-03-17 07:58:41 +00:00
// new Process(process_name + " --indexer " + std::to_string(i + 1));
new std::thread([i]() { IndexMain(i); });
2017-03-15 04:59:05 +00:00
}
std::cerr << "!! done processes" << std::endl;
// Pump query db main loop.
while (true) {
QueryDbMainLoop(&language_client, &indexers, &db);
std::this_thread::sleep_for(std::chrono::milliseconds(10));
}
}
2017-03-05 19:48:05 +00:00
// TODO: global lock on stderr output.
// Separate thread whose only job is to read from stdin and
// dispatch read commands to the actual indexer program. This
// cannot be done on the main thread because reading from std::cin
// blocks.
//
// |ipc| is connected to a server.
2017-03-14 08:33:39 +00:00
void LanguageServerStdinLoop(IpcClient* server) {
2017-03-05 02:16:23 +00:00
while (true) {
std::unique_ptr<InMessage> message = ParseMessage();
// Message parsing can fail if we don't recognize the method.
if (!message)
continue;
2017-03-17 07:58:41 +00:00
std::cerr << "[info]: Got message of type "
<< MethodIdToString(message->method_id) << std::endl;
2017-03-05 02:16:23 +00:00
switch (message->method_id) {
2017-03-17 07:58:41 +00:00
case lsMethodId::Initialize: {
auto request = static_cast<In_InitializeRequest*>(message.get());
if (request->params.rootUri) {
std::string project_path = request->params.rootUri->GetPath();
std::cerr << "Initialize in directory " << project_path
<< " with uri " << request->params.rootUri->raw_uri
<< std::endl;
IpcMessage_OpenProject open_project;
open_project.project_path = project_path;
server->SendToServer(&open_project);
}
2017-03-05 19:48:05 +00:00
2017-03-17 07:58:41 +00:00
auto response = Out_InitializeResponse();
response.id = message->id.value();
response.result.capabilities.documentSymbolProvider = true;
// response.result.capabilities.referencesProvider = true;
response.result.capabilities.codeLensProvider = lsCodeLensOptions();
response.result.capabilities.codeLensProvider->resolveProvider = false;
response.result.capabilities.workspaceSymbolProvider = true;
response.Send();
break;
}
2017-03-03 08:12:11 +00:00
2017-03-17 07:58:41 +00:00
case lsMethodId::TextDocumentDocumentSymbol: {
// TODO: response should take id as input.
// TODO: message should not have top-level id.
auto request = static_cast<In_DocumentSymbolRequest*>(message.get());
IpcMessage_DocumentSymbolsRequest ipc_request;
ipc_request.request_id = request->id.value();
ipc_request.document = request->params.textDocument.uri.GetPath();
std::cerr << "Request textDocument=" << ipc_request.document
<< std::endl;
server->SendToServer(&ipc_request);
break;
}
2017-03-06 08:48:51 +00:00
2017-03-17 07:58:41 +00:00
case lsMethodId::TextDocumentCodeLens: {
auto request = static_cast<In_DocumentCodeLensRequest*>(message.get());
2017-03-15 07:14:44 +00:00
2017-03-17 07:58:41 +00:00
IpcMessage_DocumentCodeLensRequest ipc_request;
ipc_request.request_id = request->id.value();
ipc_request.document = request->params.textDocument.uri.GetPath();
std::cerr << "Request codeLens on textDocument=" << ipc_request.document
<< std::endl;
server->SendToServer(&ipc_request);
break;
}
2017-03-15 07:14:44 +00:00
2017-03-17 07:58:41 +00:00
case lsMethodId::WorkspaceSymbol: {
auto request = static_cast<In_WorkspaceSymbolRequest*>(message.get());
IpcMessage_WorkspaceSymbolsRequest ipc_request;
ipc_request.request_id = request->id.value();
ipc_request.query = request->params.query;
std::cerr << "Request query=" << ipc_request.query << std::endl;
server->SendToServer(&ipc_request);
break;
}
2017-03-03 08:12:11 +00:00
}
}
}
2017-03-05 19:48:05 +00:00
void LanguageServerMainLoop(IpcClient* ipc) {
2017-03-12 00:36:00 +00:00
std::vector<std::unique_ptr<IpcMessage>> messages = ipc->TakeMessages();
2017-03-05 19:48:05 +00:00
for (auto& message : messages) {
2017-03-12 00:36:00 +00:00
switch (message->ipc_id) {
2017-03-17 07:58:41 +00:00
case IpcId::Quit: {
exit(0);
break;
}
2017-03-15 07:14:44 +00:00
2017-03-17 07:58:41 +00:00
case IpcId::DocumentSymbolsResponse: {
auto msg =
static_cast<IpcMessage_DocumentSymbolsResponse*>(message.get());
auto response = Out_DocumentSymbolResponse();
response.id = msg->request_id;
response.result = msg->symbols;
response.Send();
std::cerr << "Sent symbol response to client ("
<< response.result.size() << " symbols)" << std::endl;
break;
}
2017-03-05 19:48:05 +00:00
2017-03-17 07:58:41 +00:00
case IpcId::DocumentCodeLensResponse: {
auto msg =
static_cast<IpcMessage_DocumentCodeLensResponse*>(message.get());
auto response = Out_DocumentCodeLensResponse();
response.id = msg->request_id;
response.result = msg->code_lens;
response.Send();
std::cerr << "Sent code lens response to client ("
<< response.result.size() << " symbols)" << std::endl;
break;
}
2017-03-06 08:48:51 +00:00
2017-03-17 07:58:41 +00:00
case IpcId::WorkspaceSymbolsResponse: {
auto msg =
static_cast<IpcMessage_WorkspaceSymbolsResponse*>(message.get());
auto response = Out_WorkspaceSymbolResponse();
response.id = msg->request_id;
response.result = msg->symbols;
response.Send();
std::cerr << "Send symbol response to client ("
<< response.result.size() << " symbols)" << std::endl;
break;
}
2017-03-06 08:48:51 +00:00
2017-03-17 07:58:41 +00:00
default: {
std::cerr << "Unhandled IPC message with kind "
<< static_cast<int>(message->ipc_id) << std::endl;
exit(1);
}
2017-03-12 00:36:00 +00:00
}
2017-03-05 19:48:05 +00:00
}
}
void LanguageServerMain(std::string process_name) {
2017-03-15 04:59:05 +00:00
IpcClient client_ipc(kIpcLanguageClientName, 0);
// Discard any left-over messages from previous runs.
2017-03-05 19:48:05 +00:00
client_ipc.TakeMessages();
// Emit an alive check. Sleep so the server has time to respond.
IpcMessage_IsAlive check_alive;
2017-03-05 19:48:05 +00:00
client_ipc.SendToServer(&check_alive);
2017-03-04 01:45:20 +00:00
// TODO: Tune this value or make it configurable.
2017-03-16 07:36:49 +00:00
std::this_thread::sleep_for(std::chrono::milliseconds(100));
// Check if we got an IsAlive message back.
2017-03-12 00:36:00 +00:00
std::vector<std::unique_ptr<IpcMessage>> messages = client_ipc.TakeMessages();
bool has_server = false;
for (auto& message : messages) {
2017-03-12 00:36:00 +00:00
if (IpcId::IsAlive == message->ipc_id) {
has_server = true;
break;
}
}
2017-03-17 07:58:41 +00:00
// No server is running. Start it.
2017-03-05 19:48:05 +00:00
#if false
if (!has_server) {
if (process_name.empty())
return;
Process p(process_name + " --querydb", "",
/*stdout*/[](const char* bytes, size_t n) {
for (int i = 0; i < n; ++i)
std::cerr << bytes[i];
},
/*stderr*/[](const char* bytes, size_t n) {
for (int i = 0; i < n; ++i)
std::cerr << bytes[i];
2017-03-12 00:36:00 +00:00
},
2017-03-06 08:48:51 +00:00
/*open_stdin*/false);
2017-03-05 19:48:05 +00:00
std::this_thread::sleep_for(std::chrono::seconds(1));
// Pass empty process name so we only try to start the querydb once.
LanguageServerMain("");
return;
2017-03-15 07:14:44 +00:00
}
2017-03-05 19:48:05 +00:00
#endif
2017-03-05 02:16:23 +00:00
2017-03-05 19:48:05 +00:00
// for debugging attach
2017-03-17 07:58:41 +00:00
// std::this_thread::sleep_for(std::chrono::seconds(4));
2017-03-14 08:33:39 +00:00
2017-03-05 19:48:05 +00:00
if (!has_server) {
2017-03-14 06:30:41 +00:00
// No server. Run it in-process.
2017-03-17 07:58:41 +00:00
new std::thread([&]() { QueryDbMain(); });
2017-03-05 19:48:05 +00:00
}
2017-03-05 02:16:23 +00:00
2017-03-14 06:30:41 +00:00
// Run language client.
2017-03-15 04:59:05 +00:00
std::thread stdio_reader(&LanguageServerStdinLoop, &client_ipc);
2017-03-14 06:30:41 +00:00
while (true) {
LanguageServerMainLoop(&client_ipc);
2017-03-14 08:33:39 +00:00
std::this_thread::sleep_for(std::chrono::milliseconds(10));
2017-03-05 19:48:05 +00:00
}
2017-03-16 07:36:49 +00:00
}
2017-03-03 08:12:11 +00:00
2017-03-15 04:59:05 +00:00
void PreMain() {
2017-03-17 07:58:41 +00:00
// We need to write to stdout in binary mode because in Windows, writing
// \n will implicitly write \r\n. Language server API will ignore a
// \r\r\n split request.
2017-03-05 02:16:23 +00:00
#ifdef _WIN32
_setmode(_fileno(stdout), O_BINARY);
_setmode(_fileno(stdin), O_BINARY);
#endif
2017-03-15 04:59:05 +00:00
IpcRegistry::instance()->Register<IpcMessage_Quit>(IpcMessage_Quit::kIpcId);
2017-03-17 07:58:41 +00:00
IpcRegistry::instance()->Register<IpcMessage_IsAlive>(
IpcMessage_IsAlive::kIpcId);
IpcRegistry::instance()->Register<IpcMessage_OpenProject>(
IpcMessage_OpenProject::kIpcId);
IpcRegistry::instance()->Register<IpcMessage_IndexTranslationUnitRequest>(
IpcMessage_IndexTranslationUnitRequest::kIpcId);
IpcRegistry::instance()->Register<IpcMessage_IndexTranslationUnitResponse>(
IpcMessage_IndexTranslationUnitResponse::kIpcId);
IpcRegistry::instance()->Register<IpcMessage_DocumentSymbolsRequest>(
IpcMessage_DocumentSymbolsRequest::kIpcId);
IpcRegistry::instance()->Register<IpcMessage_DocumentSymbolsResponse>(
IpcMessage_DocumentSymbolsResponse::kIpcId);
IpcRegistry::instance()->Register<IpcMessage_DocumentCodeLensRequest>(
IpcMessage_DocumentCodeLensRequest::kIpcId);
IpcRegistry::instance()->Register<IpcMessage_DocumentCodeLensResponse>(
IpcMessage_DocumentCodeLensResponse::kIpcId);
IpcRegistry::instance()->Register<IpcMessage_CodeLensResolveRequest>(
IpcMessage_CodeLensResolveRequest::kIpcId);
IpcRegistry::instance()->Register<IpcMessage_CodeLensResolveResponse>(
IpcMessage_CodeLensResolveResponse::kIpcId);
IpcRegistry::instance()->Register<IpcMessage_WorkspaceSymbolsRequest>(
IpcMessage_WorkspaceSymbolsRequest::kIpcId);
IpcRegistry::instance()->Register<IpcMessage_WorkspaceSymbolsResponse>(
IpcMessage_WorkspaceSymbolsResponse::kIpcId);
2017-03-25 01:27:41 +00:00
}
2017-03-06 08:48:51 +00:00
2017-03-25 01:27:41 +00:00
template<typename T>
void RegisterId(TypedBidiMessageQueue<lsMethodId, lsBaseMessage>& t) {
t.RegisterId(T::kMethod,
[](Writer& visitor, lsBaseMessage& message) {
T& m = static_cast<T&>(message);
Reflect(visitor, m);
}, [](Reader& visitor) {
auto m = MakeUnique<T>();
Reflect(visitor, *m);
return m;
});
2017-03-15 04:59:05 +00:00
}
2017-03-25 01:28:09 +00:00
int main(int argc, char** argv) {
2017-03-25 01:27:41 +00:00
// TODO: real queue size
2017-03-24 05:20:08 +00:00
const int kQueueSize = 128;
2017-03-24 07:59:47 +00:00
TypedBidiMessageQueue<lsMethodId, lsBaseMessage> t("foo", kQueueSize);
2017-03-25 01:27:41 +00:00
RegisterId<In_CancelRequest>(t);
RegisterId<In_InitializeRequest>(t);
RegisterId<In_InitializedNotification>(t);
RegisterId<In_DocumentSymbolRequest>(t);
RegisterId<In_DocumentCodeLensRequest>(t);
RegisterId<In_WorkspaceSymbolRequest>(t);
/*
2017-03-24 07:59:47 +00:00
// TODO: We can make this entire function a template.
t.RegisterId(In_DocumentSymbolRequest::kMethod,
[](Writer& visitor, lsBaseMessage& message) {
In_DocumentSymbolRequest& m = static_cast<In_DocumentSymbolRequest&>(message);
Reflect(visitor, m);
}, [](Reader& visitor) {
auto m = MakeUnique<In_DocumentSymbolRequest>();
Reflect(visitor, *m);
return m;
});
2017-03-25 01:27:41 +00:00
*/
2017-03-24 07:59:47 +00:00
//struct In_DocumentSymbolRequest : public InRequestMessage {
// const static lsMethodId kMethod = lsMethodId::TextDocumentDocumentSymbol;
//MyMessageType mm;
//t.SendMessage(&t.for_client, lsMethodId::Initialize, &mm);
//t.GetMessages(&t.for_client);
2017-03-24 05:20:08 +00:00
2017-03-15 04:59:05 +00:00
bool loop = false;
while (loop)
std::this_thread::sleep_for(std::chrono::milliseconds(10));
2017-03-03 08:12:11 +00:00
2017-03-15 04:59:05 +00:00
PreMain();
2017-03-17 07:58:41 +00:00
// if (argc == 1) {
2017-03-16 07:36:49 +00:00
// QueryDbMain();
// return 0;
//}
2017-03-15 04:59:05 +00:00
if (argc == 1) {
2017-03-17 23:45:10 +00:00
doctest::Context context;
context.applyCommandLine(argc, argv);
int res = context.run();
if (context.shouldExit())
return res;
//RunTests();
2017-03-15 04:59:05 +00:00
return 0;
}
2017-02-25 23:59:09 +00:00
2017-03-17 07:58:41 +00:00
std::unordered_map<std::string, std::string> options =
ParseOptions(argc, argv);
2017-02-25 23:59:09 +00:00
2017-03-05 19:48:05 +00:00
if (HasOption(options, "--language-server")) {
std::cerr << "Running language server" << std::endl;
LanguageServerMain(argv[0]);
return 0;
2017-02-25 23:59:09 +00:00
}
2017-03-14 08:33:39 +00:00
/* TODO: out of process querydb -- maybe?
2017-03-05 19:48:05 +00:00
else if (HasOption(options, "--querydb")) {
std::cerr << "Running querydb" << std::endl;
QueryableDatabase db;
2017-03-15 04:59:05 +00:00
IpcServer ipc(kIpcServername);
2017-03-05 19:48:05 +00:00
while (true) {
QueryDbMainLoop(&ipc, &db);
// TODO: use a condition variable.
2017-03-14 08:33:39 +00:00
std::this_thread::sleep_for(std::chrono::milliseconds(10));
2017-02-25 23:59:09 +00:00
}
2017-03-05 19:48:05 +00:00
return 0;
2017-02-25 23:59:09 +00:00
}
2017-03-14 08:33:39 +00:00
*/
else if (HasOption(options, "--indexer")) {
int index = atoi(options["--indexer"].c_str());
if (index == 0)
std::cerr << "--indexer expects an indexer id > 0" << std::endl;
IndexMain(index);
2017-03-17 07:58:41 +00:00
} else {
2017-03-05 19:48:05 +00:00
std::cerr << "Running language server" << std::endl;
LanguageServerMain(argv[0]);
return 0;
2017-02-25 23:59:09 +00:00
}
2017-03-05 19:48:05 +00:00
return 1;
2017-02-25 23:59:09 +00:00
}