aboutsummaryrefslogtreecommitdiff
path: root/mp3amp~
diff options
context:
space:
mode:
authorHans-Christoph Steiner <eighthave@users.sourceforge.net>2003-08-16 17:08:55 +0000
committerHans-Christoph Steiner <eighthave@users.sourceforge.net>2003-08-16 17:08:55 +0000
commit506b8e7dedb80d79bf015e47d92e8b8dd8284584 (patch)
tree6393e98add0a0ae7f92388665b3b6242977f5b64 /mp3amp~
parent856eaf396d9a4d371a458a2c373a052bb72c8057 (diff)
added files straight from Yves' sources
svn path=/trunk/externals/unauthorized/; revision=864
Diffstat (limited to 'mp3amp~')
-rw-r--r--mp3amp~/CHANGES.LOG15
-rw-r--r--mp3amp~/INSTALL19
-rw-r--r--mp3amp~/Makefile82
-rw-r--r--mp3amp~/README45
-rw-r--r--mp3amp~/help-graphic-mp3amp~.pd52
-rw-r--r--mp3amp~/help-mp3amp~.pd53
-rw-r--r--mp3amp~/interface.h32
-rw-r--r--mp3amp~/mp3amp~.c1255
-rw-r--r--mp3amp~/mpg123.h136
-rw-r--r--mp3amp~/mpglib.h65
-rw-r--r--mp3amp~/punjabi-2.pls3
-rw-r--r--mp3amp~/punjabi-3.pls3
-rw-r--r--mp3amp~/punjabi-4.pls3
-rw-r--r--mp3amp~/punjabi.pls3
14 files changed, 1766 insertions, 0 deletions
diff --git a/mp3amp~/CHANGES.LOG b/mp3amp~/CHANGES.LOG
new file mode 100644
index 0000000..ba7fb54
--- /dev/null
+++ b/mp3amp~/CHANGES.LOG
@@ -0,0 +1,15 @@
+0.12
+ suppress useless warnings
+0.11
+ read all headers before proceeding -- this fixes incomplete relocation too
+0.10
+ fixed a bug/crash when the relocation is incomplete
+0.9
+ fixed handling of frames ( never ignore any, silly me!!! )
+0.8
+ rename it from shoutamp~ to mp3amp~
+0.7y
+ fixed resampling
+ fixed urls parsing
+0.6y and before
+ sorry N/A
diff --git a/mp3amp~/INSTALL b/mp3amp~/INSTALL
new file mode 100644
index 0000000..8260a98
--- /dev/null
+++ b/mp3amp~/INSTALL
@@ -0,0 +1,19 @@
+You need to get lame > v3.90 installed first.
+libmp3lame.so is searched in /usr/local/lib
+( no time to write configure scripts ).
+if it's installed elsewhere, change the Makefile,
+you won't die from that.
+
+untar in /my/pd/dir/externs
+
+cd /my/pd/dir/externs/mp3amp~
+
+make clean
+
+make
+
+make install
+
+thanks for getting here.
+
+Yves/
diff --git a/mp3amp~/Makefile b/mp3amp~/Makefile
new file mode 100644
index 0000000..dda8e3c
--- /dev/null
+++ b/mp3amp~/Makefile
@@ -0,0 +1,82 @@
+NAME=mp3amp~
+CSYM=mp3amp_tilde
+
+current: pd_linux
+
+# ----------------------- NT -----------------------
+
+pd_nt: $(NAME).dll
+
+.SUFFIXES: .dll
+
+PDNTCFLAGS = /W3 /WX /DNT /DPD /nologo
+VC="C:\Program Files\Microsoft Visual Studio\Vc98"
+
+PDNTINCLUDE = /I. /I\tcl\include /I\ftp\pd\src /I$(VC)\include
+
+PDNTLDIR = $(VC)\lib
+PDNTLIB = $(PDNTLDIR)\libc.lib \
+ $(PDNTLDIR)\oldnames.lib \
+ $(PDNTLDIR)\kernel32.lib \
+ \ftp\pd\bin\pd.lib
+
+.c.dll:
+ cl $(PDNTCFLAGS) $(PDNTINCLUDE) /c $*.c
+ link /dll /export:$(CSYM)_setup $*.obj $(PDNTLIB)
+
+# ----------------------- IRIX 5.x -----------------------
+
+pd_irix5: $(NAME).pd_irix5
+
+.SUFFIXES: .pd_irix5
+
+SGICFLAGS5 = -o32 -DPD -DUNIX -DIRIX -O2
+
+SGIINCLUDE = -I../../src
+
+.c.pd_irix5:
+ cc $(SGICFLAGS5) $(SGIINCLUDE) -o $*.o -c $*.c
+ ld -elf -shared -rdata_shared -o $*.pd_irix5 $*.o
+ rm $*.o
+
+# ----------------------- IRIX 6.x -----------------------
+
+pd_irix6: $(NAME).pd_irix6
+
+.SUFFIXES: .pd_irix6
+
+SGICFLAGS6 = -n32 -DPD -DUNIX -DIRIX -DN32 -woff 1080,1064,1185 \
+ -OPT:roundoff=3 -OPT:IEEE_arithmetic=3 -OPT:cray_ivdep=true \
+ -Ofast=ip32
+
+.c.pd_irix6:
+ cc $(SGICFLAGS6) $(SGIINCLUDE) -o $*.o -c $*.c
+ ld -n32 -IPA -shared -rdata_shared -o $*.pd_irix6 $*.o
+ rm $*.o
+
+# ----------------------- LINUX i386 -----------------------
+
+pd_linux: $(NAME).pd_linux
+
+.SUFFIXES: .pd_linux
+
+LINUXCFLAGS = -DPD -DUNIX -O2 -funroll-loops -fomit-frame-pointer \
+ -Wall -W -Wshadow -Wstrict-prototypes -Werror \
+ -Wno-unused -Wno-parentheses -Wno-switch -g
+
+LINUXINCLUDE = -I../../src
+
+.c.pd_linux:
+ cc $(LINUXCFLAGS) $(LINUXINCLUDE) -o $*.o -c $*.c
+ ld -export_dynamic -shared -o $*.pd_linux $*.o -lc -lm -L/usr/local/lib -lmp3lame
+ strip --strip-unneeded $*.pd_linux
+ rm -f $*.o ../$*.pd_linux
+ ln -s $*/$*.pd_linux ..
+
+# ----------------------------------------------------------
+
+install:
+ cp help-*.pd ../../doc/5.reference
+
+clean:
+ rm -f *.o *.pd_* so_locations
diff --git a/mp3amp~/README b/mp3amp~/README
new file mode 100644
index 0000000..4ab73ee
--- /dev/null
+++ b/mp3amp~/README
@@ -0,0 +1,45 @@
+Version 0.01
+copyright (c) 2001 by Olaf Matthes & Yves Degoyon
+
+mp3amp~ is a MPEG I Layer III (mp3) icecast/shoutcast client for Pure Data
+
+To install mp3amp~, follow the steps from INSTALL
+
+This software is published under GPL terms.
+
+This is software with ABSOLUTELY NO WARRANTY.
+Use it at your OWN RISK. It's possible to damage e.g. hardware or your hearing
+due to a bug or for other reasons.
+We do not warrant that the program is free of infringement of any third-party
+patents.
+
+*****************************************************************************
+
+mp3amp~ has been compiled for Linux using LAME 3.92.
+The newest version of LAME can be found at sourceforge.net
+
+COPYING: you may use this source under GPL terms!
+
+PLEASE NOTE: This software may contain patented alogrithm (at least
+ patented in some countries). It may be not allowed to sell/use products
+ based on this source code in these countries. Check this out first!
+
+COPYRIGHT of MP3 music:
+ Please note, that the duplicating of copyrighted music without explicit
+ permission violates the rights of the owner.
+
+*****************************************************************************
+
+ using mp3amp~ external for Pure Data
+
+Open the help-mp3amp~.pd to understand how it works.
+Open the help-graphic-mp3amp~.pd if you want to see the status of the incoming stream.
+
+BUGS :
+
+a/ certainly, not all bitrates will work,
+that's too tedious to test, 128, 256, 320 are ok.
+
+b/ cannot instantiate more than 10 decoders, if needed change MAX_DECODERS in the code
+
+c/ this is beta, be patient !!! bugs report welcome !!!
diff --git a/mp3amp~/help-graphic-mp3amp~.pd b/mp3amp~/help-graphic-mp3amp~.pd
new file mode 100644
index 0000000..241a607
--- /dev/null
+++ b/mp3amp~/help-graphic-mp3amp~.pd
@@ -0,0 +1,52 @@
+#N canvas 171 33 789 555 10;
+#X obj 115 265 dac~;
+#X floatatom 164 265 5 0 0;
+#X msg 29 150 disconnect;
+#X text 208 267 connection status;
+#X obj 458 48 loadbang;
+#X msg 458 71 \; pd dsp 1;
+#X msg 99 76 connect yves puredata 8000;
+#X text 96 55 connect <host> <mountpoint> <port>;
+#X text 38 18 constructor : mp3amp~ <graphic flag = 0 | 1>;
+#X text 151 127 connect to SHOUTcast server;
+#X msg 157 145 connect localhost listen.pls 8000;
+#X msg 176 165 connect localhost content/scpromo.mp3 8000;
+#X text 399 141 <-- play livestream;
+#X text 479 165 <-- play file;
+#X msg 121 99 connect localhost kas 8000;
+#X text 97 44 connect to ICEcast server;
+#X text 38 7 mp3amp~ : an icecast/shoucast client for PD;
+#X text 226 186 Another way of connecting;
+#X msg 226 205 connecturl http://localhost:8000/kas;
+#X msg 31 374 standby 0;
+#X text 114 380 for CPU load reasons \,;
+#X text 115 392 ability to freeze decoding;
+#X text 114 405 ( packets are read and ignored );
+#X msg 31 399 standby 1;
+#X obj 115 196 mp3amp~ 1;
+#X msg 353 230 connecturl http://216.235.81.7:20690/play?session=panjabiradio:0&amp\;lid=-1-fra&amp\;SaneID=212.198.0.97-1030988754258
+;
+#X msg 352 280 connecturl http://213.197.144.44:8000/;
+#X msg 352 334 connecturl http://24.207.26.60:8000/;
+#X msg 354 307 connecturl http://64.113.197.158:8000/;
+#X msg 352 361 connecturl http://liveice.agria.hu:8000/radioeger-hq
+;
+#X text 406 511 Authors : Yves Degoyon ( ydegoyon@free.fr );
+#X connect 2 0 24 0;
+#X connect 4 0 5 0;
+#X connect 6 0 24 0;
+#X connect 10 0 24 0;
+#X connect 11 0 24 0;
+#X connect 14 0 24 0;
+#X connect 18 0 24 0;
+#X connect 19 0 24 0;
+#X connect 23 0 24 0;
+#X connect 24 0 0 0;
+#X connect 24 0 0 1;
+#X connect 24 1 0 1;
+#X connect 24 2 1 0;
+#X connect 25 0 24 0;
+#X connect 26 0 24 0;
+#X connect 27 0 24 0;
+#X connect 28 0 24 0;
+#X connect 29 0 24 0;
diff --git a/mp3amp~/help-mp3amp~.pd b/mp3amp~/help-mp3amp~.pd
new file mode 100644
index 0000000..47249b7
--- /dev/null
+++ b/mp3amp~/help-mp3amp~.pd
@@ -0,0 +1,53 @@
+#N canvas 125 102 789 555 10;
+#X obj 115 265 dac~;
+#X floatatom 164 265 5 0 0;
+#X msg 29 150 disconnect;
+#X text 208 267 connection status;
+#X obj 458 48 loadbang;
+#X msg 458 71 \; pd dsp 1;
+#X msg 99 76 connect yves puredata 8000;
+#X text 96 55 connect <host> <mountpoint> <port>;
+#X text 38 18 constructor : mp3amp~ <graphic flag = 0 | 1>;
+#X text 151 127 connect to SHOUTcast server;
+#X msg 157 145 connect localhost listen.pls 8000;
+#X msg 176 165 connect localhost content/scpromo.mp3 8000;
+#X text 399 141 <-- play livestream;
+#X text 479 165 <-- play file;
+#X msg 121 99 connect localhost kas 8000;
+#X text 97 44 connect to ICEcast server;
+#X text 38 7 mp3amp~ : an icecast/shoucast client for PD;
+#X text 226 186 Another way of connecting;
+#X msg 226 205 connecturl http://localhost:8000/kas;
+#X msg 31 374 standby 0;
+#X text 114 380 for CPU load reasons \,;
+#X text 115 392 ability to freeze decoding;
+#X text 114 405 ( packets are read and ignored );
+#X msg 31 399 standby 1;
+#X msg 353 230 connecturl http://216.235.81.7:20690/play?session=panjabiradio:0&amp\;lid=-1-fra&amp\;SaneID=212.198.0.97-1030988754258
+;
+#X msg 352 280 connecturl http://213.197.144.44:8000/;
+#X msg 352 334 connecturl http://24.207.26.60:8000/;
+#X msg 354 307 connecturl http://64.113.197.158:8000/;
+#X msg 352 361 connecturl http://liveice.agria.hu:8000/radioeger-hq
+;
+#X text 406 511 Authors : Yves Degoyon ( ydegoyon@free.fr );
+#X obj 115 196 mp3amp~;
+#X msg 354 384 connecturl http://www.deliciound.net:8000/;
+#X connect 2 0 30 0;
+#X connect 4 0 5 0;
+#X connect 6 0 30 0;
+#X connect 10 0 30 0;
+#X connect 11 0 30 0;
+#X connect 14 0 30 0;
+#X connect 18 0 30 0;
+#X connect 19 0 30 0;
+#X connect 23 0 30 0;
+#X connect 24 0 30 0;
+#X connect 25 0 30 0;
+#X connect 26 0 30 0;
+#X connect 27 0 30 0;
+#X connect 28 0 30 0;
+#X connect 30 0 0 0;
+#X connect 30 1 0 1;
+#X connect 30 2 1 0;
+#X connect 31 0 30 0;
diff --git a/mp3amp~/interface.h b/mp3amp~/interface.h
new file mode 100644
index 0000000..de3136a
--- /dev/null
+++ b/mp3amp~/interface.h
@@ -0,0 +1,32 @@
+/*
+** Copyright (C) 2000 Albert L. Faber
+**
+** This program is free software; you can redistribute it and/or modify
+** it under the terms of the GNU General Public License as published by
+** the Free Software Foundation; either version 2 of the License, or
+** (at your option) any later version.
+**
+** This program is distributed in the hope that it will be useful,
+** but WITHOUT ANY WARRANTY; without even the implied warranty of
+** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+** GNU General Public License for more details.
+**
+** You should have received a copy of the GNU General Public License
+** along with this program; if not, write to the Free Software
+** Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
+*/
+
+#ifndef INTERFACE_H_INCLUDED
+#define INTERFACE_H_INCLUDED
+
+// #include "common.h"
+#include "interface.h"
+
+BOOL InitMP3(PMPSTR mp);
+int decodeMP3(PMPSTR mp,unsigned char *inmemory,int inmemsize,char *outmemory,int outmemsize,int *done);
+void ExitMP3(PMPSTR mp);
+
+/* added remove_buf to support mpglib seeking */
+void remove_buf(PMPSTR mp);
+
+#endif
diff --git a/mp3amp~/mp3amp~.c b/mp3amp~/mp3amp~.c
new file mode 100644
index 0000000..e29c240
--- /dev/null
+++ b/mp3amp~/mp3amp~.c
@@ -0,0 +1,1255 @@
+/* ------------------------- mp3amp~ ------------------------------------------ */
+/* */
+/* Tilde object to receive an mp3-stream from a shoutcast/icecast server. */
+/* Written by Yves Degoyon (ydegoyon@free.fr). */
+/* Get source at http://ydegoyon.free.fr */
+/* */
+/* This library is free software; you can redistribute it and/or */
+/* modify it under the terms of the GNU Lesser General Public */
+/* License as published by the Free Software Foundation; either */
+/* version 2 of the License, or (at your option) any later version. */
+/* */
+/* This library is distributed in the hope that it will be useful, */
+/* but WITHOUT ANY WARRANTY; without even the implied warranty of */
+/* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU */
+/* Lesser General Public License for more details. */
+/* */
+/* You should have received a copy of the GNU Lesser General Public */
+/* License along with this library; if not, write to the */
+/* Free Software Foundation, Inc., 59 Temple Place - Suite 330, */
+/* Boston, MA 02111-1307, USA. */
+/* */
+/* Based on PureData by Miller Puckette and others. */
+/* Uses the LAME MPEG 1 Layer 3 encoding library which can be found at */
+/* http://www.mp3dev.org */
+/* */
+/* ---------------------------------------------------------------------------- */
+
+
+#include "m_imp.h"
+#include "g_canvas.h"
+#include "pthread.h"
+
+#include <sys/types.h>
+#include <string.h>
+#include <stdio.h>
+#include <errno.h>
+#include <fcntl.h>
+#include "mpg123.h" /* mpg123 decoding library from lame 3.92 */
+#include "mpglib.h" /* mpglib decoding library from lame 3.92 */
+#include "interface.h" /* mpglib decoding library from lame 3.92 */
+#ifdef UNIX
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <netinet/tcp.h>
+#include <arpa/inet.h>
+#include <netdb.h>
+#include <sys/time.h>
+#include <unistd.h>
+#include <unistd.h>
+#include <ctype.h>
+#include <stdlib.h>
+#define SOCKET_ERROR -1
+#else
+#include <winsock.h>
+#endif
+
+#ifdef NT
+#pragma warning( disable : 4244 )
+#pragma warning( disable : 4305 )
+#endif
+
+#ifdef UNIX
+#define STRDUP strdup
+#endif
+#ifdef NT
+#define STRDUP _strdup
+#endif
+
+#define LAME_AUDIO_CHUNK_SIZE 1152
+#define MIN_AUDIO_INPUT 2*LAME_AUDIO_CHUNK_SIZE /* we must have at least n chunks to play a steady sound */
+#define INPUT_BUFFER_SIZE 131072 /* data received on the socket : 128k */
+#define OUTPUT_BUFFER_SIZE 131072 /* audio output buffer : 128k */
+#define DECODE_PACKET_SIZE 131072 /* size of the data returned by mpglib : 128k */
+#define STRBUF_SIZE 4096 /* char received from server on startup */
+#define MAX_DECODERS 50
+#define BARHEIGHT 10
+
+static int guidebug=0;
+
+#define SYS_VGUI2(a,b) if (guidebug) \
+ post(a,b);\
+ sys_vgui(a,b)
+
+#define SYS_VGUI3(a,b,c) if (guidebug) \
+ post(a,b,c);\
+ sys_vgui(a,b,c)
+
+#define SYS_VGUI4(a,b,c,d) if (guidebug) \
+ post(a,b,c,d);\
+ sys_vgui(a,b,c,d)
+
+#define SYS_VGUI5(a,b,c,d,e) if (guidebug) \
+ post(a,b,c,d,e);\
+ sys_vgui(a,b,c,d,e)
+
+#define SYS_VGUI6(a,b,c,d,e,f) if (guidebug) \
+ post(a,b,c,d,e,f);\
+ sys_vgui(a,b,c,d,e,f)
+
+#define SYS_VGUI7(a,b,c,d,e,f,g) if (guidebug) \
+ post(a,b,c,d,e,f,g );\
+ sys_vgui(a,b,c,d,e,f,g)
+
+#define SYS_VGUI8(a,b,c,d,e,f,g,h) if (guidebug) \
+ post(a,b,c,d,e,f,g,h );\
+ sys_vgui(a,b,c,d,e,f,g,h)
+
+#define SYS_VGUI9(a,b,c,d,e,f,g,h,i) if (guidebug) \
+ post(a,b,c,d,e,f,g,h,i );\
+ sys_vgui(a,b,c,d,e,f,g,h,i)
+
+
+ /* useful debugging functions from mpglib */
+extern int decode_header( struct frame* fr, unsigned long newhead );
+extern void print_header_compact( struct frame* fr );
+extern int head_check( unsigned long head, int check_layer );
+
+static char *mp3amp_version = "mp3amp~: mp3 streaming client v0.12, written by Yves Degoyon";
+
+/* ------------------------ mp3amp~ ----------------------------- */
+
+static t_class *mp3amp_class;
+
+/* too bad, this needs to be static,
+ handling an array to enable several decoders in pd */
+static MPSTR mps[MAX_DECODERS]; /* decoder buffer */
+static int nbinstances = 0;
+
+extern const long freqs[9];
+
+/* time-out used for select() call */
+static struct timeval ztout;
+
+typedef struct _mp3amp
+{
+ t_object x_obj;
+ t_int x_instance; /* instance of the object */
+ t_outlet *x_connection;
+ t_int x_fd; /* the socket number */
+ t_int x_inframes; /* number of waiting frames */
+ t_int x_dframes; /* displayed frames in status bar */
+ t_int x_packetsize; /* size of the packets */
+ t_int x_pblocks; /* processed blocks */
+ t_int x_graphic; /* indicates if we show a graphic bar */
+ t_canvas *x_canvas; /* remember canvas */
+ t_int x_nbwaitloops; /* number of loops to wait */
+ t_int x_nbloops; /* number of loops processed */
+ t_int x_blocksize; /* size of a dsp block */
+ t_int x_resample; /* resampling factor (pd's sr / stream sr) */
+ t_int x_dsp; /* number of dsp calls, used to measure time */
+ t_int x_standby; /* flag to freeze decoding */
+ t_int x_nooutput; /* flag to avoid output of connection state */
+
+#ifdef UNIX
+ unsigned char *x_inbuffer; /* accumulation buffer for incoming mp3 frames */
+#else
+ char *x_inbuffer; /* accumulation buffer for incoming mp3 frames */
+#endif
+
+ t_int x_inwriteposition;
+ t_int x_inbuffersize;
+ t_int x_offset; /* offset used for start of decoding */
+
+ t_float *x_outbuffer; /* buffer to store audio decoded data */
+ t_int x_outwriteposition;
+ t_int x_outreadposition;
+ t_int x_outunread;
+ t_int x_outbuffersize;
+ char x_out[DECODE_PACKET_SIZE];
+
+ /* mp3 stuff */
+ t_int x_samplerate;
+ t_int x_bitrate; /* bitrate of mp3 stream read at connection time */
+ t_int x_bitrateindex; /* bitrate index for each frame, might change dynamically */
+ t_int x_mp3mode; /* mode (mono, joint stereo, stereo, dual mono) */
+ char* x_bcname; /* name of broadcast */
+ char* x_bcurl; /* url of broadcast */
+ char* x_bcgenre; /* genre of broadcast */
+ char* x_bcaim; /* aim of broadcast */
+ char* x_mountpoint; /* mountpoint for IceCast server */
+ char* x_hostname; /* hostname to connect to */
+ t_int x_port; /* port number to connect to */
+
+ t_int x_stream; /* indicates if a stream is connected ( meaning correct input flow ) */
+} t_mp3amp;
+
+static void mp3amp_recv(t_mp3amp *x);
+static void mp3amp_disconnect(t_mp3amp *x);
+static void mp3amp_connect_url(t_mp3amp *x, t_symbol *url);
+
+static int strip_shout_header(char *head, int n)
+{
+ int i;
+ for (i = 0; i < (n - 2); i++)
+ {
+ if (head[i] == 10 && head[i + 1] == 13)
+ break;
+ if (head[i] == '\n' && head[i + 1] == '\n')
+ break;
+ }
+ head[i + 1] = '\0';
+ return n - (i + 1);
+}
+
+static int strip_ice_header(char *head, int n)
+{
+ int i;
+ for (i = 0; i < (n - 2); i++)
+ {
+ if ((head[i] == '\n') && (head[i + 1] == '\n'))
+ break;
+ }
+ head[i + 1] = '\0';
+ return n - (i + 1);
+}
+
+static void mp3amp_tilde_mpglib_init(t_mp3amp *x)
+{
+ int ret;
+
+ InitMP3(&mps[x->x_instance]);
+}
+
+static int mp3amp_decode_input(t_mp3amp *x)
+{
+ t_int i;
+ t_int alength = 0;
+ float resample = 0;
+ struct frame hframe;
+ unsigned int a,b,c,d;
+ unsigned long cheader;
+ signed short int *p = (signed short int *) x->x_out;
+ t_int pbytes;
+ t_int ret, totlength=0;
+ t_int pframes = 0;
+
+ x->x_offset=0;
+ // search for an header to check dynamic bitrate
+ while ( x->x_offset < x->x_inwriteposition )
+ {
+ /* decode first 4 bytes as the header */
+ a = *((unsigned char*)x->x_inbuffer+x->x_offset);
+ b = *((unsigned char*)x->x_inbuffer+x->x_offset+1);
+ c = *((unsigned char*)x->x_inbuffer+x->x_offset+2);
+ d = *((unsigned char*)x->x_inbuffer+x->x_offset+3);
+
+ cheader = 0;
+ cheader = a;
+ cheader <<= 8;
+ cheader |= b;
+ cheader <<= 8;
+ cheader |= c;
+ cheader <<= 8;
+ cheader |= d;
+ if ( head_check( cheader, 0 ) )
+ {
+ decode_header( &hframe, cheader );
+ if ( hframe.framesize == 0 )
+ {
+ post( "mp3amp~: weird header ( frame size = 0 ) .... ignored" );
+ x->x_offset++;
+ continue;
+ }
+ x->x_packetsize = hframe.framesize;
+ // print_header_compact( &hframe );
+ // when the bitrate change, reinit decoder
+ if ( x->x_bitrateindex != hframe.bitrate_index )
+ {
+ post( "mp3amp~: bitrate has changed, reinitialize decoder" );
+ ExitMP3(&mps[x->x_instance]);
+ InitMP3(&mps[x->x_instance]);
+ x->x_bitrateindex = hframe.bitrate_index;
+ }
+ break;
+ }
+ x->x_offset++;
+ }
+
+ if ( x->x_inframes > 0 )
+ {
+
+ ret = decodeMP3(&mps[x->x_instance], (unsigned char*)(x->x_inbuffer+x->x_offset),
+ hframe.framesize+sizeof( unsigned long), (char *) p, sizeof(x->x_out), &pbytes);
+
+ switch (ret)
+ {
+ case MP3_OK:
+ switch (mps[x->x_instance].fr.stereo) {
+ case 1:
+ case 2:
+ alength = ((mps[x->x_instance].fr.stereo==1)?pbytes >> 1 : pbytes >> 2);
+ // post( "mp3amp~: stereo : %d", mps[x->x_instance].fr.stereo );
+ // update outbuffer contents
+ for ( i=0; i<alength; i++ )
+ {
+ if ( x->x_outunread >= x->x_outbuffersize-2 )
+ {
+ // post( "mp3amp~: decode : too much input ... ignored" );
+ continue;
+ }
+ *(x->x_outbuffer+x->x_outwriteposition) = ((t_float)(*p++))/32767.0;
+ x->x_outwriteposition = (x->x_outwriteposition + 1)%x->x_outbuffersize;
+ *(x->x_outbuffer+x->x_outwriteposition) =
+ ((mps[x->x_instance].fr.stereo==2)?((t_float)(*p++))/32767.0 : 0.0);
+ x->x_outwriteposition = (x->x_outwriteposition + 1)%x->x_outbuffersize;
+ x->x_outunread+=2;
+
+ if ( x->x_outunread >= MIN_AUDIO_INPUT && !x->x_stream )
+ {
+ post("mp3amp~: stream connected" );
+ x->x_resample = x->x_samplerate / freqs[hframe.sampling_frequency];
+ if ( x->x_resample == 0 ) x->x_resample=1;
+ post("mp3amp~: resampling stream from %d to %d Hz (r=%d)",
+ freqs[hframe.sampling_frequency], x->x_samplerate, x->x_resample );
+ x->x_stream = 1;
+ }
+ }
+ break;
+ default:
+ alength = -1;
+ break;
+ }
+ // roll buffer
+ if ( x->x_inwriteposition > hframe.framesize+ (int) sizeof( unsigned long ) + x->x_offset )
+ // ^----- maybe the frame is not complete
+ {
+ x->x_inwriteposition -= hframe.framesize+sizeof( unsigned long )+x->x_offset;
+ memcpy( (void *)(x->x_inbuffer),
+ (void *)(x->x_inbuffer+x->x_offset+hframe.framesize+sizeof( unsigned long )),
+ x->x_inwriteposition);
+ x->x_offset = 0;
+ // post ( "mp3amp~: decoded frame %d", x->x_inframes );
+ x->x_inframes--;
+ pframes++;
+ }
+ else // sorry, it will be ignored
+ {
+ // error( "mp3amp~: incomplete frame...ignored");
+ // x->x_offset = 0;
+ // x->x_inwriteposition = 0;
+ // x->x_inframes = 0;
+ }
+
+ totlength += alength;
+ break;
+
+ case MP3_NEED_MORE:
+ if ( mps[x->x_instance].framesize == 0 && mps[x->x_instance].fsizeold != 0 )
+ {
+ post( "mp3amp~: decoding done (totlength=%d).", totlength );
+ }
+ else
+ {
+ post( "mp3amp~: retry lame decoding (more data needed)." );
+ return -1;
+ }
+ break;
+
+ case MP3_ERR:
+ post( "mp3amp~: lame decoding failed." );
+ return ret;
+ break;
+
+ }
+
+ }
+
+ if ( x->x_graphic && glist_isvisible( x->x_canvas ) )
+ {
+ /* update graphical read status */
+ if ( x->x_inframes != x->x_dframes )
+ {
+ char color[32];
+ t_int width;
+
+ width = rtext_width( glist_findrtext( (t_glist*)x->x_canvas, (t_text *)x ) );
+ SYS_VGUI3(".x%x.c delete rectangle %xSTATUS\n", x->x_canvas, x );
+ if ( x->x_inframes < (MIN_AUDIO_INPUT/LAME_AUDIO_CHUNK_SIZE) )
+ {
+ strcpy( color, "red" );
+ }
+ else
+ {
+ strcpy( color, "lightgreen" );
+ }
+ SYS_VGUI8(".x%x.c create rectangle %d %d %d %d -fill %s -tags %xSTATUS\n",
+ x->x_canvas, x->x_obj.te_xpix, x->x_obj.te_ypix-BARHEIGHT-1,
+ x->x_obj.te_xpix+(x->x_inwriteposition*width)/INPUT_BUFFER_SIZE,
+ x->x_obj.te_ypix - 1, color, x );
+ x->x_dframes = x->x_inframes;
+ }
+ }
+ return totlength;
+}
+
+static void mp3amp_recv(t_mp3amp *x)
+{
+ int ret, i;
+ float resample = 0;
+ struct frame hframe;
+ unsigned int a,b,c,d;
+ unsigned long cheader;
+
+#ifdef UNIX
+ if ( ( ret = recv(x->x_fd, (void*) (x->x_inbuffer + x->x_inwriteposition),
+ (size_t)((x->x_inbuffersize-x->x_inwriteposition)),
+ MSG_NOSIGNAL) ) < 0 )
+#else
+ if(( ret = recv(x->x_fd, (char*)x->x_inbuffer + x->x_inwriteposition,
+ (x->x_inbuffersize-x->x_inwriteposition), 0)) < 0)
+#endif
+ {
+ post( "mp3amp~: receive error" );
+#ifdef UNIX
+ perror( "recv" );
+#endif
+ mp3amp_disconnect(x);
+ return;
+ }
+ else
+ {
+
+ // post( "mp3amp~: received %d bytes at %d on %d ( up to %d)",
+ // ret, x->x_inwriteposition, x->x_fd,
+ // x->x_inbuffersize-x->x_inwriteposition );
+
+ if ( ret == 0 && ( x->x_inbuffersize-x->x_inwriteposition != 0 ) )
+ {
+ error("mp3amp~: stream lost...");
+ mp3amp_disconnect(x);
+ }
+ else
+ {
+ // check if we should decode those packets
+ if ( x->x_standby )
+ {
+ return;
+ }
+ // check we don't overflow input buffer
+ if ( ( x->x_inwriteposition + ret ) > x->x_inbuffersize*0.9 )
+ {
+ post( "mp3streamin~ : too much input...resetting" );
+ x->x_inwriteposition=0;
+ x->x_offset = 0;
+ x->x_inframes = 0;
+ return;
+ }
+ x->x_inwriteposition += ret;
+ x->x_offset = 0;
+ // check some parameters in the stream
+ while ( x->x_offset < x->x_inwriteposition )
+ {
+ /* decode first 4 bytes as the header */
+ a = *((unsigned char*)x->x_inbuffer+x->x_offset);
+ b = *((unsigned char*)x->x_inbuffer+x->x_offset+1);
+ c = *((unsigned char*)x->x_inbuffer+x->x_offset+2);
+ d = *((unsigned char*)x->x_inbuffer+x->x_offset+3);
+
+ cheader = 0;
+ cheader = a;
+ cheader <<= 8;
+ cheader |= b;
+ cheader <<= 8;
+ cheader |= c;
+ cheader <<= 8;
+ cheader |= d;
+ if ( head_check( cheader, 0 ) )
+ {
+ decode_header( &hframe, cheader );
+ // print_header_compact( &hframe );
+ x->x_packetsize = hframe.framesize;
+ if ( hframe.framesize == 0 )
+ {
+ post( "mp3amp~: weird header ( frame size = 0 ) .... ignored" );
+ x->x_inwriteposition -= ret;
+ return;
+ }
+ x->x_inframes += ret/x->x_packetsize;
+ // post( "mp3amp~: nb frames %d", x->x_inframes );
+ break;
+ }
+ x->x_offset++;
+ }
+ }
+ }
+}
+
+static t_int *mp3amp_perform(t_int *w)
+{
+ t_mp3amp *x = (t_mp3amp*) (w[1]);
+ t_float *out1 = (t_float *)(w[2]);
+ t_float *out2 = (t_float *)(w[3]);
+ int n = (int)(w[4]);
+ int ret;
+ int i = 0;
+
+ x->x_blocksize = n;
+ x->x_nbwaitloops = LAME_AUDIO_CHUNK_SIZE/x->x_blocksize;
+ // post( "mp3mp3amp~ : will wait %d loops", x->x_nbwaitloops );
+ x->x_dsp++;
+
+ while( n-- )
+ {
+ if(x->x_stream && !x->x_standby ) // check that the stream provides enough data
+ {
+ if(x->x_resample == 1) /* don't need to resample */
+ {
+ *out1++=*(x->x_outbuffer+x->x_outreadposition);
+ x->x_outreadposition = (x->x_outreadposition + 1)%x->x_outbuffersize;
+ *out2++=*(x->x_outbuffer+x->x_outreadposition);
+ x->x_outreadposition = (x->x_outreadposition + 1)%x->x_outbuffersize;
+ x->x_outunread-=2;
+ }
+ else
+ { /* we just use the same sample x->x_resample times */
+ *out1++=*(x->x_outbuffer+x->x_outreadposition);
+ *out2++=*(x->x_outbuffer+((x->x_outreadposition + 1)%x->x_outbuffersize));
+ if((n%x->x_resample)== 0)
+ {
+ x->x_outreadposition = (x->x_outreadposition + 2)%x->x_outbuffersize;
+ x->x_outunread-=2;
+ }
+ }
+ if ( n == 1 ) x->x_pblocks++;
+ }
+ else
+ {
+ *out1++=0.0;
+ *out2++=0.0;
+ }
+ }
+
+ if ( x->x_pblocks == LAME_AUDIO_CHUNK_SIZE/x->x_blocksize )
+ {
+ x->x_pblocks = 0;
+ }
+
+ /* check for readability, then fill the input buffer */
+ if(( x->x_fd > 0 )&&(x->x_dsp >= 16)) /* determine how often we try to read */
+ {
+ fd_set readset;
+ fd_set exceptset;
+
+ FD_ZERO(&readset);
+ FD_ZERO(&exceptset);
+ FD_SET(x->x_fd, &readset );
+ FD_SET(x->x_fd, &exceptset );
+
+ x->x_dsp = 0;
+
+ if ( select( x->x_fd+1, &readset, NULL, &exceptset, &ztout ) >0 )
+ {
+ if ( FD_ISSET( x->x_fd, &readset) || FD_ISSET( x->x_fd, &exceptset ) )
+ {
+ /* receive data or error */
+ mp3amp_recv(x);
+ }
+ }
+ }
+
+ // check new incoming data
+ if ( x->x_fd > 0 && ( x->x_nbloops == 0 ) && ( x->x_inframes > 0 ) && ( !x->x_standby ) )
+ {
+ mp3amp_decode_input(x);
+ }
+ if ( x->x_nbwaitloops != 0 )
+ {
+ x->x_nbloops = (x->x_nbloops+1 ) % x->x_nbwaitloops;
+ }
+ return (w+5);
+}
+
+static void mp3amp_dsp(t_mp3amp *x, t_signal **sp)
+{
+ dsp_add(mp3amp_perform, 4, x, sp[1]->s_vec, sp[2]->s_vec, sp[1]->s_n);
+}
+
+
+ /* freeze decoding */
+static void mp3amp_standby(t_mp3amp *x, t_floatarg fstandby )
+{
+ if ( fstandby == 0. )
+ {
+ x->x_standby = 0;
+ }
+ else
+ {
+ x->x_standby = 1;
+ }
+}
+
+ /* connection main procedure executed by a thread */
+static void *mp3amp_do_connect(void *tdata )
+{
+ t_mp3amp *x = (t_mp3amp*) tdata;
+ struct sockaddr_in server;
+ struct hostent *hp;
+ t_int portno = x->x_port; /* get port from message box */
+
+ /* variables used for communication with server */
+ char *sptr = NULL;
+ char request[STRBUF_SIZE]; /* string to be send to server */
+ char *url; /* used for relocation */
+ fd_set fdset;
+ struct timeval tv;
+ t_int sockfd; /* socket to server */
+ t_int relocate, numrelocs = 0;
+ t_int i, ret, rest, nanswers=0;
+ char *cpoint = NULL;
+ t_int offset = 0, endofheaders = 0;
+
+ if (x->x_fd >= 0)
+ {
+ error("mp3amp~: already connected");
+ return NULL;
+ }
+
+ sockfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
+ if (sockfd < 0)
+ {
+ error("mp3amp~: internal error while attempting to open socket");
+ return NULL;
+ }
+
+ /* connect socket using hostname provided in command line */
+ server.sin_family = AF_INET;
+ hp = gethostbyname(x->x_hostname);
+ if (hp == 0)
+ {
+ post("mp3amp~: bad host?");
+ sys_closesocket(sockfd);
+ return NULL;
+ }
+ memcpy((char *)&server.sin_addr, (char *)hp->h_addr, hp->h_length);
+
+ /* assign client port number */
+ server.sin_port = htons((unsigned short)portno);
+
+ /* try to connect. */
+ post("mp3amp~: connecting to http:/%s:%d/%s", x->x_hostname, x->x_port, x->x_mountpoint );
+ if (connect(sockfd, (struct sockaddr *) &server, sizeof (server)) < 0)
+ {
+ error("mp3amp~: connection failed!\n");
+ sys_closesocket(sockfd);
+ return NULL;
+ }
+ post("mp3amp~: connected : socket opened" );
+
+ /* sheck if we can read/write from/to the socket */
+ FD_ZERO( &fdset);
+ FD_SET( sockfd, &fdset);
+ tv.tv_sec = 0; /* seconds */
+ tv.tv_usec = 500; /* microseconds */
+
+ ret = select(sockfd + 1, &fdset, NULL, NULL, &tv);
+ if(ret != 0)
+ {
+ error("mp3amp~: can not read from socket");
+ sys_closesocket(sockfd);
+ return NULL;
+ }
+ post("mp3amp~: select done" );
+
+ /* check mountpoint */
+ if( strstr(x->x_mountpoint, "listen.pls") )
+ { /* SHOUTcast playlist -> get / */
+ x->x_mountpoint = "";
+ }
+
+ /* build up stuff we need to send to server */
+ sprintf(request, "GET /%s HTTP/1.0 \r\nHost: %s\r\nUser-Agent: mp3amp~ 0.11\r\nAccept: */*\r\n\r\n",
+ x->x_mountpoint, x->x_hostname);
+
+ if ( send(sockfd, request, strlen(request), 0) < 0 ) /* say hello to server */
+ {
+ post( "mp3amp~: could not contact server... " );
+#ifdef UNIX
+ perror( "send" );
+#endif
+ return NULL;
+ }
+ post("mp3amp~: send done" );
+
+ relocate = FALSE;
+ memset( request, 0x00, STRBUF_SIZE );
+
+ // read all the answer
+ endofheaders=0;
+ while ( !endofheaders )
+ {
+ if( ( ret = recv(sockfd, request+offset, STRBUF_SIZE, MSG_NOSIGNAL) ) <0)
+ {
+ error("mp3amp~: no response from server");
+#ifdef UNIX
+ perror( "recv" );
+#endif
+ return NULL;
+ }
+ post ( "mp3amp~ : received %d bytes at %d", ret, offset );
+ for ( i=offset; i<offset+ret-1; i++ )
+ {
+ if ( ( request[i] == '\n' && request[i+1] == '\n' ) ||
+ ( request[i] == 10 && request[i+1] == 13 ) )
+ {
+ endofheaders=1;
+ }
+ }
+ offset+=ret;
+ }
+
+ // time to parse content of the response...
+ if ( strstr(request, "audio/x-scpls") ) /* SHOUTcast playlist */
+ {
+ /* playlist playing not supported */
+ post("mp3amp~: SHOUTcast server returned a playlist, quitting");
+ sys_closesocket(sockfd);
+ return NULL;
+ }
+ if ( strstr(request, "HTTP") ) /* seems to be IceCast server */
+ {
+ strip_ice_header(request, STRBUF_SIZE);
+ if(sptr = strstr(request, "302"))
+ {
+ cpoint = NULL;
+ cpoint = strstr(request, "Location:");
+ if ( cpoint == NULL )
+ {
+ post( "mp3amp~ : stream has moved but couldn't find new location out of this :" );
+ post("mp3amp~: %s", request );
+ return NULL;
+ }
+ url = STRDUP(cpoint + 10);
+ post("mp3amp~: relocating to %s", url);
+ sys_closesocket(sockfd);
+ x->x_nooutput = 1;
+ mp3amp_connect_url(x, gensym(url));
+ x->x_nooutput = 0;
+ return NULL;
+ // relocate = TRUE;
+ }
+ if( !(sptr = strstr(request, "200")) && !relocate )
+ {
+ error("mp3amp~: cannot connect to the (default) stream");
+ return NULL;
+ }
+
+ post("mp3amp~: IceCast server detected");
+
+ // post("mp3amp~: server's header : %s", request );
+
+ // check what we got
+ if( cpoint = strstr(request, "x-audiocast-mount:"))
+ {
+ x->x_mountpoint = STRDUP(cpoint + 18);
+ for ( i=0; i<(int)strlen(x->x_mountpoint); i++ )
+ {
+ if ( x->x_mountpoint[i] == '\n' )
+ {
+ x->x_mountpoint[i] = '\0';
+ break;
+ }
+ }
+ post(" mountpoint: %s", x->x_mountpoint);
+ }
+ if( cpoint = strstr(request, "x-audiocast-server-url:"))
+ {
+ sptr = STRDUP( cpoint + 24);
+ for ( i=0; i<(int)strlen(sptr); i++ )
+ {
+ if ( sptr[i] == '\n' )
+ {
+ sptr[i] = '\0';
+ break;
+ }
+ }
+ post(" server-url: %s", sptr);
+ }
+ if( cpoint = strstr(request, "x-audiocast-location:"))
+ {
+ sptr = STRDUP( cpoint + 22);
+ for ( i=0; i<(int)strlen(sptr); i++ )
+ {
+ if ( sptr[i] == '\n' )
+ {
+ sptr[i] = '\0';
+ break;
+ }
+ }
+ post(" location: %s", sptr);
+ }
+ if( cpoint = strstr(request, "x-audiocast-admin:"))
+ {
+ sptr = STRDUP( cpoint + 19);
+ for ( i=0; i<(int)strlen(sptr); i++ )
+ {
+ if ( sptr[i] == '\n' )
+ {
+ sptr[i] = '\0';
+ break;
+ }
+ }
+ post(" admin: %s", sptr);
+ }
+ if( cpoint = strstr(request, "x-audiocast-name:"))
+ {
+ x->x_bcname = STRDUP( cpoint + 17);
+ for ( i=0; i<(int)strlen(x->x_bcname); i++ )
+ {
+ if ( x->x_bcname[i] == '\n' )
+ {
+ x->x_bcname[i] = '\0';
+ break;
+ }
+ }
+ post(" name: %s", x->x_bcname);
+ }
+ if( cpoint = strstr(request, "x-audiocast-genre:"))
+ {
+ x->x_bcgenre = STRDUP( cpoint + 18);
+ for ( i=0; i<(int)strlen(x->x_bcgenre); i++ )
+ {
+ if ( x->x_bcgenre[i] == '\n' )
+ {
+ x->x_bcgenre[i] = '\0';
+ break;
+ }
+ }
+ post(" genre: %s", x->x_bcgenre);
+ }
+ if( cpoint = strstr(request, "x-audiocast-url:"))
+ {
+ x->x_bcurl = STRDUP( cpoint + 16);
+ for ( i=0; i<(int)strlen(x->x_bcurl); i++ )
+ {
+ if ( x->x_bcurl[i] == '\n' )
+ {
+ x->x_bcurl[i] = '\0';
+ break;
+ }
+ }
+ post(" url: %s", x->x_bcurl);
+ }
+ if( cpoint = strstr(request, "x-audiocast-public:1"))
+ {
+ post(" broadcast is public");
+ }
+ else if( cpoint = strstr(request, "x-audiocast-public:0"))
+ {
+ post(" broadcast is NOT public");
+ }
+ if( cpoint = strstr(request, "x-audiocast-bitrate:"))
+ {
+ sptr = STRDUP( cpoint + 20);
+ for ( i=0; i<(int)strlen(sptr); i++ )
+ {
+ if ( sptr[i] == '\n' )
+ {
+ sptr[i] = '\0';
+ break;
+ }
+ }
+ if(!strncmp(sptr, "320", 3))x->x_bitrate = 320;
+ else if(!strncmp(sptr, "256", 3))x->x_bitrate = 256;
+ else if(!strncmp(sptr, "224", 3))x->x_bitrate = 224;
+ else if(!strncmp(sptr, "192", 3))x->x_bitrate = 192;
+ else if(!strncmp(sptr, "160", 3))x->x_bitrate = 160;
+ else if(!strncmp(sptr, "144", 3))x->x_bitrate = 144;
+ else if(!strncmp(sptr, "128", 3))x->x_bitrate = 128;
+ else if(!strncmp(sptr, "112", 3))x->x_bitrate = 112;
+ else if(!strncmp(sptr, "96", 2))x->x_bitrate = 96;
+ else if(!strncmp(sptr, "80", 2))x->x_bitrate = 80;
+ else if(!strncmp(sptr, "64", 2))x->x_bitrate = 64;
+ else if(!strncmp(sptr, "56", 2))x->x_bitrate = 56;
+ else if(!strncmp(sptr, "48", 2))x->x_bitrate = 48;
+ else if(!strncmp(sptr, "40", 2))x->x_bitrate = 40;
+ else if(!strncmp(sptr, "32", 2))x->x_bitrate = 32;
+ else if(!strncmp(sptr, "24", 2))x->x_bitrate = 24;
+ else if(!strncmp(sptr, "16", 2))x->x_bitrate = 16;
+ else if(!strncmp(sptr, "8", 1))x->x_bitrate = 8;
+ else
+ {
+ post("mp3amp~: unsupported bitrate! : %s", sptr);
+ return NULL;
+ }
+ post(" bitrate: %d", x->x_bitrate);
+ }
+ if( cpoint = strstr(request, "x-audiocast-udpport:"))
+ {
+ post("mp3amp~: sorry, server wants UDP connection!");
+ return NULL;
+ }
+ }
+ else /* it is a SHOUTcast server */
+ {
+ strip_shout_header (request, STRBUF_SIZE);
+ post("mp3amp~: SHOUTcast server detected");
+ if(strstr(request, "ICY 401") != 0)
+ {
+ post("mp3amp~: ICY 401 Service Unavailable");
+ return NULL;
+ }
+ if (strstr(request, "ICY 200 OK"))
+ {
+ /* recv and decode info about broadcast line by line */
+ post("mp3amp~: connecting to stream...");
+ i = ret;
+ /* check what we got */
+
+ if( cpoint = strstr(request, "icy-name:"))
+ {
+ x->x_bcname = STRDUP( cpoint + 10);
+ for ( i=0; i<(int)strlen(x->x_bcname); i++ )
+ {
+ if ( x->x_bcname[i] == '\n' )
+ {
+ x->x_bcname[i] = '\0';
+ break;
+ }
+ }
+ post(" name: %s", x->x_bcname);
+ }
+ if( cpoint = strstr(request, "x-audiocast-name:"))
+ {
+ x->x_bcname = STRDUP( cpoint + 18);
+ for ( i=0; i<(int)strlen(x->x_bcname); i++ )
+ {
+ if ( x->x_bcname[i] == '\n' )
+ {
+ x->x_bcname[i] = '\0';
+ break;
+ }
+ }
+ post(" name: %s", x->x_bcname);
+ }
+ if( cpoint = strstr(request, "icy-genre:"))
+ {
+ x->x_bcgenre = STRDUP( cpoint + 10);
+ for ( i=0; i<(int)strlen(x->x_bcgenre); i++ )
+ {
+ if ( x->x_bcgenre[i] == '\n' )
+ {
+ x->x_bcgenre[i] = '\0';
+ break;
+ }
+ }
+ post(" name: %s", x->x_bcname);
+ }
+ if( cpoint = strstr(request, "icy-aim:"))
+ {
+ x->x_bcaim = STRDUP( cpoint + 8);
+ for ( i=0; i<(int)strlen(x->x_bcaim); i++ )
+ {
+ if ( x->x_bcaim[i] == '\n' )
+ {
+ x->x_bcaim[i] = '\0';
+ break;
+ }
+ }
+ post(" name: %s", x->x_bcname);
+ }
+ if( cpoint = strstr(request, "icy-url:"))
+ {
+ x->x_bcurl = STRDUP( cpoint + 8);
+ for ( i=0; i<(int)strlen(x->x_bcurl); i++ )
+ {
+ if ( x->x_bcurl[i] == '\n' )
+ {
+ x->x_bcurl[i] = '\0';
+ break;
+ }
+ }
+ post(" name: %s", x->x_bcname);
+ }
+ if(strstr(request, "icy-pub:1"))
+ {
+ post(" broadcast is public");
+ }
+ else if(strstr(request, "icy-pub:0"))
+ {
+ post(" broadcast is NOT public");
+ }
+ if( cpoint = strstr(request, "icy-br:"))
+ {
+ sptr = STRDUP( cpoint + 7);
+ if(!strncmp(sptr, "320", 3))x->x_bitrate = 320;
+ else if(!strncmp(sptr, "256", 3))x->x_bitrate = 256;
+ else if(!strncmp(sptr, "224", 3))x->x_bitrate = 224;
+ else if(!strncmp(sptr, "192", 3))x->x_bitrate = 192;
+ else if(!strncmp(sptr, "160", 3))x->x_bitrate = 160;
+ else if(!strncmp(sptr, "144", 3))x->x_bitrate = 144;
+ else if(!strncmp(sptr, "128", 3))x->x_bitrate = 128;
+ else if(!strncmp(sptr, "112", 3))x->x_bitrate = 112;
+ else if(!strncmp(sptr, "96", 2))x->x_bitrate = 96;
+ else if(!strncmp(sptr, "80", 2))x->x_bitrate = 80;
+ else if(!strncmp(sptr, "64", 2))x->x_bitrate = 64;
+ else if(!strncmp(sptr, "56", 2))x->x_bitrate = 56;
+ else if(!strncmp(sptr, "48", 2))x->x_bitrate = 48;
+ else if(!strncmp(sptr, "40", 2))x->x_bitrate = 40;
+ else if(!strncmp(sptr, "32", 2))x->x_bitrate = 32;
+ else if(!strncmp(sptr, "24", 2))x->x_bitrate = 24;
+ else if(!strncmp(sptr, "16", 2))x->x_bitrate = 16;
+ else if(!strncmp(sptr, "8", 2))x->x_bitrate = 8;
+ else
+ {
+ post("mp3amp~: unsupported bitrate! (%s)", sptr);
+ return NULL;
+ }
+ post(" bitrate: %d", x->x_bitrate);
+ }
+ if(strstr(request, "x-audiocast-udpport:"))
+ {
+ post("mp3amp~: sorry, server wants UDP connection!");
+ return NULL;
+ }
+ }
+ else
+ {
+ post("mp3amp~: unknown response from server");
+ return NULL;
+ }
+ relocate = FALSE;
+ }
+ if (relocate) {
+ error("mp3amp~: too many HTTP relocations");
+ return NULL;
+ }
+ post("mp3amp~: connected to http://%s:%d/%s", hp->h_name, portno, x->x_mountpoint);
+ x->x_fd = sockfd;
+ if ( x->x_graphic && glist_isvisible( x->x_canvas ) )
+ {
+ t_int width;
+
+ width = rtext_width( glist_findrtext( (t_glist*)x->x_canvas, (t_text *)x ) );
+ SYS_VGUI3(".x%x.c delete rectangle %xPBAR\n", x->x_canvas, x );
+ SYS_VGUI7(".x%x.c create rectangle %d %d %d %d -fill lightblue -tags %xPBAR\n",
+ x->x_canvas, x->x_obj.te_xpix, x->x_obj.te_ypix-BARHEIGHT-1,
+ x->x_obj.te_xpix + width, x->x_obj.te_ypix - 1, x );
+ }
+
+ return NULL;
+}
+
+ /* launch the connection thread */
+static void mp3amp_connect(t_mp3amp *x, t_symbol *hostname, t_symbol *mountpoint, t_floatarg fportno )
+{
+ pthread_attr_t update_child_attr;
+ pthread_t connectchild;
+
+ // store data
+ x->x_hostname = (char*) getbytes( strlen( hostname->s_name ) + 1 ); // there's a memory leak here
+ strcpy( x->x_hostname, hostname->s_name );
+
+ x->x_mountpoint = (char*) getbytes( strlen( mountpoint->s_name ) + 1 ); // there's a memory leak here
+ strcpy( x->x_mountpoint, mountpoint->s_name );
+
+ x->x_port = fportno;
+
+ // launch connection thread
+ if ( pthread_attr_init( &update_child_attr ) < 0 ) {
+ post( "mp3amp~ : could not launch connection thread" );
+ perror( "pthread_attr_init" );
+ return;
+ }
+ if ( pthread_attr_setdetachstate( &update_child_attr, PTHREAD_CREATE_DETACHED ) < 0 ) {
+ post( "mp3amp~ : could not launch connection thread" );
+ perror( "pthread_attr_setdetachstate" );
+ return;
+ }
+ if ( pthread_create( &connectchild, &update_child_attr, mp3amp_do_connect, x ) < 0 ) {
+ post( "mp3amp~ : could not launch connection thread" );
+ perror( "pthread_create" );
+ return;
+ }
+ else
+ {
+ // post( "cooled~ : drawing thread %d launched", (int)x->x_updatechild );
+ }
+
+ if ( !x->x_nooutput ) outlet_float(x->x_connection, 1);
+}
+
+ /* connect using url like "http://localhost:8000/mountpoint" */
+static void mp3amp_connect_url(t_mp3amp *x, t_symbol *url)
+{
+ char *hostptr = NULL, *p, *endhost = NULL, *hostname = NULL;
+ char *pathptr = NULL;
+ t_int portno = 8000;
+
+ post( "mp3amp~ : connect url : %s", url->s_name );
+
+ /* strip http:// or ftp:// */
+ p = url->s_name;
+ if (strncmp(p, "http://", 7) == 0)
+ p += 7;
+
+ if (strncmp(p, "ftp://", 6) == 0)
+ p += 6;
+
+ hostptr = p;
+ while (*p && *p != '/' && *p != ':') /* look for end of hostname: */
+ p++;
+
+ endhost = p;
+ switch ( *p )
+ {
+ case ':' :
+ portno = atoi( p+1 );
+ while (*p && *p != '/') p++;
+ pathptr = p+1;
+ break;
+ case '/' :
+ portno = 8000;
+ pathptr = p+1;
+ break;
+ default :
+ if ( ( p - url->s_name ) != (int)strlen( url->s_name ) )
+ {
+ post( "mp3amp~ : wrong url : %s", hostptr );
+ return;
+ }
+ pathptr = "";
+ break;
+ }
+
+ hostname=(char*)getbytes( (int)(endhost - hostptr) + 1);
+ strncpy( hostname, hostptr, (int)(endhost - hostptr) );
+ hostname[ endhost - hostptr ] = '\0';
+
+ post ("mp3amp~ : connecting to host=%s port=%d path=%s", hostname, portno, pathptr );
+
+ /* call the 'normal' connection routine */
+ mp3amp_connect(x, gensym(hostname), gensym(pathptr), portno);
+}
+
+ /* close connection to SHOUTcast server */
+static void mp3amp_disconnect(t_mp3amp *x)
+{
+ x->x_stream = 0;
+ x->x_inframes = 0;
+ x->x_dframes = 0;
+ x->x_inwriteposition = 0;
+ x->x_offset = 0;
+ if(x->x_fd >= 0) /* close socket */
+ {
+ sys_closesocket(x->x_fd);
+ x->x_fd = -1;
+ }
+ ExitMP3(&mps[x->x_instance]);
+ InitMP3(&mps[x->x_instance]);
+ if ( x->x_graphic )
+ {
+ SYS_VGUI3(".x%x.c delete rectangle %xPBAR\n", x->x_canvas, x );
+ SYS_VGUI3(".x%x.c delete rectangle %xSTATUS\n", x->x_canvas, x );
+ }
+ post("mp3amp~: connection closed");
+ outlet_float(x->x_connection, 0);
+}
+
+static void mp3amp_free(t_mp3amp *x)
+{
+ if (x->x_fd > 0) {
+ post( "mp3amp~: closing socket" );
+ sys_closesocket(x->x_fd);
+ x->x_fd = -1;
+ }
+ freebytes(x->x_inbuffer, INPUT_BUFFER_SIZE);
+ freebytes(x->x_outbuffer, OUTPUT_BUFFER_SIZE*sizeof(t_float));
+}
+
+static void *mp3amp_new(t_floatarg fdographics)
+{
+ t_mp3amp *x = NULL;
+
+ if ( ((int)fdographics != 0) && ((int)fdographics != 1.) )
+ {
+ post( "mp3amp~: error : constructor : mp3amp~ [graphic flag = 0 | 1 ] ( got = %f)", fdographics );
+ return NULL;
+ }
+
+ x = (t_mp3amp *)pd_new(mp3amp_class);
+ outlet_new(&x->x_obj, gensym("signal"));
+ outlet_new(&x->x_obj, gensym("signal"));
+ x->x_connection = outlet_new(&x->x_obj, gensym("float"));
+
+ if ( nbinstances < MAX_DECODERS )
+ {
+ x->x_instance = nbinstances++;
+ }
+ else
+ {
+ post( "mp3amp~: cannot create more decoders (memory issues), sorry" );
+ return NULL;
+ }
+
+ x->x_fd = -1;
+ x->x_stream = 0;
+ x->x_inframes = 0;
+ x->x_samplerate = sys_getsr();
+ x->x_nbwaitloops = 1;
+ x->x_nbloops = 0;
+ x->x_dsp = 0;
+
+ x->x_inbuffersize = INPUT_BUFFER_SIZE;
+ x->x_outbuffersize = OUTPUT_BUFFER_SIZE;
+ x->x_inbuffer = (unsigned char*) getbytes(INPUT_BUFFER_SIZE);
+ x->x_offset = 0;
+ x->x_outbuffer = (t_float*) getbytes(OUTPUT_BUFFER_SIZE*sizeof(t_float));
+
+ if ( !x->x_inbuffer || !x->x_outbuffer )
+ {
+ post( "mp3amp~: could not allocate buffers" );
+ return NULL;
+ }
+ memset( x->x_inbuffer, 0x0, INPUT_BUFFER_SIZE );
+ memset( x->x_outbuffer, 0x0, OUTPUT_BUFFER_SIZE );
+
+ x->x_inwriteposition = 0;
+ x->x_outreadposition = 0;
+ x->x_outwriteposition = 0;
+ x->x_outunread = 0;
+ x->x_standby = 0;
+ x->x_resample = -1;
+ x->x_nooutput = 0;
+
+ ztout.tv_sec = 0;
+ ztout.tv_usec = 0;
+
+ x->x_graphic = (int)fdographics;
+ post( "mp3amp~: getting canvas" );
+ x->x_canvas = canvas_getcurrent();
+
+ post( "mp3amp~: initializing decoder..." );
+ /* init mpg123 decoder */
+ mp3amp_tilde_mpglib_init(x);
+
+ post(mp3amp_version);
+
+ return (x);
+}
+
+
+void mp3amp_tilde_setup(void)
+{
+ mp3amp_class = class_new(gensym("mp3amp~"),
+ (t_newmethod) mp3amp_new, (t_method) mp3amp_free,
+ sizeof(t_mp3amp), 0, A_DEFFLOAT, A_NULL);
+
+ class_addmethod(mp3amp_class, nullfn, gensym("signal"), 0);
+ class_addmethod(mp3amp_class, (t_method)mp3amp_dsp, gensym("dsp"), 0);
+ class_addmethod(mp3amp_class, (t_method)mp3amp_connect, gensym("connect"), A_SYMBOL, A_SYMBOL, A_FLOAT, 0);
+ class_addmethod(mp3amp_class, (t_method)mp3amp_connect_url, gensym("connecturl"), A_SYMBOL, 0);
+ class_addmethod(mp3amp_class, (t_method)mp3amp_standby, gensym("standby"), A_DEFFLOAT, 0);
+ class_addmethod(mp3amp_class, (t_method)mp3amp_disconnect, gensym("disconnect"), 0);
+ class_sethelpsymbol(mp3amp_class, gensym("help-mp3amp~.pd"));
+}
diff --git a/mp3amp~/mpg123.h b/mp3amp~/mpg123.h
new file mode 100644
index 0000000..1c530d3
--- /dev/null
+++ b/mp3amp~/mpg123.h
@@ -0,0 +1,136 @@
+#ifndef MPG123_H_INCLUDED
+#define MPG123_H_INCLUDED
+
+#include <stdio.h>
+
+#define STDC_HEADERS
+
+#ifdef STDC_HEADERS
+# include <string.h>
+#else
+# ifndef HAVE_STRCHR
+# define strchr index
+# define strrchr rindex
+# endif
+char *strchr (), *strrchr ();
+# ifndef HAVE_MEMCPY
+# define memcpy(d, s, n) bcopy ((s), (d), (n))
+# define memmove(d, s, n) bcopy ((s), (d), (n))
+# endif
+#endif
+
+#include <signal.h>
+
+
+#if defined(__riscos__) && defined(FPA10)
+#include "ymath.h"
+#else
+#include <math.h>
+#endif
+
+#ifndef M_PI
+#define M_PI 3.14159265358979323846
+#endif
+#ifndef M_SQRT2
+#define M_SQRT2 1.41421356237309504880
+#endif
+
+#ifndef FALSE
+#define FALSE 0
+#endif
+#ifndef TRUE
+#define TRUE 1
+#endif
+
+
+#ifdef REAL_IS_FLOAT
+# define real float
+#elif defined(REAL_IS_LONG_DOUBLE)
+# define real long double
+#else
+# define real double
+#endif
+
+#define FALSE 0
+#define TRUE 1
+
+#define SBLIMIT 32
+#define SSLIMIT 18
+
+#define MPG_MD_STEREO 0
+#define MPG_MD_JOINT_STEREO 1
+#define MPG_MD_DUAL_CHANNEL 2
+#define MPG_MD_MONO 3
+
+#define MAXFRAMESIZE 1792
+
+/* AF: ADDED FOR LAYER1/LAYER2 */
+#define SCALE_BLOCK 12
+
+
+/* Pre Shift fo 16 to 8 bit converter table */
+#define AUSHIFT (3)
+
+struct frame {
+ int stereo;
+ int jsbound;
+ int single;
+ int lsf;
+ int mpeg25;
+ int header_change;
+ int lay;
+ int error_protection;
+ int bitrate_index;
+ int sampling_frequency;
+ int padding;
+ int extension;
+ int mode;
+ int mode_ext;
+ int copyright;
+ int original;
+ int emphasis;
+ int framesize; /* computed framesize */
+
+ /* AF: ADDED FOR LAYER1/LAYER2 */
+#if defined(USE_LAYER_2) || defined(USE_LAYER_1)
+ int II_sblimit;
+ struct al_table2 *alloc;
+ int down_sample_sblimit;
+ int down_sample;
+
+#endif
+
+};
+
+struct gr_info_s {
+ int scfsi;
+ unsigned part2_3_length;
+ unsigned big_values;
+ unsigned scalefac_compress;
+ unsigned block_type;
+ unsigned mixed_block_flag;
+ unsigned table_select[3];
+ unsigned subblock_gain[3];
+ unsigned maxband[3];
+ unsigned maxbandl;
+ unsigned maxb;
+ unsigned region1start;
+ unsigned region2start;
+ unsigned preflag;
+ unsigned scalefac_scale;
+ unsigned count1table_select;
+ real *full_gain[3];
+ real *pow2gain;
+};
+
+struct III_sideinfo
+{
+ unsigned main_data_begin;
+ unsigned private_bits;
+ struct {
+ struct gr_info_s gr[2];
+ } ch[2];
+};
+
+
+#endif
diff --git a/mp3amp~/mpglib.h b/mp3amp~/mpglib.h
new file mode 100644
index 0000000..1f4ef9a
--- /dev/null
+++ b/mp3amp~/mpglib.h
@@ -0,0 +1,65 @@
+// #include "lame-analysis.h"
+
+#define NOANALYSIS
+
+#ifndef NOANALYSIS
+extern plotting_data *mpg123_pinfo;
+#endif
+
+struct buf {
+ unsigned char *pnt;
+ long size;
+ long pos;
+ struct buf *next;
+ struct buf *prev;
+};
+
+struct framebuf {
+ struct buf *buf;
+ long pos;
+ struct frame *next;
+ struct frame *prev;
+};
+
+typedef struct mpstr_tag {
+ struct buf *head,*tail;
+ int vbr_header; /* 1 if valid Xing vbr header detected */
+ int num_frames; /* set if vbr header present */
+ int enc_delay; /* set if vbr header present */
+ int enc_padding; /* set if vbr header present */
+ int header_parsed;
+ int side_parsed;
+ int data_parsed;
+ int free_format; /* 1 = free format frame */
+ int old_free_format; /* 1 = last frame was free format */
+ int bsize;
+ int framesize;
+ int ssize;
+ int dsize;
+ int fsizeold;
+ int fsizeold_nopadding;
+ struct frame fr;
+ unsigned char bsspace[2][MAXFRAMESIZE+512]; /* MAXFRAMESIZE */
+ real hybrid_block[2][2][SBLIMIT*SSLIMIT];
+ int hybrid_blc[2];
+ unsigned long header;
+ int bsnum;
+ real synth_buffs[2][2][0x110];
+ int synth_bo;
+ int sync_bitstream;
+
+} MPSTR, *PMPSTR;
+
+
+#if ( defined(_MSC_VER) || defined(__BORLANDC__) )
+ typedef int BOOL; /* windef.h contains the same definition */
+#else
+ #define BOOL int
+#endif
+
+#define MP3_ERR -1
+#define MP3_OK 0
+#define MP3_NEED_MORE 1
+
+
+
diff --git a/mp3amp~/punjabi-2.pls b/mp3amp~/punjabi-2.pls
new file mode 100644
index 0000000..6db94ea
--- /dev/null
+++ b/mp3amp~/punjabi-2.pls
@@ -0,0 +1,3 @@
+[playlist]
+NumberOfEntries=1
+File1=http://www.live365.com/play/295522?membername=&session=punjabicity02%3A0&pid=&SaneID=212.198.0.97-1030988754258&lid=-1-fra
diff --git a/mp3amp~/punjabi-3.pls b/mp3amp~/punjabi-3.pls
new file mode 100644
index 0000000..507f782
--- /dev/null
+++ b/mp3amp~/punjabi-3.pls
@@ -0,0 +1,3 @@
+[playlist]
+NumberOfEntries=1
+File1=http://www.live365.com/play/152468?membername=&session=indianmp3%3A0&pid=&SaneID=212.198.0.97-1030988754258&lid=-1-fra
diff --git a/mp3amp~/punjabi-4.pls b/mp3amp~/punjabi-4.pls
new file mode 100644
index 0000000..24fb8ff
--- /dev/null
+++ b/mp3amp~/punjabi-4.pls
@@ -0,0 +1,3 @@
+[playlist]
+NumberOfEntries=1
+File1=http://www.live365.com/play/159295?membername=&session=panjabiradio%3A0&pid=&SaneID=212.198.0.97-1030988754258&lid=-1-fra
diff --git a/mp3amp~/punjabi.pls b/mp3amp~/punjabi.pls
new file mode 100644
index 0000000..24fb8ff
--- /dev/null
+++ b/mp3amp~/punjabi.pls
@@ -0,0 +1,3 @@
+[playlist]
+NumberOfEntries=1
+File1=http://www.live365.com/play/159295?membername=&session=panjabiradio%3A0&pid=&SaneID=212.198.0.97-1030988754258&lid=-1-fra
generated by cgit v1.2.1 (git 2.18.0) at 2024-05-29 01:29:52 +0000