231,10 → 231,7 |
SUBTIMESPEC(&b->dline, acttime, &t2); |
if (/* 1 */ TIMESPEC_A_LT_B(&b->dline, acttime) || |
/* 2 */ TIMESPEC_A_GT_B(&t3, &t2) ) { |
TIMESPEC_ASSIGN(&b->replenish, acttime); |
ADDUSEC2TIMESPEC(b->T, &b->replenish); |
TIMESPEC_ASSIGN(&b->dline, acttime); |
ADDUSEC2TIMESPEC(b->D, &b->dline); |
|
if (b->negotiation) { |
lev->negotiation_in_progress--; |
b->negotiation=0; |
246,7 → 243,10 |
b->N_T=0; |
b->N_D=0; |
} |
|
TIMESPEC_ASSIGN(&b->replenish, acttime); |
ADDUSEC2TIMESPEC(b->T, &b->replenish); |
TIMESPEC_ASSIGN(&b->dline, acttime); |
ADDUSEC2TIMESPEC(b->D, &b->dline); |
b->avail = b->Q; |
b->last_reclaiming = 0; |
} |
336,9 → 336,9 |
JOB_TASK_MODEL job; |
|
if ( TIMESPEC_A_LT_B(&b->dline, &schedule_time)) { |
#ifdef GRUBSTAR_DEBUG |
// #ifdef GRUBSTAR_DEBUG |
kern_printf("(GS:Eli:%d)",p); |
#endif |
// #endif |
if (lev->cap_lev!=NIL) { |
kern_event_delete(lev->cap_lev); |
lev->cap_lev=NIL; |
348,12 → 348,6 |
level_table[ lev->scheduling_level ]-> |
private_extract(lev->scheduling_level, p); |
|
/* we modify the deadline ... */ |
kern_gettime(&b->replenish); |
TIMESPEC_ASSIGN(&b->dline, &b->replenish); |
ADDUSEC2TIMESPEC(b->D, &b->dline); |
ADDUSEC2TIMESPEC(b->T, &b->replenish); |
|
/* and the capacity */ |
if (b->negotiation) { |
lev->negotiation_in_progress--; |
366,6 → 360,13 |
b->N_T=0; |
b->N_D=0; |
} |
|
/* we modify the deadline ... */ |
kern_gettime(&b->replenish); |
TIMESPEC_ASSIGN(&b->dline, &b->replenish); |
ADDUSEC2TIMESPEC(b->D, &b->dline); |
ADDUSEC2TIMESPEC(b->T, &b->replenish); |
|
b->avail = b->Q; |
b->last_reclaiming = 0; |
|