i = 2;
while (cfs_atomic_read (&kptllnd_data.kptl_nthreads) != 0) {
/* Wake up all threads*/
- cfs_wake_up_all(&kptllnd_data.kptl_sched_waitq);
- cfs_wake_up_all(&kptllnd_data.kptl_watchdog_waitq);
+ cfs_waitq_broadcast(&kptllnd_data.kptl_sched_waitq);
+ cfs_waitq_broadcast(&kptllnd_data.kptl_watchdog_waitq);
i++;
CDEBUG(((i & (-i)) == i) ? D_WARNING : D_NET, /* power of 2? */
/* Setup the sched locks/lists/waitq */
cfs_spin_lock_init(&kptllnd_data.kptl_sched_lock);
- cfs_init_waitqueue_head(&kptllnd_data.kptl_sched_waitq);
+ cfs_waitq_init(&kptllnd_data.kptl_sched_waitq);
CFS_INIT_LIST_HEAD(&kptllnd_data.kptl_sched_txq);
CFS_INIT_LIST_HEAD(&kptllnd_data.kptl_sched_rxq);
CFS_INIT_LIST_HEAD(&kptllnd_data.kptl_sched_rxbq);
kptllnd_data.kptl_nak_msg->ptlm_srcstamp = kptllnd_data.kptl_incarnation;
cfs_rwlock_init(&kptllnd_data.kptl_peer_rw_lock);
- cfs_init_waitqueue_head(&kptllnd_data.kptl_watchdog_waitq);
+ cfs_waitq_init(&kptllnd_data.kptl_watchdog_waitq);
cfs_atomic_set(&kptllnd_data.kptl_needs_ptltrace, 0);
CFS_INIT_LIST_HEAD(&kptllnd_data.kptl_closing_peers);
CFS_INIT_LIST_HEAD(&kptllnd_data.kptl_zombie_peers);