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
|
/* jack-ringbuffer.c - (c) rohan drape, 2005-2006 */
#ifdef HAVE_CONFIG_H
# include "config.h"
#endif
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <errno.h>
#include <sys/types.h>
#include "jack-ringbuffer.h"
#include "common.h"
void jack_ringbuffer_print_debug(const jack_ringbuffer_t *r, const char *s)
{
eprintf("%s: read_ptr=%d,write_ptr=%d,size=%d,size_mask=%d\n",
s, (int)r->read_ptr, (int)r->write_ptr,
(int)r->size, (int)r->size_mask);
}
int jack_ringbuffer_wait_for_read(const jack_ringbuffer_t *r,
int nbytes, int fd)
{
int space = (int) jack_ringbuffer_read_space(r);
while(space < nbytes) {
char b;
if(read(fd, &b, 1)== -1) {
eprintf("%s: error reading communication pipe\n", __func__);
FAILURE;
}
space = (int) jack_ringbuffer_read_space(r);
}
return space;
}
int jack_ringbuffer_wait_for_write(jack_ringbuffer_t *r, int nbytes, int fd)
{
int space = (int)jack_ringbuffer_write_space(r);
while(space < nbytes) {
char b;
if(read(fd, &b, 1)== -1) {
fprintf (stderr, "%s: error reading communication pipe\n", __func__);
FAILURE;
}
space = (int) jack_ringbuffer_write_space(r);
}
return space;
}
void jack_ringbuffer_read_exactly(jack_ringbuffer_t *r, char *buf, int n)
{
int err = jack_ringbuffer_read(r, buf, n);
if(err != n) {
eprintf("%s: error reading ring buffer (%d != %d)\n",
__func__, err, n);
FAILURE;
}
}
void jack_ringbuffer_write_exactly(jack_ringbuffer_t *r, const char *buf, int n)
{
int err = jack_ringbuffer_write(r, buf, n);
if(err != n) {
eprintf("%s: error writing ring buffer (%d != %d)\n", __func__, err, n);
FAILURE;
}
}
|
