X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=libringbuffer%2Fbackend_internal.h;h=df3617cacd76dccdd756d870cf56d0e477b8f387;hb=f4aefcaea053313d45d9b042a23427f253258d31;hp=3ab60a7fa327b6b58acb331ecbd2a1a4f74d0185;hpb=3d1aec25c7cc70f4b240a4498d876d9782497cd4;p=lttng-ust.git diff --git a/libringbuffer/backend_internal.h b/libringbuffer/backend_internal.h index 3ab60a7f..df3617ca 100644 --- a/libringbuffer/backend_internal.h +++ b/libringbuffer/backend_internal.h @@ -45,7 +45,8 @@ int channel_backend_init(struct channel_backend *chanb, const char *name, const struct lttng_ust_lib_ring_buffer_config *config, size_t subbuf_size, - size_t num_subbuf, struct lttng_ust_shm_handle *handle); + size_t num_subbuf, struct lttng_ust_shm_handle *handle, + const int *stream_fds); void channel_backend_free(struct channel_backend *chanb, struct lttng_ust_shm_handle *handle); @@ -309,6 +310,14 @@ unsigned long subbuffer_get_data_size( return shmp(handle, pages->shmp)->data_size; } +static inline +void subbuffer_inc_packet_count(const struct lttng_ust_lib_ring_buffer_config *config, + struct lttng_ust_lib_ring_buffer_backend *bufb, + unsigned long idx, struct lttng_ust_shm_handle *handle) +{ + shmp_index(handle, bufb->buf_cnt, idx)->seq_cnt++; +} + /** * lib_ring_buffer_clear_noref - Clear the noref subbuffer flag, called by * writer. @@ -447,6 +456,18 @@ do { \ inline_memcpy(dest, src, __len); \ } while (0) +/* + * write len bytes to dest with c + */ +static inline +void lib_ring_buffer_do_memset(char *dest, int c, unsigned long len) +{ + unsigned long i; + + for (i = 0; i < len; i++) + dest[i] = c; +} + /* arch-agnostic implementation */ static inline int lttng_ust_fls(unsigned int x) @@ -472,7 +493,7 @@ static inline int lttng_ust_fls(unsigned int x) r -= 2; } if (!(x & 0x80000000U)) { - x <<= 1; + /* No need to bit shift on last operation */ r -= 1; } return r;