import traceback
from tornado import stack_context
+from tornado.escape import utf8
try:
import signal
def _wake(self):
try:
- self._waker_writer.write("x")
+ self._waker_writer.write(utf8("x"))
except IOError:
pass
def _read_waker(self, fd, events):
try:
while True:
- self._waker_reader.read()
+ result = self._waker_reader.read()
+ if not result: break
except IOError:
pass
self.deadline = deadline
self.callback = callback
- def __cmp__(self, other):
- return cmp((self.deadline, id(self.callback)),
- (other.deadline, id(other.callback)))
+ def __lt__(self, other):
+ return ((self.deadline, id(self.callback)) <
+ (other.deadline, id(other.callback)))
class PeriodicCallback(object):