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