summaryrefslogtreecommitdiff
path: root/app
diff options
context:
space:
mode:
Diffstat (limited to 'app')
-rw-r--r--app/client/socket/socket.task.js6
-rw-r--r--app/client/system/system.component.js2
-rw-r--r--app/client/types.js2
-rw-r--r--app/relay/queue.js14
-rw-r--r--app/relay/runner.js2
5 files changed, 15 insertions, 11 deletions
diff --git a/app/client/socket/socket.task.js b/app/client/socket/socket.task.js
index 3a78c6c..44e6b27 100644
--- a/app/client/socket/socket.task.js
+++ b/app/client/socket/socket.task.js
@@ -42,11 +42,13 @@ socket.on('task_res', (data) => {
break
case 'progress':
dispatch({ type: types.task.progress, task: data.task })
+ dispatch({ type: types.task.update, task: data.task })
break
case 'epoch':
- dispatch({ type: types.task.progress, task: data.task })
+ dispatch({ type: types.task.epoch, task: data.task })
+ dispatch({ type: types.task.update, task: data.task })
break
- case 'error':
+ case 'task_error':
return console.log('task error', data)
default:
return console.log('no such task command', data.type)
diff --git a/app/client/system/system.component.js b/app/client/system/system.component.js
index 57a82e5..1953ee3 100644
--- a/app/client/system/system.component.js
+++ b/app/client/system/system.component.js
@@ -30,7 +30,7 @@ const live_test_task = {
epochs: 1,
opt: {}
}
-const fruits = ["apple","pear","banana","strawberry"]
+const fruits = ["apple","pear","orange","strawberry"]
function choice(a){ return a[Math.floor(Math.random()*a.length)]}
class System extends Component {
diff --git a/app/client/types.js b/app/client/types.js
index 22d7ebc..0c7c785 100644
--- a/app/client/types.js
+++ b/app/client/types.js
@@ -29,6 +29,8 @@ export default {
'task_begin',
'stopping_task',
'task_finish',
+ 'progress',
+ 'epoch',
]),
socket: {
connect: 'SOCKET_CONNECT',
diff --git a/app/relay/queue.js b/app/relay/queue.js
index 6e67b80..9f9e821 100644
--- a/app/relay/queue.js
+++ b/app/relay/queue.js
@@ -2,16 +2,16 @@ let queue = []
let active = true
let status = 'waiting'
-const is_active = () => active
-const get_status = () => status
-const activate = () => {
+export const is_active = () => active
+export const get_status = () => status
+export const activate = () => {
active = true
status = 'active'
}
-const deactivate = reason => {
+export const deactivate = reason => {
active = false
status = reason
}
-const add_task = task => queue.push(task)
-const remove_task = task => queue = queue.filter(t => t.id !== task.id)
-const get_next_task = () => queue.shift()
+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()
diff --git a/app/relay/runner.js b/app/relay/runner.js
index c04419d..4b5522d 100644
--- a/app/relay/runner.js
+++ b/app/relay/runner.js
@@ -8,7 +8,7 @@ import uuidv1 from 'uuid/v1'
import * as fs from 'fs'
import * as path from 'path'
-import * as queue from 'queue'
+import * as queue from './queue'
const idle_state = { status: 'IDLE', task: {} }