summaryrefslogtreecommitdiff
authorllornkcor <llornkcor>2002-04-20 19:21:08 (UTC)
committer llornkcor <llornkcor>2002-04-20 19:21:08 (UTC)
commit0169070eeca0ef41d33c4e8b2feee9c90f34f6ae (patch) (unidiff)
tree638ccb275c98056b4a9ca9ec09d15b1a7636bb6c
parentb8bdd6ceaab890f8b35492a11e13bcdb101b1220 (diff)
downloadopie-0169070eeca0ef41d33c4e8b2feee9c90f34f6ae.zip
opie-0169070eeca0ef41d33c4e8b2feee9c90f34f6ae.tar.gz
opie-0169070eeca0ef41d33c4e8b2feee9c90f34f6ae.tar.bz2
MediaPlayer to OpiePlayer
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--core/multimedia/opieplayer/libmad/libmadplugin.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/core/multimedia/opieplayer/libmad/libmadplugin.cpp b/core/multimedia/opieplayer/libmad/libmadplugin.cpp
index 0fcc230..7bb6541 100644
--- a/core/multimedia/opieplayer/libmad/libmadplugin.cpp
+++ b/core/multimedia/opieplayer/libmad/libmadplugin.cpp
@@ -1,376 +1,376 @@
1/********************************************************************** 1/**********************************************************************
2** Copyright (C) 2001 Trolltech AS. All rights reserved. 2** Copyright (C) 2001 Trolltech AS. All rights reserved.
3** 3**
4** This file is part of Qtopia Environment. 4** This file is part of Qtopia Environment.
5** 5**
6** This file may be distributed and/or modified under the terms of the 6** This file may be distributed and/or modified under the terms of the
7** GNU General Public License version 2 as published by the Free Software 7** GNU General Public License version 2 as published by the Free Software
8** Foundation and appearing in the file LICENSE.GPL included in the 8** Foundation and appearing in the file LICENSE.GPL included in the
9** packaging of this file. 9** packaging of this file.
10** 10**
11** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE 11** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
12** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE. 12** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
13** 13**
14** See http://www.trolltech.com/gpl/ for GPL licensing information. 14** See http://www.trolltech.com/gpl/ for GPL licensing information.
15** 15**
16** Contact info@trolltech.com if any conditions of this licensing are 16** Contact info@trolltech.com if any conditions of this licensing are
17** not clear to you. 17** not clear to you.
18** 18**
19**********************************************************************/ 19**********************************************************************/
20#include <stdio.h> 20#include <stdio.h>
21#include <stdarg.h> 21#include <stdarg.h>
22#include <stdlib.h> 22#include <stdlib.h>
23#include <sys/types.h> 23#include <sys/types.h>
24#include <sys/stat.h> 24#include <sys/stat.h>
25#include <fcntl.h> 25#include <fcntl.h>
26#include <unistd.h> 26#include <unistd.h>
27#include <string.h> 27#include <string.h>
28#include <ctype.h> 28#include <ctype.h>
29#include <errno.h> 29#include <errno.h>
30#include <time.h> 30#include <time.h>
31#include <locale.h> 31#include <locale.h>
32#include <math.h> 32#include <math.h>
33#include <assert.h> 33#include <assert.h>
34#include <qapplication.h> 34#include <qapplication.h>
35#include <qpe/config.h> 35#include <qpe/config.h>
36 36
37// for network handling 37// for network handling
38#include <netinet/in.h> 38#include <netinet/in.h>
39#include <netdb.h> 39#include <netdb.h>
40#include <sys/socket.h> 40#include <sys/socket.h>
41#include <arpa/inet.h> 41#include <arpa/inet.h>
42#include <unistd.h> 42#include <unistd.h>
43 43
44 44
45//#define HAVE_MMAP 45//#define HAVE_MMAP
46 46
47#if defined(HAVE_MMAP) 47#if defined(HAVE_MMAP)
48# include <sys/mman.h> 48# include <sys/mman.h>
49#endif 49#endif
50#include "libmadplugin.h" 50#include "libmadplugin.h"
51 51
52 52
53extern "C" { 53extern "C" {
54#include "mad.h" 54#include "mad.h"
55} 55}
56 56
57 57
58#define MPEG_BUFFER_SIZE 65536 58#define MPEG_BUFFER_SIZE 65536
59//#define MPEG_BUFFER_SIZE 32768 //16384 // 8192 59//#define MPEG_BUFFER_SIZE 32768 //16384 // 8192
60//#define debugMsg(a) qDebug(a) 60//#define debugMsg(a) qDebug(a)
61#define debugMsg(a) 61#define debugMsg(a)
62 62
63 63
64class Input { 64class Input {
65public: 65public:
66 char const *path; 66 char const *path;
67 int fd; 67 int fd;
68#if defined(HAVE_MMAP) 68#if defined(HAVE_MMAP)
69 void *fdm; 69 void *fdm;
70#endif 70#endif
71 unsigned char *data; 71 unsigned char *data;
72 unsigned long length; 72 unsigned long length;
73 int eof; 73 int eof;
74}; 74};
75 75
76 76
77class Output { 77class Output {
78public: 78public:
79 mad_fixed_t attenuate; 79 mad_fixed_t attenuate;
80 struct filter *filters; 80 struct filter *filters;
81 unsigned int channels_in; 81 unsigned int channels_in;
82 unsigned int channels_out; 82 unsigned int channels_out;
83 unsigned int speed_in; 83 unsigned int speed_in;
84 unsigned int speed_out; 84 unsigned int speed_out;
85 const char *path; 85 const char *path;
86}; 86};
87 87
88 88
89# if defined(HAVE_MMAP) 89# if defined(HAVE_MMAP)
90static void *map_file(int fd, unsigned long *length) 90static void *map_file(int fd, unsigned long *length)
91{ 91{
92 void *fdm; 92 void *fdm;
93 93
94 *length += MAD_BUFFER_GUARD; 94 *length += MAD_BUFFER_GUARD;
95 95
96 fdm = mmap(0, *length, PROT_READ, MAP_SHARED, fd, 0); 96 fdm = mmap(0, *length, PROT_READ, MAP_SHARED, fd, 0);
97 if (fdm == MAP_FAILED) 97 if (fdm == MAP_FAILED)
98 return 0; 98 return 0;
99 99
100# if defined(HAVE_MADVISE) 100# if defined(HAVE_MADVISE)
101 madvise(fdm, *length, MADV_SEQUENTIAL); 101 madvise(fdm, *length, MADV_SEQUENTIAL);
102# endif 102# endif
103 103
104 return fdm; 104 return fdm;
105} 105}
106 106
107 107
108static int unmap_file(void *fdm, unsigned long length) 108static int unmap_file(void *fdm, unsigned long length)
109{ 109{
110 if (munmap(fdm, length) == -1) 110 if (munmap(fdm, length) == -1)
111 return -1; 111 return -1;
112 112
113 return 0; 113 return 0;
114} 114}
115# endif 115# endif
116 116
117 117
118static inline QString tr( const char *str ) { 118static inline QString tr( const char *str ) {
119 // Apparently this is okay from a plugin as it runs in the process space of the owner of the plugin 119 // Apparently this is okay from a plugin as it runs in the process space of the owner of the plugin
120 return qApp->translate( "MediaPlayer", str, "libmad strings for mp3 file info" ); 120 return qApp->translate( "OpiePlayer", str, "libmad strings for mp3 file info" );
121} 121}
122 122
123 123
124class LibMadPluginData { 124class LibMadPluginData {
125public: 125public:
126 Input input; 126 Input input;
127 Output output; 127 Output output;
128 int bad_last_frame; 128 int bad_last_frame;
129 struct mad_stream stream; 129 struct mad_stream stream;
130 struct mad_frame frame; 130 struct mad_frame frame;
131 struct mad_synth synth; 131 struct mad_synth synth;
132 bool flush; 132 bool flush;
133}; 133};
134 134
135 135
136LibMadPlugin::LibMadPlugin() { 136LibMadPlugin::LibMadPlugin() {
137 d = new LibMadPluginData; 137 d = new LibMadPluginData;
138 d->input.fd = 0; 138 d->input.fd = 0;
139#if defined(HAVE_MMAP) 139#if defined(HAVE_MMAP)
140 d->input.fdm = 0; 140 d->input.fdm = 0;
141#endif 141#endif
142 d->input.data = 0; 142 d->input.data = 0;
143 d->flush = TRUE; 143 d->flush = TRUE;
144 info = tr( "No Song Open" ); 144 info = tr( "No Song Open" );
145} 145}
146 146
147 147
148LibMadPlugin::~LibMadPlugin() { 148LibMadPlugin::~LibMadPlugin() {
149 close(); 149 close();
150 delete d; 150 delete d;
151} 151}
152 152
153 153
154bool LibMadPlugin::isFileSupported( const QString& path ) { 154bool LibMadPlugin::isFileSupported( const QString& path ) {
155 debugMsg( "LibMadPlugin::isFileSupported" ); 155 debugMsg( "LibMadPlugin::isFileSupported" );
156 156
157 // Mpeg file extensions 157 // Mpeg file extensions
158 // "mp2","mp3","m1v","m2v","m2s","mpg","vob","mpeg","ac3" 158 // "mp2","mp3","m1v","m2v","m2s","mpg","vob","mpeg","ac3"
159 // Other media extensions 159 // Other media extensions
160 // "wav","mid","mod","s3m","ogg","avi","mov","sid" 160 // "wav","mid","mod","s3m","ogg","avi","mov","sid"
161 161
162 char *ext = strrchr( path.latin1(), '.' ); 162 char *ext = strrchr( path.latin1(), '.' );
163 163
164 // Test file extension 164 // Test file extension
165 if ( ext ) { 165 if ( ext ) {
166 if ( strncasecmp(ext, ".mp2", 4) == 0 ) 166 if ( strncasecmp(ext, ".mp2", 4) == 0 )
167 return TRUE; 167 return TRUE;
168 if ( strncasecmp(ext, ".mp3", 4) == 0 ) 168 if ( strncasecmp(ext, ".mp3", 4) == 0 )
169 return TRUE; 169 return TRUE;
170 } 170 }
171 // UGLY - just for fast testing 171 // UGLY - just for fast testing
172 if ( path.left(4) == "http") { 172 if ( path.left(4) == "http") {
173 return TRUE; 173 return TRUE;
174 } 174 }
175 175
176 176
177 return FALSE; 177 return FALSE;
178} 178}
179 179
180 180
181int LibMadPlugin::tcp_open(char *address, int port) { 181int LibMadPlugin::tcp_open(char *address, int port) {
182 struct sockaddr_in stAddr; 182 struct sockaddr_in stAddr;
183 struct hostent *host; 183 struct hostent *host;
184 int sock; 184 int sock;
185 struct linger l; 185 struct linger l;
186 186
187 memset(&stAddr, 0, sizeof(stAddr)); 187 memset(&stAddr, 0, sizeof(stAddr));
188 stAddr.sin_family = AF_INET; 188 stAddr.sin_family = AF_INET;
189 stAddr.sin_port = htons(port); 189 stAddr.sin_port = htons(port);
190 190
191 if ((host = gethostbyname(address)) == NULL) 191 if ((host = gethostbyname(address)) == NULL)
192 return (0); 192 return (0);
193 193
194 stAddr.sin_addr = *((struct in_addr *)host->h_addr_list[0]); 194 stAddr.sin_addr = *((struct in_addr *)host->h_addr_list[0]);
195 195
196 if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0) 196 if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0)
197 return (0); 197 return (0);
198 198
199 l.l_onoff = 1; 199 l.l_onoff = 1;
200 l.l_linger = 5; 200 l.l_linger = 5;
201 if (setsockopt(sock, SOL_SOCKET, SO_LINGER, (char *)&l, sizeof(l)) < 0) 201 if (setsockopt(sock, SOL_SOCKET, SO_LINGER, (char *)&l, sizeof(l)) < 0)
202 return (0); 202 return (0);
203 203
204 if (connect(sock, (struct sockaddr *)&stAddr, sizeof(stAddr)) < 0) 204 if (connect(sock, (struct sockaddr *)&stAddr, sizeof(stAddr)) < 0)
205 return (0); 205 return (0);
206 206
207 return (sock); 207 return (sock);
208} 208}
209 209
210 210
211/** 211/**
212 * Read a http line header. 212 * Read a http line header.
213 * This function read character by character. 213 * This function read character by character.
214 * @param tcp_sock the socket use to read the stream 214 * @param tcp_sock the socket use to read the stream
215 * @param buf a buffer to receive the data 215 * @param buf a buffer to receive the data
216 * @param size size of the buffer 216 * @param size size of the buffer
217 * @return the size of the stream read or -1 if an error occured 217 * @return the size of the stream read or -1 if an error occured
218 */ 218 */
219int LibMadPlugin::http_read_line(int tcp_sock, char *buf, int size) { 219int LibMadPlugin::http_read_line(int tcp_sock, char *buf, int size) {
220 int offset = 0; 220 int offset = 0;
221 221
222 do 222 do
223 { 223 {
224 if (std::read(tcp_sock, buf + offset, 1) < 0) 224 if (std::read(tcp_sock, buf + offset, 1) < 0)
225 return -1; 225 return -1;
226 if (buf[offset] != '\r') /* Strip \r from answer */ 226 if (buf[offset] != '\r') /* Strip \r from answer */
227 offset++; 227 offset++;
228 } 228 }
229 while (offset < size - 1 && buf[offset - 1] != '\n'); 229 while (offset < size - 1 && buf[offset - 1] != '\n');
230 230
231 buf[offset] = 0; 231 buf[offset] = 0;
232 return offset; 232 return offset;
233} 233}
234 234
235int LibMadPlugin::http_open(const QString& path ) { 235int LibMadPlugin::http_open(const QString& path ) {
236 char *host; 236 char *host;
237 int port; 237 int port;
238 char *request; 238 char *request;
239 int tcp_sock; 239 int tcp_sock;
240 char http_request[PATH_MAX]; 240 char http_request[PATH_MAX];
241 char filename[PATH_MAX]; 241 char filename[PATH_MAX];
242 char c; 242 char c;
243 char *arg =strdup(path.latin1()); 243 char *arg =strdup(path.latin1());
244 244
245 /* Check for URL syntax */ 245 /* Check for URL syntax */
246 if (strncmp(arg, "http://", strlen("http://"))) 246 if (strncmp(arg, "http://", strlen("http://")))
247 return (0); 247 return (0);
248 248
249 /* Parse URL */ 249 /* Parse URL */
250 port = 80; 250 port = 80;
251 host = arg + strlen("http://"); 251 host = arg + strlen("http://");
252 if ((request = strchr(host, '/')) == NULL) 252 if ((request = strchr(host, '/')) == NULL)
253 return (0); 253 return (0);
254 *request++ = 0; 254 *request++ = 0;
255 255
256 if (strchr(host, ':') != NULL) /* port is specified */ 256 if (strchr(host, ':') != NULL) /* port is specified */
257 { 257 {
258 port = atoi(strchr(host, ':') + 1); 258 port = atoi(strchr(host, ':') + 1);
259 *strchr(host, ':') = 0; 259 *strchr(host, ':') = 0;
260 } 260 }
261 261
262 /* Open a TCP socket */ 262 /* Open a TCP socket */
263 if (!(tcp_sock = tcp_open(host, port))) 263 if (!(tcp_sock = tcp_open(host, port)))
264 { 264 {
265 perror("http_open"); 265 perror("http_open");
266 return (0); 266 return (0);
267 } 267 }
268 268
269 snprintf(filename, sizeof(filename) - strlen(host) - 75, "%s", request); 269 snprintf(filename, sizeof(filename) - strlen(host) - 75, "%s", request);
270 270
271 /* Send HTTP GET request */ 271 /* Send HTTP GET request */
272 /* Please don't use a Agent know by shoutcast (Lynx, Mozilla) seems to be reconized and print 272 /* Please don't use a Agent know by shoutcast (Lynx, Mozilla) seems to be reconized and print
273 * a html page and not the stream */ 273 * a html page and not the stream */
274 snprintf(http_request, sizeof(http_request), "GET /%s HTTP/1.0\r\n" 274 snprintf(http_request, sizeof(http_request), "GET /%s HTTP/1.0\r\n"
275/* "User-Agent: Mozilla/2.0 (Win95; I)\r\n" */ 275/* "User-Agent: Mozilla/2.0 (Win95; I)\r\n" */
276 "Pragma: no-cache\r\n" "Host: %s\r\n" "Accept: */*\r\n" "\r\n", filename, host); 276 "Pragma: no-cache\r\n" "Host: %s\r\n" "Accept: */*\r\n" "\r\n", filename, host);
277 277
278 send(tcp_sock, http_request, strlen(http_request), 0); 278 send(tcp_sock, http_request, strlen(http_request), 0);
279 279
280 /* Parse server reply */ 280 /* Parse server reply */
281#if 0 281#if 0
282 do 282 do
283 read(tcp_sock, &c, sizeof(char)); 283 read(tcp_sock, &c, sizeof(char));
284 while (c != ' '); 284 while (c != ' ');
285 read(tcp_sock, http_request, 4 * sizeof(char)); 285 read(tcp_sock, http_request, 4 * sizeof(char));
286 http_request[4] = 0; 286 http_request[4] = 0;
287 if (strcmp(http_request, "200 ")) 287 if (strcmp(http_request, "200 "))
288 { 288 {
289 fprintf(stderr, "http_open: "); 289 fprintf(stderr, "http_open: ");
290 do 290 do
291 { 291 {
292 read(tcp_sock, &c, sizeof(char)); 292 read(tcp_sock, &c, sizeof(char));
293 fprintf(stderr, "%c", c); 293 fprintf(stderr, "%c", c);
294 } 294 }
295 while (c != '\r'); 295 while (c != '\r');
296 fprintf(stderr, "\n"); 296 fprintf(stderr, "\n");
297 return (0); 297 return (0);
298 } 298 }
299#endif 299#endif
300 300
301 do 301 do
302 { 302 {
303 int len; 303 int len;
304 304
305 len = http_read_line(tcp_sock, http_request, sizeof(http_request)); 305 len = http_read_line(tcp_sock, http_request, sizeof(http_request));
306 306
307 if (len == -1) 307 if (len == -1)
308 { 308 {
309 fprintf(stderr, "http_open: %s\n", strerror(errno)); 309 fprintf(stderr, "http_open: %s\n", strerror(errno));
310 return 0; 310 return 0;
311 } 311 }
312 312
313 if (strncmp(http_request, "Location:", 9) == 0) 313 if (strncmp(http_request, "Location:", 9) == 0)
314 { 314 {
315 /* redirect */ 315 /* redirect */
316 std::close(tcp_sock); 316 std::close(tcp_sock);
317 317
318 http_request[strlen(http_request) - 1] = '\0'; 318 http_request[strlen(http_request) - 1] = '\0';
319 319
320 return http_open(&http_request[10]); 320 return http_open(&http_request[10]);
321 } 321 }
322 322
323 if (strncmp(http_request, "ICY ", 4) == 0) 323 if (strncmp(http_request, "ICY ", 4) == 0)
324 { 324 {
325 /* This is icecast streaming */ 325 /* This is icecast streaming */
326 if (strncmp(http_request + 4, "200 ", 4)) 326 if (strncmp(http_request + 4, "200 ", 4))
327 { 327 {
328 fprintf(stderr, "http_open: %s\n", http_request); 328 fprintf(stderr, "http_open: %s\n", http_request);
329 return 0; 329 return 0;
330 } 330 }
331 } 331 }
332 else if (strncmp(http_request, "icy-", 4) == 0) 332 else if (strncmp(http_request, "icy-", 4) == 0)
333 { 333 {
334 /* we can have: icy-noticeX, icy-name, icy-genre, icy-url, icy-pub, icy-metaint, icy-br */ 334 /* we can have: icy-noticeX, icy-name, icy-genre, icy-url, icy-pub, icy-metaint, icy-br */
335 /* Don't print these - mpg123 doesn't */ 335 /* Don't print these - mpg123 doesn't */
336 /* fprintf(stderr,"%s\n",http_request); */ 336 /* fprintf(stderr,"%s\n",http_request); */
337 } 337 }
338 } 338 }
339 while (strcmp(http_request, "\n") != 0); 339 while (strcmp(http_request, "\n") != 0);
340 340
341 return (tcp_sock); 341 return (tcp_sock);
342} 342}
343 343
344 344
345bool LibMadPlugin::open( const QString& path ) { 345bool LibMadPlugin::open( const QString& path ) {
346 debugMsg( "LibMadPlugin::open" ); 346 debugMsg( "LibMadPlugin::open" );
347 Config cfg("MediaPlayer"); 347 Config cfg("MediaPlayer");
348 cfg.setGroup("Options"); 348 cfg.setGroup("Options");
349 bufferSize = cfg.readNumEntry("MPeg_BufferSize",MPEG_BUFFER_SIZE); 349 bufferSize = cfg.readNumEntry("MPeg_BufferSize",MPEG_BUFFER_SIZE);
350 qDebug("buffer size is %d", bufferSize); 350 qDebug("buffer size is %d", bufferSize);
351 d->bad_last_frame = 0; 351 d->bad_last_frame = 0;
352 d->flush = TRUE; 352 d->flush = TRUE;
353 info = QString( "" ); 353 info = QString( "" );
354 354
355 //qDebug( "Opening %s", path.latin1() ); 355 //qDebug( "Opening %s", path.latin1() );
356 356
357 357
358 if (path.left( 4 ) == "http" ) { 358 if (path.left( 4 ) == "http" ) {
359 d->input.fd = http_open(path); 359 d->input.fd = http_open(path);
360 360
361 } else { 361 } else {
362 d->input.path = path.latin1(); 362 d->input.path = path.latin1();
363 d->input.fd = ::open( d->input.path, O_RDONLY ); 363 d->input.fd = ::open( d->input.path, O_RDONLY );
364 } 364 }
365 if (d->input.fd == -1) { 365 if (d->input.fd == -1) {
366 qDebug("error opening %s", d->input.path ); 366 qDebug("error opening %s", d->input.path );
367 return FALSE; 367 return FALSE;
368 } 368 }
369 369
370 printID3Tags(); 370 printID3Tags();
371 371
372#if defined(HAVE_MMAP) 372#if defined(HAVE_MMAP)
373 struct stat stat; 373 struct stat stat;
374 if (fstat(d->input.fd, &stat) == -1) { 374 if (fstat(d->input.fd, &stat) == -1) {
375 qDebug("error calling fstat"); return FALSE; 375 qDebug("error calling fstat"); return FALSE;
376 } 376 }