#include <getopt.h>
#include "ust/ustconsumer.h"
+#include "../libustconsumer/lowlevel.h"
#include "usterr.h"
char *sock_path=NULL;
result = patient_write(buf_local->file_fd, buf->mem + subbuf_index * buf->subbuf_size, valid_length);
if(result == -1) {
ERR("Error writing to buffer file");
- return;
+ return result;
}
/* pad with empty bytes */
result = patient_write(buf_local->file_fd, tmp, pad_size);
if(result == -1) {
ERR("Error writing to buffer file");
- return;
+ return result;
}
free(tmp);
}
-
+ return result;
}
int on_open_buffer(struct ustconsumer_callbacks *data, struct buffer_info *buf)
int on_put_error(struct ustconsumer_callbacks *data, struct buffer_info *buf)
{
- unwrite_last_subbuffer(buf);
+ return unwrite_last_subbuffer(buf);
}
struct ustconsumer_callbacks *new_callbacks()