| 1 | 1 | """Classes for manipulating audio devices (currently only for Sun and SGI)""" |
|---|
| 2 | 1 | from warnings import warnpy3k |
|---|
| 3 | 1 | warnpy3k("the audiodev module has been removed in Python 3.0", stacklevel=2) |
|---|
| 4 | 1 | del warnpy3k |
|---|
| 5 | n/a | |
|---|
| 6 | 1 | __all__ = ["error","AudioDev"] |
|---|
| 7 | n/a | |
|---|
| 8 | 2 | class error(Exception): |
|---|
| 9 | 1 | pass |
|---|
| 10 | n/a | |
|---|
| 11 | 2 | class Play_Audio_sgi: |
|---|
| 12 | n/a | # Private instance variables |
|---|
| 13 | n/a | ## if 0: access frameratelist, nchannelslist, sampwidthlist, oldparams, \ |
|---|
| 14 | n/a | ## params, config, inited_outrate, inited_width, \ |
|---|
| 15 | n/a | ## inited_nchannels, port, converter, classinited: private |
|---|
| 16 | n/a | |
|---|
| 17 | 1 | classinited = 0 |
|---|
| 18 | 1 | frameratelist = nchannelslist = sampwidthlist = None |
|---|
| 19 | n/a | |
|---|
| 20 | 1 | def initclass(self): |
|---|
| 21 | 0 | import AL |
|---|
| 22 | n/a | self.frameratelist = [ |
|---|
| 23 | 0 | (48000, AL.RATE_48000), |
|---|
| 24 | 0 | (44100, AL.RATE_44100), |
|---|
| 25 | 0 | (32000, AL.RATE_32000), |
|---|
| 26 | 0 | (22050, AL.RATE_22050), |
|---|
| 27 | 0 | (16000, AL.RATE_16000), |
|---|
| 28 | 0 | (11025, AL.RATE_11025), |
|---|
| 29 | 0 | ( 8000, AL.RATE_8000), |
|---|
| 30 | n/a | ] |
|---|
| 31 | n/a | self.nchannelslist = [ |
|---|
| 32 | 0 | (1, AL.MONO), |
|---|
| 33 | 0 | (2, AL.STEREO), |
|---|
| 34 | 0 | (4, AL.QUADRO), |
|---|
| 35 | n/a | ] |
|---|
| 36 | n/a | self.sampwidthlist = [ |
|---|
| 37 | 0 | (1, AL.SAMPLE_8), |
|---|
| 38 | 0 | (2, AL.SAMPLE_16), |
|---|
| 39 | 0 | (3, AL.SAMPLE_24), |
|---|
| 40 | n/a | ] |
|---|
| 41 | 0 | self.classinited = 1 |
|---|
| 42 | n/a | |
|---|
| 43 | 1 | def __init__(self): |
|---|
| 44 | 0 | import al, AL |
|---|
| 45 | 0 | if not self.classinited: |
|---|
| 46 | 0 | self.initclass() |
|---|
| 47 | 0 | self.oldparams = [] |
|---|
| 48 | 0 | self.params = [AL.OUTPUT_RATE, 0] |
|---|
| 49 | 0 | self.config = al.newconfig() |
|---|
| 50 | 0 | self.inited_outrate = 0 |
|---|
| 51 | 0 | self.inited_width = 0 |
|---|
| 52 | 0 | self.inited_nchannels = 0 |
|---|
| 53 | 0 | self.converter = None |
|---|
| 54 | 0 | self.port = None |
|---|
| 55 | 0 | return |
|---|
| 56 | n/a | |
|---|
| 57 | 1 | def __del__(self): |
|---|
| 58 | 0 | if self.port: |
|---|
| 59 | 0 | self.stop() |
|---|
| 60 | 0 | if self.oldparams: |
|---|
| 61 | 0 | import al, AL |
|---|
| 62 | 0 | al.setparams(AL.DEFAULT_DEVICE, self.oldparams) |
|---|
| 63 | 0 | self.oldparams = [] |
|---|
| 64 | n/a | |
|---|
| 65 | 1 | def wait(self): |
|---|
| 66 | 0 | if not self.port: |
|---|
| 67 | 0 | return |
|---|
| 68 | 0 | import time |
|---|
| 69 | 0 | while self.port.getfilled() > 0: |
|---|
| 70 | 0 | time.sleep(0.1) |
|---|
| 71 | 0 | self.stop() |
|---|
| 72 | n/a | |
|---|
| 73 | 1 | def stop(self): |
|---|
| 74 | 0 | if self.port: |
|---|
| 75 | 0 | self.port.closeport() |
|---|
| 76 | 0 | self.port = None |
|---|
| 77 | 0 | if self.oldparams: |
|---|
| 78 | 0 | import al, AL |
|---|
| 79 | 0 | al.setparams(AL.DEFAULT_DEVICE, self.oldparams) |
|---|
| 80 | 0 | self.oldparams = [] |
|---|
| 81 | n/a | |
|---|
| 82 | 1 | def setoutrate(self, rate): |
|---|
| 83 | 0 | for (raw, cooked) in self.frameratelist: |
|---|
| 84 | 0 | if rate == raw: |
|---|
| 85 | 0 | self.params[1] = cooked |
|---|
| 86 | 0 | self.inited_outrate = 1 |
|---|
| 87 | 0 | break |
|---|
| 88 | n/a | else: |
|---|
| 89 | 0 | raise error, 'bad output rate' |
|---|
| 90 | n/a | |
|---|
| 91 | 1 | def setsampwidth(self, width): |
|---|
| 92 | 0 | for (raw, cooked) in self.sampwidthlist: |
|---|
| 93 | 0 | if width == raw: |
|---|
| 94 | 0 | self.config.setwidth(cooked) |
|---|
| 95 | 0 | self.inited_width = 1 |
|---|
| 96 | 0 | break |
|---|
| 97 | n/a | else: |
|---|
| 98 | 0 | if width == 0: |
|---|
| 99 | 0 | import AL |
|---|
| 100 | 0 | self.inited_width = 0 |
|---|
| 101 | 0 | self.config.setwidth(AL.SAMPLE_16) |
|---|
| 102 | 0 | self.converter = self.ulaw2lin |
|---|
| 103 | n/a | else: |
|---|
| 104 | 0 | raise error, 'bad sample width' |
|---|
| 105 | n/a | |
|---|
| 106 | 1 | def setnchannels(self, nchannels): |
|---|
| 107 | 0 | for (raw, cooked) in self.nchannelslist: |
|---|
| 108 | 0 | if nchannels == raw: |
|---|
| 109 | 0 | self.config.setchannels(cooked) |
|---|
| 110 | 0 | self.inited_nchannels = 1 |
|---|
| 111 | 0 | break |
|---|
| 112 | n/a | else: |
|---|
| 113 | 0 | raise error, 'bad # of channels' |
|---|
| 114 | n/a | |
|---|
| 115 | 1 | def writeframes(self, data): |
|---|
| 116 | 0 | if not (self.inited_outrate and self.inited_nchannels): |
|---|
| 117 | 0 | raise error, 'params not specified' |
|---|
| 118 | 0 | if not self.port: |
|---|
| 119 | 0 | import al, AL |
|---|
| 120 | 0 | self.port = al.openport('Python', 'w', self.config) |
|---|
| 121 | 0 | self.oldparams = self.params[:] |
|---|
| 122 | 0 | al.getparams(AL.DEFAULT_DEVICE, self.oldparams) |
|---|
| 123 | 0 | al.setparams(AL.DEFAULT_DEVICE, self.params) |
|---|
| 124 | 0 | if self.converter: |
|---|
| 125 | 0 | data = self.converter(data) |
|---|
| 126 | 0 | self.port.writesamps(data) |
|---|
| 127 | n/a | |
|---|
| 128 | 1 | def getfilled(self): |
|---|
| 129 | 0 | if self.port: |
|---|
| 130 | 0 | return self.port.getfilled() |
|---|
| 131 | n/a | else: |
|---|
| 132 | 0 | return 0 |
|---|
| 133 | n/a | |
|---|
| 134 | 1 | def getfillable(self): |
|---|
| 135 | 0 | if self.port: |
|---|
| 136 | 0 | return self.port.getfillable() |
|---|
| 137 | n/a | else: |
|---|
| 138 | 0 | return self.config.getqueuesize() |
|---|
| 139 | n/a | |
|---|
| 140 | n/a | # private methods |
|---|
| 141 | n/a | ## if 0: access *: private |
|---|
| 142 | n/a | |
|---|
| 143 | 1 | def ulaw2lin(self, data): |
|---|
| 144 | 0 | import audioop |
|---|
| 145 | 0 | return audioop.ulaw2lin(data, 2) |
|---|
| 146 | n/a | |
|---|
| 147 | 2 | class Play_Audio_sun: |
|---|
| 148 | n/a | ## if 0: access outrate, sampwidth, nchannels, inited_outrate, inited_width, \ |
|---|
| 149 | n/a | ## inited_nchannels, converter: private |
|---|
| 150 | n/a | |
|---|
| 151 | 1 | def __init__(self): |
|---|
| 152 | 0 | self.outrate = 0 |
|---|
| 153 | 0 | self.sampwidth = 0 |
|---|
| 154 | 0 | self.nchannels = 0 |
|---|
| 155 | 0 | self.inited_outrate = 0 |
|---|
| 156 | 0 | self.inited_width = 0 |
|---|
| 157 | 0 | self.inited_nchannels = 0 |
|---|
| 158 | 0 | self.converter = None |
|---|
| 159 | 0 | self.port = None |
|---|
| 160 | 0 | return |
|---|
| 161 | n/a | |
|---|
| 162 | 1 | def __del__(self): |
|---|
| 163 | 0 | self.stop() |
|---|
| 164 | n/a | |
|---|
| 165 | 1 | def setoutrate(self, rate): |
|---|
| 166 | 0 | self.outrate = rate |
|---|
| 167 | 0 | self.inited_outrate = 1 |
|---|
| 168 | n/a | |
|---|
| 169 | 1 | def setsampwidth(self, width): |
|---|
| 170 | 0 | self.sampwidth = width |
|---|
| 171 | 0 | self.inited_width = 1 |
|---|
| 172 | n/a | |
|---|
| 173 | 1 | def setnchannels(self, nchannels): |
|---|
| 174 | 0 | self.nchannels = nchannels |
|---|
| 175 | 0 | self.inited_nchannels = 1 |
|---|
| 176 | n/a | |
|---|
| 177 | 1 | def writeframes(self, data): |
|---|
| 178 | 0 | if not (self.inited_outrate and self.inited_width and self.inited_nchannels): |
|---|
| 179 | 0 | raise error, 'params not specified' |
|---|
| 180 | 0 | if not self.port: |
|---|
| 181 | 0 | import sunaudiodev, SUNAUDIODEV |
|---|
| 182 | 0 | self.port = sunaudiodev.open('w') |
|---|
| 183 | 0 | info = self.port.getinfo() |
|---|
| 184 | 0 | info.o_sample_rate = self.outrate |
|---|
| 185 | 0 | info.o_channels = self.nchannels |
|---|
| 186 | 0 | if self.sampwidth == 0: |
|---|
| 187 | 0 | info.o_precision = 8 |
|---|
| 188 | 0 | self.o_encoding = SUNAUDIODEV.ENCODING_ULAW |
|---|
| 189 | n/a | # XXX Hack, hack -- leave defaults |
|---|
| 190 | n/a | else: |
|---|
| 191 | 0 | info.o_precision = 8 * self.sampwidth |
|---|
| 192 | 0 | info.o_encoding = SUNAUDIODEV.ENCODING_LINEAR |
|---|
| 193 | 0 | self.port.setinfo(info) |
|---|
| 194 | 0 | if self.converter: |
|---|
| 195 | 0 | data = self.converter(data) |
|---|
| 196 | 0 | self.port.write(data) |
|---|
| 197 | n/a | |
|---|
| 198 | 1 | def wait(self): |
|---|
| 199 | 0 | if not self.port: |
|---|
| 200 | 0 | return |
|---|
| 201 | 0 | self.port.drain() |
|---|
| 202 | 0 | self.stop() |
|---|
| 203 | n/a | |
|---|
| 204 | 1 | def stop(self): |
|---|
| 205 | 0 | if self.port: |
|---|
| 206 | 0 | self.port.flush() |
|---|
| 207 | 0 | self.port.close() |
|---|
| 208 | 0 | self.port = None |
|---|
| 209 | n/a | |
|---|
| 210 | 1 | def getfilled(self): |
|---|
| 211 | 0 | if self.port: |
|---|
| 212 | 0 | return self.port.obufcount() |
|---|
| 213 | n/a | else: |
|---|
| 214 | 0 | return 0 |
|---|
| 215 | n/a | |
|---|
| 216 | n/a | ## # Nobody remembers what this method does, and it's broken. :-( |
|---|
| 217 | n/a | ## def getfillable(self): |
|---|
| 218 | n/a | ## return BUFFERSIZE - self.getfilled() |
|---|
| 219 | n/a | |
|---|
| 220 | 1 | def AudioDev(): |
|---|
| 221 | n/a | # Dynamically try to import and use a platform specific module. |
|---|
| 222 | 0 | try: |
|---|
| 223 | 0 | import al |
|---|
| 224 | 0 | except ImportError: |
|---|
| 225 | 0 | try: |
|---|
| 226 | 0 | import sunaudiodev |
|---|
| 227 | 0 | return Play_Audio_sun() |
|---|
| 228 | 0 | except ImportError: |
|---|
| 229 | 0 | try: |
|---|
| 230 | 0 | import Audio_mac |
|---|
| 231 | 0 | except ImportError: |
|---|
| 232 | 0 | raise error, 'no audio device' |
|---|
| 233 | n/a | else: |
|---|
| 234 | 0 | return Audio_mac.Play_Audio_mac() |
|---|
| 235 | n/a | else: |
|---|
| 236 | 0 | return Play_Audio_sgi() |
|---|
| 237 | n/a | |
|---|
| 238 | 1 | def test(fn = None): |
|---|
| 239 | 0 | import sys |
|---|
| 240 | 0 | if sys.argv[1:]: |
|---|
| 241 | 0 | fn = sys.argv[1] |
|---|
| 242 | n/a | else: |
|---|
| 243 | 0 | fn = 'f:just samples:just.aif' |
|---|
| 244 | 0 | import aifc |
|---|
| 245 | 0 | af = aifc.open(fn, 'r') |
|---|
| 246 | 0 | print fn, af.getparams() |
|---|
| 247 | 0 | p = AudioDev() |
|---|
| 248 | 0 | p.setoutrate(af.getframerate()) |
|---|
| 249 | 0 | p.setsampwidth(af.getsampwidth()) |
|---|
| 250 | 0 | p.setnchannels(af.getnchannels()) |
|---|
| 251 | 0 | BUFSIZ = af.getframerate()/af.getsampwidth()/af.getnchannels() |
|---|
| 252 | 0 | while 1: |
|---|
| 253 | 0 | data = af.readframes(BUFSIZ) |
|---|
| 254 | 0 | if not data: break |
|---|
| 255 | 0 | print len(data) |
|---|
| 256 | 0 | p.writeframes(data) |
|---|
| 257 | 0 | p.wait() |
|---|
| 258 | n/a | |
|---|
| 259 | 1 | if __name__ == '__main__': |
|---|
| 260 | 0 | test() |
|---|