Subversion Repositories planix.SVN

Rev

Rev 2 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
2 - 1 
#include <u.h>
2 
#include <libc.h>
3 
#include <ip.h>
4 
#include "dat.h"
5 
#include "protos.h"
6 
 
7 
typedef struct Hdr Hdr;
8 
struct Hdr {
9 
	uchar	hdr;		/* RTCP header */
10 
	uchar	pt;		/* Packet type */
11 
	uchar	len[2];		/* Report length */
12 
	uchar	ssrc[4];	/* Synchronization source identifier */
13 
	uchar	ntp[8];		/* NTP time stamp */
14 
	uchar	rtp[4];		/* RTP time stamp */
15 
	uchar	pktc[4];	/* Sender's packet count */
16 
	uchar	octc[4];	/* Sender's octet count */
17 
};
18 
 
19 
typedef struct Report Report;
20 
struct Report {
21 
	uchar	ssrc[4];	/* SSRC identifier */
22 
	uchar	lost[4];	/* Fraction + cumu lost */
23 
	uchar	seqhi[4];	/* Highest seq number received */
24 
	uchar	jitter[4];	/* Interarrival jitter */
25 
	uchar	lsr[4];		/* Last SR */
26 
	uchar	dlsr[4];	/* Delay since last SR */
27 
};
28 
 
29 
enum{
30 
	RTCPLEN = 28,		/* Minimum size of an RTCP header */
31 
	REPORTLEN = 24,
32 
};
33 
 
34 
static int
35 
p_seprint(Msg *m)
36 
{
37 
	int rc, i, frac;
38 
	float dlsr;
39 
	Hdr*h;
40 
	Report*r;
41 
 
42 
	if(m->pe - m->ps < RTCPLEN)
43 
		return -1;
44 
 
45 
	h = (Hdr*)m->ps;
46 
	if(m->pe - m->ps < (NetS(h->len) + 1) * 4)
47 
		return -1;
48 
 
49 
	rc = h->hdr & 0x1f;
50 
	m->ps += RTCPLEN;
51 
	m->p = seprint(m->p, m->e, "version=%d rc=%d tp=%d ssrc=%8ux "
52 
		"ntp=%d.%.10ud rtp=%d pktc=%d octc=%d hlen=%d",
53 
		(h->hdr >> 6) & 3, rc, h->pt, NetL(h->ssrc), NetL(h->ntp),
54 
		(uint)NetL(&h->ntp[4]), NetL(h->rtp), NetL(h->pktc),
55 
		NetL(h->octc), (NetS(h->len) + 1) * 4);
56 
 
57 
	for(i = 0; i < rc; i++){
58 
		r = (Report*)m->ps;
59 
		m->ps += REPORTLEN;
60 
 
61 
		frac = (int)((r->lost[0] * 100.) / 256.);
62 
		r->lost[0] = 0;
63 
		dlsr = NetL(r->dlsr) / 65536.;
64 
 
65 
		m->p = seprint(m->p, m->e, "\n\trr(csrc=%8ux frac=%3d%% "
66 
			"cumu=%10d seqhi=%10ud jitter=%10d lsr=%8ux dlsr=%f)",
67 
			NetL(r->ssrc), frac, NetL(r->lost), NetL(r->seqhi),
68 
			NetL(r->jitter), NetL(r->lsr), dlsr);
69 
	}
70 
	m->pr = nil;
71 
	return 0;
72 
}
73 
 
74 
Proto rtcp = {
75 
	"rtcp",
76 
	nil,
77 
	nil,
78 
	p_seprint,
79 
	nil,
80 
	nil,
81 
	nil,
82 
	defaultframer,
83 
};