forked/ustreamer
1
0
Fork 0
mirror of https://github.com/pikvm/ustreamer.git synced 2026-05-26 23:36:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

better msg

Browse Source
This commit is contained in:
Devaev Maxim
2018-10-04 11:35:18 +03:00
parent ec738b18dc
commit 93c6248fdb
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/stream.c
View File

@@ -111,7 +111,7 @@ void stream_loop(struct stream_t *stream) {
free_worker_number = oldest_worker->ctx.number; free_worker_number = oldest_worker->ctx.number;
oldest_worker = oldest_worker->order_next; oldest_worker = oldest_worker->order_next;
LOG_PERF("##### ACCEPT : %u", free_worker_number); LOG_PERF("##### Raw frame accepted; worker = %u", free_worker_number);
} else { } else {
for (unsigned number = 0; number < stream->dev->run->n_workers; ++number) { for (unsigned number = 0; number < stream->dev->run->n_workers; ++number) {
if (!pool.workers[number].has_job && (free_worker_number == -1 if (!pool.workers[number].has_job && (free_worker_number == -1
@@ -125,7 +125,7 @@ void stream_loop(struct stream_t *stream) {
assert(free_worker_number >= 0); assert(free_worker_number >= 0);
assert(!pool.workers[free_worker_number].has_job); assert(!pool.workers[free_worker_number].has_job);
LOG_PERF("----- DROP : %u", free_worker_number); LOG_PERF("----- Raw frame dropped; worker = %u", free_worker_number);
} }
if (stream->dev->stop) { if (stream->dev->stop) {