1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
#ifndef _RINGBUFFER_H
#define _RINGBUFFER_H 1
#define RINGBUFFER_FLAGS_MONO 1 /* ignored for now */
#define RINGBUFFER_FLAGS_STEREO 2
#define RINGBUFFER_FLAGS_QUAD 4
/* these are mutual exclusive */
#define RINGBUFFER_FLAGS_8BIT 8 /* ignored for now */
#define RINGBUFFER_FLAGS_16BIT 16
#define RINGBUFFER_FLAGS_FLOAT 32
#define RINGBUFFER_FLAGS_SIGNED 64 /* valid for 8BIT and 16BIT */
#define RINGBUFFER_FLAGS_PROCESS 128 /* if present, processing and cache_process will be maintained */
struct ringbuffer_t;
/* causes all callbacks to be called */
void ringbuffer_reset (struct ringbuffer_t *self);
void ringbuffer_tail_consume_bytes (struct ringbuffer_t *self, int bytes);
void ringbuffer_processing_consume_bytes (struct ringbuffer_t *self, int bytes);
void ringbuffer_head_add_bytes (struct ringbuffer_t *self, int bytes);
void ringbuffer_head_add_pause_bytes (struct ringbuffer_t *self, int bytes);
void ringbuffer_tail_consume_samples (struct ringbuffer_t *self, int samples);
void ringbuffer_processing_consume_samples (struct ringbuffer_t *self, int samples);
void ringbuffer_head_add_samples (struct ringbuffer_t *self, int samples);
void ringbuffer_head_add_pause_samples (struct ringbuffer_t *self, int samples);
void ringbuffer_get_tail_bytes (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
void ringbuffer_get_processing_bytes (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
void ringbuffer_get_head_bytes (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
void ringbuffer_get_tail_samples (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
void ringbuffer_get_processing_samples (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
void ringbuffer_get_tailandprocessing_samples (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
void ringbuffer_get_head_samples (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
int ringbuffer_get_tail_available_bytes (struct ringbuffer_t *self);
int ringbuffer_get_processing_available_bytes (struct ringbuffer_t *self);
int ringbuffer_get_head_available_bytes (struct ringbuffer_t *self);
int ringbuffer_get_tail_available_samples (struct ringbuffer_t *self);
int ringbuffer_get_processing_available_samples (struct ringbuffer_t *self);
int ringbuffer_get_head_available_samples (struct ringbuffer_t *self);
struct ringbuffer_t *ringbuffer_new_samples (int flags, int buffersize_samples); /* some users might non-pow(2,x) size buffers */
void ringbuffer_free (struct ringbuffer_t *self);
/* samples = -10, the callback should happen when 10th future added samples passes tail
* samples = 0, the callback should happen when the next added samples passes tail
* samples = 1, the callback should happen when the last added samples passes tail
* samples = 10, the callback should happen when the 10th last added samples passes tail
*/
void ringbuffer_add_tail_callback_samples (struct ringbuffer_t *self, int samples, void (*callback)(void *arg, int samples_ago), const void *arg);
void ringbuffer_add_processing_callback_samples (struct ringbuffer_t *self, int samples, void (*callback)(void *arg, int samples_ago), const void *arg);
/* returns number of non-pause samples */
void ringbuffer_get_stats (struct ringbuffer_t *self, uint64_t *total_head, uint64_t *total_tail);
struct ringbufferAPI_t
{
void (*reset) (struct ringbuffer_t *self);
void (*tail_consume_bytes) (struct ringbuffer_t *self, int bytes);
void (*processing_consume_bytes) (struct ringbuffer_t *self, int bytes);
void (*head_add_bytes) (struct ringbuffer_t *self, int bytes);
void (*head_add_pause_bytes) (struct ringbuffer_t *self, int bytes);
void (*tail_consume_samples) (struct ringbuffer_t *self, int samples);
void (*processing_consume_samples) (struct ringbuffer_t *self, int samples);
void (*head_add_samples) (struct ringbuffer_t *self, int samples);
void (*head_add_pause_samples) (struct ringbuffer_t *self, int samples);
void (*get_tail_bytes) (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
void (*get_processing_bytes) (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
void (*get_head_bytes) (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
void (*get_tail_samples) (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
void (*get_processing_samples) (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
void (*get_tailandprocessing_samples) (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
void (*get_head_samples) (struct ringbuffer_t *self, int *pos1, int *length1, int *pos2, int *length2);
int (*get_tail_available_bytes) (struct ringbuffer_t *self);
int (*get_processing_available_bytes) (struct ringbuffer_t *self);
int (*get_head_available_bytes) (struct ringbuffer_t *self);
int (*get_tail_available_samples) (struct ringbuffer_t *self);
int (*get_processing_available_samples) (struct ringbuffer_t *self);
int (*get_head_available_samples) (struct ringbuffer_t *self);
struct ringbuffer_t * (*new_samples) (int flags, int buffersize_samples); /* some users might non-pow(2,x) size buffers */
void (*free) (struct ringbuffer_t *self);
void (*add_tail_callback_samples) (struct ringbuffer_t *self, int samples, void (*callback)(void *arg, int samples_ago), const void *arg);
void (*add_processing_callback_samples) (struct ringbuffer_t *self, int samples, void (*callback)(void *arg, int samples_ago), const void *arg);
void (*get_stats) (struct ringbuffer_t *self, uint64_t *total_head, uint64_t *total_tail); /* given in non-pause samples */
};
extern const struct ringbufferAPI_t ringbufferAPI;
#endif
|
