MCPcopy Create free account
hub / github.com/Botloader/botloader / send_create_scripts_vm

Method send_create_scripts_vm

components/scheduler/src/vm_session.rs:119–155  ·  view source on GitHub ↗
(
        &mut self,
        session_id: u64,
        scripts: Vec<Script>,
        premium_tier: Option<PremiumSlotTier>,
    )

Source from the content-addressed store, hash-verified

117 }
118
119 fn send_create_scripts_vm(
120 &mut self,
121 session_id: u64,
122 scripts: Vec<Script>,
123 premium_tier: Option<PremiumSlotTier>,
124 ) -> Result<(), ()> {
125 let evt_id = self.gen_dispatch_id();
126 self.vm_session_id = session_id;
127 self.vm_cold = true;
128
129 self.worker
130 .tx
131 .send(SchedulerMessage::CreateScriptsVm(CreateScriptsVmReq {
132 seq: evt_id,
133 session_id,
134 guild_id: self.guild_id,
135 premium_tier,
136 scripts,
137 }))
138 .map_err(|_| ())?;
139
140 self.pending_acks.insert(
141 evt_id,
142 PendingAck {
143 dispatched_session_id: session_id,
144 kind: PendingAckType::Restart,
145 dispatched: None,
146 },
147 );
148
149 self.worker.session_state = Some(SessionState {
150 guild_id: self.guild_id,
151 vm_session_id: session_id,
152 });
153
154 Ok(())
155 }
156
157 /// Sends an event to the vm, recording a pending ack for it.
158 ///

Callers 2

createMethod · 0.80
restart_vmMethod · 0.80

Calls 2

gen_dispatch_idMethod · 0.80
sendMethod · 0.45

Tested by

no test coverage detected