--- freem/src/global_bltin.c 2025/04/08 16:46:11 1.9
+++ freem/src/global_bltin.c 2025/04/11 16:52:05 1.19
@@ -1,5 +1,5 @@
/*
- * $Id: global_bltin.c,v 1.9 2025/04/08 16:46:11 snw Exp $
+ * $Id: global_bltin.c,v 1.19 2025/04/11 16:52:05 snw Exp $
* freem database engine
*
*
@@ -24,6 +24,36 @@
* along with FreeM. If not, see .
*
* $Log: global_bltin.c,v $
+ * Revision 1.19 2025/04/11 16:52:05 snw
+ * Fix indentation in global handler
+ *
+ * Revision 1.18 2025/04/11 16:23:18 snw
+ * Avoid re-reading the same block consecutively when possible
+ *
+ * Revision 1.17 2025/04/11 14:21:03 snw
+ * Make all but one of the read/write calls in global_bltin use gbl_read_block or gbl_write_block
+ *
+ * Revision 1.16 2025/04/11 00:52:40 snw
+ * Replace all lseek/read calls in global handler to use gbl_read_block function
+ *
+ * Revision 1.15 2025/04/10 01:24:38 snw
+ * Remove C++ style comments
+ *
+ * Revision 1.14 2025/04/09 19:52:02 snw
+ * Eliminate as many warnings as possible while building with -Wall
+ *
+ * Revision 1.13 2025/04/09 14:34:30 snw
+ * Further work on global_bltin.c refactor
+ *
+ * Revision 1.12 2025/04/09 00:43:07 snw
+ * Exit with fatal error if a header mismatch found
+ *
+ * Revision 1.11 2025/04/08 21:41:13 snw
+ * Make insert, update, and splitp global handler functions take a ptr to a global_handle instead of a file descriptor
+ *
+ * Revision 1.10 2025/04/08 20:00:56 snw
+ * Global handler now uses a header file and maintains the last journaling transaction ID
+ *
* Revision 1.9 2025/04/08 16:46:11 snw
* Add global file header and offsets
*
@@ -56,19 +86,21 @@
#include
#include "mpsdef.h"
+#include "journal.h"
#include "global_bltin.h"
global_handle *global_handles_head;
+unsigned long gbl_cache_misses = 0;
+unsigned long gbl_cache_hits = 0;
-static void b_free (short filedes, unsigned long blknbr);
-static void splitp (short filedes, char *block, long *addr, long *offs, unsigned long *blknbr);
-static void update (short filedes, char *ins_key, long keyl);
-static void insert (int filedes, char *ins_key, long key_len, unsigned long blknbr);
+static void b_free (global_handle *g, unsigned long blknbr);
+static void splitp (global_handle *g, char *block, long *addr, long *offs, unsigned long *blknbr);
+static void update (global_handle *g, char *ins_key, long keyl);
+static void insert (global_handle *g, char *ins_key, long key_len, unsigned long blknbr);
static void scanpblk (char *block, long *adr, long *fnd);
static void scandblk (char *block, long *adr, long *fnd);
-static void getnewblk (int filedes, unsigned long *blknbr);
+static void getnewblk (global_handle *g, unsigned long *blknbr);
static short int g_collate (char *t);
-//static short int g_numeric (char *str);
short g_numeric (char *str);
void close_all_globals(void);
static void panic (void);
@@ -113,25 +145,20 @@ static void panic (void);
#define DATA 8
#if !defined(__OpenBSD__) && !defined(_AIX) && !defined(__osf__) && !defined(MSDOS) && !defined(__vax__) && !defined(__OS2__)
- long time ();
+long time ();
#endif
inline long gbl_path(char *key, char *buf)
{
long savj;
- long savch; /* saved j and ch for multiple pathes */
register long int i;
register long int j;
register long int k;
register long int ch;
- long pathscan; /* flag for repeated scan of pathlist setting an undef global */
/* construct full UNIX filename */
savj = 0;
- savch = ch = EOL;
- pathscan = TRUE;
-nextpath:
k = 0;
j = savj;
@@ -155,8 +182,6 @@ nextpath:
}
}
-
- if (savj == 0 && ch == EOL) pathscan = FALSE; /* one path only: inhibit search */
if (k > 0) {
@@ -169,7 +194,6 @@ nextpath:
}
- savch = ch;
savj = j;
i = 0;
j = 0;
@@ -202,6 +226,19 @@ nextpath:
return i;
} /* gbl_path() */
+void gbl_cache_hit(global_handle *g)
+{
+ g->cache_hits++;
+ gbl_cache_hits++;
+} /* gbl_cache_hit() */
+
+void gbl_cache_miss(global_handle *g)
+{
+ g->fast_path = 0;
+ g->cache_misses++;
+ gbl_cache_misses++;
+} /* gbl_cache_miss() */
+
int gbl_lock(global_handle *g, int type)
{
if (g->locked == TRUE || lonelyflag == TRUE) {
@@ -210,6 +247,8 @@ int gbl_lock(global_handle *g, int type)
locking (g->fd, type, 0L);
g->locked = TRUE;
+
+ return TRUE;
} /* gbl_lock() */
int gbl_unlock(global_handle *g)
@@ -220,6 +259,8 @@ int gbl_unlock(global_handle *g)
locking (g->fd, 0, 0L);
g->locked = FALSE;
+
+ return TRUE;
} /* gbl_unlock() */
void gbl_close(global_handle *g)
@@ -244,7 +285,7 @@ void gbl_close_all(void)
}
} /* gbl_close_all() */
-int gbl_write_header(global_handle *g)
+int gbl_write_initial_header(global_handle *g)
{
global_header hdr;
unsigned long old_position;
@@ -268,7 +309,7 @@ int gbl_write_header(global_handle *g)
lseek (g->fd, 0, SEEK_SET);
if (write (g->fd, &hdr, sizeof (global_header)) == -1) {
- snprintf (msg, 256, "error %d writing global header for %s", errno, g->global_name);
+ snprintf (msg, sizeof (msg), "error %d writing global header for %s", errno, g->global_name);
m_fatal (msg);
}
@@ -276,8 +317,80 @@ int gbl_write_header(global_handle *g)
gbl_unlock (g);
return TRUE;
+} /* gbl_write_initial_header() */
+
+
+int gbl_write_header(global_handle *g, global_header *hdr)
+{
+ unsigned long old_position;
+ char msg[256];
+
+ if (g->opened == FALSE) {
+ return FALSE;
+ }
+
+ gbl_lock (g, 1);
+ old_position = lseek (g->fd, 0, SEEK_CUR);
+ lseek (g->fd, 0, SEEK_SET);
+
+ if (write (g->fd, hdr, sizeof (global_header)) == -1) {
+ snprintf (msg, sizeof (msg), "error %d writing global header for %s", errno, g->global_name);
+ m_fatal (msg);
+ }
+
+ lseek (g->fd, old_position, SEEK_SET);
+ gbl_unlock (g);
+
+ gbl_read_header (g, &g->header);
+
+ return TRUE;
} /* gbl_write_header() */
+int gbl_read_header(global_handle *g, global_header *h)
+{
+ unsigned long old_position;
+ char m[5] = GBL_MAGIC;
+
+
+ if (g->opened == FALSE) {
+ return GBL_HDR_NOTOPEN;
+ }
+
+ gbl_lock (g, 1);
+ old_position = lseek (g->fd, 0, SEEK_CUR);
+ lseek (g->fd, 0, SEEK_SET);
+
+ read (g->fd, h, sizeof (global_header));
+
+ lseek (g->fd, old_position, SEEK_SET);
+ gbl_unlock (g);
+
+ if (strncmp (h->magic, m, 5) != 0) {
+ return GBL_HDR_BADMAGIC;
+ }
+ if (h->format_version != GBL_FORMAT_VERSION) {
+ return GBL_HDR_BADVERSION;
+ }
+ if (h->block_size != BLOCKLEN) {
+ return GBL_HDR_BADBLOCKSIZE;
+ }
+
+ return GBL_HDR_OK;
+} /* gbl_read_header() */
+
+int gbl_update_tid(global_handle *g)
+{
+ global_header h;
+
+ if (gbl_read_header (g, &h) != GBL_HDR_OK) {
+ return FALSE;
+ }
+
+ h.last_transaction_id = jnl_tran_id;
+
+ return gbl_write_header (g, &h);
+} /* gbl_update_tid() */
+
int gbl_create(global_handle *g)
{
while (1) {
@@ -297,15 +410,19 @@ int gbl_create(global_handle *g)
g->age = time (0L);
g->last_block = 0;
g->use_count = 1;
-
- gbl_write_header (g);
+ g->fast_path = 0;
+
+ gbl_write_initial_header (g);
return OK;
} /* gbl_create() */
short gbl_open(global_handle *g, short action)
{
+ int result;
+
if (g->opened == FALSE) {
+ gbl_cache_miss (g);
while (1) {
errno = 0;
g->fd = open (g->global_path, 2);
@@ -318,7 +435,7 @@ short gbl_open(global_handle *g, short a
case EMFILE:
case ENFILE:
- close_all_globals ();
+ gbl_close_all ();
continue;
}
@@ -334,6 +451,35 @@ short gbl_open(global_handle *g, short a
}
else {
g->opened = TRUE;
+ result = gbl_read_header (g, &g->header);
+
+ if (result == GBL_HDR_OK) {
+ /* initialize last_block_accessed cache */
+ g->last_block_accessed = (char *) calloc (g->header.block_size, sizeof (char));
+ NULLPTRCHK(g->last_block_accessed,"gbl_open");
+
+ g->opened = TRUE;
+ }
+ else {
+ gbl_close (g);
+ set_io (UNIX);
+
+ switch (result) {
+
+ case GBL_HDR_BADMAGIC:
+ fprintf (stderr, "gbl_open: bad magic value in %s [FATAL]\n", g->global_name);
+ exit (1);
+ break;
+
+ case GBL_HDR_BADVERSION:
+ fprintf (stderr, "gbl_open: global version is %d in %s (must be %d) [FATAL]\n", g->header.format_version, g->global_name, GBL_FORMAT_VERSION);
+ exit (1);
+ break;
+
+ }
+
+ return FALSE;
+ }
}
}
@@ -341,13 +487,92 @@ short gbl_open(global_handle *g, short a
} /* gbl_open() */
+int gbl_read_block(global_handle *g, unsigned long blocknum, char *block)
+{
+ struct stat gstat;
+ unsigned long hdr_offset;
+ hdr_offset = sizeof (global_header);
+
+ if (g->opened == FALSE) {
+ return FALSE;
+ }
+
+ g->use_count++;
+
+ fstat (g->fd, &gstat);
+ if (!g->locked) gbl_lock (g, 1);
+
+
+ if ((g->last_block == blocknum) &&
+ (g->have_cached_block) &&
+ (g->cached_block_num == blocknum) &&
+ (gstat.st_mtime < g->last_read_time)) {
+ /* the global has not been modified since the last read; grab from memory */
+ g->memory_reads++;
+ g->last_read_time = time (0L);
+ memcpy (block, g->last_block_accessed, g->header.block_size);
+ }
+ else {
+ /* have to go out to disk */
+ lseek (g->fd, hdr_offset + ((long) blocknum * (long) (g->header.block_size)), SEEK_SET);
+ read (g->fd, block, g->header.block_size);
+
+ /* update cache */
+ memcpy (g->last_block_accessed, block, g->header.block_size);
+ g->have_cached_block = TRUE;
+ g->last_read_time = time (0L);
+ g->cached_block_num = blocknum;
+
+ g->last_block = blocknum;
+ g->use_count++;
+ g->read_ops++;
+ }
+
+ if (g->locked) gbl_unlock (g);
+
+ return TRUE;
+} /* gbl_read_block() */
+
+int gbl_write_block(global_handle *g, unsigned long blocknum, char *block)
+{
+ int errsav;
+ unsigned long hdr_offset;
+ hdr_offset = sizeof (global_header);
+
+ if (g->opened == FALSE) {
+ return FALSE;
+ }
+
+ gbl_lock (g, 1);
+
+ for (;;) {
+
+ errno = 0;
+
+ lseek (g->fd, hdr_offset + (blocknum * g->header.block_size), SEEK_SET);
+ write (g->fd, block, BLOCKLEN);
+ errsav = errno;
+ g->last_block = blocknum;
+ g->use_count++;
+ g->write_ops++;
+
+ if (errsav == 0) break;
+
+ panic ();
+
+ }
+
+ gbl_update_tid (g);
+ gbl_unlock (g);
+
+ return TRUE;
+}
+
global_handle *gbl_handle(char *key)
{
global_handle *g;
char global_name[256];
int i;
- long path_len;
- char block[BLOCKLEN];
struct stat dinf;
i = 0;
@@ -384,10 +609,18 @@ global_handle *gbl_handle(char *key)
g->use_count = 1;
g->locked = FALSE;
g->age = time (0L);
+ g->last_read_time = 0;
g->last_block = 0;
g->opened = FALSE;
g->fd = 0;
g->fast_path = -1;
+ g->cache_misses = 0;
+ g->cache_hits = 0;
+ g->read_ops = 0;
+ g->write_ops = 0;
+ g->memory_reads = 0;
+ g->have_cached_block = FALSE;
+ g->last_block_accessed = NULL;
strcpy (g->global_name, global_name);
gbl_path (key, g->global_path);
@@ -482,7 +715,6 @@ void global_bltin (short action, char *k
unsigned long hdr_offset;
/* these must be static variables */
- static short filedes; /* filedescr for global access */
static char filnam[256]; /* name of global/unix file */
/* the following vars may be */
@@ -507,20 +739,17 @@ void global_bltin (short action, char *k
static char block[BLOCKLEN];
static int getnflag; /* flag 1=$ZO-variable 0=$Q-function */
static int tryfast; /* try fast access if get_sym on */
- /* previous global */
+ /* previous global */
int iresult;
- struct stat dinf; /* get modification date */
-
- long savj;
- long savch; /* saved j and ch for multiple pathes */
register long int i;
register long int j;
register long int k;
register long int ch;
- long pathscan; /* flag for repeated scan of pathlist setting an undef global */
+ j = 0;
+
hdr_offset = sizeof (global_header);
/* process optional limitations */
@@ -885,19 +1114,9 @@ reopen:
merr_raise (iresult);
return;
}
-
- for (;;) {
-
- errno = 0;
-
- lseek (g->fd, hdr_offset + (ROOT * BLOCKLEN), SEEK_SET);
- write (g->fd, block, BLOCKLEN);
-
- if (errno == 0) break;
-
- panic ();
- }
+ gbl_write_block (g, ROOT, block);
+
block[NRBLK] = 0;
block[NRBLK + 1] = 0;
block[NRBLK + 2] = ROOT; /* clear */
@@ -933,134 +1152,125 @@ reopen:
/* odd numbered actions get read access (get_sym,data,fra_order) 3 */
/* even ones read/write access (set_sym,kill_sym) 1 */
-lock:
+/* temporarily disabled
+ lock:
+*/
if (action == get_sym) {
-tfast0:
+ tfast0:
gbl_lock (g, 3);
- if (tryfast) goto tfast1; /* try again last block */
+
+ if (g->fast_path > 0) goto tfast1; /* try again last block */
blknbr = g->last_block = ROOT; /* start with ROOT block */
for (;;) {
-tfast1:
+ tfast1:
+ gbl_read_block (g, blknbr, block);
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block, BLOCKLEN);
+/* temporarily disabled
+ tfast2:
+*/
+ if ((typ = block[BTYP]) == DATA) { /* scan data block: here we test for equality only */
+ offset = UNSIGN (block[OFFS]) * 256 +
+ UNSIGN (block[OFFS + 1]);
+ j = UNSIGN (block[0]);
+ i = 0;
-tfast2:
-
- if ((typ = block[BTYP]) == DATA) { /* scan data block: here we test for equality only */
-
- offset = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
- j = UNSIGN (block[0]);
- i = 0;
-
- stcpy0 (key1, &block[2], j); /* get first key */
-
- ch = keyl; /* ch is a register! */
-
- while (i < offset) {
-
- j = UNSIGN (block[i++]); /* length of key - offset */
- k = UNSIGN (block[i++]); /* offset into previous entry */
-
-#ifdef VERSNEW
-
- stcpy0 (&key0[k], &block[i], j);
- i += j;
- j += k;
-
-#else
-
- j += k;
+ stcpy0 (key1, &block[2], j); /* get first key */
- while (k < j) key1[k++] = block[i++]; /* get key */
-
-#endif /* VERSNEW */
-
- if (j != ch) { /* keys have different length */
+ ch = keyl; /* ch is a register! */
+
+ while (i < offset) {
+
+ j = UNSIGN (block[i++]); /* length of key - offset */
+ k = UNSIGN (block[i++]); /* offset into previous entry */
+
+ j += k;
+
+ while (k < j) key1[k++] = block[i++]; /* get key */
+
+ if (j != ch) { /* keys have different length */
+
+ i += UNSIGN (block[i]);
+ i++;
+
+ continue;
+
+ }
+
+ j = ch;
+
+ do {
+ j--;
+ } while (compactkey[j] == key1[j]); /* compare keys */
+
+
+ if (j < 0) {
+
+ k = UNSIGN (block[i++]);
+ stcpy0 (data, &block[i], k); /* get value */
+ data[k] = EOL1; /* append EOL */
+
+ goto quit;
+
+ }
i += UNSIGN (block[i]);
- i++;
-
- continue;
-
+ i++; /* skip data */
+
+ }
+
+ /* fast access failed. try normal path */
+ if (tryfast) {
+ gbl_cache_miss (g);
+ goto tfast0;
}
- j = ch;
+ merr_raise (M7);
+ data[0] = EOL;
- do {
- j--;
- } while (compactkey[j] == key1[j]); /* compare keys */
+ goto quit; /* variable not found */
+ }
+ else {
-
- if (j < 0) {
+ if (g->fast_path > 0) {
+ gbl_cache_miss (g);
+ goto tfast0;
+ }
+
+ if (typ == EMPTY) {
- k = UNSIGN (block[i++]);
- stcpy0 (data, &block[i], k); /* get value */
- data[k] = EOL1; /* append EOL */
-
+ if (blknbr == ROOT) {
+ gbl_close (g);
+ goto reopen;
+ }
+
+ merr_raise (DBDGD);
goto quit;
-
+
}
-
- i += UNSIGN (block[i]);
- i++; /* skip data */
-
- }
-
- /* fast access failed. try normal path */
- if (tryfast) {
- tryfast = FALSE;
- goto tfast0;
+
}
-
- merr_raise (M7);
- data[0] = EOL;
- goto quit; /* variable not found */
- }
- else {
-
- if (tryfast) {
- tryfast = FALSE;
- goto tfast0;
- }
-
- if (typ == EMPTY) {
-
- if (blknbr == ROOT) {
- //close (filedes);
- gbl_close (g);
- goto reopen;
- }
-
+ scanpblk (block, &addr, &found);
+
+ addr += UNSIGN (block[addr]) + 2; /* skip key */
+
+ if ((blknbr = UNSIGN (block[addr]) * 65536 + UNSIGN (block[addr + 1]) * 256 + UNSIGN (block[addr + 2])) == g->last_block) {
merr_raise (DBDGD);
goto quit;
-
}
- }
-
- scanpblk (block, &addr, &found);
-
- addr += UNSIGN (block[addr]) + 2; /* skip key */
+ addr += PLEN; /* skip data */
+ g->last_block = blknbr;
+ g->fast_path = 1;
- if ((blknbr = UNSIGN (block[addr]) * 65536 + UNSIGN (block[addr + 1]) * 256 + UNSIGN (block[addr + 2])) == g->last_block) {
- merr_raise (DBDGD);
- goto quit;
- }
-
- addr += PLEN; /* skip data */
- g->last_block = blknbr;
-
- if (merr () == INRPT) goto quit;
+ if (merr () == INRPT) goto quit;
}
} /* end of get_sym */
@@ -1070,14 +1280,12 @@ tfast2:
/* a KILL on an unsubscripted global deletes the entire file */
if (action == kill_sym && compactkey[0] == g_EOL) {
- lseek (g->fd, hdr_offset + ROOT, SEEK_SET);
-
- /* note : UNIX does not tell other */
- block[BTYP] = EMPTY; /* jobs that a file has been unlinked */
-
+ /* note : UNIX does not tell other jobs that a file has been unlinked */
/* as long as they keep it open. */
/* so we mark this global as EMPTY */
- write (g->fd, block, BLOCKLEN);
+ block[BTYP] = EMPTY;
+
+ gbl_write_block (g, ROOT, block);
gbl_unlock (g);
gbl_close (g);
@@ -1102,10 +1310,8 @@ k_again: /* entry point for repeated
traceblk[trx] = blknbr;
traceadr[trx] = 0;
-
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block, BLOCKLEN);
-
+
+ gbl_read_block (g, blknbr, block);
typ = block[BTYP];
if (typ == DATA) {
@@ -1137,6 +1343,7 @@ k_again: /* entry point for repeated
addr += PLEN; /* skip data */
g->last_block = blknbr;
+ g->fast_path = 1;
}
traceadr[trx] = addr;
@@ -1147,7 +1354,7 @@ k_again: /* entry point for repeated
datal = stlen (data);
offset = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
+ UNSIGN (block[OFFS + 1]);
if (found != 2) { /* new entry */
@@ -1173,7 +1380,8 @@ k_again: /* entry point for repeated
}
-s10: {
+s10:
+ {
long len; /* insert key */
char key0[256];
@@ -1271,10 +1479,9 @@ s10: {
}
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- write (g->fd, block, BLOCKLEN);
+ gbl_write_block (g, blknbr, block);
- if (traceadr[trx] == 0) update (g->fd, compactkey, keyl);
+ if (traceadr[trx] == 0) update (g, compactkey, keyl);
break;
}
@@ -1325,7 +1532,7 @@ s10: {
goto splitd;
}
-s20:
+ s20:
i = offset;
k = addr + olddatal;
@@ -1358,8 +1565,9 @@ s20:
}
stcpy0 (&block[++addr], data, (long) datal);
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- write (g->fd, block, BLOCKLEN);
+
+ gbl_write_block (g, blknbr, block);
+
break;
@@ -1384,14 +1592,13 @@ s20:
/* get following entry, eventually in the next blk */
offset = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
+ UNSIGN (block[OFFS + 1]);
if (addr >= offset) {
if ((blknbr = UNSIGN (block[RLPTR]) * 65536 + UNSIGN (block[RLPTR + 1]) * 256 + UNSIGN (block[RLPTR + 2]))) {
-
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block, BLOCKLEN);
+
+ gbl_read_block (g, blknbr, block);
j1 = UNSIGN (block[0]);
i = 0;
@@ -1472,9 +1679,8 @@ s20:
goto quit;
} /* no next block */
-
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block, BLOCKLEN);
+
+ gbl_read_block (g, blknbr, block);
scandblk (block, &addr, &found);
}
@@ -1521,7 +1727,7 @@ s20:
while (i < keyl) if (compactkey[i++] & 01)
- j1++;
+ j1++;
i = 0;
j = 0;
k = 0;
@@ -1554,8 +1760,8 @@ s20:
while ((ch = UNSIGN (scratch[i++])) != g_EOL) {
ch0 = (ch >= SP ? (ch >> 1) : /* 'string' chars */
- (ch < 20 ? (ch >> 1) + '0' : /* 0...9 */
- (ch >> 1) + SP)); /* '.' or '-' */
+ (ch < 20 ? (ch >> 1) + '0' : /* 0...9 */
+ (ch >> 1) + SP)); /* '.' or '-' */
if (ch0 == DEL) {
@@ -1630,12 +1836,11 @@ s20:
goto quit; /* no next block */
}
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block, BLOCKLEN);
+ gbl_read_block (g, blknbr, block);
addr = 0;
offset = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
+ UNSIGN (block[OFFS + 1]);
}
}
@@ -1654,8 +1859,7 @@ s20:
goto quit; /* no next block */
}
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block, BLOCKLEN);
+ gbl_read_block (g, blknbr, block);
addr = 0;
}
@@ -1703,8 +1907,8 @@ s20:
while ((ch = UNSIGN (key0[i++])) != g_EOL) {
ch0 = (ch >= SP ? (ch >> 1) : /* 'string' chars */
- (ch < 20 ? (ch >> 1) + '0' : /* 0...9 */
- (ch >> 1) + SP)); /* '.' or '-' */
+ (ch < 20 ? (ch >> 1) + '0' : /* 0...9 */
+ (ch >> 1) + SP)); /* '.' or '-' */
if (ch0 == DEL) {
@@ -1780,8 +1984,8 @@ s20:
}
ch0 = (ch >= SP ? (ch >> 1) : /* 'string' chars */
- (ch < 20 ? (ch >> 1) + '0' : /* 0...9 */
- (ch >> 1) + SP)); /* '.' or '-' */
+ (ch < 20 ? (ch >> 1) + '0' : /* 0...9 */
+ (ch >> 1) + SP)); /* '.' or '-' */
if (ch0 == DEL) {
@@ -1825,7 +2029,7 @@ s20:
case kill_sym: /* search and destroy */
-killo: /* entry from killone section */
+ killo: /* entry from killone section */
offset = UNSIGN (block[OFFS]) * 256 + UNSIGN (block[OFFS + 1]);
i = 0;
@@ -1864,32 +2068,30 @@ killo: /* entry from killone section
other = traceblk[--trx];
addr = traceadr[trx];
-
- lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block, BLOCKLEN);
+
+ gbl_read_block (g, other, block);
addr += UNSIGN (block[addr]);
addr += (2 + PLEN); /* skip previous entry */
offset = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
+ UNSIGN (block[OFFS + 1]);
traceadr[trx] = addr;
if (addr < offset) break;
traceadr[trx] = 0;
traceblk[trx] = UNSIGN (block[RLPTR]) * 65536 +
- UNSIGN (block[RLPTR + 1]) * 256 +
- UNSIGN (block[RLPTR + 2]);
+ UNSIGN (block[RLPTR + 1]) * 256 +
+ UNSIGN (block[RLPTR + 2]);
}
trx = trxsav;
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block, BLOCKLEN);
+ gbl_read_block (g, blknbr, block);
offset = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
+ UNSIGN (block[OFFS + 1]);
addr = 0;
k = UNSIGN (block[0]);
stcpy0 (key0, &block[2], k);
@@ -1978,47 +2180,43 @@ killo: /* entry from killone section
if ((begadr == 0) && (endadr == offset)) { /* block becomes empty */
long left,
- right;
+ right;
char block0[BLOCKLEN];
-p_empty: /* entry if pointer block goes empty */
+ p_empty: /* entry if pointer block goes empty */
left = UNSIGN (block[LLPTR]) * 65536 +
- UNSIGN (block[LLPTR + 1]) * 256 +
- UNSIGN (block[LLPTR + 2]);
+ UNSIGN (block[LLPTR + 1]) * 256 +
+ UNSIGN (block[LLPTR + 2]);
right = UNSIGN (block[RLPTR]) * 65536 +
- UNSIGN (block[RLPTR + 1]) * 256 +
- UNSIGN (block[RLPTR + 2]);
+ UNSIGN (block[RLPTR + 1]) * 256 +
+ UNSIGN (block[RLPTR + 2]);
if (left) {
- lseek (g->fd, hdr_offset + ((long) left * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block0, BLOCKLEN);
+ gbl_read_block (g, left, block0);
block0[RLPTR] = block[RLPTR];
block0[RLPTR + 1] = block[RLPTR + 1];
block0[RLPTR + 2] = block[RLPTR + 2];
-
- lseek (g->fd, hdr_offset + ((long) left * (long) (BLOCKLEN)), SEEK_SET);
- write (g->fd, block0, BLOCKLEN);
+
+ gbl_write_block (g, left, block0);
}
if (right) {
-
- lseek (g->fd, hdr_offset + ((long) right * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block0, BLOCKLEN);
+
+ gbl_read_block (g, right, block0);
block0[LLPTR] = block[LLPTR];
block0[LLPTR + 1] = block[LLPTR + 1];
block0[LLPTR + 2] = block[LLPTR + 2];
-
- lseek (g->fd, hdr_offset + ((long) right * (long) (BLOCKLEN)), SEEK_SET);
- write (g->fd, block0, BLOCKLEN);
+
+ gbl_write_block (g, right, block0);
}
- b_free (g->fd, blknbr); /* modify free list */
+ b_free (g, blknbr); /* modify free list */
/* delete pointer */
/**************************/
@@ -2031,10 +2229,9 @@ p_empty: /* entry if pointer block goes
blknbr = traceblk[--trx];
addr = traceadr[trx];
- lseek (g->fd, hdr_offset + ((long) (blknbr) * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block, BLOCKLEN);
+ gbl_read_block (g, blknbr, block);
offset = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
+ UNSIGN (block[OFFS + 1]);
freecnt = UNSIGN (block[addr]) + 2 + PLEN;
/* delete key */
@@ -2044,14 +2241,15 @@ p_empty: /* entry if pointer block goes
if (blknbr == ROOT) { /* global went empty */
- lseek (g->fd, hdr_offset + 0L, SEEK_SET);
+
/* note : UNIX does not tell other */
block[BTYP] = EMPTY; /* jobs that a file has been unlinked */
/* as long as they keep it open. */
/* so we mark this global as EMPTY */
- write (g->fd, block, BLOCKLEN);
+ gbl_write_block (g, 0L, block);
+
gbl_close (g);
unlink (filnam);
@@ -2076,13 +2274,12 @@ p_empty: /* entry if pointer block goes
for (i = offset; i < offset + freecnt; block[i++] = 0);
- lseek (g->fd, hdr_offset + ((long) (blknbr) * (long) (BLOCKLEN)), SEEK_SET);
- write (g->fd, block, BLOCKLEN);
+ gbl_write_block (g, blknbr, block);
if (addr == 0) { /* update of pointer */
traceadr[trx] = 0;
- update (g->fd, &block[2], (long) UNSIGN (block[0]));
+ update (g, &block[2], (long) UNSIGN (block[0]));
}
trx = trxsav;
@@ -2107,28 +2304,29 @@ p_empty: /* entry if pointer block goes
j = block[begadr + 1];
k = 0;
if (begadr)
- while (key0[k] == key1[k])
- k++; /* new key_offset */
+ while (key0[k] == key1[k])
+ k++; /* new key_offset */
if (k < j) {
- ch = j - k; /* space requirement */
- block[begadr] = i + ch; /* new key_length */
- block[begadr + 1] = k; /* new key_offset */
- i = offset;
- j = i + ch;
- offset = j;
- begadr++;
- while (i > begadr)
- block[j--] = block[i--];
- stcpy0 (&block[begadr + 1], &key0[k], ch);
+ ch = j - k; /* space requirement */
+ block[begadr] = i + ch; /* new key_length */
+ block[begadr + 1] = k; /* new key_offset */
+ i = offset;
+ j = i + ch;
+ offset = j;
+ begadr++;
+ while (i > begadr)
+ block[j--] = block[i--];
+ stcpy0 (&block[begadr + 1], &key0[k], ch);
}
}
block[OFFS] = offset / 256;
block[OFFS + 1] = offset % 256;
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- write (g->fd, block, BLOCKLEN);
+
+ gbl_write_block (g, blknbr, block);
+
if (addr < 3) { /* update of pointer */
- traceadr[trx] = 0;
- update (g->fd, &block[2], (long) UNSIGN (block[0]));
+ traceadr[trx] = 0;
+ update (g, &block[2], (long) UNSIGN (block[0]));
}
}
@@ -2136,7 +2334,7 @@ p_empty: /* entry if pointer block goes
break;
-zinv:
+ zinv:
{
long len;
@@ -2150,12 +2348,11 @@ zinv:
data[0] = EOL1;
goto quit;
} /* no previous block */
-
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block, BLOCKLEN);
+
+ gbl_read_block (g, blknbr, block);
addr = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
+ UNSIGN (block[OFFS + 1]);
}
@@ -2230,8 +2427,8 @@ zinv:
while ((ch = UNSIGN (scratch[i++])) != g_EOL) {
ch0 = (ch >= SP ? (ch >> 1) : /* 'string' chars */
- (ch < 20 ? (ch >> 1) + '0' : /* 0...9 */
- (ch >> 1) + SP)); /* '.' or '-' */
+ (ch < 20 ? (ch >> 1) + '0' : /* 0...9 */
+ (ch >> 1) + SP)); /* '.' or '-' */
if (ch0 == DEL) {
@@ -2276,144 +2473,143 @@ zinv:
case zdata: /* nonstandard data function */
- {
- long counties[128];
- char key0[256];
- int icnt, icnt0, len;
+ {
+ long counties[128];
+ char key0[256];
+ int icnt, icnt0, len;
- i = 0;
+ i = 0;
- while (i < 128) counties[i++] = 0L; /* init count; */
+ while (i < 128) counties[i++] = 0L; /* init count; */
- if (found == 2) { /* ... advance to next entry */
- addr += UNSIGN (block[addr]);
- addr += 2; /* skip key */
- addr += UNSIGN (block[addr]);
- addr++; /* skip data */
+ if (found == 2) { /* ... advance to next entry */
+ addr += UNSIGN (block[addr]);
+ addr += 2; /* skip key */
+ addr += UNSIGN (block[addr]);
+ addr++; /* skip data */
- counties[0] = 1L;
- }
+ counties[0] = 1L;
+ }
- offset = UNSIGN (block[OFFS]) * 256 + UNSIGN (block[OFFS + 1]);
- icnt = 0;
- i = 0;
+ offset = UNSIGN (block[OFFS]) * 256 + UNSIGN (block[OFFS + 1]);
+ icnt = 0;
+ i = 0;
- while ((ch = compactkey[i++]) != g_EOL) {
-
- if (ch & 01) {
- icnt++;
- }
+ while ((ch = compactkey[i++]) != g_EOL) {
+ if (ch & 01) {
+ icnt++;
}
- len = i - 1;
- i = 0;
+ }
- while (i < addr) { /* compute offset complete key */
+ len = i - 1;
+ i = 0;
+
+ while (i < addr) { /* compute offset complete key */
- icnt0 = UNSIGN (block[i++]);
- icnt0 += (j = UNSIGN (block[i++]));
+ icnt0 = UNSIGN (block[i++]);
+ icnt0 += (j = UNSIGN (block[i++]));
- while (j < icnt0) key0[j++] = block[i++];
+ while (j < icnt0) key0[j++] = block[i++];
- key0[j] = g_EOL;
- i += UNSIGN (block[i]);
+ key0[j] = g_EOL;
+ i += UNSIGN (block[i]);
- i++; /* skip data */
+ i++; /* skip data */
- }
+ }
- for (;;) { /* is it still a descendant ??? */
+ for (;;) { /* is it still a descendant ??? */
- if (addr >= offset) { /* look in next block */
+ if (addr >= offset) { /* look in next block */
- if ((blknbr = UNSIGN (block[RLPTR]) * 65536 + UNSIGN (block[RLPTR + 1]) * 256 + UNSIGN (block[RLPTR + 2])) == 0) {
- break; /* no next block */
- }
+ if ((blknbr = UNSIGN (block[RLPTR]) * 65536 + UNSIGN (block[RLPTR + 1]) * 256 + UNSIGN (block[RLPTR + 2])) == 0) {
+ break; /* no next block */
+ }
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block, BLOCKLEN);
+ gbl_read_block (g, blknbr, block);
- addr = 0;
- offset = UNSIGN (block[OFFS]) * 256 +
+ addr = 0;
+ offset = UNSIGN (block[OFFS]) * 256 +
UNSIGN (block[OFFS + 1]);
- }
+ }
- i = UNSIGN (block[addr++]);
- i += (j = UNSIGN (block[addr++]));
+ i = UNSIGN (block[addr++]);
+ i += (j = UNSIGN (block[addr++]));
- while (j < i) key0[j++] = block[addr++];
+ while (j < i) key0[j++] = block[addr++];
- addr += UNSIGN (block[addr]);
- addr++; /* skip data */
- icnt0 = 0;
- i = 0;
+ addr += UNSIGN (block[addr]);
+ addr++; /* skip data */
+ icnt0 = 0;
+ i = 0;
- while (i < j) if (key0[i++] & 01)
+ while (i < j) if (key0[i++] & 01)
- icnt0++;
+ icnt0++;
- if (icnt0 <= icnt) break;
+ if (icnt0 <= icnt) break;
- i = 0;
+ i = 0;
- while (i < len) {
+ while (i < len) {
- if (key0[i] != compactkey[i]) break;
+ if (key0[i] != compactkey[i]) break;
- i++;
+ i++;
- }
+ }
- if (i < len) break;
+ if (i < len) break;
- counties[icnt0 - icnt]++;
+ counties[icnt0 - icnt]++;
- }
+ }
- i = 128;
+ i = 128;
- while (counties[--i] == 0L);
+ while (counties[--i] == 0L);
- lintstr (data, counties[0]);
+ lintstr (data, counties[0]);
- j = 1;
- tmp1[0] = ',';
+ j = 1;
+ tmp1[0] = ',';
- while (j <= i) {
- lintstr (&tmp1[1], counties[j++]);
- stcat (data, tmp1);
- }
-
+ while (j <= i) {
+ lintstr (&tmp1[1], counties[j++]);
+ stcat (data, tmp1);
}
+
+ }
- break;
+ break;
case getinc:
- {
- int setopsav;
+ {
+ int setopsav;
- setopsav = setop;
- setop = '+';
- data[0] = '1';
- data[1] = EOL;
+ setopsav = setop;
+ setop = '+';
+ data[0] = '1';
+ data[1] = EOL;
- global (set_sym, key, data);
+ global (set_sym, key, data);
- setop = setopsav;
+ setop = setopsav;
- return;
- }
+ return;
+ }
case killone:
- {
- if (found == 2) goto killo; /* entry found use normal kill routine */
+ {
+ if (found == 2) goto killo; /* entry found use normal kill routine */
- goto quit;
- }
+ goto quit;
+ }
case merge_sym:
@@ -2460,7 +2656,7 @@ splitd: /* split data block in two se
/* 'addr' there I would like to insert, if possible (which is not) */
/* 'offset' filled up to this limit */
- getnewblk (g->fd, &newblk); /* get a new block */
+ getnewblk (g, &newblk); /* get a new block */
/* if we have to insert at the begin or end of a block */
/* we don't split - we just start a new block */
@@ -2468,8 +2664,8 @@ splitd: /* split data block in two se
if (addr >= offset) {
long right,
- right1,
- right2;
+ right1,
+ right2;
right = UNSIGN (block[RLPTR]);
right1 = UNSIGN (block[RLPTR + 1]);
@@ -2478,8 +2674,7 @@ splitd: /* split data block in two se
block[RLPTR + 1] = newblk % 65536 / 256;
block[RLPTR + 2] = newblk % 256;
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- write (g->fd, block, BLOCKLEN);
+ gbl_write_block (g, blknbr, block);
block[RLPTR] = right;
block[RLPTR + 1] = right1;
@@ -2491,23 +2686,21 @@ splitd: /* split data block in two se
addr = 0;
blknbr = newblk;
- insert (g->fd, compactkey, keyl, newblk);
+ insert (g, compactkey, keyl, newblk);
/* up-date LL-PTR of RL-block */
if ((other = right * 65536 + right1 * 256 + right2)) {
char block0[BLOCKLEN];
- lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block0, BLOCKLEN);
+ gbl_read_block (g, other, block0);
block0[LLPTR] = blknbr / 65536;
block0[LLPTR + 1] = blknbr % 65536 / 256;
block0[LLPTR + 2] = blknbr % 256;
- lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET);
- write (g->fd, block0, BLOCKLEN);
-
+ gbl_write_block (g, other, block0);
+
}
goto spltex;
@@ -2524,9 +2717,8 @@ splitd: /* split data block in two se
block[LLPTR + 1] = newblk % 65536 / 256;
block[LLPTR + 2] = newblk % 256;
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- write (g->fd, block, BLOCKLEN);
-
+ gbl_write_block (g, blknbr, block);
+
block[LLPTR] = left;
block[LLPTR + 1] = left1;
block[LLPTR + 2] = left2;
@@ -2537,26 +2729,26 @@ splitd: /* split data block in two se
blknbr = newblk;
traceadr[trx] = (-1); /* inhibit second update of pointers */
- insert (g->fd, compactkey, keyl, newblk);
+ insert (g, compactkey, keyl, newblk);
if (addr < 3) { /* update of pointer */
traceadr[trx] = 0;
- update (g->fd, compactkey, keyl);
+ update (g, compactkey, keyl);
}
/* other is ***always*** zero !!!
- * if (other=left*65536+left1*256+left2) up-date RL-PTR of LL-block
- * { char block0[BLOCKLEN];
- * lseek(filedes,(long)other*(long)(BLOCKLEN),0);
- * read(filedes,block0,BLOCKLEN);
- * block0[RLPTR ]=blknbr/65536;
- * block0[RLPTR+1]=blknbr%65536/256;
- * block0[RLPTR+2]=blknbr%256;
- * lseek(filedes,(long)other*(long)(BLOCKLEN),0);
- * write(filedes,block0,BLOCKLEN);
- * }
- */
+ * if (other=left*65536+left1*256+left2) up-date RL-PTR of LL-block
+ * { char block0[BLOCKLEN];
+ * lseek(filedes,(long)other*(long)(BLOCKLEN),0);
+ * read(filedes,block0,BLOCKLEN);
+ * block0[RLPTR ]=blknbr/65536;
+ * block0[RLPTR+1]=blknbr%65536/256;
+ * block0[RLPTR+2]=blknbr%256;
+ * lseek(filedes,(long)other*(long)(BLOCKLEN),0);
+ * write(filedes,block0,BLOCKLEN);
+ * }
+ */
goto spltex;
@@ -2638,8 +2830,8 @@ splitd: /* split data block in two se
/* update rightlink and leftlink pointers */
other = UNSIGN (block[RLPTR]) * 65536 +
- UNSIGN (block[RLPTR + 1]) * 256 +
- UNSIGN (block[RLPTR + 2]);
+ UNSIGN (block[RLPTR + 1]) * 256 +
+ UNSIGN (block[RLPTR + 2]);
block0[RLPTR] = block[RLPTR];
block0[RLPTR + 1] = block[RLPTR + 1];
block0[RLPTR + 2] = block[RLPTR + 2];
@@ -2650,26 +2842,23 @@ splitd: /* split data block in two se
block0[LLPTR + 1] = blknbr % 65536 / 256;
block0[LLPTR + 2] = blknbr % 256;
- lseek (g->fd, hdr_offset + ((long) (newblk) * (long) (BLOCKLEN)), SEEK_SET);
- write (g->fd, block0, BLOCKLEN);
+ gbl_write_block (g, newblk, block0);
offset = limit;
/* insert new block in pointer structure */
- insert (g->fd, &block0[2], (long) UNSIGN (block0[0]), newblk);
+ insert (g, &block0[2], (long) UNSIGN (block0[0]), newblk);
/* up-date LL-PTR of RL-block */
if (other != 0) {
- lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block0, BLOCKLEN);
+ gbl_read_block (g, other, block0);
block0[LLPTR] = newblk / 65536;
block0[LLPTR + 1] = newblk % 65536 / 256;
block0[LLPTR + 2] = newblk % 256;
-
- lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET);
- write (g->fd, block0, BLOCKLEN);
+
+ gbl_write_block (g, other, block0);
}
@@ -2678,8 +2867,8 @@ splitd: /* split data block in two se
/* save old block away and make new block the current block */
/* update rightlink and leftlink pointers */
other = UNSIGN (block[RLPTR]) * 65536 +
- UNSIGN (block[RLPTR + 1]) * 256 +
- UNSIGN (block[RLPTR + 2]);
+ UNSIGN (block[RLPTR + 1]) * 256 +
+ UNSIGN (block[RLPTR + 2]);
block0[RLPTR] = block[RLPTR];
block0[RLPTR + 1] = block[RLPTR + 1];
block0[RLPTR + 2] = block[RLPTR + 2];
@@ -2690,28 +2879,26 @@ splitd: /* split data block in two se
block0[LLPTR + 1] = blknbr % 65536 / 256;
block0[LLPTR + 2] = blknbr % 256;
- lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- write (g->fd, block, BLOCKLEN);
+ gbl_write_block (g, blknbr, block);
+
stcpy0 (block, block0, (long) BLOCKLEN);
traceadr[trx] = (addr -= limit);
traceblk[trx] = (blknbr = newblk);
/* insert new block in pointer structure */
- insert (g->fd, &block0[2], (long) UNSIGN (block0[0]), newblk);
+ insert (g, &block0[2], (long) UNSIGN (block0[0]), newblk);
/* up-date LL-PTR of RL-block */
if (other != 0) {
- lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET);
- read (g->fd, block0, BLOCKLEN);
+ gbl_read_block (g, other, block0);
block0[LLPTR] = newblk / 65536;
block0[LLPTR + 1] = newblk % 65536 / 256;
block0[LLPTR + 2] = newblk % 256;
-
- lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET);
- write (g->fd, block0, BLOCKLEN);
+
+ gbl_write_block (g, other, block0);
}
@@ -2738,7 +2925,7 @@ spltex:
* 'addr' there I would like to insert, if possible (which is not)
* 'offset' filled up to this limit
*/
-static void splitp (short filedes, char *block, long *addr, long *offs, unsigned long *blknbr)
+static void splitp (global_handle *g, char *block, long *addr, long *offs, unsigned long *blknbr)
{
char block0[BLOCKLEN];
@@ -2746,12 +2933,8 @@ static void splitp (short filedes, char
unsigned long newblk;
unsigned long other;
register int i, j;
-
- long hdr_offset;
-
- hdr_offset = sizeof (global_header);
- getnewblk (filedes, &newblk); /* get a new block */
+ getnewblk (g, &newblk); /* get a new block */
if (*blknbr == ROOT) { /* ROOT overflow is special */
@@ -2778,16 +2961,15 @@ static void splitp (short filedes, char
/* update number of blocks ! */
i = UNSIGN (block0[NRBLK]) * 65536 +
- UNSIGN (block0[NRBLK + 1]) * 256 +
- UNSIGN (block0[NRBLK + 2]) + 1;
+ UNSIGN (block0[NRBLK + 1]) * 256 +
+ UNSIGN (block0[NRBLK + 2]) + 1;
block0[NRBLK] = i / 65536;
block0[NRBLK + 1] = i % 65536 / 256;
block0[NRBLK + 2] = i % 256;
block0[BTYP] = POINTER;
- lseek (filedes, hdr_offset + ROOT, SEEK_SET);
- write (filedes, block0, BLOCKLEN);
+ gbl_write_block (g, ROOT, block0);
/* shift trace_stack */
j = trx++;
@@ -2804,7 +2986,7 @@ static void splitp (short filedes, char
traceblk[1] = newblk;
*blknbr = newblk;
- getnewblk (filedes, &newblk); /* get a new block */
+ getnewblk (g, &newblk); /* get a new block */
}
@@ -2846,8 +3028,8 @@ static void splitp (short filedes, char
/* update rightlink and leftlink pointers */
other = UNSIGN (block[RLPTR]) * 65536 +
- UNSIGN (block[RLPTR + 1]) * 256 +
- UNSIGN (block[RLPTR + 2]);
+ UNSIGN (block[RLPTR + 1]) * 256 +
+ UNSIGN (block[RLPTR + 2]);
block0[RLPTR] = block[RLPTR];
block0[RLPTR + 1] = block[RLPTR + 1];
block0[RLPTR + 2] = block[RLPTR + 2];
@@ -2858,25 +3040,22 @@ static void splitp (short filedes, char
block0[LLPTR + 1] = (*blknbr) % 65536 / 256;
block0[LLPTR + 2] = (*blknbr) % 256;
- lseek (filedes, hdr_offset + ((long) (newblk) * (long) (BLOCKLEN)), SEEK_SET);
- write (filedes, block0, BLOCKLEN);
+ gbl_write_block (g, newblk, block0);
(*offs) = limit;
- insert (filedes, &block0[2], (long) UNSIGN (block0[0]), newblk);
+ insert (g, &block0[2], (long) UNSIGN (block0[0]), newblk);
/* up-date LL-PTR of RL-block */
if (other != 0) {
- lseek (filedes, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET);
- read (filedes, block0, BLOCKLEN);
+ gbl_read_block (g, other, block0);
block0[LLPTR] = newblk / 65536;
block0[LLPTR + 1] = newblk % 65536 / 256;
block0[LLPTR + 2] = newblk % 256;
-
- lseek (filedes, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET);
- write (filedes, block0, BLOCKLEN);
+
+ gbl_write_block (g, other, block0);
}
@@ -2885,8 +3064,8 @@ static void splitp (short filedes, char
/* update rightlink and leftlink pointers */
other = UNSIGN (block[RLPTR]) * 65536 +
- UNSIGN (block[RLPTR + 1]) * 256 +
- UNSIGN (block[RLPTR + 2]);
+ UNSIGN (block[RLPTR + 1]) * 256 +
+ UNSIGN (block[RLPTR + 2]);
block0[RLPTR] = block[RLPTR];
block0[RLPTR + 1] = block[RLPTR + 1];
@@ -2900,27 +3079,25 @@ static void splitp (short filedes, char
(*addr) -= limit;
(*offs) -= limit;
+
+ gbl_write_block (g, *blknbr, block);
- lseek (filedes, hdr_offset + ((long) (*blknbr) * (long) (BLOCKLEN)), SEEK_SET);
- write (filedes, block, BLOCKLEN);
stcpy0 (block, block0, (long) BLOCKLEN);
(*blknbr) = newblk;
- insert (filedes, &block0[2], (long) UNSIGN (block0[0]), newblk);
+ insert (g, &block0[2], (long) UNSIGN (block0[0]), newblk);
/* up-date LL-PTR of RL-block */
if (other != 0) {
- lseek (filedes, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET);
- read (filedes, block0, BLOCKLEN);
+ gbl_read_block (g, other, block0);
block0[LLPTR] = newblk / 65536;
block0[LLPTR + 1] = newblk % 65536 / 256;
block0[LLPTR + 2] = newblk % 256;
-
- lseek (filedes, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET);
- write (filedes, block0, BLOCKLEN);
+
+ gbl_write_block (g, other, block0);
}
@@ -2935,16 +3112,13 @@ static void splitp (short filedes, char
* ins_key: key to be inserted
* keyl: length of that key
*/
-static void update (short filedes, char *ins_key, long keyl)
+static void update (global_handle *g, char *ins_key, long keyl)
{
long offset;
long addr;
unsigned long blknbr;
char block[BLOCKLEN];
long i, j, k;
- long hdr_offset;
-
- hdr_offset = sizeof (global_header);
while (traceadr[trx] == 0) { /* update of pointer blocks necessary */
@@ -2952,9 +3126,8 @@ static void update (short filedes, char
blknbr = traceblk[trx];
addr = traceadr[trx];
-
- lseek (filedes, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- read (filedes, block, BLOCKLEN);
+
+ gbl_read_block (g, blknbr, block);
{
long oldkeyl;
@@ -2965,7 +3138,7 @@ static void update (short filedes, char
j = oldkeyl - keyl;
offset = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
+ UNSIGN (block[OFFS + 1]);
if (j > 0) { /* surplus space */
@@ -2981,7 +3154,7 @@ static void update (short filedes, char
else if (j < 0) { /* we need more space */
/* block too small */
- if ((offset - j) > DATALIM) splitp (filedes, block, &addr, &offset, &blknbr);
+ if ((offset - j) > DATALIM) splitp (g, block, &addr, &offset, &blknbr);
i = offset;
offset -= j;
@@ -3004,13 +3177,10 @@ static void update (short filedes, char
while (i < keyl) block[j++] = ins_key[i++];
/* block pointed to remains the same */
- lseek (filedes, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- write (filedes, block, BLOCKLEN);
-
+ gbl_write_block (g, blknbr, block);
}
-
- lseek (filedes, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET);
- read (filedes, block, BLOCKLEN);
+
+ gbl_read_block (g, blknbr, block);
}
@@ -3025,7 +3195,7 @@ static void update (short filedes, char
* key_len: length of that key
* blknbr: key points to this block
*/
-static void insert (int filedes, char *ins_key, long key_len, unsigned long blknbr) /* insert pointer */
+static void insert (global_handle *g, char *ins_key, long key_len, unsigned long blknbr) /* insert pointer */
{
unsigned long blk;
char block[BLOCKLEN];
@@ -3034,19 +3204,15 @@ static void insert (int filedes, char *i
long needed;
long addr;
register int i, k;
- long hdr_offset;
-
- hdr_offset = sizeof (global_header);
trxsav = trx--;
blk = traceblk[trx];
addr = traceadr[trx];
- lseek (filedes, hdr_offset + ((long) (blk) * (long) (BLOCKLEN)), SEEK_SET);
- read (filedes, block, BLOCKLEN);
+ gbl_read_block (g, blk, block);
offset = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
+ UNSIGN (block[OFFS + 1]);
if (traceadr[trx + 1] != (-1)) {
addr += UNSIGN (block[addr]);
@@ -3055,7 +3221,7 @@ static void insert (int filedes, char *i
needed = key_len + 2 + PLEN;
- if ((offset + needed) > DATALIM) splitp (filedes, block, &addr, &offset, &blk);
+ if ((offset + needed) > DATALIM) splitp (g, block, &addr, &offset, &blk);
/* insert key */
i = (offset += needed);
@@ -3079,8 +3245,7 @@ static void insert (int filedes, char *i
block[i++] = blknbr % 65536 / 256;
block[i] = blknbr % 256;
- lseek (filedes, hdr_offset + ((long) (blk) * (long) (BLOCKLEN)), SEEK_SET);
- write (filedes, block, BLOCKLEN);
+ gbl_write_block (g, blk, block);
trx = trxsav;
@@ -3092,40 +3257,33 @@ static void insert (int filedes, char *i
* filedes: global file descriptor
* blknbr: block to be freed
*/
-static void b_free (short filedes, unsigned long blknbr)
+static void b_free (global_handle *g, unsigned long blknbr)
{
char block0[BLOCKLEN];
unsigned long free;
unsigned long other;
long i;
long offset;
- long hdr_offset;
-
- hdr_offset = sizeof (global_header);
/* mark block as empty */
- lseek (filedes, hdr_offset + ((long) (blknbr) * BLOCKLEN), SEEK_SET);
- read (filedes, block0, BLOCKLEN);
-
- block0[BTYP] = EMPTY;
+ gbl_read_block (g, blknbr, block0);
- lseek (filedes, hdr_offset + ((long) (blknbr) * BLOCKLEN), SEEK_SET);
- write (filedes, block0, BLOCKLEN);
+ block0[BTYP] = EMPTY;
+
+ gbl_write_block (g, blknbr, block0);
/* do we have a list of free blocks? */
- lseek (filedes, hdr_offset + ROOT, SEEK_SET);
- read (filedes, block0, BLOCKLEN);
+ gbl_read_block (g, ROOT, block0);
if ((free = UNSIGN (block0[FREE]) * 65536 + UNSIGN (block0[FREE + 1]) * 256 + UNSIGN (block0[FREE + 2]))) {
for (;;) {
-
- lseek (filedes, hdr_offset + ((long) free * (long) BLOCKLEN), SEEK_SET);
- read (filedes, block0, BLOCKLEN);
+
+ gbl_read_block (g, free, block0);
other = UNSIGN (block0[RLPTR]) * 65536 +
- UNSIGN (block0[RLPTR + 1]) * 256 +
- UNSIGN (block0[RLPTR + 2]);
+ UNSIGN (block0[RLPTR + 1]) * 256 +
+ UNSIGN (block0[RLPTR + 2]);
if (other == 0) break;
@@ -3141,8 +3299,8 @@ static void b_free (short filedes, unsig
offset -= PLEN;
other = UNSIGN (block0[offset]) * 65536 +
- UNSIGN (block0[offset + 1]) * 256 +
- UNSIGN (block0[offset + 2]);
+ UNSIGN (block0[offset + 1]) * 256 +
+ UNSIGN (block0[offset + 2]);
block0[offset] = 0;
block0[offset + 1] = 0;
@@ -3152,9 +3310,8 @@ static void b_free (short filedes, unsig
block0[RLPTR] = other / 65536;
block0[RLPTR + 1] = other % 65536 / 256;
block0[RLPTR + 2] = other % 256;
-
- lseek (filedes, hdr_offset + ((long) free * (long) BLOCKLEN), SEEK_SET);
- write (filedes, block0, BLOCKLEN);
+
+ gbl_write_block (g, free, block0);
for (i = 0; i < BLOCKLEN; block0[i++] = 0); /* clear block */
@@ -3170,19 +3327,16 @@ static void b_free (short filedes, unsig
}
else {
-
- getnewblk (filedes, &free);
+ getnewblk (g, &free);
/* set FBLK free blocks pointer */
- lseek (filedes, hdr_offset + ROOT, SEEK_SET);
- read (filedes, block0, BLOCKLEN);
+ gbl_read_block (g, ROOT, block0);
block0[FREE] = free / 65536;
block0[FREE + 1] = free % 65536 / 256;
block0[FREE + 2] = free % 256;
-
- lseek (filedes, hdr_offset + ROOT, SEEK_SET);
- write (filedes, block0, BLOCKLEN);
+
+ gbl_write_block (g, ROOT, block0);
for (i = 0; i < BLOCKLEN; block0[i++] = 0); /* clear block */
@@ -3197,8 +3351,7 @@ static void b_free (short filedes, unsig
block0[OFFS] = offset / 256;
block0[OFFS + 1] = offset % 256;
- lseek (filedes, hdr_offset + ((long) free * (long) BLOCKLEN), SEEK_SET);
- write (filedes, block0, BLOCKLEN);
+ gbl_write_block (g, free, block0);
return;
} /* end of b_free() */
@@ -3271,7 +3424,7 @@ static void scandblk (char *block, long
char key0[256];
offset = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
+ UNSIGN (block[OFFS + 1]);
while (i < offset) {
@@ -3318,26 +3471,21 @@ static void scandblk (char *block, long
* filedes: global file descriptor
* blknbr: number of new block
*/
-static void getnewblk (int filedes, unsigned long *blknbr)
+static void getnewblk (global_handle *g, unsigned long *blknbr)
{
char nblock[BLOCKLEN];
unsigned long freeblks, no_of_blks;
long other;
long offset;
- long hdr_offset;
- hdr_offset = sizeof (global_header);
-
- lseek (filedes, hdr_offset + ROOT, SEEK_SET);
- read (filedes, nblock, BLOCKLEN);
+ gbl_read_block (g, ROOT, nblock);
freeblks = UNSIGN (nblock[FREE]) * 65536 + UNSIGN (nblock[FREE + 1]) * 256 + UNSIGN (nblock[FREE + 2]);
no_of_blks = UNSIGN (nblock[NRBLK]) * 65536 + UNSIGN (nblock[NRBLK + 1]) * 256 + UNSIGN (nblock[NRBLK + 2]);
if (freeblks) {
-
- lseek (filedes, hdr_offset + ((long) (freeblks) * BLOCKLEN), SEEK_SET);
- read (filedes, nblock, BLOCKLEN);
+
+ gbl_read_block (g, freeblks, nblock);
offset = UNSIGN (nblock[OFFS]) * 256 + UNSIGN (nblock[OFFS + 1]);
@@ -3349,28 +3497,24 @@ static void getnewblk (int filedes, unsi
/* update RL-block, if any */
if (other) {
- lseek (filedes, hdr_offset + ((long) (other) * BLOCKLEN), SEEK_SET);
- read (filedes, nblock, BLOCKLEN);
+ gbl_read_block (g, other, nblock);
nblock[LLPTR] = 0;
nblock[LLPTR + 1] = 0;
nblock[LLPTR + 2] = 0;
-
- lseek (filedes, hdr_offset + ((long) (other) * BLOCKLEN), SEEK_SET);
- write (filedes, nblock, BLOCKLEN);
+
+ gbl_write_block (g, other, nblock);
}
/* update ROOT block */
- lseek (filedes, hdr_offset + ROOT, SEEK_SET);
- read (filedes, nblock, BLOCKLEN);
+ gbl_read_block (g, ROOT, nblock);
nblock[FREE] = other / 65536;
nblock[FREE + 1] = other % 65536 / 256;
nblock[FREE + 2] = other % 256;
-
- lseek (filedes, hdr_offset + ROOT, SEEK_SET);
- write (filedes, nblock, BLOCKLEN);
+
+ gbl_write_block (g, ROOT, nblock);
return;
@@ -3382,9 +3526,8 @@ static void getnewblk (int filedes, unsi
nblock[offset + 1] = 0;
nblock[OFFS] = offset / 256;
nblock[OFFS + 1] = offset % 256;
-
- lseek (filedes, hdr_offset + ((long) (freeblks) * BLOCKLEN), SEEK_SET);
- write (filedes, nblock, BLOCKLEN);
+
+ gbl_write_block (g, freeblks, nblock);
return;
@@ -3395,24 +3538,12 @@ static void getnewblk (int filedes, unsi
nblock[NRBLK] = no_of_blks / 65536;
nblock[NRBLK + 1] = no_of_blks % 65536 / 256;
nblock[NRBLK + 2] = no_of_blks % 256;
-
- lseek (filedes, hdr_offset + ROOT, SEEK_SET);
- write (filedes, nblock, BLOCKLEN);
+
+ gbl_write_block (g, ROOT, nblock);
*blknbr = no_of_blks;
-
- for (;;) {
-
- errno = 0;
-
- lseek (filedes, hdr_offset + ((long) (no_of_blks) * BLOCKLEN), SEEK_SET);
- write (filedes, nblock, BLOCKLEN);
-
- if (errno == 0) break;
- panic ();
-
- }
+ gbl_write_block (g, no_of_blks, nblock);
return;
@@ -3541,7 +3672,6 @@ static short int g_collate (char *t)
/*
* test whether 'str' is canonical
*/
-//static short int g_numeric (char *str)
short g_numeric (char *str)
{
register int ptr = 0, ch;
@@ -3584,26 +3714,13 @@ short g_numeric (char *str)
} /* end g_numeric() */
+
+/* DEPRECATED: use gbl_close_all() instead */
void close_all_globals (void)
{
- register int i;
-
- for (i = 0; i < NO_GLOBLS; i++) {
-
- if (oldfil[i][0] != NUL) {
-
- close (olddes[i]);
-
- usage[i] = 0;
- olddes[i] = 0;
- oldfil[i][0] = NUL;
-
- }
-
- }
-
+ gbl_close_all ();
+
return;
-
} /* end close_all_globals() */
static void panic (void)
@@ -3630,14 +3747,45 @@ static void panic (void)
void gbl_dump_stat(void)
{
global_handle *g;
-
- printf ("FreeM Global Statistics [PID %d]\r\n", pid);
+ int ct;
+ int miss_pct;
+ int hit_pct;
+ unsigned long access_total;
+ unsigned long hit_total;
+ unsigned long mem_reads_total;
- printf ("%-20s%-10s%-20s%-10s%s\r\n", "GLOBAL", "USECT", "AGE", "LAST BLK", "FILE");
- printf ("%-20s%-10s%-20s%-10s%s\r\n", "======", "=====", "===", "========", "====");
-
+ mem_reads_total = 0;
+ printf ("\r\nFreeM Global Statistics [PID %d]\r\n\r\n", pid);
+
+ printf ("%-20s%-10s%-10s%-10s%-10s%-12s%-20s%-10s%s\r\n", "GLOBAL", "USECT", "READS", "WRITES", "MEMREADS", "SLOW PTHCT", "AGE", "LAST BLK", "FILE");
+ printf ("%-20s%-10s%-10s%-10s%-10s%-12s%-20s%-10s%s\r\n", "======", "=====", "=====", "======", "========", "==========", "===", "========", "====");
+
+ access_total = 0;
+ ct = 0;
for (g = global_handles_head; g != NULL; g = g->next) {
- printf ("%-20s%-10d%-20d%-10d%s\r\n", g->global_name, g->use_count, g->age, g->last_block, g->global_path);
- }
+ printf ("%-20s%-10ld%-10ld%-10ld%-10ld%-12ld%-20ld%-10ld%s\r\n",
+ g->global_name,
+ g->use_count,
+ g->read_ops,
+ g->write_ops,
+ g->memory_reads,
+ g->cache_misses,
+ g->age,
+ g->last_block,
+ g->global_path);
+ ct++;
+ mem_reads_total += g->memory_reads;
+ access_total += g->use_count;
+ }
+ if (!ct) printf ("\r\n");
+
+ hit_total = access_total - gbl_cache_misses;
+ miss_pct = (gbl_cache_misses * 100) / access_total;
+ hit_pct = (hit_total * 100) / access_total;
+
+ printf ("\r\nTotal accesses: %ld\r\n", access_total);
+ printf ("Fast path hits %ld\t(%d%%)\r\n", hit_total, hit_pct);
+ printf ("Fast path misses: %ld\t(%d%%)\r\n", gbl_cache_misses, miss_pct);
+ printf ("Disk reads avoided: %ld\r\n", mem_reads_total);
}