struct byteq byteq;
};
-static bool async_append_enabled;
-
-void
-async_append_enable(void)
-{
- assert_single_threaded();
- forbid_forking("async i/o enabled");
- async_append_enabled = true;
-}
-
struct async_append *
async_append_create(int fd)
{
{
const uint8_t *data = data_;
- if (!async_append_enabled) {
- ignore(write(ap->fd, data, size));
- return;
- }
-
while (size > 0) {
struct aiocb *aiocb;
size_t chunk_size;