epic/play-with-docker
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Set session ticker inside cron

Browse Source
This commit is contained in:
Marcos Lilljedahl
2017-08-02 13:31:41 -03:00
parent cfb2ad01ca
commit 0655a4bb99
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
scheduler/scheduler.go
View File

@@ -96,7 +96,6 @@ func (s *scheduler) Start() {
for _, session := range s.scheduledSessions { for _, session := range s.scheduledSessions {
ctx, cancel := context.WithCancel(context.Background()) ctx, cancel := context.WithCancel(context.Background())
session.cancel = cancel session.cancel = cancel
session.ticker = time.NewTicker(1 * time.Second)
go s.cron(ctx, session) go s.cron(ctx, session)
} }
s.event.On(event.SESSION_NEW, func(sessionId string, args ...interface{}) { s.event.On(event.SESSION_NEW, func(sessionId string, args ...interface{}) {
@@ -129,6 +128,7 @@ func (s *scheduler) register(session *types.Session) *scheduledSession {
} }
func (s *scheduler) cron(ctx context.Context, session *scheduledSession) { func (s *scheduler) cron(ctx context.Context, session *scheduledSession) {
session.ticker = time.NewTicker(1 * time.Second)
for { for {
select { select {
case <-session.ticker.C: case <-session.ticker.C:
@@ -167,7 +167,6 @@ func (s *scheduler) Schedule(session *types.Session) error {
scheduledSession := s.register(session) scheduledSession := s.register(session)
ctx, cancel := context.WithCancel(context.Background()) ctx, cancel := context.WithCancel(context.Background())
scheduledSession.cancel = cancel scheduledSession.cancel = cancel
scheduledSession.ticker = time.NewTicker(1 * time.Second)
go s.cron(ctx, scheduledSession) go s.cron(ctx, scheduledSession)
return nil return nil
} }