2626
2727from com .dtmilano .android .adb .dumpsys import Dumpsys
2828
29- __version__ = '20.0.0 '
29+ __version__ = '20.0.0b1 '
3030
3131import sys
3232import warnings
@@ -314,7 +314,7 @@ def __send(self, msg, checkok=True, reconnect=False):
314314
315315 def __receive (self , nob = None , sock = None ):
316316 if DEBUG :
317- print ("__receive(nob=%s)" % nob , file = sys .stderr )
317+ print ("🟨 __receive(nob=%s)" % nob , file = sys .stderr )
318318 if not sock :
319319 sock = self .socket
320320 self .checkConnected (sock )
@@ -323,23 +323,25 @@ def __receive(self, nob=None, sock=None):
323323 if nob is None :
324324 nob = int (sock .recv (4 ), 16 )
325325 if DEBUG :
326- print (" __receive: receiving" , nob , "bytes" , file = sys .stderr )
326+ print ("🟨 __receive: receiving" , nob , "bytes" , file = sys .stderr )
327327 recv = bytearray (nob )
328- view = memoryview (recv )
328+ mview = memoryview (recv )
329329 nr = 0
330330 while nr < nob :
331- l = sock .recv_into (view , len (view ))
331+ l = sock .recv_into (mview , len (mview ))
332332 if DEBUG :
333- print ("l=" , l , "nr=" , nr , file = sys .stderr )
334- print ("timer=" , self .timers [timerId ], file = sys .stderr )
335- view = view [l :]
333+ print ("🟨 __receive: recv_into(mview, %d):" % len (mview ), file = sys .stderr )
334+ print ("🟨 __receive: l=" , l , "nr=" , nr , file = sys .stderr )
335+ print ("🟨 __receive: timer=" , self .timers [timerId ], file = sys .stderr )
336+ mview = mview [l :]
336337 nr += l
337338 if self .timers [timerId ] == 'EXPIRED' :
338339 raise Timer .TimeoutException ('%d EXPIRED' % timerId )
339340 finally :
340341 self .cancelTimer (timerId )
341342 if DEBUG :
342- print (" __receive: returning len=" , len (recv ), file = sys .stderr )
343+ print ("🟨 __receive: returning len=" , len (recv ), file = sys .stderr )
344+ print ("🟨 __receive: '%s'" % repr (recv ), file = sys .stderr )
343345 return recv
344346
345347 def __checkOk (self , sock = None ):
@@ -356,7 +358,7 @@ def __checkOk(self, sock=None):
356358 self .cancelTimer (timerId )
357359
358360 if DEBUG :
359- print (" __checkOk: recv=" , repr (recv ), file = sys .stderr )
361+ print (" __checkOk: recv(4) =" , repr (recv ), file = sys .stderr )
360362
361363 timerId = self .setTimer (timeout = self .timeout , description = "checkOK" )
362364 try :
@@ -527,6 +529,7 @@ def shell(self, _cmd=None, _convertOutputToString=True):
527529 chunk = None
528530 try :
529531 chunk = self .socket .recv (4096 )
532+ print ('🟣 chunk=%s' % chunk )
530533 except Exception as ex :
531534 print ("ERROR:" , ex , file = sys .stderr )
532535 if not chunk :
0 commit comments