Add DNS resolution log

trojan-gfw · Sep 30, 2019 · 967bcb4 · 967bcb4
1 parent 33b6b6b
commit 967bcb4
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 0 deletions.
diff --git a/src/session/clientsession.cpp b/src/session/clientsession.cpp
@@ -229,6 +229,7 @@ void ClientSession::in_sent() {
                     return;
                 }
                 auto iterator = results.begin();
+                Log::log_with_endpoint(in_endpoint, config.remote_addr + " is resolved to " + iterator->endpoint().address().to_string(), Log::ALL);
                 boost::system::error_code ec;
                 out_socket.next_layer().open(iterator->endpoint().protocol(), ec);
                 if (ec) {

diff --git a/src/session/forwardsession.cpp b/src/session/forwardsession.cpp
@@ -64,6 +64,7 @@ void ForwardSession::start() {
             return;
         }
         auto iterator = results.begin();
+        Log::log_with_endpoint(in_endpoint, config.remote_addr + " is resolved to " + iterator->endpoint().address().to_string(), Log::ALL);
         boost::system::error_code ec;
         out_socket.next_layer().open(iterator->endpoint().protocol(), ec);
         if (ec) {

diff --git a/src/session/natsession.cpp b/src/session/natsession.cpp
@@ -112,6 +112,7 @@ void NATSession::start() {
             return;
         }
         auto iterator = results.begin();
+        Log::log_with_endpoint(in_endpoint, config.remote_addr + " is resolved to " + iterator->endpoint().address().to_string(), Log::ALL);
         boost::system::error_code ec;
         out_socket.next_layer().open(iterator->endpoint().protocol(), ec);
         if (ec) {

diff --git a/src/session/serversession.cpp b/src/session/serversession.cpp
@@ -187,6 +187,7 @@ void ServerSession::in_recv(const string &data) {
                     }
                 }
             }
+            Log::log_with_endpoint(in_endpoint, query_addr + " is resolved to " + iterator->endpoint().address().to_string(), Log::ALL);
             boost::system::error_code ec;
             out_socket.open(iterator->endpoint().protocol(), ec);
             if (ec) {
@@ -294,6 +295,7 @@ void ServerSession::udp_sent() {
                     }
                 }
             }
+            Log::log_with_endpoint(in_endpoint, query_addr + " is resolved to " + iterator->endpoint().address().to_string(), Log::ALL);
             if (!udp_socket.is_open()) {
                 auto protocol = iterator->endpoint().protocol();
                 boost::system::error_code ec;

diff --git a/src/session/udpforwardsession.cpp b/src/session/udpforwardsession.cpp
@@ -63,6 +63,7 @@ void UDPForwardSession::start() {
             return;
         }
         auto iterator = results.begin();
+        Log::log_with_endpoint(in_endpoint, config.remote_addr + " is resolved to " + iterator->endpoint().address().to_string(), Log::ALL);
         boost::system::error_code ec;
         out_socket.next_layer().open(iterator->endpoint().protocol(), ec);
         if (ec) {