diff options
| author | Xavier Hernandez <xhernandez@datalab.es> | 2014-07-14 17:34:04 +0200 |
|---|---|---|
| committer | Vijay Bellur <vbellur@redhat.com> | 2014-09-15 23:12:16 -0700 |
| commit | d97863562bb0d2f685df3d2e3aa4bef1299c8307 (patch) | |
| tree | b8d9455cdface5425e2452e98751ac75dac358e4 /xlators/cluster/ec/src/ec-combine.c | |
| parent | 2be54585002cd1c9d02928b89a02047b58dd6aed (diff) | |
ec: Optimize read/write performance
This patch significantly improves performance of read/write
operations on a dispersed volume by reusing previous inodelk/
entrylk operations on the same inode/entry. This reduces the
latency of each individual operation considerably.
Inode version and size are also updated when needed instead
of on each request. This gives an additional boost.
Change-Id: I4b98d5508c86b53032e16e295f72a3f83fd8fcac
BUG: 1122586
Signed-off-by: Xavier Hernandez <xhernandez@datalab.es>
Reviewed-on: http://review.gluster.org/8369
Tested-by: Gluster Build System <jenkins@build.gluster.com>
Reviewed-by: Jeff Darcy <jdarcy@redhat.com>
Reviewed-by: Dan Lambright <dlambrig@redhat.com>
Diffstat (limited to 'xlators/cluster/ec/src/ec-combine.c')
| -rw-r--r-- | xlators/cluster/ec/src/ec-combine.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/xlators/cluster/ec/src/ec-combine.c b/xlators/cluster/ec/src/ec-combine.c index 3d088d9be4a..02b7e6024fd 100644 --- a/xlators/cluster/ec/src/ec-combine.c +++ b/xlators/cluster/ec/src/ec-combine.c @@ -735,7 +735,7 @@ void ec_combine(ec_cbk_data_t * cbk, ec_combine_f combine) ec_fop_data_t * fop = cbk->fop; ec_cbk_data_t * ans = NULL, * tmp = NULL; struct list_head * item = NULL; - int32_t needed = 0, report = 0; + int32_t needed = 0, resume = 0; char str[32]; LOCK(&fop->lock); @@ -776,7 +776,7 @@ void ec_combine(ec_cbk_data_t * cbk, ec_combine_f combine) ec_update_bad(fop, cbk->mask); - report = 1; + resume = 1; } ans = list_entry(fop->cbk_list.next, ec_cbk_data_t, list); @@ -788,8 +788,8 @@ void ec_combine(ec_cbk_data_t * cbk, ec_combine_f combine) { ec_dispatch_next(fop, cbk->idx); } - else if (report) + else if (resume) { - ec_report(fop, 0); + ec_resume(fop, 0); } } |