|
|
@ -53,6 +53,7 @@ |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
struct iterator_helper { |
|
|
struct iterator_helper { |
|
|
|
|
|
uint64_t count; |
|
|
GSList *del_timeout; |
|
|
GSList *del_timeout; |
|
|
GSList *del_scheduled; |
|
|
GSList *del_scheduled; |
|
|
GHashTable *addr_sfd; |
|
|
GHashTable *addr_sfd; |
|
|
@ -153,6 +154,8 @@ static void call_timer_iterator(struct call *c, struct iterator_helper *hlp) { |
|
|
enum call_stream_state css; |
|
|
enum call_stream_state css; |
|
|
atomic64 *timestamp; |
|
|
atomic64 *timestamp; |
|
|
|
|
|
|
|
|
|
|
|
hlp->count++; |
|
|
|
|
|
|
|
|
rwlock_lock_r(&c->master_lock); |
|
|
rwlock_lock_r(&c->master_lock); |
|
|
log_info_call(c); |
|
|
log_info_call(c); |
|
|
|
|
|
|
|
|
@ -582,7 +585,7 @@ void call_timer(void *ptr) { |
|
|
// stats derived while iterating calls |
|
|
// stats derived while iterating calls |
|
|
RTPE_GAUGE_SET(transcoded_media, hlp.transcoded_media); |
|
|
RTPE_GAUGE_SET(transcoded_media, hlp.transcoded_media); |
|
|
|
|
|
|
|
|
i = kernel_list(); |
|
|
|
|
|
|
|
|
i = hlp.count ? kernel_list() : NULL; |
|
|
while (i) { |
|
|
while (i) { |
|
|
ke = i->data; |
|
|
ke = i->data; |
|
|
|
|
|
|
|
|
|