We don't use the flag, it's set but never tested. On exit, we use
pthread_join() to wait for the thread to exit.
Signed-off-by: Jens Axboe <axboe@fb.com>
SW_F_IDLE = 1 << 0,
SW_F_RUNNING = 1 << 1,
SW_F_EXIT = 1 << 2,
SW_F_IDLE = 1 << 0,
SW_F_RUNNING = 1 << 1,
SW_F_EXIT = 1 << 2,
- SW_F_EXITED = 1 << 3,
- SW_F_ACCOUNTED = 1 << 4,
- SW_F_ERROR = 1 << 5,
+ SW_F_ACCOUNTED = 1 << 3,
+ SW_F_ERROR = 1 << 4,
};
static struct submit_worker *__get_submit_worker(struct workqueue *wq,
};
static struct submit_worker *__get_submit_worker(struct workqueue *wq,
{
struct submit_worker *sw = data;
struct workqueue *wq = sw->wq;
{
struct submit_worker *sw = data;
struct workqueue *wq = sw->wq;
- unsigned int eflags = 0, ret = 0;
FLIST_HEAD(local_list);
sk_out_assign(sw->sk_out);
FLIST_HEAD(local_list);
sk_out_assign(sw->sk_out);
wq->ops.update_acct_fn(sw);
done:
wq->ops.update_acct_fn(sw);
done:
- pthread_mutex_lock(&sw->lock);
- sw->flags |= (SW_F_EXITED | eflags);
- pthread_mutex_unlock(&sw->lock);
sk_out_drop();
return NULL;
}
sk_out_drop();
return NULL;
}