Annotation of freem/src/ssvn_global.c, revision 1.5
1.1 snw 1: /*
1.5 ! snw 2: * $Id: ssvn_global.c,v 1.4 2025/03/09 19:50:47 snw Exp $
1.4 snw 3: * ^$GLOBAL ssvn
1.1 snw 4: *
5: *
1.3 snw 6: * Author: Serena Willis <snw@coherent-logic.com>
1.1 snw 7: * Copyright (C) 1998 MUG Deutschland
1.4 snw 8: * Copyright (C) 2020, 2025 Coherent Logic Development LLC
1.1 snw 9: *
10: *
11: * This file is part of FreeM.
12: *
13: * FreeM is free software: you can redistribute it and/or modify
14: * it under the terms of the GNU Affero Public License as published by
15: * the Free Software Foundation, either version 3 of the License, or
16: * (at your option) any later version.
17: *
18: * FreeM is distributed in the hope that it will be useful,
19: * but WITHOUT ANY WARRANTY; without even the implied warranty of
20: * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
21: * GNU Affero Public License for more details.
22: *
23: * You should have received a copy of the GNU Affero Public License
24: * along with FreeM. If not, see <https://www.gnu.org/licenses/>.
25: *
1.5 ! snw 26: * $Log: ssvn_global.c,v $
! 27: * Revision 1.4 2025/03/09 19:50:47 snw
! 28: * Second phase of REUSE compliance and header reformat
! 29: *
1.4 snw 30: *
31: * SPDX-FileCopyrightText: (C) 2025 Coherent Logic Development LLC
32: * SPDX-License-Identifier: AGPL-3.0-or-later
1.1 snw 33: **/
34:
35: #include <stdio.h>
36: #include <unistd.h>
37: #include <fcntl.h>
38: #include <string.h>
39: #include <stdlib.h>
40:
41: #include "mpsdef.h"
42: #include "mref.h"
43: #include "iniconf.h"
44: #include "namespace.h"
45:
46: #define DATALIM (BLOCKLEN-11)
47: #define LLPTR (BLOCKLEN-10)
48: #define NRBLK LLPTR
49: #define COLLA (BLOCKLEN- 7)
50: #define RLPTR (BLOCKLEN- 6)
51: #define FREE RLPTR
52: #define BTYP (BLOCKLEN- 3)
53: #define OFFS (BLOCKLEN- 2)
54:
55: /* length of blockpointers in bytes */
56: #define PLEN 3
57:
58: #define EMPTY 0
59: #define FBLK 1
60: #define POINTER 2
61: #define BOTTOM 6
62: #define DATA 8
63:
64: typedef struct db_blockinfo {
65:
66: int keylen;
67: int keyoffs;
68: char key[STRLEN];
69: int datalen;
70: char data[STRLEN];
71:
72: long llptr;
73: long rlptr;
74:
75: long blockcount;
76: int collation;
77:
78: int btype;
79: long free_offset;
80:
81: } db_blockinfo;
82:
83: short frm_global_exists(char *, char *, char *);
84: void frm_decode_block(db_blockinfo *, char *, long);
85: long frm_blockcount(char *);
86: long frm_bytecount(char *);
87:
88: void frm_decode_block(db_blockinfo *b, char *gbpth, long blocknum)
89: {
90:
91: int fd;
92: char blk[BLOCKLEN];
93:
94:
95: fd = open (gbpth, O_RDONLY);
96: lseek (fd, blocknum * BLOCKLEN, SEEK_SET);
97: read (fd, blk, BLOCKLEN);
98:
99: close (fd);
100:
101: b->btype = blk[BTYP];
102:
103: if (blocknum == 0) {
104: b->collation = blk[COLLA];
105: b->blockcount = ((int) blk[NRBLK]) << 4;
106: }
107: else {
108: b->llptr = UNSIGN (blk[LLPTR]) * 65536 + UNSIGN (blk[LLPTR + 1]) * 256 + UNSIGN (blk[LLPTR + 2]);
109: b->rlptr = UNSIGN (blk[RLPTR]) * 65536 + UNSIGN (blk[RLPTR + 1]) * 256 + UNSIGN (blk[RLPTR + 2]);
110: }
111:
112: if (b->btype == DATA) {
113: b->free_offset = UNSIGN (blk[OFFS]) * 256 + UNSIGN (blk[OFFS + 1]);
114: b->keylen = blk[0];
115: }
116:
117: return;
118:
119: }
120:
121: void ssvn_global(short action, char *key, char *data)
122: {
123: char gb_ns[STRLEN];
1.5 ! snw 124: char gb_path[PATHLEN];
! 125: char gb_cpath[PATHLEN];
1.1 snw 126:
1.5 ! snw 127: char ns_key[STRLEN];
! 128: char ns_data[STRLEN];
1.1 snw 129:
130: long blkcount;
131:
132: freem_ref_t *r;
133: db_blockinfo *bi;
134:
135: r = (freem_ref_t *) malloc (sizeof (freem_ref_t));
136: NULLPTRCHK(r,"ssvn_global");
137:
138: bi = (db_blockinfo *) malloc (sizeof (db_blockinfo));
139: NULLPTRCHK(bi,"ssvn_global");
140:
141: mref_init (r, MREF_RT_SSV, "^$GLOBAL");
142: internal_to_mref (r, key);
143:
144: switch (action) {
145:
146: case set_sym:
147:
148: if (strcmp (mref_get_subscript (r, 1), "NAMESPACE") != 0) {
149: merr_raise (M29);
150: goto done;
151: }
152:
153: snprintf (ns_key, 255, "^$SYSTEM\202MAPPINGS\202GLOBAL\202^%s\201", mref_get_subscript (r, 0));
154: global (set_sym, ns_key, data);
155:
156: goto done;
157:
158: case kill_sym:
159:
160: if (strcmp (mref_get_subscript (r, 1), "NAMESPACE") != 0) {
161: merr_raise (M29);
162: goto done;
163: }
164:
1.5 ! snw 165: snprintf (ns_key, STRLEN, "^$SYSTEM\202MAPPINGS\202GLOBAL\202^%s\201", mref_get_subscript (r, 0));
1.1 snw 166: global (kill_sym, ns_key, data);
167:
168: goto done;
169:
170:
171:
172: case get_sym:
173:
174: if (frm_global_exists (gb_ns, gb_path, r->subscripts[0]) != TRUE) {
175: merr_raise (M7);
176: goto done;
177: }
178:
179: if (strcmp (mref_get_subscript (r, 1), "BLOCK") == 0) {
180:
181: long bn = atol (mref_get_subscript (r, 2));
182:
183: stcpy (gb_cpath, gb_path);
184: stcnv_m2c (gb_cpath);
185:
186: blkcount = frm_blockcount (gb_cpath);
187:
188: if (bn > (blkcount - 1)) {
189: merr_raise (M38);
190: goto done;
191: }
192:
193: frm_decode_block (bi, gb_cpath, bn);
194:
195: if (strcmp (mref_get_subscript (r, 3), "TYPE") == 0) {
196:
197: switch (bi->btype) {
198:
199: case 2:
200: sprintf (data, "%s\201", "POINTER");
201: merr_raise (OK);
202: goto done;
203:
204: case 6:
205: sprintf (data, "%s\201", "ROOT");
206: merr_raise (OK);
207: goto done;
208:
209: case 8:
210: sprintf (data, "%s\201", "DATA");
211: merr_raise (OK);
212: goto done;
213: }
214:
215:
216: sprintf (data, "%d\201", bi->btype);
217: merr_raise (OK);
218: goto done;
219:
220: }
221: else if (strcmp (mref_get_subscript (r, 3), "BLOCKCOUNT") == 0) {
222:
223: if (bn != 0) {
224: merr_raise (M38);
225: goto done;
226: }
227:
1.2 snw 228: sprintf (data, "%ld\201", bi->blockcount);
1.1 snw 229: merr_raise (OK);
230: goto done;
231: }
232: else if (strcmp (mref_get_subscript (r, 3), "KEYLEN") == 0) {
233:
234: if (bn == 0) {
235: merr_raise (M38);
236: goto done;
237: }
238:
239: sprintf (data, "%d\201", bi->keylen);
240: merr_raise (OK);
241: goto done;
242: }
243: else if (strcmp (mref_get_subscript (r, 3), "RLPTR") == 0) {
244:
245: if (bn == 0) {
246: merr_raise (M38);
247: goto done;
248: }
249:
250:
1.2 snw 251: sprintf (data, "%ld\201", bi->rlptr);
1.1 snw 252: merr_raise (OK);
253: goto done;
254: }
255: else if (strcmp (mref_get_subscript (r, 3), "OFFS") == 0) {
256:
257: if (bi->btype != DATA) {
258: merr_raise (M38);
259: goto done;
260: }
261:
1.2 snw 262: sprintf (data, "%ld\201", bi->free_offset);
1.1 snw 263: merr_raise (OK);
264: goto done;
265: }
266: else if (strcmp (mref_get_subscript (r, 3), "LLPTR") == 0) {
267:
268: if (bn == 0) {
269: merr_raise (M38);
270: goto done;
271: }
272:
1.2 snw 273: sprintf (data, "%ld\201", bi->llptr);
1.1 snw 274: merr_raise (OK);
275: goto done;
276: }
277:
278: }
279: else if (strcmp (mref_get_subscript (r, 1), "CHARACTER") == 0) {
280: stcpy (gb_cpath, gb_path);
281: stcnv_m2c (gb_cpath);
282:
283: frm_decode_block (bi, gb_cpath, 0L);
284:
285: if (bi->collation == 0) {
286: sprintf (data, "M\201");
287: merr_raise (OK);
288: goto done;
289: }
290: else {
291: sprintf (data, "ASCII\201");
292: merr_raise (OK);
293: goto done;
294: }
295: }
296: else if (strcmp (mref_get_subscript (r, 1), "COLLATE") == 0) {
297: stcpy (gb_cpath, gb_path);
298: stcnv_m2c (gb_cpath);
299:
300: frm_decode_block (bi, gb_cpath, 0L);
301:
302: if (bi->collation == 0) {
303: sprintf (data, "M\201");
304: merr_raise (OK);
305: goto done;
306: }
307: else {
308: sprintf (data, "ASCII\201");
309: merr_raise (OK);
310: goto done;
311: }
312: }
313: else if (strcmp (mref_get_subscript (r, 1), "NAMESPACE") == 0) {
314: sprintf (data, "%s\201", gb_ns);
315: merr_raise (OK);
316: goto done;
317: }
318: else if (strcmp (mref_get_subscript (r, 1), "FILE") == 0) {
319: sprintf (data, "%s\201", gb_path);
320: merr_raise (OK);
321: goto done;
322: }
323: else if (strcmp (mref_get_subscript (r, 1), "BLOCKSIZE") == 0) {
324: sprintf (data, "%d\201", BLOCKLEN);
325: merr_raise (OK);
326: goto done;
327: }
328: else if (strcmp (mref_get_subscript (r, 1), "BLOCKS") == 0) {
329:
330: long blockcount;
331:
332: stcpy (gb_cpath, gb_path);
333: stcnv_m2c (gb_cpath);
334:
335: blockcount = frm_blockcount (gb_cpath);
336:
337: sprintf (data, "%ld\201", blockcount);
338:
339: merr_raise (OK);
340: goto done;
341:
342: }
343: else if (strcmp (mref_get_subscript (r, 1), "BYTES") == 0) {
344:
345: FILE *fp;
346: long bytecount;
347:
348: stcpy (gb_cpath, gb_path);
349: stcnv_m2c (gb_cpath);
350:
351: bytecount = frm_bytecount (gb_cpath);
352:
353: sprintf (data, "%ld\201", bytecount);
354:
355: merr_raise (OK);
356: goto done;
357:
358: }
359:
360: merr_raise (M38);
361: goto done;
362:
363:
364: default:
365: merr_raise (INVREF);
366: goto done;
367:
368: }
369:
370: done:
371:
372: free (r);
373:
374: return;
375: }
376:
377: short frm_global_exists(char *gbl_namespace, char *gbl_path, char *global_name)
378: {
379: char *gpth;
1.5 ! snw 380: char glofile[PATHLEN];
1.1 snw 381: char goobuf[STRLEN];
382:
1.5 ! snw 383: char mapk_buf[STRLEN];
! 384: char mapd_buf[STRLEN];
! 385: char old_ns[STRLEN];
1.1 snw 386:
387: int ierr_sav = OK;
388:
389: if (global_name[0] != '^') {
1.5 ! snw 390: snprintf (mapk_buf, STRLEN, "^$SYSTEM\202MAPPINGS\202GLOBAL\202^%s\201", global_name);
1.1 snw 391: }
392: else {
1.5 ! snw 393: snprintf (mapk_buf, STRLEN, "^$SYSTEM\202MAPPINGS\202GLOBAL\202%s\201", global_name);
1.1 snw 394: }
395:
396: global (get_sym, mapk_buf, mapd_buf);
397:
398: stcnv_m2c (mapd_buf);
399:
400: if (merr () == OK) {
401:
402: strncpy (old_ns, nsname, 255);
403: set_namespace (mapd_buf, 0);
404:
405: gpth = (char *) malloc (PATHLEN * sizeof (char));
406: NULLPTRCHK(gpth,"frm_global_exists");
407:
408: strncpy (gpth, glopath, PATHLEN - 1);
409: strncpy (gbl_namespace, mapd_buf, 254);
410:
411: set_namespace (old_ns, 0);
412:
413: }
414: else {
415:
416: merr_raise (ierr_sav);
417:
418: if (global_name[0] == '%') {
419: gpth = gloplib;
420: sprintf (gbl_namespace, "SYSTEM");
421: }
422: else {
423: gpth = glopath;
424: sprintf (gbl_namespace, "%s\201", nsname);
425: }
426:
427: }
428:
429: stcpy (goobuf, gpth);
430: stcnv_m2c (goobuf);
431:
432: if (global_name[0] != '^') {
1.5 ! snw 433: snprintf (glofile, PATHLEN, "%s/^%s", goobuf, global_name);
1.1 snw 434: }
435: else {
1.5 ! snw 436: snprintf (glofile, PATHLEN, "%s/%s", goobuf, global_name);
1.1 snw 437: }
438:
439: strcpy (gbl_path, glofile);
440: stcnv_c2m (gbl_path);
441:
442: if (file_exists (glofile)) {
443: return TRUE;
444: }
445: else {
446: return FALSE;
447: }
448:
449:
450: }
451:
452: long frm_blockcount(char *gbl_path)
453: {
454: FILE *fp;
455: long blockcount;
456:
457:
458: fp = fopen (gbl_path, "r");
459: fseek (fp, 0L, SEEK_END);
460: blockcount = ftell (fp) / BLOCKLEN;
461: fclose (fp);
462:
463:
464: return blockcount;
465: }
466:
467: long frm_bytecount(char *gbl_path)
468: {
469: FILE *fp;
470: long bytecount;
471:
472:
473: fp = fopen (gbl_path, "r");
474: fseek (fp, 0L, SEEK_END);
475: bytecount = ftell (fp);
476: fclose (fp);
477:
478: return bytecount;
479: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to ssvn_global.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Coherent Logic Development] / freem / src