check duplicate port

2015-10-21 14:53:14 +08:00
parent eec312cc4c
commit 79260ff4ab
1 changed files with 6 additions and 1 deletions
@@ -116,7 +116,12 @@ class DbTransfer(object):

 			port = row['port']
 			passwd = row['passwd']
-			cur_servers[port] = passwd
+
+			if port not in cur_servers:
+				cur_servers[port] = passwd
+			else:
+				logging.error('more than one user use the same port [%s]' % (port,))
+				continue

 			if ServerPool.get_instance().server_is_run(port) > 0:
 				if not allow: