1 1.6 rin /* $NetBSD: log.c,v 1.6 2019/07/24 08:37:59 rin Exp $ */ 2 1.1 christos /*- 3 1.1 christos * Copyright (c) 1992, 1993, 1994 4 1.1 christos * The Regents of the University of California. All rights reserved. 5 1.1 christos * Copyright (c) 1992, 1993, 1994, 1995, 1996 6 1.1 christos * Keith Bostic. All rights reserved. 7 1.1 christos * 8 1.1 christos * See the LICENSE file for redistribution information. 9 1.1 christos */ 10 1.1 christos 11 1.1 christos #include "config.h" 12 1.1 christos 13 1.3 christos #include <sys/cdefs.h> 14 1.3 christos #if 0 15 1.1 christos #ifndef lint 16 1.1 christos static const char sccsid[] = "Id: log.c,v 10.26 2002/03/02 23:12:13 skimo Exp (Berkeley) Date: 2002/03/02 23:12:13 "; 17 1.1 christos #endif /* not lint */ 18 1.3 christos #else 19 1.6 rin __RCSID("$NetBSD: log.c,v 1.6 2019/07/24 08:37:59 rin Exp $"); 20 1.3 christos #endif 21 1.1 christos 22 1.1 christos #include <sys/types.h> 23 1.1 christos #include <sys/queue.h> 24 1.1 christos #include <sys/stat.h> 25 1.1 christos 26 1.1 christos #include <bitstring.h> 27 1.1 christos #include <errno.h> 28 1.1 christos #include <fcntl.h> 29 1.1 christos #include <limits.h> 30 1.1 christos #include <stdio.h> 31 1.1 christos #include <stdlib.h> 32 1.1 christos #include <string.h> 33 1.1 christos 34 1.1 christos #include "common.h" 35 1.2 christos #include "dbinternal.h" 36 1.1 christos 37 1.1 christos /* 38 1.1 christos * The log consists of records, each containing a type byte and a variable 39 1.1 christos * length byte string, as follows: 40 1.1 christos * 41 1.1 christos * LOG_CURSOR_INIT MARK 42 1.1 christos * LOG_CURSOR_END MARK 43 1.1 christos * LOG_LINE_APPEND_F db_recno_t char * 44 1.1 christos * LOG_LINE_APPEND_B db_recno_t char * 45 1.1 christos * LOG_LINE_DELETE_F db_recno_t char * 46 1.1 christos * LOG_LINE_DELETE_B db_recno_t char * 47 1.1 christos * LOG_LINE_RESET_F db_recno_t char * 48 1.1 christos * LOG_LINE_RESET_B db_recno_t char * 49 1.1 christos * LOG_MARK LMARK 50 1.1 christos * 51 1.1 christos * We do before image physical logging. This means that the editor layer 52 1.1 christos * MAY NOT modify records in place, even if simply deleting or overwriting 53 1.1 christos * characters. Since the smallest unit of logging is a line, we're using 54 1.1 christos * up lots of space. This may eventually have to be reduced, probably by 55 1.1 christos * doing logical logging, which is a much cooler database phrase. 56 1.1 christos * 57 1.1 christos * The implementation of the historic vi 'u' command, using roll-forward and 58 1.1 christos * roll-back, is simple. Each set of changes has a LOG_CURSOR_INIT record, 59 1.1 christos * followed by a number of other records, followed by a LOG_CURSOR_END record. 60 1.1 christos * LOG_LINE_RESET records come in pairs. The first is a LOG_LINE_RESET_B 61 1.1 christos * record, and is the line before the change. The second is LOG_LINE_RESET_F, 62 1.1 christos * and is the line after the change. Roll-back is done by backing up to the 63 1.1 christos * first LOG_CURSOR_INIT record before a change. Roll-forward is done in a 64 1.1 christos * similar fashion. 65 1.1 christos * 66 1.1 christos * The 'U' command is implemented by rolling backward to a LOG_CURSOR_END 67 1.1 christos * record for a line different from the current one. It should be noted that 68 1.1 christos * this means that a subsequent 'u' command will make a change based on the 69 1.1 christos * new position of the log's cursor. This is okay, and, in fact, historic vi 70 1.1 christos * behaved that way. 71 1.1 christos */ 72 1.1 christos 73 1.1 christos static int vi_log_get __P((SCR *sp, db_recno_t *lnop, size_t *size)); 74 1.1 christos static int log_cursor1 __P((SCR *, int)); 75 1.2 christos static void log_err __P((SCR *, const char *, int)); 76 1.1 christos #if defined(DEBUG) && 0 77 1.2 christos static void log_trace __P((SCR *, const char *, db_recno_t, u_char *)); 78 1.1 christos #endif 79 1.1 christos 80 1.1 christos /* Try and restart the log on failure, i.e. if we run out of memory. */ 81 1.1 christos #define LOG_ERR { \ 82 1.1 christos log_err(sp, __FILE__, __LINE__); \ 83 1.1 christos return (1); \ 84 1.1 christos } 85 1.1 christos 86 1.1 christos /* offset of CHAR_T string in log needs to be aligned on some systems 87 1.1 christos * because it is passed to db_set as a string 88 1.1 christos */ 89 1.1 christos typedef struct { 90 1.1 christos char data[sizeof(u_char) /* type */ + sizeof(db_recno_t)]; 91 1.1 christos CHAR_T str[1]; 92 1.1 christos } log_t; 93 1.5 kamil #define CHAR_T_OFFSET (offsetof(log_t, str)) 94 1.1 christos 95 1.1 christos /* 96 1.1 christos * log_init -- 97 1.1 christos * Initialize the logging subsystem. 98 1.1 christos * 99 1.1 christos * PUBLIC: int log_init __P((SCR *, EXF *)); 100 1.1 christos */ 101 1.1 christos int 102 1.1 christos log_init(SCR *sp, EXF *ep) 103 1.1 christos { 104 1.1 christos /* 105 1.1 christos * !!! 106 1.1 christos * ep MAY NOT BE THE SAME AS sp->ep, DON'T USE THE LATTER. 107 1.1 christos * 108 1.1 christos * Initialize the buffer. The logging subsystem has its own 109 1.1 christos * buffers because the global ones are almost by definition 110 1.1 christos * going to be in use when the log runs. 111 1.1 christos */ 112 1.1 christos sp->wp->l_lp = NULL; 113 1.1 christos sp->wp->l_len = 0; 114 1.1 christos ep->l_cursor.lno = 1; /* XXX Any valid recno. */ 115 1.1 christos ep->l_cursor.cno = 0; 116 1.1 christos ep->l_high = ep->l_cur = 1; 117 1.1 christos 118 1.1 christos if (db_create(&ep->log, 0, 0) != 0 || 119 1.1 christos db_open(ep->log, NULL, DB_RECNO, 120 1.1 christos DB_CREATE | VI_DB_THREAD, S_IRUSR | S_IWUSR) != 0) { 121 1.1 christos msgq(sp, M_SYSERR, "009|Log file"); 122 1.1 christos F_SET(ep, F_NOLOG); 123 1.1 christos return (1); 124 1.1 christos } 125 1.1 christos 126 1.1 christos ep->l_win = NULL; 127 1.1 christos /*LOCK_INIT(sp->wp, ep);*/ 128 1.1 christos 129 1.1 christos return (0); 130 1.1 christos } 131 1.1 christos 132 1.1 christos /* 133 1.1 christos * log_end -- 134 1.1 christos * Close the logging subsystem. 135 1.1 christos * 136 1.1 christos * PUBLIC: int log_end __P((SCR *, EXF *)); 137 1.1 christos */ 138 1.1 christos int 139 1.1 christos log_end(SCR *sp, EXF *ep) 140 1.1 christos { 141 1.1 christos /* 142 1.1 christos * !!! 143 1.1 christos * ep MAY NOT BE THE SAME AS sp->ep, DON'T USE THE LATTER. 144 1.1 christos */ 145 1.1 christos /*LOCK_END(sp->wp, ep);*/ 146 1.1 christos if (ep->log != NULL) { 147 1.1 christos (void)(ep->log->close)(ep->log, DB_NOSYNC); 148 1.1 christos ep->log = NULL; 149 1.1 christos } 150 1.1 christos if (sp->wp->l_lp != NULL) { 151 1.1 christos free(sp->wp->l_lp); 152 1.1 christos sp->wp->l_lp = NULL; 153 1.1 christos } 154 1.1 christos sp->wp->l_len = 0; 155 1.1 christos ep->l_cursor.lno = 1; /* XXX Any valid recno. */ 156 1.1 christos ep->l_cursor.cno = 0; 157 1.1 christos ep->l_high = ep->l_cur = 1; 158 1.1 christos return (0); 159 1.1 christos } 160 1.1 christos 161 1.1 christos /* 162 1.1 christos * log_cursor -- 163 1.1 christos * Log the current cursor position, starting an event. 164 1.1 christos * 165 1.1 christos * PUBLIC: int log_cursor __P((SCR *)); 166 1.1 christos */ 167 1.1 christos int 168 1.1 christos log_cursor(SCR *sp) 169 1.1 christos { 170 1.1 christos EXF *ep; 171 1.1 christos 172 1.1 christos ep = sp->ep; 173 1.1 christos if (F_ISSET(ep, F_NOLOG)) 174 1.1 christos return (0); 175 1.1 christos 176 1.1 christos /* 177 1.1 christos * If any changes were made since the last cursor init, 178 1.1 christos * put out the ending cursor record. 179 1.1 christos */ 180 1.1 christos if (ep->l_cursor.lno == OOBLNO) { 181 1.1 christos if (ep->l_win && ep->l_win != sp->wp) 182 1.1 christos return 0; 183 1.1 christos ep->l_cursor.lno = sp->lno; 184 1.1 christos ep->l_cursor.cno = sp->cno; 185 1.1 christos ep->l_win = NULL; 186 1.1 christos return (log_cursor1(sp, LOG_CURSOR_END)); 187 1.1 christos } 188 1.1 christos ep->l_cursor.lno = sp->lno; 189 1.1 christos ep->l_cursor.cno = sp->cno; 190 1.1 christos return (0); 191 1.1 christos } 192 1.1 christos 193 1.1 christos /* 194 1.1 christos * log_cursor1 -- 195 1.1 christos * Actually push a cursor record out. 196 1.1 christos */ 197 1.1 christos static int 198 1.1 christos log_cursor1(SCR *sp, int type) 199 1.1 christos { 200 1.1 christos DBT data, key; 201 1.1 christos EXF *ep; 202 1.1 christos 203 1.1 christos ep = sp->ep; 204 1.1 christos 205 1.1 christos /* 206 1.1 christos if (type == LOG_CURSOR_INIT && 207 1.1 christos LOCK_TRY(sp->wp, ep)) 208 1.1 christos return 1; 209 1.1 christos */ 210 1.1 christos 211 1.1 christos BINC_RETC(sp, sp->wp->l_lp, sp->wp->l_len, sizeof(u_char) + sizeof(MARK)); 212 1.1 christos sp->wp->l_lp[0] = type; 213 1.1 christos memmove(sp->wp->l_lp + sizeof(u_char), &ep->l_cursor, sizeof(MARK)); 214 1.1 christos 215 1.1 christos memset(&key, 0, sizeof(key)); 216 1.1 christos key.data = &ep->l_cur; 217 1.1 christos key.size = sizeof(db_recno_t); 218 1.1 christos memset(&data, 0, sizeof(data)); 219 1.1 christos data.data = sp->wp->l_lp; 220 1.1 christos data.size = sizeof(u_char) + sizeof(MARK); 221 1.1 christos if (ep->log->put(ep->log, NULL, &key, &data, 0) == -1) 222 1.1 christos LOG_ERR; 223 1.1 christos 224 1.1 christos #if defined(DEBUG) && 0 225 1.1 christos vtrace(sp, "%lu: %s: %u/%u\n", ep->l_cur, 226 1.1 christos type == LOG_CURSOR_INIT ? "log_cursor_init" : "log_cursor_end", 227 1.1 christos sp->lno, sp->cno); 228 1.1 christos #endif 229 1.1 christos /* Reset high water mark. */ 230 1.1 christos ep->l_high = ++ep->l_cur; 231 1.1 christos 232 1.1 christos /* 233 1.1 christos if (type == LOG_CURSOR_END) 234 1.1 christos LOCK_UNLOCK(sp->wp, ep); 235 1.1 christos */ 236 1.1 christos return (0); 237 1.1 christos } 238 1.1 christos 239 1.1 christos /* 240 1.1 christos * log_line -- 241 1.1 christos * Log a line change. 242 1.1 christos * 243 1.1 christos * PUBLIC: int log_line __P((SCR *, db_recno_t, u_int)); 244 1.1 christos */ 245 1.1 christos int 246 1.1 christos log_line(SCR *sp, db_recno_t lno, u_int action) 247 1.1 christos { 248 1.1 christos DBT data, key; 249 1.1 christos EXF *ep; 250 1.1 christos size_t len; 251 1.1 christos CHAR_T *lp; 252 1.1 christos db_recno_t lcur; 253 1.1 christos 254 1.1 christos ep = sp->ep; 255 1.1 christos if (F_ISSET(ep, F_NOLOG)) 256 1.1 christos return (0); 257 1.1 christos 258 1.1 christos /* 259 1.1 christos * XXX 260 1.1 christos * 261 1.1 christos * Kluge for vi. Clear the EXF undo flag so that the 262 1.1 christos * next 'u' command does a roll-back, regardless. 263 1.1 christos */ 264 1.1 christos F_CLR(ep, F_UNDO); 265 1.1 christos 266 1.1 christos /* Put out one initial cursor record per set of changes. */ 267 1.1 christos if (ep->l_cursor.lno != OOBLNO) { 268 1.1 christos if (log_cursor1(sp, LOG_CURSOR_INIT)) 269 1.1 christos return (1); 270 1.1 christos ep->l_cursor.lno = OOBLNO; 271 1.1 christos ep->l_win = sp->wp; 272 1.1 christos } /*else if (ep->l_win != sp->wp) { 273 1.1 christos printf("log_line own: %p, this: %p\n", ep->l_win, sp->wp); 274 1.1 christos return 1; 275 1.1 christos }*/ 276 1.1 christos 277 1.1 christos switch (action) { 278 1.1 christos /* newly added for DB4 logging */ 279 1.1 christos case LOG_LINE_APPEND_B: 280 1.1 christos case LOG_LINE_DELETE_F: 281 1.1 christos return 0; 282 1.1 christos } 283 1.1 christos 284 1.1 christos /* 285 1.1 christos * Put out the changes. If it's a LOG_LINE_RESET_B call, it's a 286 1.1 christos * special case, avoid the caches. Also, if it fails and it's 287 1.1 christos * line 1, it just means that the user started with an empty file, 288 1.1 christos * so fake an empty length line. 289 1.1 christos */ 290 1.1 christos if (action == LOG_LINE_RESET_B) { 291 1.1 christos if (db_get(sp, lno, DBG_NOCACHE, &lp, &len)) { 292 1.1 christos static CHAR_T nul = 0; 293 1.1 christos if (lno != 1) { 294 1.1 christos db_err(sp, lno); 295 1.1 christos return (1); 296 1.1 christos } 297 1.1 christos len = 0; 298 1.1 christos lp = &nul; 299 1.1 christos } 300 1.1 christos } else 301 1.1 christos if (db_get(sp, lno, DBG_FATAL, &lp, &len)) 302 1.1 christos return (1); 303 1.1 christos BINC_RETC(sp, 304 1.1 christos sp->wp->l_lp, sp->wp->l_len, 305 1.1 christos len * sizeof(CHAR_T) + CHAR_T_OFFSET); 306 1.1 christos sp->wp->l_lp[0] = action; 307 1.1 christos memmove(sp->wp->l_lp + sizeof(u_char), &lno, sizeof(db_recno_t)); 308 1.1 christos MEMMOVEW(sp->wp->l_lp + CHAR_T_OFFSET, lp, len); 309 1.1 christos 310 1.1 christos lcur = ep->l_cur; 311 1.1 christos memset(&key, 0, sizeof(key)); 312 1.1 christos key.data = &lcur; 313 1.1 christos key.size = sizeof(db_recno_t); 314 1.1 christos memset(&data, 0, sizeof(data)); 315 1.1 christos data.data = sp->wp->l_lp; 316 1.1 christos data.size = len * sizeof(CHAR_T) + CHAR_T_OFFSET; 317 1.1 christos if (ep->log->put(ep->log, NULL, &key, &data, 0) == -1) 318 1.1 christos LOG_ERR; 319 1.1 christos 320 1.1 christos #if defined(DEBUG) && 0 321 1.1 christos switch (action) { 322 1.1 christos case LOG_LINE_APPEND_F: 323 1.1 christos vtrace(sp, "%u: log_line: append_f: %lu {%u}\n", 324 1.1 christos ep->l_cur, lno, len); 325 1.1 christos break; 326 1.1 christos case LOG_LINE_APPEND_B: 327 1.1 christos vtrace(sp, "%u: log_line: append_b: %lu {%u}\n", 328 1.1 christos ep->l_cur, lno, len); 329 1.1 christos break; 330 1.1 christos case LOG_LINE_DELETE_F: 331 1.1 christos vtrace(sp, "%lu: log_line: delete_f: %lu {%u}\n", 332 1.1 christos ep->l_cur, lno, len); 333 1.1 christos break; 334 1.1 christos case LOG_LINE_DELETE_B: 335 1.1 christos vtrace(sp, "%lu: log_line: delete_b: %lu {%u}\n", 336 1.1 christos ep->l_cur, lno, len); 337 1.1 christos break; 338 1.1 christos case LOG_LINE_RESET_F: 339 1.1 christos vtrace(sp, "%lu: log_line: reset_f: %lu {%u}\n", 340 1.1 christos ep->l_cur, lno, len); 341 1.1 christos break; 342 1.1 christos case LOG_LINE_RESET_B: 343 1.1 christos vtrace(sp, "%lu: log_line: reset_b: %lu {%u}\n", 344 1.1 christos ep->l_cur, lno, len); 345 1.1 christos break; 346 1.1 christos } 347 1.1 christos #endif 348 1.1 christos /* Reset high water mark. */ 349 1.1 christos ep->l_high = ++ep->l_cur; 350 1.1 christos 351 1.1 christos return (0); 352 1.1 christos } 353 1.1 christos 354 1.1 christos /* 355 1.1 christos * log_mark -- 356 1.1 christos * Log a mark position. For the log to work, we assume that there 357 1.1 christos * aren't any operations that just put out a log record -- this 358 1.1 christos * would mean that undo operations would only reset marks, and not 359 1.1 christos * cause any other change. 360 1.1 christos * 361 1.1 christos * PUBLIC: int log_mark __P((SCR *, LMARK *)); 362 1.1 christos */ 363 1.1 christos int 364 1.1 christos log_mark(SCR *sp, LMARK *lmp) 365 1.1 christos { 366 1.1 christos DBT data, key; 367 1.1 christos EXF *ep; 368 1.1 christos 369 1.1 christos ep = sp->ep; 370 1.1 christos if (F_ISSET(ep, F_NOLOG)) 371 1.1 christos return (0); 372 1.1 christos 373 1.1 christos /* Put out one initial cursor record per set of changes. */ 374 1.1 christos if (ep->l_cursor.lno != OOBLNO) { 375 1.1 christos if (log_cursor1(sp, LOG_CURSOR_INIT)) 376 1.1 christos return (1); 377 1.1 christos ep->l_cursor.lno = OOBLNO; 378 1.1 christos ep->l_win = sp->wp; 379 1.1 christos } 380 1.1 christos 381 1.1 christos BINC_RETC(sp, sp->wp->l_lp, 382 1.1 christos sp->wp->l_len, sizeof(u_char) + sizeof(LMARK)); 383 1.1 christos sp->wp->l_lp[0] = LOG_MARK; 384 1.1 christos memmove(sp->wp->l_lp + sizeof(u_char), lmp, sizeof(LMARK)); 385 1.1 christos 386 1.1 christos memset(&key, 0, sizeof(key)); 387 1.1 christos key.data = &ep->l_cur; 388 1.1 christos key.size = sizeof(db_recno_t); 389 1.1 christos memset(&data, 0, sizeof(data)); 390 1.1 christos data.data = sp->wp->l_lp; 391 1.1 christos data.size = sizeof(u_char) + sizeof(LMARK); 392 1.1 christos if (ep->log->put(ep->log, NULL, &key, &data, 0) == -1) 393 1.1 christos LOG_ERR; 394 1.1 christos 395 1.1 christos #if defined(DEBUG) && 0 396 1.1 christos vtrace(sp, "%lu: mark %c: %lu/%u\n", 397 1.1 christos ep->l_cur, lmp->name, lmp->lno, lmp->cno); 398 1.1 christos #endif 399 1.1 christos /* Reset high water mark. */ 400 1.1 christos ep->l_high = ++ep->l_cur; 401 1.1 christos return (0); 402 1.1 christos } 403 1.1 christos 404 1.1 christos /* 405 1.1 christos * vi_log_get -- 406 1.1 christos * Get a line from the log in log buffer. 407 1.1 christos */ 408 1.1 christos static int 409 1.1 christos vi_log_get(SCR *sp, db_recno_t *lnop, size_t *size) 410 1.1 christos { 411 1.1 christos DBT key, data; 412 1.1 christos size_t nlen; 413 1.1 christos EXF *ep; 414 1.1 christos 415 1.1 christos ep = sp->ep; 416 1.1 christos 417 1.1 christos nlen = 1024; 418 1.1 christos retry: 419 1.1 christos BINC_RETC(sp, sp->wp->l_lp, sp->wp->l_len, nlen); 420 1.1 christos 421 1.1 christos memset(&key, 0, sizeof(key)); 422 1.1 christos key.data = lnop; /* Initialize db request. */ 423 1.1 christos key.size = sizeof(db_recno_t); 424 1.1 christos memset(&data, 0, sizeof(data)); 425 1.1 christos data.data = sp->wp->l_lp; 426 1.1 christos data.ulen = sp->wp->l_len; 427 1.1 christos data.flags = DB_DBT_USERMEM; 428 1.1 christos switch (ep->log->get(ep->log, NULL, &key, &data, 0)) { 429 1.1 christos case ENOMEM: 430 1.1 christos nlen = data.size; 431 1.1 christos goto retry; 432 1.1 christos case 0: 433 1.1 christos *size = data.size; 434 1.1 christos return 0; 435 1.1 christos default: 436 1.1 christos return 1; 437 1.1 christos } 438 1.1 christos } 439 1.1 christos 440 1.1 christos /* 441 1.1 christos * Log_backward -- 442 1.1 christos * Roll the log backward one operation. 443 1.1 christos * 444 1.1 christos * PUBLIC: int log_backward __P((SCR *, MARK *)); 445 1.1 christos */ 446 1.1 christos int 447 1.1 christos log_backward(SCR *sp, MARK *rp) 448 1.1 christos { 449 1.1 christos EXF *ep; 450 1.1 christos LMARK lm; 451 1.1 christos MARK m; 452 1.1 christos db_recno_t lno; 453 1.1 christos int didop; 454 1.1 christos u_char *p; 455 1.1 christos size_t size; 456 1.1 christos 457 1.1 christos ep = sp->ep; 458 1.1 christos if (F_ISSET(ep, F_NOLOG)) { 459 1.1 christos msgq(sp, M_ERR, 460 1.1 christos "010|Logging not being performed, undo not possible"); 461 1.1 christos return (1); 462 1.1 christos } 463 1.1 christos 464 1.1 christos if (ep->l_cur == 1) { 465 1.1 christos msgq(sp, M_BERR, "011|No changes to undo"); 466 1.1 christos return (1); 467 1.1 christos } 468 1.1 christos 469 1.1 christos if (ep->l_win && ep->l_win != sp->wp) { 470 1.1 christos ex_emsg(sp, NULL, EXM_LOCKED); 471 1.1 christos return 1; 472 1.1 christos } 473 1.1 christos ep->l_win = sp->wp; 474 1.1 christos 475 1.1 christos 476 1.1 christos F_SET(ep, F_NOLOG); /* Turn off logging. */ 477 1.1 christos 478 1.1 christos for (didop = 0;;) { 479 1.1 christos --ep->l_cur; 480 1.1 christos if (vi_log_get(sp, &ep->l_cur, &size)) 481 1.1 christos LOG_ERR; 482 1.1 christos #if defined(DEBUG) && 0 483 1.1 christos log_trace(sp, "log_backward", ep->l_cur, data.data); 484 1.1 christos #endif 485 1.1 christos switch (*(p = (u_char *)sp->wp->l_lp)) { 486 1.1 christos case LOG_CURSOR_INIT: 487 1.1 christos if (didop) { 488 1.1 christos memmove(rp, p + sizeof(u_char), sizeof(MARK)); 489 1.1 christos F_CLR(ep, F_NOLOG); 490 1.1 christos ep->l_win = NULL; 491 1.1 christos return (0); 492 1.1 christos } 493 1.1 christos break; 494 1.1 christos case LOG_CURSOR_END: 495 1.1 christos break; 496 1.1 christos case LOG_LINE_APPEND_F: 497 1.1 christos didop = 1; 498 1.1 christos memmove(&lno, p + sizeof(u_char), sizeof(db_recno_t)); 499 1.1 christos if (db_delete(sp, lno)) 500 1.1 christos goto err; 501 1.1 christos ++sp->rptlines[L_DELETED]; 502 1.1 christos break; 503 1.1 christos case LOG_LINE_DELETE_B: 504 1.1 christos didop = 1; 505 1.1 christos memmove(&lno, p + sizeof(u_char), sizeof(db_recno_t)); 506 1.1 christos if (db_insert(sp, lno, 507 1.1 christos (CHAR_T *)(p + CHAR_T_OFFSET), 508 1.1 christos (size - CHAR_T_OFFSET) / sizeof(CHAR_T))) 509 1.1 christos goto err; 510 1.1 christos ++sp->rptlines[L_ADDED]; 511 1.1 christos break; 512 1.1 christos case LOG_LINE_RESET_F: 513 1.1 christos break; 514 1.1 christos case LOG_LINE_RESET_B: 515 1.1 christos didop = 1; 516 1.1 christos memmove(&lno, p + sizeof(u_char), sizeof(db_recno_t)); 517 1.1 christos if (db_set(sp, lno, 518 1.1 christos (CHAR_T *)(p + CHAR_T_OFFSET), 519 1.1 christos (size - CHAR_T_OFFSET) / sizeof(CHAR_T))) 520 1.1 christos goto err; 521 1.1 christos if (sp->rptlchange != lno) { 522 1.1 christos sp->rptlchange = lno; 523 1.1 christos ++sp->rptlines[L_CHANGED]; 524 1.1 christos } 525 1.1 christos break; 526 1.1 christos case LOG_MARK: 527 1.1 christos didop = 1; 528 1.1 christos memmove(&lm, p + sizeof(u_char), sizeof(LMARK)); 529 1.1 christos m.lno = lm.lno; 530 1.1 christos m.cno = lm.cno; 531 1.1 christos if (mark_set(sp, lm.name, &m, 0)) 532 1.1 christos goto err; 533 1.1 christos break; 534 1.1 christos default: 535 1.1 christos abort(); 536 1.1 christos } 537 1.1 christos } 538 1.1 christos 539 1.1 christos err: F_CLR(ep, F_NOLOG); 540 1.1 christos ep->l_win = NULL; 541 1.1 christos return (1); 542 1.1 christos } 543 1.1 christos 544 1.1 christos /* 545 1.1 christos * Log_setline -- 546 1.1 christos * Reset the line to its original appearance. 547 1.1 christos * 548 1.1 christos * XXX 549 1.1 christos * There's a bug in this code due to our not logging cursor movements 550 1.1 christos * unless a change was made. If you do a change, move off the line, 551 1.1 christos * then move back on and do a 'U', the line will be restored to the way 552 1.1 christos * it was before the original change. 553 1.1 christos * 554 1.1 christos * PUBLIC: int log_setline __P((SCR *)); 555 1.1 christos */ 556 1.1 christos int 557 1.1 christos log_setline(SCR *sp) 558 1.1 christos { 559 1.1 christos EXF *ep; 560 1.1 christos LMARK lm; 561 1.1 christos MARK m; 562 1.1 christos db_recno_t lno; 563 1.1 christos u_char *p; 564 1.1 christos size_t size; 565 1.1 christos 566 1.1 christos ep = sp->ep; 567 1.1 christos if (F_ISSET(ep, F_NOLOG)) { 568 1.1 christos msgq(sp, M_ERR, 569 1.1 christos "012|Logging not being performed, undo not possible"); 570 1.1 christos return (1); 571 1.1 christos } 572 1.1 christos 573 1.1 christos if (ep->l_cur == 1) 574 1.1 christos return (1); 575 1.1 christos 576 1.1 christos if (ep->l_win && ep->l_win != sp->wp) { 577 1.1 christos ex_emsg(sp, NULL, EXM_LOCKED); 578 1.1 christos return 1; 579 1.1 christos } 580 1.1 christos ep->l_win = sp->wp; 581 1.1 christos 582 1.1 christos F_SET(ep, F_NOLOG); /* Turn off logging. */ 583 1.1 christos 584 1.1 christos for (;;) { 585 1.1 christos --ep->l_cur; 586 1.1 christos if (vi_log_get(sp, &ep->l_cur, &size)) 587 1.1 christos LOG_ERR; 588 1.1 christos #if defined(DEBUG) && 0 589 1.1 christos log_trace(sp, "log_setline", ep->l_cur, data.data); 590 1.1 christos #endif 591 1.1 christos switch (*(p = (u_char *)sp->wp->l_lp)) { 592 1.1 christos case LOG_CURSOR_INIT: 593 1.1 christos memmove(&m, p + sizeof(u_char), sizeof(MARK)); 594 1.1 christos if (m.lno != sp->lno || ep->l_cur == 1) { 595 1.1 christos F_CLR(ep, F_NOLOG); 596 1.1 christos ep->l_win = NULL; 597 1.1 christos return (0); 598 1.1 christos } 599 1.1 christos break; 600 1.1 christos case LOG_CURSOR_END: 601 1.1 christos memmove(&m, p + sizeof(u_char), sizeof(MARK)); 602 1.1 christos if (m.lno != sp->lno) { 603 1.1 christos ++ep->l_cur; 604 1.1 christos F_CLR(ep, F_NOLOG); 605 1.1 christos ep->l_win = NULL; 606 1.1 christos return (0); 607 1.1 christos } 608 1.1 christos break; 609 1.1 christos case LOG_LINE_APPEND_F: 610 1.1 christos case LOG_LINE_DELETE_B: 611 1.1 christos case LOG_LINE_RESET_F: 612 1.1 christos break; 613 1.1 christos case LOG_LINE_RESET_B: 614 1.1 christos memmove(&lno, p + sizeof(u_char), sizeof(db_recno_t)); 615 1.1 christos if (lno == sp->lno && 616 1.1 christos db_set(sp, lno, (CHAR_T *)(p + CHAR_T_OFFSET), 617 1.1 christos (size - CHAR_T_OFFSET) / sizeof(CHAR_T))) 618 1.1 christos goto err; 619 1.1 christos if (sp->rptlchange != lno) { 620 1.1 christos sp->rptlchange = lno; 621 1.1 christos ++sp->rptlines[L_CHANGED]; 622 1.1 christos } 623 1.6 rin break; 624 1.1 christos case LOG_MARK: 625 1.1 christos memmove(&lm, p + sizeof(u_char), sizeof(LMARK)); 626 1.1 christos m.lno = lm.lno; 627 1.1 christos m.cno = lm.cno; 628 1.1 christos if (mark_set(sp, lm.name, &m, 0)) 629 1.1 christos goto err; 630 1.1 christos break; 631 1.1 christos default: 632 1.1 christos abort(); 633 1.1 christos } 634 1.1 christos } 635 1.1 christos 636 1.1 christos err: F_CLR(ep, F_NOLOG); 637 1.1 christos ep->l_win = NULL; 638 1.1 christos return (1); 639 1.1 christos } 640 1.1 christos 641 1.1 christos /* 642 1.1 christos * Log_forward -- 643 1.1 christos * Roll the log forward one operation. 644 1.1 christos * 645 1.1 christos * PUBLIC: int log_forward __P((SCR *, MARK *)); 646 1.1 christos */ 647 1.1 christos int 648 1.1 christos log_forward(SCR *sp, MARK *rp) 649 1.1 christos { 650 1.1 christos EXF *ep; 651 1.1 christos LMARK lm; 652 1.1 christos MARK m; 653 1.1 christos db_recno_t lno; 654 1.1 christos int didop; 655 1.1 christos u_char *p; 656 1.1 christos size_t size; 657 1.1 christos 658 1.1 christos ep = sp->ep; 659 1.1 christos if (F_ISSET(ep, F_NOLOG)) { 660 1.1 christos msgq(sp, M_ERR, 661 1.1 christos "013|Logging not being performed, roll-forward not possible"); 662 1.1 christos return (1); 663 1.1 christos } 664 1.1 christos 665 1.1 christos if (ep->l_cur == ep->l_high) { 666 1.1 christos msgq(sp, M_BERR, "014|No changes to re-do"); 667 1.1 christos return (1); 668 1.1 christos } 669 1.1 christos 670 1.1 christos if (ep->l_win && ep->l_win != sp->wp) { 671 1.1 christos ex_emsg(sp, NULL, EXM_LOCKED); 672 1.1 christos return 1; 673 1.1 christos } 674 1.1 christos ep->l_win = sp->wp; 675 1.1 christos 676 1.1 christos F_SET(ep, F_NOLOG); /* Turn off logging. */ 677 1.1 christos 678 1.1 christos for (didop = 0;;) { 679 1.1 christos ++ep->l_cur; 680 1.1 christos if (vi_log_get(sp, &ep->l_cur, &size)) 681 1.1 christos LOG_ERR; 682 1.1 christos #if defined(DEBUG) && 0 683 1.1 christos log_trace(sp, "log_forward", ep->l_cur, data.data); 684 1.1 christos #endif 685 1.1 christos switch (*(p = (u_char *)sp->wp->l_lp)) { 686 1.1 christos case LOG_CURSOR_END: 687 1.1 christos if (didop) { 688 1.1 christos ++ep->l_cur; 689 1.1 christos memmove(rp, p + sizeof(u_char), sizeof(MARK)); 690 1.1 christos F_CLR(ep, F_NOLOG); 691 1.1 christos ep->l_win = NULL; 692 1.1 christos return (0); 693 1.1 christos } 694 1.1 christos break; 695 1.1 christos case LOG_CURSOR_INIT: 696 1.1 christos break; 697 1.1 christos case LOG_LINE_APPEND_F: 698 1.1 christos didop = 1; 699 1.1 christos memmove(&lno, p + sizeof(u_char), sizeof(db_recno_t)); 700 1.1 christos if (db_insert(sp, lno, 701 1.1 christos (CHAR_T *)(p + CHAR_T_OFFSET), 702 1.1 christos (size - CHAR_T_OFFSET) / sizeof(CHAR_T))) 703 1.1 christos goto err; 704 1.1 christos ++sp->rptlines[L_ADDED]; 705 1.1 christos break; 706 1.1 christos case LOG_LINE_DELETE_B: 707 1.1 christos didop = 1; 708 1.1 christos memmove(&lno, p + sizeof(u_char), sizeof(db_recno_t)); 709 1.1 christos if (db_delete(sp, lno)) 710 1.1 christos goto err; 711 1.1 christos ++sp->rptlines[L_DELETED]; 712 1.1 christos break; 713 1.1 christos case LOG_LINE_RESET_B: 714 1.1 christos break; 715 1.1 christos case LOG_LINE_RESET_F: 716 1.1 christos didop = 1; 717 1.1 christos memmove(&lno, p + sizeof(u_char), sizeof(db_recno_t)); 718 1.1 christos if (db_set(sp, lno, 719 1.1 christos (CHAR_T *)(p + CHAR_T_OFFSET), 720 1.1 christos (size - CHAR_T_OFFSET) / sizeof(CHAR_T))) 721 1.1 christos goto err; 722 1.1 christos if (sp->rptlchange != lno) { 723 1.1 christos sp->rptlchange = lno; 724 1.1 christos ++sp->rptlines[L_CHANGED]; 725 1.1 christos } 726 1.1 christos break; 727 1.1 christos case LOG_MARK: 728 1.1 christos didop = 1; 729 1.1 christos memmove(&lm, p + sizeof(u_char), sizeof(LMARK)); 730 1.1 christos m.lno = lm.lno; 731 1.1 christos m.cno = lm.cno; 732 1.1 christos if (mark_set(sp, lm.name, &m, 0)) 733 1.1 christos goto err; 734 1.1 christos break; 735 1.1 christos default: 736 1.1 christos abort(); 737 1.1 christos } 738 1.1 christos } 739 1.1 christos 740 1.1 christos err: F_CLR(ep, F_NOLOG); 741 1.1 christos ep->l_win = NULL; 742 1.1 christos return (1); 743 1.1 christos } 744 1.1 christos 745 1.1 christos /* 746 1.1 christos * log_err -- 747 1.1 christos * Try and restart the log on failure, i.e. if we run out of memory. 748 1.1 christos */ 749 1.1 christos static void 750 1.2 christos log_err(SCR *sp, const char *file, int line) 751 1.1 christos { 752 1.1 christos EXF *ep; 753 1.1 christos 754 1.1 christos msgq(sp, M_SYSERR, "015|%s/%d: log put error", tail(file), line); 755 1.1 christos ep = sp->ep; 756 1.1 christos (void)ep->log->close(ep->log, DB_NOSYNC); 757 1.1 christos if (!log_init(sp, ep)) 758 1.1 christos msgq(sp, M_ERR, "267|Log restarted"); 759 1.1 christos } 760 1.1 christos 761 1.1 christos #if defined(DEBUG) && 0 762 1.1 christos static void 763 1.2 christos log_trace(SCR *sp, const char *msg, db_recno_t rno, u_char *p) 764 1.1 christos { 765 1.1 christos LMARK lm; 766 1.1 christos MARK m; 767 1.1 christos db_recno_t lno; 768 1.1 christos 769 1.1 christos switch (*p) { 770 1.1 christos case LOG_CURSOR_INIT: 771 1.1 christos memmove(&m, p + sizeof(u_char), sizeof(MARK)); 772 1.1 christos vtrace(sp, "%lu: %s: C_INIT: %u/%u\n", rno, msg, m.lno, m.cno); 773 1.1 christos break; 774 1.1 christos case LOG_CURSOR_END: 775 1.1 christos memmove(&m, p + sizeof(u_char), sizeof(MARK)); 776 1.1 christos vtrace(sp, "%lu: %s: C_END: %u/%u\n", rno, msg, m.lno, m.cno); 777 1.1 christos break; 778 1.1 christos case LOG_LINE_APPEND_F: 779 1.1 christos memmove(&lno, p + sizeof(u_char), sizeof(db_recno_t)); 780 1.1 christos vtrace(sp, "%lu: %s: APPEND_F: %lu\n", rno, msg, lno); 781 1.1 christos break; 782 1.1 christos case LOG_LINE_APPEND_B: 783 1.1 christos memmove(&lno, p + sizeof(u_char), sizeof(db_recno_t)); 784 1.1 christos vtrace(sp, "%lu: %s: APPEND_B: %lu\n", rno, msg, lno); 785 1.1 christos break; 786 1.1 christos case LOG_LINE_DELETE_F: 787 1.1 christos memmove(&lno, p + sizeof(u_char), sizeof(db_recno_t)); 788 1.1 christos vtrace(sp, "%lu: %s: DELETE_F: %lu\n", rno, msg, lno); 789 1.1 christos break; 790 1.1 christos case LOG_LINE_DELETE_B: 791 1.1 christos memmove(&lno, p + sizeof(u_char), sizeof(db_recno_t)); 792 1.1 christos vtrace(sp, "%lu: %s: DELETE_B: %lu\n", rno, msg, lno); 793 1.1 christos break; 794 1.1 christos case LOG_LINE_RESET_F: 795 1.1 christos memmove(&lno, p + sizeof(u_char), sizeof(db_recno_t)); 796 1.1 christos vtrace(sp, "%lu: %s: RESET_F: %lu\n", rno, msg, lno); 797 1.1 christos break; 798 1.1 christos case LOG_LINE_RESET_B: 799 1.1 christos memmove(&lno, p + sizeof(u_char), sizeof(db_recno_t)); 800 1.1 christos vtrace(sp, "%lu: %s: RESET_B: %lu\n", rno, msg, lno); 801 1.1 christos break; 802 1.1 christos case LOG_MARK: 803 1.1 christos memmove(&lm, p + sizeof(u_char), sizeof(LMARK)); 804 1.1 christos vtrace(sp, 805 1.1 christos "%lu: %s: MARK: %u/%u\n", rno, msg, lm.lno, lm.cno); 806 1.1 christos break; 807 1.1 christos default: 808 1.1 christos abort(); 809 1.1 christos } 810 1.1 christos } 811 1.1 christos #endif 812