version 1.8, 2025/04/08 14:39:21
|
version 1.12, 2025/04/09 00:43:07
|
Line 24
|
Line 24
|
* along with FreeM. If not, see <https://www.gnu.org/licenses/>. |
* along with FreeM. If not, see <https://www.gnu.org/licenses/>. |
* |
* |
* $Log$ |
* $Log$ |
|
* 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 |
|
* |
* Revision 1.8 2025/04/08 14:39:21 snw |
* Revision 1.8 2025/04/08 14:39:21 snw |
* Initial work on global handler refactor |
* Initial work on global handler refactor |
* |
* |
Line 53
|
Line 65
|
#include <errno.h> |
#include <errno.h> |
|
|
#include "mpsdef.h" |
#include "mpsdef.h" |
|
#include "journal.h" |
#include "global_bltin.h" |
#include "global_bltin.h" |
|
|
global_handle *global_handles_head; |
global_handle *global_handles_head; |
|
|
static void b_free (short filedes, unsigned long blknbr); |
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 splitp (global_handle *g, char *block, long *addr, long *offs, unsigned long *blknbr); |
static void update (short filedes, char *ins_key, long keyl); |
static void update (global_handle *g, char *ins_key, long keyl); |
static void insert (int filedes, char *ins_key, long key_len, unsigned long blknbr); |
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 scanpblk (char *block, long *adr, long *fnd); |
static void scandblk (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 (int filedes, unsigned long *blknbr); |
Line 197 nextpath:
|
Line 210 nextpath:
|
buf[k] = NUL; /* NUL not EOL !!! */ |
buf[k] = NUL; /* NUL not EOL !!! */ |
|
|
return i; |
return i; |
} /* global_file */ |
} /* gbl_path() */ |
|
|
int gbl_lock(global_handle *g, int type) |
int gbl_lock(global_handle *g, int type) |
{ |
{ |
Line 207 int gbl_lock(global_handle *g, int type)
|
Line 220 int gbl_lock(global_handle *g, int type)
|
|
|
locking (g->fd, type, 0L); |
locking (g->fd, type, 0L); |
g->locked = TRUE; |
g->locked = TRUE; |
} |
} /* gbl_lock() */ |
|
|
int gbl_unlock(global_handle *g) |
int gbl_unlock(global_handle *g) |
{ |
{ |
Line 217 int gbl_unlock(global_handle *g)
|
Line 230 int gbl_unlock(global_handle *g)
|
|
|
locking (g->fd, 0, 0L); |
locking (g->fd, 0, 0L); |
g->locked = FALSE; |
g->locked = FALSE; |
} |
} /* gbl_unlock() */ |
|
|
void gbl_close(global_handle *g) |
void gbl_close(global_handle *g) |
{ |
{ |
Line 230 void gbl_close(global_handle *g)
|
Line 243 void gbl_close(global_handle *g)
|
g->locked = FALSE; |
g->locked = FALSE; |
g->opened = FALSE; |
g->opened = FALSE; |
} |
} |
} |
} /* gbl_close() */ |
|
|
void gbl_close_all(void) |
void gbl_close_all(void) |
{ |
{ |
Line 239 void gbl_close_all(void)
|
Line 252 void gbl_close_all(void)
|
for (g = global_handles_head; g != NULL; g = g->next) { |
for (g = global_handles_head; g != NULL; g = g->next) { |
gbl_close (g); |
gbl_close (g); |
} |
} |
} |
} /* gbl_close_all() */ |
|
|
|
int gbl_write_initial_header(global_handle *g) |
|
{ |
|
global_header hdr; |
|
unsigned long old_position; |
|
char m[5] = GBL_MAGIC; |
|
char msg[256]; |
|
|
|
if (g->opened == FALSE) { |
|
return FALSE; |
|
} |
|
|
|
memcpy (hdr.magic, m, 5); |
|
hdr.format_version = GBL_FORMAT_VERSION; |
|
strncpy (hdr.host_triplet, HOST, 40); |
|
hdr.block_size = BLOCKLEN; |
|
hdr.last_transaction_id = 0; |
|
hdr.created = time (0L); |
|
hdr.last_backup = -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); |
|
m_fatal (msg); |
|
} |
|
|
|
lseek (g->fd, old_position, SEEK_SET); |
|
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) |
int gbl_create(global_handle *g) |
{ |
{ |
Line 260 int gbl_create(global_handle *g)
|
Line 379 int gbl_create(global_handle *g)
|
g->age = time (0L); |
g->age = time (0L); |
g->last_block = 0; |
g->last_block = 0; |
g->use_count = 1; |
g->use_count = 1; |
|
|
|
gbl_write_initial_header (g); |
|
|
return OK; |
return OK; |
} |
} /* gbl_create() */ |
|
|
short gbl_open(global_handle *g, short action) |
short gbl_open(global_handle *g, short action) |
{ |
{ |
|
int result; |
|
|
if (g->opened == FALSE) { |
if (g->opened == FALSE) { |
while (1) { |
while (1) { |
errno = 0; |
errno = 0; |
Line 279 short gbl_open(global_handle *g, short a
|
Line 402 short gbl_open(global_handle *g, short a
|
|
|
case EMFILE: |
case EMFILE: |
case ENFILE: |
case ENFILE: |
close_all_globals (); |
gbl_close_all (); |
continue; |
continue; |
} |
} |
|
|
Line 295 short gbl_open(global_handle *g, short a
|
Line 418 short gbl_open(global_handle *g, short a
|
} |
} |
else { |
else { |
g->opened = TRUE; |
g->opened = TRUE; |
|
result = gbl_read_header (g, &g->header); |
|
|
|
if (result == GBL_HDR_OK) { |
|
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; |
|
} |
} |
} |
} |
} |
|
|
return g->opened; |
return g->opened; |
|
|
} /* gbl_open */ |
} /* gbl_open() */ |
|
|
global_handle *gbl_handle(char *key) |
global_handle *gbl_handle(char *key) |
{ |
{ |
Line 357 global_handle *gbl_handle(char *key)
|
Line 505 global_handle *gbl_handle(char *key)
|
global_handles_head = g; |
global_handles_head = g; |
|
|
return g; |
return g; |
} |
} /* gbl_handle() */ |
|
|
|
|
/* globals management */ |
/* globals management */ |
Line 439 void global_bltin (short action, char *k
|
Line 587 void global_bltin (short action, char *k
|
{ |
{ |
|
|
global_handle *g; |
global_handle *g; |
|
|
|
unsigned long hdr_offset; |
|
|
/* these must be static variables */ |
/* these must be static variables */ |
|
|
static short filedes; /* filedescr for global access */ |
static short filedes; /* filedescr for global access */ |
static char filnam[256]; /* name of global/unix file */ |
static char filnam[256]; /* name of global/unix file */ |
|
|
/* the following vars may be */ |
/* the following vars may be */ |
/* static or dynamic */ |
/* static or dynamic */ |
|
|
static unsigned long blknbr; /* block number */ |
static unsigned long blknbr; /* block number */ |
// static unsigned long oldblk; |
|
static unsigned long newblk; |
static unsigned long newblk; |
static unsigned long other; |
static unsigned long other; |
static long j1; |
static long j1; |
static long limit; |
static long limit; |
static short typ; /* block type */ |
static short typ; /* block type */ |
static long keyl, /* length of compacted key */ |
static long keyl; /* length of compacted key */ |
datal, /* length of data */ |
static long datal; /* length of data */ |
olddatal, |
static long olddatal; |
offset, |
static long offset; |
found, |
static long found; |
addr, /* address of key in 'block' */ |
static long addr; /* address of key in 'block' */ |
needed, /* new bytes needed to ins. stuff */ |
static long needed; /* new bytes needed to ins. stuff */ |
ret_to, /* return code */ |
static long ret_to; /* return code */ |
kill_again; |
static long kill_again; |
static char key1[256]; |
static char key1[256]; |
static char tmp1[256]; /* intermediate storage for op= */ |
static char tmp1[256]; /* intermediate storage for op= */ |
static char block[BLOCKLEN]; |
static char block[BLOCKLEN]; |
Line 475 void global_bltin (short action, char *k
|
Line 622 void global_bltin (short action, char *k
|
|
|
struct stat dinf; /* get modification date */ |
struct stat dinf; /* get modification date */ |
|
|
long savj, |
long savj; |
savch; /* saved j and ch for multiple pathes */ |
long savch; /* saved j and ch for multiple pathes */ |
register long int i, |
register long int i; |
j, |
register long int j; |
k, |
register long int k; |
ch; |
register long int ch; |
long pathscan; /* flag for repeated scan of pathlist setting an undef global */ |
long pathscan; /* flag for repeated scan of pathlist setting an undef global */ |
|
|
|
hdr_offset = sizeof (global_header); |
|
|
/* process optional limitations */ |
/* process optional limitations */ |
if (glvnflag.all && key[0] >= '%' && key[0] <= 'z') { |
if (glvnflag.all && key[0] >= '%' && key[0] <= 'z') { |
|
|
Line 561 void global_bltin (short action, char *k
|
Line 710 void global_bltin (short action, char *k
|
|
|
|
|
if (action == getnext) { |
if (action == getnext) { |
|
|
getnflag = TRUE; |
getnflag = TRUE; |
varnam[0] = EOL; |
varnam[0] = EOL; |
|
|
Line 851 reopen:
|
Line 999 reopen:
|
|
|
errno = 0; |
errno = 0; |
|
|
lseek (g->fd, ROOT * BLOCKLEN, 0); |
lseek (g->fd, hdr_offset + (ROOT * BLOCKLEN), SEEK_SET); |
write (g->fd, block, BLOCKLEN); |
write (g->fd, block, BLOCKLEN); |
|
|
if (errno == 0) break; |
if (errno == 0) break; |
Line 877 reopen:
|
Line 1025 reopen:
|
|
|
if (errno == 0) break; |
if (errno == 0) break; |
|
|
lseek (g->fd, (ROOT + 1L) * BLOCKLEN, 0); |
lseek (g->fd, hdr_offset + ((ROOT + 1L) * BLOCKLEN), SEEK_SET); |
panic (); |
panic (); |
|
|
} |
} |
Line 909 tfast0:
|
Line 1057 tfast0:
|
|
|
tfast1: |
tfast1: |
|
|
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
|
|
|
|
Line 1031 tfast2:
|
Line 1179 tfast2:
|
/* a KILL on an unsubscripted global deletes the entire file */ |
/* a KILL on an unsubscripted global deletes the entire file */ |
if (action == kill_sym && compactkey[0] == g_EOL) { |
if (action == kill_sym && compactkey[0] == g_EOL) { |
|
|
lseek (g->fd, ROOT, 0); |
lseek (g->fd, hdr_offset + ROOT, SEEK_SET); |
|
|
/* note : UNIX does not tell other */ |
/* note : UNIX does not tell other */ |
block[BTYP] = EMPTY; /* jobs that a file has been unlinked */ |
block[BTYP] = EMPTY; /* jobs that a file has been unlinked */ |
Line 1064 k_again: /* entry point for repeated
|
Line 1212 k_again: /* entry point for repeated
|
traceblk[trx] = blknbr; |
traceblk[trx] = blknbr; |
traceadr[trx] = 0; |
traceadr[trx] = 0; |
|
|
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
|
|
typ = block[BTYP]; |
typ = block[BTYP]; |
Line 1232 s10: {
|
Line 1380 s10: {
|
|
|
} |
} |
|
|
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
write (g->fd, block, BLOCKLEN); |
write (g->fd, block, BLOCKLEN); |
|
|
if (traceadr[trx] == 0) update (g->fd, compactkey, keyl); |
if (traceadr[trx] == 0) update (g, compactkey, keyl); |
|
|
break; |
break; |
} |
} |
Line 1319 s20:
|
Line 1467 s20:
|
} |
} |
|
|
stcpy0 (&block[++addr], data, (long) datal); |
stcpy0 (&block[++addr], data, (long) datal); |
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
write (g->fd, block, BLOCKLEN); |
write (g->fd, block, BLOCKLEN); |
|
|
|
gbl_update_tid (g); |
|
|
break; |
break; |
|
|
|
|
Line 1351 s20:
|
Line 1502 s20:
|
|
|
if ((blknbr = UNSIGN (block[RLPTR]) * 65536 + UNSIGN (block[RLPTR + 1]) * 256 + UNSIGN (block[RLPTR + 2]))) { |
if ((blknbr = UNSIGN (block[RLPTR]) * 65536 + UNSIGN (block[RLPTR + 1]) * 256 + UNSIGN (block[RLPTR + 2]))) { |
|
|
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
j1 = UNSIGN (block[0]); |
j1 = UNSIGN (block[0]); |
|
|
Line 1434 s20:
|
Line 1585 s20:
|
goto quit; |
goto quit; |
} /* no next block */ |
} /* no next block */ |
|
|
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
scandblk (block, &addr, &found); |
scandblk (block, &addr, &found); |
|
|
Line 1591 s20:
|
Line 1742 s20:
|
goto quit; /* no next block */ |
goto quit; /* no next block */ |
} |
} |
|
|
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
|
|
addr = 0; |
addr = 0; |
Line 1615 s20:
|
Line 1766 s20:
|
goto quit; /* no next block */ |
goto quit; /* no next block */ |
} |
} |
|
|
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
|
|
addr = 0; |
addr = 0; |
Line 1826 killo: /* entry from killone section
|
Line 1977 killo: /* entry from killone section
|
other = traceblk[--trx]; |
other = traceblk[--trx]; |
addr = traceadr[trx]; |
addr = traceadr[trx]; |
|
|
lseek (g->fd, (long) other * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
|
|
addr += UNSIGN (block[addr]); |
addr += UNSIGN (block[addr]); |
Line 1846 killo: /* entry from killone section
|
Line 1997 killo: /* entry from killone section
|
|
|
trx = trxsav; |
trx = trxsav; |
|
|
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
|
|
offset = UNSIGN (block[OFFS]) * 256 + |
offset = UNSIGN (block[OFFS]) * 256 + |
Line 1953 p_empty: /* entry if pointer block goes
|
Line 2104 p_empty: /* entry if pointer block goes
|
|
|
if (left) { |
if (left) { |
|
|
lseek (g->fd, (long) left * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) left * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block0, BLOCKLEN); |
read (g->fd, block0, BLOCKLEN); |
|
|
block0[RLPTR] = block[RLPTR]; |
block0[RLPTR] = block[RLPTR]; |
block0[RLPTR + 1] = block[RLPTR + 1]; |
block0[RLPTR + 1] = block[RLPTR + 1]; |
block0[RLPTR + 2] = block[RLPTR + 2]; |
block0[RLPTR + 2] = block[RLPTR + 2]; |
|
|
lseek (g->fd, (long) left * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) left * (long) (BLOCKLEN)), SEEK_SET); |
write (g->fd, block0, BLOCKLEN); |
write (g->fd, block0, BLOCKLEN); |
|
|
} |
} |
|
|
if (right) { |
if (right) { |
|
|
lseek (g->fd, (long) right * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) right * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block0, BLOCKLEN); |
read (g->fd, block0, BLOCKLEN); |
|
|
block0[LLPTR] = block[LLPTR]; |
block0[LLPTR] = block[LLPTR]; |
block0[LLPTR + 1] = block[LLPTR + 1]; |
block0[LLPTR + 1] = block[LLPTR + 1]; |
block0[LLPTR + 2] = block[LLPTR + 2]; |
block0[LLPTR + 2] = block[LLPTR + 2]; |
|
|
lseek (g->fd, (long) right * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) right * (long) (BLOCKLEN)), SEEK_SET); |
write (g->fd, block0, BLOCKLEN); |
write (g->fd, block0, BLOCKLEN); |
|
|
} |
} |
Line 1992 p_empty: /* entry if pointer block goes
|
Line 2143 p_empty: /* entry if pointer block goes
|
blknbr = traceblk[--trx]; |
blknbr = traceblk[--trx]; |
addr = traceadr[trx]; |
addr = traceadr[trx]; |
|
|
lseek (g->fd, (long) (blknbr) * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) (blknbr) * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
offset = UNSIGN (block[OFFS]) * 256 + |
offset = UNSIGN (block[OFFS]) * 256 + |
UNSIGN (block[OFFS + 1]); |
UNSIGN (block[OFFS + 1]); |
Line 2005 p_empty: /* entry if pointer block goes
|
Line 2156 p_empty: /* entry if pointer block goes
|
|
|
if (blknbr == ROOT) { /* global went empty */ |
if (blknbr == ROOT) { /* global went empty */ |
|
|
lseek (g->fd, 0L, 0); |
lseek (g->fd, hdr_offset + 0L, SEEK_SET); |
|
|
/* note : UNIX does not tell other */ |
/* note : UNIX does not tell other */ |
block[BTYP] = EMPTY; /* jobs that a file has been unlinked */ |
block[BTYP] = EMPTY; /* jobs that a file has been unlinked */ |
Line 2037 p_empty: /* entry if pointer block goes
|
Line 2188 p_empty: /* entry if pointer block goes
|
|
|
for (i = offset; i < offset + freecnt; block[i++] = 0); |
for (i = offset; i < offset + freecnt; block[i++] = 0); |
|
|
lseek (g->fd, (long) (blknbr) * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) (blknbr) * (long) (BLOCKLEN)), SEEK_SET); |
write (g->fd, block, BLOCKLEN); |
write (g->fd, block, BLOCKLEN); |
|
|
if (addr == 0) { /* update of pointer */ |
if (addr == 0) { /* update of pointer */ |
traceadr[trx] = 0; |
traceadr[trx] = 0; |
|
|
update (g->fd, &block[2], (long) UNSIGN (block[0])); |
update (g, &block[2], (long) UNSIGN (block[0])); |
} |
} |
|
|
trx = trxsav; |
trx = trxsav; |
Line 2085 p_empty: /* entry if pointer block goes
|
Line 2236 p_empty: /* entry if pointer block goes
|
} |
} |
block[OFFS] = offset / 256; |
block[OFFS] = offset / 256; |
block[OFFS + 1] = offset % 256; |
block[OFFS + 1] = offset % 256; |
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
write (g->fd, block, BLOCKLEN); |
write (g->fd, block, BLOCKLEN); |
if (addr < 3) { /* update of pointer */ |
if (addr < 3) { /* update of pointer */ |
traceadr[trx] = 0; |
traceadr[trx] = 0; |
update (g->fd, &block[2], (long) UNSIGN (block[0])); |
update (g, &block[2], (long) UNSIGN (block[0])); |
} |
} |
} |
} |
|
|
Line 2112 zinv:
|
Line 2263 zinv:
|
goto quit; |
goto quit; |
} /* no previous block */ |
} /* no previous block */ |
|
|
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
|
|
addr = UNSIGN (block[OFFS]) * 256 + |
addr = UNSIGN (block[OFFS]) * 256 + |
Line 2292 zinv:
|
Line 2443 zinv:
|
break; /* no next block */ |
break; /* no next block */ |
} |
} |
|
|
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
|
|
addr = 0; |
addr = 0; |
Line 2408 quit:
|
Line 2559 quit:
|
|
|
/* clean things up */ |
/* clean things up */ |
|
|
lseek (g->fd, ROOT, 0); |
lseek (g->fd, hdr_offset + ROOT, SEEK_SET); |
gbl_unlock (g); |
gbl_unlock (g); |
|
|
return; |
return; |
Line 2439 splitd: /* split data block in two se
|
Line 2590 splitd: /* split data block in two se
|
block[RLPTR + 1] = newblk % 65536 / 256; |
block[RLPTR + 1] = newblk % 65536 / 256; |
block[RLPTR + 2] = newblk % 256; |
block[RLPTR + 2] = newblk % 256; |
|
|
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
write (g->fd, block, BLOCKLEN); |
write (g->fd, block, BLOCKLEN); |
|
|
block[RLPTR] = right; |
block[RLPTR] = right; |
Line 2452 splitd: /* split data block in two se
|
Line 2603 splitd: /* split data block in two se
|
addr = 0; |
addr = 0; |
blknbr = newblk; |
blknbr = newblk; |
|
|
insert (g->fd, compactkey, keyl, newblk); |
insert (g, compactkey, keyl, newblk); |
|
|
/* up-date LL-PTR of RL-block */ |
/* up-date LL-PTR of RL-block */ |
if ((other = right * 65536 + right1 * 256 + right2)) { |
if ((other = right * 65536 + right1 * 256 + right2)) { |
|
|
char block0[BLOCKLEN]; |
char block0[BLOCKLEN]; |
|
|
lseek (g->fd, (long) other * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block0, BLOCKLEN); |
read (g->fd, block0, BLOCKLEN); |
|
|
block0[LLPTR] = blknbr / 65536; |
block0[LLPTR] = blknbr / 65536; |
block0[LLPTR + 1] = blknbr % 65536 / 256; |
block0[LLPTR + 1] = blknbr % 65536 / 256; |
block0[LLPTR + 2] = blknbr % 256; |
block0[LLPTR + 2] = blknbr % 256; |
|
|
lseek (g->fd, (long) other * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET); |
write (g->fd, block0, BLOCKLEN); |
write (g->fd, block0, BLOCKLEN); |
|
|
} |
} |
Line 2485 splitd: /* split data block in two se
|
Line 2636 splitd: /* split data block in two se
|
block[LLPTR + 1] = newblk % 65536 / 256; |
block[LLPTR + 1] = newblk % 65536 / 256; |
block[LLPTR + 2] = newblk % 256; |
block[LLPTR + 2] = newblk % 256; |
|
|
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
write (g->fd, block, BLOCKLEN); |
write (g->fd, block, BLOCKLEN); |
|
|
block[LLPTR] = left; |
block[LLPTR] = left; |
Line 2498 splitd: /* split data block in two se
|
Line 2649 splitd: /* split data block in two se
|
blknbr = newblk; |
blknbr = newblk; |
traceadr[trx] = (-1); /* inhibit second update of pointers */ |
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 */ |
if (addr < 3) { /* update of pointer */ |
traceadr[trx] = 0; |
traceadr[trx] = 0; |
|
|
update (g->fd, compactkey, keyl); |
update (g, compactkey, keyl); |
} |
} |
|
|
/* other is ***always*** zero !!! |
/* other is ***always*** zero !!! |
Line 2611 splitd: /* split data block in two se
|
Line 2762 splitd: /* split data block in two se
|
block0[LLPTR + 1] = blknbr % 65536 / 256; |
block0[LLPTR + 1] = blknbr % 65536 / 256; |
block0[LLPTR + 2] = blknbr % 256; |
block0[LLPTR + 2] = blknbr % 256; |
|
|
lseek (g->fd, (long) (newblk) * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) (newblk) * (long) (BLOCKLEN)), SEEK_SET); |
write (g->fd, block0, BLOCKLEN); |
write (g->fd, block0, BLOCKLEN); |
|
|
offset = limit; |
offset = limit; |
/* insert new block in pointer structure */ |
/* 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 */ |
/* up-date LL-PTR of RL-block */ |
if (other != 0) { |
if (other != 0) { |
|
|
lseek (g->fd, (long) other * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block0, BLOCKLEN); |
read (g->fd, block0, BLOCKLEN); |
|
|
block0[LLPTR] = newblk / 65536; |
block0[LLPTR] = newblk / 65536; |
block0[LLPTR + 1] = newblk % 65536 / 256; |
block0[LLPTR + 1] = newblk % 65536 / 256; |
block0[LLPTR + 2] = newblk % 256; |
block0[LLPTR + 2] = newblk % 256; |
|
|
lseek (g->fd, (long) other * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET); |
write (g->fd, block0, BLOCKLEN); |
write (g->fd, block0, BLOCKLEN); |
|
|
} |
} |
Line 2651 splitd: /* split data block in two se
|
Line 2802 splitd: /* split data block in two se
|
block0[LLPTR + 1] = blknbr % 65536 / 256; |
block0[LLPTR + 1] = blknbr % 65536 / 256; |
block0[LLPTR + 2] = blknbr % 256; |
block0[LLPTR + 2] = blknbr % 256; |
|
|
lseek (g->fd, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
write (g->fd, block, BLOCKLEN); |
write (g->fd, block, BLOCKLEN); |
stcpy0 (block, block0, (long) BLOCKLEN); |
stcpy0 (block, block0, (long) BLOCKLEN); |
|
|
Line 2659 splitd: /* split data block in two se
|
Line 2810 splitd: /* split data block in two se
|
traceblk[trx] = (blknbr = newblk); |
traceblk[trx] = (blknbr = newblk); |
|
|
/* insert new block in pointer structure */ |
/* 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 */ |
/* up-date LL-PTR of RL-block */ |
if (other != 0) { |
if (other != 0) { |
|
|
lseek (g->fd, (long) other * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET); |
read (g->fd, block0, BLOCKLEN); |
read (g->fd, block0, BLOCKLEN); |
|
|
block0[LLPTR] = newblk / 65536; |
block0[LLPTR] = newblk / 65536; |
block0[LLPTR + 1] = newblk % 65536 / 256; |
block0[LLPTR + 1] = newblk % 65536 / 256; |
block0[LLPTR + 2] = newblk % 256; |
block0[LLPTR + 2] = newblk % 256; |
|
|
lseek (g->fd, (long) other * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET); |
write (g->fd, block0, BLOCKLEN); |
write (g->fd, block0, BLOCKLEN); |
|
|
} |
} |
Line 2699 spltex:
|
Line 2850 spltex:
|
* 'addr' there I would like to insert, if possible (which is not) |
* 'addr' there I would like to insert, if possible (which is not) |
* 'offset' filled up to this limit |
* '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]; |
char block0[BLOCKLEN]; |
Line 2708 static void splitp (short filedes, char
|
Line 2859 static void splitp (short filedes, char
|
unsigned long other; |
unsigned long other; |
register int i, j; |
register int i, j; |
|
|
getnewblk (filedes, &newblk); /* get a new block */ |
long hdr_offset; |
|
|
|
hdr_offset = sizeof (global_header); |
|
|
|
getnewblk (g->fd, &newblk); /* get a new block */ |
|
|
if (*blknbr == ROOT) { /* ROOT overflow is special */ |
if (*blknbr == ROOT) { /* ROOT overflow is special */ |
|
|
Line 2743 static void splitp (short filedes, char
|
Line 2898 static void splitp (short filedes, char
|
block0[NRBLK + 2] = i % 256; |
block0[NRBLK + 2] = i % 256; |
block0[BTYP] = POINTER; |
block0[BTYP] = POINTER; |
|
|
lseek (filedes, ROOT, 0); |
lseek (g->fd, hdr_offset + ROOT, SEEK_SET); |
write (filedes, block0, BLOCKLEN); |
write (g->fd, block0, BLOCKLEN); |
|
|
/* shift trace_stack */ |
/* shift trace_stack */ |
j = trx++; |
j = trx++; |
Line 2761 static void splitp (short filedes, char
|
Line 2916 static void splitp (short filedes, char
|
traceblk[1] = newblk; |
traceblk[1] = newblk; |
*blknbr = newblk; |
*blknbr = newblk; |
|
|
getnewblk (filedes, &newblk); /* get a new block */ |
getnewblk (g->fd, &newblk); /* get a new block */ |
|
|
} |
} |
|
|
Line 2815 static void splitp (short filedes, char
|
Line 2970 static void splitp (short filedes, char
|
block0[LLPTR + 1] = (*blknbr) % 65536 / 256; |
block0[LLPTR + 1] = (*blknbr) % 65536 / 256; |
block0[LLPTR + 2] = (*blknbr) % 256; |
block0[LLPTR + 2] = (*blknbr) % 256; |
|
|
lseek (filedes, (long) (newblk) * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) (newblk) * (long) (BLOCKLEN)), SEEK_SET); |
write (filedes, block0, BLOCKLEN); |
write (g->fd, block0, BLOCKLEN); |
|
|
(*offs) = limit; |
(*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 */ |
/* up-date LL-PTR of RL-block */ |
if (other != 0) { |
if (other != 0) { |
|
|
lseek (filedes, (long) other * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET); |
read (filedes, block0, BLOCKLEN); |
read (g->fd, block0, BLOCKLEN); |
|
|
block0[LLPTR] = newblk / 65536; |
block0[LLPTR] = newblk / 65536; |
block0[LLPTR + 1] = newblk % 65536 / 256; |
block0[LLPTR + 1] = newblk % 65536 / 256; |
block0[LLPTR + 2] = newblk % 256; |
block0[LLPTR + 2] = newblk % 256; |
|
|
lseek (filedes, (long) other * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET); |
write (filedes, block0, BLOCKLEN); |
write (g->fd, block0, BLOCKLEN); |
|
|
} |
} |
|
|
Line 2858 static void splitp (short filedes, char
|
Line 3013 static void splitp (short filedes, char
|
(*addr) -= limit; |
(*addr) -= limit; |
(*offs) -= limit; |
(*offs) -= limit; |
|
|
lseek (filedes, (long) (*blknbr) * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) (*blknbr) * (long) (BLOCKLEN)), SEEK_SET); |
write (filedes, block, BLOCKLEN); |
write (g->fd, block, BLOCKLEN); |
stcpy0 (block, block0, (long) BLOCKLEN); |
stcpy0 (block, block0, (long) BLOCKLEN); |
|
|
(*blknbr) = newblk; |
(*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 */ |
/* up-date LL-PTR of RL-block */ |
if (other != 0) { |
if (other != 0) { |
|
|
lseek (filedes, (long) other * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET); |
read (filedes, block0, BLOCKLEN); |
read (g->fd, block0, BLOCKLEN); |
|
|
block0[LLPTR] = newblk / 65536; |
block0[LLPTR] = newblk / 65536; |
block0[LLPTR + 1] = newblk % 65536 / 256; |
block0[LLPTR + 1] = newblk % 65536 / 256; |
block0[LLPTR + 2] = newblk % 256; |
block0[LLPTR + 2] = newblk % 256; |
|
|
lseek (filedes, (long) other * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) other * (long) (BLOCKLEN)), SEEK_SET); |
write (filedes, block0, BLOCKLEN); |
write (g->fd, block0, BLOCKLEN); |
|
|
} |
} |
|
|
Line 2892 static void splitp (short filedes, char
|
Line 3047 static void splitp (short filedes, char
|
* ins_key: key to be inserted |
* ins_key: key to be inserted |
* keyl: length of that key |
* 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 offset; |
long addr; |
long addr; |
unsigned long blknbr; |
unsigned long blknbr; |
char block[BLOCKLEN]; |
char block[BLOCKLEN]; |
long i, j, k; |
long i, j, k; |
|
long hdr_offset; |
|
|
|
hdr_offset = sizeof (global_header); |
|
|
while (traceadr[trx] == 0) { /* update of pointer blocks necessary */ |
while (traceadr[trx] == 0) { /* update of pointer blocks necessary */ |
|
|
if (--trx < 0) break; |
if (--trx < 0) break; |
Line 2907 static void update (short filedes, char
|
Line 3065 static void update (short filedes, char
|
blknbr = traceblk[trx]; |
blknbr = traceblk[trx]; |
addr = traceadr[trx]; |
addr = traceadr[trx]; |
|
|
lseek (filedes, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
read (filedes, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
|
|
{ |
{ |
long oldkeyl; |
long oldkeyl; |
Line 2935 static void update (short filedes, char
|
Line 3093 static void update (short filedes, char
|
else if (j < 0) { /* we need more space */ |
else if (j < 0) { /* we need more space */ |
|
|
/* block too small */ |
/* 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; |
i = offset; |
offset -= j; |
offset -= j; |
Line 2958 static void update (short filedes, char
|
Line 3116 static void update (short filedes, char
|
while (i < keyl) block[j++] = ins_key[i++]; |
while (i < keyl) block[j++] = ins_key[i++]; |
|
|
/* block pointed to remains the same */ |
/* block pointed to remains the same */ |
lseek (filedes, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
write (filedes, block, BLOCKLEN); |
write (g->fd, block, BLOCKLEN); |
|
|
} |
} |
|
|
lseek (filedes, (long) blknbr * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) blknbr * (long) (BLOCKLEN)), SEEK_SET); |
read (filedes, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
|
|
} |
} |
|
|
Line 2979 static void update (short filedes, char
|
Line 3137 static void update (short filedes, char
|
* key_len: length of that key |
* key_len: length of that key |
* blknbr: key points to this block |
* 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; |
unsigned long blk; |
char block[BLOCKLEN]; |
char block[BLOCKLEN]; |
Line 2988 static void insert (int filedes, char *i
|
Line 3146 static void insert (int filedes, char *i
|
long needed; |
long needed; |
long addr; |
long addr; |
register int i, k; |
register int i, k; |
|
long hdr_offset; |
|
|
|
hdr_offset = sizeof (global_header); |
|
|
trxsav = trx--; |
trxsav = trx--; |
blk = traceblk[trx]; |
blk = traceblk[trx]; |
addr = traceadr[trx]; |
addr = traceadr[trx]; |
|
|
lseek (filedes, (long) (blk) * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) (blk) * (long) (BLOCKLEN)), SEEK_SET); |
read (filedes, block, BLOCKLEN); |
read (g->fd, block, BLOCKLEN); |
|
|
offset = UNSIGN (block[OFFS]) * 256 + |
offset = UNSIGN (block[OFFS]) * 256 + |
UNSIGN (block[OFFS + 1]); |
UNSIGN (block[OFFS + 1]); |
Line 3006 static void insert (int filedes, char *i
|
Line 3167 static void insert (int filedes, char *i
|
|
|
needed = key_len + 2 + PLEN; |
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 */ |
/* insert key */ |
i = (offset += needed); |
i = (offset += needed); |
Line 3030 static void insert (int filedes, char *i
|
Line 3191 static void insert (int filedes, char *i
|
block[i++] = blknbr % 65536 / 256; |
block[i++] = blknbr % 65536 / 256; |
block[i] = blknbr % 256; |
block[i] = blknbr % 256; |
|
|
lseek (filedes, (long) (blk) * (long) (BLOCKLEN), 0); |
lseek (g->fd, hdr_offset + ((long) (blk) * (long) (BLOCKLEN)), SEEK_SET); |
write (filedes, block, BLOCKLEN); |
write (g->fd, block, BLOCKLEN); |
|
|
trx = trxsav; |
trx = trxsav; |
|
|
Line 3050 static void b_free (short filedes, unsig
|
Line 3211 static void b_free (short filedes, unsig
|
unsigned long other; |
unsigned long other; |
long i; |
long i; |
long offset; |
long offset; |
|
long hdr_offset; |
|
|
|
hdr_offset = sizeof (global_header); |
|
|
/* mark block as empty */ |
/* mark block as empty */ |
lseek (filedes, (long) (blknbr) * BLOCKLEN, 0); |
lseek (filedes, hdr_offset + ((long) (blknbr) * BLOCKLEN), SEEK_SET); |
read (filedes, block0, BLOCKLEN); |
read (filedes, block0, BLOCKLEN); |
|
|
block0[BTYP] = EMPTY; |
block0[BTYP] = EMPTY; |
|
|
lseek (filedes, (long) (blknbr) * BLOCKLEN, 0); |
lseek (filedes, hdr_offset + ((long) (blknbr) * BLOCKLEN), SEEK_SET); |
write (filedes, block0, BLOCKLEN); |
write (filedes, block0, BLOCKLEN); |
|
|
/* do we have a list of free blocks? */ |
/* do we have a list of free blocks? */ |
lseek (filedes, ROOT, 0); |
lseek (filedes, hdr_offset + ROOT, SEEK_SET); |
read (filedes, block0, BLOCKLEN); |
read (filedes, block0, BLOCKLEN); |
|
|
if ((free = UNSIGN (block0[FREE]) * 65536 + UNSIGN (block0[FREE + 1]) * 256 + UNSIGN (block0[FREE + 2]))) { |
if ((free = UNSIGN (block0[FREE]) * 65536 + UNSIGN (block0[FREE + 1]) * 256 + UNSIGN (block0[FREE + 2]))) { |
|
|
for (;;) { |
for (;;) { |
|
|
lseek (filedes, (long) free * (long) BLOCKLEN, 0); |
lseek (filedes, hdr_offset + ((long) free * (long) BLOCKLEN), SEEK_SET); |
read (filedes, block0, BLOCKLEN); |
read (filedes, block0, BLOCKLEN); |
|
|
other = UNSIGN (block0[RLPTR]) * 65536 + |
other = UNSIGN (block0[RLPTR]) * 65536 + |
Line 3101 static void b_free (short filedes, unsig
|
Line 3265 static void b_free (short filedes, unsig
|
block0[RLPTR + 1] = other % 65536 / 256; |
block0[RLPTR + 1] = other % 65536 / 256; |
block0[RLPTR + 2] = other % 256; |
block0[RLPTR + 2] = other % 256; |
|
|
lseek (filedes, (long) free * (long) BLOCKLEN, 0); |
lseek (filedes, hdr_offset + ((long) free * (long) BLOCKLEN), SEEK_SET); |
write (filedes, block0, BLOCKLEN); |
write (filedes, block0, BLOCKLEN); |
|
|
for (i = 0; i < BLOCKLEN; block0[i++] = 0); /* clear block */ |
for (i = 0; i < BLOCKLEN; block0[i++] = 0); /* clear block */ |
Line 3122 static void b_free (short filedes, unsig
|
Line 3286 static void b_free (short filedes, unsig
|
getnewblk (filedes, &free); |
getnewblk (filedes, &free); |
|
|
/* set FBLK free blocks pointer */ |
/* set FBLK free blocks pointer */ |
lseek (filedes, ROOT, 0); |
lseek (filedes, hdr_offset + ROOT, SEEK_SET); |
read (filedes, block0, BLOCKLEN); |
read (filedes, block0, BLOCKLEN); |
|
|
block0[FREE] = free / 65536; |
block0[FREE] = free / 65536; |
block0[FREE + 1] = free % 65536 / 256; |
block0[FREE + 1] = free % 65536 / 256; |
block0[FREE + 2] = free % 256; |
block0[FREE + 2] = free % 256; |
|
|
lseek (filedes, ROOT, 0); |
lseek (filedes, hdr_offset + ROOT, SEEK_SET); |
write (filedes, block0, BLOCKLEN); |
write (filedes, block0, BLOCKLEN); |
|
|
for (i = 0; i < BLOCKLEN; block0[i++] = 0); /* clear block */ |
for (i = 0; i < BLOCKLEN; block0[i++] = 0); /* clear block */ |
Line 3145 static void b_free (short filedes, unsig
|
Line 3309 static void b_free (short filedes, unsig
|
block0[OFFS] = offset / 256; |
block0[OFFS] = offset / 256; |
block0[OFFS + 1] = offset % 256; |
block0[OFFS + 1] = offset % 256; |
|
|
lseek (filedes, (long) free * (long) BLOCKLEN, 0); |
lseek (filedes, hdr_offset + ((long) free * (long) BLOCKLEN), SEEK_SET); |
write (filedes, block0, BLOCKLEN); |
write (filedes, block0, BLOCKLEN); |
|
|
return; |
return; |
Line 3272 static void getnewblk (int filedes, unsi
|
Line 3436 static void getnewblk (int filedes, unsi
|
unsigned long freeblks, no_of_blks; |
unsigned long freeblks, no_of_blks; |
long other; |
long other; |
long offset; |
long offset; |
|
long hdr_offset; |
|
|
lseek (filedes, ROOT, 0); |
hdr_offset = sizeof (global_header); |
|
|
|
lseek (filedes, hdr_offset + ROOT, SEEK_SET); |
read (filedes, nblock, BLOCKLEN); |
read (filedes, nblock, BLOCKLEN); |
|
|
freeblks = UNSIGN (nblock[FREE]) * 65536 + UNSIGN (nblock[FREE + 1]) * 256 + UNSIGN (nblock[FREE + 2]); |
freeblks = UNSIGN (nblock[FREE]) * 65536 + UNSIGN (nblock[FREE + 1]) * 256 + UNSIGN (nblock[FREE + 2]); |
Line 3281 static void getnewblk (int filedes, unsi
|
Line 3448 static void getnewblk (int filedes, unsi
|
|
|
if (freeblks) { |
if (freeblks) { |
|
|
lseek (filedes, (long) (freeblks) * BLOCKLEN, 0); |
lseek (filedes, hdr_offset + ((long) (freeblks) * BLOCKLEN), SEEK_SET); |
read (filedes, nblock, BLOCKLEN); |
read (filedes, nblock, BLOCKLEN); |
|
|
offset = UNSIGN (nblock[OFFS]) * 256 + UNSIGN (nblock[OFFS + 1]); |
offset = UNSIGN (nblock[OFFS]) * 256 + UNSIGN (nblock[OFFS + 1]); |
Line 3294 static void getnewblk (int filedes, unsi
|
Line 3461 static void getnewblk (int filedes, unsi
|
/* update RL-block, if any */ |
/* update RL-block, if any */ |
if (other) { |
if (other) { |
|
|
lseek (filedes, (long) (other) * BLOCKLEN, 0); |
lseek (filedes, hdr_offset + ((long) (other) * BLOCKLEN), SEEK_SET); |
read (filedes, nblock, BLOCKLEN); |
read (filedes, nblock, BLOCKLEN); |
|
|
nblock[LLPTR] = 0; |
nblock[LLPTR] = 0; |
nblock[LLPTR + 1] = 0; |
nblock[LLPTR + 1] = 0; |
nblock[LLPTR + 2] = 0; |
nblock[LLPTR + 2] = 0; |
|
|
lseek (filedes, (long) (other) * BLOCKLEN, 0); |
lseek (filedes, hdr_offset + ((long) (other) * BLOCKLEN), SEEK_SET); |
write (filedes, nblock, BLOCKLEN); |
write (filedes, nblock, BLOCKLEN); |
|
|
} |
} |
|
|
/* update ROOT block */ |
/* update ROOT block */ |
lseek (filedes, ROOT, 0); |
lseek (filedes, hdr_offset + ROOT, SEEK_SET); |
read (filedes, nblock, BLOCKLEN); |
read (filedes, nblock, BLOCKLEN); |
|
|
nblock[FREE] = other / 65536; |
nblock[FREE] = other / 65536; |
nblock[FREE + 1] = other % 65536 / 256; |
nblock[FREE + 1] = other % 65536 / 256; |
nblock[FREE + 2] = other % 256; |
nblock[FREE + 2] = other % 256; |
|
|
lseek (filedes, ROOT, 0); |
lseek (filedes, hdr_offset + ROOT, SEEK_SET); |
write (filedes, nblock, BLOCKLEN); |
write (filedes, nblock, BLOCKLEN); |
|
|
return; |
return; |
Line 3328 static void getnewblk (int filedes, unsi
|
Line 3495 static void getnewblk (int filedes, unsi
|
nblock[OFFS] = offset / 256; |
nblock[OFFS] = offset / 256; |
nblock[OFFS + 1] = offset % 256; |
nblock[OFFS + 1] = offset % 256; |
|
|
lseek (filedes, (long) (freeblks) * BLOCKLEN, 0); |
lseek (filedes, hdr_offset + ((long) (freeblks) * BLOCKLEN), SEEK_SET); |
write (filedes, nblock, BLOCKLEN); |
write (filedes, nblock, BLOCKLEN); |
|
|
return; |
return; |
Line 3341 static void getnewblk (int filedes, unsi
|
Line 3508 static void getnewblk (int filedes, unsi
|
nblock[NRBLK + 1] = no_of_blks % 65536 / 256; |
nblock[NRBLK + 1] = no_of_blks % 65536 / 256; |
nblock[NRBLK + 2] = no_of_blks % 256; |
nblock[NRBLK + 2] = no_of_blks % 256; |
|
|
lseek (filedes, ROOT, 0); |
lseek (filedes, hdr_offset + ROOT, SEEK_SET); |
write (filedes, nblock, BLOCKLEN); |
write (filedes, nblock, BLOCKLEN); |
|
|
*blknbr = no_of_blks; |
*blknbr = no_of_blks; |
Line 3350 static void getnewblk (int filedes, unsi
|
Line 3517 static void getnewblk (int filedes, unsi
|
|
|
errno = 0; |
errno = 0; |
|
|
lseek (filedes, (long) (no_of_blks) * BLOCKLEN, 0); |
lseek (filedes, hdr_offset + ((long) (no_of_blks) * BLOCKLEN), SEEK_SET); |
write (filedes, nblock, BLOCKLEN); |
write (filedes, nblock, BLOCKLEN); |
|
|
if (errno == 0) break; |
if (errno == 0) break; |
Line 3529 short g_numeric (char *str)
|
Line 3696 short g_numeric (char *str)
|
|
|
} /* end g_numeric() */ |
} /* end g_numeric() */ |
|
|
|
|
|
/* DEPRECATED: use gbl_close_all() instead */ |
void close_all_globals (void) |
void close_all_globals (void) |
{ |
{ |
register int i; |
gbl_close_all (); |
|
|
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; |
|
|
|
} |
|
|
|
} |
|
|
|
return; |
return; |
|
|
} /* end close_all_globals() */ |
} /* end close_all_globals() */ |
|
|
static void panic (void) |
static void panic (void) |