[PATCH] D90376: [clangd] Add requests logging to clangd-index-server

[Kirill Bobyrev via Phabricator via cfe-commits]

kbobyrev created this revision.
kbobyrev added a reviewer: kadircet.
Herald added subscribers: cfe-commits, usaxena95, arphaman.
Herald added a project: clang.
kbobyrev requested review of this revision.
Herald added subscribers: MaskRay, ilya-biryukov.

This will allow us to track metrics of the server usage.


Repository:
  rG LLVM Github Monorepo

https://reviews.llvm.org/D90376

Files:
  clang-tools-extra/clangd/index/remote/server/Server.cpp


Index: clang-tools-extra/clangd/index/remote/server/Server.cpp
===================================================================
--- clang-tools-extra/clangd/index/remote/server/Server.cpp
+++ clang-tools-extra/clangd/index/remote/server/Server.cpp
@@ -88,6 +88,7 @@
                       const LookupRequest *Request,
                       grpc::ServerWriter<LookupReply> *Reply) override {
     trace::Span Tracer("LookupRequest");
+    const auto TimerStart = std::chrono::high_resolution_clock::now();
     auto Req = ProtobufMarshaller->fromProtobuf(Request);
     if (!Req) {
       elog("Can not parse LookupRequest from protobuf: {0}", Req.takeError());
@@ -113,6 +114,10 @@
     Reply->Write(LastMessage);
     SPAN_ATTACH(Tracer, "Sent", Sent);
     SPAN_ATTACH(Tracer, "Failed to send", FailedToSend);
+    const auto TimerStop = std::chrono::high_resolution_clock::now();
+    const auto Duration = 
std::chrono::duration_cast<std::chrono::milliseconds>(
+        TimerStop - TimerStart);
+    log("LookupRequest finished in {1:ms+n}", Duration);
     return grpc::Status::OK;
   }
 
@@ -120,6 +125,7 @@
                          const FuzzyFindRequest *Request,
                          grpc::ServerWriter<FuzzyFindReply> *Reply) override {
     trace::Span Tracer("FuzzyFindRequest");
+    const auto TimerStart = std::chrono::high_resolution_clock::now();
     auto Req = ProtobufMarshaller->fromProtobuf(Request);
     if (!Req) {
       elog("Can not parse FuzzyFindRequest from protobuf: {0}",
@@ -146,12 +152,17 @@
     Reply->Write(LastMessage);
     SPAN_ATTACH(Tracer, "Sent", Sent);
     SPAN_ATTACH(Tracer, "Failed to send", FailedToSend);
+    const auto TimerStop = std::chrono::high_resolution_clock::now();
+    const auto Duration = 
std::chrono::duration_cast<std::chrono::milliseconds>(
+        TimerStop - TimerStart);
+    log("FuzzyFindRequest finished in {1:ms+n}", Duration);
     return grpc::Status::OK;
   }
 
   grpc::Status Refs(grpc::ServerContext *Context, const RefsRequest *Request,
                     grpc::ServerWriter<RefsReply> *Reply) override {
     trace::Span Tracer("RefsRequest");
+    const auto TimerStart = std::chrono::high_resolution_clock::now();
     auto Req = ProtobufMarshaller->fromProtobuf(Request);
     if (!Req) {
       elog("Can not parse RefsRequest from protobuf: {0}", Req.takeError());
@@ -177,6 +188,10 @@
     Reply->Write(LastMessage);
     SPAN_ATTACH(Tracer, "Sent", Sent);
     SPAN_ATTACH(Tracer, "Failed to send", FailedToSend);
+    const auto TimerStop = std::chrono::high_resolution_clock::now();
+    const auto Duration = 
std::chrono::duration_cast<std::chrono::milliseconds>(
+        TimerStop - TimerStart);
+    log("RefsRequest finished in {1:ms+n}", Duration);
     return grpc::Status::OK;
   }
 
@@ -184,6 +199,7 @@
                          const RelationsRequest *Request,
                          grpc::ServerWriter<RelationsReply> *Reply) override {
     trace::Span Tracer("RelationsRequest");
+    const auto TimerStart = std::chrono::high_resolution_clock::now();
     auto Req = ProtobufMarshaller->fromProtobuf(Request);
     if (!Req) {
       elog("Can not parse RelationsRequest from protobuf: {0}",
@@ -211,6 +227,10 @@
     Reply->Write(LastMessage);
     SPAN_ATTACH(Tracer, "Sent", Sent);
     SPAN_ATTACH(Tracer, "Failed to send", FailedToSend);
+    const auto TimerStop = std::chrono::high_resolution_clock::now();
+    const auto Duration = 
std::chrono::duration_cast<std::chrono::milliseconds>(
+        TimerStop - TimerStart);
+    log("RelationsRequest finished in {1:ms+n}", Duration);
     return grpc::Status::OK;
   }
 



Index: clang-tools-extra/clangd/index/remote/server/Server.cpp
===================================================================
--- clang-tools-extra/clangd/index/remote/server/Server.cpp
+++ clang-tools-extra/clangd/index/remote/server/Server.cpp
@@ -88,6 +88,7 @@
                       const LookupRequest *Request,
                       grpc::ServerWriter<LookupReply> *Reply) override {
     trace::Span Tracer("LookupRequest");
+    const auto TimerStart = std::chrono::high_resolution_clock::now();
     auto Req = ProtobufMarshaller->fromProtobuf(Request);
     if (!Req) {
       elog("Can not parse LookupRequest from protobuf: {0}", Req.takeError());
@@ -113,6 +114,10 @@
     Reply->Write(LastMessage);
     SPAN_ATTACH(Tracer, "Sent", Sent);
     SPAN_ATTACH(Tracer, "Failed to send", FailedToSend);
+    const auto TimerStop = std::chrono::high_resolution_clock::now();
+    const auto Duration = std::chrono::duration_cast<std::chrono::milliseconds>(
+        TimerStop - TimerStart);
+    log("LookupRequest finished in {1:ms+n}", Duration);
     return grpc::Status::OK;
   }
 
@@ -120,6 +125,7 @@
                          const FuzzyFindRequest *Request,
                          grpc::ServerWriter<FuzzyFindReply> *Reply) override {
     trace::Span Tracer("FuzzyFindRequest");
+    const auto TimerStart = std::chrono::high_resolution_clock::now();
     auto Req = ProtobufMarshaller->fromProtobuf(Request);
     if (!Req) {
       elog("Can not parse FuzzyFindRequest from protobuf: {0}",
@@ -146,12 +152,17 @@
     Reply->Write(LastMessage);
     SPAN_ATTACH(Tracer, "Sent", Sent);
     SPAN_ATTACH(Tracer, "Failed to send", FailedToSend);
+    const auto TimerStop = std::chrono::high_resolution_clock::now();
+    const auto Duration = std::chrono::duration_cast<std::chrono::milliseconds>(
+        TimerStop - TimerStart);
+    log("FuzzyFindRequest finished in {1:ms+n}", Duration);
     return grpc::Status::OK;
   }
 
   grpc::Status Refs(grpc::ServerContext *Context, const RefsRequest *Request,
                     grpc::ServerWriter<RefsReply> *Reply) override {
     trace::Span Tracer("RefsRequest");
+    const auto TimerStart = std::chrono::high_resolution_clock::now();
     auto Req = ProtobufMarshaller->fromProtobuf(Request);
     if (!Req) {
       elog("Can not parse RefsRequest from protobuf: {0}", Req.takeError());
@@ -177,6 +188,10 @@
     Reply->Write(LastMessage);
     SPAN_ATTACH(Tracer, "Sent", Sent);
     SPAN_ATTACH(Tracer, "Failed to send", FailedToSend);
+    const auto TimerStop = std::chrono::high_resolution_clock::now();
+    const auto Duration = std::chrono::duration_cast<std::chrono::milliseconds>(
+        TimerStop - TimerStart);
+    log("RefsRequest finished in {1:ms+n}", Duration);
     return grpc::Status::OK;
   }
 
@@ -184,6 +199,7 @@
                          const RelationsRequest *Request,
                          grpc::ServerWriter<RelationsReply> *Reply) override {
     trace::Span Tracer("RelationsRequest");
+    const auto TimerStart = std::chrono::high_resolution_clock::now();
     auto Req = ProtobufMarshaller->fromProtobuf(Request);
     if (!Req) {
       elog("Can not parse RelationsRequest from protobuf: {0}",
@@ -211,6 +227,10 @@
     Reply->Write(LastMessage);
     SPAN_ATTACH(Tracer, "Sent", Sent);
     SPAN_ATTACH(Tracer, "Failed to send", FailedToSend);
+    const auto TimerStop = std::chrono::high_resolution_clock::now();
+    const auto Duration = std::chrono::duration_cast<std::chrono::milliseconds>(
+        TimerStop - TimerStart);
+    log("RelationsRequest finished in {1:ms+n}", Duration);
     return grpc::Status::OK;
   }
 

_______________________________________________
cfe-commits mailing list
cfe-commits@lists.llvm.org
https://lists.llvm.org/cgi-bin/mailman/listinfo/cfe-commits