Check prv_* return values

This commit is contained in:
Rodrigo Arias 2023-03-21 10:06:26 +01:00 committed by Rodrigo Arias Mallo
parent 9de0b18db2
commit b42fb4d2f3

View File

@ -24,7 +24,7 @@ test_emit(const char *path)
bay_init(&bay); bay_init(&bay);
struct prv prv; struct prv prv;
prv_open(&prv, NROWS, path); OK(prv_open(&prv, NROWS, path));
for (int i = 0; i < NROWS; i++) { for (int i = 0; i < NROWS; i++) {
char buf[MAX_CHAN_NAME]; char buf[MAX_CHAN_NAME];
@ -43,14 +43,14 @@ test_emit(const char *path)
if (chan_set(&chan[i], value_int64(value_base + i)) != 0) if (chan_set(&chan[i], value_int64(value_base + i)) != 0)
die("chan_set failed\n"); die("chan_set failed\n");
prv_advance(&prv, 10000); OK(prv_advance(&prv, 10000));
if (bay_propagate(&bay) != 0) if (bay_propagate(&bay) != 0)
die("bay_propagate failed\n"); die("bay_propagate failed\n");
/* Ensure all writes are flushed to the buffer and /* Ensure all writes are flushed to the buffer and
* the header has been fixed */ * the header has been fixed */
prv_close(&prv); OK(prv_close(&prv));
FILE *f = fopen(path, "r"); FILE *f = fopen(path, "r");
int c; int c;
@ -74,7 +74,7 @@ test_duplicate(const char *path)
bay_init(&bay); bay_init(&bay);
struct prv prv; struct prv prv;
prv_open(&prv, NROWS, path); OK(prv_open(&prv, NROWS, path));
struct chan chan; struct chan chan;
chan_init(&chan, CHAN_SINGLE, "testchan"); chan_init(&chan, CHAN_SINGLE, "testchan");
@ -108,7 +108,7 @@ test_duplicate(const char *path)
/* Ensure all writes are flushed to the buffer and /* Ensure all writes are flushed to the buffer and
* the header has been fixed */ * the header has been fixed */
prv_close(&prv); OK(prv_close(&prv));
err("test duplicate OK\n"); err("test duplicate OK\n");
} }
@ -124,7 +124,7 @@ test_same_type(const char *path)
bay_init(&bay); bay_init(&bay);
struct prv prv; struct prv prv;
prv_open(&prv, NROWS, path); OK(prv_open(&prv, NROWS, path));
struct chan chan; struct chan chan;
chan_init(&chan, CHAN_SINGLE, "testchan"); chan_init(&chan, CHAN_SINGLE, "testchan");