cthrace/collabvm-1.2.ts
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

I hate race conditions

Browse Source
This commit is contained in:
MDMCK10
2023-04-05 20:34:15 +02:00
committed by GitHub
parent 90b91bc0e4
commit 983860ff02
1 changed files with 43 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

84
src/QMPClient.ts
View File

@@ -46,50 +46,52 @@ export default class QMPClient extends EventEmitter {
}
private async onData(data : Buffer) {
let msgraw = data.toString();
let msg;
let msgraw = data.toString().split("\n");
for(var message in msgraw) {
let msg;
try {
msg = JSON.parse(msgraw);
} catch {
this.emit("qmpreturn", '');
return;
}
if (msg.QMP !== undefined) {
if (this.sentConnected)
try {
msg = JSON.parse(msgraw[message]);
} catch {
this.emit("qmpreturn", "");
return;
await this.execute({ execute: "qmp_capabilities" });
this.emit('connected');
this.sentConnected = true;
}
if (msg.return !== undefined)
this.emit("qmpreturn", msg.return);
else if(msg.event !== undefined) {
switch(msg.event) {
case "STOP":
{
log("INFO", "The VM was shut down, restarting...");
this.reboot();
break;
}
case "RESET":
{
log("INFO", "QEMU reset event occured");
this.resume();
break;
};
default: {
this.emit("qmpreturn", '');
break;
}
}
}else
// for now just return an empty string.
// This is a giant hack but avoids a deadlock
this.emit("qmpreturn", '');
if (msg.QMP !== undefined) {
if (this.sentConnected)
return;
await this.execute({ execute: "qmp_capabilities" });
this.emit('connected');
this.sentConnected = true;
}
if (msg.return !== undefined)
this.emit("qmpreturn", msg.return);
else if(msg.event !== undefined) {
switch(msg.event) {
case "STOP":
{
log("INFO", "The VM was shut down, restarting...");
this.reboot();
break;
}
case "RESET":
{
log("INFO", "QEMU reset event occured");
this.resume();
break;
};
default: {
this.emit("qmpreturn", "");
break;
}
}
}else
// for now just return an empty string.
// This is a giant hack but avoids a deadlock
this.emit("qmpreturn", "");
}
}
private onClose() {