fs/jfs/jfs_txnmgr.h - linux - Git at Google

 /*
  *   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 struct tlock *txLock(tid_t tid, struct inode *ip, struct metapage *mp,
 			    int flag);

 extern struct tlock *txMaplock(tid_t tid, struct inode *ip, int flag);

 extern int txCommit(tid_t tid, int nip, struct inode **iplist, int flag);

 extern tid_t txBegin(struct super_block *sb, int flag);

 extern void txBeginAnon(struct super_block *sb);

 extern void txEnd(tid_t tid);

 extern void txAbort(tid_t tid, int dirty);

 extern struct linelock *txLinelock(struct linelock * tlock);

 extern void txFreeMap(struct inode *ip, struct maplock * maplock,
 		      struct tblock * tblk, int maptype);

 extern void txEA(tid_t tid, struct inode *ip, dxd_t * oldea, dxd_t * newea);

 extern void txFreelock(struct inode *ip);

 extern int lmLog(struct jfs_log * log, struct tblock * tblk, struct lrd * lrd,
 		 struct tlock * tlck);

 extern void txQuiesce(struct super_block *sb);

 extern void txResume(struct super_block *sb);
 #endif				/* _H_JFS_TXNMGR */
	/*
	* 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 struct tlock txLock(tid_t tid, struct inode ip, struct metapage *mp,
	int flag);

	extern struct tlock txMaplock(tid_t tid, struct inode ip, int flag);

	extern int txCommit(tid_t tid, int nip, struct inode **iplist, int flag);

	extern tid_t txBegin(struct super_block *sb, int flag);

	extern void txBeginAnon(struct super_block *sb);

	extern void txEnd(tid_t tid);

	extern void txAbort(tid_t tid, int dirty);

	extern struct linelock txLinelock(struct linelock tlock);

	extern void txFreeMap(struct inode ip, struct maplock maplock,
	struct tblock * tblk, int maptype);

	extern void txEA(tid_t tid, struct inode ip, dxd_t oldea, dxd_t * newea);

	extern void txFreelock(struct inode *ip);

	extern int lmLog(struct jfs_log * log, struct tblock * tblk, struct lrd * lrd,
	struct tlock * tlck);

	extern void txQuiesce(struct super_block *sb);

	extern void txResume(struct super_block *sb);
	#endif /* _H_JFS_TXNMGR */