Measure processing latency

This commit is contained in:
Kamil Trzcinski 2022-04-07 12:44:36 +02:00
parent a56886cb6c
commit 944b051daa
3 changed files with 7 additions and 3 deletions

View File

@ -17,6 +17,7 @@ typedef struct buffer_s {
int mmap_reflinks; int mmap_reflinks;
struct buffer_s *mmap_source; struct buffer_s *mmap_source;
bool enqueued; bool enqueued;
uint64_t enqueue_time_us;
} buffer_t; } buffer_t;
buffer_t *buffer_open(const char *name, struct buffer_list_s *buf_list, int buffer); buffer_t *buffer_open(const char *name, struct buffer_list_s *buf_list, int buffer);

View File

@ -43,11 +43,13 @@ void buffer_lock_capture(buffer_lock_t *buf_lock, buffer_t *buf)
buffer_use(buf); buffer_use(buf);
buf_lock->buf = buf; buf_lock->buf = buf;
buf_lock->counter++; buf_lock->counter++;
buf_lock->buf_time_us = get_monotonic_time_us(NULL, NULL); uint64_t last_lock_us = buf_lock->buf_time_us;
uint64_t captured_time_us = get_time_us(CLOCK_FROM_PARAMS, NULL, &buf->v4l2_buffer.timestamp, 0); uint64_t captured_time_us = get_time_us(CLOCK_FROM_PARAMS, NULL, &buf->v4l2_buffer.timestamp, 0);
E_LOG_DEBUG(buf_lock, "Captured buffer %s (refs=%d), frame=%d, delay=%.1f", buf_lock->buf_time_us = get_monotonic_time_us(NULL, NULL);
E_LOG_DEBUG(buf_lock, "Captured buffer %s (refs=%d), frame=%d, processing_us=%.1f, frame_us=%.1f",
dev_name(buf), buf ? buf->mmap_reflinks : 0, buf_lock->counter, dev_name(buf), buf ? buf->mmap_reflinks : 0, buf_lock->counter,
(buf_lock->buf_time_us - captured_time_us) / 1000.0f); (buf_lock->buf_time_us - captured_time_us) / 1000.0f,
(buf_lock->buf_time_us - last_lock_us) / 1000.0f);
pthread_cond_broadcast(&buf_lock->cond_wait); pthread_cond_broadcast(&buf_lock->cond_wait);
pthread_mutex_unlock(&buf_lock->lock); pthread_mutex_unlock(&buf_lock->lock);
} }

View File

@ -58,6 +58,7 @@ bool buffer_consumed(buffer_t *buf, const char *who)
E_XIOCTL(buf, buf->buf_list->device->fd, VIDIOC_QBUF, &buf->v4l2_buffer, "Can't queue buffer."); E_XIOCTL(buf, buf->buf_list->device->fd, VIDIOC_QBUF, &buf->v4l2_buffer, "Can't queue buffer.");
buf->enqueued = true; buf->enqueued = true;
buf->enqueue_time_us = get_monotonic_time_us(NULL, NULL);
} }
pthread_mutex_unlock(&buffer_lock); pthread_mutex_unlock(&buffer_lock);