Lines Matching refs:send
550 _channelend *send;
563 ends->send = NULL;
571 _channelend_free_all(ends->send);
572 ends->send = NULL;
589 int send)
597 if (send) {
598 ends->send = end;
607 if (send) {
617 _channelends_associate(_channelends *ends, int64_t interp, int send)
620 _channelend *end = _channelend_find(send ? ends->send : ends->recv,
630 if (_channelends_add(ends, prev, interp, send) == NULL) {
642 if (ends->send == NULL && ends->recv == NULL) {
649 _channelends_close_end(_channelends *ends, _channelend *end, int send)
652 if (send) {
665 if (which >= 0) { // send/both
666 end = _channelend_find(ends->send, interp, &prev);
696 // Ensure all the "send"-associated interpreters are closed.
698 for (end = ends->send; 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);
1396 int send)
1401 } else if (send && chan->closing != NULL) {
1406 _channelend *end = _channelend_find(send ? chan->ends->send : chan->ends->recv,
1483 static char *kwlist[] = {"id", "send", "recv", "force", "_resolve", NULL};
1485 int send = -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");
1502 if (send == 1) {
1534 fmt = "%s(%" PRId64 ", send=True)";
1743 return PyUnicode_InternFromString("send");
1756 PyDoc_STR("'send', 'recv', or 'both'")},
1757 {"send", (getter)channelid_end, NULL,
1758 PyDoc_STR("the 'send' end of the channel"), &_channelid_end_send},
2341 static char *kwlist[] = {"cid", "send", NULL};
2343 int send = 0; /* Send or receive end? */
2350 kwlist, channel_id_converter, &cid, &send)) {
2363 int res = _channel_is_associated(&_globals.channels, cid, id, send);
2392 "channel_list_interpreters(cid, *, send) -> [id]\n\
2396 The 'send' argument should be a boolean indicating whether to use the send or\n\
2460 static char *kwlist[] = {"cid", "send", "recv", "force", NULL};
2462 int send = 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\
2495 - fully close the 'send' end\n\
2508 static char *kwlist[] = {"cid", "send", "recv", "force", NULL};
2510 int send = 0;
2515 channel_id_converter, &cid, &send, &recv, &force)) {
2518 if (send == 0 && recv == 0) {
2519 send = 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\