wip

Author: sparrc

plugins/in_forward/fw_conn.c

@@ -45,8 +45,26 @@ int fw_conn_event(void *data)
 
     conn = connection->user_data;
 
+    /* Check if connection is still valid */
+    if (!conn) {
+        return -1;
+    }
+
     ctx = conn->ctx;
 
+    /*
+     * Acquire mutex to check if plugin is paused.
+     * If paused, the connection may have been deleted, so exit early.
+     */
+    pthread_mutex_lock(&ctx->conn_mutex);
+
+    if (ctx->is_paused) {
+        pthread_mutex_unlock(&ctx->conn_mutex);
+        return -1;
+    }
+
+    pthread_mutex_unlock(&ctx->conn_mutex);
+
     event = &connection->event;
 
     if (event->mask & MK_EVENT_READ) {