@@@ tvec buffer align power-of-two

[mLib] / struct / buf.c

diff --git a/struct/buf.c b/struct/buf.c
index 9efc4fcecbd59b37d1a13e7168f2e51ce13489e1..67cc30e93977e0ad2d1548cfc9227fbf304699e2 100644 (file)
--- a/struct/buf.c
+++ b/struct/buf.c
@@ -27,10 +27,10 @@
 
 /*----- Header files ------------------------------------------------------*/
 
-#include <assert.h>
 #include <string.h>
 
 #include "buf.h"
+#include "growbuf.h"
 #include "macros.h"
 
 /*----- Main code ---------------------------------------------------------*/
@@ -63,11 +63,7 @@ void buf_init(buf *b, void *p, size_t sz)
  *             and ready for writing.
  */
 
-void dbuf_create(dbuf *db)
-{
-  db->_b.base = db->_b.p = db->_b.limit = 0; db->_b.f = BF_ALLOC | BF_WRITE;
-  db->a = &arena_stdlib; db->sz = 0;
-}
+void dbuf_create(dbuf *db) { DBCREATE(db); }
 
 /* --- @dbuf_reset@ --- *
  *
@@ -89,11 +85,7 @@ void dbuf_reset(dbuf *db) { DBRESET(db); }
  * Use:                Release all of the resources held by a dynamic buffer.
  */
 
-void dbuf_destroy(dbuf *db)
-{
-  if (db->_b.base) x_free(db->a, db->_b.base);
-  dbuf_create(db);
-}
+void dbuf_destroy(dbuf *db) { DBDESTROY(db); }
 
 /* --- @{,d}buf_break@ --- *
  *
@@ -104,8 +96,8 @@ void dbuf_destroy(dbuf *db)
  * Use:                Marks a buffer as broken.
  */
 
-int buf_break(buf *b) { b->f |= BF_BROKEN; return (-1); }
-int (dbuf_break)(dbuf *db) { return (dbuf_break(db)); }
+int buf_break(buf *b) { BBREAK(b); return (-1); }
+int (dbuf_break)(dbuf *db) { DBBREAK(db); return (-1); }
 
 /* --- @{,d}buf_flip@ --- *
  *
@@ -118,7 +110,7 @@ int (dbuf_break)(dbuf *db) { return (dbuf_break(db)); }
  */
 
 void buf_flip(buf *b) { BFLIP(b); }
-void (dbuf_flip)(dbuf *db) { dbuf_flip(db); }
+void (dbuf_flip)(dbuf *db) { DBFLIP(db); }
 
 /* --- @{,d}buf_ensure@ --- *
  *
@@ -147,22 +139,17 @@ int (dbuf_ensure)(dbuf *db, size_t sz) { return (dbuf_ensure(db, sz)); }
 int buf_tryextend(buf *b, size_t sz)
 {
   dbuf *db;
-  size_t newsz, len;
-
-  if (~b->f&(BF_ALLOC | BF_WRITE))
-    { b->f |= BF_BROKEN; return (-1); }
-  db = (dbuf *)b;
-  len = BLEN(&db->_b); sz += len;
-  if (db->sz >= sz)
-    newsz = db->sz;
-  else {
-    newsz = db->sz ? 2*db->sz : 64;
-    while (newsz < sz) { assert(newsz < ((size_t)-1)/2); newsz *= 2; }
-    if (!db->_b.base) db->_b.base = x_alloc(db->a, newsz);
-    else db->_b.base = x_realloc(db->a, db->_b.base, newsz, db->sz);
-    db->_b.p = db->_b.base + len; db->sz = newsz;
+  size_t want, len;
+
+  if (sz <= BLEFT(b)) return (0);
+  if (~b->f&(BF_ALLOC | BF_WRITE)) { b->f |= BF_BROKEN; return (-1); }
+
+  db = (dbuf *)b; len = DBLEN(db); want = sz + len;
+  if (db->sz < want) {
+    GROWBUF_EXTEND(size_t, db->a, db->_b.base, db->sz, want, 64, 1);
+    db->_b.p = db->_b.base + len;
   }
-  db->_b.limit = db->_b.base + newsz;
+  db->_b.limit = db->_b.base + db->sz;
   return (0);
 }
 int (dbuf_tryextend)(dbuf *db, size_t sz)
@@ -374,10 +361,7 @@ static int findz(buf *b, size_t *nn)
 {
   octet *p;
 
-  if ((p = memchr(BCUR(b), 0, BLEFT(b))) == 0) {
-    buf_break(b);
-    return (-1);
-  }
+  if ((p = memchr(BCUR(b), 0, BLEFT(b))) == 0) { BBREAK(b); return (-1); }
   *nn = p - BCUR(b) + 1;
   return (0);
 }
@@ -423,7 +407,7 @@ static void *getmem_k64(buf *b, size_t *nn_out, kludge64 k)
   size_t n;
 
   ASSIGN64(szmax, (size_t)-1);
-  if (CMP64(k, >, szmax)) { buf_break(b); return (-1); }
+  if (CMP64(k, >, szmax)) { BBREAK(b); return (-1); }
   n = GET64(size_t, k); *nn_out = n; return (buf_get(b, n));
 }
 
@@ -478,7 +462,7 @@ void *(dbuf_getmem64b)(dbuf *db, size_t *nn)
   {                                                                    \
     MUFFLE_WARNINGS_STMT                                               \
       (CLANG_WARNING("-Wtautological-constant-out-of-range-compare"),  \
-       { assert(sz <= MASK##W); });                                    \
+       { if (sz > MASK##W) { BBREAK(b); return (-1); } });             \
     if (buf_putu##w(b, sz) || buf_put(b, p, sz))                       \
       return (-1);                                                     \
     return (0);                                                                \
@@ -526,7 +510,7 @@ int buf_putmemz(buf *b, const void *p, size_t n)
 {
   octet *q;
 
-  assert(!memchr(p, 0, n));
+  if (memchr(p, 0, n)) { BBREAK(b); return (-1); }
   if ((q = buf_get(b, n + 1)) == 0)
     return (-1);
   memcpy(q, p, n);