diff --git a/src/queue.lisp b/src/queue.lisp index b8a1723..c66ac99 100644 --- a/src/queue.lisp +++ b/src/queue.lisp @@ -8,13 +8,6 @@ ;;; reader fills in batches of data from the source of data, and the writer ;;; pushes the data down to PostgreSQL using the COPY protocol. ;;; -;;; The reader thread is always preparing the next batch to send. The reader -;;; thread only works with *reader-batch*. -;;; -;;; As soon as *reader-batch* is ready, it's made available to the writer -;;; thread as *writer-batch*, as soon as the writer is ready for processing -;;; another batch. -;;; (defstruct batch (data (make-array *copy-batch-rows* :element-type 'simple-string) :type (vector simple-string *)) @@ -32,7 +25,7 @@ (defun batch-row (row copy queue) "Add ROW to the reader batch. When the batch is full, provide it to the - writer as the *writer-batch*." + writer." (when (or (eq :data *log-min-messages*) (eq :data *client-min-messages*)) (log-message :data "< ~s" row))