@@ -186,14 +186,14 @@ def run(config):
186
186
def test ():
187
187
import time
188
188
import threading
189
- import os
190
189
import struct
191
190
from shadowsocks import encrypt
192
191
193
- logging .basicConfig (level = logging . DEBUG ,
192
+ logging .basicConfig (level = 5 ,
194
193
format = '%(asctime)s %(levelname)-8s %(message)s' ,
195
194
datefmt = '%Y-%m-%d %H:%M:%S' )
196
195
enc = []
196
+ eventloop .TIMEOUT_PRECISION = 1
197
197
198
198
def run_server ():
199
199
config = {
@@ -213,8 +213,9 @@ def run_server():
213
213
enc .append (manager )
214
214
manager .run ()
215
215
216
- threading .Thread (target = run_server ).start ()
217
- time .sleep (2 )
216
+ t = threading .Thread (target = run_server )
217
+ t .start ()
218
+ time .sleep (1 )
218
219
manager = enc [0 ]
219
220
cli = socket .socket (socket .AF_INET , socket .SOCK_DGRAM )
220
221
cli .connect (('127.0.0.1' , 6001 ))
@@ -236,9 +237,8 @@ def run_server():
236
237
tcp_cli = socket .socket ()
237
238
tcp_cli .connect (('127.0.0.1' , 7001 ))
238
239
tcp_cli .send (data )
239
- rdata = tcp_cli .recv (4096 )
240
+ tcp_cli .recv (4096 )
240
241
tcp_cli .close ()
241
- rdata = encrypt .encrypt_all (b'1234' , 'aes-256-cfb' , 0 , rdata )
242
242
243
243
data , addr = cli .recvfrom (1506 )
244
244
data = common .to_str (data )
@@ -264,7 +264,8 @@ def run_server():
264
264
assert '8382' in stats
265
265
logging .info ('UDP statistics test passed' )
266
266
267
- os ._exit (0 )
267
+ manager ._loop .stop ()
268
+ t .join ()
268
269
269
270
270
271
if __name__ == '__main__' :
0 commit comments