From 86aa16574e055ab3ee26060c50e638b0c977d04f Mon Sep 17 00:00:00 2001
From: wuaho <wuaho@legu.cc>
Date: Sat, 14 Aug 2021 11:19:50 +0800
Subject: [PATCH] 1

---
 v2/transmitter.py | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/v2/transmitter.py b/v2/transmitter.py
index e76a7a4..226d85e 100644
--- a/v2/transmitter.py
+++ b/v2/transmitter.py
@@ -11,13 +11,14 @@ __all__ = 'Transmitter',
 
 
 class Ping(threading.Thread):
-    def __init__(self, db_client, log):
+    def __init__(self, db_client, p, log):
         threading.Thread.__init__(self)
         self.daemon = True
         self.ping_ts = 0
         self.time_out = 60
         self.log = log
         self.db_client = db_client
+        self.p = p
 
     def run(self):
         while True:
@@ -26,7 +27,7 @@ class Ping(threading.Thread):
                 # 保持连接
                 try:
                     self.ping_ts = ts
-                    self.log.info('保持连接 ping')
+                    self.log.info(f'保持连接{self.p} ping')
                     self.db_client.execute('select 1')
                 except:
                     self.log.error('ping error')
@@ -44,7 +45,7 @@ class Transmitter:
         self.p = p
 
     def start_ping(self):
-        t = Ping(self.db_client, self.log)
+        t = Ping(self.db_client, self.p, self.log)
         t.start()
 
     def add_source(self, handler, bulk_max=1000, time_out=60):