equal
deleted
inserted
replaced
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) |