Annotation of freem/src/tp_check.c, revision 1.3
1.1 snw 1: /*
1.3 ! snw 2: * $Id$
! 3: * TP global checkpointing code
1.1 snw 4: *
5: *
1.2 snw 6: * Author: Serena Willis <snw@coherent-logic.com>
1.1 snw 7: * Copyright (C) 1998 MUG Deutschland
1.3 ! snw 8: * Copyright (C) 2022, 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.3 ! snw 26: * $Log$
! 27: *
! 28: * SPDX-FileCopyrightText: (C) 2025 Coherent Logic Development LLC
! 29: * SPDX-License-Identifier: AGPL-3.0-or-later
1.1 snw 30: **/
31:
32: #include <stdlib.h>
33: #include <string.h>
34: #include <unistd.h>
35: #include "tp_check.h"
36: #include "mpsdef.h"
37: #include "transact.h"
38: #include "journal.h"
39: #include "fs.h"
40:
41: short frm_global_exists(char *, char *, char *);
42:
43: cptab *cptab_head[TP_MAX_NEST];
44:
45: cptab *cptab_insert(int tlevel, char *global)
46: {
47: cptab *t;
48: char mode;
49:
50: short g_exists;
51:
52: char *gc_ns;
53: char *gc_pth;
54:
55: gc_ns = (char *) malloc (STRLEN * sizeof (char));
56: NULLPTRCHK(gc_ns,"cptab_insert");
57:
58: gc_pth = (char *) malloc (STRLEN * sizeof (char));
59: NULLPTRCHK(gc_pth,"cptab_insert");
60:
61: for (t = cptab_head[tlevel]; t != NULL; t = t->next) {
62:
63: if ((strcmp (t->global, global) == 0) && (t->mode > CP_UNUSED)) {
64: /* found match */
65: return t;
66: }
67:
68: }
69:
70: /* insert */
71: t = (cptab *) malloc (sizeof (cptab));
72: NULLPTRCHK(t,"cptab_insert");
73:
74: t->global = (char *) malloc (sizeof (char) * (strlen (global) + 1));
75: NULLPTRCHK(t->global,"cptab_insert");
76:
77: strcpy (t->global, global);
78:
79: g_exists = frm_global_exists (gc_ns, gc_pth, global);
80:
81: t->file = (char *) malloc (sizeof (char) * (strlen (gc_pth)));
82: NULLPTRCHK(t->file,"cptab_insert");
83:
84: t->cp_file = (char *) malloc (sizeof (char) * STRLEN);
85: NULLPTRCHK(t->cp_file,"cptab_insert");
86:
87: strcpy (t->file, gc_pth);
88: stcnv_m2c (t->file);
89:
90: snprintf (t->cp_file, STRLEN - 1, "%s.%d.%d.chk", t->file, pid, tp_level);
91:
92: free (gc_ns);
93: free (gc_pth);
94:
95: if (!g_exists) {
96: t->mode = CP_REMOVE;
97: }
98: else {
99: t->mode = CP_RESTORE;
100: }
101:
102: t->next = cptab_head[tlevel];
103: cptab_head[tlevel] = t;
104:
105: return t;
106: }
107:
108: short cptab_precommit(int tlevel)
109: {
110: cptab *t;
111: /*char *cmd;*/
112: char *pctmp;
113: int rc;
114:
115: /*
116: cmd = (char *) malloc (STRLEN * sizeof (char));
117: NULLPTRCHK(cmd,"cptab_precommit");
118: */
119:
120: pctmp = (char *) malloc (STRLEN * sizeof (char));
121: NULLPTRCHK(pctmp,"cptab_precommit");
122:
123: for (t = cptab_head[tlevel]; t != NULL; t = t->next) {
124:
125: if (t->mode == CP_RESTORE) {
126:
127: /*
128: snprintf (cmd, STRLEN - 1, "/bin/cp %s %s", t->file, t->cp_file);
129: rc = system (cmd);
130: */
131:
132: rc = cp (t->cp_file, t->file);
133:
134: if (rc != 0) {
135:
136: strcpy (pctmp, t->file);
137: stcnv_c2m (pctmp);
138:
139: jnl_ent_write (JNLA_CHECKPOINT_FAIL, " \201", pctmp);
140:
141: /*free (cmd);*/
142: free (pctmp);
143:
144: return FALSE;
145:
146: }
147: else {
148:
149: strcpy (pctmp, t->file);
150: stcnv_c2m (pctmp);
151:
152: jnl_ent_write (JNLA_CHECKPOINT_OK, " \201", pctmp);
153:
154: }
155:
156: }
157:
158: }
159:
160: /*free (cmd);*/
161: free (pctmp);
162:
163: return TRUE;
164: }
165:
166: void cptab_postcommit(int tlevel)
167: {
168: cptab *t;
169: /*char *cmd;*/
170: int rc;
171:
172: /*
173: cmd = (char *) malloc (STRLEN * sizeof (char));
174: NULLPTRCHK(cmd,"cptab_postcommit");
175: */
176:
177: for (t = cptab_head[tlevel]; t != NULL; t = t->next) {
178:
179: if (t->mode == CP_RESTORE) {
180: /*
181: snprintf (cmd, STRLEN - 1, "/bin/rm -f '%s'", t->cp_file);
182: rc = system (cmd);
183: */
184: unlink (t->cp_file);
185: }
186:
187: }
188:
189: cptab_head[tlevel] = NULL;
190: }
191:
192: short cptab_rollback(int tlevel)
193: {
194: cptab *t;
195: /*char *cmd;*/
196: int rc;
197:
198: /*
199: cmd = (char *) malloc (STRLEN * sizeof (char));
200: NULLPTRCHK(cmd,"cptab_rollback");
201: */
202:
203: for (t = cptab_head[tlevel]; t != NULL; t = t->next) {
204:
205: switch (t->mode) {
206:
207: case CP_REMOVE:
208: unlink (t->file);
209: /*
210: snprintf (cmd, STRLEN - 1, "/bin/rm -f '%s'", t->file);
211: rc = system (cmd);
212: */
213: break;
214:
215: case CP_RESTORE:
216: /*
217: snprintf (cmd, STRLEN - 1, "/bin/cp '%s' '%s'", t->cp_file, t->file);
218: rc = system (cmd);
219: */
220: rc = cp (t->file, t->cp_file);
221:
222: if (rc != 0) {
223: cptab_head[tlevel] = NULL;
224: /*free (cmd);*/
225: return FALSE;
226: }
227:
228: /*
229: snprintf (cmd, STRLEN - 1, "/bin/rm -f %s", t->cp_file);
230: rc = system (cmd);
231: */
232:
233: unlink (t->cp_file);
234: if (rc != 0) {
235: cptab_head[tlevel] = NULL;
236: /*free (cmd);*/
237: return FALSE;
238: }
239:
240: break;
241:
242:
243: }
244:
245: }
246:
247: cptab_head[tlevel] = NULL;
248:
249: return TRUE;
250:
251: }
252:
253: void cptab_dump(int tlevel)
254: {
255: cptab *gt;
256: char cp_mode[15];
257:
258: printf ("\n Global database checkpoints:\n");
259:
260: printf ("\n %-30s%-20s%s\n", "GLOBAL", "MODE", "FILES");
261: printf (" %-30s%-20s%s\n", "------", "----", "-----");
262:
263: for (gt = cptab_head[tlevel]; gt != NULL; gt = gt->next) {
264:
265: switch (gt->mode) {
266:
267: case CP_UNUSED:
268: strcpy (cp_mode, "CP_UNUSED");
269: break;
270:
271: case CP_REMOVE:
272: strcpy (cp_mode, "CP_REMOVE");
273: break;
274:
275: case CP_RESTORE:
276: strcpy (cp_mode, "CP_RESTORE");
277: break;
278:
279: }
280:
281: if (gt->mode > CP_UNUSED) {
282: printf (" %-30s%-20sIN: %s\n", gt->global, cp_mode, gt->file);
283: }
284: else {
285: printf (" N/A\n");
286: }
287:
288: if (gt->mode == CP_RESTORE) {
289: printf (" %-30s%-20sOUT: %s\n", "", "", gt->cp_file);
290: }
291:
292: }
293: }
294:
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to tp_check.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Coherent Logic Development] / freem / src