Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
subscriptions: correct the atomic bytes in/out calculations (clang sa…
…nitizer)
  • Loading branch information
perexg committed Mar 10, 2016
1 parent 75d640c commit df03341
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions src/subscriptions.c
Expand Up @@ -985,15 +985,13 @@ subscription_status_callback ( void *p )

LIST_FOREACH(s, &subscriptions, ths_global_link) {
/* Store the difference between total bytes from the last round */
uint64_t in_prev = atomic_get_u64(&s->ths_total_bytes_in_prev);
uint64_t in_curr = atomic_get_u64(&s->ths_total_bytes_in);
uint64_t out_prev = atomic_get_u64(&s->ths_total_bytes_out_prev);
uint64_t in_prev = atomic_exchange_u64(&s->ths_total_bytes_in_prev, in_curr);
uint64_t out_curr = atomic_get_u64(&s->ths_total_bytes_out);
uint64_t out_prev = atomic_exchange_u64(&s->ths_total_bytes_out_prev, out_curr);

atomic_set(&s->ths_bytes_in_avg, (int)(in_curr - in_prev));
atomic_set_u64(&s->ths_total_bytes_in_prev, s->ths_total_bytes_in);
atomic_set(&s->ths_bytes_out_avg, (int)(out_curr - out_prev));
atomic_set_u64(&s->ths_total_bytes_out_prev, s->ths_total_bytes_out);

htsmsg_t *m = subscription_create_msg(s, NULL);
htsmsg_add_u32(m, "updateEntry", 1);
Expand Down

0 comments on commit df03341

Please sign in to comment.