diff options
Diffstat (limited to 'net/sunrpc/sched.c')
-rw-r--r-- | net/sunrpc/sched.c | 66 |
1 files changed, 35 insertions, 31 deletions
diff --git a/net/sunrpc/sched.c b/net/sunrpc/sched.c index 13ab0c6fed01..ca56b8e9b649 100644 --- a/net/sunrpc/sched.c +++ b/net/sunrpc/sched.c | |||
@@ -74,7 +74,7 @@ static DEFINE_SPINLOCK(rpc_sched_lock); | |||
74 | static inline void | 74 | static inline void |
75 | __rpc_disable_timer(struct rpc_task *task) | 75 | __rpc_disable_timer(struct rpc_task *task) |
76 | { | 76 | { |
77 | dprintk("RPC: %4d disabling timer\n", task->tk_pid); | 77 | dprintk("RPC: %5u disabling timer\n", task->tk_pid); |
78 | task->tk_timeout_fn = NULL; | 78 | task->tk_timeout_fn = NULL; |
79 | task->tk_timeout = 0; | 79 | task->tk_timeout = 0; |
80 | } | 80 | } |
@@ -93,7 +93,7 @@ static void rpc_run_timer(struct rpc_task *task) | |||
93 | callback = task->tk_timeout_fn; | 93 | callback = task->tk_timeout_fn; |
94 | task->tk_timeout_fn = NULL; | 94 | task->tk_timeout_fn = NULL; |
95 | if (callback && RPC_IS_QUEUED(task)) { | 95 | if (callback && RPC_IS_QUEUED(task)) { |
96 | dprintk("RPC: %4d running timer\n", task->tk_pid); | 96 | dprintk("RPC: %5u running timer\n", task->tk_pid); |
97 | callback(task); | 97 | callback(task); |
98 | } | 98 | } |
99 | smp_mb__before_clear_bit(); | 99 | smp_mb__before_clear_bit(); |
@@ -110,7 +110,7 @@ __rpc_add_timer(struct rpc_task *task, rpc_action timer) | |||
110 | if (!task->tk_timeout) | 110 | if (!task->tk_timeout) |
111 | return; | 111 | return; |
112 | 112 | ||
113 | dprintk("RPC: %4d setting alarm for %lu ms\n", | 113 | dprintk("RPC: %5u setting alarm for %lu ms\n", |
114 | task->tk_pid, task->tk_timeout * 1000 / HZ); | 114 | task->tk_pid, task->tk_timeout * 1000 / HZ); |
115 | 115 | ||
116 | if (timer) | 116 | if (timer) |
@@ -132,7 +132,7 @@ rpc_delete_timer(struct rpc_task *task) | |||
132 | return; | 132 | return; |
133 | if (test_and_clear_bit(RPC_TASK_HAS_TIMER, &task->tk_runstate)) { | 133 | if (test_and_clear_bit(RPC_TASK_HAS_TIMER, &task->tk_runstate)) { |
134 | del_singleshot_timer_sync(&task->tk_timer); | 134 | del_singleshot_timer_sync(&task->tk_timer); |
135 | dprintk("RPC: %4d deleting timer\n", task->tk_pid); | 135 | dprintk("RPC: %5u deleting timer\n", task->tk_pid); |
136 | } | 136 | } |
137 | } | 137 | } |
138 | 138 | ||
@@ -179,8 +179,8 @@ static void __rpc_add_wait_queue(struct rpc_wait_queue *queue, struct rpc_task * | |||
179 | queue->qlen++; | 179 | queue->qlen++; |
180 | rpc_set_queued(task); | 180 | rpc_set_queued(task); |
181 | 181 | ||
182 | dprintk("RPC: %4d added to queue %p \"%s\"\n", | 182 | dprintk("RPC: %5u added to queue %p \"%s\"\n", |
183 | task->tk_pid, queue, rpc_qname(queue)); | 183 | task->tk_pid, queue, rpc_qname(queue)); |
184 | } | 184 | } |
185 | 185 | ||
186 | /* | 186 | /* |
@@ -212,8 +212,8 @@ static void __rpc_remove_wait_queue(struct rpc_task *task) | |||
212 | else | 212 | else |
213 | list_del(&task->u.tk_wait.list); | 213 | list_del(&task->u.tk_wait.list); |
214 | queue->qlen--; | 214 | queue->qlen--; |
215 | dprintk("RPC: %4d removed from queue %p \"%s\"\n", | 215 | dprintk("RPC: %5u removed from queue %p \"%s\"\n", |
216 | task->tk_pid, queue, rpc_qname(queue)); | 216 | task->tk_pid, queue, rpc_qname(queue)); |
217 | } | 217 | } |
218 | 218 | ||
219 | static inline void rpc_set_waitqueue_priority(struct rpc_wait_queue *queue, int priority) | 219 | static inline void rpc_set_waitqueue_priority(struct rpc_wait_queue *queue, int priority) |
@@ -344,8 +344,8 @@ static void rpc_make_runnable(struct rpc_task *task) | |||
344 | static void __rpc_sleep_on(struct rpc_wait_queue *q, struct rpc_task *task, | 344 | static void __rpc_sleep_on(struct rpc_wait_queue *q, struct rpc_task *task, |
345 | rpc_action action, rpc_action timer) | 345 | rpc_action action, rpc_action timer) |
346 | { | 346 | { |
347 | dprintk("RPC: %4d sleep_on(queue \"%s\" time %ld)\n", task->tk_pid, | 347 | dprintk("RPC: %5u sleep_on(queue \"%s\" time %lu)\n", |
348 | rpc_qname(q), jiffies); | 348 | task->tk_pid, rpc_qname(q), jiffies); |
349 | 349 | ||
350 | if (!RPC_IS_ASYNC(task) && !RPC_IS_ACTIVATED(task)) { | 350 | if (!RPC_IS_ASYNC(task) && !RPC_IS_ACTIVATED(task)) { |
351 | printk(KERN_ERR "RPC: Inactive synchronous task put to sleep!\n"); | 351 | printk(KERN_ERR "RPC: Inactive synchronous task put to sleep!\n"); |
@@ -381,7 +381,8 @@ void rpc_sleep_on(struct rpc_wait_queue *q, struct rpc_task *task, | |||
381 | */ | 381 | */ |
382 | static void __rpc_do_wake_up_task(struct rpc_task *task) | 382 | static void __rpc_do_wake_up_task(struct rpc_task *task) |
383 | { | 383 | { |
384 | dprintk("RPC: %4d __rpc_wake_up_task (now %ld)\n", task->tk_pid, jiffies); | 384 | dprintk("RPC: %5u __rpc_wake_up_task (now %lu)\n", |
385 | task->tk_pid, jiffies); | ||
385 | 386 | ||
386 | #ifdef RPC_DEBUG | 387 | #ifdef RPC_DEBUG |
387 | BUG_ON(task->tk_magic != RPC_TASK_MAGIC_ID); | 388 | BUG_ON(task->tk_magic != RPC_TASK_MAGIC_ID); |
@@ -397,7 +398,7 @@ static void __rpc_do_wake_up_task(struct rpc_task *task) | |||
397 | 398 | ||
398 | rpc_make_runnable(task); | 399 | rpc_make_runnable(task); |
399 | 400 | ||
400 | dprintk("RPC: __rpc_wake_up_task done\n"); | 401 | dprintk("RPC: __rpc_wake_up_task done\n"); |
401 | } | 402 | } |
402 | 403 | ||
403 | /* | 404 | /* |
@@ -418,7 +419,7 @@ static void __rpc_wake_up_task(struct rpc_task *task) | |||
418 | static void | 419 | static void |
419 | __rpc_default_timer(struct rpc_task *task) | 420 | __rpc_default_timer(struct rpc_task *task) |
420 | { | 421 | { |
421 | dprintk("RPC: %d timeout (default timer)\n", task->tk_pid); | 422 | dprintk("RPC: %5u timeout (default timer)\n", task->tk_pid); |
422 | task->tk_status = -ETIMEDOUT; | 423 | task->tk_status = -ETIMEDOUT; |
423 | rpc_wake_up_task(task); | 424 | rpc_wake_up_task(task); |
424 | } | 425 | } |
@@ -502,7 +503,8 @@ struct rpc_task * rpc_wake_up_next(struct rpc_wait_queue *queue) | |||
502 | { | 503 | { |
503 | struct rpc_task *task = NULL; | 504 | struct rpc_task *task = NULL; |
504 | 505 | ||
505 | dprintk("RPC: wake_up_next(%p \"%s\")\n", queue, rpc_qname(queue)); | 506 | dprintk("RPC: wake_up_next(%p \"%s\")\n", |
507 | queue, rpc_qname(queue)); | ||
506 | rcu_read_lock_bh(); | 508 | rcu_read_lock_bh(); |
507 | spin_lock(&queue->lock); | 509 | spin_lock(&queue->lock); |
508 | if (RPC_IS_PRIORITY(queue)) | 510 | if (RPC_IS_PRIORITY(queue)) |
@@ -629,8 +631,8 @@ static void __rpc_execute(struct rpc_task *task) | |||
629 | { | 631 | { |
630 | int status = 0; | 632 | int status = 0; |
631 | 633 | ||
632 | dprintk("RPC: %4d rpc_execute flgs %x\n", | 634 | dprintk("RPC: %5u __rpc_execute flags=0x%x\n", |
633 | task->tk_pid, task->tk_flags); | 635 | task->tk_pid, task->tk_flags); |
634 | 636 | ||
635 | BUG_ON(RPC_IS_QUEUED(task)); | 637 | BUG_ON(RPC_IS_QUEUED(task)); |
636 | 638 | ||
@@ -686,7 +688,7 @@ static void __rpc_execute(struct rpc_task *task) | |||
686 | } | 688 | } |
687 | 689 | ||
688 | /* sync task: sleep here */ | 690 | /* sync task: sleep here */ |
689 | dprintk("RPC: %4d sync task going to sleep\n", task->tk_pid); | 691 | dprintk("RPC: %5u sync task going to sleep\n", task->tk_pid); |
690 | /* Note: Caller should be using rpc_clnt_sigmask() */ | 692 | /* Note: Caller should be using rpc_clnt_sigmask() */ |
691 | status = out_of_line_wait_on_bit(&task->tk_runstate, | 693 | status = out_of_line_wait_on_bit(&task->tk_runstate, |
692 | RPC_TASK_QUEUED, rpc_wait_bit_interruptible, | 694 | RPC_TASK_QUEUED, rpc_wait_bit_interruptible, |
@@ -698,16 +700,17 @@ static void __rpc_execute(struct rpc_task *task) | |||
698 | * clean up after sleeping on some queue, we don't | 700 | * clean up after sleeping on some queue, we don't |
699 | * break the loop here, but go around once more. | 701 | * break the loop here, but go around once more. |
700 | */ | 702 | */ |
701 | dprintk("RPC: %4d got signal\n", task->tk_pid); | 703 | dprintk("RPC: %5u got signal\n", task->tk_pid); |
702 | task->tk_flags |= RPC_TASK_KILLED; | 704 | task->tk_flags |= RPC_TASK_KILLED; |
703 | rpc_exit(task, -ERESTARTSYS); | 705 | rpc_exit(task, -ERESTARTSYS); |
704 | rpc_wake_up_task(task); | 706 | rpc_wake_up_task(task); |
705 | } | 707 | } |
706 | rpc_set_running(task); | 708 | rpc_set_running(task); |
707 | dprintk("RPC: %4d sync task resuming\n", task->tk_pid); | 709 | dprintk("RPC: %5u sync task resuming\n", task->tk_pid); |
708 | } | 710 | } |
709 | 711 | ||
710 | dprintk("RPC: %4d, return %d, status %d\n", task->tk_pid, status, task->tk_status); | 712 | dprintk("RPC: %5u return %d, status %d\n", task->tk_pid, status, |
713 | task->tk_status); | ||
711 | /* Release all resources associated with the task */ | 714 | /* Release all resources associated with the task */ |
712 | rpc_release_task(task); | 715 | rpc_release_task(task); |
713 | } | 716 | } |
@@ -824,7 +827,7 @@ void rpc_init_task(struct rpc_task *task, struct rpc_clnt *clnt, int flags, cons | |||
824 | /* starting timestamp */ | 827 | /* starting timestamp */ |
825 | task->tk_start = jiffies; | 828 | task->tk_start = jiffies; |
826 | 829 | ||
827 | dprintk("RPC: %4d new task procpid %d\n", task->tk_pid, | 830 | dprintk("RPC: new task initialized, procpid %u\n", |
828 | current->pid); | 831 | current->pid); |
829 | } | 832 | } |
830 | 833 | ||
@@ -837,7 +840,7 @@ rpc_alloc_task(void) | |||
837 | static void rpc_free_task(struct rcu_head *rcu) | 840 | static void rpc_free_task(struct rcu_head *rcu) |
838 | { | 841 | { |
839 | struct rpc_task *task = container_of(rcu, struct rpc_task, u.tk_rcu); | 842 | struct rpc_task *task = container_of(rcu, struct rpc_task, u.tk_rcu); |
840 | dprintk("RPC: %4d freeing task\n", task->tk_pid); | 843 | dprintk("RPC: %5u freeing task\n", task->tk_pid); |
841 | mempool_free(task, rpc_task_mempool); | 844 | mempool_free(task, rpc_task_mempool); |
842 | } | 845 | } |
843 | 846 | ||
@@ -856,7 +859,7 @@ struct rpc_task *rpc_new_task(struct rpc_clnt *clnt, int flags, const struct rpc | |||
856 | 859 | ||
857 | rpc_init_task(task, clnt, flags, tk_ops, calldata); | 860 | rpc_init_task(task, clnt, flags, tk_ops, calldata); |
858 | 861 | ||
859 | dprintk("RPC: %4d allocated task\n", task->tk_pid); | 862 | dprintk("RPC: allocated task %p\n", task); |
860 | task->tk_flags |= RPC_TASK_DYNAMIC; | 863 | task->tk_flags |= RPC_TASK_DYNAMIC; |
861 | out: | 864 | out: |
862 | return task; | 865 | return task; |
@@ -900,7 +903,7 @@ static void rpc_release_task(struct rpc_task *task) | |||
900 | #ifdef RPC_DEBUG | 903 | #ifdef RPC_DEBUG |
901 | BUG_ON(task->tk_magic != RPC_TASK_MAGIC_ID); | 904 | BUG_ON(task->tk_magic != RPC_TASK_MAGIC_ID); |
902 | #endif | 905 | #endif |
903 | dprintk("RPC: %4d release task\n", task->tk_pid); | 906 | dprintk("RPC: %5u release task\n", task->tk_pid); |
904 | 907 | ||
905 | /* Remove from global task list */ | 908 | /* Remove from global task list */ |
906 | spin_lock(&rpc_sched_lock); | 909 | spin_lock(&rpc_sched_lock); |
@@ -953,7 +956,7 @@ void rpc_killall_tasks(struct rpc_clnt *clnt) | |||
953 | struct rpc_task *rovr; | 956 | struct rpc_task *rovr; |
954 | struct list_head *le; | 957 | struct list_head *le; |
955 | 958 | ||
956 | dprintk("RPC: killing all tasks for client %p\n", clnt); | 959 | dprintk("RPC: killing all tasks for client %p\n", clnt); |
957 | 960 | ||
958 | /* | 961 | /* |
959 | * Spin lock all_tasks to prevent changes... | 962 | * Spin lock all_tasks to prevent changes... |
@@ -982,7 +985,8 @@ static void rpciod_killall(void) | |||
982 | rpc_killall_tasks(NULL); | 985 | rpc_killall_tasks(NULL); |
983 | flush_workqueue(rpciod_workqueue); | 986 | flush_workqueue(rpciod_workqueue); |
984 | if (!list_empty(&all_tasks)) { | 987 | if (!list_empty(&all_tasks)) { |
985 | dprintk("rpciod_killall: waiting for tasks to exit\n"); | 988 | dprintk("RPC: rpciod_killall: waiting for tasks " |
989 | "to exit\n"); | ||
986 | yield(); | 990 | yield(); |
987 | } | 991 | } |
988 | } | 992 | } |
@@ -1002,7 +1006,7 @@ rpciod_up(void) | |||
1002 | int error = 0; | 1006 | int error = 0; |
1003 | 1007 | ||
1004 | mutex_lock(&rpciod_mutex); | 1008 | mutex_lock(&rpciod_mutex); |
1005 | dprintk("rpciod_up: users %d\n", rpciod_users); | 1009 | dprintk("RPC: rpciod_up: users %u\n", rpciod_users); |
1006 | rpciod_users++; | 1010 | rpciod_users++; |
1007 | if (rpciod_workqueue) | 1011 | if (rpciod_workqueue) |
1008 | goto out; | 1012 | goto out; |
@@ -1010,7 +1014,7 @@ rpciod_up(void) | |||
1010 | * If there's no pid, we should be the first user. | 1014 | * If there's no pid, we should be the first user. |
1011 | */ | 1015 | */ |
1012 | if (rpciod_users > 1) | 1016 | if (rpciod_users > 1) |
1013 | printk(KERN_WARNING "rpciod_up: no workqueue, %d users??\n", rpciod_users); | 1017 | printk(KERN_WARNING "rpciod_up: no workqueue, %u users??\n", rpciod_users); |
1014 | /* | 1018 | /* |
1015 | * Create the rpciod thread and wait for it to start. | 1019 | * Create the rpciod thread and wait for it to start. |
1016 | */ | 1020 | */ |
@@ -1032,7 +1036,7 @@ void | |||
1032 | rpciod_down(void) | 1036 | rpciod_down(void) |
1033 | { | 1037 | { |
1034 | mutex_lock(&rpciod_mutex); | 1038 | mutex_lock(&rpciod_mutex); |
1035 | dprintk("rpciod_down sema %d\n", rpciod_users); | 1039 | dprintk("RPC: rpciod_down sema %u\n", rpciod_users); |
1036 | if (rpciod_users) { | 1040 | if (rpciod_users) { |
1037 | if (--rpciod_users) | 1041 | if (--rpciod_users) |
1038 | goto out; | 1042 | goto out; |
@@ -1040,7 +1044,7 @@ rpciod_down(void) | |||
1040 | printk(KERN_WARNING "rpciod_down: no users??\n"); | 1044 | printk(KERN_WARNING "rpciod_down: no users??\n"); |
1041 | 1045 | ||
1042 | if (!rpciod_workqueue) { | 1046 | if (!rpciod_workqueue) { |
1043 | dprintk("rpciod_down: Nothing to do!\n"); | 1047 | dprintk("RPC: rpciod_down: Nothing to do!\n"); |
1044 | goto out; | 1048 | goto out; |
1045 | } | 1049 | } |
1046 | rpciod_killall(); | 1050 | rpciod_killall(); |
@@ -1070,7 +1074,7 @@ void rpc_show_tasks(void) | |||
1070 | if (RPC_IS_QUEUED(t)) | 1074 | if (RPC_IS_QUEUED(t)) |
1071 | rpc_waitq = rpc_qname(t->u.tk_wait.rpc_waitq); | 1075 | rpc_waitq = rpc_qname(t->u.tk_wait.rpc_waitq); |
1072 | 1076 | ||
1073 | printk("%05d %04d %04x %06d %8p %6d %8p %08ld %8s %8p %8p\n", | 1077 | printk("%5u %04d %04x %6d %8p %6d %8p %8ld %8s %8p %8p\n", |
1074 | t->tk_pid, | 1078 | t->tk_pid, |
1075 | (t->tk_msg.rpc_proc ? t->tk_msg.rpc_proc->p_proc : -1), | 1079 | (t->tk_msg.rpc_proc ? t->tk_msg.rpc_proc->p_proc : -1), |
1076 | t->tk_flags, t->tk_status, | 1080 | t->tk_flags, t->tk_status, |