Quelle  jfs_txnmgr.h   Sprache: C

/* SPDX-License-Identifier: GPL-2.0-or-later */
/*
 *   Copyright (C) International Business Machines Corp., 2000-2004
 */
#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 */