Lines Matching refs:recv
551 _channelend *recv;
564 ends->recv = NULL;
575 _channelend_free_all(ends->recv);
576 ends->recv = NULL;
601 ends->recv = end;
620 _channelend *end = _channelend_find(send ? ends->send : ends->recv,
642 if (ends->send == NULL && ends->recv == NULL) {
676 if (which <= 0) { // recv/both
677 end = _channelend_find(ends->recv, interp, &prev);
702 // Ensure all the "recv"-associated interpreters are closed.
703 for (end = ends->recv; end != NULL; end = end->next) {
1367 _channel_drop(_channels *channels, int64_t id, int send, int recv)
1383 int res = _channel_close_interpreter(chan, PyInterpreterState_GetID(interp), send-recv);
1406 _channelend *end = _channelend_find(send ? chan->ends->send : chan->ends->recv,
1483 static char *kwlist[] = {"id", "send", "recv", "force", "_resolve", NULL};
1486 int recv = -1;
1491 channel_id_converter, &cid, &send, &recv, &force, &resolve))
1494 // Handle "send" and "recv".
1495 if (send == 0 && recv == 0) {
1497 "'send' and 'recv' cannot both be False");
1503 if (recv == 0 || recv == -1) {
1507 else if (recv == 1) {
1537 fmt = "%s(%" PRId64 ", recv=True)";
1746 return PyUnicode_InternFromString("recv");
1756 PyDoc_STR("'send', 'recv', or 'both'")},
1759 {"recv", (getter)channelid_end, NULL,
1760 PyDoc_STR("the 'recv' end of the channel"), &_channelid_end_recv},
2460 static char *kwlist[] = {"cid", "send", "recv", "force", NULL};
2463 int recv = 0;
2467 channel_id_converter, &cid, &send, &recv, &force)) {
2471 if (_channel_close(&_globals.channels, cid, send-recv, force) != 0) {
2478 "channel_close(cid, *, send=None, recv=None, force=False)\n\
2490 * recv is True (regardless of send):\n\
2492 * recv is None and send is None:\n\
2494 * send is True and recv is not True:\n\
2496 - close the 'recv' end to interpreters not already receiving\n\
2508 static char *kwlist[] = {"cid", "send", "recv", "force", NULL};
2511 int recv = 0;
2515 channel_id_converter, &cid, &send, &recv, &force)) {
2518 if (send == 0 && recv == 0) {
2520 recv = 1;
2526 if (_channel_drop(&_globals.channels, cid, send, recv) != 0) {
2533 "channel_release(cid, *, send=None, recv=None, force=True)\n\
2535 Close the channel for the current interpreter. 'send' and 'recv'\n\