diff options
Diffstat (limited to 'src/couch_replicator/src/couch_replicator_scheduler_job.erl')
| -rw-r--r-- | src/couch_replicator/src/couch_replicator_scheduler_job.erl | 16 |
1 files changed, 6 insertions, 10 deletions
diff --git a/src/couch_replicator/src/couch_replicator_scheduler_job.erl b/src/couch_replicator/src/couch_replicator_scheduler_job.erl index 565a2bd97..d69febb81 100644 --- a/src/couch_replicator/src/couch_replicator_scheduler_job.erl +++ b/src/couch_replicator/src/couch_replicator_scheduler_job.erl @@ -600,7 +600,7 @@ init_state(Rep) -> ?DEFAULT_CHECKPOINT_INTERVAL), type = Type, view = View, - stats = Stats + stats = couch_replicator_stats:new(Stats) }, State#rep_state{timer = start_timer(State)}. @@ -949,20 +949,16 @@ get_pending_count_int(#rep_state{source = Db}=St) -> update_task(State) -> #rep_state{ + rep_details = #rep{id = JobId}, current_through_seq = {_, ThroughSeq}, highest_seq_done = {_, HighestSeq} } = State, - update_scheduler_job_stats(State), - couch_task_status:update( - rep_stats(State) ++ [ + Status = rep_stats(State) ++ [ {source_seq, HighestSeq}, {through_seq, ThroughSeq} - ]). - - -update_scheduler_job_stats(#rep_state{rep_details = Rep, stats = Stats}) -> - JobId = Rep#rep.id, - couch_replicator_scheduler:update_job_stats(JobId, Stats). + ], + couch_replicator_scheduler:update_job_stats(JobId, Status), + couch_task_status:update(Status). rep_stats(State) -> |