1 files changed, 151 insertions, 0 deletions
diff --git a/Util/CSoundClient.py b/Util/CSoundClient.py
new file mode 100644
index 0000000..b72ce92
--- /dev/null
+++ b/Util/CSoundClient.py
@@ -0,0 +1,151 @@
+import csnd
+import os
+import socket
+import select
+import sys
+import threading
+import time
+
+import Config
+
+#----------------------------------------------------------------------
+# A CSound client used to send messages to the CSound server
+# CSoundClient is a singleton
+#----------------------------------------------------------------------
+CSoundClient = None
+class CSoundClientBase:
+    def setMasterVolume(self, volume):
+        self.sendText("csound.SetChannel('masterVolume', %f)\n" % volume)
+
+    def micRecording( self, table ):
+        mess = Config.MIC_RECORDING_COMMAND % table
+#        print mess
+        self.sendText( mess )
+
+    def load_instruments( self ):
+        for instrumentSoundFile in Config.INSTRUMENTS.keys():
+            fileName = Config.SOUNDS_DIR + "/" + instrumentSoundFile
+            instrumentID = Config.INSTRUMENT_TABLE_OFFSET + Config.INSTRUMENTS[ instrumentSoundFile ].instrumentID
+            mess = Config.LOAD_INSTRUMENT_COMMAND % ( instrumentID, fileName )
+            self.sendText( mess )
+
+    def startTime(self):
+        self.sendText("perf.InputMessage('i 5999 0.0  600')")
+        # if any other message arrives to csound at the same time as this one, 
+        # then the global variables will not be set up right in the orcestra
+        #
+        # NB: match this to the constant in the instrument 5777 of the csound orcestra
+        time.sleep(0.1)
+
+    def sendText(self, txt):
+        raise 'noImpl'
+
+    def initialize(self, flag):
+        raise 'noImpl'
+
+
+
+
+class CSoundClientSocket( CSoundClientBase ):
+    def __init__( self, serverAddress, serverPort, clientID ):
+        self.clientID = clientID
+        self.serverInfo = ( serverAddress, serverPort )
+        self.connected = False
+
+    def sendText( self, text ):
+        #print "Sending to CSound server: %s" % text        
+        try:
+            self.socket.send( text )
+        except socket.error:
+            if Config.SERVER_REQUIRED : 
+                print 'ERROR: no CSound server. Ignoring message: %s' % text
+
+    def initialize( self, init = True ):
+        if init :
+            n = Config.INIT_ATTEMPTS
+            self.socket = socket.socket()
+            self.connected = False
+            while n > 0 and not self.connected:
+                try:
+                    self.socket.connect( self.serverInfo )
+                    self.connected = True
+                    self.load_instruments()
+                except socket.error:
+                    if Config.SERVER_REQUIRED : 
+                        print 'ERROR: no CSound server. Ignoring connection request.'
+                    time.sleep(Config.INIT_DELAY)
+                    n = n - 1
+        else : #un-init
+            self.sendText( Config.UNLOAD_TABLES_COMMAND  )
+            del self.socket
+
+class CSoundClientPerf( CSoundClientBase ):
+    def __init__(self, orc):
+        self.orc = orc
+        self.on = False
+    def initialize( self, init = True ):
+        if init:
+            if self.on : return
+            self.on = True
+            self.csound = csnd.Csound()
+            self.perf   = csnd.CsoundPerformanceThread(self.csound)
+            self.csound.Compile( self.orc )
+            self.perf.Play()
+            self.load_instruments()
+        else:
+            if not self.on : return
+            self.on = False
+            #self.csound.SetChannel('udprecv.0.on', 0)
+            print Config.UNLOAD_TABLES_COMMAND
+            self.sendText( Config.UNLOAD_TABLES_COMMAND  )
+            print 'PERF STOP'
+            self.perf.Stop()
+            #print 'SLEEP'
+            #time.sleep(1)
+            print 'JOIN'
+            #time.sleep(1)
+            self.perf.Join()
+            del self.perf
+            #print 'RESET'
+            #time.sleep(1)
+            print 'STOP'
+            self.csound.Stop()
+            #self.csound.Reset()
+            #careful how much cleaning up we do... don't cause a segault!
+            # better to leave a segfault for the automatic cleanning at the end of the prog
+            
+            #self.csound.Cleanup()
+            #print 'STOPPED'
+            #time.sleep(1)
+            #del self.csound
+            #print 'DELETED'
+            #time.sleep(1)
+    def setMasterVolume(self, volume):
+        self.csound.SetChannel('masterVolume',volume )
+
+    def sendText(self, txt):
+        #print txt
+        perf = self.perf
+        csound = self.csound
+        if 'csound' in txt:
+            print txt
+            import sys
+            sys.exit(0)
+        exec txt
+
+class CSoundClientPipe( CSoundClientBase ):
+    def __init__(self, orc):
+        self.orc = orc
+    def initialize( self, init = True ):
+        if init:
+            (self.child_out, self.child_in) = os.popen2('csound ' + self.orc)
+        else:
+            self.child_in.close()
+            self.child_out.close()
+
+    def sendText(self, txt):
+        str = txt[19:-3]
+        if len(str) == 0: return
+        #print 'tosend:[%s]' % (str,)
+        self.child_out.write(str)
+