summaryrefslogtreecommitdiffstats
path: root/flow/gslschedule.h
diff options
context:
space:
mode:
authortpearson <tpearson@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2010-01-05 00:01:18 +0000
committertpearson <tpearson@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2010-01-05 00:01:18 +0000
commit42995d7bf396933ee60c5f89c354ea89cf13df0d (patch)
treecfdcea0ac57420e7baf570bfe435e107bb842541 /flow/gslschedule.h
downloadarts-42995d7bf396933ee60c5f89c354ea89cf13df0d.tar.gz
arts-42995d7bf396933ee60c5f89c354ea89cf13df0d.zip
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
Diffstat (limited to 'flow/gslschedule.h')
-rw-r--r--flow/gslschedule.h262
1 files changed, 262 insertions, 0 deletions
diff --git a/flow/gslschedule.h b/flow/gslschedule.h
new file mode 100644
index 0000000..4564dfc
--- /dev/null
+++ b/flow/gslschedule.h
@@ -0,0 +1,262 @@
+ /*
+
+ Copyright (C) 2000-2002 Stefan Westerfeld
+ stefan@space.twc.de
+
+ This library is free software; you can redistribute it and/or
+ modify it under the terms of the GNU Library 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
+ Library General Public License for more details.
+
+ You should have received a copy of the GNU Library General Public License
+ along with this library; see the file COPYING.LIB. If not, write to
+ the Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+ Boston, MA 02111-1307, USA.
+
+ */
+
+#ifndef ARTS_GSLSCHEDULE_H
+#define ARTS_GSLSCHEDULE_H
+
+#include "artsflow.h"
+#include "flowsystem.h"
+#include <gsl/gsldefs.h>
+#include <string>
+#include <list>
+
+/*
+ * BC - Status (2002-03-08): Port, AudioPort, MultiPort, StdFlowSystem,
+ * StdScheduleNode
+ *
+ * None of these classes is considered part of the public API. Do NOT use it
+ * in your apps. These are part of the implementation of libartsflow's
+ * StdFlowSystem, and subject to change with the needs of it.
+ *
+ * If you want to access flowsystem functionality, do so over the core.idl
+ * specified flowsystem interface, (object)->_node() or stuff in mcop/connect.h.
+ */
+
+namespace Arts {
+
+class StdScheduleNode;
+
+class Port {
+ friend class VPort; // TODO: debugging, remove me when it works?
+ friend class VPortConnection; // TODO: debugging, remove me when it works?
+protected:
+ std::string _name;
+public:
+ void *_ptr;
+public: // FIXME: GSL
+ AttributeType _flags;
+ StdScheduleNode *parent;
+
+ // each port has a virtual port, which allows port redirection
+ class VPort *_vport;
+
+ // dynamic ports are created to implement multiports
+ bool _dynamicPort;
+
+ // functionality to remove all connections automatically as soon as
+ // the module gets destroyed
+ std::list<Port *> autoDisconnect;
+
+ /**
+ * call these from your (dis)connect implementation as soon as a the
+ * port gets (dis)connected to some other port (only one call per
+ * connection: destinationport->addAutoDisconnect(sourceport), not
+ * for the other direction)
+ */
+ void addAutoDisconnect(Port *source);
+ void removeAutoDisconnect(Port *source);
+
+public:
+ Port(const std::string& name, void *ptr, long flags,
+ StdScheduleNode* parent);
+ virtual ~Port();
+
+ inline VPort* vport() { assert(_vport); return _vport; }
+ AttributeType flags();
+ std::string name();
+ void setPtr(void *ptr);
+
+ inline bool dynamicPort() { return _dynamicPort; }
+ inline void setDynamicPort() { _dynamicPort = true; }
+
+ virtual class AudioPort *audioPort();
+ virtual class ASyncPort *asyncPort();
+
+ virtual void disconnectAll();
+ virtual void connect(Port *) = 0;
+ virtual void disconnect(Port *) = 0;
+};
+
+class AudioPort : public Port {
+public: // FIXME: GSL
+ AudioPort *source;
+
+public:
+ StdScheduleNode *sourcemodule;
+ unsigned long destcount;
+ unsigned long gslEngineChannel;
+
+ /* GSL */
+ bool gslIsConstant;
+ float gslConstantValue;
+
+ AudioPort(const std::string& name,
+ void *ptr, long flags,StdScheduleNode *parent);
+ ~AudioPort();
+
+ virtual class AudioPort *audioPort();
+
+ void setFloatValue(float f);
+ void connect(Port *psource);
+ void disconnect(Port *psource);
+};
+
+class MultiPort : public Port {
+protected:
+ struct Part {
+ AudioPort *src, *dest;
+ };
+
+ std::list<Part> parts;
+ typedef float *float_ptr;
+ float **conns;
+ long nextID;
+ void initConns();
+
+public:
+ MultiPort(const std::string& name,
+ void *ptr, long flags,StdScheduleNode *parent);
+ ~MultiPort();
+
+ void connect(Port *port);
+ void disconnect(Port *port);
+};
+
+class StdFlowSystem;
+
+class StdScheduleNode :public ScheduleNode
+{
+ friend class StdFlowSystem;
+ bool running;
+ bool suspended;
+
+ Object_skel *_object;
+ SynthModule_base *module;
+ StdFlowSystem *flowSystem;
+ std::list<Port *> ports;
+ AudioPort **inConn;
+ AudioPort **outConn;
+ unsigned long inConnCount, outConnCount;
+ typedef AudioPort *AudioPort_ptr;
+ QueryInitStreamFunc queryInitStreamFunc;
+
+ void freeConn();
+ void rebuildConn();
+ void accessModule();
+
+ static void gslProcess(GslModule *module, guint n_values);
+ public: /* TODO? */
+ Port *findPort(const std::string& name);
+
+public:
+
+ GslModule *gslModule;
+ bool gslRunning;
+
+ /**
+ * this is used by StdFlowSystem::suspend() to mark nodes which
+ * have already been seen by the algorithm
+ */
+ bool suspendTag;
+
+ StdScheduleNode(Object_skel *object, StdFlowSystem *flowSystem);
+ virtual ~StdScheduleNode();
+ void initStream(const std::string& name, void *ptr, long flags);
+ void addDynamicPort(Port *port);
+ void removeDynamicPort(Port *port);
+
+ void start();
+ void stop();
+ void requireFlow();
+ void virtualize(const std::string& port, ScheduleNode *implNode,
+ const std::string& implPort);
+ void devirtualize(const std::string& port, ScheduleNode *implNode,
+ const std::string& implPort);
+
+ // AutoSuspend stuff
+ AutoSuspendState suspendable();
+ void suspend();
+ void restart();
+
+ void connect(const std::string& port, ScheduleNode *dest,
+ const std::string& destport);
+ void disconnect(const std::string& port, ScheduleNode *dest,
+ const std::string& destport);
+
+ AttributeType queryFlags(const std::string& port);
+ void setFloatValue(const std::string& port, float value);
+
+ Object_skel *object();
+ void *cast(const std::string &target);
+
+ // used by StdSynthModule
+ unsigned long inputConnectionCount(const std::string& port);
+ unsigned long outputConnectionCount(const std::string& port);
+
+ bool _connectionCountChanged;
+ inline bool connectionCountChanged() {
+ bool c = _connectionCountChanged;
+ _connectionCountChanged = false;
+ return c;
+ }
+};
+
+class StdFlowSystem :public FlowSystem_impl
+{
+protected:
+ std::list<StdScheduleNode *> nodes;
+ bool _suspended;
+ bool needUpdateStarted;
+public:
+ StdFlowSystem();
+
+ ScheduleNode *addObject(Object_skel *object);
+ void removeObject(ScheduleNode *node);
+
+ /* AutoSuspend */
+ bool suspendable();
+ bool suspended();
+ void suspend();
+ void restart();
+
+ /* remote accessibility */
+ void startObject(Object node);
+ void stopObject(Object node);
+ void connectObject(Object sourceObject, const std::string& sourcePort,
+ Object destObject, const std::string& destPort);
+ void disconnectObject(Object sourceObject, const std::string& sourcePort,
+ Object destObject, const std::string& destPort);
+ AttributeType queryFlags(Object node, const std::string& port);
+ void setFloatValue(Object node, const std::string& port, float value);
+
+ FlowSystemReceiver createReceiver(Object object, const std::string &port,
+ FlowSystemSender sender);
+
+ /* interface to StdScheduleNode */
+ void schedule(unsigned long samples);
+ void updateStarted();
+ void startedChanged();
+};
+
+}
+
+#endif