and times out eventually.'''
bob = MockBobSimple()
bob.c_channel_env = {}
- # keep the timeout small for the test to complete quickly
+ # set the timeout to an arbitrary pre-determined value (which
+ # code below depends on)
bob.msgq_timeout = 1
bob._run_under_unittests = False
# out.
pi = bob.start_msgq()
- # 1 second of attempts every 0.1 seconds should result in 10
- # attempts. 1 attempt happens at the start. 2 more attempts seem
- # to happen inside start_msgq().
+ # time.time() should be called 12 times within the while loop:
+ # starting from 0, and 11 more times from 0.1 to 1.1. There's
+ # another call to time.time() outside the loop, which makes it
+ # 13.
self.assertEqual(attempts, 13)
# group_subscribe() should not have been called here.
bob = MockBobSimple()
bob.c_channel_env = {}
bob.cc_session = DummySession()
- # keep the wait time small for the test to complete quickly
+ # set wait_time to an arbitrary pre-determined value (which code
+ # below depends on)
bob.wait_time = 2
# use the MockProcessInfo creator
if flags != socket.MSG_DONTWAIT:
raise Exception('flags != socket.MSG_DONTWAIT')
# after 15 recv()s, throw a socket.error with EAGAIN to
- # get _socket_data() to save back what's been read.
+ # get _socket_data() to save back what's been read. The
+ # number 15 is arbitrarily chosen, but the checks then
+ # depend on this being 15, i.e., if you adjust this
+ # number, you may have to adjust the checks below too.
if self.throw and self.i > 15:
raise socket.error(errno.EAGAIN, 'Try again')
if self.i >= len(self.buf):