|  | /* | 
|  | *   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 | 
|  | /* 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 */ |