diff options
Diffstat (limited to 'fs/dlm/lowcomms-sctp.c')
-rw-r--r-- | fs/dlm/lowcomms-sctp.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/fs/dlm/lowcomms-sctp.c b/fs/dlm/lowcomms-sctp.c index fe158d7a9285..0940a805b3d7 100644 --- a/fs/dlm/lowcomms-sctp.c +++ b/fs/dlm/lowcomms-sctp.c | |||
@@ -1109,7 +1109,7 @@ static int dlm_recvd(void *data) | |||
1109 | set_current_state(TASK_INTERRUPTIBLE); | 1109 | set_current_state(TASK_INTERRUPTIBLE); |
1110 | add_wait_queue(&lowcomms_recv_wait, &wait); | 1110 | add_wait_queue(&lowcomms_recv_wait, &wait); |
1111 | if (!test_bit(CF_READ_PENDING, &sctp_con.flags)) | 1111 | if (!test_bit(CF_READ_PENDING, &sctp_con.flags)) |
1112 | cond_resched(); | 1112 | schedule(); |
1113 | remove_wait_queue(&lowcomms_recv_wait, &wait); | 1113 | remove_wait_queue(&lowcomms_recv_wait, &wait); |
1114 | set_current_state(TASK_RUNNING); | 1114 | set_current_state(TASK_RUNNING); |
1115 | 1115 | ||
@@ -1141,7 +1141,7 @@ static int dlm_sendd(void *data) | |||
1141 | while (!kthread_should_stop()) { | 1141 | while (!kthread_should_stop()) { |
1142 | set_current_state(TASK_INTERRUPTIBLE); | 1142 | set_current_state(TASK_INTERRUPTIBLE); |
1143 | if (write_list_empty()) | 1143 | if (write_list_empty()) |
1144 | cond_resched(); | 1144 | schedule(); |
1145 | set_current_state(TASK_RUNNING); | 1145 | set_current_state(TASK_RUNNING); |
1146 | 1146 | ||
1147 | if (sctp_con.eagain_flag) { | 1147 | if (sctp_con.eagain_flag) { |