1 files changed, 143 insertions, 0 deletions
diff --git a/City/CsSched.py b/City/CsSched.py
new file mode 100755
index 0000000..14e5588
--- /dev/null
+++ b/City/CsSched.py
@@ -0,0 +1,143 @@
+#!/usr/bin/env python
+
+import csnd, heapq
+from CsHelpers import *
+
+class Csound:
+    "precompiles a csound object"
+    def __init__(self):
+        self.csound = csnd.CppSound()
+        self.csound.setPythonMessageCallback()
+        self.csound.PreCompile()
+    def __repr__(self):
+        return "Precompiled Csound object"
+
+
+class Sched:
+    def __init__(self):
+        self.queue = []
+    def schedEvent(self, time, func, *args):
+        heapq.heappush(self.queue, (time, func, args))
+    def getTime(self):
+        if self:
+            return self.queue[0][0]
+        else:
+            return False
+    def getFunc(self):
+        if len(self) == 0:
+            return False
+        else:
+            return self.queue[0][1]
+    def getArgs(self):
+        if len(self) == 0:
+            return False
+        else:
+            return self.queue[0][2]
+    def __len__(self):
+        return len(self.queue)
+    def __repr__(self):
+        return str(self.queue)
+
+class CsoundChan:
+    "a container for Csound channel data"
+        #type is either Audio, Control, or String
+        #Dirction = INput or Output
+        #subType = interger, linear or exponential
+        #default = default value
+        #minval = suggested minimum
+        #maxval == suggested maximum
+    pass
+    
+
+
+def channels(csound):
+    "returns a list of Input and output software bus channels"
+    Chanlist = csnd.CsoundChannelList(csound)
+    result = []
+    for ndx in range(Chanlist.Count()):
+        ch = CsoundChan()
+        ch.name = Chanlist.Name(ndx)
+        if Chanlist.IsAudioChannel(ndx):
+            ch.type = "Audio"
+        elif Chanlist.IsControlChannel(ndx):
+            ch.type = "Control"
+        elif Chanlist.IsStringChannel(ndx):
+            ch.type = "String"
+        else: pass
+        if Chanlist.IsInputChannel(ndx) and Chanlist.IsOutputChannel(ndx):
+        	ch.direction = "bidirectional"
+        elif Chanlist.IsInputChannel(ndx):
+        	ch.direction = "input"
+        elif Chanlist.IsOutputChannel(ndx):
+        	ch.direction = "output"
+        else: pass 
+        if Chanlist.SubType(ndx) > 0:
+            tmp = ['integer', 'linear', 'exponential']
+            ch.subtype = (tmp[Chanlist.SubType(ndx) - 1])
+            ch.default = (Chanlist.DefaultValue(ndx))
+            ch.minval = (Chanlist.MinValue(ndx))
+            ch.maxval = (Chanlist.MaxValue(ndx))
+        result.append(ch)
+    Chanlist.Clear()
+    return result
+
+
+
+class CsoundPerformer:
+    def pollScheduler(self, schedObj):
+        st =  schedObj.getTime()
+        if st:
+            t = self.perfTime()
+            if t >= st:
+                obj = heapq.heappop(schedObj.queue)
+                (obj[1] (*obj[2]))
+    def __init__(self, schedObj, orcObj, *cs):
+        "SchedObj is a Csound timer instance, orcObJ is a CsOrcConstructor Object"
+        self.Timer = csnd.CsoundTimer()
+        self.schedObj = schedObj
+        self.orcObj = orcObj
+        if len(cs) == 0:
+            cs = Csound()
+            self.csound = Csound.csound
+        else: self.csound = cs[0] 
+        self.csound.setOrchestra(orcObj.exportOrc())
+        self.csound.setScore(orcObj.sco)
+        self.time = 0
+        if platform == "Sugar":
+            self.csound.setCommand("csound -b256 -B2048 -+rtaudio=alsa -odac --expression-opt --sched=1 -d -m0 /tmp/tmp.orc /tmp/tmp.sco")
+        else:
+            self.csound.setCommand("csound -b256 -B2048 -odac --expression-opt -d -m0 /tmp/tmp.orc /tmp/tmp.sco")
+        self.csound.exportForPerformance()
+        self.csound.compile()
+        self.Channels = channels(self.csound)
+        self.perf = csnd.CsoundPerformanceThread(self.csound) 
+        self.perf.Play()
+        self.perf.SetProcessCallback(self.pollScheduler, schedObj)
+    def perfTime(self):
+        return self.Timer.GetRealTime()
+    def Stop(self):
+        self.perf.Stop()
+        #self.perf.Join()
+        self.csound.Cleanup()
+    def setChannelValue(self, channame, value):
+        self.csound.SetChannel(channame, value)
+    def getChannelValue(self, channame):
+        return self.csound.GetChannel(channame)
+    def getChannelList(self):
+        return csnd.CsoundChannelList(self.csound)
+    def getChannelNames(self):
+        chlst = self.getChannelList()
+        return [chlst.Name(ch) for ch in range(chlst.Count())]
+    def playParams(self, ins, start, dur, *params):
+        "send score message to Csound with parameter values"
+        if start < 0: start = 0
+        s = ' '.join(map(str, (['i', ins, start, dur] + [str(n) for n in params])))
+        self.perf.InputMessage(s)
+    def playNote(self, ins, note):
+        "send score message to Csound using a note object"
+        start = note[0]
+        dur = note[1]
+        params = note[2:]
+        self.perf.InputMessage(' '.join(['i', str(ins),str(start),str(dur)]+[str(n) for n in params]))
+
+