We might need to call ObjWaitstate twice to see BOS_FINISHED

parent 97578b06
...@@ -547,8 +547,9 @@ fellow_stream_f(void *priv, unsigned flush, const void *ptr, ssize_t len) ...@@ -547,8 +547,9 @@ fellow_stream_f(void *priv, unsigned flush, const void *ptr, ssize_t len)
return (fs->func(fs->priv, flush, ptr, len)); return (fs->func(fs->priv, flush, ptr, len));
if (flush & OBJ_ITER_END) { if (flush & OBJ_ITER_END) {
if (fellow_stream_wait(fs) == BOS_FAILED) for (r = 0; fs->state != BOS_FINISHED && r < 2; r++)
return (-1); if (fellow_stream_wait(fs) == BOS_FAILED)
return (-1);
assert(fs->state == BOS_FINISHED); assert(fs->state == BOS_FINISHED);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment