fix(log): remove all the log output

Author: Raltour

src/core/common/config.cc

@@ -17,13 +17,13 @@ void Config::LoadConfigFile(const std::string& file_path) {
   tinyxml2::XMLDocument doc;
   tinyxml2::XMLError error = doc.LoadFile(file_path.c_str());
   if (error != tinyxml2::XML_SUCCESS) {
-    LOG_ERROR("Error: " + std::string(doc.ErrorStr()));
+    // LOG_ERROR("Error: " + std::string(doc.ErrorStr()));
     return;
   }
 
   tinyxml2::XMLElement* root = doc.FirstChildElement("root");
   if (!root) {
-    LOG_ERROR("No <root>.\n");
+    // LOG_ERROR("No <root>.\n");
     return;
   }
 

src/core/common/logger.h

@@ -35,9 +35,9 @@ class Logger {
 
 // 定义宏，自动填入文件名和行号
 // 使用spdlog的格式化日志宏
-#define LOG_DEBUG(...) SPDLOG_DEBUG(__VA_ARGS__)
-#define LOG_INFO(...) SPDLOG_INFO(__VA_ARGS__)
-#define LOG_WARN(...) SPDLOG_WARN(__VA_ARGS__)
-#define LOG_ERROR(...) SPDLOG_ERROR(__VA_ARGS__)
+// #define LOG_DEBUG(...) SPDLOG_DEBUG(__VA_ARGS__)
+// #define LOG_INFO(...) SPDLOG_INFO(__VA_ARGS__)
+// #define LOG_WARN(...) SPDLOG_WARN(__VA_ARGS__)
+// #define LOG_ERROR(...) SPDLOG_ERROR(__VA_ARGS__)
 
 #endif  // PHOTONRPC_LOGGER_H

src/core/net/acceptor.cc

@@ -24,31 +24,31 @@ void Acceptor::StartListen() {
 
   this->listenfd_ = socket(PF_INET, SOCK_STREAM, 0);
   if (listenfd_ < 0) {
-    LOG_ERROR("create listen_fd failure");
+    // LOG_ERROR("create listen_fd failure");
     return;
   }
 
   // Enable the bind function to reuse the same port.
   // In some case, the socket haven't been released by the Linux OS, but the server run again.
   int opt = 1;
   if (setsockopt(listenfd_, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)) < 0) {
-    LOG_ERROR("setsockopt failure");
+    // LOG_ERROR("setsockopt failure");
   }
 
   int ret = bind(listenfd_, (struct sockaddr*)&address, sizeof(address));
   if (ret < 0) {
-    LOG_ERROR("bind listen_fd failure, errno = " +
-              std::string(strerror(errno)));
+    // LOG_ERROR("bind listen_fd failure, errno = " +
+    //           std::string(strerror(errno)));
     exit(1);
   }
 
   ret = listen(listenfd_, MAX_LISTEN);
   if (ret < 0) {
-    LOG_ERROR("listen failure");
+    // LOG_ERROR("listen failure");
     return;
   }
 
-  LOG_INFO("Acceptor start listening on {}:{}", ip, port);
+  // LOG_INFO("Acceptor start listening on {}:{}", ip, port);
 
   listen_channel = Channel(listenfd_, true, false);
   listen_channel.set_handle_read([this] {
@@ -57,13 +57,13 @@ void Acceptor::StartListen() {
     int connfd =
         accept(listenfd_, (struct sockaddr*)&client_addr, &client_addr_len);
     if (connfd < 0) {
-      LOG_ERROR("accept failure");
+      // LOG_ERROR("accept failure");
       return;
     }
 
-    LOG_INFO("Acceptor accepted new connection from {}:{}, fd: {}",
-             inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port),
-             connfd);
+    // LOG_INFO("Acceptor accepted new connection from {}:{}, fd: {}",
+    //          inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port),
+    //          connfd);
     this->new_connection_callback_(connfd);
   });
 

src/core/net/event_loop.cc

@@ -22,7 +22,7 @@ EventLoop::EventLoop() : stopped_(false) {
   wakeup_channel->set_handle_read([this] {
     uint64_t one;
     int ret = read(wakeup_fd_, &one, sizeof(one));
-    LOG_INFO("Signal: Stoping Loop");
+    // LOG_INFO("Signal: Stoping Loop");
     stopped_ = true;
   });
 
@@ -34,7 +34,7 @@ EventLoop::EventLoop() : stopped_(false) {
 }
 
 void EventLoop::Loop() {
-  LOG_INFO("EventLoop start looping");
+  // LOG_INFO("EventLoop start looping");
   while (!stopped_) {
     int ret = poller_.poll(-1);
     if (ret < 0) {
@@ -56,7 +56,7 @@ void EventLoop::Loop() {
       }
     }
   }
-  LOG_INFO("EventLoop finish looping");
+  // LOG_INFO("EventLoop finish looping");
 }
 
 void EventLoop::AddChannel(Channel* channel) {

src/core/net/poller.cc

@@ -11,10 +11,10 @@ int Poller::poll(int timeout) {
                        timeout);
   if (ret < 0) {
     if (errno == EINTR) {
-      LOG_DEBUG("poll error: EINTR, continue");
+      // LOG_DEBUG("poll error: EINTR, continue");
       return 0;
     }
-    LOG_ERROR("epoll failure");
+    // LOG_ERROR("epoll failure");
     return -1;
   }
   return ret;

src/core/net/tcp_connection.cc

@@ -39,8 +39,8 @@ void TcpConnection::HandleRead() {
       decoded_data.clear();
     }
   } else {
-    LOG_INFO("TcpConnection(fd:{}) closed",
-             static_cast<int>(channel_.event()->data.fd));
+    // LOG_INFO("TcpConnection(fd:{}) closed",
+    //          static_cast<int>(channel_.event()->data.fd));
     close(channel_.event()->data.fd);
   }
 }

src/core/net/tcp_server.cc

@@ -5,7 +5,7 @@
 void TcpServer::SetUpTcpServer(
     std::function<void(std::string&, std::string&)> service) {
   acceptor_.set_start_listen_callback([this](Channel* channel) {
-    LOG_DEBUG("Acceptor called listen_callback");
+    // LOG_DEBUG("Acceptor called listen_callback");
     event_loop_.AddChannel(channel);
   });
 
@@ -20,7 +20,7 @@ void TcpServer::SetUpTcpServer(
           this->event_loop_.RemoveChannel(channel);
           this->fd_connection_map_.erase(channel->event()->data.fd);
         });
-    LOG_INFO("TcpServer created new TcpConnection for fd: {}", connect_fd);
+    // LOG_INFO("TcpServer created new TcpConnection for fd: {}", connect_fd);
   });
 
   acceptor_.StartListen();

src/core/rpc/rpc_server.cc

@@ -11,7 +11,7 @@ RpcServer::RpcServer() {
 }
 
 void RpcServer::StartServer() {
-  LOG_INFO("RpcServer started");
+  // LOG_INFO("RpcServer started");
   tcp_server_.RunLoop();
 }
 
@@ -23,7 +23,7 @@ void RpcServer::HandleRequest(std::string& request, std::string& response) {
   rpc::RpcMessage request_message;
   request_message.ParseFromString(request);
 
-  LOG_DEBUG("Received request: \n" + request_message.DebugString());
+  // LOG_DEBUG("Received request: \n" + request_message.DebugString());
 
   if (!CheckRequest(request_message)) {
     rpc::RpcMessage response_message;
@@ -52,27 +52,27 @@ void RpcServer::HandleRequest(std::string& request, std::string& response) {
   response_message.set_response(method_response->SerializeAsString());
   response_message.SerializeToString(&response);
 
-  LOG_DEBUG("Send response: \n" + response_message.DebugString());
+  // LOG_DEBUG("Send response: \n" + response_message.DebugString());
 }
 
 bool RpcServer::CheckRequest(rpc::RpcMessage request) {
   if (request.type() != rpc::RPC_TYPE_REQUEST) {
-    LOG_ERROR("Invalid request type: " + std::to_string(request.type()));
+    // LOG_ERROR("Invalid request type: " + std::to_string(request.type()));
     return false;
   }
 
   if (request.method_name().empty()) {
-    LOG_ERROR("Empty method name");
+    // LOG_ERROR("Empty method name");
     return false;
   }
 
   if (request.service_name().empty()) {
-    LOG_ERROR("Empty service name");
+    // LOG_ERROR("Empty service name");
     return false;
   }
 
   if (service_map_.find(request.service_name()) == service_map_.end()) {
-    LOG_ERROR("Service not found: " + request.service_name());
+    // LOG_ERROR("Service not found: " + request.service_name());
     return false;
   }
   auto service = service_map_.find(request.service_name())->second;
@@ -84,12 +84,12 @@ bool RpcServer::CheckRequest(rpc::RpcMessage request) {
   auto service_desc = service->GetDescriptor();
   auto method_desc = service_desc->FindMethodByName(request.method_name());
   if (method_desc == nullptr) {
-    LOG_ERROR("Method not found: " + request.method_name());
+    // LOG_ERROR("Method not found: " + request.method_name());
     return false;
   }
 
   if (request.request().empty()) {
-    LOG_ERROR("Empty request");
+    // LOG_ERROR("Empty request");
     return false;
   }