X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=ustd%2Flowlevel.c;h=a10f9317c056abd0fb639728ad2addad7e0b5129;hb=4267e589be114e837b06ad0b40fc58cdf7ea080a;hp=47a6f776e6dc5a9f92c90327c7bb88179e5e36f6;hpb=920bdf719a175cc0e542e2f001e7d01f230412c1;p=ust.git

diff --git a/ustd/lowlevel.c b/ustd/lowlevel.c
index 47a6f77..a10f931 100644
--- a/ustd/lowlevel.c
+++ b/ustd/lowlevel.c
@@ -15,6 +15,7 @@
  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301 USA
  */
 
+#include <stdlib.h>
 #include <assert.h>
 #include <byteswap.h>
 
@@ -63,10 +64,12 @@ size_t subbuffer_data_size(void *subbuf)
 
 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;
 
@@ -95,7 +98,7 @@ void finish_consuming_dead_subbuffer(struct buffer_info *buf)
 		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);
@@ -120,6 +123,7 @@ void finish_consuming_dead_subbuffer(struct buffer_info *buf)
 			/* If it was, we only check the data_size. This is the amount of valid data at
 			 * the beginning of the subbuffer. */
 			valid_length = header->data_size;
+			DBG("writing full subbuffer (%d) with valid_length = %ld", i_subbuf, valid_length);
 		}
 		else {
 			/* If the subbuffer was not fully written, then we don't check data_size because
@@ -128,20 +132,29 @@ void finish_consuming_dead_subbuffer(struct buffer_info *buf)
 			 */
 
 			valid_length = commit_seq & (buf->subbuf_size-1);
+			DBG("writing unfull subbuffer (%d) with valid_length = %ld", i_subbuf, valid_length);
 			header->data_size = valid_length;
 			header->sb_size = PAGE_ALIGN(valid_length);
 			assert(i_subbuf == (last_subbuf % 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);
 		}