window.h File Reference

#include <time.h>
#include <stdlib.h>
#include <stdint.h>

Go to the source code of this file.

Data Structures
struct	ts_node_t
	A timestamp node. More...
struct	sliding_window_t
	A sliding sampling window represented as a linked list of timestamps. More...

Functions
void	sliding_window_init (sliding_window_t *w, long window_size_ms, long slide_ms)
	Initialize a sliding window.
void	sliding_window_destroy (sliding_window_t *w)
	Graceful cleanup of a window. Frees all ts_node_t in the window, not the window itself.
int	sliding_window_add (sliding_window_t *w, struct timespec event_ts)
	Append the event timestamp as ts_node_t to tail. Evicts head while head->ts < (event_ts - window_size_ms).
int	sliding_window_should_emit (const sliding_window_t *w, struct timespec now)
	Checks if it's time to emit (slide_ms elapsed since last emit).
void	sliding_window_mark_emitted (sliding_window_t *w, struct timespec now)
	Called on emit, sets the last emit time.
size_t	sliding_window_count (const sliding_window_t *w)
	Get the count of events currently in the window.
struct timespec	sliding_window_oldest (const sliding_window_t *w)
	Get the timestamp of the oldest event in the window.
struct timespec	sliding_window_newest (const sliding_window_t *w)
	Get the timestamp of the newest event in the window.

Function Documentation

sliding_window_add()

int sliding_window_add	(	sliding_window_t *	w,
		struct timespec	event_ts )

Append the event timestamp as ts_node_t to tail. Evicts head while head->ts < (event_ts - window_size_ms).

Parameters

w	Pointer to the window.
event_ts	Timestamp of the event.

Returns

0 on success, -1 on alloc error, -2 on empty sliding window.

sliding_window_count()

size_t sliding_window_count

(

const sliding_window_t *

w

)

Get the count of events currently in the window.

Parameters

w	Pointer to the window.

Returns

Number of events in the window.

sliding_window_destroy()

void sliding_window_destroy

(

sliding_window_t *

w

)

Graceful cleanup of a window. Frees all ts_node_t in the window, not the window itself.

Parameters

w	Pointer to the window.

sliding_window_init()

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

Initialize a sliding window.

Parameters

w	Pointer to the window.
window_size_ms	Window span.
slide_ms	Sliding interval.

sliding_window_mark_emitted()

void sliding_window_mark_emitted	(	sliding_window_t *	w,
		struct timespec	now )

Called on emit, sets the last emit time.

Parameters

w	Pointer to the window.
now	Current timestamp.

sliding_window_newest()

struct timespec sliding_window_newest

(

const sliding_window_t *

w

)

Get the timestamp of the newest event in the window.

Parameters

w	Pointer to the window.

Returns

Timespec of the newest event.

sliding_window_oldest()

struct timespec sliding_window_oldest

(

const sliding_window_t *

w

)

Get the timestamp of the oldest event in the window.

Parameters

w	Pointer to the window.

Returns

Timespec of the oldest event.

sliding_window_should_emit()

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

Checks if it's time to emit (slide_ms elapsed since last emit).

Parameters

w	Pointer to the window.
now	Current timestamp.

Returns

1 if should emit, 0 otherwise.