| -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 @@ -36,2 +36,10 @@ +// for network handling +#include <netinet/in.h> +#include <netdb.h> +#include <sys/socket.h> +#include <arpa/inet.h> +#include <unistd.h> + + //#define HAVE_MMAP @@ -162,2 +170,7 @@ bool LibMadPlugin::isFileSupported( const QString& path ) { } + // UGLY - just for fast testing + if ( path.left(4) == "http") { + return TRUE; + } + @@ -167,2 +180,166 @@ bool LibMadPlugin::isFileSupported( const QString& path ) { +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 ) { @@ -179,4 +356,10 @@ bool LibMadPlugin::open( const QString& path ) { - 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) { @@ -498,3 +681,3 @@ bool LibMadPlugin::audioReadSamples( short *output, int /*channels*/, long sampl static bool needInput = TRUE; - + if ( samples == 0 ) 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 @@ -19,3 +19,3 @@ **********************************************************************/ -#ifndef LIBMAD_PLUGIN_H +#ifndef LIBMAD_PLUGIN_H #define LIBMAD_PLUGIN_H @@ -45,2 +45,3 @@ public: bool open( const QString& ); + bool close(); @@ -51,3 +52,3 @@ public: int audioStreams(); - int audioChannels( int stream ); + int audioChannels( int stream ); int audioFrequency( int stream ); @@ -103,2 +104,6 @@ public: 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; |