-rw-r--r-- | core/multimedia/opieplayer/libmad/libmadplugin.cpp | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/core/multimedia/opieplayer/libmad/libmadplugin.cpp b/core/multimedia/opieplayer/libmad/libmadplugin.cpp index 8b692ef..c744c6d 100644 --- a/core/multimedia/opieplayer/libmad/libmadplugin.cpp +++ b/core/multimedia/opieplayer/libmad/libmadplugin.cpp | |||
@@ -342,204 +342,210 @@ int LibMadPlugin::http_open(const QString& path ) { | |||
342 | 342 | ||
343 | /* Send HTTP GET request */ | 343 | /* Send HTTP GET request */ |
344 | /* Please don't use a Agent know by shoutcast (Lynx, Mozilla) seems to be reconized and print | 344 | /* Please don't use a Agent know by shoutcast (Lynx, Mozilla) seems to be reconized and print |
345 | * a html page and not the stream */ | 345 | * a html page and not the stream */ |
346 | snprintf(http_request, sizeof(http_request), "GET /%s HTTP/1.0\r\n" | 346 | snprintf(http_request, sizeof(http_request), "GET /%s HTTP/1.0\r\n" |
347 | /* "User-Agent: Mozilla/2.0 (Win95; I)\r\n" */ | 347 | /* "User-Agent: Mozilla/2.0 (Win95; I)\r\n" */ |
348 | "Pragma: no-cache\r\n" "Host: %s\r\n" "Accept: */*\r\n" "\r\n", filename, host); | 348 | "Pragma: no-cache\r\n" "Host: %s\r\n" "Accept: */*\r\n" "\r\n", filename, host); |
349 | 349 | ||
350 | send(tcp_sock, http_request, strlen(http_request), 0); | 350 | send(tcp_sock, http_request, strlen(http_request), 0); |
351 | 351 | ||
352 | /* Parse server reply */ | 352 | /* Parse server reply */ |
353 | #if 0 | 353 | #if 0 |
354 | do | 354 | do |
355 | read(tcp_sock, &c, sizeof(char)); | 355 | read(tcp_sock, &c, sizeof(char)); |
356 | while (c != ' '); | 356 | while (c != ' '); |
357 | read(tcp_sock, http_request, 4 * sizeof(char)); | 357 | read(tcp_sock, http_request, 4 * sizeof(char)); |
358 | http_request[4] = 0; | 358 | http_request[4] = 0; |
359 | if (strcmp(http_request, "200 ")) { | 359 | if (strcmp(http_request, "200 ")) { |
360 | fprintf(stderr, "http_open: "); | 360 | fprintf(stderr, "http_open: "); |
361 | do { | 361 | do { |
362 | read(tcp_sock, &c, sizeof(char)); | 362 | read(tcp_sock, &c, sizeof(char)); |
363 | fprintf(stderr, "%c", c); | 363 | fprintf(stderr, "%c", c); |
364 | } while (c != '\r'); | 364 | } while (c != '\r'); |
365 | fprintf(stderr, "\n"); | 365 | fprintf(stderr, "\n"); |
366 | return (0); | 366 | return (0); |
367 | } | 367 | } |
368 | #endif | 368 | #endif |
369 | 369 | ||
370 | QString name; | 370 | QString name; |
371 | QString genre; | 371 | QString genre; |
372 | QString bitrate; | 372 | QString bitrate; |
373 | QString url; | 373 | QString url; |
374 | QString message = tr("Info: "); | 374 | QString message = tr("Info: "); |
375 | do { | 375 | do { |
376 | 376 | ||
377 | int len; | 377 | int len; |
378 | 378 | ||
379 | len = http_read_line(tcp_sock, http_request, sizeof(http_request)); | 379 | len = http_read_line(tcp_sock, http_request, sizeof(http_request)); |
380 | 380 | ||
381 | if (len == -1) { | 381 | if (len == -1) { |
382 | qDebug( "http_open: "+ QString(strerror(errno)) +"\n"); | 382 | qDebug( "http_open: "+ QString(strerror(errno)) +"\n"); |
383 | return 0; | 383 | return 0; |
384 | } | 384 | } |
385 | 385 | ||
386 | if (QString(http_request).left(9) == "Location:") { | 386 | if (QString(http_request).left(9) == "Location:") { |
387 | /* redirect */ | 387 | /* redirect */ |
388 | std::close(tcp_sock); | 388 | std::close(tcp_sock); |
389 | http_request[strlen(http_request) - 1] = '\0'; | 389 | http_request[strlen(http_request) - 1] = '\0'; |
390 | return http_open(&http_request[10]); | 390 | return http_open(&http_request[10]); |
391 | } | 391 | } |
392 | 392 | ||
393 | if (QString(http_request).left(4) == "ICY ") { | 393 | if (QString(http_request).left(4) == "ICY ") { |
394 | /* This is shoutcast/icecast streaming */ | 394 | /* This is shoutcast/icecast streaming */ |
395 | if (strncmp(http_request + 4, "200 ", 4)) { | 395 | if (strncmp(http_request + 4, "200 ", 4)) { |
396 | qDebug("http_open: " + QString(http_request) + "\n"); | 396 | qDebug("http_open: " + QString(http_request) + "\n"); |
397 | return 0; | 397 | return 0; |
398 | } | 398 | } |
399 | } else if (QString(http_request).left(4) == "icy-") { | 399 | } else if (QString(http_request).left(4) == "icy-") { |
400 | /* we can have: icy-noticeX, icy-name, icy-genre, icy-url, icy-pub, icy-metaint, icy-br */ | 400 | /* we can have: icy-noticeX, icy-name, icy-genre, icy-url, icy-pub, icy-metaint, icy-br */ |
401 | if ( QString( http_request ).left( 8 ) == "icy-name" ) { | 401 | if ( QString( http_request ).left( 8 ) == "icy-name" ) { |
402 | name = tr("Name: ") + QString(http_request).mid(9, (QString(http_request).length())- 9 ); | 402 | name = tr("Name: ") + QString(http_request).mid(9, (QString(http_request).length())- 9 ); |
403 | } else if ( QString( http_request ).left( 9 ) == "icy-genre" ) { | 403 | } else if ( QString( http_request ).left( 9 ) == "icy-genre" ) { |
404 | genre = tr("Genre: ") + QString(http_request).mid(10, (QString(http_request).length())-10 ); | 404 | genre = tr("Genre: ") + QString(http_request).mid(10, (QString(http_request).length())-10 ); |
405 | } else if ( QString( http_request ).left( 6 ) == "icy-br" ) { | 405 | } else if ( QString( http_request ).left( 6 ) == "icy-br" ) { |
406 | bitrate = tr("Bitrate: ") + QString(http_request).mid(7, (QString(http_request).length())- 7 ); | 406 | bitrate = tr("Bitrate: ") + QString(http_request).mid(7, (QString(http_request).length())- 7 ); |
407 | } else if ( QString( http_request ).left( 7 ) == "icy-url" ) { | 407 | } else if ( QString( http_request ).left( 7 ) == "icy-url" ) { |
408 | url = tr("URL: ") + QString(http_request).mid(8, (QString(http_request).length())- 8 ); | 408 | url = tr("URL: ") + QString(http_request).mid(8, (QString(http_request).length())- 8 ); |
409 | } else if ( QString( http_request ).left( 10 ) == "icy-notice" ) { | 409 | } else if ( QString( http_request ).left( 10 ) == "icy-notice" ) { |
410 | message += QString(http_request).mid(11, QString(http_request).length()-11 ) ; | 410 | message += QString(http_request).mid(11, QString(http_request).length()-11 ) ; |
411 | } | 411 | } |
412 | } | 412 | } |
413 | } while (strcmp(http_request, "\n") != 0); | 413 | } while (strcmp(http_request, "\n") != 0); |
414 | 414 | ||
415 | info = QString(name + genre + url + bitrate + message).replace( QRegExp("\n"), " : " ); | 415 | info = QString(name + genre + url + bitrate + message).replace( QRegExp("\n"), " : " ); |
416 | 416 | ||
417 | qDebug("Stream info: " + info); | 417 | qDebug("Stream info: " + info); |
418 | 418 | ||
419 | return (tcp_sock); | 419 | return (tcp_sock); |
420 | } | 420 | } |
421 | 421 | ||
422 | 422 | ||
423 | 423 | ||
424 | bool LibMadPlugin::open( const QString& path ) { | 424 | bool LibMadPlugin::open( const QString& path ) { |
425 | debugMsg( "LibMadPlugin::open" ); | 425 | debugMsg( "LibMadPlugin::open" ); |
426 | Config cfg("MediaPlayer"); | 426 | Config cfg("MediaPlayer"); |
427 | cfg.setGroup("Options"); | 427 | cfg.setGroup("Options"); |
428 | bufferSize = cfg.readNumEntry("MPeg_BufferSize",MPEG_BUFFER_SIZE); | 428 | bufferSize = cfg.readNumEntry("MPeg_BufferSize",MPEG_BUFFER_SIZE); |
429 | qDebug("buffer size is %d", bufferSize); | 429 | qDebug("buffer size is %d", bufferSize); |
430 | d->bad_last_frame = 0; | 430 | d->bad_last_frame = 0; |
431 | d->flush = TRUE; | 431 | d->flush = TRUE; |
432 | info = QString( "" ); | 432 | info = QString( "" ); |
433 | 433 | ||
434 | //qDebug( "Opening %s", path.latin1() ); | 434 | //qDebug( "Opening %s", path.latin1() ); |
435 | 435 | ||
436 | 436 | ||
437 | if (path.left( 4 ) == "http" ) { | 437 | if (path.left( 4 ) == "http" ) { |
438 | qDebug("Test2"); | ||
438 | // in case of any error we get 0 here | 439 | // in case of any error we get 0 here |
439 | if ( !(http_open(path)==0) ) { | 440 | if ( !(http_open(path) == 0) ) { |
441 | qDebug("Test3"); | ||
440 | d->input.fd = http_open(path); | 442 | d->input.fd = http_open(path); |
443 | } else { | ||
444 | qDebug("Test5"); | ||
445 | return FALSE; | ||
441 | } | 446 | } |
442 | } else { | 447 | } else { |
448 | qDebug("Test4"); | ||
443 | d->input.path = path.latin1(); | 449 | d->input.path = path.latin1(); |
444 | d->input.fd = ::open( d->input.path, O_RDONLY ); | 450 | d->input.fd = ::open( d->input.path, O_RDONLY ); |
445 | // thats a better place, since it should only seek for ID3 tags on mp3 files, not streams | 451 | // thats a better place, since it should only seek for ID3 tags on mp3 files, not streams |
446 | printID3Tags(); | 452 | printID3Tags(); |
447 | } | 453 | } |
448 | if (d->input.fd == -1) { | 454 | if (d->input.fd == -1) { |
449 | // qDebug("error opening %s", d->input.path ); | 455 | qDebug("error opening %s", d->input.path ); |
450 | return FALSE; | 456 | return FALSE; |
451 | } | 457 | } |
452 | 458 | ||
453 | // printID3Tags(); | 459 | // printID3Tags(); |
454 | 460 | ||
455 | #if defined(HAVE_MMAP) | 461 | #if defined(HAVE_MMAP) |
456 | struct stat stat; | 462 | struct stat stat; |
457 | if (fstat(d->input.fd, &stat) == -1) { | 463 | if (fstat(d->input.fd, &stat) == -1) { |
458 | //qDebug("error calling fstat"); return FALSE; | 464 | //qDebug("error calling fstat"); return FALSE; |
459 | } | 465 | } |
460 | if (S_ISREG(stat.st_mode) && stat.st_size > 0) { | 466 | if (S_ISREG(stat.st_mode) && stat.st_size > 0) { |
461 | d->input.length = stat.st_size; | 467 | d->input.length = stat.st_size; |
462 | d->input.fdm = map_file(d->input.fd, &d->input.length); | 468 | d->input.fdm = map_file(d->input.fd, &d->input.length); |
463 | if (d->input.fdm == 0) { | 469 | if (d->input.fdm == 0) { |
464 | qDebug("error mmapping file"); return FALSE; | 470 | qDebug("error mmapping file"); return FALSE; |
465 | } | 471 | } |
466 | d->input.data = (unsigned char *)d->input.fdm; | 472 | d->input.data = (unsigned char *)d->input.fdm; |
467 | } | 473 | } |
468 | #endif | 474 | #endif |
469 | 475 | ||
470 | if (d->input.data == 0) { | 476 | if (d->input.data == 0) { |
471 | d->input.data = (unsigned char *)malloc( bufferSize /*MPEG_BUFFER_SIZE*/); | 477 | d->input.data = (unsigned char *)malloc( bufferSize /*MPEG_BUFFER_SIZE*/); |
472 | if (d->input.data == 0) { | 478 | if (d->input.data == 0) { |
473 | qDebug("error allocating input buffer"); | 479 | qDebug("error allocating input buffer"); |
474 | return FALSE; | 480 | return FALSE; |
475 | } | 481 | } |
476 | d->input.length = 0; | 482 | d->input.length = 0; |
477 | } | 483 | } |
478 | 484 | ||
479 | d->input.eof = 0; | 485 | d->input.eof = 0; |
480 | 486 | ||
481 | mad_stream_init(&d->stream); | 487 | mad_stream_init(&d->stream); |
482 | mad_frame_init(&d->frame); | 488 | mad_frame_init(&d->frame); |
483 | mad_synth_init(&d->synth); | 489 | mad_synth_init(&d->synth); |
484 | 490 | ||
485 | return TRUE; | 491 | return TRUE; |
486 | } | 492 | } |
487 | 493 | ||
488 | 494 | ||
489 | bool LibMadPlugin::close() { | 495 | bool LibMadPlugin::close() { |
490 | debugMsg( "LibMadPlugin::close" ); | 496 | debugMsg( "LibMadPlugin::close" ); |
491 | 497 | ||
492 | int result = TRUE; | 498 | int result = TRUE; |
493 | 499 | ||
494 | mad_synth_finish(&d->synth); | 500 | mad_synth_finish(&d->synth); |
495 | mad_frame_finish(&d->frame); | 501 | mad_frame_finish(&d->frame); |
496 | mad_stream_finish(&d->stream); | 502 | mad_stream_finish(&d->stream); |
497 | 503 | ||
498 | #if defined(HAVE_MMAP) | 504 | #if defined(HAVE_MMAP) |
499 | if (d->input.fdm) { | 505 | if (d->input.fdm) { |
500 | if (unmap_file(d->input.fdm, d->input.length) == -1) { | 506 | if (unmap_file(d->input.fdm, d->input.length) == -1) { |
501 | qDebug("error munmapping file"); | 507 | qDebug("error munmapping file"); |
502 | result = FALSE; | 508 | result = FALSE; |
503 | } | 509 | } |
504 | d->input.fdm = 0; | 510 | d->input.fdm = 0; |
505 | d->input.data = 0; | 511 | d->input.data = 0; |
506 | } | 512 | } |
507 | #endif | 513 | #endif |
508 | 514 | ||
509 | if (d->input.data) { | 515 | if (d->input.data) { |
510 | free(d->input.data); | 516 | free(d->input.data); |
511 | d->input.data = 0; | 517 | d->input.data = 0; |
512 | } | 518 | } |
513 | 519 | ||
514 | if (::close(d->input.fd) == -1) { | 520 | if (::close(d->input.fd) == -1) { |
515 | qDebug("error closing file %s", d->input.path); | 521 | qDebug("error closing file %s", d->input.path); |
516 | result = FALSE; | 522 | result = FALSE; |
517 | } | 523 | } |
518 | 524 | ||
519 | d->input.fd = 0; | 525 | d->input.fd = 0; |
520 | 526 | ||
521 | return result; | 527 | return result; |
522 | } | 528 | } |
523 | 529 | ||
524 | 530 | ||
525 | bool LibMadPlugin::isOpen() { | 531 | bool LibMadPlugin::isOpen() { |
526 | debugMsg( "LibMadPlugin::isOpen" ); | 532 | debugMsg( "LibMadPlugin::isOpen" ); |
527 | return ( d->input.fd != 0 ); | 533 | return ( d->input.fd != 0 ); |
528 | } | 534 | } |
529 | 535 | ||
530 | 536 | ||
531 | int LibMadPlugin::audioStreams() { | 537 | int LibMadPlugin::audioStreams() { |
532 | debugMsg( "LibMadPlugin::audioStreams" ); | 538 | debugMsg( "LibMadPlugin::audioStreams" ); |
533 | return 1; | 539 | return 1; |
534 | } | 540 | } |
535 | 541 | ||
536 | 542 | ||
537 | int LibMadPlugin::audioChannels( int ) { | 543 | int LibMadPlugin::audioChannels( int ) { |
538 | debugMsg( "LibMadPlugin::audioChannels" ); | 544 | debugMsg( "LibMadPlugin::audioChannels" ); |
539 | /* | 545 | /* |
540 | long t; short t1[5]; audioReadSamples( t1, 2, 1, t, 0 ); | 546 | long t; short t1[5]; audioReadSamples( t1, 2, 1, t, 0 ); |
541 | qDebug( "LibMadPlugin::audioChannels: %i", d->frame.header.mode > 0 ? 2 : 1 ); | 547 | qDebug( "LibMadPlugin::audioChannels: %i", d->frame.header.mode > 0 ? 2 : 1 ); |
542 | return d->frame.header.mode > 0 ? 2 : 1; | 548 | return d->frame.header.mode > 0 ? 2 : 1; |
543 | */ | 549 | */ |
544 | return 2; | 550 | return 2; |
545 | } | 551 | } |