Add some comments.

3 files changed, 7 insertions, 1 deletions

diff --git a/src/lib/grok/context.h b/src/lib/grok/context.h
index 0749a9697..4c7e4304a 100644
--- a/src/lib/grok/context.h
+++ b/src/lib/grok/context.h
@@ -129,10 +129,12 @@ public:
 
 					int const minimum_size = 16384;
 
+					/* Write the compressed data out and tidy up */
 					bool needsRecompression = compressedFrameLength < minimum_size;
 					_messenger->process_compressed(str, processor, needsRecompression);
 
 					if (needsRecompression) {
+						/* The JPEG2000 frame data was too small, so handle it with the CPU encoder */
 						auto vf = _messenger->retrieve(clientFrameId);
 						if (!vf) {
 							return;
diff --git a/src/lib/grok/messenger.cc b/src/lib/grok/messenger.cc
index 834cc132e..e8dfcf3df 100644
--- a/src/lib/grok/messenger.cc
+++ b/src/lib/grok/messenger.cc
@@ -93,6 +93,8 @@ Messenger::processor_thread()
 		} else if (tag == GRK_MSGR_BATCH_PROCESSSED_COMPRESSED) {
 			reclaimCompressed(msg.nextUint());
 		}
+
+		/* Handle writing J2K data to disk */
 		_init.processor_(message);
 	}
 }
diff --git a/src/lib/grok/messenger.h b/src/lib/grok/messenger.h
index d3d3966ce..6b0571655 100644
--- a/src/lib/grok/messenger.h
+++ b/src/lib/grok/messenger.h
@@ -602,6 +602,7 @@ struct ScheduledMessenger : public Messenger
 		return true;
 	}
 
+	/** @param processor function taking compressed J2K data and sending it to the Writer */
 	void process_compressed(std::string const& message, std::function<void (F, uint8_t*, uint32_t)> processor, bool needsRecompression)
 	{
 		Msg msg(message);
@@ -614,7 +615,8 @@ struct ScheduledMessenger : public Messenger
 			if (!src_frame) {
 				return;
 			}
-			processor(*src_frame, getCompressedFrame(compressedFrameId),compressedFrameLength);
+			/* Write the compressed J2K data out */
+			processor(*src_frame, getCompressedFrame(compressedFrameId), compressedFrameLength);
 		}
 
 		++_frames_compressed;