Index: common.scm
==================================================================
--- common.scm
+++ common.scm
@@ -3404,11 +3404,17 @@
 	  (debug:print 0 *default-log-port* "ERROR: packets directory path " pktsdir " is not a directory."))
 	 ((not (file-read-access? pktsdir))
 	  (debug:print 0 *default-log-port* "ERROR: packets directory path " pktsdir " is not readable."))
 	 (else
 	  (debug:print-info 0 *default-log-port* "Loading packets found in " pktsdir)
-	  (let ((pkts (glob (conc pktsdir "/*.pkt"))))
+	  (let ((pkts (glob (conc pktsdir "/*.pkt")))
+                (sqdb (dbi:db-conn pdb))
+                )
+           ;; Put this in a transaction to avoid issues overloading the db
+           (sqlite3:with-transaction
+            sqdb
+            (lambda ()
 	    (for-each
 	     (lambda (pkt)
 	       (let* ((uuid    (cadr (string-match ".*/([0-9a-f]+).pkt" pkt)))
 		      (exists  (lookup-by-uuid pdb uuid #f)))
 		 (if (not exists)
@@ -3419,11 +3425,11 @@
 			    (ptype  (alist-ref 'T apkt)))
 		       (add-to-queue pdb pktdat uuid (or ptype 'cmd) #f 0)
 		       (debug:print 4 *default-log-port* "Added " uuid " of type " ptype " to queue"))
 		     (debug:print 4 *default-log-port* "pkt: " uuid " exists, skipping...")
 		     )))
-	     pkts)))))
+	     pkts)))))))
       pktsdirs))
    use-lt: use-lt))
 
 (define (common:get-pkt-alists pkts)
   (map (lambda (x)