diff options
| author | Jules Laplace <julescarbon@gmail.com> | 2018-06-04 23:57:23 +0200 |
|---|---|---|
| committer | Jules Laplace <julescarbon@gmail.com> | 2018-06-04 23:57:23 +0200 |
| commit | a960d57ad80a65d5cf028f2595b38ca07bb46b83 (patch) | |
| tree | 58bc92a8c30511a1e4caa79f7ce5a3528d7ac35b /app/relay/queue.js | |
| parent | 1ccc4c798d95133cde1d4558318f0640a772526a (diff) | |
updating task status on serverrrrrr
Diffstat (limited to 'app/relay/queue.js')
| -rw-r--r-- | app/relay/queue.js | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/app/relay/queue.js b/app/relay/queue.js index 9f9e821..6c65e06 100644 --- a/app/relay/queue.js +++ b/app/relay/queue.js @@ -1,8 +1,10 @@ +// get the processor that uses the task and give it its own queue! + let queue = [] -let active = true +let active = false let status = 'waiting' -export const is_active = () => active +export const is_active = () => active && queue.length export const get_status = () => status export const activate = () => { active = true @@ -15,3 +17,4 @@ export const deactivate = reason => { export const add_task = task => queue.push(task) export const remove_task = task => queue = queue.filter(t => t.id !== task.id) export const get_next_task = () => queue.shift() +export const list_tasks = () => queue |
