1 /* 2 * Copyright (C) International Business Machines Corp., 2000-2004 3 * 4 * This program is free software; you can redistribute it and/or modify 5 * it under the terms of the GNU General Public License as published by 6 * the Free Software Foundation; either version 2 of the License, or 7 * (at your option) any later version. 8 * 9 * This program is distributed in the hope that it will be useful, 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of 11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See 12 * the GNU General Public License for more details. 13 * 14 * You should have received a copy of the GNU General Public License 15 * along with this program; if not, write to the Free Software 16 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA 17 */ 18 #ifndef _H_JFS_TXNMGR 19 #define _H_JFS_TXNMGR 20 21 #include "jfs_logmgr.h" 22 23 /* 24 * Hide implementation of TxBlock and TxLock 25 */ 26 #define tid_to_tblock(tid) (&TxBlock[tid]) 27 28 #define lid_to_tlock(lid) (&TxLock[lid]) 29 30 /* 31 * transaction block 32 */ 33 struct tblock { 34 /* 35 * tblock and jbuf_t common area: struct logsyncblk 36 * 37 * the following 5 fields are the same as struct logsyncblk 38 * which is common to tblock and jbuf to form logsynclist 39 */ 40 u16 xflag; /* tx commit type */ 41 u16 flag; /* tx commit state */ 42 lid_t dummy; /* Must keep structures common */ 43 s32 lsn; /* recovery lsn */ 44 struct list_head synclist; /* logsynclist link */ 45 46 /* lock management */ 47 struct super_block *sb; /* super block */ 48 lid_t next; /* index of first tlock of tid */ 49 lid_t last; /* index of last tlock of tid */ 50 wait_queue_head_t waitor; /* tids waiting on this tid */ 51 52 /* log management */ 53 u32 logtid; /* log transaction id */ 54 55 /* commit management */ 56 struct list_head cqueue; /* commit queue list */ 57 s32 clsn; /* commit lsn */ 58 struct lbuf *bp; 59 s32 pn; /* commit record log page number */ 60 s32 eor; /* commit record eor */ 61 wait_queue_head_t gcwait; /* group commit event list: 62 * ready transactions wait on this 63 * event for group commit completion. 64 */ 65 union { 66 struct inode *ip; /* inode being deleted */ 67 pxd_t ixpxd; /* pxd of inode extent for created inode */ 68 } u; 69 u32 ino; /* inode number being created */ 70 }; 71 72 extern struct tblock *TxBlock; /* transaction block table */ 73 74 /* commit flags: tblk->xflag */ 75 #define COMMIT_SYNC 0x0001 /* synchronous commit */ 76 #define COMMIT_FORCE 0x0002 /* force pageout at end of commit */ 77 #define COMMIT_FLUSH 0x0004 /* init flush at end of commit */ 78 #define COMMIT_MAP 0x00f0 79 #define COMMIT_PMAP 0x0010 /* update pmap */ 80 #define COMMIT_WMAP 0x0020 /* update wmap */ 81 #define COMMIT_PWMAP 0x0040 /* update pwmap */ 82 #define COMMIT_FREE 0x0f00 83 #define COMMIT_DELETE 0x0100 /* inode delete */ 84 #define COMMIT_TRUNCATE 0x0200 /* file truncation */ 85 #define COMMIT_CREATE 0x0400 /* inode create */ 86 #define COMMIT_LAZY 0x0800 /* lazy commit */ 87 #define COMMIT_PAGE 0x1000 /* Identifies element as metapage */ 88 #define COMMIT_INODE 0x2000 /* Identifies element as inode */ 89 90 /* group commit flags tblk->flag: see jfs_logmgr.h */ 91 92 /* 93 * transaction lock 94 */ 95 struct tlock { 96 lid_t next; /* 2: index next lockword on tid locklist 97 * next lockword on freelist 98 */ 99 tid_t tid; /* 2: transaction id holding lock */ 100 101 u16 flag; /* 2: lock control */ 102 u16 type; /* 2: log type */ 103 104 struct metapage *mp; /* 4/8: object page buffer locked */ 105 struct inode *ip; /* 4/8: object */ 106 /* (16) */ 107 108 s16 lock[24]; /* 48: overlay area */ 109 }; /* (64) */ 110 111 extern struct tlock *TxLock; /* transaction lock table */ 112 113 /* 114 * tlock flag 115 */ 116 /* txLock state */ 117 #define tlckPAGELOCK 0x8000 118 #define tlckINODELOCK 0x4000 119 #define tlckLINELOCK 0x2000 120 #define tlckINLINELOCK 0x1000 121 /* lmLog state */ 122 #define tlckLOG 0x0800 123 /* updateMap state */ 124 #define tlckUPDATEMAP 0x0080 125 #define tlckDIRECTORY 0x0040 126 /* freeLock state */ 127 #define tlckFREELOCK 0x0008 128 #define tlckWRITEPAGE 0x0004 129 #define tlckFREEPAGE 0x0002 130 131 /* 132 * tlock type 133 */ 134 #define tlckTYPE 0xfe00 135 #define tlckINODE 0x8000 136 #define tlckXTREE 0x4000 137 #define tlckDTREE 0x2000 138 #define tlckMAP 0x1000 139 #define tlckEA 0x0800 140 #define tlckACL 0x0400 141 #define tlckDATA 0x0200 142 #define tlckBTROOT 0x0100 143 144 #define tlckOPERATION 0x00ff 145 #define tlckGROW 0x0001 /* file grow */ 146 #define tlckREMOVE 0x0002 /* file delete */ 147 #define tlckTRUNCATE 0x0004 /* file truncate */ 148 #define tlckRELOCATE 0x0008 /* file/directory relocate */ 149 #define tlckENTRY 0x0001 /* directory insert/delete */ 150 #define tlckEXTEND 0x0002 /* directory extend in-line */ 151 #define tlckSPLIT 0x0010 /* splited page */ 152 #define tlckNEW 0x0020 /* new page from split */ 153 #define tlckFREE 0x0040 /* free page */ 154 #define tlckRELINK 0x0080 /* update sibling pointer */ 155 156 /* 157 * linelock for lmLog() 158 * 159 * note: linelock and its variations are overlaid 160 * at tlock.lock: watch for alignment; 161 */ 162 struct lv { 163 u8 offset; /* 1: */ 164 u8 length; /* 1: */ 165 }; /* (2) */ 166 167 #define TLOCKSHORT 20 168 #define TLOCKLONG 28 169 170 struct linelock { 171 lid_t next; /* 2: next linelock */ 172 173 s8 maxcnt; /* 1: */ 174 s8 index; /* 1: */ 175 176 u16 flag; /* 2: */ 177 u8 type; /* 1: */ 178 u8 l2linesize; /* 1: log2 of linesize */ 179 /* (8) */ 180 181 struct lv lv[20]; /* 40: */ 182 }; /* (48) */ 183 184 #define dt_lock linelock 185 186 struct xtlock { 187 lid_t next; /* 2: */ 188 189 s8 maxcnt; /* 1: */ 190 s8 index; /* 1: */ 191 192 u16 flag; /* 2: */ 193 u8 type; /* 1: */ 194 u8 l2linesize; /* 1: log2 of linesize */ 195 /* (8) */ 196 197 struct lv header; /* 2: */ 198 struct lv lwm; /* 2: low water mark */ 199 struct lv hwm; /* 2: high water mark */ 200 struct lv twm; /* 2: */ 201 /* (16) */ 202 203 s32 pxdlock[8]; /* 32: */ 204 }; /* (48) */ 205 206 207 /* 208 * maplock for txUpdateMap() 209 * 210 * note: maplock and its variations are overlaid 211 * at tlock.lock/linelock: watch for alignment; 212 * N.B. next field may be set by linelock, and should not 213 * be modified by maplock; 214 * N.B. index of the first pxdlock specifies index of next 215 * free maplock (i.e., number of maplock) in the tlock; 216 */ 217 struct maplock { 218 lid_t next; /* 2: */ 219 220 u8 maxcnt; /* 2: */ 221 u8 index; /* 2: next free maplock index */ 222 223 u16 flag; /* 2: */ 224 u8 type; /* 1: */ 225 u8 count; /* 1: number of pxd/xad */ 226 /* (8) */ 227 228 pxd_t pxd; /* 8: */ 229 }; /* (16): */ 230 231 /* maplock flag */ 232 #define mlckALLOC 0x00f0 233 #define mlckALLOCXADLIST 0x0080 234 #define mlckALLOCPXDLIST 0x0040 235 #define mlckALLOCXAD 0x0020 236 #define mlckALLOCPXD 0x0010 237 #define mlckFREE 0x000f 238 #define mlckFREEXADLIST 0x0008 239 #define mlckFREEPXDLIST 0x0004 240 #define mlckFREEXAD 0x0002 241 #define mlckFREEPXD 0x0001 242 243 #define pxd_lock maplock 244 245 struct xdlistlock { 246 lid_t next; /* 2: */ 247 248 u8 maxcnt; /* 2: */ 249 u8 index; /* 2: */ 250 251 u16 flag; /* 2: */ 252 u8 type; /* 1: */ 253 u8 count; /* 1: number of pxd/xad */ 254 /* (8) */ 255 256 /* 257 * We need xdlist to be 64 bits (8 bytes), regardless of 258 * whether void * is 32 or 64 bits 259 */ 260 union { 261 void *_xdlist; /* pxd/xad list */ 262 s64 pad; /* 8: Force 64-bit xdlist size */ 263 } union64; 264 }; /* (16): */ 265 266 #define xdlist union64._xdlist 267 268 /* 269 * commit 270 * 271 * parameter to the commit manager routines 272 */ 273 struct commit { 274 tid_t tid; /* tid = index of tblock */ 275 int flag; /* flags */ 276 struct jfs_log *log; /* log */ 277 struct super_block *sb; /* superblock */ 278 279 int nip; /* number of entries in iplist */ 280 struct inode **iplist; /* list of pointers to inodes */ 281 282 /* log record descriptor on 64-bit boundary */ 283 struct lrd lrd; /* : log record descriptor */ 284 }; 285 286 /* 287 * external declarations 288 */ 289 extern int jfs_tlocks_low; 290 291 extern int txInit(void); 292 extern void txExit(void); 293 extern struct tlock *txLock(tid_t, struct inode *, struct metapage *, int); 294 extern struct tlock *txMaplock(tid_t, struct inode *, int); 295 extern int txCommit(tid_t, int, struct inode **, int); 296 extern tid_t txBegin(struct super_block *, int); 297 extern void txBeginAnon(struct super_block *); 298 extern void txEnd(tid_t); 299 extern void txAbort(tid_t, int); 300 extern struct linelock *txLinelock(struct linelock *); 301 extern void txFreeMap(struct inode *, struct maplock *, struct tblock *, int); 302 extern void txEA(tid_t, struct inode *, dxd_t *, dxd_t *); 303 extern void txFreelock(struct inode *); 304 extern int lmLog(struct jfs_log *, struct tblock *, struct lrd *, 305 struct tlock *); 306 extern void txQuiesce(struct super_block *); 307 extern void txResume(struct super_block *); 308 extern void txLazyUnlock(struct tblock *); 309 extern int jfs_lazycommit(void *); 310 extern int jfs_sync(void *); 311 #endif /* _H_JFS_TXNMGR */ 312