server/cwzmq.py
changeset 8695 358d8bed9626
parent 8670 f02139297beb
child 8982 6bc1c1b4473a
equal deleted inserted replaced
8694:d901c36bcfce 8695:358d8bed9626
   219         """
   219         """
   220         try:
   220         try:
   221             for cmd in cmds:
   221             for cmd in cmds:
   222                 result = self.process_cmd(cmd)
   222                 result = self.process_cmd(cmd)
   223                 self.send_data(result)
   223                 self.send_data(result)
   224         except Exception, exc:
   224         except Exception as exc:
   225             traceback.print_exc()
   225             traceback.print_exc()
   226             self.send_data(exc)
   226             self.send_data(exc)
   227 
   227 
   228     def send_data(self, data):
   228     def send_data(self, data):
   229         self.socket.send_pyobj(data)
   229         self.socket.send_pyobj(data)
   233         self.info('Quitting ZMQ server')
   233         self.info('Quitting ZMQ server')
   234         try:
   234         try:
   235             self.loop.add_callback(self.loop.stop)
   235             self.loop.add_callback(self.loop.stop)
   236             self.stream.on_recv(None)
   236             self.stream.on_recv(None)
   237             self.stream.close()
   237             self.stream.close()
   238         except Exception, e:
   238         except Exception as e:
   239             print e
   239             print e
   240             pass
   240             pass
   241         if shutdown_repo and not self.repo.shutting_down:
   241         if shutdown_repo and not self.repo.shutting_down:
   242             event = QuitEvent()
   242             event = QuitEvent()
   243             event.fire(self)
   243             event.fire(self)