int overwrite,
unsigned int switch_timer_interval,
unsigned int read_timer_interval,
int overwrite,
unsigned int switch_timer_interval,
unsigned int read_timer_interval,
int consumer_is_data_pending(uint64_t session_id,
struct consumer_output *consumer);
int consumer_close_metadata(struct consumer_socket *socket,
int consumer_is_data_pending(uint64_t session_id,
struct consumer_output *consumer);
int consumer_close_metadata(struct consumer_socket *socket,