Annotation of freem/src/fma_journals.c, revision 1.3
1.1 snw 1: /*
1.3 ! snw 2: * $Id$
1.1 snw 3: * Journal utilities for fmadm
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) 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.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 <stdio.h>
34: #include <stdlib.h>
35: #include <string.h>
36: #include <dirent.h>
37: #include <time.h>
38: #include <unistd.h>
39: #include <sys/types.h>
40: #include <sys/stat.h>
41: #include <fcntl.h>
42: #include <errno.h>
43:
44: #include "fmadm.h"
45: #include "jnldefs.h"
46:
47: void cvt_key (char *buf, char *key);
48: extern short ierr;
49:
50: int fma_journals_examine (int optc, char **opts)
51: {
52: register int i;
53: register int k;
54: int fd;
55: unsigned long siz;
56: unsigned long ct;
57:
58: char buf[2048];
59: char kbuf[1024];
60: char *tbuf;
61:
62: char dbuf[2049];
63:
64: jnl_hdr_t hdr;
65: jnl_ent_t ent;
66:
67: if ((fd = open (fma_journal_path, O_RDONLY)) == -1) {
68: fprintf (stderr, "fmadm: error %d opening journal file %s (%s)\n", errno, fma_journal_path, strerror (errno));
69:
70: exit (2);
71: }
72:
73: if (read (fd, &hdr, sizeof (jnl_hdr_t)) == -1) {
74: fprintf (stderr, "fmadm: error %d reading header from journal file %s (%s)\n", errno, fma_journal_path, strerror (errno));
75:
76: exit (3);
77: }
78:
79: printf ("\nFreeM Journal Dump\n");
80: printf ("------------------\n\n");
81:
82: printf ("Namespace: %s\n", fma_namespace);
83: printf ("Journal File: %s\n", fma_journal_path);
84: printf ("Journal Format Version: %d\n", hdr.fmt_version);
85: printf ("Cut Threshold: %s bytes\n", fma_journal_cut_threshold);
86:
87: lseek (fd, 0L, SEEK_SET);
88: siz = lseek (fd, 0L, SEEK_END);
89:
90: ct = (siz - sizeof (jnl_hdr_t)) / sizeof (jnl_ent_t);
91:
92: printf ("Journal Entries: %ld\n\n", ct);
93:
94: printf ("%-26s %-6s %-7s %-10s %s\n", "DATE", "PID", "TRNID", "ACTION", "DATA");
95: printf ("%-26s %-6s %-7s %-10s %s\n", "----", "---", "-----", "------", "----");
96:
97: lseek (fd, sizeof (jnl_hdr_t), SEEK_SET);
98:
99: for (i = 0; i < ct; i++) {
100:
101: read (fd, &ent, sizeof (jnl_ent_t));
102:
103: switch (ent.action) {
104:
105: case JNLA_TSTART:
106: strcpy (buf, "TSTART");
107: break;
108:
109: case JNLA_TROLLBACK:
110: strcpy (buf, "TROLLBACK");
111: break;
112:
113: case JNLA_TCOMMIT:
114: strcpy (buf, "TCOMMIT");
115: break;
116:
117: case JNLA_SET:
118: strcpy (buf, "SET");
119: break;
120:
121: case JNLA_KILL:
122: strcpy (buf, "KILL");
123: break;
124:
125: }
126:
127: cvt_key (kbuf, ent.key);
128:
129:
130: tbuf = ctime (&ent.ts);
131: tbuf[strlen(tbuf) - 1] = '\0';
132:
133: if (ent.action == JNLA_SET) {
134:
135: snprintf (dbuf, 2049, "%s=%s", kbuf, ent.data);
136:
137: for (k = 0; k < strlen (dbuf); k++) {
138: if (dbuf[k] == '\201') dbuf[k] = '\0';
139: }
140:
141: printf ("%-26s %-6d %-7ld %-10s %s\n", tbuf, ent.pid, ent.tran_id, buf, dbuf);
142:
143: }
144: else {
145: printf ("%-26s %-6d %-7ld %-10s %s\n", tbuf, ent.pid, ent.tran_id, buf, kbuf);
146: }
147:
148: }
149:
150: return 0;
151:
152: }
153:
154: int fma_journals_restore (int optc, char **opts)
155: {
156:
157: register int i;
158: register int k;
159: int fd;
160: unsigned long siz;
161: unsigned long ct;
162:
163: char kbuf[1024];
164: char *tbuf;
165:
166: char dbuf[2049];
167:
168: jnl_hdr_t hdr;
169: jnl_ent_t ent;
170:
171: if ((fd = open (fma_journal_path, O_RDONLY)) == -1) {
172: fprintf (stderr, "error: error %d opening journal file %s\n", errno, fma_journal_path);
173:
174: exit (2);
175: }
176:
177: if (read (fd, &hdr, sizeof (jnl_hdr_t)) == -1) {
178: fprintf (stderr, "error: error %d reading header from journal file %s\n", errno, fma_journal_path);
179:
180: exit (3);
181: }
182:
183: printf ("\nFreeM Journal Playback\n");
184: printf ("----------------------\n\n");
185:
186: printf ("Namespace: %s\n", fma_namespace);
187: printf ("Journal File: %s\n", fma_journal_path);
188: printf ("Journal Format Version: %d\n", hdr.fmt_version);
189: printf ("Cut Threshold: %s bytes\n", fma_journal_cut_threshold);
190:
191: lseek (fd, 0L, SEEK_SET);
192: siz = lseek (fd, 0L, SEEK_END);
193:
194: ct = (siz - sizeof (jnl_hdr_t)) / sizeof (jnl_ent_t);
195:
196: printf ("Journal Entries: %ld\n\n", ct);
197:
198:
199: lseek (fd, sizeof (jnl_hdr_t), SEEK_SET);
200:
201: for (i = 0; i < ct; i++) {
202:
203: read (fd, &ent, sizeof (jnl_ent_t));
204:
205: switch (ent.action) {
206:
207: case JNLA_TSTART:
208: printf (" Played back TSTART (transaction id %ld)\n", ent.tran_id);
209: break;
210:
211: case JNLA_TROLLBACK:
212: printf (" Played back TROLLBACK (transaction id %ld)\n", ent.tran_id);
213: break;
214:
215: case JNLA_TCOMMIT:
216: printf (" Played back TCOMMIT (transaction id %ld)\n", ent.tran_id);
217: break;
218:
219: case JNLA_SET:
220: global (set_sym, ent.key, ent.data);
221: printf (" Played back SET (transaction id %ld)\n", ent.tran_id);
222: break;
223:
224: case JNLA_KILL:
225: global (kill_sym, ent.key, ent.data);
226: printf (" Played back KILL (transaction id %ld)\n", ent.tran_id);
227: break;
228:
229: }
230:
231: }
232:
233: return 0;
234:
235: }
236:
237:
238: void cvt_key (char *buf, char *key)
239: {
240: int i;
241: int j = 0;
242: int first = 1;
243:
244: if (key[0] == '\0') {
245: buf[0] = '\0';
246:
247: return;
248: }
249:
250: for(i = 0; i < 1023; i++) {
251:
252: switch (key[i]) {
253:
254: case '\201':
255: if (first == 0) {
256: buf[j] = ')';
257: buf[j + 1] = '\0';
258: }
259: else {
260: buf[j] = '\0';
261: }
262: return;
263:
264: case '\202':
265: if (first == 1) {
266: buf[j] = '(';
267: first = 0;
268: }
269: else {
270: buf[j] = ',';
271: }
272:
273: break;
274:
275: default:
276: buf[j] = key[i];
277: break;
278: }
279:
280: j++;
281: }
282:
283: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to fma_journals.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Coherent Logic Development] / freem / src