Add seg_erased

confluentinc · Jun 4, 2024 · 4071f8b · 4071f8b
1 parent 7c01770
commit 4071f8b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/src/rdbuf.c b/src/rdbuf.c
@@ -660,6 +660,7 @@ size_t rd_buf_erase(rd_buf_t *rbuf, size_t absof, size_t size) {
                                 segremains);
 
                 seg->seg_of -= toerase;
+                seg->seg_erased += toerase;
                 rbuf->rbuf_len -= toerase;
 
                 of += toerase;
@@ -712,6 +713,7 @@ int rd_buf_write_seek(rd_buf_t *rbuf, size_t absof) {
                 rd_segment_t *this = next;
                 next = TAILQ_PREV(this, rd_segment_head, seg_link);
                 rd_buf_destroy_segment(rbuf, this);
+                rbuf->rbuf_erased -= seg->seg_erased;
         }
 
         /* Update relative write offset */

diff --git a/src/rdbuf.h b/src/rdbuf.h
@@ -70,6 +70,8 @@ typedef struct rd_segment_s {
                                     *   beginning in the grand rd_buf_t */
         void (*seg_free)(void *p); /**< Optional free function for seg_p */
         int seg_flags;             /**< Segment flags */
+        size_t seg_erased;         /** Total number of bytes erased from
+                                    *   this segment. */
 #define RD_SEGMENT_F_RDONLY 0x1    /**< Read-only segment */
 #define RD_SEGMENT_F_FREE                                                      \
         0x2 /**< Free segment on destroy,                                      \