Implemented stage 1 of measuring delay

pull/101/head
Frederic-Philippe Metz 11 years ago
parent 6bc7a77e9b
commit e0f9c59274

@ -1345,9 +1345,8 @@ static void callmaster_timer(void *ptr) {
DS(errors);
mutex_lock(&m->statspslock);
ilog(LOG_INFO, "Start time:%llu\n", ke->stats.start.tv_nsec);
m->statsps.start = ke->stats.start;
m->statsps.end = ke->stats.end;
ps->stats.start = m->statsps.start = ke->stats.start;
ps->stats.end = m->statsps.end = ke->stats.end;
mutex_unlock(&m->statspslock);
mutex_lock(&ps->in_lock);

@ -151,7 +151,7 @@ static void cli_incoming_list_callid(char* buffer, int len, struct callmaster* m
struct timespec result;
timespec_subtract(&result,&(ps->stats.end),&(ps->stats.start));
printlen = snprintf(replybuffer,(outbufend-replybuffer), "------ Media #%u, port %5u <> %15s:%-5hu%s, "
"%llu p, %llu b, %llu e, %llu last_packet, %llu.%9llu delay\n",
"%llu p, %llu b, %llu e, %llu last_packet, %llu.%09llu delay\n",
md->index,
(unsigned int) (ps->sfd ? ps->sfd->fd.localport : 0),
smart_ntop_p_buf(&ps->endpoint.ip46), ps->endpoint.port,

@ -1808,7 +1808,6 @@ drop:
static int send_proxy_packet(struct sk_buff *skb, struct re_address *src, struct re_address *dst, unsigned char tos) {
printk(KERN_WARNING "xt_RTPENGINE send_proxy_packet\n");
if (src->family != dst->family)
goto drop;
@ -2238,7 +2237,7 @@ out:
getnstimeofday(&g->stats.end);
g->stats.measureactive=0;
}
printk(KERN_WARNING "xt_RTPENGINE failed to create /proc entry for ID %llu\n", g->stats.start.tv_nsec);
if (err)
g->stats.errors++;
else {

Loading…
Cancel
Save