added missing 'go' directive
This commit is contained in:
parent
2a4d1c8dad
commit
305432e58a
@ -243,7 +243,7 @@ func main() {
|
|||||||
runninginstances[i].min_id = p.min_id
|
runninginstances[i].min_id = p.min_id
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
DeferRun(p, &runninginstances, reportInstanceChan, reportPostChan, pollMessageChan)
|
go DeferRun(p, &runninginstances, reportInstanceChan, reportPostChan, pollMessageChan)
|
||||||
case v := <-reportPostChan: // New Post
|
case v := <-reportPostChan: // New Post
|
||||||
go writePost( v)
|
go writePost( v)
|
||||||
case w := <-reportInstanceChan: // Start a new instance
|
case w := <-reportInstanceChan: // Start a new instance
|
||||||
|
Loading…
x
Reference in New Issue
Block a user