Lines Matching refs:wr
55 rd, wr = socketpair()
57 self.addCleanup(wr.close)
58 return rd, wr
64 rd, wr = self.make_socketpair()
90 rd, wr = self.make_socketpair()
104 rd, wr = self.make_socketpair()
105 r, w = rd.fileno(), wr.fileno()
109 wr.close()
117 rd, wr = self.make_socketpair()
118 r, w = rd.fileno(), wr.fileno()
123 wr.close()
134 rd, wr = self.make_socketpair()
136 s.register(wr, selectors.EVENT_WRITE)
138 wr.close()
140 s.unregister(wr)
146 rd, wr = self.make_socketpair()
200 rd, wr = self.make_socketpair()
212 rd, wr = self.make_socketpair()
215 s.register(wr, selectors.EVENT_WRITE)
219 self.assertRaises(RuntimeError, s.get_key, wr)
221 self.assertRaises(KeyError, mapping.__getitem__, wr)
227 rd, wr = self.make_socketpair()
239 rd, wr = self.make_socketpair()
264 rd, wr = self.make_socketpair()
267 wr_key = s.register(wr, selectors.EVENT_WRITE)
282 rd, wr = self.make_socketpair()
286 sel.register(wr, selectors.EVENT_WRITE)
289 self.assertRaises(RuntimeError, s.get_key, wr)
313 rd, wr = self.make_socketpair()
315 s.register(wr, selectors.EVENT_WRITE)
317 writers.append(wr)
318 r2w[rd] = wr
319 w2r[wr] = rd
328 wr = random.choice(ready_writers)
329 wr.send(MSG)
342 self.assertEqual([w2r[wr]], ready_readers)
366 rd, wr = self.make_socketpair()
368 s.register(wr, selectors.EVENT_WRITE)
374 s.unregister(wr)
394 rd, wr = self.make_socketpair()
424 rd, wr = self.make_socketpair()
469 rd, wr = self.make_socketpair()
478 s.register(wr, selectors.EVENT_WRITE)