From cf823e87ee7e3f2608b451528a24aea7f0900c7e Mon Sep 17 00:00:00 2001 From: Dmitry Simonenko Date: Tue, 30 May 2017 14:17:35 +0300 Subject: [PATCH] odissey: set client readahead --- src/od_cancel.c | 2 ++ src/od_frontend.c | 8 +++++++- 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/src/od_cancel.c b/src/od_cancel.c index 88cb79ee..913f7ca1 100644 --- a/src/od_cancel.c +++ b/src/od_cancel.c @@ -84,11 +84,13 @@ int od_cancel(od_instance_t *instance, machine_io_free(io); return -1; } +#if 0 rc = machine_set_readahead(io, instance->scheme.readahead); if (rc == -1) { od_error(&instance->log, NULL, "(cancel) failed to set readahead"); return -1; } +#endif so_stream_t stream; so_stream_init(&stream); diff --git a/src/od_frontend.c b/src/od_frontend.c index 124abbae..07644282 100644 --- a/src/od_frontend.c +++ b/src/od_frontend.c @@ -363,6 +363,13 @@ void od_frontend(void *arg) od_client_free(client); return; } + rc = machine_set_readahead(client->io, instance->scheme.readahead); + if (rc == -1) { + od_error(&instance->log, client->io, "failed to set client readahead"); + machine_close(client->io); + od_client_free(client); + return; + } /* client startup */ rc = od_frontend_startup(client); @@ -380,7 +387,6 @@ void od_frontend(void *arg) od_frontend_close(client); od_cancel(relay, &key); #endif - od_frontend_close(client); return; }