Fix lag with lws 3.2, based on ttyd upstream fix

src/protocol.c

@@ -23,8 +23,14 @@ char initial_cmds[] = {
     SET_PREFERENCES
 };
 
-int
-send_initial_message(struct lws *wsi, int index) {
+static void stagger_callback(lws_sorted_usec_list_t *sul) {
+    struct tty_client *client = lws_container_of(sul, struct tty_client, sul_stagger);
+
+    lws_callback_on_writable(client->wsi);
+    lws_sul_schedule(context, 0, sul, stagger_callback, 10);
+}
+
+int send_initial_message(struct lws *wsi, int index) {
     unsigned char message[LWS_PRE + 1 + 4096];
     unsigned char *p = &message[LWS_PRE];
     char buffer[128];
@@ -149,6 +155,8 @@ void tty_client_destroy(struct tty_client *client) {
     if (client->buffer != NULL)
         free(client->buffer);
 
+    lws_sul_schedule(context, 0, &client->sul_stagger, NULL, LWS_SET_TIMER_USEC_CANCEL);
+
     // remove from client list
     tty_client_remove(client);
 }
@@ -301,6 +309,8 @@ int callback_tty(struct lws *wsi, enum lws_callback_reasons reason, void *user,
             // check if there are more fragmented messages
             if (lws_remaining_packet_payload(wsi) > 0 || !lws_is_final_fragment(wsi)) {
                 return 0;
+            } else {
+                lws_sul_schedule(context, 0, &client->sul_stagger, stagger_callback, 10);
             }
 
             switch (command) {

src/server.c

@@ -931,7 +931,7 @@ int main(int argc, char **argv) {
     while(!force_exit) {
         lws_service(context, 0);
         process_watch();
-        usleep(5000);
+        usleep(1000);
     }
 
     printf("[+] exiting\n");

src/server.h

@@ -91,6 +91,8 @@ struct tty_client {
     ssize_t pty_len;
 
     LIST_ENTRY(tty_client) list;
+
+    lws_sorted_usec_list_t sul_stagger;
 };
 
 struct pss_http {