Ark/leporello-js
1
0
Fork 0
mirror of https://github.com/leporello-js/leporello-js synced 2026-01-13 13:04:30 -08:00
Code Issues Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
Dmitry Vasilev
2023-02-07 21:36:36 +08:00
parent 9b9d2e305e
commit 34188eddc3
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/record_io.js
View File

@@ -17,7 +17,6 @@ const io_patch = (cxt, path, use_context = false) => {
} }
const name = path.join('.') const name = path.join('.')
console.log('patching', name, obj, method)
const original = obj[method] const original = obj[method]
obj[method] = function(...args) { obj[method] = function(...args) {
@@ -65,7 +64,7 @@ const io_patch = (cxt, path, use_context = false) => {
console.log('value', value) console.log('value', value)
if(value instanceof Promise) { if(value instanceof cxt.window.Promise) {
// TODO use native .finally for promise, not patched then? // TODO use native .finally for promise, not patched then?
value.finally(() => { value.finally(() => {
// TODO guard calls from prev runs // TODO guard calls from prev runs
@@ -97,8 +96,8 @@ const io_patch = (cxt, path, use_context = false) => {
} }
} else { } else {
const call = cxt.io_cache[cxt.io_cache_index] const call = cxt.io_cache[cxt.io_cache_index]
/*
TODO remove /* TODO remove
console.log( console.log(
call.type != 'call' call.type != 'call'
, call == null , call == null
@@ -126,7 +125,7 @@ const io_patch = (cxt, path, use_context = false) => {
JSON.stringify(call.args) != JSON.stringify(args) JSON.stringify(call.args) != JSON.stringify(args)
) )
){ ){
console.log('discard cache', call) console.error('DISCARD cache', call)
cxt.io_cache_is_replay_aborted = true cxt.io_cache_is_replay_aborted = true
// Try to finish fast // Try to finish fast
throw new Error('io replay aborted') throw new Error('io replay aborted')
@@ -153,6 +152,7 @@ const io_patch = (cxt, path, use_context = false) => {
// TODO check if call from prev run // TODO check if call from prev run
if(cxt.io_cache_is_replay_aborted) { if(cxt.io_cache_is_replay_aborted) {
console.error('RESOLVER ABORTED')
return return
} }
@@ -195,7 +195,7 @@ const io_patch = (cxt, path, use_context = false) => {
// TODO resolve promises in the same order they were resolved on // TODO resolve promises in the same order they were resolved on
// initial execution // initial execution
if(call.value instanceof Promise) { if(call.value instanceof cxt.window.Promise) {
return new Promise(resolve => { return new Promise(resolve => {
cxt.io_cache_resolvers.set(cxt.io_cache_index - 1, resolve) cxt.io_cache_resolvers.set(cxt.io_cache_index - 1, resolve)
}) })
@@ -226,7 +226,6 @@ const io_patch_remove = (cxt, path) => {
return return
} }
console.log('removing io patch', obj, method)
obj[method] = obj[method].__original obj[method] = obj[method].__original
} }

1
src/runtime.js
View File

@@ -42,6 +42,7 @@ const do_run = function*(module_fns, cxt, io_cache){
: {...cxt, : {...cxt,
io_cache_is_recording: false, io_cache_is_recording: false,
io_cache, io_cache,
io_cache_is_replay_aborted: false,
io_cache_resolver_is_set: false, io_cache_resolver_is_set: false,
// Map of (index in io_cache) -> resolve // Map of (index in io_cache) -> resolve
io_cache_resolvers: new Map(), io_cache_resolvers: new Map(),