mirror of
https://github.com/python/cpython.git
synced 2025-10-30 21:21:22 +00:00
244 lines
8.3 KiB
Python
Executable file
244 lines
8.3 KiB
Python
Executable file
# Class interface to the CD module.
|
|
|
|
import cd, CD
|
|
|
|
class Error(Exception):
|
|
pass
|
|
class _Stop(Exception):
|
|
pass
|
|
|
|
def _doatime(self, cb_type, data):
|
|
if ((data[0] * 60) + data[1]) * 75 + data[2] > self.end:
|
|
## print 'done with list entry', repr(self.listindex)
|
|
raise _Stop
|
|
func, arg = self.callbacks[cb_type]
|
|
if func:
|
|
func(arg, cb_type, data)
|
|
|
|
def _dopnum(self, cb_type, data):
|
|
if data > self.end:
|
|
## print 'done with list entry', repr(self.listindex)
|
|
raise _Stop
|
|
func, arg = self.callbacks[cb_type]
|
|
if func:
|
|
func(arg, cb_type, data)
|
|
|
|
class Readcd:
|
|
def __init__(self, *arg):
|
|
if len(arg) == 0:
|
|
self.player = cd.open()
|
|
elif len(arg) == 1:
|
|
self.player = cd.open(arg[0])
|
|
elif len(arg) == 2:
|
|
self.player = cd.open(arg[0], arg[1])
|
|
else:
|
|
raise Error, 'bad __init__ call'
|
|
self.list = []
|
|
self.callbacks = [(None, None)] * 8
|
|
self.parser = cd.createparser()
|
|
self.playing = 0
|
|
self.end = 0
|
|
self.status = None
|
|
self.trackinfo = None
|
|
|
|
def eject(self):
|
|
self.player.eject()
|
|
self.list = []
|
|
self.end = 0
|
|
self.listindex = 0
|
|
self.status = None
|
|
self.trackinfo = None
|
|
if self.playing:
|
|
## print 'stop playing from eject'
|
|
raise _Stop
|
|
|
|
def pmsf2msf(self, track, min, sec, frame):
|
|
if not self.status:
|
|
self.cachestatus()
|
|
if track < self.status[5] or track > self.status[6]:
|
|
raise Error, 'track number out of range'
|
|
if not self.trackinfo:
|
|
self.cacheinfo()
|
|
start, total = self.trackinfo[track]
|
|
start = ((start[0] * 60) + start[1]) * 75 + start[2]
|
|
total = ((total[0] * 60) + total[1]) * 75 + total[2]
|
|
block = ((min * 60) + sec) * 75 + frame
|
|
if block > total:
|
|
raise Error, 'out of range'
|
|
block = start + block
|
|
min, block = divmod(block, 75*60)
|
|
sec, frame = divmod(block, 75)
|
|
return min, sec, frame
|
|
|
|
def reset(self):
|
|
self.list = []
|
|
|
|
def appendtrack(self, track):
|
|
self.appendstretch(track, track)
|
|
|
|
def appendstretch(self, start, end):
|
|
if not self.status:
|
|
self.cachestatus()
|
|
if not start:
|
|
start = 1
|
|
if not end:
|
|
end = self.status[6]
|
|
if type(end) == type(0):
|
|
if end < self.status[5] or end > self.status[6]:
|
|
raise Error, 'range error'
|
|
else:
|
|
l = len(end)
|
|
if l == 4:
|
|
prog, min, sec, frame = end
|
|
if prog < self.status[5] or prog > self.status[6]:
|
|
raise Error, 'range error'
|
|
end = self.pmsf2msf(prog, min, sec, frame)
|
|
elif l != 3:
|
|
raise Error, 'syntax error'
|
|
if type(start) == type(0):
|
|
if start < self.status[5] or start > self.status[6]:
|
|
raise Error, 'range error'
|
|
if len(self.list) > 0:
|
|
s, e = self.list[-1]
|
|
if type(e) == type(0):
|
|
if start == e+1:
|
|
start = s
|
|
del self.list[-1]
|
|
else:
|
|
l = len(start)
|
|
if l == 4:
|
|
prog, min, sec, frame = start
|
|
if prog < self.status[5] or prog > self.status[6]:
|
|
raise Error, 'range error'
|
|
start = self.pmsf2msf(prog, min, sec, frame)
|
|
elif l != 3:
|
|
raise Error, 'syntax error'
|
|
self.list.append((start, end))
|
|
|
|
def settracks(self, list):
|
|
self.list = []
|
|
for track in list:
|
|
self.appendtrack(track)
|
|
|
|
def setcallback(self, cb_type, func, arg):
|
|
if cb_type < 0 or cb_type >= 8:
|
|
raise Error, 'type out of range'
|
|
self.callbacks[cb_type] = (func, arg)
|
|
if self.playing:
|
|
start, end = self.list[self.listindex]
|
|
if type(end) == type(0):
|
|
if cb_type != CD.PNUM:
|
|
self.parser.setcallback(cb_type, func, arg)
|
|
else:
|
|
if cb_type != CD.ATIME:
|
|
self.parser.setcallback(cb_type, func, arg)
|
|
|
|
def removecallback(self, cb_type):
|
|
if cb_type < 0 or cb_type >= 8:
|
|
raise Error, 'type out of range'
|
|
self.callbacks[cb_type] = (None, None)
|
|
if self.playing:
|
|
start, end = self.list[self.listindex]
|
|
if type(end) == type(0):
|
|
if cb_type != CD.PNUM:
|
|
self.parser.removecallback(cb_type)
|
|
else:
|
|
if cb_type != CD.ATIME:
|
|
self.parser.removecallback(cb_type)
|
|
|
|
def gettrackinfo(self, *arg):
|
|
if not self.status:
|
|
self.cachestatus()
|
|
if not self.trackinfo:
|
|
self.cacheinfo()
|
|
if len(arg) == 0:
|
|
return self.trackinfo[self.status[5]:self.status[6]+1]
|
|
result = []
|
|
for i in arg:
|
|
if i < self.status[5] or i > self.status[6]:
|
|
raise Error, 'range error'
|
|
result.append(self.trackinfo[i])
|
|
return result
|
|
|
|
def cacheinfo(self):
|
|
if not self.status:
|
|
self.cachestatus()
|
|
self.trackinfo = []
|
|
for i in range(self.status[5]):
|
|
self.trackinfo.append(None)
|
|
for i in range(self.status[5], self.status[6]+1):
|
|
self.trackinfo.append(self.player.gettrackinfo(i))
|
|
|
|
def cachestatus(self):
|
|
self.status = self.player.getstatus()
|
|
if self.status[0] == CD.NODISC:
|
|
self.status = None
|
|
raise Error, 'no disc in player'
|
|
|
|
def getstatus(self):
|
|
return self.player.getstatus()
|
|
|
|
def play(self):
|
|
if not self.status:
|
|
self.cachestatus()
|
|
size = self.player.bestreadsize()
|
|
self.listindex = 0
|
|
self.playing = 0
|
|
for i in range(8):
|
|
func, arg = self.callbacks[i]
|
|
if func:
|
|
self.parser.setcallback(i, func, arg)
|
|
else:
|
|
self.parser.removecallback(i)
|
|
if len(self.list) == 0:
|
|
for i in range(self.status[5], self.status[6]+1):
|
|
self.appendtrack(i)
|
|
try:
|
|
while 1:
|
|
if not self.playing:
|
|
if self.listindex >= len(self.list):
|
|
return
|
|
start, end = self.list[self.listindex]
|
|
if type(start) == type(0):
|
|
dummy = self.player.seektrack(
|
|
start)
|
|
else:
|
|
min, sec, frame = start
|
|
dummy = self.player.seek(
|
|
min, sec, frame)
|
|
if type(end) == type(0):
|
|
self.parser.setcallback(
|
|
CD.PNUM, _dopnum, self)
|
|
self.end = end
|
|
func, arg = \
|
|
self.callbacks[CD.ATIME]
|
|
if func:
|
|
self.parser.setcallback(CD.ATIME, func, arg)
|
|
else:
|
|
self.parser.removecallback(CD.ATIME)
|
|
else:
|
|
min, sec, frame = end
|
|
self.parser.setcallback(
|
|
CD.ATIME, _doatime,
|
|
self)
|
|
self.end = (min * 60 + sec) * \
|
|
75 + frame
|
|
func, arg = \
|
|
self.callbacks[CD.PNUM]
|
|
if func:
|
|
self.parser.setcallback(CD.PNUM, func, arg)
|
|
else:
|
|
self.parser.removecallback(CD.PNUM)
|
|
self.playing = 1
|
|
data = self.player.readda(size)
|
|
if data == '':
|
|
self.playing = 0
|
|
self.listindex = self.listindex + 1
|
|
continue
|
|
try:
|
|
self.parser.parseframe(data)
|
|
except _Stop:
|
|
self.playing = 0
|
|
self.listindex = self.listindex + 1
|
|
finally:
|
|
self.playing = 0
|