Mercurial > mplayer.hg
annotate stream/rtp.c @ 19313:0792ad01e9bf
split rtp stack, udp input layer and rtp input layer from rtp.c
author | ben |
---|---|
date | Fri, 04 Aug 2006 18:32:36 +0000 |
parents | 64d82a45a05d |
children | 4591b597b62c |
rev | line source |
---|---|
15178
8dd7a656eaf8
Mark modified imported files as such to comply more closely with GPL ¡ø2a.
diego
parents:
12799
diff
changeset
|
1 /* Imported from the dvbstream-0.2 project |
8dd7a656eaf8
Mark modified imported files as such to comply more closely with GPL ¡ø2a.
diego
parents:
12799
diff
changeset
|
2 * |
18783 | 3 * Modified for use with MPlayer, for details see the changelog at |
4 * http://svn.mplayerhq.hu/mplayer/trunk/ | |
15178
8dd7a656eaf8
Mark modified imported files as such to comply more closely with GPL ¡ø2a.
diego
parents:
12799
diff
changeset
|
5 * $Id$ |
8dd7a656eaf8
Mark modified imported files as such to comply more closely with GPL ¡ø2a.
diego
parents:
12799
diff
changeset
|
6 */ |
8dd7a656eaf8
Mark modified imported files as such to comply more closely with GPL ¡ø2a.
diego
parents:
12799
diff
changeset
|
7 |
3686 | 8 #include <stdlib.h> |
9 #include <string.h> | |
3716 | 10 #include <unistd.h> |
3686 | 11 #include <stdlib.h> |
12 #include <stdio.h> | |
13 #include <sys/types.h> | |
15585 | 14 #include <ctype.h> |
10281 | 15 #include "config.h" |
16 #ifndef HAVE_WINSOCK2 | |
17 #include <netinet/in.h> | |
3686 | 18 #include <sys/socket.h> |
19 #include <arpa/inet.h> | |
15585 | 20 #define closesocket close |
10281 | 21 #else |
22 #include <winsock2.h> | |
23 #include <ws2tcpip.h> | |
24 #endif | |
15585 | 25 #include <errno.h> |
26 #include "stream.h" | |
3686 | 27 |
28 /* MPEG-2 TS RTP stack */ | |
29 | |
30 #define DEBUG 1 | |
31 #include "rtp.h" | |
32 | |
15585 | 33 |
18802
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
34 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
35 #define DEBUG 1 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
36 #include "../mp_msg.h" |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
37 #include "rtp.h" |
15585 | 38 |
18802
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
39 // RTP reorder routines |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
40 // Also handling of repeated UDP packets (a bug of ExtremeNetworks switches firmware) |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
41 // rtpreord procedures |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
42 // write rtp packets in cache |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
43 // get rtp packets reordered |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
44 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
45 #define MAXRTPPACKETSIN 32 // The number of max packets being reordered |
15585 | 46 |
18802
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
47 struct rtpbuffer |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
48 { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
49 unsigned char data[MAXRTPPACKETSIN][STREAM_BUFFER_SIZE]; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
50 unsigned short seq[MAXRTPPACKETSIN]; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
51 unsigned short len[MAXRTPPACKETSIN]; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
52 unsigned short first; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
53 }; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
54 static struct rtpbuffer rtpbuf; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
55 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
56 // RTP Reordering functions |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
57 // Algorithm works as follows: |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
58 // If next packet is in sequence just copy it to buffer |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
59 // Otherwise copy it in cache according to its sequence number |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
60 // Cache is a circular array where "rtpbuf.first" points to next sequence slot |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
61 // and keeps track of expected sequence |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
62 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
63 // Initialize rtp cache |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
64 static void rtp_cache_reset(unsigned short seq) |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
65 { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
66 int i; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
67 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
68 rtpbuf.first = 0; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
69 rtpbuf.seq[0] = ++seq; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
70 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
71 for (i=0; i<MAXRTPPACKETSIN; i++) { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
72 rtpbuf.len[i] = 0; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
73 } |
15585 | 74 } |
75 | |
18802
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
76 // Write in a cache the rtp packet in right rtp sequence order |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
77 static int rtp_cache(int fd, char *buffer, int length) |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
78 { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
79 struct rtpheader rh; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
80 int newseq; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
81 char *data; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
82 unsigned short seq; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
83 static int is_first = 1; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
84 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
85 getrtp2(fd, &rh, &data, &length); |
18805
1f8d9010ce2f
exit() is not allowed in any other function than main(); removed
nicodvb
parents:
18804
diff
changeset
|
86 if(!length) |
1f8d9010ce2f
exit() is not allowed in any other function than main(); removed
nicodvb
parents:
18804
diff
changeset
|
87 return 0; |
18802
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
88 seq = rh.b.sequence; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
89 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
90 newseq = seq - rtpbuf.seq[rtpbuf.first]; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
91 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
92 if ((newseq == 0) || is_first) |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
93 { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
94 is_first = 0; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
95 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
96 //mp_msg(MSGT_NETWORK, MSGL_DBG4, "RTP (seq[%d]=%d seq=%d, newseq=%d)\n", rtpbuf.first, rtpbuf.seq[rtpbuf.first], seq, newseq); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
97 rtpbuf.first = ( 1 + rtpbuf.first ) % MAXRTPPACKETSIN; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
98 rtpbuf.seq[rtpbuf.first] = ++seq; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
99 goto feed; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
100 } |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
101 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
102 if (newseq > MAXRTPPACKETSIN) |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
103 { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
104 mp_msg(MSGT_NETWORK, MSGL_DBG2, "Overrun(seq[%d]=%d seq=%d, newseq=%d)\n", rtpbuf.first, rtpbuf.seq[rtpbuf.first], seq, newseq); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
105 rtp_cache_reset(seq); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
106 goto feed; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
107 } |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
108 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
109 if (newseq < 0) |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
110 { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
111 int i; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
112 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
113 // Is it a stray packet re-sent to network? |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
114 for (i=0; i<MAXRTPPACKETSIN; i++) { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
115 if (rtpbuf.seq[i] == seq) { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
116 mp_msg(MSGT_NETWORK, MSGL_ERR, "Stray packet (seq[%d]=%d seq=%d, newseq=%d found at %d)\n", rtpbuf.first, rtpbuf.seq[rtpbuf.first], seq, newseq, i); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
117 return 0; // Yes, it is! |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
118 } |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
119 } |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
120 // Some heuristic to decide when to drop packet or to restart everything |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
121 if (newseq > -(3 * MAXRTPPACKETSIN)) { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
122 mp_msg(MSGT_NETWORK, MSGL_ERR, "Too Old packet (seq[%d]=%d seq=%d, newseq=%d)\n", rtpbuf.first, rtpbuf.seq[rtpbuf.first], seq, newseq); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
123 return 0; // Yes, it is! |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
124 } |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
125 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
126 mp_msg(MSGT_NETWORK, MSGL_ERR, "Underrun(seq[%d]=%d seq=%d, newseq=%d)\n", rtpbuf.first, rtpbuf.seq[rtpbuf.first], seq, newseq); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
127 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
128 rtp_cache_reset(seq); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
129 goto feed; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
130 } |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
131 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
132 mp_msg(MSGT_NETWORK, MSGL_DBG4, "Out of Seq (seq[%d]=%d seq=%d, newseq=%d)\n", rtpbuf.first, rtpbuf.seq[rtpbuf.first], seq, newseq); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
133 newseq = ( newseq + rtpbuf.first ) % MAXRTPPACKETSIN; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
134 memcpy (rtpbuf.data[newseq], data, length); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
135 rtpbuf.len[newseq] = length; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
136 rtpbuf.seq[newseq] = seq; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
137 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
138 return 0; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
139 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
140 feed: |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
141 memcpy (buffer, data, length); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
142 return length; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
143 } |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
144 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
145 // Get next packet in cache |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
146 // Look in cache to get first packet in sequence |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
147 static int rtp_get_next(int fd, char *buffer, int length) |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
148 { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
149 int i; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
150 unsigned short nextseq; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
151 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
152 // If we have empty buffer we loop to fill it |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
153 for (i=0; i < MAXRTPPACKETSIN -3; i++) { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
154 if (rtpbuf.len[rtpbuf.first] != 0) break; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
155 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
156 length = rtp_cache(fd, buffer, length) ; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
157 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
158 // returns on first packet in sequence |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
159 if (length > 0) { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
160 //mp_msg(MSGT_NETWORK, MSGL_DBG4, "Getting rtp [%d] %hu\n", i, rtpbuf.first); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
161 return length; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
162 } else if (length < 0) break; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
163 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
164 // Only if length == 0 loop continues! |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
165 } |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
166 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
167 i = rtpbuf.first; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
168 while (rtpbuf.len[i] == 0) { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
169 mp_msg(MSGT_NETWORK, MSGL_ERR, "Lost packet %hu\n", rtpbuf.seq[i]); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
170 i = ( 1 + i ) % MAXRTPPACKETSIN; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
171 if (rtpbuf.first == i) break; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
172 } |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
173 rtpbuf.first = i; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
174 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
175 // Copy next non empty packet from cache |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
176 mp_msg(MSGT_NETWORK, MSGL_DBG4, "Getting rtp from cache [%d] %hu\n", rtpbuf.first, rtpbuf.seq[rtpbuf.first]); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
177 memcpy (buffer, rtpbuf.data[rtpbuf.first], rtpbuf.len[rtpbuf.first]); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
178 length = rtpbuf.len[rtpbuf.first]; // can be zero? |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
179 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
180 // Reset fisrt slot and go next in cache |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
181 rtpbuf.len[rtpbuf.first] = 0; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
182 nextseq = rtpbuf.seq[rtpbuf.first]; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
183 rtpbuf.first = ( 1 + rtpbuf.first ) % MAXRTPPACKETSIN; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
184 rtpbuf.seq[rtpbuf.first] = nextseq + 1; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
185 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
186 return length; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
187 } |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
188 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
189 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
190 // Read next rtp packet using cache |
18829
317e0fd394c5
added new native rtsp demuxer code for mpeg-ts over rtp (now both real and non-real servers should be handled)
ben
parents:
18805
diff
changeset
|
191 int read_rtp_from_server(int fd, char *buffer, int length) { |
18802
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
192 // Following test is ASSERT (i.e. uneuseful if code is correct) |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
193 if(buffer==NULL || length<STREAM_BUFFER_SIZE) { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
194 mp_msg(MSGT_NETWORK, MSGL_ERR, "RTP buffer invalid; no data return from network\n"); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
195 return 0; |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
196 } |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
197 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
198 // loop just to skip empty packets |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
199 while ((length = rtp_get_next(fd, buffer, length)) == 0) { |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
200 mp_msg(MSGT_NETWORK, MSGL_ERR, "Got empty packet from RTP cache!?\n"); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
201 } |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
202 |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
203 return(length); |
b52ed08b17ad
rtp reordering of packets; patch by Ernitron (ernitron@fastwebnet.it)
nicodvb
parents:
18783
diff
changeset
|
204 } |
15585 | 205 |
206 // Start listening on a UDP port. If multicast, join the group. | |
19313
0792ad01e9bf
split rtp stack, udp input layer and rtp input layer from rtp.c
ben
parents:
19271
diff
changeset
|
207 int rtp_open_socket( URL_t *url ) { |
15585 | 208 int socket_server_fd, rxsockbufsz; |
209 int err, err_len; | |
210 fd_set set; | |
211 struct sockaddr_in server_address; | |
212 struct ip_mreq mcast; | |
213 struct timeval tv; | |
214 struct hostent *hp; | |
215 | |
216 mp_msg(MSGT_NETWORK,MSGL_V,"Listening for traffic on %s:%d ...\n", url->hostname, url->port ); | |
217 | |
218 socket_server_fd = socket(AF_INET, SOCK_DGRAM, 0); | |
219 // fcntl( socket_server_fd, F_SETFL, fcntl(socket_server_fd, F_GETFL) | O_NONBLOCK ); | |
220 if( socket_server_fd==-1 ) { | |
221 mp_msg(MSGT_NETWORK,MSGL_ERR,"Failed to create socket\n"); | |
222 return -1; | |
223 } | |
224 | |
225 if( isalpha(url->hostname[0]) ) { | |
226 #ifndef HAVE_WINSOCK2 | |
227 hp =(struct hostent*)gethostbyname( url->hostname ); | |
228 if( hp==NULL ) { | |
229 mp_msg(MSGT_NETWORK,MSGL_ERR,"Counldn't resolve name: %s\n", url->hostname); | |
15760
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
230 goto err_out; |
15585 | 231 } |
18466 | 232 memcpy( (void*)&server_address.sin_addr.s_addr, (void*)hp->h_addr_list[0], hp->h_length ); |
15585 | 233 #else |
234 server_address.sin_addr.s_addr = htonl(INADDR_ANY); | |
235 #endif | |
236 } else { | |
237 #ifndef HAVE_WINSOCK2 | |
238 #ifdef USE_ATON | |
239 inet_aton(url->hostname, &server_address.sin_addr); | |
240 #else | |
241 inet_pton(AF_INET, url->hostname, &server_address.sin_addr); | |
242 #endif | |
243 #else | |
244 server_address.sin_addr.s_addr = htonl(INADDR_ANY); | |
245 #endif | |
246 } | |
247 server_address.sin_family=AF_INET; | |
248 server_address.sin_port=htons(url->port); | |
249 | |
250 if( bind( socket_server_fd, (struct sockaddr*)&server_address, sizeof(server_address) )==-1 ) { | |
251 #ifndef HAVE_WINSOCK2 | |
252 if( errno!=EINPROGRESS ) { | |
253 #else | |
254 if( WSAGetLastError() != WSAEINPROGRESS ) { | |
255 #endif | |
256 mp_msg(MSGT_NETWORK,MSGL_ERR,"Failed to connect to server\n"); | |
15760
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
257 goto err_out; |
15585 | 258 } |
259 } | |
260 | |
261 #ifdef HAVE_WINSOCK2 | |
262 if (isalpha(url->hostname[0])) { | |
263 hp =(struct hostent*)gethostbyname( url->hostname ); | |
264 if( hp==NULL ) { | |
265 mp_msg(MSGT_NETWORK,MSGL_ERR,"Counldn't resolve name: %s\n", url->hostname); | |
15760
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
266 goto err_out; |
15585 | 267 } |
268 memcpy( (void*)&server_address.sin_addr.s_addr, (void*)hp->h_addr, hp->h_length ); | |
269 } else { | |
270 unsigned int addr = inet_addr(url->hostname); | |
271 memcpy( (void*)&server_address.sin_addr, (void*)&addr, sizeof(addr) ); | |
272 } | |
273 #endif | |
274 | |
275 // Increase the socket rx buffer size to maximum -- this is UDP | |
276 rxsockbufsz = 240 * 1024; | |
277 if( setsockopt( socket_server_fd, SOL_SOCKET, SO_RCVBUF, &rxsockbufsz, sizeof(rxsockbufsz))) { | |
278 mp_msg(MSGT_NETWORK,MSGL_ERR,"Couldn't set receive socket buffer size\n"); | |
279 } | |
280 | |
281 if((ntohl(server_address.sin_addr.s_addr) >> 28) == 0xe) { | |
282 mcast.imr_multiaddr.s_addr = server_address.sin_addr.s_addr; | |
283 //mcast.imr_interface.s_addr = inet_addr("10.1.1.2"); | |
284 mcast.imr_interface.s_addr = 0; | |
285 if( setsockopt( socket_server_fd, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mcast, sizeof(mcast))) { | |
286 mp_msg(MSGT_NETWORK,MSGL_ERR,"IP_ADD_MEMBERSHIP failed (do you have multicasting enabled in your kernel?)\n"); | |
15760
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
287 goto err_out; |
15585 | 288 } |
289 } | |
290 | |
291 tv.tv_sec = 0; | |
292 tv.tv_usec = (1 * 1000000); // 1 second timeout | |
293 FD_ZERO( &set ); | |
294 FD_SET( socket_server_fd, &set ); | |
15760
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
295 err = select(socket_server_fd+1, &set, NULL, NULL, &tv); |
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
296 if (err < 0) { |
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
297 mp_msg(MSGT_NETWORK, MSGL_FATAL, "Select failed: %s\n", strerror(errno)); |
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
298 goto err_out; |
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
299 } |
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
300 if (err == 0) { |
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
301 mp_msg(MSGT_NETWORK,MSGL_ERR,"Timeout! No data from host %s\n", url->hostname ); |
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
302 goto err_out; |
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
303 } |
15585 | 304 err_len = sizeof( err ); |
305 getsockopt( socket_server_fd, SOL_SOCKET, SO_ERROR, &err, &err_len ); | |
306 if( err ) { | |
307 mp_msg(MSGT_NETWORK,MSGL_DBG2,"Socket error: %d\n", err ); | |
15760
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
308 goto err_out; |
15585 | 309 } |
310 return socket_server_fd; | |
15760
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
311 |
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
312 err_out: |
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
313 closesocket(socket_server_fd); |
5dcc5524cb68
fix wrong usage of select() (based on patch by Selwyn Tang selwyn hectrix com),
reimar
parents:
15585
diff
changeset
|
314 return -1; |
15585 | 315 } |
316 | |
18803 | 317 static int getrtp2(int fd, struct rtpheader *rh, char** data, int* lengthData) { |
3686 | 318 static char buf[1600]; |
319 unsigned int intP; | |
320 char* charP = (char*) &intP; | |
321 int headerSize; | |
322 int lengthPacket; | |
323 lengthPacket=recv(fd,buf,1590,0); | |
18805
1f8d9010ce2f
exit() is not allowed in any other function than main(); removed
nicodvb
parents:
18804
diff
changeset
|
324 if (lengthPacket<0) |
18804 | 325 mp_msg(MSGT_NETWORK,MSGL_ERR,"rtp: socket read error\n"); |
18805
1f8d9010ce2f
exit() is not allowed in any other function than main(); removed
nicodvb
parents:
18804
diff
changeset
|
326 else if (lengthPacket<12) |
18804 | 327 mp_msg(MSGT_NETWORK,MSGL_ERR,"rtp: packet too small (%d) to be an rtp frame (>12bytes)\n", lengthPacket); |
18805
1f8d9010ce2f
exit() is not allowed in any other function than main(); removed
nicodvb
parents:
18804
diff
changeset
|
328 if(lengthPacket<12) { |
1f8d9010ce2f
exit() is not allowed in any other function than main(); removed
nicodvb
parents:
18804
diff
changeset
|
329 *lengthData = 0; |
1f8d9010ce2f
exit() is not allowed in any other function than main(); removed
nicodvb
parents:
18804
diff
changeset
|
330 return 0; |
3686 | 331 } |
332 rh->b.v = (unsigned int) ((buf[0]>>6)&0x03); | |
333 rh->b.p = (unsigned int) ((buf[0]>>5)&0x01); | |
334 rh->b.x = (unsigned int) ((buf[0]>>4)&0x01); | |
335 rh->b.cc = (unsigned int) ((buf[0]>>0)&0x0f); | |
336 rh->b.m = (unsigned int) ((buf[1]>>7)&0x01); | |
337 rh->b.pt = (unsigned int) ((buf[1]>>0)&0x7f); | |
338 intP = 0; | |
339 memcpy(charP+2,&buf[2],2); | |
340 rh->b.sequence = ntohl(intP); | |
341 intP = 0; | |
342 memcpy(charP,&buf[4],4); | |
343 rh->timestamp = ntohl(intP); | |
344 | |
345 headerSize = 12 + 4*rh->b.cc; /* in bytes */ | |
346 | |
347 *lengthData = lengthPacket - headerSize; | |
348 *data = (char*) buf + headerSize; | |
349 | |
18804 | 350 // mp_msg(MSGT_NETWORK,MSGL_DBG2,"Reading rtp: v=%x p=%x x=%x cc=%x m=%x pt=%x seq=%x ts=%x lgth=%d\n",rh->b.v,rh->b.p,rh->b.x,rh->b.cc,rh->b.m,rh->b.pt,rh->b.sequence,rh->timestamp,lengthPacket); |
3686 | 351 |
352 return(0); | |
353 } |