diff --git a/io/io_canread.c b/io/io_canread.c index 7e8df7c..bc22c11 100644 --- a/io/io_canread.c +++ b/io/io_canread.c @@ -24,6 +24,7 @@ int64 io_canread() { if (!e) break; r=first_readable; first_readable=e->next_read; + e->next_read=-1; debug_printf(("io_canread: dequeue %lld from normal read queue (next is %ld)\n",r,first_readable)); if (e->wantread && e->canread) { #ifdef HAVE_SIGIO diff --git a/io/io_canwrite.c b/io/io_canwrite.c index 0aaec31..f28ef12 100644 --- a/io/io_canwrite.c +++ b/io/io_canwrite.c @@ -24,6 +24,7 @@ int64 io_canwrite() { if (!e) break; r=first_writeable; first_writeable=e->next_write; + e->next_write=-1; debug_printf(("io_canwrite: dequeue %lld from normal write queue (next is %ld)\n",r,first_writeable)); if (e->wantwrite && e->canwrite) { #ifdef HAVE_SIGIO