yumoqing/apppublic
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2020-07-12 10:28:57 +08:00
parent 531851ac34
commit 2e4d4abb29
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
appPublic/sockPackage.py
View File

@ -3,10 +3,6 @@ import time
import threading import threading
import sys import sys
import socket import socket
from mylog import mylog
def logit(s) :
mylog(__file__ + ':' + s)
def get_free_local_addr(): def get_free_local_addr():
with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s: with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s:
@ -56,7 +52,7 @@ class SocketServer(threading.Thread) :
self.sock.listen(self.max_c) self.sock.listen(self.max_c)
self.ready = True self.ready = True
except Exception as e: except Exception as e:
logit('setSocketServer() Error:%s\nhost=%s,port=%d' % (e,self.host,self.port)) print('setSocketServer() Error:%s\nhost=%s,port=%d' % (e,self.host,self.port))
pass pass
def run(self) : def run(self) :
@ -104,7 +100,7 @@ class SocketClient :
self.ready = True self.ready = True
except Exception as e: except Exception as e:
self.ready = False self.ready = False
logit('Socket connect error,%s\nhost=%s,port=%s' % (e,self.host,self.port)) print('Socket connect error,%s\nhost=%s,port=%s' % (e,self.host,self.port))
raise SocketClientError('connect error') raise SocketClientError('connect error')
def read(self,size) : def read(self,size) :
@ -112,14 +108,14 @@ class SocketClient :
data = self.sock.recv(size) data = self.sock.recv(size)
return data return data
except Exception as e: except Exception as e:
logit('recv error,%s' % e) print('recv error,%s' % e)
raise SocketClientError('recv error') raise SocketClientError('recv error')
def write(self,data) : def write(self,data) :
try : try :
self.sock.send(data) self.sock.send(data)
except Exception as e: except Exception as e:
logit('recv error,%s' % e) print('recv error,%s' % e)
raise SocketClientError('send error') raise SocketClientError('send error')
def close(self) : def close(self) :