/* * Copyright (C) International Business Machines Corp., 2000-2004 * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See * the GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ #ifndef _H_JFS_TXNMGR #define _H_JFS_TXNMGR #include "jfs_logmgr.h" /* * Hide implementation of TxBlock and TxLock */ #define tid_to_tblock(tid) (&TxBlock[tid]) #define lid_to_tlock(lid) (&TxLock[lid]) /* * transaction block */ struct tblock { /* * tblock and jbuf_t common area: struct logsyncblk * * the following 5 fields are the same as struct logsyncblk * which is common to tblock and jbuf to form logsynclist */ u16 xflag; /* tx commit type */ u16 flag; /* tx commit state */ lid_t dummy; /* Must keep structures common */ s32 lsn; /* recovery lsn */ struct list_head synclist; /* logsynclist link */ /* lock management */ struct super_block *sb; /* super block */ lid_t next; /* index of first tlock of tid */ lid_t last; /* index of last tlock of tid */ wait_queue_head_t waitor; /* tids waiting on this tid */ /* log management */ u32 logtid; /* log transaction id */ /* commit management */ struct list_head cqueue; /* commit queue list */ s32 clsn; /* commit lsn */ struct lbuf *bp; s32 pn; /* commit record log page number */ s32 eor; /* commit record eor */ wait_queue_head_t gcwait; /* group commit event list: * ready transactions wait on this * event for group commit completion. */ union { struct inode *ip; /* inode being deleted */ pxd_t ixpxd; /* pxd of inode extent for created inode */ } u; u32 ino; /* inode number being created */ }; extern struct tblock *TxBlock; /* transaction block table */ /* commit flags: tblk->xflag */ #define COMMIT_SYNC 0x0001 /* synchronous commit */ #define COMMIT_FORCE 0x0002 /* force pageout at end of commit */ #define COMMIT_FLUSH 0x0004 /* init flush at end of commit */ #define COMMIT_MAP 0x00f0 #define COMMIT_PMAP 0x0010 /* update pmap */ #define COMMIT_WMAP 0x0020 /* update wmap */ #define COMMIT_PWMAP 0x0040 /* update pwmap */ #define COMMIT_FREE 0x0f00 #define COMMIT_DELETE 0x0100 /* inode delete */ #define COMMIT_TRUNCATE 0x0200 /* file truncation */ #define COMMIT_CREATE 0x0400 /* inode create */ #define COMMIT_LAZY 0x0800 /* lazy commit */ #define COMMIT_PAGE 0x1000 /* Identifies element as metapage */ #define COMMIT_INODE 0x2000 /* Identifies element as inode */ /* group commit flags tblk->flag: see jfs_logmgr.h */ /* * transaction lock */ struct tlock { lid_t next; /* 2: index next lockword on tid locklist * next lockword on freelist */ tid_t tid; /* 2: transaction id holding lock */ u16 flag; /* 2: lock control */ u16 type; /* 2: log type */ struct metapage *mp; /* 4/8: object page buffer locked */ struct inode *ip; /* 4/8: object */ /* (16) */ s16 lock[24]; /* 48: overlay area */ }; /* (64) */ extern struct tlock *TxLock; /* transaction lock table */ /* * tlock flag */ /* txLock state */ #define tlckPAGELOCK 0x8000 #define tlckINODELOCK 0x4000 #define tlckLINELOCK 0x2000 #define tlckINLINELOCK 0x1000 /* lmLog state */ #define tlckLOG 0x0800 /* updateMap state */ #define tlckUPDATEMAP 0x0080 #define tlckDIRECTORY 0x0040 /* freeLock state */ #define tlckFREELOCK 0x0008 #define tlckWRITEPAGE 0x0004 #define tlckFREEPAGE 0x0002 /* * tlock type */ #define tlckTYPE 0xfe00 #define tlckINODE 0x8000 #define tlckXTREE 0x4000 #define tlckDTREE 0x2000 #define tlckMAP 0x1000 #define tlckEA 0x0800 #define tlckACL 0x0400 #define tlckDATA 0x0200 #define tlckBTROOT 0x0100 #define tlckOPERATION 0x00ff #define tlckGROW 0x0001 /* file grow */ #define tlckREMOVE 0x0002 /* file delete */ #define tlckTRUNCATE 0x0004 /* file truncate */ #define tlckRELOCATE 0x0008 /* file/directory relocate */ #define tlckENTRY 0x0001 /* directory insert/delete */ #define tlckEXTEND 0x0002 /* directory extend in-line */ #define tlckSPLIT 0x0010 /* splited page */ #define tlckNEW 0x0020 /* new page from split */ #define tlckFREE 0x0040 /* free page */ #define tlckRELINK 0x0080 /* update sibling pointer */ /* * linelock for lmLog() * * note: linelock and its variations are overlaid * at tlock.lock: watch for alignment; */ struct lv { u8 offset; /* 1: */ u8 length; /* 1: */ }; /* (2) */ #define TLOCKSHORT 20 #define TLOCKLONG 28 struct linelock { lid_t next; /* 2: next linelock */ s8 maxcnt; /* 1: */ s8 index; /* 1: */ u16 flag; /* 2: */ u8 type; /* 1: */ u8 l2linesize; /* 1: log2 of linesize */ /* (8) */ struct lv lv[20]; /* 40: */ }; /* (48) */ #define dt_lock linelock struct xtlock { lid_t next; /* 2: */ s8 maxcnt; /* 1: */ s8 index; /* 1: */ u16 flag; /* 2: */ u8 type; /* 1: */ u8 l2linesize; /* 1: log2 of linesize */ /* (8) */ struct lv header; /* 2: */ struct lv lwm; /* 2: low water mark */ struct lv hwm; /* 2: high water mark */ struct lv twm; /* 2: */ /* (16) */ s32 pxdlock[8]; /* 32: */ }; /* (48) */ /* * maplock for txUpdateMap() * * note: maplock and its variations are overlaid * at tlock.lock/linelock: watch for alignment; * N.B. next field may be set by linelock, and should not * be modified by maplock; * N.B. index of the first pxdlock specifies index of next * free maplock (i.e., number of maplock) in the tlock; */ struct maplock { lid_t next; /* 2: */ u8 maxcnt; /* 2: */ u8 index; /* 2: next free maplock index */ u16 flag; /* 2: */ u8 type; /* 1: */ u8 count; /* 1: number of pxd/xad */ /* (8) */ pxd_t pxd; /* 8: */ }; /* (16): */ /* maplock flag */ #define mlckALLOC 0x00f0 #define mlckALLOCXADLIST 0x0080 #define mlckALLOCPXDLIST 0x0040 #define mlckALLOCXAD 0x0020 #define mlckALLOCPXD 0x0010 #define mlckFREE 0x000f #define mlckFREEXADLIST 0x0008 #define mlckFREEPXDLIST 0x0004 #define mlckFREEXAD 0x0002 #define mlckFREEPXD 0x0001 #define pxd_lock maplock struct xdlistlock { lid_t next; /* 2: */ u8 maxcnt; /* 2: */ u8 index; /* 2: */ u16 flag; /* 2: */ u8 type; /* 1: */ u8 count; /* 1: number of pxd/xad */ /* (8) */ /* * We need xdlist to be 64 bits (8 bytes), regardless of * whether void * is 32 or 64 bits */ union { void *_xdlist; /* pxd/xad list */ s64 pad; /* 8: Force 64-bit xdlist size */ } union64; }; /* (16): */ #define xdlist union64._xdlist /* * commit * * parameter to the commit manager routines */ struct commit { tid_t tid; /* tid = index of tblock */ int flag; /* flags */ struct jfs_log *log; /* log */ struct super_block *sb; /* superblock */ int nip; /* number of entries in iplist */ struct inode **iplist; /* list of pointers to inodes */ /* log record descriptor on 64-bit boundary */ struct lrd lrd; /* : log record descriptor */ }; /* * external declarations */ extern int jfs_tlocks_low; extern int txInit(void); extern void txExit(void); extern struct tlock *txLock(tid_t, struct inode *, struct metapage *, int); extern struct tlock *txMaplock(tid_t, struct inode *, int); extern int txCommit(tid_t, int, struct inode **, int); extern tid_t txBegin(struct super_block *, int); extern void txBeginAnon(struct super_block *); extern void txEnd(tid_t); extern void txAbort(tid_t, int); extern struct linelock *txLinelock(struct linelock *); extern void txFreeMap(struct inode *, struct maplock *, struct tblock *, int); extern void txEA(tid_t, struct inode *, dxd_t *, dxd_t *); extern void txFreelock(struct inode *); extern int lmLog(struct jfs_log *, struct tblock *, struct lrd *, struct tlock *); extern void txQuiesce(struct super_block *); extern void txResume(struct super_block *); extern void txLazyUnlock(struct tblock *); extern int jfs_lazycommit(void *); extern int jfs_sync(void *); #endif /* _H_JFS_TXNMGR */