secc
/
l4ka-pistachio
mirror of https://github.com/l4ka/pistachio.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Remove doubled IRQ handling code

This commit is contained in:
Jan Stoess 2010-04-12 14:47:39 +02:00
parent d52a5e203d
commit dcfd5b3719
2 changed files with 0 additions and 66 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
kernel/src/api/v4/sched-hs/schedule_functions.h
View File

@ -427,40 +427,7 @@ INLINE bool scheduler_t::schedule(tcb_t *dest1, tcb_t *dest2, const sched_flags_
INLINE bool scheduler_t::schedule_interrupt(tcb_t *irq, tcb_t *handler)
{
threadid_t irq_tid = irq->get_global_id();
if (EXPECT_TRUE(handler->get_state().is_waiting() ))
{
// thread is waiting for IPC -- we use a shortcut
threadid_t partner = handler->get_partner();
if (EXPECT_TRUE( partner == irq_tid || partner.is_anythread() ))
{
// set IRQ thread to be waiting for the ack IPC
irq->set_partner(handler->get_global_id());
irq->set_state(thread_state_t::waiting_forever);
#if defined(CONFIG_SMP)
if (!handler->is_local_cpu())
{
xcpu_request( handler->get_cpu(), do_xcpu_send_irq, handler,
irq->get_global_id().get_irqno());
return true;
}
#endif
// deliver IPC
handler->set_tag(msg_tag_t::irq_tag());
handler->set_partner(irq_tid);
handler->set_state(thread_state_t::running);
/* we enter this path only if the handler is waiting -- so
* we are not currently execuing on its TCB */
schedule(handler);
return true;
}
}
irq->set_tag(msg_tag_t::irq_tag());
irq->set_partner(handler->get_global_id());
irq->set_state(thread_state_t::polling);

33
kernel/src/api/v4/sched-rr/schedule_functions.h
View File

@ -297,40 +297,7 @@ INLINE bool scheduler_t::schedule(tcb_t *dest1, tcb_t *dest2, const sched_flags_
INLINE bool scheduler_t::schedule_interrupt(tcb_t *irq, tcb_t *handler)
{
threadid_t irq_tid = irq->get_global_id();
if (EXPECT_TRUE(handler->get_state().is_waiting() ))
{
// thread is waiting for IPC -- we use a shortcut
threadid_t partner = handler->get_partner();
if (EXPECT_TRUE( partner == irq_tid || partner.is_anythread() ))
{
// set IRQ thread to be waiting for the ack IPC
irq->set_partner(handler->get_global_id());
irq->set_state(thread_state_t::waiting_forever);
#if defined(CONFIG_SMP)
if (!handler->is_local_cpu())
{
xcpu_request( handler->get_cpu(), do_xcpu_send_irq, handler,
irq->get_global_id().get_irqno());
return true;
}
#endif
// deliver IPC
handler->set_tag(msg_tag_t::irq_tag());
handler->set_partner(irq_tid);
handler->set_state(thread_state_t::running);
/* we enter this path only if the handler is waiting -- so
* we are not currently execuing on its TCB */
schedule(handler);
return true;
}
}
irq->set_tag(msg_tag_t::irq_tag());
irq->set_partner(handler->get_global_id());
irq->set_state(thread_state_t::polling);