window.h

Go to the documentation of this file.

#ifndef WINDOW_H
#define WINDOW_H
 
#include <time.h>
#include <stdlib.h>
#include <stdint.h>

typedef struct ts_node {
    struct timespec  ts;
    struct ts_node  *next;
} ts_node_t;

typedef struct sliding_window_t {
    ts_node_t   *head;             /* oldest retained timestamp, eviction happens here */
    ts_node_t   *tail;             /* newest retained timestamp, insertion happens here*/
    size_t       count;            /* deque size */
 
    long         window_size_ms;   /* retention horizon */
    long         slide_ms;         /* emit cadence */
 
    struct timespec last_emit;     /* Last sink() */
} sliding_window_t;
 
/***********
 * Functions
 **********/

void sliding_window_init(sliding_window_t *w,
                         long window_size_ms,
                         long slide_ms);

void sliding_window_destroy(sliding_window_t *w);

int sliding_window_add(sliding_window_t *w, struct timespec event_ts);

int sliding_window_should_emit(const sliding_window_t *w,
                                struct timespec now);

void sliding_window_mark_emitted(sliding_window_t *w,
                                 struct timespec now);

size_t sliding_window_count(const sliding_window_t *w);

struct timespec sliding_window_oldest(const sliding_window_t *w);

struct timespec sliding_window_newest(const sliding_window_t *w);
#endif