xuemingqiang/shadowsocks
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add connect

Browse Source
This commit is contained in:
clowwindy
2014-04-24 00:10:45 +08:00
parent 10c73e555a
commit 6e50890f4f
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
shadowsocks/udprelay.py
View File

@ -183,6 +183,8 @@ class UDPRelay(object):
data = encrypt.encrypt_all(self._password, self._method, 1, data) data = encrypt.encrypt_all(self._password, self._method, 1, data)
if not data: if not data:
return return
# prevent from recv other sources
client.connect((server_addr, server_port))
client.sendto(data, (server_addr, server_port)) client.sendto(data, (server_addr, server_port))
def _handle_client(self, sock): def _handle_client(self, sock):
@ -212,10 +214,9 @@ class UDPRelay(object):
if client_addr: if client_addr:
self._server_socket.sendto(response, client_addr) self._server_socket.sendto(response, client_addr)
else: else:
# this packet is from somewhere else we know
# simply drop that packet
pass pass
# self._eventloop.remove(sock)
# sock.close()
# TODO remove it from cache else we can't close it
def _run(self): def _run(self):
server_socket = self._server_socket server_socket = self._server_socket