--- freem/src/global_bltin.c 2025/04/11 16:23:18 1.18 +++ freem/src/global_bltin.c 2025/04/17 14:34:27 1.23 @@ -1,5 +1,5 @@ /* - * $Id: global_bltin.c,v 1.18 2025/04/11 16:23:18 snw Exp $ + * $Id: global_bltin.c,v 1.23 2025/04/17 14:34:27 snw Exp $ * freem database engine * * @@ -24,6 +24,21 @@ * 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 * @@ -85,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; @@ -102,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) @@ -306,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); } @@ -331,7 +308,7 @@ int gbl_write_header(global_handle *g, g 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); } @@ -464,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; } @@ -496,9 +471,8 @@ int gbl_read_block(global_handle *g, uns g->use_count++; - fstat (g->fd, &gstat); if (!g->locked) gbl_lock (g, 1); - + fstat (g->fd, &gstat); if ((g->last_block == blocknum) && (g->have_cached_block) && @@ -506,7 +480,6 @@ int gbl_read_block(global_handle *g, uns (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 { @@ -517,14 +490,14 @@ int gbl_read_block(global_handle *g, uns /* 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->cached_block_num = blocknum; g->last_block = blocknum; - g->use_count++; g->read_ops++; } + g->last_read_time = time (0L); + g->use_count++; + if (g->locked) gbl_unlock (g); return TRUE; @@ -547,7 +520,7 @@ int gbl_write_block(global_handle *g, un 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++; @@ -736,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; @@ -745,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++; } } + } } @@ -884,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); @@ -964,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; } @@ -1040,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) { @@ -1124,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); @@ -1155,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); @@ -1172,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]); @@ -1181,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 */ @@ -1191,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; @@ -1205,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 */ @@ -1259,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 */ @@ -1351,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 */ @@ -1377,7 +1291,8 @@ k_again: /* entry point for repeated } -s10: { +s10: + { long len; /* insert key */ char key0[256]; @@ -1528,7 +1443,7 @@ s10: { goto splitd; } -s20: + s20: i = offset; k = addr + olddatal; @@ -1588,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) { @@ -1723,7 +1638,7 @@ s20: while (i < keyl) if (compactkey[i++] & 01) - j1++; + j1++; i = 0; j = 0; k = 0; @@ -1756,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) { @@ -1836,7 +1751,7 @@ s20: addr = 0; offset = UNSIGN (block[OFFS]) * 256 + - UNSIGN (block[OFFS + 1]); + UNSIGN (block[OFFS + 1]); } } @@ -1903,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) { @@ -1980,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) { @@ -2025,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; @@ -2070,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]); } @@ -2087,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); @@ -2176,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) { @@ -2227,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 */ @@ -2300,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; @@ -2330,7 +2245,7 @@ p_empty: /* entry if pointer block goes break; -zinv: + zinv: { long len; @@ -2348,7 +2263,7 @@ zinv: gbl_read_block (g, blknbr, block); addr = UNSIGN (block[OFFS]) * 256 + - UNSIGN (block[OFFS + 1]); + UNSIGN (block[OFFS + 1]); } @@ -2423,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) { @@ -2469,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: @@ -2660,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]); @@ -2734,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; @@ -2826,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]; @@ -2863,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]; @@ -2957,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; @@ -3024,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]; @@ -3060,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]; @@ -3134,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 */ @@ -3208,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]); @@ -3278,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; @@ -3295,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; @@ -3420,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) { @@ -3717,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)