WIP: async preview

drawpile · Aug 17, 2023 · 712830c · 712830c
1 parent 9140fb6
commit 712830c
Show file tree

Hide file tree

Showing 10 changed files with 963 additions and 473 deletions.
diff --git a/src/drawdance/libcommon/dpcommon/queue.c b/src/drawdance/libcommon/dpcommon/queue.c
@@ -82,6 +82,24 @@ static size_t resize(DP_Queue *queue, size_t old_capacity, size_t element_size)
     return new_capacity;
 }
 
+void *DP_queue_unshift(DP_Queue *queue, size_t element_size)
+{
+    DP_ASSERT(queue);
+    DP_ASSERT(element_size > 0);
+    DP_ASSERT(queue->capacity > 0);
+    DP_ASSERT(queue->used <= queue->capacity);
+    size_t used = queue->used;
+    size_t capacity = queue->capacity;
+    if (used == capacity) {
+        capacity = resize(queue, capacity, element_size);
+    }
+    size_t head = queue->head;
+    size_t new_head = head == 0 ? capacity - 1 : head - 1;
+    queue->head = new_head;
+    queue->used = used + 1;
+    return element_at(queue, new_head, element_size);
+}
+
 void *DP_queue_push(DP_Queue *queue, size_t element_size)
 {
     DP_ASSERT(queue);
@@ -196,3 +214,22 @@ size_t DP_queue_search_index(DP_Queue *queue, size_t element_size,
     }
     return used;
 }
+
+size_t DP_queue_search_last_index(DP_Queue *queue, size_t element_size,
+                                  bool (*predicate)(void *element, void *user),
+                                  void *user)
+{
+    DP_ASSERT(queue);
+    DP_ASSERT(predicate);
+    size_t capacity = queue->capacity;
+    size_t used = queue->used;
+    size_t head = queue->head;
+    for (size_t i = 0; i < used; ++i) {
+        size_t j = used - i - 1;
+        void *element = element_at(queue, (head + j) % capacity, element_size);
+        if (predicate(element, user)) {
+            return j;
+        }
+    }
+    return used;
+}
diff --git a/src/drawdance/libcommon/dpcommon/queue.h b/src/drawdance/libcommon/dpcommon/queue.h
@@ -46,6 +46,8 @@ void DP_queue_dispose(DP_Queue *queue);
 void DP_queue_clear(DP_Queue *queue, size_t element_size,
                     void (*dispose_element)(void *));
 
+void *DP_queue_unshift(DP_Queue *queue, size_t element_size);
+
 void *DP_queue_push(DP_Queue *queue, size_t element_size);
 
 void *DP_queue_peek(DP_Queue *queue, size_t element_size);
@@ -71,5 +73,9 @@ size_t DP_queue_search_index(DP_Queue *queue, size_t element_size,
                              bool (*predicate)(void *element, void *user),
                              void *user);
 
+size_t DP_queue_search_last_index(DP_Queue *queue, size_t element_size,
+                                  bool (*predicate)(void *element, void *user),
+                                  void *user);
+
 
 #endif
diff --git a/src/drawdance/libengine/CMakeLists.txt b/src/drawdance/libengine/CMakeLists.txt
@@ -31,6 +31,7 @@ dp_target_sources(dpengine
     dpengine/paint_engine.c
     dpengine/pixels.c
     dpengine/player.c
+    dpengine/preview.c
     dpengine/recorder.c
     dpengine/renderer.c
     dpengine/snapshots.c
@@ -72,6 +73,7 @@ dp_target_sources(dpengine
     dpengine/paint_engine.h
     dpengine/pixels.h
     dpengine/player.h
+    dpengine/preview.h
     dpengine/recorder.h
     dpengine/renderer.h
     dpengine/snapshots.h