src/mprocess.py

   1 #!/usr/bin/env python
   2
   3 from PyQt4.QtCore import SIGNAL,SLOT,Qt
   4
   5 from PyQt4.QtCore import QProcess
   6 from PyQt4.QtCore import QStringList
   7
   8 import re
   9
  10 class MProcess(QProcess):
  11     """ Mplayer process controller
  12         Signals:   stopped()
  13     """
  14
  15     STOPPED, PAUSED, PLAYING = range(3)
  16     INTERVAL = 200 #For check timer
  17
  18     def __init__(self, wid = None, parent = None):
  19         super(MProcess, self).__init__(parent)
  20         self.playerState = MProcess.STOPPED
  21         ##The current file's name.
  22         self.fileName = None
  23
  24         ##Slider should be a QSlider or its subclass-object
  25         ##self.slider will be update it isn't None
  26         self.slider = None
  27
  28         ##The Widget Id which used to play vedio.
  29         self.wid = wid
  30
  31         ##Point A and Point B used to circle
  32         self.pa  = None;
  33         self.pb  = None;
  34
  35         self.timerId = self.startTimer(MProcess.INTERVAL)
  36
  37         self.timePos = None
  38         self.timeLength = None
  39
  40         self.connect(self, SIGNAL("readyReadStandardOutput()"),
  41                      self.analyseResult)
  42         self.connect(self, SIGNAL("readyReadStandardError()"),
  43                      self.analyseResult)
  44
  45     #END def __init__(self, parent = None):
  46
  47     def setSlider(self,slider):
  48         self.slider = slider
  49         self.connect(self.slider,SIGNAL("sliderPressed()"),self.pause)
  50         self.connect(self.slider,SIGNAL("sliderReleased()"),self.seek)
  51     #END def setSlider(self,slider):
  52
  53     def seek(self):
  54         self.timePos = self.slider.value()
  55         self.write("seek "+ str(self.slider.value()) + " 2\n")
  56         self.pause()
  57     #END def seek(self,value):
  58
  59     def setFileName(self,fileName):
  60         self.fileName = fileName
  61
  62     #END def setFileName(self,fileName):
  63
  64     def play(self):
  65         if(self.fileName == None):
  66             return
  67
  68         cmd = "mplayer"
  69         args = QStringList(["-slave",
  70                             "-quiet",
  71                             "-wid", str(self.wid), self.fileName])
  72
  73         if(self.state() != QProcess.NotRunning):
  74             print "self.terminate()"
  75             self.terminate()
  76             if(not self.waitForFinished()):
  77                 self.kill()
  78         self.timeLength = None
  79
  80
  81         self.playerState = MProcess.PLAYING
  82         self.start(cmd, args)
  83         self.setupTimer()
  84     #END def play(self)
  85
  86     def setA(self):
  87         self.pa  = int(self.timePos)/10*10;
  88
  89     def setB(self):
  90         self.pb  = int(self.timePos) + 1;
  91
  92     def cleanPoints(self):
  93         self.pa = None
  94         self.pb = None
  95
  96     #END def setCirclePoint(self):
  97
  98     def setVolume(self,value):
  99         if(self.playerState == MProcess.PLAYING):
 100             self.write("volume " + str(value) + " 1\n")
 101         else:
 102             pass
 103     #END def setVolume(self,value):
 104
 105     def setupTimer(self):
 106         if(self.timerId == None):
 107             self.timerId = self.startTimer(MProcess.INTERVAL)
 108         else:
 109             pass
 110     #END def setupTimer(self):
 111
 112     def closeTimer(self):
 113         if(self.timerId != None):
 114             self.killTimer(self.timerId)
 115             self.timerId = None
 116         else:
 117             pass
 118     #END def closeTimer(self):
 119
 120     def pause(self):
 121         if(self.playerState == MProcess.PAUSED):
 122             self.playerState = MProcess.PLAYING
 123             self.setupTimer()
 124         elif(self.playerState == MProcess.PLAYING):
 125             self.closeTimer()
 126             self.playerState = MProcess.PAUSED
 127         else:  ## if STOPPED, then return directly
 128             self.closeTimer()
 129             return
 130         self.write("pause \n")
 131     #END def pause(self):
 132
 133     def stop(self):
 134         self.closeTimer()
 135         self.playerState == MProcess.STOPPED
 136         self.timeLength = None
 137         self.write("stop \n")
 138     #END  def stop(self):
 139
 140     def analyseResult(self):
 141         resStr = self.readAll().data()
 142         if(re.search("POSITION",resStr)):
 143             self.timePos = float((re.search("\d+\.?\d",resStr).group(0)))
 144         elif(re.search("LENGTH",resStr)):
 145             self.timeLength = float(re.search("\d+\.?\d",resStr).group(0))
 146             if(self.slider != None):
 147                 self.slider.setRange(0,int(self.timeLength)+1)
 148             print self.timeLength
 149         elif(re.search("End of file",resStr)):
 150             self.closeTimer()
 151             self.playerState = MProcess.STOPPED
 152             self.emit(SIGNAL("stopped()"))
 153         else:
 154             print resStr
 155
 156
 157
 158         if(self.pa == None or self.pb == None):
 159             return
 160
 161         if( self.pa >= self.pb ):
 162             self.pb += 10
 163
 164         if(self.timePos > self.pb):
 165             self.timePos = self.pa
 166             print "seek "+ str(self.pa) + " 0\n"
 167             self.write("seek "+ str(self.pa) + " 2\n")
 168
 169     #END  def analyseResult(self):
 170
 171     def timerEvent(self,event):
 172         if(event.timerId() != self.timerId):
 173             return
 174
 175         print self.timePos, "  ", self.pa, "  ", self.pb
 176         if(self.slider != None and self.timePos != None):
 177             self.slider.setValue(int(self.timePos))
 178
 179
 180         if(self.playerState == MProcess.PAUSED):
 181             self.closeTimer()
 182             return
 183
 184         if(self.state() == QProcess.NotRunning):
 185             self.closeTimer()
 186             self.playerState = MProcess.STOPPED
 187             self.emit(SIGNAL("stopped()"))
 188             return
 189
 190         self.write("get_time_pos\n")
 191         if(self.timeLength == None):
 192             self.write("get_time_length\n")
 193
 194     #END def timerEvent(self,event):
 195
 196 #END class MProcess(QProcess):