1 /* 2 * Copyright (c) 2004,2005 The DragonFly Project. All rights reserved. 3 * 4 * This code is derived from software contributed to The DragonFly Project 5 * by Matthew Dillon <dillon@backplane.com> 6 * 7 * Redistribution and use in source and binary forms, with or without 8 * modification, are permitted provided that the following conditions 9 * are met: 10 * 11 * 1. Redistributions of source code must retain the above copyright 12 * notice, this list of conditions and the following disclaimer. 13 * 2. Redistributions in binary form must reproduce the above copyright 14 * notice, this list of conditions and the following disclaimer in 15 * the documentation and/or other materials provided with the 16 * distribution. 17 * 3. Neither the name of The DragonFly Project nor the names of its 18 * contributors may be used to endorse or promote products derived 19 * from this software without specific, prior written permission. 20 * 21 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 22 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 23 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS 24 * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE 25 * COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, 26 * INCIDENTAL, SPECIAL, EXEMPLARY OR CONSEQUENTIAL DAMAGES (INCLUDING, 27 * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 28 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED 29 * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, 30 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT 31 * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 32 * SUCH DAMAGE. 33 */ 34 35 #include <sys/types.h> 36 #include <sys/time.h> 37 #include <sys/journal.h> 38 #include <sys/stat.h> 39 #include <stdio.h> 40 #include <stdarg.h> 41 #include <stdlib.h> 42 #include <stddef.h> 43 #include <unistd.h> 44 #include <string.h> 45 #include <limits.h> 46 #include <time.h> 47 #include <fcntl.h> 48 #include <errno.h> 49 #include <ctype.h> 50 #include <assert.h> 51 #include "jattr.h" 52 53 struct jdata; 54 55 enum jdirection { JD_FORWARDS, JD_BACKWARDS, JD_SEQFIRST, JD_SEQLAST }; 56 57 struct jfile { 58 off_t jf_pos; /* current seek position */ 59 int jf_fd; /* reading/scanning */ 60 int jf_write_fd; /* appending */ 61 off_t jf_write_pos; /* append position */ 62 int jf_error; 63 int jf_open_flags; 64 char *jf_prefix; /* prefix: name */ 65 unsigned int jf_seq_beg; /* prefix: sequence space */ 66 unsigned int jf_seq_end; /* prefix: sequence space */ 67 unsigned int jf_seq; /* prefix: current sequence number */ 68 int64_t jf_last_transid;/* prefix: last recorded transid */ 69 }; 70 71 /* 72 * Output session (debug, record, output, etc) 73 */ 74 struct jsession { 75 struct jfile *ss_jfin; 76 struct jfile *ss_jfout; 77 enum jdirection ss_direction; 78 const char *ss_mirror_directory; 79 const char *ss_transid_file; 80 int ss_transid_fd; 81 int64_t ss_transid; 82 }; 83 84 #define JF_FULL_DUPLEX 0x0001 85 86 struct jdata { 87 int64_t jd_transid; /* transaction id from header */ 88 int jd_alloc; /* allocated bytes */ 89 int jd_size; /* data bytes */ 90 int jd_refs; /* ref count */ 91 unsigned int jd_seq; /* location data */ 92 off_t jd_pos; /* location data */ 93 char jd_data[4]; /* must be last field */ 94 }; 95 96 struct jstream { 97 struct jstream *js_next; /* linked list / same transaction */ 98 struct jsession *js_session; 99 char *js_alloc_buf; 100 int js_alloc_size; 101 102 /* 103 * Normalized fields strip all rawrecbeg, rawrecend, and deadspace except 104 * for the initial rawrecbeg header. 105 */ 106 char *js_normalized_base; 107 int js_normalized_size; 108 off_t js_normalized_off; 109 off_t js_normalized_total; 110 111 /* 112 * This is used by the first js record only to cache other records in the 113 * chain. 114 */ 115 struct jstream *js_cache; 116 struct jdata *js_jdata; 117 struct journal_rawrecbeg *js_head; 118 }; 119 120 struct jhash { 121 struct jhash *jh_hash; 122 struct jstream *jh_first; 123 struct jstream *jh_last; 124 struct jsession *jh_session; 125 int16_t jh_transid; 126 }; 127 128 #define JHASH_SIZE 1024 129 #define JHASH_MASK (JHASH_SIZE - 1) 130 131 #define JMODEF_DEBUG 0x00000001 132 #define JMODEF_MIRROR 0x00000002 133 #define JMODEF_UNUSED0004 0x00000004 134 #define JMODEF_RECORD 0x00000008 135 #define JMODEF_RECORD_TMP 0x00000010 136 #define JMODEF_INPUT_FULL 0x00000020 137 #define JMODEF_INPUT_PIPE 0x00000040 138 #define JMODEF_INPUT_PREFIX 0x00000080 139 #define JMODEF_OUTPUT 0x00000100 140 #define JMODEF_OUTPUT_FULL 0x00000200 141 #define JMODEF_MEMORY_TRACKING 0x00000400 142 #define JMODEF_LOOP_FOREVER 0x00000800 143 144 #define JMODEF_OUTPUT_TRANSID_GOOD 0x00010000 145 #define JMODEF_RECORD_TRANSID_GOOD 0x00020000 146 #define JMODEF_MIRROR_TRANSID_GOOD 0x00040000 147 #define JMODEF_TRANSID_GOOD_MASK (JMODEF_OUTPUT_TRANSID_GOOD|\ 148 JMODEF_RECORD_TRANSID_GOOD|\ 149 JMODEF_MIRROR_TRANSID_GOOD) 150 #define JMODEF_COMMAND_MASK (JMODEF_RECORD|JMODEF_MIRROR|JMODEF_DEBUG|\ 151 JMODEF_OUTPUT) 152 153 extern int jmodes; 154 extern int fsync_opt; 155 extern int verbose_opt; 156 extern off_t prefix_file_size; 157 extern off_t trans_count; 158 159 const char *type_to_name(int16_t rectype); 160 void stringout(FILE *fp, char c, int exact); 161 void jattr_reset(struct jattr *jattr); 162 int64_t buf_to_int64(const void *buf, int bytes); 163 char *dupdatastr(const void *buf, int bytes); 164 char *dupdatapath(const void *buf, int bytes); 165 void get_transid_from_file(const char *path, int64_t *transid, int flags); 166 167 void jsession_init(struct jsession *ss, struct jfile *jfin, 168 enum jdirection direction, 169 const char *transid_file, int64_t transid); 170 void jsession_update_transid(struct jsession *ss, int64_t transid); 171 int jsession_check(struct jsession *ss, struct jdata *jd); 172 void jsession_term(struct jsession *ss); 173 174 struct jfile *jopen_fd(int fd); 175 struct jfile *jopen_prefix(const char *prefix, int rw); 176 void jclose(struct jfile *jf); 177 struct jdata *jread(struct jfile *jf, struct jdata *jd, 178 enum jdirection direction); 179 struct jdata *jseek(struct jfile *jf, int64_t transid, 180 enum jdirection direction); 181 void jwrite(struct jfile *jf, struct jdata *jd); 182 struct jdata *jref(struct jdata *jd); 183 void jfree(struct jfile *jf, struct jdata *jd); 184 void jf_warn(struct jfile *jf, const char *ctl, ...) __printflike(2, 3); 185 186 struct jstream *jaddrecord(struct jsession *ss, struct jdata *jd); 187 void jscan_dispose(struct jstream *js); 188 189 void dump_debug(struct jsession *ss, struct jdata *jd); 190 void dump_mirror(struct jsession *ss, struct jdata *jd); 191 void dump_record(struct jsession *ss, struct jdata *jd); 192 void dump_output(struct jsession *ss, struct jdata *jd); 193 194 int jrecord_init(const char *record_prefix); 195 196 int jsreadany(struct jstream *js, off_t off, const void **bufp); 197 int jsreadp(struct jstream *js, off_t off, const void **bufp, int bytes); 198 int jsread(struct jstream *js, off_t off, void *buf, int bytes); 199 int jsreadcallback(struct jstream *js, ssize_t (*func)(int, const void *, size_t), int fd, off_t off, int bytes); 200 201