diff --git a/src/server/mysql.c b/src/server/mysql.c
--- a/src/server/mysql.c
+++ b/src/server/mysql.c
@@ -382,3 +382,12 @@ int auth_slave(distrend_mysql_conn_t con
 
   return rtn;
 }
+
+/** Runs frame watchdog to reassign stale frames */
+void frame_watchdog(distrend_mysql_conn_t conn)
+{
+  char *query;
+  _distren_asprintf(&query, "CALL `distren`.`Watchdog_Delete`()");
+  mysqlQuery(conn, query, 0);
+  free(query);
+}