Lines Matching full:send
134 if self.end not in ('same', 'opposite', 'send', 'recv'):
137 if self.end not in ('both', 'same', 'opposite', 'send', 'recv'):
148 return 'recv' if end == 'send' else 'send'
215 if end == 'send':
216 _channels.send(cid, b'spam', blocking=False)
233 if end in ('recv', 'send'):
241 if end in ('recv', 'send'):
276 cid = _channels._channel_id(10, send=True, force=True)
277 self.assertEqual(cid.end, 'send')
279 cid = _channels._channel_id(10, send=True, recv=False, force=True)
280 self.assertEqual(cid.end, 'send')
285 cid = _channels._channel_id(10, recv=True, send=False, force=True)
288 cid = _channels._channel_id(10, send=True, recv=True, force=True)
309 _channels._channel_id(10, send=False, recv=False)
324 cid = _channels._channel_id(10, send=True, force=True)
325 self.assertEqual(repr(cid), 'ChannelID(10, send=True)')
330 cid = _channels._channel_id(10, send=True, recv=True, force=True)
359 _channels.send(chan, obj, blocking=False)
408 send_interps = _channels.list_interpreters(cid, send=True)
409 recv_interps = _channels.list_interpreters(cid, send=False)
417 _channels.send(cid, "send", blocking=False)
419 send_interps = _channels.list_interpreters(cid, send=True)
420 recv_interps = _channels.list_interpreters(cid, send=False)
430 send_interps = _channels.list_interpreters(cid, send=True)
431 recv_interps = _channels.list_interpreters(cid, send=False)
443 _channels.send(cid, "send", blocking=False)
446 _channels.send({cid}, "send", blocking=False)
456 send_interps = _channels.list_interpreters(cid, send=True)
457 recv_interps = _channels.list_interpreters(cid, send=False)
466 _channels.send(cid, "send", blocking=False)
472 send_interps = _channels.list_interpreters(cid, send=True)
473 recv_interps = _channels.list_interpreters(cid, send=False)
479 send_interps = _channels.list_interpreters(cid, send=True)
480 recv_interps = _channels.list_interpreters(cid, send=False)
486 # Set up one channel with main interpreter on the send end and two
492 _channels.send(cid, "data", blocking=False)
497 _channels.send(cid, "data", blocking=False)
503 send_interps = _channels.list_interpreters(cid, send=True)
504 recv_interps = _channels.list_interpreters(cid, send=False)
508 # Release the main interpreter from the send end.
509 _channels.release(cid, send=True)
510 # Send end should have no associated _interpreters.
511 send_interps = _channels.list_interpreters(cid, send=True)
512 recv_interps = _channels.list_interpreters(cid, send=False)
522 send_interps = _channels.list_interpreters(cid, send=True)
523 recv_interps = _channels.list_interpreters(cid, send=False)
533 _channels.send(cid, "send", blocking=False)
536 send_interps = _channels.list_interpreters(cid, send=True)
537 recv_interps = _channels.list_interpreters(cid, send=False)
545 _channels.list_interpreters(cid, send=True)
547 _channels.list_interpreters(cid, send=False)
550 """Test listing channel interpreters with a channel's send end closed."""
555 _channels.send(cid, "send", blocking=False)
558 send_interps = _channels.list_interpreters(cid, send=True)
559 recv_interps = _channels.list_interpreters(cid, send=False)
563 # Close the send end of the channel.
564 _channels.close(cid, send=True)
565 # Send end should raise an error.
567 _channels.list_interpreters(cid, send=True)
569 recv_interps = _channels.list_interpreters(cid, send=False)
580 _channels.list_interpreters(cid, send=True)
582 _channels.list_interpreters(cid, send=False)
594 _channels.send(cid, obj, blocking=False)
607 _interpreters.set___main___attrs(interp, dict(cid=cid.send))
611 _channels.send(cid, b'spam', blocking=False)
616 self.assertEqual(out.strip(), 'send')
630 _channels.send(chan.id, b'spam', blocking=False)
632 dict(chan=cid.send))
636 self.assertEqual(out.strip(), 'send')
639 # send/recv
644 _channels.send(cid, orig, blocking=False)
656 _channels.send(cid, orig, blocking=False)
667 _channels.send({cid}, b'spam', blocking=False)
678 _channels.send(cid, obj)
682 _channels.send(cid, b'spam')
705 _channels.send({cid}, b'eggs')
710 _channels.send(cid, b'spam')
718 _channels.send(10, b'spam')
733 _channels.send(cid, None, blocking=False)
734 _channels.send(cid, 1, blocking=False)
735 _channels.send(cid, b'spam', blocking=False)
736 _channels.send(cid, b'eggs', blocking=False)
756 _channels.send({cid1}, b'spam', blocking=False)
769 _channels.send({cid2}, b'spam', blocking=False)
771 _channels.send(cid2, b'eggs', blocking=False)
800 # send with waiting
803 # We want a long enough sleep that send() actually has to wait.
806 send = _channels.send_buffer
808 send = _channels.send
813 send(cid, obj, blocking=False)
836 _channels.send(cid, obj, blocking=True)
866 _channels.send(cid, obj, blocking=True)
891 _channels.send(cid, obj, blocking=False, timeout=0.1)
896 _channels.send(cid, obj, blocking=True, timeout=0.1)
907 _channels.send(cid, obj, blocking=True, timeout=10)
959 _channels.send(cid, obj, blocking=True)
970 _channels.send(cid, obj, blocking=True, timeout=30)
1016 _channels.send(cid, b'spam', blocking=False)
1021 _channels.send(cid, b'eggs')
1031 _channels.send({cid}, b'spam', blocking=False)
1040 _channels.send({cid}, b'spam')
1045 _channels.send({cid}, b'spam')
1051 _channels.send(cid, b'spam', blocking=False)
1065 for send, recv in tests:
1066 with self.subTest((send, recv)):
1068 _channels.send(cid, b'spam', blocking=False)
1070 _channels.close(cid, send=send, recv=recv)
1073 _channels.send(cid, b'eggs')
1079 _channels.send(cid, b'spam', blocking=False)
1080 _channels.send(cid, b'ham', blocking=False)
1085 _channels.send(cid, b'eggs', blocking=False)
1089 _channels.send(cid, b'spam', blocking=False)
1090 _channels.send(cid, b'ham', blocking=False)
1095 _channels.send(cid, b'eggs', blocking=False)
1102 _channels.send(cid, b'spam', blocking=False)
1103 _channels.send(cid, b'ham', blocking=False)
1104 _channels.close(cid, send=True)
1107 _channels.send(cid, b'eggs')
1115 _channels.send(cid, b'spam', blocking=False)
1116 _channels.send(cid, b'ham', blocking=False)
1119 _channels.close(cid, recv=True, send=True)
1121 _channels.send(cid, b'eggs', blocking=False)
1128 _channels.send(cid, b'spam', blocking=False)
1129 _channels.send(cid, b'ham', blocking=False)
1133 _channels.send(cid, b'eggs')
1139 _channels.send(cid, b'spam', blocking=False)
1140 _channels.send(cid, b'ham', blocking=False)
1141 _channels.close(cid, send=True, force=True)
1144 _channels.send(cid, b'eggs')
1150 _channels.send(cid, b'spam', blocking=False)
1151 _channels.send(cid, b'ham', blocking=False)
1152 _channels.close(cid, send=True, recv=True, force=True)
1155 _channels.send(cid, b'eggs')
1164 _channels.send(cid, b'spam')
1170 _channels.send(cid, b'spam', blocking=False)
1183 _channels.send(cid, b'spam', blocking=False)
1184 _channels.send(cid, b'spam', blocking=False)
1185 _channels.send(cid, b'spam', blocking=False)
1190 _channels.send(cid, b'eggs')
1198 _channels.list_interpreters(1000, send=True)
1203 _channels.list_interpreters(cid, send=True)
1242 …use: None,send,recv,send/recv in None,same,other(incl. interp2),same+other(incl. in…
1243 …pre-release: None,send,recv,both in None,same,other(incl. interp2),same+other(incl. interp2…
1244 …pre-release forced: None,send,recv,both in None,same,other(incl. interp2),same+other(incl. interp2…
1249 …use after: None,send,recv,send/recv in None,same,other(incl. interp2),same+other(incl. in…
1250 …release after: None,send,recv,send/recv in None,same,other(incl. interp2),same+other(incl. in…
1251 check released: send/recv for same/other(incl. interp2)
1252 check closed: send/recv for same/other(incl. interp2)
1257 _channels.send(cid, b'spam', blocking=False)
1259 _channels.release(cid, send=True, recv=True)
1262 _channels.send(cid, b'eggs')
1272 _channels.send({cid}, b'spam', blocking=False)
1288 _channels.send(cid, b'spam', blocking=False)
1293 _channels.send(cid, b'eggs')
1299 _channels.send(cid, b'spam', blocking=False)
1301 _channels.release(cid, send=True, recv=True)
1304 _channels.release(cid, send=True, recv=True)
1308 _channels.send(cid, b'spam', blocking=False)
1309 _channels.send(cid, b'ham', blocking=False)
1310 _channels.release(cid, send=True, recv=True)
1320 _channels.send(cid, b'spam')
1326 _channels.send(cid, b'spam', blocking=False)
1336 _channels.send(cid, b'eggs')
1345 obj = _channels.send({cid}, b'spam', blocking=False)
1355 _channels.send(cid, None, blocking=False)
1357 _channels.send(cid, b'spam', blocking=False)
1358 _channels.release(cid, send=True)
1365 _channels.send(cid, b'spam', blocking=False)
1366 _channels.send(cid, b'spam', blocking=False)
1367 _channels.send(cid, b'spam', blocking=False)
1369 _channels.release(cid, send=True, recv=True)
1372 _channels.send(cid, b'eggs')
1385 assert end in ('send', 'recv')
1426 if end == 'recv' and self.state.closed == 'send':
1450 # We purposefully send back an int to avoid tying the
1452 _xxsubchannels.send({ch}, int(cid), blocking=False)
1521 use: None,send,recv,send/recv in None,same,other,same+other,all
1522 pre-close: None,send,recv in None,same,other,same+other,all
1523 pre-close forced: None,send,recv in None,same,other,same+other,all
1528 use after: None,send,recv,send/recv in None,same,other,extra,same+other,all
1529 close after: None,send,recv,send/recv in None,same,other,extra,same+other,all
1530 check closed: send/recv for same/other(incl. interp2)
1595 ChannelAction('use', 'send', interp1),
1598 ChannelAction('use', 'send', interp2),
1601 ChannelAction('use', 'send', interp1),
1602 ChannelAction('use', 'send', interp2),
1610 ChannelAction('use', 'send', interp1),
1611 ChannelAction('use', 'send', interp2),
1621 ChannelAction('use', 'send', interp1),
1622 ChannelAction('use', 'send', interp2),
1628 ends = ('recv', 'send')
1640 for send in interps:
1643 ChannelAction(sendop, 'send', send),
1652 ChannelAction('use', 'send', interp),
1682 _channels.send({_cid}, result.pending.to_bytes(1, 'little'), blocking=False)
1683 _channels.send({_cid}, b'X' if result.closed else b'', blocking=False)
1701 for end in ('send', 'recv'):
1718 _channels.send(fix.cid, b'spam')
1730 _channels.send(cid, b'spam', blocking=False)