cubetiq/pyztk
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

fix udp bulk mode

Browse Source
This commit is contained in:
Arturo Hernandez 2018-05-07 19:48:19 -04:00
parent 50003aa9cf
commit 32da02f6fe
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
zk/base.py
View File

@ -432,7 +432,8 @@ class ZK(object):
device = self.__data.split(b'=')[-1].split(b'\x00')[0] device = self.__data.split(b'=')[-1].split(b'\x00')[0]
return device.decode() return device.decode()
else: else:
raise ZKErrorResponse("can't read device name") return "" #no name
#raise ZKErrorResponse("can't read device name")
def get_face_version(self): def get_face_version(self):
''' '''
@ -1327,7 +1328,7 @@ class ZK(object):
#could be broken #could be broken
if len(data_recv) < 16: if len(data_recv) < 16:
print ("trying to complete broken ACK") print ("trying to complete broken ACK")
data_recv += self.__sock.recv(16 - len(data_recv)) data_recv += self.__sock.recv(16 - len(data_recv)) #TODO: CHECK HERE_!
if not self.__test_tcp_top(data_recv): if not self.__test_tcp_top(data_recv):
if self.verbose: print ("invalid tcp ACK OK") if self.verbose: print ("invalid tcp ACK OK")
return None #b''.join(data) # incomplete? return None #b''.join(data) # incomplete?
@ -1340,7 +1341,7 @@ class ZK(object):
return None return None
#else udp #else udp
while True: #limitado por respuesta no por tamaño while True: #limitado por respuesta no por tamaño
data_recv = self.__sock.recv(response_size) data_recv = self.__sock.recv(1024+8)
response = unpack('HHHH', data_recv[:8])[0] response = unpack('HHHH', data_recv[:8])[0]
if self.verbose: print ("# packet response is: {}".format(response)) if self.verbose: print ("# packet response is: {}".format(response))
if response == const.CMD_DATA: if response == const.CMD_DATA: