Files
@ 655956f6ba89
Branch filter:
Location: OneEye/src/core.py
655956f6ba89
2.7 KiB
text/x-python
training and testing model
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 | import multiprocessing
import threading
import logging
import PIL
import config as cfg
from util import MsgQueue
from gui import gui
from analyzer import ImageAnalyzer
from analyzer.framecache import FrameCache
from go.core import Go, isLegalPosition
from statebag import StateBag
from video import capVideo
log=logging.getLogger(__name__)
class Core:
def __init__(self):
self.grid=None
self.go=Go()
self.detector=ImageAnalyzer()
self._cache=FrameCache()
self.states=StateBag()
self._ownMessages=MsgQueue("Core",self._handleEvent)
self._guiMessages=MsgQueue("GUI")
self._vidMessages=MsgQueue("Video")
self._listenerThread=None
self._frame=None
self._guiProc=multiprocessing.Process(name="gui", target=gui, args=(self._guiMessages,self._ownMessages))
self._guiProc.start()
self._vidProc=multiprocessing.Process(
name="video",
target=capVideo,
args=(cfg.misc.video, self._vidMessages,self._ownMessages)
)
self._vidProc.start()
def fetchFrame(self,key):
frame=self._cache.get(key)
if frame is None:
(key,frame)=self._cache.getRelative(10)
self._guiMessages.send("setFrame", (frame.copy(), gui.PREVIEW, key))
def putFrame(self,frame):
self._frame=PIL.Image.fromarray(frame)
k=self._cache.put(self._frame)
self._guiMessages.send("setFrame", (self._frame, gui.REAL, k))
self.analyze()
def sendParams(self):
self._guiMessages.send("setParams",(self.detector.params.copy(),))
def setParams(self,params):
self.detector.setParams(params)
def analyze(self):
if self.detector.analyze(self._frame):
if isLegalPosition(self.detector.board):
state=self.states.pushState(self.detector.board)
rec=[]
if state:
rec=state.exportRecord()
log.debug("progressive game record: %s",rec)
self._guiMessages.send("setGameState", (self.detector.board,rec))
self.go.transitionMove(self.detector.board)
log.debug("conservative game record: %s",self.go._record)
else:
log.info("illegal position detected")
def listen(self):
self._listenerThread=threading.Thread(target=lambda: self._ownMessages.listen())
self._listenerThread.start()
def joinChildren(self):
self._guiProc.join()
self._vidMessages.send("shutDown")
self._vidProc.join()
self._ownMessages.send("!kill",("core",))
self._listenerThread.join()
log.info("Core exiting.")
def _handleEvent(self,e):
actions={
"fetchFrame": self.fetchFrame,
"putFrame": self.putFrame,
"fetchParams": self.sendParams,
"setParams": self.setParams
}
(actionName,args,kwargs)=e
return actions[actionName](*args,**kwargs)
if __name__=="__main__":
core=Core()
core.listen()
log.info("OneEye started.")
core.joinChildren()
log.info("OneEye done.")
|