forked/ustreamer
1
0
Fork 0
mirror of https://github.com/pikvm/ustreamer.git synced 2026-03-12 18:43:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactoring

Browse Source
This commit is contained in:
Maxim Devaev
2024-04-04 23:25:06 +03:00
parent fca69db680
commit c40b3ee225
1 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/ustreamer/stream.c
View File

@@ -313,23 +313,23 @@ static void *_jpeg_thread(void *v_ctx) {
uint fluency_passed = 0; uint fluency_passed = 0;
while (!atomic_load(ctx->stop)) { while (!atomic_load(ctx->stop)) {
us_worker_s *const ready_wr = us_workers_pool_wait(stream->enc->run->pool); us_worker_s *const wr = us_workers_pool_wait(stream->enc->run->pool);
us_encoder_job_s *const ready_job = ready_wr->job; us_encoder_job_s *const job = wr->job;
if (ready_job->hw != NULL) { if (job->hw != NULL) {
us_capture_hwbuf_decref(ready_job->hw); us_capture_hwbuf_decref(job->hw);
ready_job->hw = NULL; job->hw = NULL;
if (ready_wr->job_failed) { if (wr->job_failed) {
// pass // pass
} else if (ready_wr->job_timely) { } else if (wr->job_timely) {
_stream_expose_jpeg(stream, ready_job->dest); _stream_expose_jpeg(stream, job->dest);
if (atomic_load(&stream->run->http->snapshot_requested) > 0) { // Process real snapshots if (atomic_load(&stream->run->http->snapshot_requested) > 0) { // Process real snapshots
atomic_fetch_sub(&stream->run->http->snapshot_requested, 1); atomic_fetch_sub(&stream->run->http->snapshot_requested, 1);
} }
US_LOG_PERF("JPEG: ##### Encoded JPEG exposed; worker=%s, latency=%.3Lf", US_LOG_PERF("JPEG: ##### Encoded JPEG exposed; worker=%s, latency=%.3Lf",
ready_wr->name, us_get_now_monotonic() - ready_job->dest->grab_ts); wr->name, us_get_now_monotonic() - job->dest->grab_ts);
} else { } else {
US_LOG_PERF("JPEG: ----- Encoded JPEG dropped; worker=%s", ready_wr->name); US_LOG_PERF("JPEG: ----- Encoded JPEG dropped; worker=%s", wr->name);
} }
} }
@@ -355,13 +355,13 @@ static void *_jpeg_thread(void *v_ctx) {
} }
fluency_passed = 0; fluency_passed = 0;
const ldf fluency_delay = us_workers_pool_get_fluency_delay(stream->enc->run->pool, ready_wr); const ldf fluency_delay = us_workers_pool_get_fluency_delay(stream->enc->run->pool, wr);
grab_after_ts = now_ts + fluency_delay; grab_after_ts = now_ts + fluency_delay;
US_LOG_VERBOSE("JPEG: Fluency: delay=%.03Lf, grab_after=%.03Lf", fluency_delay, grab_after_ts); US_LOG_VERBOSE("JPEG: Fluency: delay=%.03Lf, grab_after=%.03Lf", fluency_delay, grab_after_ts);
ready_job->hw = hw; job->hw = hw;
us_workers_pool_assign(stream->enc->run->pool, ready_wr); us_workers_pool_assign(stream->enc->run->pool, wr);
US_LOG_DEBUG("JPEG: Assigned new frame in buffer=%d to worker=%s", hw->buf.index, ready_wr->name); US_LOG_DEBUG("JPEG: Assigned new frame in buffer=%d to worker=%s", hw->buf.index, wr->name);
} }
return NULL; return NULL;
} }