return (0);
}
-
-int kptllnd_process_scheduled_tx(kptl_data_t *kptllnd_data)
-{
- kptl_tx_t *tx = NULL;
- unsigned long flags;
-
- spin_lock_irqsave(&kptllnd_data->kptl_sched_lock, flags);
-
- /*
- * If the list is not empty, grab the first one
- * and pull it off the list
- */
- if(!list_empty(&kptllnd_data->kptl_sched_txq)){
- tx = list_entry (kptllnd_data->kptl_sched_txq.next,
- kptl_tx_t, tx_schedlist);
- list_del_init(&tx->tx_schedlist);
- }
-
- spin_unlock_irqrestore(&kptllnd_data->kptl_sched_lock, flags);
-
- if(tx){
- PJK_UT_MSG(">>> tx=%p\n",tx);
- kptllnd_tx_done(tx);
- PJK_UT_MSG("<<<\n");
- }
-
- return tx!=NULL;
-}
-
-int kptllnd_process_scheduled_rx(kptl_data_t *kptllnd_data)
-{
- kptl_rx_t *rx = NULL;
- unsigned long flags;
-
- spin_lock_irqsave(&kptllnd_data->kptl_sched_lock, flags);
-
- /*
- * If the list is not empty, grab the first one
- * and pull it off the list
- */
- if(!list_empty(&kptllnd_data->kptl_sched_rxq)){
- rx = list_entry (kptllnd_data->kptl_sched_rxq.next,
- kptl_rx_t, rx_list);
- list_del_init(&rx->rx_list);
- }
-
- spin_unlock_irqrestore(&kptllnd_data->kptl_sched_lock, flags);
-
- if(rx)
- kptllnd_rx_scheduler_handler(rx);
-
- return rx!=NULL;
-}
-
-int kptllnd_process_scheduled_rxb(kptl_data_t *kptllnd_data)
-{
- kptl_rx_buffer_t *rxb = NULL;
- unsigned long flags;
-
- spin_lock_irqsave(&kptllnd_data->kptl_sched_lock, flags);
-
- /*
- * If the list is not empty, grab the first one
- * and pull it off the list
- */
- if(!list_empty(&kptllnd_data->kptl_sched_rxbq)){
- rxb = list_entry (kptllnd_data->kptl_sched_rxbq.next,
- kptl_rx_buffer_t, rxb_repost_list);
- list_del_init(&rxb->rxb_repost_list);
- }
-
- spin_unlock_irqrestore(&kptllnd_data->kptl_sched_lock, flags);
-
- if(rxb)
- kptllnd_rx_buffer_post_handle_error(rxb);
-
- return rxb!=NULL;
-}
-
void kptllnd_clean_canceled_peers(kptl_data_t *kptllnd_data)
{
unsigned long flags;