| 1386 | } |
| 1387 | |
| 1388 | BOOL io_start_buffering_in(int f_in) |
| 1389 | { |
| 1390 | if (msgs2stderr == 1 && DEBUG_GTE(IO, 2)) |
| 1391 | rprintf(FINFO, "[%s] io_start_buffering_in(%d)\n", who_am_i(), f_in); |
| 1392 | |
| 1393 | if (iobuf.in.buf) { |
| 1394 | if (iobuf.in_fd == -1) |
| 1395 | iobuf.in_fd = f_in; |
| 1396 | else |
| 1397 | assert(f_in == iobuf.in_fd); |
| 1398 | return False; |
| 1399 | } |
| 1400 | |
| 1401 | alloc_xbuf(&iobuf.in, ROUND_UP_1024(IO_BUFFER_SIZE)); |
| 1402 | iobuf.in_fd = f_in; |
| 1403 | |
| 1404 | return True; |
| 1405 | } |
| 1406 | |
| 1407 | void io_end_buffering_in(BOOL free_buffers) |
| 1408 | { |
no test coverage detected