Commit 5d7de5f9 authored by 神楽坂玲奈's avatar 神楽坂玲奈 Committed by 铃兰

fix

parent 90f65d18
Pipeline #16083 passed with stages
in 20 seconds
...@@ -10,15 +10,16 @@ export class Server { ...@@ -10,15 +10,16 @@ export class Server {
ack = 0; ack = 0;
onMessage(socket: Socket, message: Change, self: Hello) { onMessage(socket: Socket, message: Change, self: Hello) {
if (message.seq && this.ack !== message.seq) {
console.log('seq mismatch rejected');
return;
}
if (message.seq === 0) { if (message.seq === 0) {
this.ack = 0;
RouteWriter.reset(); RouteWriter.reset();
} }
if (this.ack !== message.seq) {
console.log('seq mismatch rejected');
return;
}
for (const [to, via] of Object.entries(message.via)) { for (const [to, via] of Object.entries(message.via)) {
RouteWriter.setVia(parseInt(to), via); RouteWriter.setVia(parseInt(to), via);
} }
...@@ -26,7 +27,7 @@ export class Server { ...@@ -26,7 +27,7 @@ export class Server {
// RouteWriter.setVia(parseInt(plan), to); // RouteWriter.setVia(parseInt(plan), to);
// } // }
RouteWriter.commit(); RouteWriter.commit();
this.ack = message.seq + 1; this.ack++;
const response: Report = { const response: Report = {
id: self.id, id: self.id,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment