Setup for multiplexing a MSG_* stream with the data stream. */
| 2445 | |
| 2446 | /* Setup for multiplexing a MSG_* stream with the data stream. */ |
| 2447 | void io_start_multiplex_out(int fd) |
| 2448 | { |
| 2449 | io_flush(FULL_FLUSH); |
| 2450 | |
| 2451 | if (msgs2stderr == 1 && DEBUG_GTE(IO, 2)) |
| 2452 | rprintf(FINFO, "[%s] io_start_multiplex_out(%d)\n", who_am_i(), fd); |
| 2453 | |
| 2454 | if (!iobuf.msg.buf) |
| 2455 | alloc_xbuf(&iobuf.msg, ROUND_UP_1024(IO_BUFFER_SIZE)); |
| 2456 | |
| 2457 | iobuf.out_empty_len = 4; /* See also OUT_MULTIPLEXED */ |
| 2458 | io_start_buffering_out(fd); |
| 2459 | got_kill_signal = 0; |
| 2460 | |
| 2461 | iobuf.raw_data_header_pos = iobuf.out.pos + iobuf.out.len; |
| 2462 | iobuf.out.len += 4; |
| 2463 | } |
| 2464 | |
| 2465 | /* Setup for multiplexing a MSG_* stream with the data stream. */ |
| 2466 | void io_start_multiplex_in(int fd) |
no test coverage detected