|
|
|
@ -120,7 +120,7 @@ function bitmap_bbox(event) {
@@ -120,7 +120,7 @@ function bitmap_bbox(event) {
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
async function handle_event(event) { |
|
|
|
|
console.debug(`event type ${event.type} from user ${event.user_id}`); |
|
|
|
|
if (config.debug_print) console.debug(`event type ${event.type} from user ${event.user_id}`); |
|
|
|
|
|
|
|
|
|
// TODO(@speed): do not handle locally predicted events
|
|
|
|
|
|
|
|
|
@ -246,7 +246,7 @@ async function handle_event(event) {
@@ -246,7 +246,7 @@ async function handle_event(event) {
|
|
|
|
|
async function handle_message(d) { |
|
|
|
|
const message_type = des_u8(d); |
|
|
|
|
|
|
|
|
|
console.debug(message_type); |
|
|
|
|
if (config.debug_print) console.debug(message_type); |
|
|
|
|
|
|
|
|
|
switch (message_type) { |
|
|
|
|
case MESSAGE.JOIN: |
|
|
|
@ -263,14 +263,14 @@ async function handle_message(d) {
@@ -263,14 +263,14 @@ async function handle_message(d) {
|
|
|
|
|
|
|
|
|
|
if (message_type === MESSAGE.JOIN) { |
|
|
|
|
ls.setItem('sessionId', des_u32(d)); |
|
|
|
|
console.debug('join in'); |
|
|
|
|
if (config.debug_print) console.debug('join in'); |
|
|
|
|
} else { |
|
|
|
|
console.debug('init in'); |
|
|
|
|
if (config.debug_print) console.debug('init in'); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
const event_count = des_u32(d); |
|
|
|
|
|
|
|
|
|
console.debug(`${event_count} events in init`); |
|
|
|
|
if (config.debug_print) console.debug(`${event_count} events in init`); |
|
|
|
|
|
|
|
|
|
storage.ctx0.clearRect(0, 0, storage.ctx0.canvas.width, storage.ctx0.canvas.height); |
|
|
|
|
elements.images.innerHTML = ''; |
|
|
|
@ -303,7 +303,7 @@ async function handle_message(d) {
@@ -303,7 +303,7 @@ async function handle_message(d) {
|
|
|
|
|
case MESSAGE.ACK: { |
|
|
|
|
const lsn = des_u32(d); |
|
|
|
|
|
|
|
|
|
console.debug(`ack ${lsn} in`); |
|
|
|
|
if (config.debug_print) console.debug(`ack ${lsn} in`); |
|
|
|
|
|
|
|
|
|
if (lsn > storage.server_lsn) { |
|
|
|
|
// ACKs may arrive out of order
|
|
|
|
@ -320,7 +320,7 @@ async function handle_message(d) {
@@ -320,7 +320,7 @@ async function handle_message(d) {
|
|
|
|
|
const we_expect = sn - storage.sn; |
|
|
|
|
const first = count - we_expect; |
|
|
|
|
|
|
|
|
|
console.debug(`syn ${sn} in`); |
|
|
|
|
if (config.debug_print) console.debug(`syn ${sn} in`); |
|
|
|
|
|
|
|
|
|
for (let i = 0; i < count; ++i) { |
|
|
|
|
const event = des_event(d); |
|
|
|
|