diff options
Diffstat (limited to 'xlators/features/changelog/src/changelog-rt.c')
| -rw-r--r-- | xlators/features/changelog/src/changelog-rt.c | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/xlators/features/changelog/src/changelog-rt.c b/xlators/features/changelog/src/changelog-rt.c index 4e801ae85..c147f68ca 100644 --- a/xlators/features/changelog/src/changelog-rt.c +++ b/xlators/features/changelog/src/changelog-rt.c @@ -52,9 +52,8 @@ changelog_rt_fini (xlator_t *this, changelog_dispatcher_t *cd) } int -changelog_rt_enqueue (xlator_t *this, - changelog_priv_t *priv, void *cbatch, - changelog_local_t *local, changelog_log_data_t *cld_0) +changelog_rt_enqueue (xlator_t *this, changelog_priv_t *priv, void *cbatch, + changelog_log_data_t *cld_0, changelog_log_data_t *cld_1) { int ret = 0; changelog_rt_t *crt = NULL; @@ -63,7 +62,9 @@ changelog_rt_enqueue (xlator_t *this, LOCK (&crt->lock); { - ret = changelog_handle_change (this, priv, local, cld_0); + ret = changelog_handle_change (this, priv, cld_0); + if (!ret && cld_1) + ret = changelog_handle_change (this, priv, cld_1); } UNLOCK (&crt->lock); |