| 2473 | } |
| 2474 | |
| 2475 | int io_end_multiplex_in(int mode) |
| 2476 | { |
| 2477 | int ret = iobuf.in_multiplexed ? iobuf.in_fd : -1; |
| 2478 | |
| 2479 | if (msgs2stderr == 1 && DEBUG_GTE(IO, 2)) |
| 2480 | rprintf(FINFO, "[%s] io_end_multiplex_in(mode=%d)\n", who_am_i(), mode); |
| 2481 | |
| 2482 | iobuf.in_multiplexed = 0; |
| 2483 | if (mode == MPLX_SWITCHING) |
| 2484 | iobuf.raw_input_ends_before = 0; |
| 2485 | else |
| 2486 | assert(iobuf.raw_input_ends_before == 0); |
| 2487 | if (mode != MPLX_TO_BUFFERED) |
| 2488 | io_end_buffering_in(mode); |
| 2489 | |
| 2490 | return ret; |
| 2491 | } |
| 2492 | |
| 2493 | int io_end_multiplex_out(int mode) |
| 2494 | { |
no test coverage detected