@@ -643,7 +643,7 @@ err_out_exit:
/*
* Schedule crypto processing for given transaction.
- */
+ */
int dst_trans_crypto(struct dst_trans *t)
{
struct dst_node *n = t->n;
@@ -795,7 +795,6 @@ static int dst_start_node(struct dst_node *n, struct dst_ctl *ctl,
return 0;
}
-
typedef int (*dst_command_func)(struct dst_node *n, struct dst_ctl *ctl,
void *data, unsigned int size);
@@ -823,7 +822,6 @@ static void cn_dst_callback(void *data)
struct dst_node *n = NULL, *tmp;
unsigned int hash;
-
if (msg->len < sizeof(struct dst_ctl)) {
err = -EBADMSG;
goto out;
@@ -271,13 +271,13 @@ static void dst_state_cleanup_export(struct dst_state *st)
if (p)
bio_put(p->bio);
-
+
dprintk("%s: st: %p, refcnt: %d, list_empty: %d, p: %p.\n",
__func__, st, atomic_read(&st->refcnt),
list_empty(&st->request_list), p);
}
}
-
+
dst_state_put(st);
}
@@ -327,7 +327,7 @@ static int dst_accept(void *init_data, void *schedule_data)
}
dprintk("%s: freeing listening socket st: %p.\n", __func__, main);
-
+
dst_state_lock(main);
dst_poll_exit(main);
dst_state_socket_release(main);
@@ -809,7 +809,7 @@ int dst_trans_send(struct dst_trans *t)
struct bio *bio = t->bio;
dst_convert_cmd(&t->cmd);
-
+
dst_state_lock(st);
if (!st->socket) {
err = dst_state_init_connected(st);
@@ -828,7 +828,7 @@ int dst_trans_send(struct dst_trans *t)
dst_state_unlock(st);
return 0;
-
+
err_out_reset:
dst_state_reset_nolock(st);
err_out_unlock:
@@ -42,7 +42,7 @@ struct thread_pool_worker
int has_data;
int need_exit;
unsigned int id;
-
+
wait_queue_head_t wait;
void *private;
@@ -170,7 +170,7 @@ void thread_pool_del_worker_id(struct thread_pool *p, unsigned int id)
}
}
mutex_unlock(&p->thread_lock);
-
+
if (found)
thread_pool_exit_worker(w);
}