--- freem/src/global_bltin.c 2025/04/11 14:21:03 1.17
+++ freem/src/global_bltin.c 2025/04/17 14:34:27 1.23
@@ -1,5 +1,5 @@
/*
- * $Id: global_bltin.c,v 1.17 2025/04/11 14:21:03 snw Exp $
+ * $Id: global_bltin.c,v 1.23 2025/04/17 14:34:27 snw Exp $
* freem database engine
*
*
@@ -24,6 +24,24 @@
* along with FreeM. If not, see .
*
* $Log: global_bltin.c,v $
+ * Revision 1.23 2025/04/17 14:34:27 snw
+ * Further logging improvements
+ *
+ * Revision 1.22 2025/04/13 04:22:43 snw
+ * Fix snprintf calls
+ *
+ * Revision 1.21 2025/04/11 20:55:49 snw
+ * Disable -Wunused-result where possible
+ *
+ * Revision 1.20 2025/04/11 18:24:32 snw
+ * Fix bug in memory cache
+ *
+ * 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
*
@@ -82,6 +100,7 @@
#include "mpsdef.h"
#include "journal.h"
#include "global_bltin.h"
+#include "log.h"
global_handle *global_handles_head;
unsigned long gbl_cache_misses = 0;
@@ -99,47 +118,8 @@ short g_numeric (char *str);
void close_all_globals(void);
static void panic (void);
-#define ROOT 0L
-
-/* end of line symbol in global module is 30, which is a code not */
-/* otherwise used in subscripts */
-#define g_EOL 30
-
-#define EOL1 EOL
-
-/* numerics (('.'<<1)&037)==28 ; (('-'<<1)&037)==26; */
-#define POINT 28
-#define MINUS 26
-
-/* ALPHA and OMEGA are dummy subscripts in $order processing */
-/* ALPHA sorts before all other subscripts */
-/* OMEGA sorts after all other subscripts */
-/* e.g. ("abc") -> "abc",OMEGA ; ("abc","") -> "abc",ALPHA */
-#define OMEGA 29
-#define ALPHA 31
-
-/* length of blocks. status bytes defined as offset to blocklength */
-/* BLOCKLEN 1024 is defined in mpsdef0 include file */
-#define DATALIM (BLOCKLEN-11)
-#define LLPTR (BLOCKLEN-10)
-#define NRBLK LLPTR
-#define COLLA (BLOCKLEN- 7)
-#define RLPTR (BLOCKLEN- 6)
-#define FREE RLPTR
-#define BTYP (BLOCKLEN- 3)
-#define OFFS (BLOCKLEN- 2)
-
-/* length of blockpointers in bytes */
-#define PLEN 3
-
-#define EMPTY 0
-#define FBLK 1
-#define POINTER 2
-#define BOTTOM 6
-#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)
@@ -303,7 +283,7 @@ int gbl_write_initial_header(global_hand
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);
+ snprintf (msg, sizeof (msg) - 1, "error %d writing global header for %s", errno, g->global_name);
m_fatal (msg);
}
@@ -323,17 +303,17 @@ int gbl_write_header(global_handle *g, g
return FALSE;
}
- if (g->locked == FALSE) gbl_lock (g, 1);
+ 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);
+ snprintf (msg, sizeof (msg) - 1, "error %d writing global header for %s", errno, g->global_name);
m_fatal (msg);
}
lseek (g->fd, old_position, SEEK_SET);
- if (g->locked == TRUE) gbl_unlock (g);
+ gbl_unlock (g);
gbl_read_header (g, &g->header);
@@ -445,9 +425,13 @@ short gbl_open(global_handle *g, short a
}
else {
g->opened = TRUE;
- result = gbl_read_header (g, &g->header);
+ 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 {
@@ -457,13 +441,11 @@ short gbl_open(global_handle *g, short a
switch (result) {
case GBL_HDR_BADMAGIC:
- fprintf (stderr, "gbl_open: bad magic value in %s [FATAL]\n", g->global_name);
- exit (1);
+ logprintf (FM_LOG_FATAL, "gbl_open: bad magic value in %s", g->global_name);
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);
+ logprintf (FM_LOG_FATAL, "gbl_open: global version is %d in %s (must be %d)", g->header.format_version, g->global_name, GBL_FORMAT_VERSION);
break;
}
@@ -479,6 +461,7 @@ short gbl_open(global_handle *g, short a
int gbl_read_block(global_handle *g, unsigned long blocknum, char *block)
{
+ struct stat gstat;
unsigned long hdr_offset;
hdr_offset = sizeof (global_header);
@@ -486,13 +469,36 @@ int gbl_read_block(global_handle *g, uns
return FALSE;
}
- gbl_lock (g, 1);
- lseek (g->fd, hdr_offset + ((long) blocknum * (long) (g->header.block_size)), SEEK_SET);
- read (g->fd, block, g->header.block_size);
- g->last_block = blocknum;
g->use_count++;
- g->read_ops++;
- gbl_unlock (g);
+
+ if (!g->locked) gbl_lock (g, 1);
+ fstat (g->fd, &gstat);
+
+ 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++;
+ 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->cached_block_num = blocknum;
+ g->last_block = blocknum;
+ g->read_ops++;
+ }
+
+ g->last_read_time = time (0L);
+ g->use_count++;
+
+ if (g->locked) gbl_unlock (g);
return TRUE;
} /* gbl_read_block() */
@@ -507,16 +513,14 @@ int gbl_write_block(global_handle *g, un
return FALSE;
}
- if (!g->locked) {
- gbl_lock (g, 1);
- }
+ gbl_lock (g, 1);
for (;;) {
errno = 0;
lseek (g->fd, hdr_offset + (blocknum * g->header.block_size), SEEK_SET);
- write (g->fd, block, BLOCKLEN);
+ write (g->fd, block, g->header.block_size);
errsav = errno;
g->last_block = blocknum;
g->use_count++;
@@ -528,11 +532,8 @@ int gbl_write_block(global_handle *g, un
}
- gbl_update_tid (g);
-
- if (g->locked) {
- gbl_unlock (g);
- }
+ gbl_update_tid (g);
+ gbl_unlock (g);
return TRUE;
}
@@ -578,6 +579,7 @@ 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;
@@ -586,6 +588,9 @@ global_handle *gbl_handle(char *key)
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);
@@ -704,7 +709,7 @@ 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;
@@ -713,83 +718,62 @@ void global_bltin (short action, char *k
register long int k;
register long int ch;
- j = 0;
-
+ j = 0;
hdr_offset = sizeof (global_header);
/* process optional limitations */
if (glvnflag.all && key[0] >= '%' && key[0] <= 'z') {
if ((i = glvnflag.one[0])) { /* number of significant chars */
-
j = 0;
while ((k = key[j]) != DELIM && k != EOL) {
-
if (j >= i) {
-
while ((k = key[++j]) != DELIM && k != EOL);
-
stcpy (&key[i], &key[j]);
-
break;
}
-
j++;
-
}
}
if (glvnflag.one[1]) { /* upper/lower sensitivity */
-
j = 0;
-
while ((k = key[j]) != DELIM && k != EOL) {
-
if (k >= 'a' && k <= 'z') key[j] = k - 32;
-
j++;
-
}
}
if ((i = glvnflag.one[2])) {
-
if (stlen (key) > i) {
merr_raise (M75);
return;
} /* key length limit */
-
}
if ((i = glvnflag.one[3])) { /* subscript length limit */
-
+
j = 0;
-
while ((k = key[j++]) != DELIM && k != EOL);
-
+
if (k == DELIM) {
-
k = 0;
for (;;) {
-
k = key[j++];
-
if (k == DELIM || k == EOL) {
-
if (k > i) {
merr_raise (M75);
return;
}
-
k = 0;
}
-
if (k == EOL) break;
k++;
}
}
+
}
}
@@ -852,22 +836,6 @@ void global_bltin (short action, char *k
}
}
- if (v22ptr) {
-
- procv22 (key);
-
- if (key[0] != '^') {
- char losav[256];
-
- stcpy (losav, l_o_val);
- symtab (action, key, data);
- stcpy (g_o_val, l_o_val);
- stcpy (l_o_val, losav);
-
- return;
- }
- }
-
g = gbl_handle (key);
i = gbl_path (key, filnam);
@@ -932,10 +900,8 @@ void global_bltin (short action, char *k
compactkey[k++] = ch << 1;
}
- else if (ch < SP || ch >= DEL) {
-
- /*no CTRLs */
-
+ else if (ch < SP || ch >= DEL) {
+ /* no CTRLs */
merr_raise (SBSCR);
return;
}
@@ -1008,8 +974,7 @@ void global_bltin (short action, char *k
reopen:
- gbl_open (g, action);
- if (g->fd == -1) {
+ if (!gbl_open (g, action)) {
/* file not found */
if (action != set_sym) {
@@ -1092,19 +1057,9 @@ reopen:
block[BTYP] = DATA; /* type */
block[OFFS] = i / 256;
block[OFFS + 1] = i % 256;
-
- for (;;) {
-
- errno = 0;
- write (g->fd, block, BLOCKLEN);
-
- if (errno == 0) break;
-
- lseek (g->fd, hdr_offset + ((ROOT + 1L) * BLOCKLEN), SEEK_SET);
- panic ();
-
- }
+ gbl_write_block (g, ROOT + 1, block);
+
gbl_close (g);
gbl_unlock (g);
gbl_open (g, action);
@@ -1123,16 +1078,16 @@ reopen:
if (action == get_sym) {
- tfast0:
+tfast0:
gbl_lock (g, 3);
- if (g->fast_path > 0) 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:
gbl_read_block (g, blknbr, block);
@@ -1140,7 +1095,6 @@ reopen:
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]);
@@ -1149,9 +1103,7 @@ reopen:
stcpy0 (key1, &block[2], j); /* get first key */
ch = keyl; /* ch is a register! */
-
- while (i < offset) {
-
+ while (i < offset) {
j = UNSIGN (block[i++]); /* length of key - offset */
k = UNSIGN (block[i++]); /* offset into previous entry */
@@ -1159,13 +1111,11 @@ reopen:
while (k < j) key1[k++] = block[i++]; /* get key */
- if (j != ch) { /* keys have different length */
-
+ if (j != ch) { /* keys have different length */
i += UNSIGN (block[i]);
i++;
- continue;
-
+ continue;
}
j = ch;
@@ -1173,21 +1123,17 @@ reopen:
do {
j--;
} while (compactkey[j] == key1[j]); /* compare keys */
-
-
- if (j < 0) {
-
+
+ if (j < 0) {
k = UNSIGN (block[i++]);
stcpy0 (data, &block[i], k); /* get value */
data[k] = EOL1; /* append EOL */
- goto quit;
-
+ goto quit;
}
i += UNSIGN (block[i]);
- i++; /* skip data */
-
+ i++; /* skip data */
}
/* fast access failed. try normal path */
@@ -1227,15 +1173,15 @@ reopen:
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;
- }
+ merr_raise (DBDGD);
+ goto quit;
+ }
- addr += PLEN; /* skip data */
- g->last_block = blknbr;
- g->fast_path = 1;
+ addr += PLEN; /* skip data */
+ g->last_block = blknbr;
+ g->fast_path = 1;
- if (merr () == INRPT) goto quit;
+ if (merr () == INRPT) goto quit;
}
} /* end of get_sym */
@@ -1319,7 +1265,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 */
@@ -1345,7 +1291,8 @@ k_again: /* entry point for repeated
}
-s10: {
+s10:
+ {
long len; /* insert key */
char key0[256];
@@ -1496,7 +1443,7 @@ s10: {
goto splitd;
}
-s20:
+ s20:
i = offset;
k = addr + olddatal;
@@ -1556,7 +1503,7 @@ 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) {
@@ -1691,7 +1638,7 @@ s20:
while (i < keyl) if (compactkey[i++] & 01)
- j1++;
+ j1++;
i = 0;
j = 0;
k = 0;
@@ -1724,8 +1671,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) {
@@ -1804,7 +1751,7 @@ s20:
addr = 0;
offset = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
+ UNSIGN (block[OFFS + 1]);
}
}
@@ -1871,8 +1818,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) {
@@ -1948,8 +1895,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) {
@@ -1993,7 +1940,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;
@@ -2038,15 +1985,15 @@ killo: /* entry from killone section
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]);
}
@@ -2055,7 +2002,7 @@ killo: /* entry from killone section
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);
@@ -2144,17 +2091,17 @@ 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) {
@@ -2195,7 +2142,7 @@ p_empty: /* entry if pointer block goes
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 */
@@ -2268,19 +2215,19 @@ 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;
@@ -2298,7 +2245,7 @@ p_empty: /* entry if pointer block goes
break;
-zinv:
+ zinv:
{
long len;
@@ -2316,7 +2263,7 @@ zinv:
gbl_read_block (g, blknbr, block);
addr = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
+ UNSIGN (block[OFFS + 1]);
}
@@ -2391,8 +2338,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) {
@@ -2437,166 +2384,142 @@ 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 */
+ }
- gbl_read_block (g, blknbr, block);
+ 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;
- }
-
- case merge_sym:
-
- printf("MERGE NOT IMPLEMENTED FOR GLOBALS\n");
-
-#ifdef DEBUG_GBL
-
- int loop;
-
- printf ("DEBUG MERGE: ");
- printf ("[key] is [");
-
- for (loop = 0; key[loop] != EOL; loop++) printf ("%c", (key[loop] == DELIM) ? '!' : key[loop]);
-
- printf ("]\r\n");
- printf ("[data] is [");
-
- for(loop = 0; data[loop] != EOL; loop++) printf ("%c", (data[loop] == DELIM) ? '!' : data[loop]);
-
- printf("]\r\n");
-
-#endif
- return;
+ goto quit;
+ }
default:
@@ -2628,8 +2551,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]);
@@ -2702,17 +2625,17 @@ splitd: /* split data block in two se
}
/* 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;
@@ -2794,8 +2717,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];
@@ -2831,8 +2754,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];
@@ -2925,8 +2848,8 @@ static void splitp (global_handle *g, ch
/* 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;
@@ -2992,8 +2915,8 @@ static void splitp (global_handle *g, ch
/* 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];
@@ -3028,8 +2951,8 @@ static void splitp (global_handle *g, ch
/* 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];
@@ -3102,7 +3025,7 @@ static void update (global_handle *g, ch
j = oldkeyl - keyl;
offset = UNSIGN (block[OFFS]) * 256 +
- UNSIGN (block[OFFS + 1]);
+ UNSIGN (block[OFFS + 1]);
if (j > 0) { /* surplus space */
@@ -3176,7 +3099,7 @@ static void insert (global_handle *g, ch
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]);
@@ -3246,8 +3169,8 @@ static void b_free (global_handle *g, un
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;
@@ -3263,8 +3186,8 @@ static void b_free (global_handle *g, un
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;
@@ -3388,7 +3311,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) {
@@ -3685,27 +3608,13 @@ void close_all_globals (void)
gbl_close_all ();
return;
-} /* end close_all_globals() */
+} /* close_all_globals() */
static void panic (void)
{
- printf ("write failed\r\n");
-
- printf ("\033[s\033[25H\033[5;7mwrite needs more disk space immediately\007");
- sleep (1);
- printf ("\033[m\007\033[2K\033[u");
-
- /* restore screen 'cause system messed up screen */
-
-#ifdef NOWRITEM
-
- write_m ("\033[4~\201");
-
-#endif /* NOWRITEM */
-
+ logprintf (FM_LOG_ERROR, "global_bltin: could not write to full disk");
return;
-
-} /* end panic() */
+} /* panic() */
void gbl_dump_stat(void)
@@ -3716,25 +3625,29 @@ void gbl_dump_stat(void)
int hit_pct;
unsigned long access_total;
unsigned long hit_total;
-
+ unsigned long mem_reads_total;
+
+ mem_reads_total = 0;
printf ("\r\nFreeM Global Statistics [PID %d]\r\n\r\n", pid);
- printf ("%-20s%-10s%-10s%-10s%-12s%-20s%-10s%s\r\n", "GLOBAL", "USECT", "READS", "WRITES", "SLOW PTHCT", "AGE", "LAST BLK", "FILE");
- printf ("%-20s%-10s%-10s%-10s%-12s%-20s%-10s%s\r\n", "======", "=====", "=====", "======", "==========", "===", "========", "====");
+ 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%-10ld%-10ld%-10ld%-12ld%-20ld%-10ld%s\r\n",
+ 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");
@@ -3745,5 +3658,7 @@ void gbl_dump_stat(void)
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 ("Fast path misses: %ld\t(%d%%)\r\n", gbl_cache_misses, miss_pct);
+ printf ("Disk reads avoided: %ld\r\n", mem_reads_total);
+
}