{"header":{"message":"wrote a dummy InnerExecutor and the run decision logic for WasmPool","description":null,"timestamp":"2021-01-17T16:23:57.823598147Z","authors":[{"email":"3611916+oreganoli@users.noreply.github.com","full_name":"oreganoli","name":"oreganoli"}]},"hash":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC","authors":[],"deps":{"hashes":[["7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC","wrote a dummy InnerExecutor and the run decision logic for WasmPool"],["AA",null],["ADGKEIDIFEFIDGO6E5NMELKLSE5K6V74X73O6BX7C3LDBY5NQQ2AC","clarified Envelope description; changed ExecutorMsg::Invoke to be just Vec"],["NUXZXM3D64JDAP7TVBAY23Z43RW27JL4XHVOEXFLT5CLDU6CVOOAC","created an Envelope abstraction and started work on the Wasm executor pool"],["6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC","gateway now parses HTTP requests into invocations"],["BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC","wrote rudimentary hello-world core"],["TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC","started work on executors"],["KZMW4JDYUYSQHRZMLNL7EOVWYJWOI7L573QAL3KUMMMG6IWKBS6AC","Created zhur_common crate with reexports"],["WXLXWHPVYBBSZ76TUABERVLQAN26QTZLF6NGZZMB56FUTCLPSB4QC","wrote an abstraction over client/server threads"],["WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC","Hyper hello world is up"],["Q5GUHJ4O6GNSL23U77Y3HR2WW7V3LTYVHXPKOMJY76JKIZUU5YWQC","initial commit, readme"]],"deps":["ADGKEIDIFEFIDGO6E5NMELKLSE5K6V74X73O6BX7C3LDBY5NQQ2AC"],"known":["Q5GUHJ4O6GNSL23U77Y3HR2WW7V3LTYVHXPKOMJY76JKIZUU5YWQC","KZMW4JDYUYSQHRZMLNL7EOVWYJWOI7L573QAL3KUMMMG6IWKBS6AC","WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC","6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC","WXLXWHPVYBBSZ76TUABERVLQAN26QTZLF6NGZZMB56FUTCLPSB4QC","BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC","NUXZXM3D64JDAP7TVBAY23Z43RW27JL4XHVOEXFLT5CLDU6CVOOAC","TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC"]},"hunks":[{"Replacement":{"inode":{"change":3,"pos":6716},"path":"zhur_gate/src/handle.rs","line":48,"ins":{"up_context":[{"change":3,"pos":8405}],"down_context":[],"flag":"BLOCK","start":0,"end":3,"inode":{"change":3,"pos":6716}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8405},"to":{"change":2,"start":0,"end":3},"introduced_by":2}],"inode":{"change":3,"pos":6716}},"ins_contents":[{"Add":{"text":"}\\","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2"}}],"del_contents":[{"Del":{"text":"}\\","pos":"ADGKEIDIFEFIDGO6E5NMELKLSE5K6V74X73O6BX7C3LDBY5NQQ2AC:2"}}]}},{"Replacement":{"inode":{"change":3,"pos":147},"path":"zhur_core/src/wasm.rs","line":1,"ins":{"up_context":[{"change":3,"pos":147}],"down_context":[{"change":3,"pos":191}],"flag":"BLOCK","start":4,"end":59,"inode":{"change":3,"pos":147}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":147},"to":{"change":3,"start":148,"end":191},"introduced_by":3}],"inode":{"change":3,"pos":147}},"ins_contents":[{"Add":{"text":"use zhur_common::msg::chan::{Envelope, HandleRequest};","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:58"}}],"del_contents":[{"Del":{"text":"use zhur_common::msg::chan::HandleRequest;","pos":"NUXZXM3D64JDAP7TVBAY23Z43RW27JL4XHVOEXFLT5CLDU6CVOOAC:190"}}]}},{"Replacement":{"inode":{"change":3,"pos":147},"path":"zhur_core/src/wasm.rs","line":7,"ins":{"up_context":[{"change":3,"pos":15814}],"down_context":[],"flag":"BLOCK","start":60,"end":181,"inode":{"change":3,"pos":147}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":15814},"to":{"change":2,"start":4,"end":23},"introduced_by":2}],"inode":{"change":3,"pos":147}},"ins_contents":[{"Add":{"text":"pub mod executor;","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:77"}},{"Add":{"text":"","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:78"}},{"Add":{"text":"pub type InvocEnv = Envelope>;","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:129"}},{"Add":{"text":"pub type PayloadEnv = Envelope, Vec>;\\","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:180"}}],"del_contents":[{"Del":{"text":"pub mod executor;\\","pos":"ADGKEIDIFEFIDGO6E5NMELKLSE5K6V74X73O6BX7C3LDBY5NQQ2AC:22"}}]}},{"Edit":{"inode":{"change":3,"pos":329},"path":"zhur_core/src/wasm/pool.rs","line":4,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":457}],"down_context":[{"change":3,"pos":457}],"flag":"BLOCK","start":182,"end":210,"inode":{"change":3,"pos":329}}},"contents":[{"Add":{"text":"","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:182"}},{"Add":{"text":"use crate::wasm::InvocEnv;","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:209"}}]}},{"Replacement":{"inode":{"change":3,"pos":329},"path":"zhur_core/src/wasm/pool.rs","line":7,"ins":{"up_context":[{"change":3,"pos":458}],"down_context":[{"change":3,"pos":530}],"flag":"BLOCK","start":211,"end":242,"inode":{"change":3,"pos":329}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":458},"to":{"change":3,"start":458,"end":530},"introduced_by":3}],"inode":{"change":3,"pos":329}},"ins_contents":[{"Add":{"text":"use super::executor::Executor;","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:241"}}],"del_contents":[{"Del":{"text":"type InvocEnv = Envelope>;","pos":"NUXZXM3D64JDAP7TVBAY23Z43RW27JL4XHVOEXFLT5CLDU6CVOOAC:529"}}]}},{"Replacement":{"inode":{"change":3,"pos":329},"path":"zhur_core/src/wasm/pool.rs","line":18,"ins":{"up_context":[{"change":3,"pos":1045}],"down_context":[],"flag":"BLOCK","start":243,"end":1791,"inode":{"change":3,"pos":329}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1045},"to":{"change":3,"start":15834,"end":15837},"introduced_by":3}],"inode":{"change":3,"pos":329}},"ins_contents":[{"Add":{"text":" /// The actual executors.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:272"}},{"Add":{"text":" executors: Vec,","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:302"}},{"Add":{"text":"}","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:304"}},{"Add":{"text":"/// These are the possible decisions the `WasmPool` can make when receiving an invocation.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:395"}},{"Add":{"text":"enum RunDecision {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:414"}},{"Add":{"text":" /// The invocation can't be run right away, as there are no free executors, and needs to be put on hold.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:523"}},{"Add":{"text":" PutAway,","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:536"}},{"Add":{"text":" /// Forward the invocation to the executor at the given index, which already has the relevant code.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:640"}},{"Add":{"text":" Forward(usize),","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:660"}},{"Add":{"text":" /// Forward the invocation to the executor at the given index, but make it load the relevant code first.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:769"}},{"Add":{"text":" Replace(usize),","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:789"}},{"Add":{"text":" /// Spawn a new executor to handle this invocation.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:845"}},{"Add":{"text":" SpawnNew,","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:859"}},{"Add":{"text":"}","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:861"}},{"Add":{"text":"","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:862"}},{"Add":{"text":"impl WasmPool {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:878"}},{"Add":{"text":" /// Decides what to do with an incoming `Invocation`.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:936"}},{"Add":{"text":" fn decide(&self, i: &Invocation) -> RunDecision {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:990"}},{"Add":{"text":" // Do we have a free executor with the necessary app?","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1052"}},{"Add":{"text":" for (index, each) in self.executors.iter().enumerate() {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1117"}},{"Add":{"text":" if each.owner == i.owner && each.app_name == i.app_name && each.free {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1200"}},{"Add":{"text":" return RunDecision::Forward(index)","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1251"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1265"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1275"}},{"Add":{"text":" // If not, can we spawn another to handle it?","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1329"}},{"Add":{"text":" if self.n_executors < self.max_executors {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1380"}},{"Add":{"text":" return RunDecision::SpawnNew","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1421"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1431"}},{"Add":{"text":" // Let's try evicting the first free executor we find, then.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1500"}},{"Add":{"text":" for (index, each) in self.executors.iter().enumerate() {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1565"}},{"Add":{"text":" if each.free {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1592"}},{"Add":{"text":" return RunDecision::Replace(index)","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1643"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1657"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1667"}},{"Add":{"text":" // If there are no free executors and we can't spawn more, we can only wait.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1752"}},{"Add":{"text":" RunDecision::PutAway","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1781"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1787"}},{"Add":{"text":"}\\","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1790"}}],"del_contents":[{"Del":{"text":"}\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15836"}}]}},{"Edit":{"inode":{"change":3,"pos":15852},"path":"zhur_core/src/wasm/executor.rs","line":2,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":15882}],"down_context":[{"change":3,"pos":15882}],"flag":"BLOCK","start":1792,"end":1904,"inode":{"change":3,"pos":15852}}},"contents":[{"Add":{"text":"","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1792"}},{"Add":{"text":"use zhur_common::{flume::{Receiver, Sender}, log::*, msg::chan::Envelope};","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1867"}},{"Add":{"text":"","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1868"}},{"Add":{"text":"use super::{InvocEnv, PayloadEnv};","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1903"}}]}},{"Replacement":{"inode":{"change":3,"pos":15852},"path":"zhur_core/src/wasm/executor.rs","line":7,"ins":{"up_context":[{"change":3,"pos":15883}],"down_context":[{"change":3,"pos":16001}],"flag":"BLOCK","start":1905,"end":1916,"inode":{"change":3,"pos":15852}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":15883},"to":{"change":3,"start":15883,"end":16001},"introduced_by":3}],"inode":{"change":3,"pos":15852}},"ins_contents":[{"Add":{"text":"mod inner;","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1915"}}],"del_contents":[{"Del":{"text":"use zhur_common::{flume::Sender, log::*, msg::chan::Envelope};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15945"}},{"Del":{"text":"use zhur_invk::{HttpRes, Invocation, InvocationError};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16000"}}]}},{"Edit":{"inode":{"change":3,"pos":15852},"path":"zhur_core/src/wasm/executor.rs","line":15,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":16241}],"down_context":[{"change":3,"pos":16241}],"flag":"BLOCK","start":1917,"end":2009,"inode":{"change":3,"pos":15852}}},"contents":[{"Add":{"text":" /// Whether or not the executor can handle an invocation right now.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:1988"}},{"Add":{"text":" pub free: bool,","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2008"}}]}},{"Edit":{"inode":{"change":3,"pos":15852},"path":"zhur_core/src/wasm/executor.rs","line":19,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":16344}],"down_context":[{"change":3,"pos":16344}],"flag":"BLOCK","start":2010,"end":2097,"inode":{"change":3,"pos":15852}}},"contents":[{"Add":{"text":" /// Receiver for \"done\" messages from the inner thread.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2069"}},{"Add":{"text":" done_rx: Receiver<()>,","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2096"}}]}},{"Replacement":{"inode":{"change":3,"pos":15852},"path":"zhur_core/src/wasm/executor.rs","line":28,"ins":{"up_context":[{"change":3,"pos":16629}],"down_context":[{"change":3,"pos":16723}],"flag":"BLOCK","start":2098,"end":2304,"inode":{"change":3,"pos":15852}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":16629},"to":{"change":2,"start":24,"end":236},"introduced_by":2}],"inode":{"change":3,"pos":15852}},"ins_contents":[{"Add":{"text":" /// Self-explanatory. We're only passing in a payload and expecting a serialized reply which the core won't need to deserialize, thus we use `Vec` rather than complex types.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2279"}},{"Add":{"text":" Invoke(PayloadEnv),","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2303"}}],"del_contents":[{"Del":{"text":" /// Self-explanatory. We're only passing in a payload and a serialized reply which the core won't need to deserialize, thus we use `Vec` rather than complex types.","pos":"ADGKEIDIFEFIDGO6E5NMELKLSE5K6V74X73O6BX7C3LDBY5NQQ2AC:195"}},{"Del":{"text":" Invoke(Envelope, Vec>),","pos":"ADGKEIDIFEFIDGO6E5NMELKLSE5K6V74X73O6BX7C3LDBY5NQQ2AC:235"}}]}},{"Edit":{"inode":{"change":3,"pos":15852},"path":"zhur_core/src/wasm/executor.rs","line":35,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":16791}],"down_context":[{"change":3,"pos":16791}],"flag":"BLOCK","start":2305,"end":2660,"inode":{"change":3,"pos":15852}}},"contents":[{"Add":{"text":" pub fn load_code(&self, code: Vec) {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2349"}},{"Add":{"text":" self.msg_tx.send(ExecutorMsg::LoadCode(code))","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2403"}},{"Add":{"text":" .expect(\"Could not pass WASM code down to inner executor.\");","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2472"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2478"}},{"Add":{"text":" pub fn invoke(&self, envelope: PayloadEnv) {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2527"}},{"Add":{"text":" self.msg_tx.send(ExecutorMsg::Invoke(envelope))","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2583"}},{"Add":{"text":" .expect(\"Could not pass invocation down to inner executor.\");","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2653"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2659"}}]}},{"Replacement":{"inode":{"change":3,"pos":15852},"path":"zhur_core/src/wasm/executor.rs","line":61,"ins":{"up_context":[{"change":3,"pos":17429}],"down_context":[],"flag":"BLOCK","start":2661,"end":2664,"inode":{"change":3,"pos":15852}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17429},"to":{"change":2,"start":237,"end":240},"introduced_by":2}],"inode":{"change":3,"pos":15852}},"ins_contents":[{"Add":{"text":"}\\","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2663"}}],"del_contents":[{"Del":{"text":"}\\","pos":"ADGKEIDIFEFIDGO6E5NMELKLSE5K6V74X73O6BX7C3LDBY5NQQ2AC:239"}}]}},{"FileAdd":{"meta":{"basename":"executor","metadata":1005},"path":"zhur_core/src/wasm/executor","context":[{"change":3,"pos":318}],"contents":[]}},{"FileAdd":{"meta":{"basename":"inner.rs","metadata":420},"path":"zhur_core/src/wasm/executor/inner.rs","context":[{"change":0,"pos":2676}],"contents":[{"Add":{"text":"use std::thread::JoinHandle;","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2717"}},{"Add":{"text":"","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2718"}},{"Add":{"text":"use zhur_common::flume::{Receiver, Sender};","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2762"}},{"Add":{"text":"use zhur_common::log::*;","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2787"}},{"Add":{"text":"use super::ExecutorMsg;","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2811"}},{"Add":{"text":"/// This struct contains the actual code engine used to run user-provided apps.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2891"}},{"Add":{"text":"pub struct InnerExecutor {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2918"}},{"Add":{"text":" /// Inner executor's numeral ID. Inherited from the outer `Executor` struct.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:2999"}},{"Add":{"text":" id: usize,","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3014"}},{"Add":{"text":" msg_rx: Receiver,","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3049"}},{"Add":{"text":" done_tx: Sender<()>,","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3074"}},{"Add":{"text":"}","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3076"}},{"Add":{"text":"impl InnerExecutor {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3097"}},{"Add":{"text":" pub fn new(id: usize, msg_rx: Receiver, done_tx: Sender<()>) -> Self {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3185"}},{"Add":{"text":" Self {id, msg_rx, done_tx}","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3220"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3226"}},{"Add":{"text":" /// Handles incoming `ExecutorMsg`s and decides whether or not the executor's loop should continue to run by returning a `bool`.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3359"}},{"Add":{"text":" fn handle(&mut self) -> bool {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3394"}},{"Add":{"text":" let msg = match self.msg_rx.recv() {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3439"}},{"Add":{"text":" Ok(msg) => msg,","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3467"}},{"Add":{"text":" Err(_) => {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3491"}},{"Add":{"text":" let text = format!(\"Inner WASM executor #1 could not receive a message from its outer executor thread!\");","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3613"}},{"Add":{"text":" error!(\"{}\", &text);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3650"}},{"Add":{"text":" panic!(\"{}\", &text);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3687"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3701"}},{"Add":{"text":" };","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3712"}},{"Add":{"text":" match msg {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3732"}},{"Add":{"text":" ExecutorMsg::LoadCode(_v) => {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3775"}},{"Add":{"text":" trace!(\"Inner WASM executor #{} was requested to reload its code.\", self.id);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3869"}},{"Add":{"text":" trace!(\"Not actually doing anything, WASM not implemented yet.\");","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3951"}},{"Add":{"text":" },","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:3966"}},{"Add":{"text":" ExecutorMsg::Invoke(_env) => {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4009"}},{"Add":{"text":" trace!(\"Inner WASM executor #{} received an invocation.\", self.id);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4093"}},{"Add":{"text":" trace!(\"Not actually doing anything, WASM not implemented yet.\");","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4175"}},{"Add":{"text":" match _env.1.send(b\"PLACEHOLDER\".to_vec()) {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4236"}},{"Add":{"text":" Ok(_) => (),","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4269"}},{"Add":{"text":" Err(_) => {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4301"}},{"Add":{"text":" let text = format!(\"Inner WASM executor #{} could not respond to the invocation it got!\", self.id);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4425"}},{"Add":{"text":" error!(\"{}\", &text);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4470"}},{"Add":{"text":" panic!(\"{}\", &text);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4515"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4537"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4555"}},{"Add":{"text":" match self.done_tx.send(()) {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4601"}},{"Add":{"text":" Ok(_) => (),","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4634"}},{"Add":{"text":" Err(_) => {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4666"}},{"Add":{"text":" let text = format!(\"Inner WASM executor #{} could not report a successful execution!\", self.id);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4787"}},{"Add":{"text":" error!(\"{}\", &text);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4832"}},{"Add":{"text":" panic!(\"{}\", &text);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4877"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4899"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4917"}},{"Add":{"text":" },","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4932"}},{"Add":{"text":" ExecutorMsg::Shutdown => {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:4971"}},{"Add":{"text":" trace!(\"Inner WASM executor #{} was told to shut down.\", self.id);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5054"}},{"Add":{"text":" return false // quit thread loop","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5103"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5117"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5127"}},{"Add":{"text":" true","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5140"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5146"}},{"Add":{"text":" /// Runs the executor in a background thread and returns a join handle to said thread.","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5237"}},{"Add":{"text":" pub fn run_as_thread(self) -> JoinHandle<()> {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5288"}},{"Add":{"text":" let id = self.id;","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5314"}},{"Add":{"text":" let builder = std::thread::Builder::new();","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5365"}},{"Add":{"text":" match builder","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5387"}},{"Add":{"text":" .name(format!(\"inner_executor_{}\", self.id))","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5440"}},{"Add":{"text":" .spawn(move || {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5465"}},{"Add":{"text":" let mut exec = self;","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5498"}},{"Add":{"text":" loop {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5517"}},{"Add":{"text":" if !exec.handle() {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5553"}},{"Add":{"text":" break;","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5580"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5598"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5612"}},{"Add":{"text":" }) {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5625"}},{"Add":{"text":" Ok(h) => h,","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5649"}},{"Add":{"text":" Err(_) => {","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5673"}},{"Add":{"text":" let text = format!(\"Inner WASM executor #{} could not be launched as a thread!\", id);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5775"}},{"Add":{"text":" error!(\"{}\", &text);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5812"}},{"Add":{"text":" panic!(\"{}\", &text);","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5849"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5863"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5873"}},{"Add":{"text":" }","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5879"}},{"Add":{"text":"}\\","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5882"}}]}},{"Replacement":{"inode":{"change":3,"pos":17443},"path":"zhur_core/src/main.rs","line":14,"ins":{"up_context":[{"change":3,"pos":17686}],"down_context":[],"flag":"BLOCK","start":5884,"end":5887,"inode":{"change":3,"pos":17443}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17686},"to":{"change":2,"start":241,"end":244},"introduced_by":2}],"inode":{"change":3,"pos":17443}},"ins_contents":[{"Add":{"text":"}\\","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5886"}}],"del_contents":[{"Del":{"text":"}\\","pos":"ADGKEIDIFEFIDGO6E5NMELKLSE5K6V74X73O6BX7C3LDBY5NQQ2AC:243"}}]}},{"Replacement":{"inode":{"change":3,"pos":17699},"path":"zhur_core/src/lib.rs","line":67,"ins":{"up_context":[{"change":3,"pos":20161}],"down_context":[],"flag":"BLOCK","start":5888,"end":5891,"inode":{"change":3,"pos":17699}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":20161},"to":{"change":2,"start":245,"end":248},"introduced_by":2}],"inode":{"change":3,"pos":17699}},"ins_contents":[{"Add":{"text":"}\\","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5890"}}],"del_contents":[{"Del":{"text":"}\\","pos":"ADGKEIDIFEFIDGO6E5NMELKLSE5K6V74X73O6BX7C3LDBY5NQQ2AC:247"}}]}},{"Replacement":{"inode":{"change":3,"pos":20305},"path":"zhur_core/Cargo.toml","line":11,"ins":{"up_context":[{"change":3,"pos":20595}],"down_context":[],"flag":"BLOCK","start":5892,"end":5931,"inode":{"change":3,"pos":20305}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":20595},"to":{"change":3,"start":20595,"end":20634},"introduced_by":3}],"inode":{"change":3,"pos":20305}},"ins_contents":[{"Add":{"text":"zhur_invk = { path = \"../zhur_invk\" }\\","pos":"7DWHC7LK3XMI7JMAIM35ZEDZY5VLLPPASEGSGGEX36LN7RHBAUVAC:5930"}}],"del_contents":[{"Del":{"text":"zhur_invk = { path = \"../zhur_invk\" }\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20633"}}]}},{"FileMove":{"meta":{"basename":"lib.rs","metadata":511},"path":"zhur_common/src/lib.rs","to_path":"lib.rs","old":[{"basename":"lib.rs","metadata":511}],"up":[{"change":3,"pos":21}],"down":[{"change":3,"pos":31}],"show_perms":false}},{"FileMove":{"meta":{"basename":"README.md","metadata":511},"path":"zhur_common/README.md","to_path":"README.md","old":[{"basename":"README.md","metadata":511}],"up":[{"change":3,"pos":14}],"down":[{"change":3,"pos":129}],"show_perms":false}},{"FileMove":{"meta":{"basename":"Cargo.toml","metadata":511},"path":"zhur_common/Cargo.toml","to_path":"Cargo.toml","old":[{"basename":"Cargo.toml","metadata":511}],"up":[{"change":3,"pos":14}],"down":[{"change":3,"pos":220}],"show_perms":false}},{"FileMove":{"meta":{"basename":"Cargo.toml","metadata":511},"path":"Cargo.toml","to_path":"Cargo.toml","old":[{"basename":"Cargo.toml","metadata":511}],"up":[{"change":1,"pos":0}],"down":[{"change":3,"pos":689}],"show_perms":false}},{"FileMove":{"meta":{"basename":"Cargo.lock","metadata":511},"path":"Cargo.lock","to_path":"Cargo.lock","old":[{"basename":"Cargo.lock","metadata":511}],"up":[{"change":1,"pos":0}],"down":[{"change":3,"pos":741}],"show_perms":false}}],"owner":"oreganoli","repo":"zhur","login":null}

…

Dependencies

Change contents

Review