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

flint: pre-check cancel state for ft_write()

This commit is contained in:
Dmitry Simonenko 2016-11-18 16:28:49 +03:00
parent e219cfd107
commit 74fb9d627a
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
lib/ft_iowrite.c
View File

@ -47,11 +47,14 @@ FLINT_API int
ft_write(ftio_t iop, char *buf, int size, uint64_t time_ms)
{
ftio *io = iop;
ftfiber *current = ft_current(io->f);
if (ft_fiber_is_cancel(current))
return -ECANCELED;
if (!io->connected || io->write_fiber)
return -1;
io->write_status = 0;
io->write_timeout = 0;
io->write_fiber = ft_current(io->f);
io->write_fiber = current;
ft_io_timer_start(&io->connect_timer, ft_io_write_timeout_cb,
time_ms);