disable udp normal

This commit is contained in:
mengskysama 2014-09-30 12:16:45 +08:00
parent bb860bb364
commit 7b0e01722a

View file

@ -48,8 +48,8 @@ class ServerPool(object):
self.mgr = asyncmgr.ServerMgr() self.mgr = asyncmgr.ServerMgr()
self.tcp_servers_pool = {} self.tcp_servers_pool = {}
self.tcp_ipv6_servers_pool = {} self.tcp_ipv6_servers_pool = {}
self.udp_servers_pool = {} #self.udp_servers_pool = {}
self.udp_ipv6_servers_pool = {} #self.udp_ipv6_servers_pool = {}
self.loop = eventloop.EventLoop() self.loop = eventloop.EventLoop()
thread.start_new_thread(ServerPool._loop, (self.loop, self.dns_resolver, self.mgr)) thread.start_new_thread(ServerPool._loop, (self.loop, self.dns_resolver, self.mgr))
@ -107,9 +107,9 @@ class ServerPool(object):
tcp_server = tcprelay.TCPRelay(a_config, self.dns_resolver, False) tcp_server = tcprelay.TCPRelay(a_config, self.dns_resolver, False)
tcp_server.add_to_loop(self.loop) tcp_server.add_to_loop(self.loop)
self.tcp_servers_pool.update({port: tcp_server}) self.tcp_servers_pool.update({port: tcp_server})
udp_server = udprelay.UDPRelay(a_config, self.dns_resolver, False) #udp_server = udprelay.UDPRelay(a_config, self.dns_resolver, False)
udp_server.add_to_loop(self.loop) #udp_server.add_to_loop(self.loop)
self.udp_servers_pool.update({port: udp_server}) #self.udp_servers_pool.update({port: udp_server})
except Exception, e: except Exception, e:
logging.warn(e) logging.warn(e)
@ -127,9 +127,9 @@ class ServerPool(object):
tcp_server = tcprelay.TCPRelay(a_config, self.dns_resolver, False) tcp_server = tcprelay.TCPRelay(a_config, self.dns_resolver, False)
tcp_server.add_to_loop(self.loop) tcp_server.add_to_loop(self.loop)
self.tcp_ipv6_servers_pool.update({port: tcp_server}) self.tcp_ipv6_servers_pool.update({port: tcp_server})
udp_server = udprelay.UDPRelay(a_config, self.dns_resolver, False) #udp_server = udprelay.UDPRelay(a_config, self.dns_resolver, False)
udp_server.add_to_loop(self.loop) #udp_server.add_to_loop(self.loop)
self.udp_ipv6_servers_pool.update({port: udp_server}) #self.udp_ipv6_servers_pool.update({port: udp_server})
except Exception, e: except Exception, e:
logging.warn(e) logging.warn(e)
return True return True
@ -155,8 +155,8 @@ class ServerPool(object):
try: try:
self.tcp_servers_pool[port].destroy() self.tcp_servers_pool[port].destroy()
del self.tcp_servers_pool[port] del self.tcp_servers_pool[port]
self.udp_servers_pool[port].destroy() #self.udp_servers_pool[port].destroy()
del self.udp_servers_pool[port] #del self.udp_servers_pool[port]
except Exception, e: except Exception, e:
logging.warn(e) logging.warn(e)
@ -167,8 +167,8 @@ class ServerPool(object):
try: try:
self.tcp_ipv6_servers_pool[port].destroy() self.tcp_ipv6_servers_pool[port].destroy()
del self.tcp_ipv6_servers_pool[port] del self.tcp_ipv6_servers_pool[port]
self.udp_ipv6_servers_pool[port].destroy() #self.udp_ipv6_servers_pool[port].destroy()
del self.udp_ipv6_servers_pool[port] #del self.udp_ipv6_servers_pool[port]
except Exception, e: except Exception, e:
logging.warn(e) logging.warn(e)