X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lnet%2Fklnds%2Fqswlnd%2Fqswlnd_cb.c;fp=lnet%2Fklnds%2Fqswlnd%2Fqswlnd_cb.c;h=203cddc43c2fcedb1edfa128e1c1f5476326d221;hb=e089a515efae3391709b997be889ebe0f3306e9d;hp=a469d3d517062a94ee87aa5fcd4f1cd0c0308c77;hpb=8c47378b057e72d6125f4baffe8721e0734d0d3f;p=fs%2Flustre-release.git

diff --git a/lnet/klnds/qswlnd/qswlnd_cb.c b/lnet/klnds/qswlnd/qswlnd_cb.c
index a469d3d..203cddc 100644
--- a/lnet/klnds/qswlnd/qswlnd_cb.c
+++ b/lnet/klnds/qswlnd/qswlnd_cb.c
@@ -518,7 +518,7 @@ kqswnal_tx_done (kqswnal_tx_t *ktx, int status)
 
 	cfs_list_add_tail(&ktx->ktx_schedlist,
 			   &kqswnal_data.kqn_donetxds);
-	cfs_waitq_signal(&kqswnal_data.kqn_sched_waitq);
+	wake_up(&kqswnal_data.kqn_sched_waitq);
 
 	spin_unlock_irqrestore(&kqswnal_data.kqn_sched_lock, flags);
 }
@@ -669,7 +669,7 @@ kqswnal_launch (kqswnal_tx_t *ktx)
 
 		cfs_list_add_tail(&ktx->ktx_schedlist,
 				  &kqswnal_data.kqn_delayedtxds);
-		cfs_waitq_signal(&kqswnal_data.kqn_sched_waitq);
+		wake_up(&kqswnal_data.kqn_sched_waitq);
 
 		spin_unlock_irqrestore(&kqswnal_data.kqn_sched_lock,
                                             flags);
@@ -1542,7 +1542,7 @@ kqswnal_rxhandler(EP_RXD *rxd)
 	spin_lock_irqsave(&kqswnal_data.kqn_sched_lock, flags);
 
 	cfs_list_add_tail(&krx->krx_list, &kqswnal_data.kqn_readyrxds);
-	cfs_waitq_signal(&kqswnal_data.kqn_sched_waitq);
+	wake_up(&kqswnal_data.kqn_sched_waitq);
 
 	spin_unlock_irqrestore(&kqswnal_data.kqn_sched_lock, flags);
 }
@@ -1764,15 +1764,15 @@ kqswnal_scheduler (void *arg)
 							kqn_donetxds) ||
 					!cfs_list_empty(&kqswnal_data. \
 							kqn_delayedtxds));
-                                LASSERT (rc == 0);
-                        } else if (need_resched())
-                                cfs_schedule ();
+				LASSERT (rc == 0);
+			} else if (need_resched())
+				schedule ();
 
 			spin_lock_irqsave(&kqswnal_data.kqn_sched_lock,
-                                               flags);
-                }
-        }
+					       flags);
+		}
+	}
 
-        kqswnal_thread_fini ();
-        return (0);
+	kqswnal_thread_fini ();
+	return 0;
 }