Lines Matching refs:rd
53 rd, wr = socketpair()
54 self.addCleanup(rd.close)
56 return rd, wr
62 rd, wr = self.make_socketpair()
64 key = s.register(rd, selectors.EVENT_READ, "data")
66 self.assertEqual(key.fileobj, rd)
67 self.assertEqual(key.fd, rd.fileno())
78 self.assertRaises(KeyError, s.register, rd, selectors.EVENT_READ)
81 self.assertRaises(KeyError, s.register, rd.fileno(),
88 rd, wr = self.make_socketpair()
90 s.register(rd, selectors.EVENT_READ)
91 s.unregister(rd)
97 self.assertRaises(KeyError, s.unregister, rd)
102 rd, wr = self.make_socketpair()
103 r, w = rd.fileno(), wr.fileno()
106 rd.close()
115 rd, wr = self.make_socketpair()
116 r, w = rd.fileno(), wr.fileno()
120 rd.close()
132 rd, wr = self.make_socketpair()
133 s.register(rd, selectors.EVENT_READ)
135 rd.close()
137 s.unregister(rd)
144 rd, wr = self.make_socketpair()
146 key = s.register(rd, selectors.EVENT_READ)
149 key2 = s.modify(rd, selectors.EVENT_WRITE)
151 self.assertEqual(key2, s.get_key(rd))
153 s.unregister(rd)
159 key = s.register(rd, selectors.EVENT_READ, d1)
160 key2 = s.modify(rd, selectors.EVENT_READ, d2)
163 self.assertEqual(key2, s.get_key(rd))
174 s.modify(rd, selectors.EVENT_READ, d3)
183 rd, wr = self.make_socketpair()
185 s.register(rd, selectors.EVENT_READ)
189 self.assertRaises(RuntimeError, s.get_key, rd)
191 self.assertRaises(KeyError, mapping.__getitem__, rd)
198 rd, wr = self.make_socketpair()
200 key = s.register(rd, selectors.EVENT_READ, "data")
201 self.assertEqual(key, s.get_key(rd))
210 rd, wr = self.make_socketpair()
216 key = s.register(rd, selectors.EVENT_READ, "data")
217 self.assertIn(rd, keys)
218 self.assertEqual(key, keys[rd])
220 self.assertEqual(list(keys), [rd.fileno()])
229 del keys[rd]
235 rd, wr = self.make_socketpair()
237 s.register(rd, selectors.EVENT_READ)
253 rd, wr = self.make_socketpair()
256 sel.register(rd, selectors.EVENT_READ)
259 self.assertRaises(RuntimeError, s.get_key, rd)
284 rd, wr = self.make_socketpair()
285 s.register(rd, selectors.EVENT_READ)
287 readers.append(rd)
289 r2w[rd] = wr
290 w2r[wr] = rd
314 rd = ready_readers[0]
315 buf = rd.recv(MSG_LEN)
318 s.unregister(r2w[rd])
319 s.unregister(rd)
320 writers.remove(r2w[rd])
337 rd, wr = self.make_socketpair()
346 s.register(rd, selectors.EVENT_READ)
365 rd, wr = self.make_socketpair()
379 s.register(rd, selectors.EVENT_READ)
393 rd, wr = self.make_socketpair()
401 s.register(rd, selectors.EVENT_READ)
436 rd, wr = self.make_socketpair()
444 s.register(rd, selectors.EVENT_READ)
