New struct empfile callback onresize

This commit is contained in:
Markus Armbruster 2008-09-06 13:58:15 -04:00
parent a1f20efd02
commit f21cb48f69
3 changed files with 30 additions and 15 deletions

View file

@ -77,6 +77,11 @@ struct empfile {
* visible to caller of ef_write() and are written to the file. * visible to caller of ef_write() and are written to the file.
*/ */
void (*prewrite)(int id, void *old, void *elt); void (*prewrite)(int id, void *old, void *elt);
/*
* Called after table size changed, with file type as argument.
* Return -1 and set errno to make the operation fail.
*/
int (*onresize)(int type);
}; };
struct emptypedstr { struct emptypedstr {

View file

@ -156,6 +156,8 @@ ef_open(int type, int how, int nelt)
} }
} }
if (ep->onresize && ep->onresize(type) < 0)
return 0;
return 1; return 1;
} }
@ -250,6 +252,8 @@ ef_close(int type)
ep->fd = -1; ep->fd = -1;
} }
ep->baseid = ep->cids = ep->fids = 0; ep->baseid = ep->cids = ep->fids = 0;
if (ep->onresize && ep->onresize(type) < 0)
retval = 0;
return retval; return retval;
} }
@ -487,25 +491,27 @@ ef_write(int type, int id, void *from)
ep = &empfile[type]; ep = &empfile[type];
if (CANT_HAPPEN((ep->flags & (EFF_MEM | EFF_PRIVATE)) == EFF_PRIVATE)) if (CANT_HAPPEN((ep->flags & (EFF_MEM | EFF_PRIVATE)) == EFF_PRIVATE))
return 0; return 0;
if (CANT_HAPPEN((ep->flags & EFF_MEM) ? id >= ep->fids : id > ep->fids))
return 0; /* not implemented */
new_seqno(ep, from);
if (id >= ep->fids) {
/* write beyond end of file extends it, take note */
ep->fids = id + 1;
if (ep->onresize && ep->onresize(type) < 0)
return 0;
}
if (id >= ep->baseid && id < ep->baseid + ep->cids) if (id >= ep->baseid && id < ep->baseid + ep->cids)
cachep = ep->cache + (id - ep->baseid) * ep->size; cachep = ep->cache + (id - ep->baseid) * ep->size;
else else
cachep = NULL; cachep = NULL;
if (ep->prewrite) if (ep->prewrite)
ep->prewrite(id, cachep, from); ep->prewrite(id, cachep, from);
if (CANT_HAPPEN((ep->flags & EFF_MEM) ? id >= ep->fids : id > ep->fids))
return 0; /* not implemented */
new_seqno(ep, from);
if (ep->fd >= 0) { if (ep->fd >= 0) {
if (do_write(ep, from, id, 1) < 0) if (do_write(ep, from, id, 1) < 0)
return 0; return 0;
} }
if (cachep && cachep != from) /* update the cache if necessary */ if (cachep && cachep != from) /* update the cache if necessary */
memcpy(cachep, from, ep->size); memcpy(cachep, from, ep->size);
if (id >= ep->fids) {
/* write beyond end of file extends it, take note */
ep->fids = id + 1;
}
return 1; return 1;
} }
@ -634,6 +640,8 @@ ef_extend(int type, int count)
} }
} }
ep->fids = id + count; ep->fids = id + count;
if (ep->onresize && ep->onresize(type) < 0)
return 0;
return 1; return 1;
} }
@ -723,6 +731,8 @@ ef_truncate(int type, int count)
ep->cids = count - ep->baseid; ep->cids = count - ep->baseid;
} }
if (ep->onresize && ep->onresize(type) < 0)
return 0;
return 1; return 1;
} }

View file

@ -62,21 +62,21 @@
/* Initializers for members flags... */ /* Initializers for members flags... */
/* Unmapped cache */ /* Unmapped cache */
#define UNMAPPED_CACHE(type, flags) \ #define UNMAPPED_CACHE(type, flags) \
sizeof(type), (flags), NULL, 0, 0, 0, 0, -1, NULL, NULL, NULL sizeof(type), (flags), NULL, 0, 0, 0, 0, -1, NULL, NULL, NULL, NULL
/* /*
* Mapped cache, array with known size. * Mapped cache, array with known size.
* Members cids, fids are not set. * Members cids, fids are not set.
*/ */
#define ARRAY_CACHE(array, flags) \ #define ARRAY_CACHE(array, flags) \
sizeof(*(array)), (flags), (char *)(array), \ sizeof(*(array)), (flags), (char *)(array), \
SZ((array)), 0, 0, 0, -1, NULL, NULL, NULL SZ((array)), 0, 0, 0, -1, NULL, NULL, NULL, NULL
/* /*
* Mapped cache, array with unknown size. * Mapped cache, array with unknown size.
* Members csize, cids, fids are not set. * Members csize, cids, fids are not set.
*/ */
#define PTR_CACHE(ptr, flags) \ #define PTR_CACHE(ptr, flags) \
sizeof(*(ptr)), (flags), (char *)(ptr), \ sizeof(*(ptr)), (flags), (char *)(ptr), \
0, 0, 0, 0, -1, NULL, NULL, NULL 0, 0, 0, 0, -1, NULL, NULL, NULL, NULL
/* /*
* Array-backed table. * Array-backed table.
* The array's last element is the sentinel. * The array's last element is the sentinel.
@ -84,7 +84,7 @@
#define ARRAY_TABLE(array, flags) \ #define ARRAY_TABLE(array, flags) \
sizeof(*(array)), (flags), (char *)(array), \ sizeof(*(array)), (flags), (char *)(array), \
SZ((array)), 0, SZ((array)) - 1, SZ((array)) - 1, -1, \ SZ((array)), 0, SZ((array)) - 1, SZ((array)) - 1, -1, \
NULL, NULL, NULL NULL, NULL, NULL, NULL
/* Common configuration table flags */ /* Common configuration table flags */
#define EFF_CFG (EFF_PRIVATE | EFF_MEM | EFF_STATIC | EFF_SENTINEL) #define EFF_CFG (EFF_PRIVATE | EFF_MEM | EFF_STATIC | EFF_SENTINEL)
@ -145,9 +145,9 @@ struct empfile empfile[] = {
{EF_LOAN, "loan", "loan", loan_ca, {EF_LOAN, "loan", "loan", loan_ca,
UNMAPPED_CACHE(struct lonstr, EFF_TYPED)}, UNMAPPED_CACHE(struct lonstr, EFF_TYPED)},
{EF_MAP, "map", "map", NULL, {EF_MAP, "map", "map", NULL,
0, 0, NULL, 0, 0, 0, 0, -1, NULL, NULL, NULL}, 0, 0, NULL, 0, 0, 0, 0, -1, NULL, NULL, NULL, NULL},
{EF_BMAP, "bmap", "bmap", NULL, {EF_BMAP, "bmap", "bmap", NULL,
0, 0, NULL, 0, 0, 0, 0, -1, NULL, NULL, NULL}, 0, 0, NULL, 0, 0, 0, 0, -1, NULL, NULL, NULL, NULL},
{EF_COMM, "commodity", "commodity", commodity_ca, {EF_COMM, "commodity", "commodity", commodity_ca,
UNMAPPED_CACHE(struct comstr, EFF_TYPED | EFF_OWNER)}, UNMAPPED_CACHE(struct comstr, EFF_TYPED | EFF_OWNER)},
{EF_LOST, "lost", "lostitems", lost_ca, {EF_LOST, "lost", "lostitems", lost_ca,
@ -197,7 +197,7 @@ struct empfile empfile[] = {
ARRAY_TABLE(empfile, EFF_CFG)}, ARRAY_TABLE(empfile, EFF_CFG)},
{EF_VERSION, "version", NULL, NULL, {EF_VERSION, "version", NULL, NULL,
sizeof(PACKAGE_STRING), EFF_STATIC, version, 1, 0, 1, 1, -1, sizeof(PACKAGE_STRING), EFF_STATIC, version, 1, 0, 1, 1, -1,
NULL, NULL, NULL}, NULL, NULL, NULL, NULL},
{EF_META, "meta", NULL, mdchr_ca, {EF_META, "meta", NULL, mdchr_ca,
PTR_CACHE(mdchr_ca, EFF_CFG)}, PTR_CACHE(mdchr_ca, EFF_CFG)},
@ -237,7 +237,7 @@ struct empfile empfile[] = {
/* Sentinel */ /* Sentinel */
{EF_BAD, NULL, NULL, NULL, {EF_BAD, NULL, NULL, NULL,
0, 0, NULL, 0, 0, 0, 0, -1, NULL, NULL, NULL}, 0, 0, NULL, 0, 0, 0, 0, -1, NULL, NULL, NULL, NULL},
}; };
static void static void