* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*/
+#include <stdlib.h>
#include <assert.h>
#include <byteswap.h>
void finish_consuming_dead_subbuffer(struct buffer_info *buf)
{
+ int result;
+
struct ust_buffer *ustbuf = buf->bufstruct_mem;
- long write_offset = local_read(&ustbuf->offset);
- long consumed_offset = atomic_long_read(&ustbuf->consumed);
+ long write_offset = uatomic_read(&ustbuf->offset);
+ long consumed_offset = uatomic_read(&ustbuf->consumed);
long i_subbuf;
void *tmp;
/* commit_seq is the offset in the buffer of the end of the last sequential commit.
* Bytes beyond this limit cannot be recovered. This is a free-running counter. */
- long commit_seq = local_read(&ustbuf->commit_seq[i_subbuf]);
+ long commit_seq = uatomic_read(&ustbuf->commit_seq[i_subbuf]);
unsigned long valid_length = buf->subbuf_size;
long n_subbufs_order = get_count_order(buf->n_subbufs);
}
- patient_write(buf->file_fd, buf->mem + i_subbuf * buf->subbuf_size, valid_length);
+ result = patient_write(buf->file_fd, buf->mem + i_subbuf * buf->subbuf_size, valid_length);
+ if(result == -1) {
+ ERR("Error writing to buffer file");
+ return;
+ }
/* pad with empty bytes */
pad_size = PAGE_ALIGN(valid_length)-valid_length;
if(pad_size) {
tmp = malloc(pad_size);
memset(tmp, 0, pad_size);
- patient_write(buf->file_fd, tmp, pad_size);
+ result = patient_write(buf->file_fd, tmp, pad_size);
+ if(result == -1) {
+ ERR("Error writing to buffer file");
+ return;
+ }
free(tmp);
}