Copy of aRts for Trinity modifications

git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/dependencies/arts@1070145 283d02a7-25f6-0310-bc7c-ecb5cbfe19da

1 files changed, 244 insertions, 0 deletions

diff --git a/soundserver/artscat.cc b/soundserver/artscat.cc
new file mode 100644
index 0000000..28b1aaf
--- /dev/null
+++ b/soundserver/artscat.cc
@@ -0,0 +1,244 @@
+    /*
+
+    Copyright (C) 2000 Stefan Westerfeld
+                       stefan@space.twc.de
+
+    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.
+
+    Permission is also granted to link this program with the Qt
+    library, treating Qt like a library that normally accompanies the
+    operating system kernel, whether or not that is in fact the case.
+
+    */
+
+#include "soundserver.h"
+#include "stdsynthmodule.h"
+#include "artsversion.h"
+
+#include <stdio.h>
+#include <unistd.h>
+#include <fcntl.h>
+#include <iostream>
+#include <cstdlib>
+
+using namespace std;
+using namespace Arts;
+
+int cfgSamplingRate = 44100;
+int cfgBits = 16;
+int cfgChannels = 2;
+string cfgTitle = "artscat";
+
+class Sender :	public ByteSoundProducerV2_skel,
+				public StdSynthModule,
+				public IONotify
+{
+protected:
+	FILE *pfile;
+	int pfd;
+	int packets;
+	bool waiting;
+	queue< DataPacket<mcopbyte>* > wqueue;
+public:
+	Sender(FILE *input,float minStreamBufferTime) : pfile(input), waiting(false)
+	{
+		pfd = fileno(pfile);
+
+		int rc = fcntl(pfd, F_SETFL, O_NONBLOCK);
+		assert(rc != -1);
+
+		/*
+		 * calculate stream buffer parameters
+		 */
+		float streamBufferTime;
+		packets = 7;
+		do {
+			packets++;
+			streamBufferTime = (float)(packets * packetCapacity * 1000)
+			                 / (float)(samplingRate() * channels() * 2);
+		} while(streamBufferTime < minStreamBufferTime);
+	}
+
+	~Sender()
+	{
+		if(waiting) Dispatcher::the()->ioManager()->remove(this,IOType::read);
+	}
+
+	long samplingRate() { return cfgSamplingRate; }
+	long channels()     { return cfgChannels; }
+	long bits()         { return cfgBits; }
+	bool finished()     { return (pfile == 0); }
+	string title()		{ return cfgTitle; }
+
+	void streamStart()
+	{
+		/*
+		 * start streaming
+		 */
+		outdata.setPull(packets, packetCapacity);
+	}
+
+	enum { packetCapacity = 4096 };
+	void handle_eof()
+	{
+		/*
+		 * cleanup
+		 */
+		outdata.endPull();
+		pclose(pfile);
+		pfile = 0;
+		pfd = 0;
+
+		/*
+		 * remove all packets from the wqueue
+		 */
+		while(!wqueue.empty())
+		{
+			DataPacket<mcopbyte> *packet = wqueue.front();
+			packet->size = 0;
+			packet->send();
+			wqueue.pop();
+		}
+		
+		/*
+		 * go out of the waiting mode
+		 */
+		if(waiting)
+		{
+			Dispatcher::the()->ioManager()->remove(this,IOType::read);
+			waiting = false;
+		}
+
+		/*
+		 * terminate dispatcher to end the program
+		 */
+		Dispatcher::the()->terminate();
+	}
+	void request_outdata(DataPacket<mcopbyte> *packet)
+	{
+		if(!waiting)
+		{
+			packet->size = read(pfd, packet->contents, packetCapacity);
+			if(packet->size > 0)
+			{
+				// got something - done here
+				packet->send();
+				return;
+			}
+			Dispatcher::the()->ioManager()->watchFD(pfd,IOType::read,this);
+			waiting = true;
+		}
+
+		wqueue.push(packet);
+	}
+
+	void notifyIO(int,int)
+	{
+		assert(waiting);
+
+		DataPacket<mcopbyte> *packet = wqueue.front();
+		packet->size = read(pfd, packet->contents, packetCapacity);
+		assert(packet->size >= 0);
+		if(packet->size == 0) {
+			handle_eof();
+			return;
+		}
+		packet->send();
+
+		wqueue.pop();
+
+		if(wqueue.empty())
+		{
+			Dispatcher::the()->ioManager()->remove(this,IOType::read);
+			waiting = false;
+		}
+	}
+};
+
+static void exitUsage(const char *progname)
+{
+	fprintf(stderr,"usage: %s [ options ] [ <filename> ]\n",progname);
+	fprintf(stderr,"-r <samplingrate>   set samplingrate to use\n");
+	fprintf(stderr,"-b <bits>           set number of bits (8 or 16)\n");
+	fprintf(stderr,"-c <channels>       set number of channels (1 or 2)\n");
+	fprintf(stderr,"-t <title>          set stream title\n");
+	fprintf(stderr,"-v                  show version\n");
+	fprintf(stderr,"-h                  display this help and exit\n");
+	exit(1);	
+}
+
+int main(int argc, char **argv)
+{
+	bool titleSetByUser = false;
+	int optch;
+	while((optch = getopt(argc,argv,"r:b:c:t:hv")) > 0)
+	{
+		switch(optch)
+		{
+			case 'r':
+				cfgSamplingRate = atoi(optarg);
+				break;
+			case 'b':
+				cfgBits = atoi(optarg);
+				break;
+			case 'c':
+				cfgChannels = atoi(optarg);
+				break;
+			case 't':
+				cfgTitle = optarg;
+				titleSetByUser = true;
+				break;
+			case 'v':
+				printf("artscat %s\n",ARTS_VERSION);
+				exit(0);
+				break;
+			case 'h':
+			default:
+				exitUsage(argc?argv[0]:"artscat");
+				break;
+		}
+	}
+
+	FILE *infile = stdin;
+
+	if (optind < argc)
+	{
+		string filename = argv[optind];
+		if(filename != "-")
+		{
+			infile = fopen(filename.c_str(),"r");
+			if(!infile)
+			{
+				cerr << "Can't open file '" << argv[optind] << "'." << endl;
+				exit(1);
+			}
+			if(!titleSetByUser) cfgTitle = filename;
+		}
+	}
+	Dispatcher dispatcher;
+	SimpleSoundServer server(Reference("global:Arts_SimpleSoundServer"));
+
+	if(server.isNull())
+	{
+		cerr << "Can't connect to sound server" << endl;
+		return 1;
+	}
+
+	ByteSoundProducerV2 sender = ByteSoundProducerV2::_from_base(new Sender(infile,server.minStreamBufferTime()));
+	server.attach(sender);
+	sender.start();
+	dispatcher.run();
+	server.detach(sender);
+}