X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=libringbuffer%2Ffrontend_types.h;h=b44783f713630a584e99e28bd6c6982f5bf08444;hb=1572ffb1ad081d6a47b3b05831aa19e15435a40d;hp=9d3932d8978d51b17f64c87af472c675e6472824;hpb=74d81a6cca2cd4a7718bba9368f382f9f2fbba84;p=lttng-ust.git diff --git a/libringbuffer/frontend_types.h b/libringbuffer/frontend_types.h index 9d3932d8..b44783f7 100644 --- a/libringbuffer/frontend_types.h +++ b/libringbuffer/frontend_types.h @@ -29,6 +29,7 @@ */ #include +#include /* for timer_t */ #include #include @@ -37,6 +38,7 @@ #include #include "backend_types.h" #include "shm_internal.h" +#include "shm_types.h" #include "vatomic.h" /* @@ -56,12 +58,18 @@ struct channel { * subbuffer index. */ - unsigned long switch_timer_interval; /* Buffer flush (jiffies) */ - unsigned long read_timer_interval; /* Reader wakeup (jiffies) */ - //wait_queue_head_t read_wait; /* reader wait queue */ + unsigned long switch_timer_interval; /* Buffer flush (us) */ + timer_t switch_timer; + int switch_timer_enabled; + + unsigned long read_timer_interval; /* Reader wakeup (us) */ + timer_t read_timer; + int read_timer_enabled; + int finalized; /* Has channel been finalized */ size_t priv_data_offset; unsigned int nr_streams; /* Number of streams */ + struct lttng_ust_shm_handle *handle; char padding[RB_CHANNEL_PADDING]; /* * Associated backend contains a variable-length array. Needs to @@ -118,14 +126,10 @@ struct lttng_ust_lib_ring_buffer { union v_atomic records_overrun; /* Number of overwritten records */ //wait_queue_head_t read_wait; /* reader buffer-level wait queue */ int finalized; /* buffer has been finalized */ - //struct timer_list switch_timer; /* timer for periodical switch */ - //struct timer_list read_timer; /* timer for read poll */ unsigned long get_subbuf_consumed; /* Read-side consumed */ unsigned long prod_snapshot; /* Producer count snapshot */ unsigned long cons_snapshot; /* Consumer count snapshot */ - unsigned int get_subbuf:1, /* Sub-buffer being held by reader */ - switch_timer_enabled:1, /* Protected by ring_buffer_nohz_lock */ - read_timer_enabled:1; /* Protected by ring_buffer_nohz_lock */ + unsigned int get_subbuf:1; /* Sub-buffer being held by reader */ /* shmp pointer to self */ DECLARE_SHMP(struct lttng_ust_lib_ring_buffer, self); char padding[RB_RING_BUFFER_PADDING]; @@ -162,7 +166,7 @@ void *channel_get_private(struct channel *chan) uatomic_inc(&__chan->record_disabled); \ WARN_ON(1); \ } \ - _____ret; \ + _____ret = _____ret; /* For clang "unused result". */ \ }) #endif /* _LTTNG_RING_BUFFER_FRONTEND_TYPES_H */