Cacheline align xlog_t
PATCH 1/1 Cacheline align xlog_t
Reorganise xlog_t for better cacheline isolation of contention
To reduce contention on the log in large CPU count, separate out different parts of the xlog_t structure onto different cachelines. Move each lock onto a different cacheline along with all the members that are accessed/modified while that lock is held.
Also, move the debugging code into debug code.
--- fs/xfs/xfs_log.c | 5 +--- fs/xfs/xfs_log_priv.h | 55 +++++++++++++++++++++++++++----------------------- 2 files changed, 32 insertions(+), 28 deletions(-)
fs/xfs/xfs_log.c +2 -3
@@ -1237,9 +1237,9 @@ xlog_alloc_log(xfs_mount_t *mp,XFS_BUF_SET_FSPRIVATE2 (bp, (unsigned long )1 ); iclog->ic_bp = bp; iclog->hic_data = bp->b_addr; - +#ifdef DEBUG log->l_iclog_bak[i] = (xfs_caddr_t)&(iclog->ic_header); - +#endif head = &iclog->ic_header;memset (head,0 ,sizeof (xlog_rec_header_t)); head->h_magicno =cpu_to_be32 (XLOG_HEADER_MAGIC_NUM );
@@ -1250,7 +1250,6 @@ xlog_alloc_log(xfs_mount_t *mp, head->h_fmt =cpu_to_be32 (XLOG_FMT );memcpy (&head->h_fs_uuid, &mp->m_sb.sb_uuid,sizeof (uuid_t)); - iclog->ic_size =XFS_BUF_SIZE (bp) - log->l_iclog_hsize; iclog->ic_state =XLOG_STATE_ACTIVE ; iclog->ic_log = log;
fs/xfs/xfs_log_priv.h +30 -25
85 lines not on this page · raw message
Looks good - just one comment.
Quoted 118 lines · David Chinner
Reorganise
xlog_tfor better cacheline isolation of contentionTo reduce contention on the log in large CPU count, separate out different parts of the
xlog_tstructure onto different cachelines. Move each lock onto a different cacheline along with all the members that are accessed/modified while that lock is held.Also, move the debugging code into debug code.
Signed-off-by Dave Chinner <[email protected]>--- fs/xfs/xfs_log.c | 5 +--- fs/xfs/xfs_log_priv.h | 55 +++++++++++++++++++++++++++----------------------- 2 files changed, 32 insertions(+), 28 deletions(-)Index:
2.6.x-xfs-new/fs/xfs/xfs_log.c
===================================================================fs/xfs/xfs_log.c +2
-3@@ -1237,9 +1237,9 @@ xlog_alloc_log(xfs_mount_t *mp,XFS_BUF_SET_FSPRIVATE2 (bp, (unsigned long )1 ); iclog->ic_bp = bp; iclog->hic_data = bp->b_addr; - +#ifdef DEBUG log->l_iclog_bak[i] = (xfs_caddr_t)&(iclog->ic_header); - +#endif head = &iclog->ic_header;memset (head,0 ,sizeof (xlog_rec_header_t)); head->h_magicno =cpu_to_be32 (XLOG_HEADER_MAGIC_NUM );@@ -1250,7 +1250,6 @@ xlog_alloc_log(xfs_mount_t *mp, head->h_fmt =cpu_to_be32 (XLOG_FMT );memcpy (&head->h_fs_uuid, &mp->m_sb.sb_uuid,sizeof (uuid_t)); - iclog->ic_size =XFS_BUF_SIZE (bp) - log->l_iclog_hsize; iclog->ic_state =XLOG_STATE_ACTIVE ; iclog->ic_log = log;Index:
2.6.x-xfs-new/fs/xfs/xfs_log_priv.h
===================================================================fs/xfs/xfs_log_priv.h +23
-22@@ -402,8 +402,29 @@ typedef struct xlog_in_core {* that round off problems won't occur when releasing partial reservations. */ typedef struct log { + /* The following fields don't need locking */ + struct xfs_mount *l_mp; /* mount point */ + struct xfs_buf *l_xbuf; /* extra buffer for log + * wrapping */ + struct xfs_buftarg *l_targ; /* buftarg of log */ + uint l_flags; + uint l_quotaoffs_flag; /* XFS_DQ_*, for QUOTAOFFs */ + struct xfs_buf_cancel **l_buf_cancel_table; + int l_iclog_hsize; /* size of iclog header */ + int l_iclog_heads; /* # of iclog header sectors */ + uint l_sectbb_log; /* log2 of sector size in BBs */ + uint l_sectbb_mask; /* sector size (in BBs) + * alignment mask */ + int l_iclog_size; /* size of log in bytes */ + int l_iclog_size_log; /* log power size of log */ + int l_iclog_bufs; /* number of iclog buffers */ + xfs_daddr_t l_logBBstart; /* start block of log */ + int l_logsize; /* size of log in bytes */ + int l_logBBsize; /* size of log in BB chunks */ + /* The following block of fields are changed while holding icloglock */ - sema_t l_flushsema; /* iclog flushing semaphore */ + sema_t l_flushsema ____cacheline_aligned_in_smp; + /* iclog flushing semaphore */ int l_flushcnt; /* # of procs waiting on this * sema */ int l_covered_state;/* state of "covering disk@@ -413,27 +434,14 @@ typedef struct log {xfs_lsn_t l_tail_lsn;/* lsn of 1st LR with unflushed * buffers */ xfs_lsn_t l_last_sync_lsn;/* lsn of last LR on disk */ -struct xfs_mount *l_mp;/* mount point */ -struct xfs_buf *l_xbuf;/* extra buffer for log -* wrapping */ -struct xfs_buftarg *l_targ;/* buftarg of log */ -xfs_daddr_t l_logBBstart;/* start block of log */ -int l_logsize;/* size of log in bytes */ -int l_logBBsize;/* size of log in BB chunks */ int l_curr_cycle;/* Cycle number of log writes */ int l_prev_cycle;/* Cycle number before last * block increment */ int l_curr_block;/* current logical log block */ int l_prev_block;/* previous logical log block */ -int l_iclog_size;/* size of log in bytes */ -int l_iclog_size_log;/* log power size of log */ -int l_iclog_bufs;/* number of iclog buffers */ - -/* The following field are used for debugging; need to hold icloglock */ -char *l_iclog_bak[XLOG_MAX_ICLOGS ];/* The following block of fields are changed while holding grant_lock */ -spinlock_t l_grant_lock; +spinlock_t l_grant_lock____cacheline_aligned_in_smp ;xlog_ticket_t *l_reserve_headq;xlog_ticket_t *l_write_headq;int l_grant_reserve_cycle;@@ -441,20 +449,17 @@ typedef struct log {int l_grant_write_cycle;int l_grant_write_bytes; -/* The following fields don't need locking */ #ifdef XFS_LOG_TRACE struct ktrace *l_trace;struct ktrace *l_grant_trace;#endif -uint l_flags; -uint l_quotaoffs_flag;/* XFS_DQ_*, for QUOTAOFFs */ -struct xfs_buf_cancel **l_buf_cancel_table; -int l_iclog_hsize;/* size of iclog header */ -int l_iclog_heads;/* # of iclog header sectors */ -uint l_sectbb_log;/* log2 of sector size in BBs */
fs/xfs/xfs_log_priv.h typedef struct log { · line 462
Quoted 10 lines
fs/xfs/xfs_log_priv.h +7
-3-uint l_sectbb_mask;/* sector size (in BBs) -* alignment mask */ -} xlog_t; + +/* The following field are used for debugging; need to hold icloglock */ +#ifdef DEBUG +char *l_iclog_bak[XLOG_MAX_ICLOGS ]; +#endif + +} xlog_t____cacheline_aligned_in_smp ;
Is it necessary to add a ____cacheline_aligned_in_smp tag here? The important sections of the xlog_t structure are already tagged.
Quoted 4 lines
fs/xfs/xfs_log_priv.h +0
-0#define XLOG_FORCED_SHUTDOWN (log) ((log)->l_flags & XLOG_IO_ERROR)
Quoted 8 lines · Lachlan McIlroy
Quoted 8 lines
*/
(quoted diff) +0
-1- uint l_sectbb_log; /* log2 of sector size inBBs */
fs/xfs/xfs_log_priv.h +2
-3-uint l_sectbb_mask;/* sector size (in BBs) -* alignment mask */ -} xlog_t; + +/* The following field are used for debugging; need to hold
Quoted 8 lines
fs/xfs/xfs_log_priv.h typedef struct log { · line 462
Quoted 6 lines
icloglock */
fs/xfs/xfs_log_priv.h +5
-0+#ifdef DEBUG +char *l_iclog_bak[XLOG_MAX_ICLOGS ]; +#endif + +} xlog_t____cacheline_aligned_in_smp ;Is it necessary to add a
____cacheline_aligned_in_smptag here? The important sections of thexlog_tstructure are already tagged.
This just means that the start of the structure is cacheline aligned. I don't think the internal alignment commands force the entire structure to be cacheline aligned, merely pad the struture internally. In that case, even though the specific internal parts of the structure are on separate cache lines, there's no guarantee that all the related members are on the same cacheline. Hence I'm explicitly stating the exact alignment I want for the structure....
Cheers,
Dave.
Signature · 3 lines
Dave Chinner Principal Engineer SGI Australian Software Group
Quoted 8 lines · David Chinner
This just means that the start of the structure is cacheline aligned. I don't think the internal alignment commands force the entire structure to be cacheline aligned, merely pad the struture internally. In that case, even though the specific internal parts of the structure are on separate cache lines, there's no guarantee that all the related members are on the same cacheline. Hence I'm explicitly stating the exact alignment I want for the structure....
Isn't the structure dynamically allocated anyways? The full type alignment really only matters for statics/globals where the linker can handle it.
For the dynamic allocation you would rather need to make sure it starts at a cache line boundary explicitely because the allocator doesn't know the alignment of the target type, otherwise your careful padding might be useless.
-Andi
Quoted 10 lines · Andi Kleen
Quoted 8 lines · David Chinner
This just means that the start of the structure is cacheline aligned. I don't think the internal alignment commands force the entire structure to be cacheline aligned, merely pad the struture internally. In that case, even though the specific internal parts of the structure are on separate cache lines, there's no guarantee that all the related members are on the same cacheline. Hence I'm explicitly stating the exact alignment I want for the structure....
Quoted 3 lines
Isn't the structure dynamically allocated anyways? The full type alignment really only matters for statics/globals where the linker can handle it.
Ah, right you are. My bad.
Quoted 4 lines
For the dynamic allocation you would rather need to make sure it starts at a cache line boundary explicitely because the allocator doesn't know the alignment of the target type, otherwise your careful padding might be useless.
Yup. Is there an allocator function gives us cacheline aligned allocation (apart from a slab initialised with SLAB_HWCACHE_ALIGN)? There isn't one, right?
Cheers,
Dave.
Signature · 3 lines
Dave Chinner Principal Engineer SGI Australian Software Group
Quoted 7 lines · David Chinner
Quoted 4 lines
For the dynamic allocation you would rather need to make sure it starts at a cache line boundary explicitely because the allocator doesn't know the alignment of the target type, otherwise your careful padding might be useless.
Yup. Is there an allocator function gives us cacheline aligned allocation
__get_free_pages() @) [ok not serious]
Quoted 1 line
(apart from a slab initialised with
SLAB_HWCACHE_ALIGN)?
That too yes.
Quoted 1 line
There isn't one, right?
You can always align yourself with kmalloc (or any other arbitary size allocator) with the standard technique:
get L1_CACHE_BYTES-1 or possibly better cache_line_size() - 1 bytes more and then align the pointer manually with ALIGN. Only tricky part is that you have to undo the alignment before freeing.
-Andi
Quoted 6 lines · Andi Kleen
Quoted 4 lines · David Chinner
Quoted 4 lines
For the dynamic allocation you would rather need to make sure it starts at a cache line boundary explicitely because the allocator doesn't know the alignment of the target type, otherwise your careful padding might be useless.
Quoted 7 lines
Quoted 1 line
There isn't one, right?
You can always align yourself with kmalloc (or any other arbitary size allocator) with the standard technique:
get L1_CACHE_BYTES-1 or possibly bettercache_line_size()- 1 bytes
more and then align the pointer manually with ALIGN. Only tricky part
is that you have to undo the alignment before freeing.
Yeah, how do you know how much was offset for the alignment
to go back for the freeing. I guess you could also keep the original pointer or the offset handy (a pain). Or can the allocator help out?
--Tim
Quoted 15 lines · Andi Kleen
Quoted 7 lines · David Chinner
Quoted 4 lines
For the dynamic allocation you would rather need to make sure it starts at a cache line boundary explicitely because the allocator doesn't know the alignment of the target type, otherwise your careful padding might be useless.
Yup. Is there an allocator function gives us cacheline aligned allocation
__get_free_pages()@) [ok not serious]Quoted 1 line
(apart from a slab initialised with
SLAB_HWCACHE_ALIGN)?That too yes.
Quoted 7 lines
Quoted 1 line
There isn't one, right?
You can always align yourself with kmalloc (or any other arbitary size allocator) with the standard technique:
get L1_CACHE_BYTES-1 or possibly bettercache_line_size()- 1 bytes more and then align the pointer manually with ALIGN. Only tricky part is that you have to undo the alignment before freeing.
Great. I guess that means a wrapper function is in order. I'm not going to deal with this as part of this patch series, though. I'll just remove the superfluous notations.
Patch below.
Cheers,
Dave.
Signature · 147 lines
Dave Chinner Principal Engineer SGI Australian Software Group --- Reorganise xlog_t for better cacheline isolation of contention To reduce contention on the log in large CPU count, separate out different parts of the xlog_t structure onto different cachelines. Move each lock onto a different cacheline along with all the members that are accessed/modified while that lock is held. Also, move the debugging code into debug code. Version 2: o kill the structure alignment hint as these are dynamically allocated structures. Signed-off-by: Dave Chinner <[email protected]> --- fs/xfs/xfs_log.c | 5 +--- fs/xfs/xfs_log_priv.h | 55 +++++++++++++++++++++++++++----------------------- 2 files changed, 32 insertions(+), 28 deletions(-) Index: 2.6.x-xfs-new/fs/xfs/xfs_log.c =================================================================== --- 2.6.x-xfs-new.orig/fs/xfs/xfs_log.c 2008-04-02 21:57:09.664237248 +1000 +++ 2.6.x-xfs-new/fs/xfs/xfs_log.c 2008-04-02 21:57:12.591863526 +1000 @@ -1237,9 +1237,9 @@ xlog_alloc_log(xfs_mount_t *mp, XFS_BUF_SET_FSPRIVATE2(bp, (unsigned long)1); iclog->ic_bp = bp; iclog->hic_data = bp->b_addr; - +#ifdef DEBUG log->l_iclog_bak[i] = (xfs_caddr_t)&(iclog->ic_header); - +#endif head = &iclog->ic_header; memset(head, 0, sizeof(xlog_rec_header_t)); head->h_magicno = cpu_to_be32(XLOG_HEADER_MAGIC_NUM); @@ -1250,7 +1250,6 @@ xlog_alloc_log(xfs_mount_t *mp, head->h_fmt = cpu_to_be32(XLOG_FMT); memcpy(&head->h_fs_uuid, &mp->m_sb.sb_uuid, sizeof(uuid_t)); - iclog->ic_size = XFS_BUF_SIZE(bp) - log->l_iclog_hsize; iclog->ic_state = XLOG_STATE_ACTIVE; iclog->ic_log = log; Index: 2.6.x-xfs-new/fs/xfs/xfs_log_priv.h =================================================================== --- 2.6.x-xfs-new.orig/fs/xfs/xfs_log_priv.h 2008-04-02 21:57:09.668236737 +1000 +++ 2.6.x-xfs-new/fs/xfs/xfs_log_priv.h 2008-04-03 07:46:41.418849158 +1000 @@ -361,7 +361,7 @@ typedef struct xlog_iclog_fields { /* reference counts need their own cacheline */ atomic_t ic_refcnt ____cacheline_aligned_in_smp; -} xlog_iclog_fields_t ____cacheline_aligned_in_smp; +} xlog_iclog_fields_t; typedef union xlog_in_core2 { xlog_rec_header_t hic_header; @@ -402,8 +402,29 @@ typedef struct xlog_in_core { * that round off problems won't occur when releasing partial reservations. */ typedef struct log { + /* The following fields don't need locking */ + struct xfs_mount *l_mp; /* mount point */ + struct xfs_buf *l_xbuf; /* extra buffer for log + * wrapping */ + struct xfs_buftarg *l_targ; /* buftarg of log */ + uint l_flags; + uint l_quotaoffs_flag; /* XFS_DQ_*, for QUOTAOFFs */ + struct xfs_buf_cancel **l_buf_cancel_table; + int l_iclog_hsize; /* size of iclog header */ + int l_iclog_heads; /* # of iclog header sectors */ + uint l_sectbb_log; /* log2 of sector size in BBs */ + uint l_sectbb_mask; /* sector size (in BBs) + * alignment mask */ + int l_iclog_size; /* size of log in bytes */ + int l_iclog_size_log; /* log power size of log */ + int l_iclog_bufs; /* number of iclog buffers */ + xfs_daddr_t l_logBBstart; /* start block of log */ + int l_logsize; /* size of log in bytes */ + int l_logBBsize; /* size of log in BB chunks */ + /* The following block of fields are changed while holding icloglock */ - sema_t l_flushsema; /* iclog flushing semaphore */ + sema_t l_flushsema ____cacheline_aligned_in_smp; + /* iclog flushing semaphore */ int l_flushcnt; /* # of procs waiting on this * sema */ int l_covered_state;/* state of "covering disk @@ -413,27 +434,14 @@ typedef struct log { xfs_lsn_t l_tail_lsn; /* lsn of 1st LR with unflushed * buffers */ xfs_lsn_t l_last_sync_lsn;/* lsn of last LR on disk */ - struct xfs_mount *l_mp; /* mount point */ - struct xfs_buf *l_xbuf; /* extra buffer for log - * wrapping */ - struct xfs_buftarg *l_targ; /* buftarg of log */ - xfs_daddr_t l_logBBstart; /* start block of log */ - int l_logsize; /* size of log in bytes */ - int l_logBBsize; /* size of log in BB chunks */ int l_curr_cycle; /* Cycle number of log writes */ int l_prev_cycle; /* Cycle number before last * block increment */ int l_curr_block; /* current logical log block */ int l_prev_block; /* previous logical log block */ - int l_iclog_size; /* size of log in bytes */ - int l_iclog_size_log; /* log power size of log */ - int l_iclog_bufs; /* number of iclog buffers */ - - /* The following field are used for debugging; need to hold icloglock */ - char *l_iclog_bak[XLOG_MAX_ICLOGS]; /* The following block of fields are changed while holding grant_lock */ - spinlock_t l_grant_lock; + spinlock_t l_grant_lock ____cacheline_aligned_in_smp; xlog_ticket_t *l_reserve_headq; xlog_ticket_t *l_write_headq; int l_grant_reserve_cycle; @@ -441,19 +449,16 @@ typedef struct log { int l_grant_write_cycle; int l_grant_write_bytes; - /* The following fields don't need locking */ #ifdef XFS_LOG_TRACE struct ktrace *l_trace; struct ktrace *l_grant_trace; #endif - uint l_flags; - uint l_quotaoffs_flag; /* XFS_DQ_*, for QUOTAOFFs */ - struct xfs_buf_cancel **l_buf_cancel_table; - int l_iclog_hsize; /* size of iclog header */ - int l_iclog_heads; /* # of iclog header sectors */ - uint l_sectbb_log; /* log2 of sector size in BBs */ - uint l_sectbb_mask; /* sector size (in BBs) - * alignment mask */ + + /* The following field are used for debugging; need to hold icloglock */ +#ifdef DEBUG + char *l_iclog_bak[XLOG_MAX_ICLOGS]; +#endif + } xlog_t; #define XLOG_FORCED_SHUTDOWN(log) ((log)->l_flags & XLOG_IO_ERROR)