senset/vnpy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

新增DataEngine的处理

Browse Source
This commit is contained in:
zhu4ling3 2018-04-09 20:18:24 +08:00
parent a0575aa7bf
commit 4aaf77a423
1 changed files with 19 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
UML/dataRecord.puml
View File

@ -4,7 +4,7 @@ participant runDataRecord as rundr
participant Process as run participant Process as run
participant MainEngine as me participant MainEngine as me
participant LogEngine as runle participant LogEngine as runle
participant DataEngine as dt participant DataEngine as dte
participant LogEngine as le participant LogEngine as le
participant DrEngine as dr participant DrEngine as dr
participant Queue as drq participant Queue as drq
@ -49,9 +49,24 @@ run->me ** : new mainEngine(ee)
ee->eet ++ #red : thread.start() ee->eet ++ #red : thread.start()
ee->eetm ++ #green : timer.start() ee->eetm ++ #green : timer.start()
ee-->me--: return ee-->me--: return
me->dt ** :创建DataEngine() me->dte ** :创建DataEngine()
activate dt activate dte
dt->dt ++ : init() dte->dte ++ : init()
dte->dte ++ : registerEvent()
dte->ee ++ : ee.register(EVENT_CONTRACT, self.processContractEvent)
return
dte->ee ++ : ee.register(EVENT_ORDER, self.processOrderEvent)
return
dte->ee ++ : ee.register(EVENT_TRADE, self.processTradeEvent)
return
dte->ee ++ : ee.register(EVENT_POSITION, self.processPositionEvent)
return
dte->ee ++ : ee.register(EVENT_ACCOUNT, self.processAccountEvent)
return
dte->ee ++ : ee.register(EVENT_LOG, self.processLogEvent)
return
dte->ee ++ : ee.register(EVENT_ERROR, self.processErrorEvent)
return
return return
return object return object
me->le ** :创建LogEngine() me->le ** :创建LogEngine()