StacklessSocketServer.py (702B)
1 #Embedded file name: C:\BuildAgent\work\20d73f1b24eed06e\eve\release\V24.01\carbon\common\script\net\StacklessSocketServer.py 2 import SocketServer 3 import uthread 4 5 class UThreadingMixIn: 6 7 def process_request_tasklet(self, request, client_address): 8 try: 9 self.finish_request(request, client_address) 10 self.close_request(request) 11 except: 12 self.handle_error(request, client_address) 13 self.close_request(request) 14 15 def process_request(self, request, client_address): 16 t = uthread.new(self.process_request_tasklet, request, client_address) 17 t.run() 18 19 20 class UThreadingTCPServer(UThreadingMixIn, SocketServer.TCPServer): 21 pass