diff options
Diffstat (limited to 'site/udo/twist/checkpointing_hold.udo')
| -rwxr-xr-x | site/udo/twist/checkpointing_hold.udo | 196 |
1 files changed, 196 insertions, 0 deletions
diff --git a/site/udo/twist/checkpointing_hold.udo b/site/udo/twist/checkpointing_hold.udo new file mode 100755 index 0000000..523d423 --- /dev/null +++ b/site/udo/twist/checkpointing_hold.udo @@ -0,0 +1,196 @@ +#ifndef UDO_TWIST_CHECKPOINTING
+#define UDO_TWIST_CHECKPOINTING ##
+
+; file checkpointing broken due to WASM FS issue, but keep in memory maybe better anyway
+
+#ifdef TWIST_FTCHECKPOINTING
+
+gitwst_checkpoints[][] init imaxinstances, gitwst_maxundolevels
+gitwst_checkpointstate[] init imaxinstances
+gitwst_checkpointencodemult = 10000
+
+opcode twst_checkpoint, 0, j
+ instanceindex xin
+ imaxundo chnget "maxundo"
+ imaxundo = (imaxundo == -1) ? gitwst_maxundolevels : imaxundo
+ if (imaxundo == 0 || imaxundo > gitwst_maxundolevels) then
+ goto complete
+ endif
+
+ instanceindex = (instanceindex == -1) ? gitwst_instanceindex : instanceindex
+ icheckpointnumber = gitwst_checkpointstate[instanceindex]
+
+ if (icheckpointnumber >= imaxundo) then
+ ftfree gitwst_checkpoints[instanceindex][0], 0
+ index = 1
+ while (index < gitwst_maxundolevels) do
+ gitwst_checkpoints[instanceindex][index - 1] = gitwst_checkpoints[instanceindex][index]
+ index += 1
+ od
+ else
+ gitwst_checkpointstate[instanceindex] = icheckpointnumber + 1
+ endif
+
+ ifnL = gitwst_bufferL[instanceindex]
+ ifnR = gitwst_bufferR[instanceindex]
+ ilen = ftlen(ifnL)
+
+ ifnCheckpointL ftgen 0, 0, ilen, 2, 0
+ tableicopy ifnCheckpointL, ifnL
+ ifnEncodedL = ifnCheckpointL * gitwst_checkpointencodemult
+ if (ifnR > 0) then
+ ifnCheckpointR ftgen 0, 0, ilen, 2, 0
+ tableicopy ifnCheckpointR, ifnR
+ ifnEncodedR = ifnCheckpointR / gitwst_checkpointencodemult
+ else
+ ifnEncodedR = 0
+ endif
+
+ iencoded = ifnEncodedL + ifnEncodedR
+ gitwst_checkpoints[instanceindex][icheckpointnumber] = iencoded
+
+complete:
+endop
+
+opcode twst_undo, i, j
+ instanceindex xin
+ instanceindex = (instanceindex == -1) ? gitwst_instanceindex : instanceindex
+ Sloaded = ""
+
+ icheckpointnumber = gitwst_checkpointstate[instanceindex]
+
+ icheckpointnumber -= 1
+ if (icheckpointnumber < 0) then
+ istatus = -1
+ goto complete
+ endif
+
+ icheckpointEncoded = gitwst_checkpoints[instanceindex][icheckpointnumber]
+ ifnCheckpointL = icheckpointEncoded / gitwst_checkpointencodemult
+ ifnCheckpointR = icheckpointEncoded * gitwst_checkpointencodemult
+
+ ftfree gitwst_bufferL[instanceindex], 0
+ gitwst_bufferL[instanceindex] = ifnCheckpointL
+
+ if (ifnCheckpointR > 0) then
+ ftfree gitwst_bufferR[instanceindex], 0
+ gitwst_bufferR[instanceindex] = ifnCheckpointR
+ endif
+
+ istatus = 1
+
+complete:
+ xout istatus
+endop
+
+#else
+
+gitwst_checkpoint[][] init imaxinstances, 2
+gitwst_checkpointlengths[][] init imaxinstances, gitwst_maxundolevels
+opcode twst_checkpointfilename, S, jj
+ instanceindex, icheckpointnumber xin
+ instanceindex = (instanceindex == -1) ? gitwst_instanceindex : instanceindex
+ icheckpointnumber = (icheckpointnumber == -1) ? gitwst_checkpoint[instanceindex][0] : icheckpointnumber
+ Sfile = sprintf("checkpoint-%d-%d", instanceindex, icheckpointnumber)
+ Sfile = strcat(host_tempdir(), strcat("/", Sfile))
+ xout Sfile
+endop
+
+opcode twst_checkpoint, 0, j
+ instanceindex xin
+ imaxundo chnget "maxundo"
+ if (imaxundo == 0 || imaxundo > gitwst_maxundolevels) then
+ goto complete
+ endif
+
+ instanceindex = (instanceindex == -1) ? gitwst_instanceindex : instanceindex
+ icheckpointnumber = gitwst_checkpoint[instanceindex][0]
+ icheckpointoffset = gitwst_checkpoint[instanceindex][1]
+
+ if (icheckpointoffset + icheckpointnumber >= imaxundo) then
+ Sdelete = twst_checkpointfilename(icheckpointoffset)
+ io_sendstring("callback", sprintf("{\"cbid\":%d,\"delete\": [\"%s\", \"%s.len\"]}", giwst_globalcbid, Sdelete, Sdelete))
+ icheckpointoffset += 1
+ gitwst_checkpoint[instanceindex][1] = icheckpointoffset
+ endif
+
+ Sfile = twst_checkpointfilename(instanceindex)
+
+ gitwst_checkpointlengths[instanceindex][icheckpointnumber - icheckpointoffset] = ftlen(gitwst_bufferL[instanceindex])
+ /* can't use this as WASM not writing/closing files properly
+ ilen = ftlen(gitwst_bufferL[instanceindex])
+ ihf fiopen strcat(Sfile, ".len"), 0
+ fouti ihf, 0, 0, ilen
+ ficlose ihf*
+ ; nor this ;fprints strcat(Sfile, ".len"), "%d\n", ftlen(gitwst_bufferL[instanceindex])
+ */
+
+ if (gitwst_channels[instanceindex] == 1) then
+ ftsave Sfile, 0, gitwst_bufferL[instanceindex]
+ else
+ ftsave Sfile, 0, gitwst_bufferL[instanceindex], gitwst_bufferR[instanceindex]
+ endif
+ gitwst_checkpoint[instanceindex][0] = icheckpointnumber + 1
+complete:
+endop
+
+opcode twst_undo, iS, j
+ instanceindex xin
+ instanceindex = (instanceindex == -1) ? gitwst_instanceindex : instanceindex
+ Sloaded = ""
+
+ icheckpointnumber = gitwst_checkpoint[instanceindex][0]
+ icheckpointoffset = gitwst_checkpoint[instanceindex][1]
+
+ if (icheckpointnumber - icheckpointoffset <= 0) then
+ istatus = -1
+ goto complete
+ endif
+
+ icheckpointnumber -= 1
+ gitwst_checkpoint[instanceindex][0] = icheckpointnumber
+ Sfile = twst_checkpointfilename(instanceindex)
+
+ ilen = gitwst_checkpointlengths[instanceindex][icheckpointnumber - icheckpointoffset]
+ /* can't use this as WASM not writing/closing files properly thus checkpoint step doesn't write
+ SlenFile = strcat(Sfile, ".len")
+ if (filevalid(Sfile) != 1 || filevalid(SlenFile) != 1) then
+ istatus = -2
+ goto complete
+ endif
+
+ ilen init 0
+ ihf fiopen SlenFile, 1
+ fini ihf, 0, 1, ilen
+ ficlose ihf
+ */
+
+ if (ilen == 0) then
+ istatus = -3
+ goto complete
+ endif
+
+ if (ilen != ftlen(gitwst_bufferL[instanceindex])) then
+ twst_clearbuffers gitwst_bufferL[instanceindex], gitwst_bufferR[instanceindex]
+ gitwst_bufferL[instanceindex] ftgen 0, 0, -ilen, -2, 0
+ if (gitwst_channels[instanceindex] == 2) then
+ gitwst_bufferR[instanceindex] ftgen 0, 0, -ilen, -2, 0
+ else
+ gitwst_bufferR[instanceindex] = 0
+ endif
+ endif
+
+ if (gitwst_channels[instanceindex] == 1) then
+ ftload Sfile, 0, gitwst_bufferL[instanceindex]
+ else
+ ftload Sfile, 0, gitwst_bufferL[instanceindex], gitwst_bufferR[instanceindex]
+ endif
+ Sloaded = Sfile
+ istatus = 1
+
+complete:
+ xout istatus, Sloaded
+endop
+#end
+
+#end
\ No newline at end of file |