Lines Matching refs:recv
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'
223 if action == 'use' and end == 'recv' and state.pending:
247 elif end == 'recv':
262 if end in ('recv', 'send'):
270 if end in ('recv', 'send'):
1086 cid = interpreters._channel_id(10, send=True, recv=False, force=True)
1089 cid = interpreters._channel_id(10, recv=True, force=True)
1090 self.assertEqual(cid.end, 'recv')
1092 cid = interpreters._channel_id(10, recv=True, send=False, force=True)
1093 self.assertEqual(cid.end, 'recv')
1095 cid = interpreters._channel_id(10, send=True, recv=True, force=True)
1116 interpreters._channel_id(10, send=False, recv=False)
1134 cid = interpreters._channel_id(10, recv=True, force=True)
1135 self.assertEqual(repr(cid), 'ChannelID(10, recv=True)')
1137 cid = interpreters._channel_id(10, send=True, recv=True, force=True)
1582 for send, recv in tests:
1583 with self.subTest((send, recv)):
1587 interpreters.channel_close(cid, send=send, recv=recv)
1610 interpreters.channel_close(cid, recv=True)
1615 interpreters.channel_close(cid, recv=True)
1636 interpreters.channel_close(cid, recv=True, send=True)
1641 interpreters.channel_close(cid, recv=True)
1647 interpreters.channel_close(cid, recv=True, force=True)
1669 interpreters.channel_close(cid, send=True, recv=True, force=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)
1886 interpreters.channel_release(cid, send=True, recv=True)
1902 assert end in ('send', 'recv')
1943 if end == 'recv' and self.state.closed == 'send':
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)
2098 # only recv end used
2100 ChannelAction('use', 'recv', interp1),
2103 ChannelAction('use', 'recv', interp2),
2106 ChannelAction('use', 'recv', interp1),
2107 ChannelAction('use', 'recv', interp2),
2129 ChannelAction('use', 'recv', interp3),
2140 ChannelAction('use', 'recv', interp3),
2141 ChannelAction('use', 'recv', interp4),
2145 ends = ('recv', 'send')
2156 for recv in interps:
2159 ChannelAction(recvop, 'recv', recv),
2166 ChannelAction('use', 'recv', interp),
2218 for end in ('send', 'recv'):