if (!cc_cold)
return;
v_set(config, &cc_hot->cc, 0);
+ cc_hot->cc_rseq = 0;
v_set(config, &cc_hot->seq, 0);
v_set(config, &cc_cold->cc_sb, 0);
}
if (!cc_cold)
return;
commit_count = v_read(config, &cc_hot->cc);
+ commit_count += cc_hot->cc_rseq;
commit_count_sb = v_read(config, &cc_cold->cc_sb);
if (subbuf_offset(commit_count, chan) != 0)
v_add(config, config->cb.subbuffer_header_size(),
&cc_hot->cc);
commit_count = v_read(config, &cc_hot->cc);
+ commit_count += cc_hot->cc_rseq;
/* Check if the written buffer has to be delivered */
lib_ring_buffer_check_deliver(config, buf, chan, offsets->old,
commit_count, oldidx, handle, tsc);
return;
v_add(config, padding_size, &cc_hot->cc);
commit_count = v_read(config, &cc_hot->cc);
+ commit_count += cc_hot->cc_rseq;
lib_ring_buffer_check_deliver(config, buf, chan, offsets->old - 1,
commit_count, oldidx, handle, tsc);
lib_ring_buffer_write_commit_counter(config, buf, chan,
return;
v_add(config, config->cb.subbuffer_header_size(), &cc_hot->cc);
commit_count = v_read(config, &cc_hot->cc);
+ commit_count += cc_hot->cc_rseq;
/* Check if the written buffer has to be delivered */
lib_ring_buffer_check_deliver(config, buf, chan, offsets->begin,
commit_count, beginidx, handle, tsc);