5.8.6 fix seley ip_manager bug.

Author: Michael-X-Net

code/default/lib/noarch/front_base/http1.py

@@ -162,7 +162,7 @@ def request_task(self, task):
 
             task.set_state("h1_req_sended")
         except Exception as e:
-            self.logger.exception("%s h1_request send:%r inactive_time:%d task.timeout:%d",
+            self.logger.warn("%s h1_request send:%r inactive_time:%d task.timeout:%d",
                              self.ip_str, e, time.time() - self.last_recv_time, task.timeout)
             self.logger.warn('%s trace:%s', self.ip_str, self.get_trace())
 
@@ -176,7 +176,7 @@ def request_task(self, task):
             response.begin(timeout=timeout)
             task.set_state("response_begin")
         except Exception as e:
-            self.logger.exception("%s h1_request recv:%r inactive_time:%d task.timeout:%d",
+            self.logger.warn("%s h1_request recv:%r inactive_time:%d task.timeout:%d",
                              self.ip_str, e, time.time() - self.last_recv_time, task.timeout)
             self.logger.warn('%s trace:%s', self.ip_str, self.get_trace())
 

code/default/lib/noarch/front_base/http_common.py

@@ -199,7 +199,7 @@ def __init__(self, logger, ip_manager, config, ssl_sock, close_cb, retry_task_cb
         self.ssl_sock = ssl_sock
         self.handshake = ssl_sock.handshake_time * 0.001
         self.rtt = ssl_sock.handshake_time * 0.001
-        self.streams = []
+        self.streams = {}
         self.ip_str = ssl_sock.ip_str
         self.close_cb = close_cb
         self.retry_task_cb = retry_task_cb

code/default/version.txt

@@ -1 +1 @@
-5.8.5
+5.8.6

code/default/x_tunnel/local/seley_front/ip_manager.py

@@ -25,10 +25,11 @@ def __str__(self):
         return o
 
     def set_hosts(self, hosts):
-        self.hosts = hosts
         try:
             with open(self.config_fn, "w") as fd:
-                json.dump(self.hosts, fd, indent=2)
+                json.dump(hosts, fd, indent=2)
+
+            self.load()
         except Exception as e:
             xlog.error("save hosts %s e:%r", self.config_fn, e)