Lines Matching refs:rd
59 rd, wr = socketpair()
60 self.addCleanup(rd.close)
62 return rd, wr
68 rd, wr = self.make_socketpair()
70 key = s.register(rd, selectors.EVENT_READ, "data")
72 self.assertEqual(key.fileobj, rd)
73 self.assertEqual(key.fd, rd.fileno())
84 self.assertRaises(KeyError, s.register, rd, selectors.EVENT_READ)
87 self.assertRaises(KeyError, s.register, rd.fileno(),
94 rd, wr = self.make_socketpair()
96 s.register(rd, selectors.EVENT_READ)
97 s.unregister(rd)
103 self.assertRaises(KeyError, s.unregister, rd)
108 rd, wr = self.make_socketpair()
109 r, w = rd.fileno(), wr.fileno()
112 rd.close()
121 rd, wr = self.make_socketpair()
122 r, w = rd.fileno(), wr.fileno()
126 rd.close()
138 rd, wr = self.make_socketpair()
139 s.register(rd, selectors.EVENT_READ)
141 rd.close()
143 s.unregister(rd)
150 rd, wr = self.make_socketpair()
152 key = s.register(rd, selectors.EVENT_READ)
155 key2 = s.modify(rd, selectors.EVENT_WRITE)
157 self.assertEqual(key2, s.get_key(rd))
159 s.unregister(rd)
165 key = s.register(rd, selectors.EVENT_READ, d1)
166 key2 = s.modify(rd, selectors.EVENT_READ, d2)
169 self.assertEqual(key2, s.get_key(rd))
180 s.modify(rd, selectors.EVENT_READ, d3)
204 rd, wr = self.make_socketpair()
205 s.register(rd, selectors.EVENT_READ)
208 s.modify(rd, selectors.EVENT_WRITE)
216 rd, wr = self.make_socketpair()
218 s.register(rd, selectors.EVENT_READ)
222 self.assertRaises(RuntimeError, s.get_key, rd)
224 self.assertRaises(KeyError, mapping.__getitem__, rd)
231 rd, wr = self.make_socketpair()
233 key = s.register(rd, selectors.EVENT_READ, "data")
234 self.assertEqual(key, s.get_key(rd))
243 rd, wr = self.make_socketpair()
249 key = s.register(rd, selectors.EVENT_READ, "data")
250 self.assertIn(rd, keys)
251 self.assertEqual(key, keys[rd])
253 self.assertEqual(list(keys), [rd.fileno()])
262 del keys[rd]
268 rd, wr = self.make_socketpair()
270 s.register(rd, selectors.EVENT_READ)
286 rd, wr = self.make_socketpair()
289 sel.register(rd, selectors.EVENT_READ)
292 self.assertRaises(RuntimeError, s.get_key, rd)
317 rd, wr = self.make_socketpair()
318 s.register(rd, selectors.EVENT_READ)
320 readers.append(rd)
322 r2w[rd] = wr
323 w2r[wr] = rd
347 rd = ready_readers[0]
348 buf = rd.recv(MSG_LEN)
351 s.unregister(r2w[rd])
352 s.unregister(rd)
353 writers.remove(r2w[rd])
370 rd, wr = self.make_socketpair()
379 s.register(rd, selectors.EVENT_READ)
398 rd, wr = self.make_socketpair()
412 s.register(rd, selectors.EVENT_READ)
428 rd, wr = self.make_socketpair()
436 s.register(rd, selectors.EVENT_READ)
473 rd, wr = self.make_socketpair()
481 s.register(rd, selectors.EVENT_READ)