From d4a77c147ed6af9298ecb3f43106af435bbc2663 Mon Sep 17 00:00:00 2001 From: Dmitry Simonenko Date: Tue, 8 Nov 2016 15:57:56 +0300 Subject: [PATCH] fluent: cleanups for write handler --- lib/ft_iowrite.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/lib/ft_iowrite.c b/lib/ft_iowrite.c index 94337d63..5fd8eeae 100644 --- a/lib/ft_iowrite.c +++ b/lib/ft_iowrite.c @@ -34,10 +34,11 @@ FLUENT_API int ft_write(ftio_t iop, char *buf, int size, uint64_t time_ms) { ftio *io = iop; + if (!io->connected || io->write_fiber) + return -1; io->write_status = 0; io->write_timeout = 0; io->write_fiber = ft_current(io->f); - ft_bufreset(&io->read_buf); ft_io_timer_start(&io->connect_timer, ft_io_write_timeout_cb, time_ms);