Generation numbers to catch write back of stale copies

[empserver] / src / lib / empthread / io.c

diff --git a/src/lib/empthread/io.c b/src/lib/empthread/io.c
index 6679dfc667e77cb6de50dc340bb93b3a8f1d3606..8016044d3e7060840bd784f3dec04360f5a9e384 100644 (file)
--- a/src/lib/empthread/io.c
+++ b/src/lib/empthread/io.c
@@ -51,6 +51,7 @@
 #include <unistd.h>
 #include "empio.h"
 #include "empthread.h"
+#include "file.h"
 #include "ioqueue.h"
 #include "misc.h"
 #include "queue.h"
@@ -196,6 +197,9 @@ io_output(struct iop *iop, int wait)
     struct iovec iov[16];
     int n, res, cc;
 
+    if (wait)
+       ef_make_stale();
+
     if (!ioq_qsize(iop->output))
        return 0;