Lines Matching refs:send
163 if self.end not in ('same', 'opposite', 'send', 'recv'):
166 if self.end not in ('both', 'same', 'opposite', 'send', 'recv'):
177 return 'recv' if end == 'send' else 'send'
244 if end == 'send':
262 if end in ('recv', 'send'):
270 if end in ('recv', 'send'):
1083 cid = interpreters._channel_id(10, send=True, force=True)
1084 self.assertEqual(cid.end, 'send')
1086 cid = interpreters._channel_id(10, send=True, recv=False, force=True)
1087 self.assertEqual(cid.end, 'send')
1092 cid = interpreters._channel_id(10, recv=True, send=False, force=True)
1095 cid = interpreters._channel_id(10, send=True, recv=True, force=True)
1116 interpreters._channel_id(10, send=False, recv=False)
1131 cid = interpreters._channel_id(10, send=True, force=True)
1132 self.assertEqual(repr(cid), 'ChannelID(10, send=True)')
1137 cid = interpreters._channel_id(10, send=True, recv=True, force=True)
1203 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1204 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1212 interpreters.channel_send(cid, "send")
1214 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1215 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1225 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1226 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1238 interpreters.channel_send(cid, "send")
1241 _interpreters.channel_send({cid}, "send")
1251 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1252 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1261 interpreters.channel_send(cid, "send")
1267 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1268 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1274 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1275 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1281 # Set up one channel with main interpreter on the send end and two
1298 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1299 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1303 # Release the main interpreter from the send end.
1304 interpreters.channel_release(cid, send=True)
1306 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1307 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1317 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1318 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1328 interpreters.channel_send(cid, "send")
1331 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1332 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1340 interpreters.channel_list_interpreters(cid, send=True)
1342 interpreters.channel_list_interpreters(cid, send=False)
1345 """Test listing channel interpreters with a channel's send end closed."""
1350 interpreters.channel_send(cid, "send")
1353 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1354 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1358 # Close the send end of the channel.
1359 interpreters.channel_close(cid, send=True)
1362 interpreters.channel_list_interpreters(cid, send=True)
1364 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1374 interpreters.channel_list_interpreters(cid, send=True)
1376 interpreters.channel_list_interpreters(cid, send=False)
1503 dict(cid=cid.send))
1507 self.assertEqual(out.strip(), 'send')
1523 dict(chan=cid.send))
1527 self.assertEqual(out.strip(), 'send')
1582 for send, recv in tests:
1583 with self.subTest((send, recv)):
1587 interpreters.channel_close(cid, send=send, recv=recv)
1621 interpreters.channel_close(cid, send=True)
1636 interpreters.channel_close(cid, recv=True, send=True)
1658 interpreters.channel_close(cid, send=True, force=True)
1669 interpreters.channel_close(cid, send=True, recv=True, force=True)
1715 interpreters.channel_list_interpreters(1000, send=True)
1720 interpreters.channel_list_interpreters(cid, send=True)
1759 use: None,send,recv,send/recv in None,same,other(incl. interp2),same+other(incl. interp2),all
1760 pre-release: None,send,recv,both in None,same,other(incl. interp2),same+other(incl. interp2),all
1761 pre-release forced: None,send,recv,both in None,same,other(incl. interp2),same+other(incl. interp2),all
1766 use after: None,send,recv,send/recv in None,same,other(incl. interp2),same+other(incl. interp2),all
1767 release after: None,send,recv,send/recv in None,same,other(incl. interp2),same+other(incl. interp2),all
1768 check released: send/recv for same/other(incl. interp2)
1769 check closed: send/recv for same/other(incl. interp2)
1776 interpreters.channel_release(cid, send=True, recv=True)
1818 interpreters.channel_release(cid, send=True, recv=True)
1821 interpreters.channel_release(cid, send=True, recv=True)
1827 interpreters.channel_release(cid, send=True, recv=True)
1875 interpreters.channel_release(cid, send=True)
1886 interpreters.channel_release(cid, send=True, recv=True)
1902 assert end in ('send', 'recv')
1943 if end == 'recv' and self.state.closed == 'send':
1967 # We purposefully send back an int to avoid tying the
2038 use: None,send,recv,send/recv in None,same,other,same+other,all
2039 pre-close: None,send,recv in None,same,other,same+other,all
2040 pre-close forced: None,send,recv in None,same,other,same+other,all
2045 use after: None,send,recv,send/recv in None,same,other,extra,same+other,all
2046 close after: None,send,recv,send/recv in None,same,other,extra,same+other,all
2047 check closed: send/recv for same/other(incl. interp2)
2112 ChannelAction('use', 'send', interp1),
2115 ChannelAction('use', 'send', interp2),
2118 ChannelAction('use', 'send', interp1),
2119 ChannelAction('use', 'send', interp2),
2127 ChannelAction('use', 'send', interp1),
2128 ChannelAction('use', 'send', interp2),
2138 ChannelAction('use', 'send', interp1),
2139 ChannelAction('use', 'send', interp2),
2145 ends = ('recv', 'send')
2157 for send in interps:
2160 ChannelAction(sendop, 'send', send),
2169 ChannelAction('use', 'send', interp),
2218 for end in ('send', 'recv'):