diff options
| author | Raghavendra G <raghavendra@gluster.com> | 2011-07-19 15:09:13 +0530 |
|---|---|---|
| committer | Anand Avati <avati@gluster.com> | 2011-07-29 01:33:43 -0700 |
| commit | 9759d7e6d8f11ef6111fd6d313ced098efa2e38b (patch) | |
| tree | cb2bf9bafb5bac4ec286e802cba5c75a92c7c21c /xlators/performance/io-cache/src/ioc-inode.c | |
| parent | dbc567ec9f97a540e6cab8006ba285ab62fc372c (diff) | |
performance/io-cache: hold lock on ioc_inode whereever a page is being accessed/modified
Change-Id: Ifc435c2e289b2a8ceeed2a091e555953af179936
BUG: 2939
Reviewed-on: http://review.gluster.com/21
Tested-by: Gluster Build System <jenkins@build.gluster.com>
Reviewed-by: Anand Avati <avati@gluster.com>
Diffstat (limited to 'xlators/performance/io-cache/src/ioc-inode.c')
| -rw-r--r-- | xlators/performance/io-cache/src/ioc-inode.c | 25 |
1 files changed, 14 insertions, 11 deletions
diff --git a/xlators/performance/io-cache/src/ioc-inode.c b/xlators/performance/io-cache/src/ioc-inode.c index 1367a124698..208dbd357f8 100644 --- a/xlators/performance/io-cache/src/ioc-inode.c +++ b/xlators/performance/io-cache/src/ioc-inode.c @@ -36,6 +36,7 @@ void * str_to_ptr (char *string) { void *ptr = NULL; + GF_VALIDATE_OR_GOTO ("io-cache", string, out); ptr = (void *)strtoul (string, NULL, 16); @@ -122,7 +123,7 @@ ioc_inode_wakeup (call_frame_t *frame, ioc_inode_t *ioc_inode, ioc_inode_lock (ioc_inode); { page_waitq = - ioc_page_wakeup (waiter_page); + __ioc_page_wakeup (waiter_page); } ioc_inode_unlock (ioc_inode); if (page_waitq) @@ -132,17 +133,19 @@ ioc_inode_wakeup (call_frame_t *frame, ioc_inode_t *ioc_inode, * page->ready = 0, to avoid double faults */ ioc_inode_lock (ioc_inode); - - if (waiter_page->ready) { - waiter_page->ready = 0; - need_fault = 1; - } else { - gf_log (frame->this->name, GF_LOG_TRACE, - "validate frame(%p) is waiting" - "for in-transit page = %p", - frame, waiter_page); + { + if (waiter_page->ready) { + waiter_page->ready = 0; + need_fault = 1; + } else { + gf_log (frame->this->name, + GF_LOG_TRACE, + "validate frame(%p) is " + "waiting for in-transit" + " page = %p", frame, + waiter_page); + } } - ioc_inode_unlock (ioc_inode); if (need_fault) { |