X-Git-Url: https://git.martlubbers.net/?a=blobdiff_plain;f=Tasks%2FmTaskTask.icl;h=e8282576116ca1f56420a76720048d4078a6dd7a;hb=6d956995e169ae8fd44d62e26e35d499a9660225;hp=dcd0b8a56b2dfba6893cdfafc8d0c4f930ede4ef;hpb=96bcbbd100188d284eac9c00630657b85c57a6ae;p=mTask.git diff --git a/Tasks/mTaskTask.icl b/Tasks/mTaskTask.icl index dcd0b8a..e828257 100644 --- a/Tasks/mTaskTask.icl +++ b/Tasks/mTaskTask.icl @@ -9,13 +9,17 @@ import iTasks._Framework.Serialization derive class iTask MTaskTask, MTaskInterval, Main, ByteCode, Stmt, Expr, BC, BCState, RWST, Identity makeTask :: String Int -> Task MTaskTask -makeTask name ident = get currentDateTime +makeTask name ident = get currentDateTime @ \dt->{MTaskTask | name=name,ident=ident,dateAdded=dt} +import StdDebug +import StdMisc sendTaskToDevice :: String (Main (ByteCode a Stmt)) (MTaskDevice, MTaskInterval) -> Task [MTaskDevice] sendTaskToDevice wta mTask (device, timeout) -# (msgs, newState) = toMessages timeout mTask device.deviceState -# shares = [makeShare wta sdsi sdsval\\{sdsi,sdsval}<-newState.sdss, (MTSds sdsi` _)<-msgs | sdsi == sdsi`] +| not (trace_tn "compiling task") = undef +# (msgs, newState=:{sdss}) = toMessages timeout mTask device.deviceState +| not (trace_tn "Done compiling task") = undef +# shares = [makeShare wta "" sdsi sdsval\\{sdsi,sdsval}<-sdss, (MTSds sdsi` _)<-msgs | sdsi == sdsi`] = updateShares device ((++) shares) >>| sendMessages msgs device >>| makeTask wta -1 @@ -24,3 +28,9 @@ sendTaskToDevice wta mTask (device, timeout) addTaskUpState :: BCState MTaskTask MTaskDevice -> MTaskDevice addTaskUpState st task device = { MTaskDevice | device & deviceState=st, deviceTasks=[task:device.deviceTasks]} + +//liftmTask :: String (Main (ByteCode a Stmt)) (MTaskDevice, MTaskInterval) -> Task a +//liftmTask wta mTask (device, timeout) +// = sendTaskToDevice wta mTask (device, timeout) +// >>| wait "waiting for task to return" $ sdsFocus +// >>| treturn