Moved the csound server to memosono

Added the csound server to memosono (used the osc protocol for the communication with the server), this is not optimal yet since other activities might want to use the sound server as well.
Adopted memosono to communicate with the soundserver using osc.

3 files changed, 206 insertions, 0 deletions

diff --git a/csound/__init__.py b/csound/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/csound/__init__.py
diff --git a/csound/csoundserver.py b/csound/csoundserver.py
new file mode 100644
index 0000000..c384300
--- /dev/null
+++ b/csound/csoundserver.py
@@ -0,0 +1,106 @@
+#! /usr/bin/env python
+
+import select
+import os
+import logging
+from threading import Thread
+
+import csnd
+from  osc.oscapi import OscApi
+
+class CsoundServer(Thread):    
+    CSOUND_PORT = 6783
+    MAX_PINGS = 3
+    TIMEOUT_PING = 10
+    def __init__(self):
+        Thread.__init__(self)
+        self.oscapi = OscApi(self.CSOUND_PORT)
+        self.oscapi.addmethod('/CSOUND/connect', '', self._connect)
+        self.oscapi.addmethod('/CSOUND/pong', '', self._pong)
+        self.oscapi.addmethod('/CSOUND/perform', 's', self._perform)
+        self.oscapi.addmethod('/CSOUND/disconnect', '', self._disconnect)
+        self.oscapi.addmethod('/CSOUND/quit', '', self._quit)
+        self.running = 1                
+
+        self.clients = {}
+        self.start()
+
+    def run(self):
+        logging.info('start listening...')
+        self.csound = csnd.Csound()
+        
+        while self.running:            
+            inputready,outputready,exceptready = select.select([self.oscapi.iosock],[], [], self.TIMEOUT_PING)
+            for s in inputready:
+                if s == self.oscapi.iosock:
+                    data, address = s.recvfrom(1024)
+                    self.oscapi.handlemsg(data, address)
+                if len(inputready) == 0:
+                    self.ping()
+                                
+    def ping(self):
+        rm = []
+        for client in self.clients:
+            if self.clients[client] == self.MAX_PINGS:               
+                rm.append(client)
+                logging.debug('[ping] remove client %s'%str(client))                
+            else:
+                self.oscapi.send(client, '/CSOUND/ping', [])
+                self.clients[client]+=1
+                ### print '     [ping] client=%s seq=%s'%(str(client), self.clients[client])
+
+        for elem in rm:
+            del self.clients[elem]
+            if len(self.clients) == 0:
+                self.perf.Stop()
+                self.perf.Join()                                    
+                self.csound.Reset()
+                logging.debug('[csound] stop csound performance')                
+
+                
+    def _connect(self, *msg):            
+        if msg[1] in self.clients:
+            logging.debug('[connect_cb] %s already connected'%str(msg[1]))
+        else:    
+            self.clients[msg[1]]=0
+            logging.debug('[connect_cb] %s connected'%str(msg[1]))
+            if len(self.clients) == 1:
+                self.perf = csnd.CsoundPerformanceThread(self.csound)
+                uniorcpath = os.path.join( os.path.dirname(__file__), 'univorc.csd')
+                if not os.path.exists(uniorcpath):
+                    logging.error('[csound] univorc not found %s'%uniorcpath)                
+                self.csound.Compile(uniorcpath)        
+                self.perf.Play()
+                logging.debug('[csound] start csound performance %s'%uniorcpath)
+
+
+    def _disconnect(self, *msg):            
+        if msg[1] not in self.clients:
+            logging.debug('[disconnect_cb] %s not connected'%str(msg[1]))
+        else:    
+            del self.clients[msg[1]]
+            logging.debug('[disconnect_cb] %s disconnected'%str(msg[1]))
+            if len(self.clients) == 0:
+                self.perf.Stop()
+                self.perf.Join()                                    
+                self.csound.Reset()
+                logging.debug('[csound] stop csound performance')
+
+
+    def _quit(self, *msg):
+        logging.info('stop listening...')
+        self.running = 0
+        self.csound.Reset()
+        self.csound = None
+        
+    
+    def _pong(self, *msg):
+        self.clients[msg[1]]-=1
+        ### print '     [pong_cb] %s'%str(msg)
+
+
+    def _perform(self, *msg):
+        logging.debug('     [perform_cb] %s'%str(msg[0][2]))
+        self.perf.InputMessage(msg[0][2])
+
+
diff --git a/csound/univorc.csd b/csound/univorc.csd
new file mode 100644
index 0000000..e4264e9
--- /dev/null
+++ b/csound/univorc.csd
@@ -0,0 +1,100 @@
+<CsoundSynthesizer>
+<CsOptions>
+-+rtaudio=alsa -odac -m0 -d -b1024 -B4096
+</CsOptions>
+<CsInstruments>
+sr=22050
+ksmps=100
+nchnls=2
+
+gaudp1  init 0
+gaudp2  init 0
+
+
+/**************************************************************************
+ General Soundfile Player - Used by Memosono
+**************************************************************************/
+
+instr 108
+/* soundfile play control
+  p4 : filename
+  p5 : unique instance ID
+  p6 : output gain (0-1)
+  p7 : udp send gain (0-1)
+  p8 : offset in seconds
+
+  channels:
+  sfplay.<ID>.on  - instance control channel (1:on 0: off)
+  sfplay.<ID>.gain - soundfile play gain (0-1)
+  sfplay.<ID>.udpgain - udp send gain (0-1)
+  sfplay.<ID>.flen  - holds the channel length
+*/
+S1 strget p4
+inst = p5
+ich    filenchnls S1
+iln    filelen  S1
+ioffset = p8
+
+Slen  sprintf "sfplay.%d.flen", p5  ; file length channel
+chnset iln, Slen
+
+if ioffset >= iln then
+turnoff
+else
+iln = iln - ioffset
+endif
+
+Splay sprintf "sfplay.%d.on", inst  ; instance control channel
+Sname sprintf "sfplay.%d.fname", inst  ; filename channel
+Sgain sprintf "sfplay.%d.gain", inst ; gain channel
+Sudp  sprintf "sfplay.%d.udpgain", inst ; udp gain channel  
+chnset S1, Sname
+chnset 1,  Splay
+chnset p6, Sgain
+chnset p7, Sudp
+event_i "i",109,0,iln,inst,ich,ioffset
+turnoff
+endin
+
+
+instr 109
+/* soundfile player
+  This is the actual soundfile player.
+  It never gets called directly
+*/
+ich = p5
+inst= p4
+ioffset = p6
+Splay sprintf "sfplay.%d.on", inst  ; instance control channel
+Sname sprintf "sfplay.%d.fname", inst  ; filename channel
+Sgain sprintf "sfplay.%d.gain", inst ; gain channel
+Sudp  sprintf "sfplay.%d.udpgain", inst ; udp gain channel   
+kon chnget Splay
+kg1 chnget Sgain
+kg2 chnget Sudp
+S1  chnget Sname
+if kon == 0 then
+printf "sfplay:%d OFF\n", 1, inst
+turnoff
+endif
+if ich = 1 then
+a1 diskin2 S1,1,ioffset,1
+a2 = a1
+else
+a1,a2 diskin2 S1,1,ioffset,1
+endif
+     outs a1*kg1, a2*kg1
+gaudp1 = a1*kg2 + gaudp1
+gaudp2 = a2*kg2 + gaudp2
+printf_i "sfplay:%d\n", 1, inst
+endin
+
+
+
+
+</CsInstruments>
+<CsScore>
+f0 600000
+
+</CsScore>
+</CsoundSynthesizer>