summaryrefslogtreecommitdiffstats
path: root/soundserver/artscat.cpp
diff options
context:
space:
mode:
authorMichele Calgaro <michele.calgaro@yahoo.it>2020-12-06 19:28:06 +0900
committerMichele Calgaro <michele.calgaro@yahoo.it>2020-12-06 19:28:06 +0900
commit00d4f92b717fbcbed6f9eee361975d6ee5380d59 (patch)
tree043b5970d66e539e1fbf6dde03440d6569e34c4e /soundserver/artscat.cpp
parent2f53bfe61c8ee78ff36ac6c66ae714b01e407b33 (diff)
downloadarts-00d4f92b717fbcbed6f9eee361975d6ee5380d59.tar.gz
arts-00d4f92b717fbcbed6f9eee361975d6ee5380d59.zip
Renaming of files in preparation for code style tools.
Signed-off-by: Michele Calgaro <michele.calgaro@yahoo.it>
Diffstat (limited to 'soundserver/artscat.cpp')
-rw-r--r--soundserver/artscat.cpp244
1 files changed, 244 insertions, 0 deletions
diff --git a/soundserver/artscat.cpp b/soundserver/artscat.cpp
new file mode 100644
index 0000000..c6818c8
--- /dev/null
+++ b/soundserver/artscat.cpp
@@ -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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, 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);
+}