1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
|
import csnd
import os
import socket
import select
import sys
import threading
import time
from Framework.CSound.CSoundConstants import CSoundConstants
#----------------------------------------------------------------------
# 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 = CSoundConstants.MIC_RECORDING_COMMAND % table
# print mess
self.sendText( mess )
def load_instruments( self ):
for instrumentSoundFile in CSoundConstants.INSTRUMENTS.keys():
fileName = CSoundConstants.SOUNDS_DIR + "/" + instrumentSoundFile
instrumentID = CSoundConstants.INSTRUMENT_TABLE_OFFSET + CSoundConstants.INSTRUMENTS[ instrumentSoundFile ].instrumentID
mess = CSoundConstants.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 CSoundConstants.SERVER_REQUIRED :
print 'ERROR: no CSound server. Ignoring message: %s' % text
def initialize( self, init = True ):
if init :
n = CSoundConstants.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 CSoundConstants.SERVER_REQUIRED :
print 'ERROR: no CSound server. Ignoring connection request.'
time.sleep(CSoundConstants.INIT_DELAY)
n = n - 1
else : #un-init
self.sendText( CSoundConstants.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 CSoundConstants.UNLOAD_TABLES_COMMAND
self.sendText( CSoundConstants.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)
|
