1 /*****************************************************************************
2 * rtcp.c: RTCP stream output support
3 *****************************************************************************
4 * Copyright © 2007 Rémi Denis-Courmont
7 * This library is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU Lesser General Public
9 * License as published by the Free Software Foundation; either
10 * version 2.1 of the License, or (at your option) any later version.
12 * This library is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Lesser General Public License for more details.
17 * You should have received a copy of the GNU Lesser General Public
18 * License along with this library; if not, write to the Free Software
19 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
20 *****************************************************************************/
22 /*****************************************************************************
24 *****************************************************************************/
30 #include <vlc_common.h>
31 #include <vlc_block.h>
33 #include <vlc_network.h>
41 # define SOL_IP IPPROTO_IP
45 * NOTE on RTCP implementation:
46 * - there is a single sender (us), no conferencing here! => n = sender = 1,
47 * - as such we need not bother to include Receiver Reports,
48 * - in unicast case, there is a single receiver => members = 1 + 1 = 2,
49 * and obviously n > 25% of members,
50 * - in multicast case, we do not want to maintain the number of receivers
51 * and we assume it is big (i.e. than 3) because that's what broadcasting is
53 * - it is assumed we_sent = true (could be wrong), since we are THE sender,
54 * - we always send SR + SDES, while running,
55 * - FIXME: we do not implement separate rate limiting for SDES,
56 * - we do not implement any profile-specific extensions for the time being.
60 size_t length
; /* RTCP packet length */
61 uint8_t payload
[28 + 8 + (2 * 257) + 8];
62 int handle
; /* RTCP socket handler */
64 uint32_t packets
; /* RTP packets sent */
65 uint32_t bytes
; /* RTP bytes sent */
66 unsigned counter
; /* RTP packets sent since last RTCP packet */
70 rtcp_sender_t
*OpenRTCP (vlc_object_t
*obj
, int rtp_fd
, int proto
,
76 char src
[NI_MAXNUMERICHOST
];
79 if (net_GetSockAddress (rtp_fd
, src
, &sport
))
84 /* RTP/RTCP mux: duplicate the socket */
86 fd
= vlc_dup (rtp_fd
);
87 #elif defined(UNDER_CE)
88 #warning Muxed RTP/RTCP unimplemented!
91 WSAPROTOCOL_INFO info
;
92 WSADuplicateSocket (rtp_fd
, GetCurrentProcessId (), &info
);
93 fd
= WSASocket (info
.iAddressFamily
, info
.iSocketType
, info
.iProtocol
,
99 /* RTCP on a separate port */
100 char dst
[NI_MAXNUMERICHOST
];
103 if (net_GetPeerAddress (rtp_fd
, dst
, &dport
))
109 fd
= net_OpenDgram (obj
, src
, sport
, dst
, dport
, AF_UNSPEC
, proto
);
112 /* Copy the multicast IPv4 TTL value (useless for IPv6) */
114 socklen_t len
= sizeof (ttl
);
116 if (!getsockopt (rtp_fd
, SOL_IP
, IP_MULTICAST_TTL
, &ttl
, &len
))
117 setsockopt (fd
, SOL_IP
, IP_MULTICAST_TTL
, &ttl
, len
);
119 /* Ignore all incoming RTCP-RR packets */
120 setsockopt (fd
, SOL_SOCKET
, SO_RCVBUF
, &(int){ 0 }, sizeof (int));
127 rtcp
= malloc (sizeof (*rtcp
));
135 rtcp
->bytes
= rtcp
->packets
= rtcp
->counter
= 0;
137 ptr
= (uint8_t *)strchr (src
, '%');
139 *ptr
= '\0'; /* remove scope ID frop IPv6 addresses */
144 ptr
[0] = 2 << 6; /* V = 2, P = RC = 0 */
145 ptr
[1] = 200; /* payload type: Sender Report */
146 SetWBE (ptr
+ 2, 6); /* length = 6 (7 double words) */
147 memset (ptr
+ 4, 0, 4); /* SSRC unknown yet */
148 SetQWBE (ptr
+ 8, NTPtime64 ());
149 memset (ptr
+ 16, 0, 12); /* timestamp and counters */
152 /* Source description */
154 ptr
[0] = (2 << 6) | 1; /* V = 2, P = 0, SC = 1 */
155 ptr
[1] = 202; /* payload type: Source Description */
156 uint8_t *lenptr
= ptr
+ 2;
157 memset (ptr
+ 4, 0, 4); /* SSRC unknown yet */
160 ptr
[0] = 1; /* CNAME - mandatory */
161 assert (NI_MAXNUMERICHOST
<= 256);
162 ptr
[1] = strlen (src
);
163 memcpy (ptr
+ 2, src
, ptr
[1]);
166 static const char tool
[] = PACKAGE_STRING
;
167 ptr
[0] = 6; /* TOOL */
168 ptr
[1] = (sizeof (tool
) > 256) ? 255 : (sizeof (tool
) - 1);
169 memcpy (ptr
+ 2, tool
, ptr
[1]);
172 while ((ptr
- sdes
) & 3) /* 32-bits padding */
174 SetWBE (lenptr
, (ptr
- sdes
- 1) >> 2);
176 rtcp
->length
= ptr
- rtcp
->payload
;
181 void CloseRTCP (rtcp_sender_t
*rtcp
)
186 uint8_t *ptr
= rtcp
->payload
;
187 uint64_t now64
= NTPtime64 ();
188 SetQWBE (ptr
+ 8, now64
); /* Update the Sender Report timestamp */
192 ptr
[0] = (2 << 6) | 1; /* V = 2, P = 0, SC = 1 */
193 ptr
[1] = 203; /* payload type: Bye */
195 memcpy (ptr
+ 4, rtcp
->payload
+ 4, 4); /* Copy SSRC from Sender Report */
198 /* We are THE sender, so we are more important than anybody else, so
199 * we can afford not to check bandwidth constraints here. */
200 send (rtcp
->handle
, rtcp
->payload
, rtcp
->length
, 0);
201 net_Close (rtcp
->handle
);
206 void SendRTCP (rtcp_sender_t
*restrict rtcp
, const block_t
*rtp
)
208 if ((rtcp
== NULL
) /* RTCP sender off */
209 || (rtp
->i_buffer
< 12)) /* too short RTP packet */
212 /* Updates statistics */
214 rtcp
->bytes
+= rtp
->i_buffer
;
215 rtcp
->counter
+= rtp
->i_buffer
;
217 /* 1.25% rate limit */
218 if ((rtcp
->counter
/ 80) < rtcp
->length
)
221 uint8_t *ptr
= rtcp
->payload
;
222 uint32_t last
= GetDWBE (ptr
+ 8); // last RTCP SR send time
223 uint64_t now64
= NTPtime64 ();
224 if ((now64
>> 32) < (last
+ 5))
225 return; // no more than one SR every 5 seconds
227 memcpy (ptr
+ 4, rtp
->p_buffer
+ 8, 4); /* SR SSRC */
228 SetQWBE (ptr
+ 8, now64
);
229 memcpy (ptr
+ 16, rtp
->p_buffer
+ 4, 4); /* RTP timestamp */
230 SetDWBE (ptr
+ 20, rtcp
->packets
);
231 SetDWBE (ptr
+ 24, rtcp
->bytes
);
232 memcpy (ptr
+ 28 + 4, rtp
->p_buffer
+ 8, 4); /* SDES SSRC */
234 if (send (rtcp
->handle
, ptr
, rtcp
->length
, 0) == (ssize_t
)rtcp
->length
)