Replace the enum TASK_STATE_START by TASK_STATE_IDLE. Signed-off-by: Bob Pearson <rpearsonhpe@xxxxxxxxx> --- drivers/infiniband/sw/rxe/rxe_task.c | 37 ++++++++++++++-------------- drivers/infiniband/sw/rxe/rxe_task.h | 4 +-- 2 files changed, 21 insertions(+), 20 deletions(-) diff --git a/drivers/infiniband/sw/rxe/rxe_task.c b/drivers/infiniband/sw/rxe/rxe_task.c index a9eb66d69cb7..a2c58ce66c8f 100644 --- a/drivers/infiniband/sw/rxe/rxe_task.c +++ b/drivers/infiniband/sw/rxe/rxe_task.c @@ -12,12 +12,12 @@ static bool task_is_idle(struct rxe_task *task) { - if (task->destroyed) + if (!task->valid) return false; spin_lock_bh(&task->lock); switch (task->state) { - case TASK_STATE_START: + case TASK_STATE_IDLE: task->state = TASK_STATE_BUSY; spin_unlock_bh(&task->lock); return true; @@ -57,15 +57,15 @@ static void do_task(struct rxe_task *task) spin_lock_bh(&task->lock); switch (task->state) { - case TASK_STATE_START: + case TASK_STATE_IDLE: case TASK_STATE_BUSY: if (ret) { - task->state = TASK_STATE_START; + task->state = TASK_STATE_IDLE; } else if (task->type == RXE_TASK_TYPE_INLINE || iterations--) { cont = 1; } else { - task->state = TASK_STATE_START; + task->state = TASK_STATE_IDLE; resched = true; } break; @@ -98,7 +98,7 @@ static void disable_task(struct rxe_task *task) static void enable_task(struct rxe_task *task) { spin_lock_bh(&task->lock); - task->state = TASK_STATE_START; + task->state = TASK_STATE_IDLE; spin_unlock_bh(&task->lock); /* restart task in case */ @@ -110,11 +110,11 @@ static void cleanup_task(struct rxe_task *task) { bool idle; - task->destroyed = true; + task->valid = false; do { spin_lock_bh(&task->lock); - idle = (task->state == TASK_STATE_START || + idle = (task->state == TASK_STATE_IDLE || task->state == TASK_STATE_PAUSED); spin_unlock_bh(&task->lock); } while (!idle); @@ -135,13 +135,13 @@ static void inline_run(struct rxe_task *task) static void inline_disable(struct rxe_task *task) { - if (!task->destroyed) + if (task->valid) disable_task(task); } static void inline_enable(struct rxe_task *task) { - if (!task->destroyed) + if (task->valid) enable_task(task); } @@ -174,7 +174,7 @@ static void tsklet_do_task(struct tasklet_struct *tasklet) { struct rxe_task *task = container_of(tasklet, typeof(*task), tasklet); - if (!task->destroyed) + if (task->valid) do_task(task); } @@ -186,13 +186,13 @@ static void tsklet_run(struct rxe_task *task) static void tsklet_disable(struct rxe_task *task) { - if (!task->destroyed) + if (task->valid) disable_task(task); } static void tsklet_enable(struct rxe_task *task) { - if (!task->destroyed) + if (task->valid) enable_task(task); } @@ -219,11 +219,10 @@ static void tsklet_init(struct rxe_task *task) int rxe_init_task(struct rxe_task *task, void *arg, int (*func)(void *), enum rxe_task_type type) { - task->arg = arg; - task->func = func; - task->destroyed = false; - task->type = type; - task->state = TASK_STATE_START; + task->arg = arg; + task->func = func; + task->type = type; + task->state = TASK_STATE_IDLE; spin_lock_init(&task->lock); @@ -239,6 +238,8 @@ int rxe_init_task(struct rxe_task *task, void *arg, int (*func)(void *), return -EINVAL; } + task->valid = true; + return 0; } diff --git a/drivers/infiniband/sw/rxe/rxe_task.h b/drivers/infiniband/sw/rxe/rxe_task.h index 792832786456..c81947e88629 100644 --- a/drivers/infiniband/sw/rxe/rxe_task.h +++ b/drivers/infiniband/sw/rxe/rxe_task.h @@ -23,7 +23,7 @@ enum rxe_task_type { }; enum { - TASK_STATE_START = 0, + TASK_STATE_IDLE = 0, TASK_STATE_BUSY = 1, TASK_STATE_ARMED = 2, TASK_STATE_PAUSED = 3, @@ -41,7 +41,7 @@ struct rxe_task { void *arg; int (*func)(void *arg); int ret; - bool destroyed; + bool valid; const struct rxe_task_ops *ops; enum rxe_task_type type; }; -- 2.34.1