97,15 → 97,22 |
|
decoder_arg_ptr darg = (decoder_arg_ptr)(arg); |
int i,Q,R; |
struct timespec current; |
|
while(1) { |
|
cprintf("Decoder Start %d Frame %d\n",exec_shadow,darg->frame_number); |
|
for (i=0;i<100;i++); |
for (i=0;i<100;i++) { |
if (MPEGSTAR_is_frame_skipped(darg->server_id)) { |
kern_printf("Skipping this frame\n"); |
break; |
} |
kern_gettime(¤t); |
} |
|
Q = MPEGSTAR_get_remain_capacity(darg->server_id); |
R = MPEGSTAR_get_last_reclaiming(); |
R = MPEGSTAR_get_last_reclaiming(darg->server_id); |
printf_xy(55,10+exec_shadow,WHITE,"[S%02d:Q%06d:R%06d]",darg->server_id,Q,R); |
|
cprintf("Decoder End %d\n",exec_shadow); |
175,17 → 182,17 |
decoder_arg_table[server_I]->frame_type = FRAME_I; |
task_activate(pI); |
|
T = 100000; |
T = 150000; |
Q = 10000; |
MPEGSTAR_rescale(server_P,Q,T); |
decoder_arg_table[server_P]->frame_number = 1; |
decoder_arg_table[server_P]->frame_number = 2; |
decoder_arg_table[server_P]->frame_type = FRAME_P; |
task_activate(pP); |
|
T = 150000; |
T = 100000; |
Q = 10000; |
MPEGSTAR_rescale(server_B,Q,T); |
decoder_arg_table[server_B]->frame_number = 2; |
decoder_arg_table[server_B]->frame_number = 1; |
decoder_arg_table[server_B]->frame_type = FRAME_B; |
task_activate(pB); |
|