|
|
|
|
275
|
camd_do_msg(msg);
|
275
|
camd_do_msg(msg);
|
276
|
|
276
|
|
277
|
if (ts->camd.ecm_queue->items >= ECM_QUEUE_HARD_LIMIT) {
|
277
|
if (ts->camd.ecm_queue->items >= ECM_QUEUE_HARD_LIMIT) {
|
278
|
- ts_LOGf("WRN | Too much items (%d) in ECM queue, dropping the oldest.\n", ts->camd.ecm_queue->items);
|
|
|
|
|
278
|
+ ts_LOGf("WRN | Too many items (%d) in ECM queue, dropping the oldest.\n", ts->camd.ecm_queue->items);
|
279
|
while(ts->camd.ecm_queue->items >= ECM_QUEUE_SOFT_LIMIT) {
|
279
|
while(ts->camd.ecm_queue->items >= ECM_QUEUE_SOFT_LIMIT) {
|
280
|
msg = queue_get_nowait(ts->camd.ecm_queue);
|
280
|
msg = queue_get_nowait(ts->camd.ecm_queue);
|
281
|
camd_msg_free(&msg);
|
281
|
camd_msg_free(&msg);
|
|
|
|
|
283
|
}
|
283
|
}
|
284
|
|
284
|
|
285
|
if (ts->camd.emm_queue->items >= EMM_QUEUE_HARD_LIMIT) {
|
285
|
if (ts->camd.emm_queue->items >= EMM_QUEUE_HARD_LIMIT) {
|
286
|
- ts_LOGf("WRN | Too much items (%d) in EMM queue, dropping the oldest.%s\n",
|
|
|
|
|
286
|
+ ts_LOGf("WRN | Too many items (%d) in EMM queue, dropping the oldest.%s\n",
|
287
|
ts->camd.emm_queue->items, ts->camd.ops.proto == CAMD_NEWCAMD ?
|
287
|
ts->camd.emm_queue->items, ts->camd.ops.proto == CAMD_NEWCAMD ?
|
288
|
" Consider switching to cs378x protocol!" : "");
|
288
|
" Consider switching to cs378x protocol!" : "");
|
289
|
while(ts->camd.emm_queue->items >= EMM_QUEUE_SOFT_LIMIT) {
|
289
|
while(ts->camd.emm_queue->items >= EMM_QUEUE_SOFT_LIMIT) {
|