Loading libs/vr/libdvr/dvr_buffer_queue.cpp +7 −0 Original line number Diff line number Diff line Loading @@ -302,6 +302,13 @@ int dvrReadBufferQueueGetId(DvrReadBufferQueue* read_queue) { return read_queue->id(); } int dvrReadBufferQueueGetEventFd(DvrReadBufferQueue* read_queue) { if (!read_queue) return -EINVAL; return read_queue->event_fd(); } int dvrReadBufferQueueCreateReadQueue(DvrReadBufferQueue* read_queue, DvrReadBufferQueue** out_read_queue) { if (!read_queue || !out_read_queue) Loading libs/vr/libdvr/dvr_buffer_queue_internal.h +1 −0 Original line number Diff line number Diff line Loading @@ -49,6 +49,7 @@ struct DvrReadBufferQueue { const std::shared_ptr<ConsumerQueue>& consumer_queue); int id() const { return consumer_queue_->id(); } int event_fd() const { return consumer_queue_->queue_fd(); } size_t capacity() const { return consumer_queue_->capacity(); } int CreateReadQueue(DvrReadBufferQueue** out_read_queue); Loading libs/vr/libdvr/include/dvr/dvr_api.h +1 −0 Original line number Diff line number Diff line Loading @@ -177,6 +177,7 @@ typedef void (*DvrReadBufferQueueDestroyPtr)(DvrReadBufferQueue* read_queue); typedef ssize_t (*DvrReadBufferQueueGetCapacityPtr)( DvrReadBufferQueue* read_queue); typedef int (*DvrReadBufferQueueGetIdPtr)(DvrReadBufferQueue* read_queue); typedef int (*DvrReadBufferQueueGetEventFdPtr)(DvrReadBufferQueue* read_queue); typedef int (*DvrReadBufferQueueCreateReadQueuePtr)( DvrReadBufferQueue* read_queue, DvrReadBufferQueue** out_read_queue); typedef int (*DvrReadBufferQueueDequeuePtr)(DvrReadBufferQueue* read_queue, Loading libs/vr/libdvr/include/dvr/dvr_api_entries.h +3 −0 Original line number Diff line number Diff line Loading @@ -157,3 +157,6 @@ DVR_V1_API_ENTRY(PerformanceSetSchedulerPolicy); // Pose client DVR_V1_API_ENTRY(PoseClientSensorsEnable); // Read buffer queue DVR_V1_API_ENTRY(ReadBufferQueueGetEventFd); libs/vr/libdvr/include/dvr/dvr_buffer_queue.h +8 −0 Original line number Diff line number Diff line Loading @@ -102,6 +102,14 @@ ssize_t dvrReadBufferQueueGetCapacity(DvrReadBufferQueue* read_queue); // @return Queue id on success; or negative error code. int dvrReadBufferQueueGetId(DvrReadBufferQueue* read_queue); // Get the event fd that signals when queue updates occur. // // Use ReadBufferQueueHandleEvents to trigger registered event callbacks. // // @param read_queue The DvrReadBufferQueue of interest. // @return Fd on success; or negative error code. int dvrReadBufferQueueGetEventFd(DvrReadBufferQueue* read_queue); // Create a read buffer queue from an existing read buffer queue. // // @param read_queue The DvrReadBufferQueue of interest. Loading Loading
libs/vr/libdvr/dvr_buffer_queue.cpp +7 −0 Original line number Diff line number Diff line Loading @@ -302,6 +302,13 @@ int dvrReadBufferQueueGetId(DvrReadBufferQueue* read_queue) { return read_queue->id(); } int dvrReadBufferQueueGetEventFd(DvrReadBufferQueue* read_queue) { if (!read_queue) return -EINVAL; return read_queue->event_fd(); } int dvrReadBufferQueueCreateReadQueue(DvrReadBufferQueue* read_queue, DvrReadBufferQueue** out_read_queue) { if (!read_queue || !out_read_queue) Loading
libs/vr/libdvr/dvr_buffer_queue_internal.h +1 −0 Original line number Diff line number Diff line Loading @@ -49,6 +49,7 @@ struct DvrReadBufferQueue { const std::shared_ptr<ConsumerQueue>& consumer_queue); int id() const { return consumer_queue_->id(); } int event_fd() const { return consumer_queue_->queue_fd(); } size_t capacity() const { return consumer_queue_->capacity(); } int CreateReadQueue(DvrReadBufferQueue** out_read_queue); Loading
libs/vr/libdvr/include/dvr/dvr_api.h +1 −0 Original line number Diff line number Diff line Loading @@ -177,6 +177,7 @@ typedef void (*DvrReadBufferQueueDestroyPtr)(DvrReadBufferQueue* read_queue); typedef ssize_t (*DvrReadBufferQueueGetCapacityPtr)( DvrReadBufferQueue* read_queue); typedef int (*DvrReadBufferQueueGetIdPtr)(DvrReadBufferQueue* read_queue); typedef int (*DvrReadBufferQueueGetEventFdPtr)(DvrReadBufferQueue* read_queue); typedef int (*DvrReadBufferQueueCreateReadQueuePtr)( DvrReadBufferQueue* read_queue, DvrReadBufferQueue** out_read_queue); typedef int (*DvrReadBufferQueueDequeuePtr)(DvrReadBufferQueue* read_queue, Loading
libs/vr/libdvr/include/dvr/dvr_api_entries.h +3 −0 Original line number Diff line number Diff line Loading @@ -157,3 +157,6 @@ DVR_V1_API_ENTRY(PerformanceSetSchedulerPolicy); // Pose client DVR_V1_API_ENTRY(PoseClientSensorsEnable); // Read buffer queue DVR_V1_API_ENTRY(ReadBufferQueueGetEventFd);
libs/vr/libdvr/include/dvr/dvr_buffer_queue.h +8 −0 Original line number Diff line number Diff line Loading @@ -102,6 +102,14 @@ ssize_t dvrReadBufferQueueGetCapacity(DvrReadBufferQueue* read_queue); // @return Queue id on success; or negative error code. int dvrReadBufferQueueGetId(DvrReadBufferQueue* read_queue); // Get the event fd that signals when queue updates occur. // // Use ReadBufferQueueHandleEvents to trigger registered event callbacks. // // @param read_queue The DvrReadBufferQueue of interest. // @return Fd on success; or negative error code. int dvrReadBufferQueueGetEventFd(DvrReadBufferQueue* read_queue); // Create a read buffer queue from an existing read buffer queue. // // @param read_queue The DvrReadBufferQueue of interest. Loading