summaryrefslogtreecommitdiff
Side-by-side diff
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--core/multimedia/opieplayer/libmad/libmadplugin.cpp189
-rw-r--r--core/multimedia/opieplayer/libmad/libmadplugin.h9
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
@@ -21,32 +21,40 @@
#include <stdarg.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <string.h>
#include <ctype.h>
#include <errno.h>
#include <time.h>
#include <locale.h>
#include <math.h>
#include <assert.h>
#include <qapplication.h>
#include <qpe/config.h>
+// for network handling
+#include <netinet/in.h>
+#include <netdb.h>
+#include <sys/socket.h>
+#include <arpa/inet.h>
+#include <unistd.h>
+
+
//#define HAVE_MMAP
#if defined(HAVE_MMAP)
# include <sys/mman.h>
#endif
#include "libmadplugin.h"
extern "C" {
#include "mad.h"
}
#define MPEG_BUFFER_SIZE 65536
//#define MPEG_BUFFER_SIZE 32768 //16384 // 8192
//#define debugMsg(a) qDebug(a)
@@ -147,51 +155,226 @@ bool LibMadPlugin::isFileSupported( const QString& path ) {
debugMsg( "LibMadPlugin::isFileSupported" );
// Mpeg file extensions
// "mp2","mp3","m1v","m2v","m2s","mpg","vob","mpeg","ac3"
// Other media extensions
// "wav","mid","mod","s3m","ogg","avi","mov","sid"
char *ext = strrchr( path.latin1(), '.' );
// Test file extension
if ( ext ) {
if ( strncasecmp(ext, ".mp2", 4) == 0 )
return TRUE;
if ( strncasecmp(ext, ".mp3", 4) == 0 )
return TRUE;
}
+ // UGLY - just for fast testing
+ if ( path.left(4) == "http") {
+ return TRUE;
+ }
+
return FALSE;
}
+int LibMadPlugin::tcp_open(char *address, int port) {
+ struct sockaddr_in stAddr;
+ struct hostent *host;
+ int sock;
+ struct linger l;
+
+ memset(&stAddr, 0, sizeof(stAddr));
+ stAddr.sin_family = AF_INET;
+ stAddr.sin_port = htons(port);
+
+ if ((host = gethostbyname(address)) == NULL)
+ return (0);
+
+ stAddr.sin_addr = *((struct in_addr *)host->h_addr_list[0]);
+
+ if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0)
+ return (0);
+
+ l.l_onoff = 1;
+ l.l_linger = 5;
+ if (setsockopt(sock, SOL_SOCKET, SO_LINGER, (char *)&l, sizeof(l)) < 0)
+ return (0);
+
+ if (connect(sock, (struct sockaddr *)&stAddr, sizeof(stAddr)) < 0)
+ return (0);
+
+ return (sock);
+}
+
+
+/**
+ * Read a http line header.
+ * This function read character by character.
+ * @param tcp_sock the socket use to read the stream
+ * @param buf a buffer to receive the data
+ * @param size size of the buffer
+ * @return the size of the stream read or -1 if an error occured
+ */
+int LibMadPlugin::http_read_line(int tcp_sock, char *buf, int size) {
+ int offset = 0;
+
+ do
+ {
+ if (std::read(tcp_sock, buf + offset, 1) < 0)
+ return -1;
+ if (buf[offset] != '\r') /* Strip \r from answer */
+ offset++;
+ }
+ while (offset < size - 1 && buf[offset - 1] != '\n');
+
+ buf[offset] = 0;
+ return offset;
+}
+
+int LibMadPlugin::http_open(const QString& path ) {
+ char *host;
+ int port;
+ char *request;
+ int tcp_sock;
+ char http_request[PATH_MAX];
+ char filename[PATH_MAX];
+ char c;
+ char *arg =strdup(path.latin1());
+
+ /* Check for URL syntax */
+ if (strncmp(arg, "http://", strlen("http://")))
+ return (0);
+
+ /* Parse URL */
+ port = 80;
+ host = arg + strlen("http://");
+ if ((request = strchr(host, '/')) == NULL)
+ return (0);
+ *request++ = 0;
+
+ if (strchr(host, ':') != NULL) /* port is specified */
+ {
+ port = atoi(strchr(host, ':') + 1);
+ *strchr(host, ':') = 0;
+ }
+
+ /* Open a TCP socket */
+ if (!(tcp_sock = tcp_open(host, port)))
+ {
+ perror("http_open");
+ return (0);
+ }
+
+ snprintf(filename, sizeof(filename) - strlen(host) - 75, "%s", request);
+
+ /* Send HTTP GET request */
+ /* Please don't use a Agent know by shoutcast (Lynx, Mozilla) seems to be reconized and print
+ * a html page and not the stream */
+ snprintf(http_request, sizeof(http_request), "GET /%s HTTP/1.0\r\n"
+/* "User-Agent: Mozilla/2.0 (Win95; I)\r\n" */
+ "Pragma: no-cache\r\n" "Host: %s\r\n" "Accept: */*\r\n" "\r\n", filename, host);
+
+ send(tcp_sock, http_request, strlen(http_request), 0);
+
+ /* Parse server reply */
+#if 0
+ do
+ read(tcp_sock, &c, sizeof(char));
+ while (c != ' ');
+ read(tcp_sock, http_request, 4 * sizeof(char));
+ http_request[4] = 0;
+ if (strcmp(http_request, "200 "))
+ {
+ fprintf(stderr, "http_open: ");
+ do
+ {
+ read(tcp_sock, &c, sizeof(char));
+ fprintf(stderr, "%c", c);
+ }
+ while (c != '\r');
+ fprintf(stderr, "\n");
+ return (0);
+ }
+#endif
+
+ do
+ {
+ int len;
+
+ len = http_read_line(tcp_sock, http_request, sizeof(http_request));
+
+ if (len == -1)
+ {
+ fprintf(stderr, "http_open: %s\n", strerror(errno));
+ return 0;
+ }
+
+ if (strncmp(http_request, "Location:", 9) == 0)
+ {
+ /* redirect */
+ std::close(tcp_sock);
+
+ http_request[strlen(http_request) - 1] = '\0';
+
+ return http_open(&http_request[10]);
+ }
+
+ if (strncmp(http_request, "ICY ", 4) == 0)
+ {
+ /* This is icecast streaming */
+ if (strncmp(http_request + 4, "200 ", 4))
+ {
+ fprintf(stderr, "http_open: %s\n", http_request);
+ return 0;
+ }
+ }
+ else if (strncmp(http_request, "icy-", 4) == 0)
+ {
+ /* we can have: icy-noticeX, icy-name, icy-genre, icy-url, icy-pub, icy-metaint, icy-br */
+ /* Don't print these - mpg123 doesn't */
+ /* fprintf(stderr,"%s\n",http_request); */
+ }
+ }
+ while (strcmp(http_request, "\n") != 0);
+
+ return (tcp_sock);
+}
+
+
bool LibMadPlugin::open( const QString& path ) {
debugMsg( "LibMadPlugin::open" );
Config cfg("MediaPlayer");
cfg.setGroup("Options");
bufferSize = cfg.readNumEntry("MPeg_BufferSize",MPEG_BUFFER_SIZE);
qDebug("buffer size is %d", bufferSize);
d->bad_last_frame = 0;
d->flush = TRUE;
info = QString( "" );
//qDebug( "Opening %s", path.latin1() );
- d->input.path = path.latin1();
- d->input.fd = ::open( d->input.path, O_RDONLY );
+
+ if (path.left( 4 ) == "http" ) {
+ d->input.fd = http_open(path);
+
+ } else {
+ d->input.path = path.latin1();
+ d->input.fd = ::open( d->input.path, O_RDONLY );
+ }
if (d->input.fd == -1) {
qDebug("error opening %s", d->input.path );
return FALSE;
}
printID3Tags();
#if defined(HAVE_MMAP)
struct stat stat;
if (fstat(d->input.fd, &stat) == -1) {
qDebug("error calling fstat"); return FALSE;
}
if (S_ISREG(stat.st_mode) && stat.st_size > 0) {
d->input.length = stat.st_size;
d->input.fdm = map_file(d->input.fd, &d->input.length);
if (d->input.fdm == 0) {
@@ -483,33 +666,33 @@ bool LibMadPlugin::decode( short *output, long samples, long& samplesMade ) {
return TRUE;
}
/*
bool LibMadPlugin::audioReadMonoSamples( short *, long, long&, int ) {
debugMsg( "LibMadPlugin::audioReadMonoSamples" );
return FALSE;
}
bool LibMadPlugin::audioReadStereoSamples( short *output, long samples, long& samplesMade, int ) {
*/
bool LibMadPlugin::audioReadSamples( short *output, int /*channels*/, long samples, long& samplesMade, int ) {
debugMsg( "LibMadPlugin::audioReadStereoSamples" );
static bool needInput = TRUE;
-
+
if ( samples == 0 )
return FALSE;
do {
if ( needInput )
if ( !read() ) {
// if ( d->input.eof )
// needInput = FALSE;
// else
return FALSE;
}
needInput = FALSE;
if ( decode( output, samples, samplesMade ) )
return TRUE;
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
@@ -4,65 +4,66 @@
** This file is part of Qtopia Environment.
**
** This file may be distributed and/or modified under the terms of the
** GNU General Public License version 2 as published by the Free Software
** Foundation and appearing in the file LICENSE.GPL included in the
** packaging of this file.
**
** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
**
** See http://www.trolltech.com/gpl/ for GPL licensing information.
**
** Contact info@trolltech.com if any conditions of this licensing are
** not clear to you.
**
**********************************************************************/
-#ifndef LIBMAD_PLUGIN_H
+#ifndef LIBMAD_PLUGIN_H
#define LIBMAD_PLUGIN_H
#include <qstring.h>
#include <qpe/mediaplayerplugininterface.h>
/* #include "../mediaplayerplugininterface.h" */
// #define OLD_MEDIAPLAYER_API
class LibMadPluginData;
class LibMadPlugin : public MediaPlayerDecoder {
public:
LibMadPlugin();
~LibMadPlugin();
const char *pluginName() { return "LibMadPlugin"; }
const char *pluginComment() { return "This is the libmad library that has been wrapped as a plugin"; }
double pluginVersion() { return 1.0; }
bool isFileSupported( const QString& );
bool open( const QString& );
+
bool close();
bool isOpen();
const QString &fileInfo() { return info; }
// If decoder doesn't support audio then return 0 here
int audioStreams();
- int audioChannels( int stream );
+ int audioChannels( int stream );
int audioFrequency( int stream );
int audioSamples( int stream );
bool audioSetSample( long sample, int stream );
/* int audioBitsPerSample(int) {return 0;} */
long audioGetSample( int stream );
#ifdef OLD_MEDIAPLAYER_API
bool audioReadMonoSamples( short *output, long samples, long& samplesRead, int stream );
bool audioReadStereoSamples( short *output, long samples, long& samplesRead, int stream );
bool audioReadSamples( short *output, int channel, long samples, int stream );
bool audioReReadSamples( short *output, int channel, long samples, int stream );
#else
bool audioReadSamples( short *output, int channels, long samples, long& samplesRead, int stream );
#endif
bool read();
@@ -88,23 +89,27 @@ public:
// Ignore if these aren't supported
bool setSMP( int ) { return FALSE; }
bool setMMX( bool ) { return FALSE; }
// Capabilities
bool supportsAudio() { return TRUE; }
bool supportsVideo() { return FALSE; }
bool supportsYUV() { return FALSE; }
bool supportsMMX() { return TRUE; }
bool supportsSMP() { return FALSE; }
bool supportsStereo() { return TRUE; }
bool supportsScaling() { return FALSE; }
long getPlayTime() { return -1; }
private:
+ int tcp_open(char *address, int port);
+ int http_read_line(int tcp_sock, char *buf, int size) ;
+ int http_open(const QString& path );
+
LibMadPluginData *d;
QString info;
int bufferSize;
};
#endif