Skip to content

unit TickerMgr

em.utils/TickerMgr.em
 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
package em.utils

import AlarmMgr
import FiberMgr

module TickerMgr
            #   ^|
    type TickCallback: function()
            #   ^|
    type Ticker: opaque
            #   ^|
        host function initH()
            #   ^|
        function start(rate256: uint32, tickCb: TickCallback)
            #   ^|        
        function stop()
            #   ^|        
    end

    host function createH(): Ticker&
            #   ^|
private:

    def opaque Ticker
        alarm: AlarmMgr.Alarm&
        fiber: FiberMgr.Fiber&
        rate256: uint32
        tickCb: TickCallback
    end

    function alarmFB: FiberMgr.FiberBodyFxn

    var tickerTab: Ticker[]

end

def createH()
    var ticker: Ticker& = tickerTab[tickerTab.length++]
    ticker.initH()
    return ticker
end

def Ticker.initH()
    this.fiber = FiberMgr.createH(alarmFB, ^^this.$$cn^^)
    this.alarm = AlarmMgr.createH(this.fiber)
end

def alarmFB(arg)
    auto ticker = <Ticker&>arg
    return if ticker.tickCb == null
    ticker.tickCb() 
    ticker.alarm.wakeupAt(ticker.rate256)
end

def Ticker.start(rate256, tickCb)
    this.rate256 = rate256
    this.tickCb = tickCb
    this.alarm.wakeupAt(rate256)
end

def Ticker.stop()
    this.alarm.cancel()
    this.tickCb = null
end