|
@@ -285,7 +285,9 @@ void deq_msg()
|
|
|
* queue.
|
|
* queue.
|
|
|
*/
|
|
*/
|
|
|
egg_timeval_t last_time_save = { last_time.sec, last_time.usec };
|
|
egg_timeval_t last_time_save = { last_time.sec, last_time.usec };
|
|
|
|
|
+#ifdef DEBUG
|
|
|
bool bursted = 0;
|
|
bool bursted = 0;
|
|
|
|
|
+#endif
|
|
|
// -1 here to avoid DP_CACHE
|
|
// -1 here to avoid DP_CACHE
|
|
|
for(size_t nq = 0; nq < (sizeof(qdsc) / sizeof(qdsc[0])) - 1; ++nq) {
|
|
for(size_t nq = 0; nq < (sizeof(qdsc) / sizeof(qdsc[0])) - 1; ++nq) {
|
|
|
while (qdsc[nq].q->head &&
|
|
while (qdsc[nq].q->head &&
|
|
@@ -312,10 +314,13 @@ void deq_msg()
|
|
|
free(qdsc[nq].q->head->msg);
|
|
free(qdsc[nq].q->head->msg);
|
|
|
free(qdsc[nq].q->head);
|
|
free(qdsc[nq].q->head);
|
|
|
qdsc[nq].q->head = q;
|
|
qdsc[nq].q->head = q;
|
|
|
- if (qdsc[nq].burst)
|
|
|
|
|
- bursted = 1;
|
|
|
|
|
- else // Help Queue does not burst, push out 1 line then go to next queue.
|
|
|
|
|
|
|
+ if (!qdsc[nq].burst) {
|
|
|
|
|
+ // Help Queue does not burst, push out 1 line then go to next queue.
|
|
|
break;
|
|
break;
|
|
|
|
|
+ }
|
|
|
|
|
+#ifdef DEBUG
|
|
|
|
|
+ bursted = 1;
|
|
|
|
|
+#endif
|
|
|
}
|
|
}
|
|
|
if (!qdsc[nq].q->head)
|
|
if (!qdsc[nq].q->head)
|
|
|
qdsc[nq].q->last = NULL;
|
|
qdsc[nq].q->last = NULL;
|