vbatts/shadowsocks
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

implement send_all myself

Browse source
This commit is contained in:
clowwindy 2012-12-30 14:12:15 +08:00
parent 65444c5b06
commit 004e9292f4
2 changed files with 23 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
local.py
View file

@ -50,6 +50,15 @@ def get_table(key):
table.sort(lambda x, y: int(a % (ord(x) + i) - a % (ord(y) + i)))
return table
def send_all(sock, data):
bytes_sent = 0
while True:
r = sock.send(data[bytes_sent:])
if r < 0:
return r
bytes_sent += r
if bytes_sent == len(data):
return bytes_sent
class ThreadingTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
allow_reuse_address = True
@ -65,13 +74,13 @@ class Socks5Server(SocketServer.StreamRequestHandler):
data = sock.recv(4096)
if data <= 0:
break
remote.sendall(self.encrypt(data))
send_all(remote, self.encrypt(data))
if remote in r:
data = remote.recv(4096)
if data <= 0:
break
sock.sendall(self.decrypt(data))
send_all(sock, self.decrypt(data))
finally:
sock.close()
remote.close()

14
server.py
View file

@ -50,6 +50,16 @@ def get_table(key):
table.sort(lambda x, y: int(a % (ord(x) + i) - a % (ord(y) + i)))
return table
def send_all(sock, data):
bytes_sent = 0
while True:
r = sock.send(data[bytes_sent:])
if r < 0:
return r
bytes_sent += r
if bytes_sent == len(data):
return bytes_sent
class ThreadingTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
allow_reuse_address = True
@ -65,12 +75,12 @@ class Socks5Server(SocketServer.StreamRequestHandler):
data = sock.recv(4096)
if data <= 0:
break
remote.sendall(self.decrypt(data))
send_all(remote, self.decrypt(data))
if remote in r:
data = remote.recv(4096)
if data <= 0:
break
sock.send(self.encrypt(data))
send_all(sock, self.encrypt(data))
finally:
sock.close()
remote.close()