Lines Matching refs:wr
53 rd, wr = socketpair()
55 self.addCleanup(wr.close)
56 return rd, wr
62 rd, wr = self.make_socketpair()
88 rd, wr = self.make_socketpair()
102 rd, wr = self.make_socketpair()
103 r, w = rd.fileno(), wr.fileno()
107 wr.close()
115 rd, wr = self.make_socketpair()
116 r, w = rd.fileno(), wr.fileno()
121 wr.close()
132 rd, wr = self.make_socketpair()
134 s.register(wr, selectors.EVENT_WRITE)
136 wr.close()
138 s.unregister(wr)
144 rd, wr = self.make_socketpair()
198 rd, wr = self.make_socketpair()
210 rd, wr = self.make_socketpair()
213 s.register(wr, selectors.EVENT_WRITE)
217 self.assertRaises(RuntimeError, s.get_key, wr)
219 self.assertRaises(KeyError, mapping.__getitem__, wr)
225 rd, wr = self.make_socketpair()
237 rd, wr = self.make_socketpair()
262 rd, wr = self.make_socketpair()
265 wr_key = s.register(wr, selectors.EVENT_WRITE)
280 rd, wr = self.make_socketpair()
284 sel.register(wr, selectors.EVENT_WRITE)
287 self.assertRaises(RuntimeError, s.get_key, wr)
311 rd, wr = self.make_socketpair()
313 s.register(wr, selectors.EVENT_WRITE)
315 writers.append(wr)
316 r2w[rd] = wr
317 w2r[wr] = rd
326 wr = random.choice(ready_writers)
327 wr.send(MSG)
340 self.assertEqual([w2r[wr]], ready_readers)
364 rd, wr = self.make_socketpair()
366 s.register(wr, selectors.EVENT_WRITE)
372 s.unregister(wr)
392 rd, wr = self.make_socketpair()
422 rd, wr = self.make_socketpair()
467 rd, wr = self.make_socketpair()
476 s.register(wr, selectors.EVENT_WRITE)