Rooba
/
odyssey
mirror of https://github.com/yandex/odyssey.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fluent: cleanups for write handler

This commit is contained in:
Dmitry Simonenko 2016-11-08 15:57:56 +03:00
parent d6d48c7193
commit d4a77c147e
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
lib/ft_iowrite.c
View File

@ -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);