Commitfb0b823

committed

don't crash on interrupts: catch the interrupt and continue the handling loop

1 parentb4825a6 commitfb0b823Copy full SHA for fb0b823

File tree

-1

lines changed

-1

lines changed

Lines changed: 8 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -4,6 +4,7 @@`
`4`	`4`	`# information.`
`5`	`5`
`6`	`6`	`importthreading`
	`7`	`+importerrno`
`7`	`8`
`8`	`9`	`importzmq`
`9`	`10`
`@@ -39,7 +40,13 @@ def stop(self):`
`39`	`40`	`defrun(self):`
`40`	`41`	`self.logger.info("^_^ Server now listening on %s",self.endpoint)`
`41`	`42`	`whilenotself.should_stop:`
`42`		`-self._handle_one_message()`
	`43`	`+try:`
	`44`	`+self._handle_one_message()`
	`45`	`+exceptzmq.ZMQErrorase:`
	`46`	`+ife.errno==errno.EINTR:`
	`47`	`+continue`
	`48`	`+else:`
	`49`	`+raise`
`43`	`50`
`44`	`51`	`def_handle_one_message(self):`
`45`	`52`	`req=client_id=None`

Comments

(0)