author | harlekin <harlekin> | 2002-04-20 18:38:39 (UTC) |
---|---|---|
committer | harlekin <harlekin> | 2002-04-20 18:38:39 (UTC) |
commit | 703c9c483b5e3fa6d2090398d6ee3a5638326b02 (patch) (unidiff) | |
tree | 1e965c35afc244ae31f5842047fe27bb2dd3f2cc /core/multimedia | |
parent | 758c9e817087252894b15c6f7476c1f16a02f65d (diff) | |
download | opie-703c9c483b5e3fa6d2090398d6ee3a5638326b02.zip opie-703c9c483b5e3fa6d2090398d6ee3a5638326b02.tar.gz opie-703c9c483b5e3fa6d2090398d6ee3a5638326b02.tar.bz2 |
ugly hack for the beginning
-rw-r--r-- | core/multimedia/opieplayer/libmad/libmadplugin.cpp | 189 | ||||
-rw-r--r-- | core/multimedia/opieplayer/libmad/libmadplugin.h | 9 |
2 files changed, 193 insertions, 5 deletions
diff --git a/core/multimedia/opieplayer/libmad/libmadplugin.cpp b/core/multimedia/opieplayer/libmad/libmadplugin.cpp index 8ede537..0fcc230 100644 --- a/core/multimedia/opieplayer/libmad/libmadplugin.cpp +++ b/core/multimedia/opieplayer/libmad/libmadplugin.cpp | |||
@@ -31,12 +31,20 @@ | |||
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 | ||
38 | #include <netinet/in.h> | ||
39 | #include <netdb.h> | ||
40 | #include <sys/socket.h> | ||
41 | #include <arpa/inet.h> | ||
42 | #include <unistd.h> | ||
43 | |||
44 | |||
37 | //#define HAVE_MMAP | 45 | //#define HAVE_MMAP |
38 | 46 | ||
39 | #if defined(HAVE_MMAP) | 47 | #if defined(HAVE_MMAP) |
40 | # include <sys/mman.h> | 48 | # include <sys/mman.h> |
41 | #endif | 49 | #endif |
42 | #include "libmadplugin.h" | 50 | #include "libmadplugin.h" |
@@ -157,31 +165,206 @@ bool LibMadPlugin::isFileSupported( const QString& path ) { | |||
157 | if ( ext ) { | 165 | if ( ext ) { |
158 | if ( strncasecmp(ext, ".mp2", 4) == 0 ) | 166 | if ( strncasecmp(ext, ".mp2", 4) == 0 ) |
159 | return TRUE; | 167 | return TRUE; |
160 | if ( strncasecmp(ext, ".mp3", 4) == 0 ) | 168 | if ( strncasecmp(ext, ".mp3", 4) == 0 ) |
161 | return TRUE; | 169 | return TRUE; |
162 | } | 170 | } |
171 | // UGLY - just for fast testing | ||
172 | if ( path.left(4) == "http") { | ||
173 | return TRUE; | ||
174 | } | ||
175 | |||
163 | 176 | ||
164 | return FALSE; | 177 | return FALSE; |
165 | } | 178 | } |
166 | 179 | ||
167 | 180 | ||
181 | int LibMadPlugin::tcp_open(char *address, int port) { | ||
182 | struct sockaddr_in stAddr; | ||
183 | struct hostent *host; | ||
184 | int sock; | ||
185 | struct linger l; | ||
186 | |||
187 | memset(&stAddr, 0, sizeof(stAddr)); | ||
188 | stAddr.sin_family = AF_INET; | ||
189 | stAddr.sin_port = htons(port); | ||
190 | |||
191 | if ((host = gethostbyname(address)) == NULL) | ||
192 | return (0); | ||
193 | |||
194 | stAddr.sin_addr = *((struct in_addr *)host->h_addr_list[0]); | ||
195 | |||
196 | if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0) | ||
197 | return (0); | ||
198 | |||
199 | l.l_onoff = 1; | ||
200 | l.l_linger = 5; | ||
201 | if (setsockopt(sock, SOL_SOCKET, SO_LINGER, (char *)&l, sizeof(l)) < 0) | ||
202 | return (0); | ||
203 | |||
204 | if (connect(sock, (struct sockaddr *)&stAddr, sizeof(stAddr)) < 0) | ||
205 | return (0); | ||
206 | |||
207 | return (sock); | ||
208 | } | ||
209 | |||
210 | |||
211 | /** | ||
212 | * Read a http line header. | ||
213 | * This function read character by character. | ||
214 | * @param tcp_sock the socket use to read the stream | ||
215 | * @param buf a buffer to receive the data | ||
216 | * @param size size of the buffer | ||
217 | * @return the size of the stream read or -1 if an error occured | ||
218 | */ | ||
219 | int LibMadPlugin::http_read_line(int tcp_sock, char *buf, int size) { | ||
220 | int offset = 0; | ||
221 | |||
222 | do | ||
223 | { | ||
224 | if (std::read(tcp_sock, buf + offset, 1) < 0) | ||
225 | return -1; | ||
226 | if (buf[offset] != '\r') /* Strip \r from answer */ | ||
227 | offset++; | ||
228 | } | ||
229 | while (offset < size - 1 && buf[offset - 1] != '\n'); | ||
230 | |||
231 | buf[offset] = 0; | ||
232 | return offset; | ||
233 | } | ||
234 | |||
235 | int LibMadPlugin::http_open(const QString& path ) { | ||
236 | char *host; | ||
237 | int port; | ||
238 | char *request; | ||
239 | int tcp_sock; | ||
240 | char http_request[PATH_MAX]; | ||
241 | char filename[PATH_MAX]; | ||
242 | char c; | ||
243 | char *arg =strdup(path.latin1()); | ||
244 | |||
245 | /* Check for URL syntax */ | ||
246 | if (strncmp(arg, "http://", strlen("http://"))) | ||
247 | return (0); | ||
248 | |||
249 | /* Parse URL */ | ||
250 | port = 80; | ||
251 | host = arg + strlen("http://"); | ||
252 | if ((request = strchr(host, '/')) == NULL) | ||
253 | return (0); | ||
254 | *request++ = 0; | ||
255 | |||
256 | if (strchr(host, ':') != NULL) /* port is specified */ | ||
257 | { | ||
258 | port = atoi(strchr(host, ':') + 1); | ||
259 | *strchr(host, ':') = 0; | ||
260 | } | ||
261 | |||
262 | /* Open a TCP socket */ | ||
263 | if (!(tcp_sock = tcp_open(host, port))) | ||
264 | { | ||
265 | perror("http_open"); | ||
266 | return (0); | ||
267 | } | ||
268 | |||
269 | snprintf(filename, sizeof(filename) - strlen(host) - 75, "%s", request); | ||
270 | |||
271 | /* Send HTTP GET request */ | ||
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 */ | ||
274 | snprintf(http_request, sizeof(http_request), "GET /%s HTTP/1.0\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); | ||
277 | |||
278 | send(tcp_sock, http_request, strlen(http_request), 0); | ||
279 | |||
280 | /* Parse server reply */ | ||
281 | #if 0 | ||
282 | do | ||
283 | read(tcp_sock, &c, sizeof(char)); | ||
284 | while (c != ' '); | ||
285 | read(tcp_sock, http_request, 4 * sizeof(char)); | ||
286 | http_request[4] = 0; | ||
287 | if (strcmp(http_request, "200 ")) | ||
288 | { | ||
289 | fprintf(stderr, "http_open: "); | ||
290 | do | ||
291 | { | ||
292 | read(tcp_sock, &c, sizeof(char)); | ||
293 | fprintf(stderr, "%c", c); | ||
294 | } | ||
295 | while (c != '\r'); | ||
296 | fprintf(stderr, "\n"); | ||
297 | return (0); | ||
298 | } | ||
299 | #endif | ||
300 | |||
301 | do | ||
302 | { | ||
303 | int len; | ||
304 | |||
305 | len = http_read_line(tcp_sock, http_request, sizeof(http_request)); | ||
306 | |||
307 | if (len == -1) | ||
308 | { | ||
309 | fprintf(stderr, "http_open: %s\n", strerror(errno)); | ||
310 | return 0; | ||
311 | } | ||
312 | |||
313 | if (strncmp(http_request, "Location:", 9) == 0) | ||
314 | { | ||
315 | /* redirect */ | ||
316 | std::close(tcp_sock); | ||
317 | |||
318 | http_request[strlen(http_request) - 1] = '\0'; | ||
319 | |||
320 | return http_open(&http_request[10]); | ||
321 | } | ||
322 | |||
323 | if (strncmp(http_request, "ICY ", 4) == 0) | ||
324 | { | ||
325 | /* This is icecast streaming */ | ||
326 | if (strncmp(http_request + 4, "200 ", 4)) | ||
327 | { | ||
328 | fprintf(stderr, "http_open: %s\n", http_request); | ||
329 | return 0; | ||
330 | } | ||
331 | } | ||
332 | else if (strncmp(http_request, "icy-", 4) == 0) | ||
333 | { | ||
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 */ | ||
336 | /* fprintf(stderr,"%s\n",http_request); */ | ||
337 | } | ||
338 | } | ||
339 | while (strcmp(http_request, "\n") != 0); | ||
340 | |||
341 | return (tcp_sock); | ||
342 | } | ||
343 | |||
344 | |||
168 | bool LibMadPlugin::open( const QString& path ) { | 345 | bool LibMadPlugin::open( const QString& path ) { |
169 | debugMsg( "LibMadPlugin::open" ); | 346 | debugMsg( "LibMadPlugin::open" ); |
170 | Config cfg("MediaPlayer"); | 347 | Config cfg("MediaPlayer"); |
171 | cfg.setGroup("Options"); | 348 | cfg.setGroup("Options"); |
172 | bufferSize = cfg.readNumEntry("MPeg_BufferSize",MPEG_BUFFER_SIZE); | 349 | bufferSize = cfg.readNumEntry("MPeg_BufferSize",MPEG_BUFFER_SIZE); |
173 | qDebug("buffer size is %d", bufferSize); | 350 | qDebug("buffer size is %d", bufferSize); |
174 | d->bad_last_frame = 0; | 351 | d->bad_last_frame = 0; |
175 | d->flush = TRUE; | 352 | d->flush = TRUE; |
176 | info = QString( "" ); | 353 | info = QString( "" ); |
177 | 354 | ||
178 | //qDebug( "Opening %s", path.latin1() ); | 355 | //qDebug( "Opening %s", path.latin1() ); |
179 | 356 | ||
180 | d->input.path = path.latin1(); | 357 | |
181 | d->input.fd = ::open( d->input.path, O_RDONLY ); | 358 | if (path.left( 4 ) == "http" ) { |
359 | d->input.fd = http_open(path); | ||
360 | |||
361 | } else { | ||
362 | d->input.path = path.latin1(); | ||
363 | d->input.fd = ::open( d->input.path, O_RDONLY ); | ||
364 | } | ||
182 | if (d->input.fd == -1) { | 365 | if (d->input.fd == -1) { |
183 | qDebug("error opening %s", d->input.path ); | 366 | qDebug("error opening %s", d->input.path ); |
184 | return FALSE; | 367 | return FALSE; |
185 | } | 368 | } |
186 | 369 | ||
187 | printID3Tags(); | 370 | printID3Tags(); |
@@ -493,13 +676,13 @@ bool LibMadPlugin::audioReadMonoSamples( short *, long, long&, int ) { | |||
493 | bool LibMadPlugin::audioReadStereoSamples( short *output, long samples, long& samplesMade, int ) { | 676 | bool LibMadPlugin::audioReadStereoSamples( short *output, long samples, long& samplesMade, int ) { |
494 | */ | 677 | */ |
495 | bool LibMadPlugin::audioReadSamples( short *output, int /*channels*/, long samples, long& samplesMade, int ) { | 678 | bool LibMadPlugin::audioReadSamples( short *output, int /*channels*/, long samples, long& samplesMade, int ) { |
496 | debugMsg( "LibMadPlugin::audioReadStereoSamples" ); | 679 | debugMsg( "LibMadPlugin::audioReadStereoSamples" ); |
497 | 680 | ||
498 | static bool needInput = TRUE; | 681 | static bool needInput = TRUE; |
499 | 682 | ||
500 | if ( samples == 0 ) | 683 | if ( samples == 0 ) |
501 | return FALSE; | 684 | return FALSE; |
502 | 685 | ||
503 | do { | 686 | do { |
504 | if ( needInput ) | 687 | if ( needInput ) |
505 | if ( !read() ) { | 688 | if ( !read() ) { |
diff --git a/core/multimedia/opieplayer/libmad/libmadplugin.h b/core/multimedia/opieplayer/libmad/libmadplugin.h index 46cd4a1..ee1ca9d 100644 --- a/core/multimedia/opieplayer/libmad/libmadplugin.h +++ b/core/multimedia/opieplayer/libmad/libmadplugin.h | |||
@@ -14,13 +14,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 | #ifndef LIBMAD_PLUGIN_H | 20 | #ifndef LIBMAD_PLUGIN_H |
21 | #define LIBMAD_PLUGIN_H | 21 | #define LIBMAD_PLUGIN_H |
22 | 22 | ||
23 | #include <qstring.h> | 23 | #include <qstring.h> |
24 | #include <qpe/mediaplayerplugininterface.h> | 24 | #include <qpe/mediaplayerplugininterface.h> |
25 | /* #include "../mediaplayerplugininterface.h" */ | 25 | /* #include "../mediaplayerplugininterface.h" */ |
26 | 26 | ||
@@ -40,19 +40,20 @@ public: | |||
40 | const char *pluginName() { return "LibMadPlugin"; } | 40 | const char *pluginName() { return "LibMadPlugin"; } |
41 | const char *pluginComment() { return "This is the libmad library that has been wrapped as a plugin"; } | 41 | const char *pluginComment() { return "This is the libmad library that has been wrapped as a plugin"; } |
42 | double pluginVersion() { return 1.0; } | 42 | double pluginVersion() { return 1.0; } |
43 | 43 | ||
44 | bool isFileSupported( const QString& ); | 44 | bool isFileSupported( const QString& ); |
45 | bool open( const QString& ); | 45 | bool open( const QString& ); |
46 | |||
46 | bool close(); | 47 | bool close(); |
47 | bool isOpen(); | 48 | bool isOpen(); |
48 | const QString &fileInfo() { return info; } | 49 | const QString &fileInfo() { return info; } |
49 | 50 | ||
50 | // If decoder doesn't support audio then return 0 here | 51 | // If decoder doesn't support audio then return 0 here |
51 | int audioStreams(); | 52 | int audioStreams(); |
52 | int audioChannels( int stream ); | 53 | int audioChannels( int stream ); |
53 | int audioFrequency( int stream ); | 54 | int audioFrequency( int stream ); |
54 | int audioSamples( int stream ); | 55 | int audioSamples( int stream ); |
55 | bool audioSetSample( long sample, int stream ); | 56 | bool audioSetSample( long sample, int stream ); |
56 | /* int audioBitsPerSample(int) {return 0;} */ | 57 | /* int audioBitsPerSample(int) {return 0;} */ |
57 | long audioGetSample( int stream ); | 58 | long audioGetSample( int stream ); |
58 | #ifdef OLD_MEDIAPLAYER_API | 59 | #ifdef OLD_MEDIAPLAYER_API |
@@ -98,12 +99,16 @@ public: | |||
98 | bool supportsStereo() { return TRUE; } | 99 | bool supportsStereo() { return TRUE; } |
99 | bool supportsScaling() { return FALSE; } | 100 | bool supportsScaling() { return FALSE; } |
100 | 101 | ||
101 | long getPlayTime() { return -1; } | 102 | long getPlayTime() { return -1; } |
102 | 103 | ||
103 | private: | 104 | private: |
105 | int tcp_open(char *address, int port); | ||
106 | int http_read_line(int tcp_sock, char *buf, int size) ; | ||
107 | int http_open(const QString& path ); | ||
108 | |||
104 | LibMadPluginData *d; | 109 | LibMadPluginData *d; |
105 | QString info; | 110 | QString info; |
106 | int bufferSize; | 111 | int bufferSize; |
107 | }; | 112 | }; |
108 | 113 | ||
109 | 114 | ||