git » libjio » commit ac6eb0e

diff --git a/common.h b/common.h
index 76a3e3a..b5861f6 100644
--- a/common.h
+++ b/common.h
@@ -26,6 +26,8 @@
 #define F_TLOCKW	(_F_TLOCK | _F_WRITE)
 #define F_UNLOCK	(_F_ULOCK)
 
+#define MAX_TSIZE	(SSIZE_MAX)
+
 
 off_t plockf(int fd, int cmd, off_t offset, off_t len);
 ssize_t spread(int fd, void *buf, size_t count, off_t offset);
diff --git a/libjio.h b/libjio.h
index 32519d5..0ff1ba6 100644
--- a/libjio.h
+++ b/libjio.h
@@ -63,6 +63,7 @@ struct jtrans {
 	int id;			/* transaction id */
 	uint32_t flags;		/* transaction flags */
 	unsigned int numops;	/* quantity of operations in the list */
+	ssize_t len;		/* transaction's length */
 	pthread_mutex_t lock;	/* used to modify the operation list */
 	struct joper *op;	/* list of operations */
 };
diff --git a/trans.c b/trans.c
index 688594d..0132f19 100644
--- a/trans.c
+++ b/trans.c
@@ -146,6 +146,11 @@ int jtrans_add(struct jtrans *ts, const void *buf, size_t count, off_t offset)
 		return 0;
 	}
 
+	if (ts->len + count > MAX_TSIZE) {
+		pthread_mutex_unlock(&(ts->lock));
+		return 0;
+	}
+
 	/* find the last operation in the transaction and create a new one at
 	 * the end */
 	if (ts->op == NULL) {
@@ -181,6 +186,8 @@ int jtrans_add(struct jtrans *ts, const void *buf, size_t count, off_t offset)
 		return 0;
 	}
 
+	ts->numops++;
+	ts->len += count;
 	pthread_mutex_unlock(&(ts->lock));
 
 	/* we copy the buffer because then the caller can reuse it */
@@ -192,8 +199,6 @@ int jtrans_add(struct jtrans *ts, const void *buf, size_t count, off_t offset)
 	jop->pdata = NULL;
 	jop->locked = 0;
 
-	ts->numops++;
-
 	return 1;
 }