Lines Matching refs:wr
59 rd, wr = socketpair()
61 self.addCleanup(wr.close)
62 return rd, wr
68 rd, wr = self.make_socketpair()
94 rd, wr = self.make_socketpair()
108 rd, wr = self.make_socketpair()
109 r, w = rd.fileno(), wr.fileno()
113 wr.close()
121 rd, wr = self.make_socketpair()
122 r, w = rd.fileno(), wr.fileno()
127 wr.close()
138 rd, wr = self.make_socketpair()
140 s.register(wr, selectors.EVENT_WRITE)
142 wr.close()
144 s.unregister(wr)
150 rd, wr = self.make_socketpair()
204 rd, wr = self.make_socketpair()
216 rd, wr = self.make_socketpair()
219 s.register(wr, selectors.EVENT_WRITE)
223 self.assertRaises(RuntimeError, s.get_key, wr)
225 self.assertRaises(KeyError, mapping.__getitem__, wr)
231 rd, wr = self.make_socketpair()
243 rd, wr = self.make_socketpair()
268 rd, wr = self.make_socketpair()
271 wr_key = s.register(wr, selectors.EVENT_WRITE)
286 rd, wr = self.make_socketpair()
290 sel.register(wr, selectors.EVENT_WRITE)
293 self.assertRaises(RuntimeError, s.get_key, wr)
317 rd, wr = self.make_socketpair()
319 s.register(wr, selectors.EVENT_WRITE)
321 writers.append(wr)
322 r2w[rd] = wr
323 w2r[wr] = rd
332 wr = random.choice(ready_writers)
333 wr.send(MSG)
346 self.assertEqual([w2r[wr]], ready_readers)
370 rd, wr = self.make_socketpair()
372 s.register(wr, selectors.EVENT_WRITE)
378 s.unregister(wr)
398 rd, wr = self.make_socketpair()
428 rd, wr = self.make_socketpair()
473 rd, wr = self.make_socketpair()
482 s.register(wr, selectors.EVENT_WRITE)