int q, l = 0;
register struct proc *xp;
- if(!intr_disabled()) {
- minix_panic("check_runqueues called with interrupts enabled", NO_NUM);
- }
-
FIXME("check_runqueues being done");
#define MYPANIC(msg) { \
varname = ENTERED;
#define NOREC_RETURN(varname, v) do { \
- vmassert(intr_disabled()); \
vmassert(magictest == MAGICTEST); \
vmassert(varname == ENTERED || varname == NOTENTERED); \
varname = NOTENTERED; \
* to be scheduled again.
*/
NOREC_ENTER(schedch);
- vmassert(intr_disabled());
/*
* if the current process is still runnable check the misc flags and let
int r;
int dst_p;
- vmassert(intr_disabled());
-
if (!isokendpt(dst_e, &dst_p)) {
util_stacktrace();
kprintf("mini_notify: bogus endpoint %d\n", dst_e);
NOREC_ENTER(enqueuefunc);
#if DEBUG_SCHED_CHECK
- if(!intr_disabled()) { minix_panic("enqueue with interrupts enabled", NO_NUM); }
if (rp->p_ready) minix_panic("enqueue already ready process", NO_NUM);
#endif
int q; /* scheduling queue to use */
#if DEBUG_SCHED_CHECK
- if(!intr_disabled()) { minix_panic("enqueue with interrupts enabled", NO_NUM); }
if (rp->p_ready) minix_panic("enqueue already ready process", NO_NUM);
#endif
#endif
#if DEBUG_SCHED_CHECK
- if(!intr_disabled()) { minix_panic("dequeue with interrupts enabled", NO_NUM); }
if (! rp->p_ready) minix_panic("dequeue() already unready process", NO_NUM);
#endif
clock_t next_period; /* time of next period */
int ticks_added = 0; /* total time added */
- vmassert(!intr_disabled());
-
for (rp=BEG_PROC_ADDR; rp<END_PROC_ADDR; rp++) {
if (! isemptyp(rp)) { /* check slot use */
if (rp->p_priority > rp->p_max_priority) { /* update priority? */
/* Set flag and dequeue if the process was runnable. */
#define RTS_SET(rp, f) \
do { \
- vmassert(intr_disabled()); \
if(proc_is_runnable(rp)) { dequeue(rp); } \
(rp)->p_rts_flags |= (f); \
- vmassert(intr_disabled()); \
} while(0)
/* Clear flag and enqueue if the process was not runnable but is now. */
#define RTS_UNSET(rp, f) \
do { \
int rts; \
- vmassert(intr_disabled()); \
rts = (rp)->p_rts_flags; \
(rp)->p_rts_flags &= ~(f); \
if(!rts_f_is_runnable(rts) && proc_is_runnable(rp)) { \
enqueue(rp); \
} \
- vmassert(intr_disabled()); \
} while(0)
/* Set flags to this value. */
*/
int proc_nr;
- vmassert(intr_disabled());
-
/* As a side-effect, the interrupt handler gathers random information by
* timestamping the interrupt events. This is used for /dev/random.
*/
priv(proc_addr(proc_nr))->s_int_pending |= (1 << hook->notify_id);
/* Build notification message and return. */
- vmassert(intr_disabled());
mini_notify(proc_addr(HARDWARE), hook->proc_nr_e);
return(hook->policy & IRQ_REENABLE);
}
#define FIXLINMSG(prp) { prp->p_delivermsg_lin = umap_local(prp, D, prp->p_delivermsg_vir, sizeof(message)); }
#define PHYS_COPY_CATCH(src, dst, size, a) { \
- vmassert(intr_disabled()); \
catch_pagefaults++; \
a = phys_copy(src, dst, size); \
catch_pagefaults--; \