Commitcbda273

committed

Work without interruptBuffer

1 parent135d68a commitcbda273Copy full SHA for cbda273

File tree

+11

-6

lines changed

+11

-6

lines changed

Lines changed: 7 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -94,11 +94,14 @@ export const runCode = async ({code, source}) => {`
`94`	`94`	`};`
`95`	`95`
`96`	`96`	`interrupt();`
`97`		`-interruptBuffer=newInt32Array(newSharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT*1));`
`98`	`97`	`letinterrupted=false;`
`99`		`-interrupt=()=>{`
`100`		`-interruptBuffer[0]=2;`
`101`		`-interrupted=true;`
	`98`	`+`
	`99`	`+if(typeofSharedArrayBuffer!=="undefined"){`
	`100`	`+interruptBuffer=newInt32Array(newSharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT*1));`
	`101`	`+interrupt=()=>{`
	`102`	`+interruptBuffer[0]=2;`
	`103`	`+interrupted=true;`
	`104`	`+}`
`102`	`105`	`}`
`103`	`106`
`104`	`107`	`consthasPrediction=currentStep().prediction.choices;`

Lines changed: 4 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -70,7 +70,7 @@ async function runCode(entry, channel, interruptBuffer, outputCallback, inputCal`
`70`	`70`	`constmessageId=Math.random()+" "+newDate();`
`71`	`71`	`inputCallback(messageId,toObject(data));`
`72`	`72`	`functioncheckInterrupt(){`
`73`		`-returninterruptBuffer[0]===2;`
	`73`	`+returninterruptBuffer?.[0]===2;`
`74`	`74`	`}`
`75`	`75`	`returnreadChannel(`
`76`	`76`	`channel,`
`@@ -79,7 +79,9 @@ async function runCode(entry, channel, interruptBuffer, outputCallback, inputCal`
`79`	`79`	`)+"\n";`
`80`	`80`	`}`
`81`	`81`
`82`		`-pyodide._module.setInterruptBuffer(interruptBuffer);`
	`82`	`+if(interruptBuffer){`
	`83`	`+pyodide._module.setInterruptBuffer(interruptBuffer);`
	`84`	`+}`
`83`	`85`
`84`	`86`	`try{`
`85`	`87`	`awaitinstall_imports(entry.input);`

Comments

(0)