LNET_LOCK();
lnet_initialise_handle (&eq->eq_lh, LNET_COOKIE_TYPE_EQ);
- list_add (&eq->eq_list, &the_lnet.ln_active_eqs);
+ cfs_list_add (&eq->eq_list, &the_lnet.ln_active_eqs);
LNET_UNLOCK();
size = eq->eq_size;
lnet_invalidate_handle (&eq->eq_lh);
- list_del (&eq->eq_list);
+ cfs_list_del (&eq->eq_list);
lnet_eq_free (eq);
LNET_UNLOCK();
LNET_LOCK();
for (;;) {
+#ifndef __KERNEL__
+ LNET_UNLOCK();
+
+ /* Recursion breaker */
+ if (the_lnet.ln_rc_state == LNET_RC_STATE_RUNNING &&
+ !LNetHandleIsEqual(eventqs[0], the_lnet.ln_rc_eqh))
+ lnet_router_checker();
+
+ LNET_LOCK();
+#endif
for (i = 0; i < neq; i++) {
lnet_eq_t *eq = lnet_handle2eq(&eventqs[i]);
}
cfs_waitlink_init(&wl);
- set_current_state(TASK_INTERRUPTIBLE);
+ cfs_set_current_state(CFS_TASK_INTERRUPTIBLE);
cfs_waitq_add(&the_lnet.ln_waitq, &wl);
LNET_UNLOCK();