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 */ 33struct 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 72extern 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 */ 95struct 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 111extern 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 */ 162struct lv { 163 u8 offset; /* 1: */ 164 u8 length; /* 1: */ 165}; /* (2) */ 166 167#define TLOCKSHORT 20 168#define TLOCKLONG 28 169 170struct 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 186struct 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 */ 217struct 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 245struct 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 */ 273struct 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 */ 289extern int jfs_tlocks_low; 290 291extern int txInit(void); 292extern void txExit(void); 293extern struct tlock *txLock(tid_t, struct inode *, struct metapage *, int); 294extern struct tlock *txMaplock(tid_t, struct inode *, int); 295extern int txCommit(tid_t, int, struct inode **, int); 296extern tid_t txBegin(struct super_block *, int); 297extern void txBeginAnon(struct super_block *); 298extern void txEnd(tid_t); 299extern void txAbort(tid_t, int); 300extern struct linelock *txLinelock(struct linelock *); 301extern void txFreeMap(struct inode *, struct maplock *, struct tblock *, int); 302extern void txEA(tid_t, struct inode *, dxd_t *, dxd_t *); 303extern void txFreelock(struct inode *); 304extern int lmLog(struct jfs_log *, struct tblock *, struct lrd *, 305 struct tlock *); 306extern void txQuiesce(struct super_block *); 307extern void txResume(struct super_block *); 308extern void txLazyUnlock(struct tblock *); 309extern int jfs_lazycommit(void *); 310extern int jfs_sync(void *); 311#endif /* _H_JFS_TXNMGR */ 312