@@ -661,8 +661,6 @@ def __init__(self, serialno="MOCK12345678", version=15, startviewserver=False, u
661661 print >> sys.stderr, "\n**** Starting ViewServer... ****", self
662662 self.viewServer = MockViewServer()
663663 else:
664- if DEBUG:
665- print >> sys.stderr, "\n**** Not Starting ViewServer... ****"
666664 self.viewServer = None
667665 self.uiAutomatorKilled = uiautomatorkilled
668666 self.language = language
@@ -767,12 +765,16 @@ def run(self):
767765 print >> sys.stderr, "ServerThread: serving running=", self.running
768766 # In 2.5 serve_forever() never exits and there's no way of stopping the server
769767 #self.server.serve_forever(self.pollInterval)
770- # while self.running:
771- # if DEBUG:
772- # print >> sys.stderr, "ServerThread: polling (self=%s)" % self
773- # r, w, e = select([self.server], [], [], self.pollInterval)
774- # if r:
775- # self.server.handle_request()
768+ while self.running:
769+ if DEBUG:
770+ print >> sys.stderr, "ServerThread: polling (self=%s)" % self
771+ r, w, e = select.select([self.server], [], [], self.pollInterval)
772+ if r:
773+ if self.server:
774+ try:
775+ self.server.handle_request()
776+ except:
777+ print >> sys.stderr, "ServerThread: the socket may have been closed"
776778
777779
778780 def __init__(self, host=HOST, port=PORT):
@@ -784,30 +786,30 @@ def __init__(self, host=HOST, port=PORT):
784786 self.host = host
785787 self.port = port
786788 # In 2.5 serve_forever() never exits and there's no way of stopping the server
787- self.server.serve_forever(1)
788-
789+ # self.server.serve_forever(1)
790+ #print >> sys.stderr, "MockViewServer: NEVER REACHED on Linux"
789791 # Activate the server; this will keep running until you shutdown
790- # self.serverThread = MockViewServer.ServerThread(self.server)
791- # self.serverThread.start()
792+ self.serverThread = MockViewServer.ServerThread(self.server)
793+ self.serverThread.start()
792794
793795 def shutdown(self):
794796 if DEBUG:
795797 print >> sys.stderr, "**** MockViewServer.shutdown() ****"
796798 try:
797- # self.server.socket.shutdown(socket.SHUT_RDWR)
798- if DEBUG:
799- print >> sys.stderr, " shutdown: shutting down the server, serve_forever() should exit"
800- self.server.shutdown()
799+ self.server.socket.shutdown(socket.SHUT_RDWR)
800+ # if DEBUG:
801+ # print >> sys.stderr, " shutdown: shutting down the server, serve_forever() should exit"
802+ # self.server.shutdown()
801803 if DEBUG:
802804 print >> sys.stderr, " shutdown: DONE"
803805 except Exception, ex:
804806 print >> sys.stderr, "ERROR", ex
805807 pass
806808 self.serverThread.running = False
807- # #self.server.socket.shutdown(socket.SHUT_RDWR)
808- # self.server.socket.close()
809+ #self.server.socket.shutdown(socket.SHUT_RDWR)
810+ self.server.socket.close()
809811# del(self.server.socket)
810812 #del(self.server)
811- # time.sleep(120)
812- # time.sleep(5)
813+ time.sleep(120)
814+ time.sleep(5)
813815
0 commit comments