Index: libcfa/src/concurrency/io.cfa
===================================================================
--- libcfa/src/concurrency/io.cfa	(revision e9c0b4c888f358d2f8bdd9e67817fc67b133d7a9)
+++ libcfa/src/concurrency/io.cfa	(revision fa4915c459b6f00d06ebb6e563e580bcfe1e54ae)
@@ -138,5 +138,11 @@
 		/* paranoid */ verify( proc->io.ctx );
 
+		__attribute__((unused)) cluster * cltr = proc->cltr;
 		$io_context & ctx = *proc->io.ctx;
+
+		// for(i; 2) {
+		// 	unsigned idx = proc->rdq.id + i;
+		// 	cltr->ready_queue.lanes.tscs[idx].tv = -1ull;
+		// }
 
 		__ioarbiter_flush( ctx );
@@ -151,4 +157,8 @@
 				// Update statistics
 				__STATS__( false, io.calls.errors.busy ++; )
+				// for(i; 2) {
+				// 	unsigned idx = proc->rdq.id + i;
+				// 	cltr->ready_queue.lanes.tscs[idx].tv = rdtscl();
+				// }
 				return;
 			default:
@@ -172,4 +182,12 @@
 
 		ctx.proc->io.pending = false;
+
+		ready_schedule_lock();
+		__cfa_io_drain( proc );
+		ready_schedule_unlock();
+		// for(i; 2) {
+		// 	unsigned idx = proc->rdq.id + i;
+		// 	cltr->ready_queue.lanes.tscs[idx].tv = rdtscl();
+		// }
 	}