Restoring authorship annotation for Ivan Blinkov <ivan@blinkov.ru>. Commit 1 of 2.

1 files changed, 206 insertions, 206 deletions

diff --git a/contrib/libs/hyperscan/src/rose/match.c b/contrib/libs/hyperscan/src/rose/match.c
index 84d3b1fdc2..7fdacd22a3 100644
--- a/contrib/libs/hyperscan/src/rose/match.c
+++ b/contrib/libs/hyperscan/src/rose/match.c
@@ -28,7 +28,7 @@
 
 #include "catchup.h"
 #include "match.h"
-#include "program_runtime.h"
+#include "program_runtime.h" 
 #include "rose.h"
 #include "util/bitutils.h"
 #include "util/fatbit.h"
@@ -66,32 +66,32 @@ void printMatch(const struct core_info *ci, u64a start, u64a end) {
 }
 #endif
 
-hwlmcb_rv_t roseDelayRebuildCallback(size_t end, u32 id,
-                                     struct hs_scratch *scratch) {
+hwlmcb_rv_t roseDelayRebuildCallback(size_t end, u32 id, 
+                                     struct hs_scratch *scratch) { 
     struct RoseContext *tctx = &scratch->tctxt;
     struct core_info *ci = &scratch->core_info;
-    const struct RoseEngine *t = ci->rose;
+    const struct RoseEngine *t = ci->rose; 
     size_t rb_len = MIN(ci->hlen, t->delayRebuildLength);
 
     u64a real_end = ci->buf_offset - rb_len + end + 1; // index after last byte
 
 #ifdef DEBUG
-    DEBUG_PRINTF("REBUILD MATCH id=%u end offset@%llu]: ", id, real_end);
-    u64a start = real_end < 8 ? 1 : real_end - 7;
-    printMatch(ci, start, real_end);
+    DEBUG_PRINTF("REBUILD MATCH id=%u end offset@%llu]: ", id, real_end); 
+    u64a start = real_end < 8 ? 1 : real_end - 7; 
+    printMatch(ci, start, real_end); 
     printf("\n");
 #endif
 
-    DEBUG_PRINTF("STATE groups=0x%016llx\n", tctx->groups);
+    DEBUG_PRINTF("STATE groups=0x%016llx\n", tctx->groups); 
 
-    assert(id && id < t->size); // id is a program offset
-    const u64a som = 0;
-    const u8 flags = 0;
-    UNUSED hwlmcb_rv_t rv =
-        roseRunProgram(t, scratch, id, som, real_end, flags);
-    assert(rv != HWLM_TERMINATE_MATCHING);
+    assert(id && id < t->size); // id is a program offset 
+    const u64a som = 0; 
+    const u8 flags = 0; 
+    UNUSED hwlmcb_rv_t rv = 
+        roseRunProgram(t, scratch, id, som, real_end, flags); 
+    assert(rv != HWLM_TERMINATE_MATCHING); 
 
-    /* we are just repopulating the delay queue, groups should be
+    /* we are just repopulating the delay queue, groups should be 
      * already set from the original scan. */
 
     return tctx->groups;
@@ -100,23 +100,23 @@ hwlmcb_rv_t roseDelayRebuildCallback(size_t end, u32 id,
 static really_inline
 hwlmcb_rv_t ensureMpvQueueFlushed(const struct RoseEngine *t,
                                   struct hs_scratch *scratch, u32 qi, s64a loc,
-                                  char in_chained) {
-    return ensureQueueFlushed_i(t, scratch, qi, loc, 1, in_chained);
+                                  char in_chained) { 
+    return ensureQueueFlushed_i(t, scratch, qi, loc, 1, in_chained); 
 }
 
-hwlmcb_rv_t roseHandleChainMatch(const struct RoseEngine *t,
-                                 struct hs_scratch *scratch, u32 event,
-                                 u64a top_squash_distance, u64a end,
-                                 char in_catchup) {
-    assert(event == MQE_TOP || event >= MQE_TOP_FIRST);
+hwlmcb_rv_t roseHandleChainMatch(const struct RoseEngine *t, 
+                                 struct hs_scratch *scratch, u32 event, 
+                                 u64a top_squash_distance, u64a end, 
+                                 char in_catchup) { 
+    assert(event == MQE_TOP || event >= MQE_TOP_FIRST); 
     struct core_info *ci = &scratch->core_info;
 
-    u8 *aa = getActiveLeafArray(t, scratch->core_info.state);
+    u8 *aa = getActiveLeafArray(t, scratch->core_info.state); 
     u32 aaCount = t->activeArrayCount;
     struct fatbit *activeQueues = scratch->aqa;
     u32 qCount = t->queueCount;
 
-    const u32 qi = 0; /* MPV is always queue 0 if it exists */
+    const u32 qi = 0; /* MPV is always queue 0 if it exists */ 
     struct mq *q = &scratch->queues[qi];
     const struct NfaInfo *info = getNfaInfoByQueue(t, qi);
 
@@ -124,7 +124,7 @@ hwlmcb_rv_t roseHandleChainMatch(const struct RoseEngine *t,
     assert(loc <= (s64a)ci->len && loc >= -(s64a)ci->hlen);
 
     if (!mmbit_set(aa, aaCount, qi)) {
-        initQueue(q, qi, t, scratch);
+        initQueue(q, qi, t, scratch); 
         nfaQueueInitState(q->nfa, q);
         pushQueueAt(q, 0, MQE_START, loc);
         fatbit_set(activeQueues, qCount, qi);
@@ -133,25 +133,25 @@ hwlmcb_rv_t roseHandleChainMatch(const struct RoseEngine *t,
         /* nfa only needs one top; we can go home now */
         return HWLM_CONTINUE_MATCHING;
     } else if (!fatbit_set(activeQueues, qCount, qi)) {
-        initQueue(q, qi, t, scratch);
+        initQueue(q, qi, t, scratch); 
         loadStreamState(q->nfa, q, 0);
         pushQueueAt(q, 0, MQE_START, 0);
     } else if (isQueueFull(q)) {
         DEBUG_PRINTF("queue %u full -> catching up nfas\n", qi);
         /* we know it is a chained nfa and the suffixes/outfixes must already
          * be known to be consistent */
-        if (ensureMpvQueueFlushed(t, scratch, qi, loc, in_catchup)
+        if (ensureMpvQueueFlushed(t, scratch, qi, loc, in_catchup) 
             == HWLM_TERMINATE_MATCHING) {
-            DEBUG_PRINTF("terminating...\n");
+            DEBUG_PRINTF("terminating...\n"); 
             return HWLM_TERMINATE_MATCHING;
         }
     }
 
-    if (top_squash_distance) {
-        assert(q->cur < q->end);
+    if (top_squash_distance) { 
+        assert(q->cur < q->end); 
         struct mq_item *last = &q->items[q->end - 1];
         if (last->type == event
-            && last->location >= loc - (s64a)top_squash_distance) {
+            && last->location >= loc - (s64a)top_squash_distance) { 
             last->location = loc;
             goto event_enqueued;
         }
@@ -166,7 +166,7 @@ event_enqueued:
         pushQueueNoMerge(q, MQE_END, loc);
         char alive = nfaQueueExec(q->nfa, q, loc);
         if (alive) {
-            scratch->tctxt.mpv_inactive = 0;
+            scratch->tctxt.mpv_inactive = 0; 
             q->cur = q->end = 0;
             pushQueueAt(q, 0, MQE_START, loc);
         } else {
@@ -176,24 +176,24 @@ event_enqueued:
     }
 
     DEBUG_PRINTF("added mpv event at %lld\n", loc);
-    scratch->tctxt.next_mpv_offset = 0; /* the top event may result in matches
-                                         * earlier than expected */
+    scratch->tctxt.next_mpv_offset = 0; /* the top event may result in matches 
+                                         * earlier than expected */ 
     return HWLM_CONTINUE_MATCHING;
 }
 
-int roseAnchoredCallback(u64a start, u64a end, u32 id, void *ctx) {
-    struct hs_scratch *scratch = ctx;
-    assert(scratch && scratch->magic == SCRATCH_MAGIC);
-    struct RoseContext *tctxt = &scratch->tctxt;
+int roseAnchoredCallback(u64a start, u64a end, u32 id, void *ctx) { 
+    struct hs_scratch *scratch = ctx; 
+    assert(scratch && scratch->magic == SCRATCH_MAGIC); 
+    struct RoseContext *tctxt = &scratch->tctxt; 
     struct core_info *ci = &scratch->core_info;
-    const struct RoseEngine *t = ci->rose;
+    const struct RoseEngine *t = ci->rose; 
 
     u64a real_end = ci->buf_offset + end; // index after last byte
 
     DEBUG_PRINTF("MATCH id=%u offsets=[???,%llu]\n", id, real_end);
-    DEBUG_PRINTF("STATE groups=0x%016llx\n", tctxt->groups);
+    DEBUG_PRINTF("STATE groups=0x%016llx\n", tctxt->groups); 
 
-    if (can_stop_matching(scratch)) {
+    if (can_stop_matching(scratch)) { 
         DEBUG_PRINTF("received a match when we're already dead!\n");
         return MO_HALT_MATCHING;
     }
@@ -206,38 +206,38 @@ int roseAnchoredCallback(u64a start, u64a end, u32 id, void *ctx) {
      * boundary */
 
     if (real_end <= t->floatingMinLiteralMatchOffset) {
-        roseFlushLastByteHistory(t, scratch, real_end);
+        roseFlushLastByteHistory(t, scratch, real_end); 
         tctxt->lastEndOffset = real_end;
     }
 
-    // Note that the "id" we have been handed is the program offset.
-    const u8 flags = ROSE_PROG_FLAG_IN_ANCHORED;
-    if (roseRunProgram(t, scratch, id, start, real_end, flags)
-                       == HWLM_TERMINATE_MATCHING) {
-        assert(can_stop_matching(scratch));
+    // Note that the "id" we have been handed is the program offset. 
+    const u8 flags = ROSE_PROG_FLAG_IN_ANCHORED; 
+    if (roseRunProgram(t, scratch, id, start, real_end, flags) 
+                       == HWLM_TERMINATE_MATCHING) { 
+        assert(can_stop_matching(scratch)); 
         DEBUG_PRINTF("caller requested termination\n");
         return MO_HALT_MATCHING;
     }
 
-    DEBUG_PRINTF("DONE groups=0x%016llx\n", tctxt->groups);
+    DEBUG_PRINTF("DONE groups=0x%016llx\n", tctxt->groups); 
 
     return MO_CONTINUE_MATCHING;
 }
 
-/**
- * \brief Run the program for the given literal ID, with the interpreter
- * inlined into this call.
- *
- * Assumes not in_anchored.
- */
+/** 
+ * \brief Run the program for the given literal ID, with the interpreter 
+ * inlined into this call. 
+ * 
+ * Assumes not in_anchored. 
+ */ 
 static really_inline
-hwlmcb_rv_t roseProcessMatchInline(const struct RoseEngine *t,
-                                   struct hs_scratch *scratch, u64a end,
-                                   u32 id) {
+hwlmcb_rv_t roseProcessMatchInline(const struct RoseEngine *t, 
+                                   struct hs_scratch *scratch, u64a end, 
+                                   u32 id) { 
     DEBUG_PRINTF("id=%u\n", id);
-    assert(id && id < t->size); // id is an offset into bytecode
-    const u64a som = 0;
-    const u8 flags = 0;
+    assert(id && id < t->size); // id is an offset into bytecode 
+    const u64a som = 0; 
+    const u8 flags = 0; 
     if (t->pureLiteral) {
         return roseRunProgram_l(t, scratch, id, som, end, flags);
     } else {
@@ -246,38 +246,38 @@ hwlmcb_rv_t roseProcessMatchInline(const struct RoseEngine *t,
 }
 
 static rose_inline
-hwlmcb_rv_t playDelaySlot(const struct RoseEngine *t,
-                          struct hs_scratch *scratch,
-                          struct fatbit **delaySlots, u32 vicIndex,
-                          u64a offset) {
+hwlmcb_rv_t playDelaySlot(const struct RoseEngine *t, 
+                          struct hs_scratch *scratch, 
+                          struct fatbit **delaySlots, u32 vicIndex, 
+                          u64a offset) { 
     /* assert(!tctxt->in_anchored); */
     assert(vicIndex < DELAY_SLOT_COUNT);
-    const struct fatbit *vicSlot = delaySlots[vicIndex];
-    u32 delay_count = t->delay_count;
+    const struct fatbit *vicSlot = delaySlots[vicIndex]; 
+    u32 delay_count = t->delay_count; 
 
-    if (offset < t->floatingMinLiteralMatchOffset) {
+    if (offset < t->floatingMinLiteralMatchOffset) { 
         DEBUG_PRINTF("too soon\n");
         return HWLM_CONTINUE_MATCHING;
     }
 
-    struct RoseContext *tctxt = &scratch->tctxt;
-    roseFlushLastByteHistory(t, scratch, offset);
+    struct RoseContext *tctxt = &scratch->tctxt; 
+    roseFlushLastByteHistory(t, scratch, offset); 
     tctxt->lastEndOffset = offset;
 
-    const u32 *programs = getByOffset(t, t->delayProgramOffset);
+    const u32 *programs = getByOffset(t, t->delayProgramOffset); 
 
-    for (u32 it = fatbit_iterate(vicSlot, delay_count, MMB_INVALID);
-         it != MMB_INVALID; it = fatbit_iterate(vicSlot, delay_count, it)) {
+    for (u32 it = fatbit_iterate(vicSlot, delay_count, MMB_INVALID); 
+         it != MMB_INVALID; it = fatbit_iterate(vicSlot, delay_count, it)) { 
         UNUSED rose_group old_groups = tctxt->groups;
 
-        DEBUG_PRINTF("DELAYED MATCH id=%u offset=%llu\n", it, offset);
-        const u64a som = 0;
-        const u8 flags = 0;
-        hwlmcb_rv_t rv = roseRunProgram(t, scratch, programs[it], som, offset,
-                                        flags);
-        DEBUG_PRINTF("DONE groups=0x%016llx\n", tctxt->groups);
+        DEBUG_PRINTF("DELAYED MATCH id=%u offset=%llu\n", it, offset); 
+        const u64a som = 0; 
+        const u8 flags = 0; 
+        hwlmcb_rv_t rv = roseRunProgram(t, scratch, programs[it], som, offset, 
+                                        flags); 
+        DEBUG_PRINTF("DONE groups=0x%016llx\n", tctxt->groups); 
 
-        /* delayed literals can't safely set groups.
+        /* delayed literals can't safely set groups. 
          * However we may be setting groups that successors already have
          * worked out that we don't need to match the group */
         DEBUG_PRINTF("groups in %016llx out %016llx\n", old_groups,
@@ -292,30 +292,30 @@ hwlmcb_rv_t playDelaySlot(const struct RoseEngine *t,
 }
 
 static really_inline
-hwlmcb_rv_t flushAnchoredLiteralAtLoc(const struct RoseEngine *t,
-                                      struct hs_scratch *scratch,
-                                      u32 curr_loc) {
-    struct RoseContext *tctxt = &scratch->tctxt;
-    struct fatbit *curr_row = getAnchoredLiteralLog(scratch)[curr_loc - 1];
-    u32 region_width = t->anchored_count;
-
-    const u32 *programs = getByOffset(t, t->anchoredProgramOffset);
-
+hwlmcb_rv_t flushAnchoredLiteralAtLoc(const struct RoseEngine *t, 
+                                      struct hs_scratch *scratch, 
+                                      u32 curr_loc) { 
+    struct RoseContext *tctxt = &scratch->tctxt; 
+    struct fatbit *curr_row = getAnchoredLiteralLog(scratch)[curr_loc - 1]; 
+    u32 region_width = t->anchored_count; 
+
+    const u32 *programs = getByOffset(t, t->anchoredProgramOffset); 
+ 
     DEBUG_PRINTF("report matches at curr loc\n");
-    for (u32 it = fatbit_iterate(curr_row, region_width, MMB_INVALID);
-         it != MMB_INVALID; it = fatbit_iterate(curr_row, region_width, it)) {
+    for (u32 it = fatbit_iterate(curr_row, region_width, MMB_INVALID); 
+         it != MMB_INVALID; it = fatbit_iterate(curr_row, region_width, it)) { 
         DEBUG_PRINTF("it = %u/%u\n", it, region_width);
 
         rose_group old_groups = tctxt->groups;
-        DEBUG_PRINTF("ANCH REPLAY MATCH id=%u offset=%u\n", it, curr_loc);
-        const u64a som = 0;
-        const u8 flags = 0;
-        hwlmcb_rv_t rv = roseRunProgram(t, scratch, programs[it], som, curr_loc,
-                                        flags);
-        DEBUG_PRINTF("DONE groups=0x%016llx\n", tctxt->groups);
-
-        /* anchored literals can't safely set groups.
-         * However we may be setting groups that successors already
+        DEBUG_PRINTF("ANCH REPLAY MATCH id=%u offset=%u\n", it, curr_loc); 
+        const u64a som = 0; 
+        const u8 flags = 0; 
+        hwlmcb_rv_t rv = roseRunProgram(t, scratch, programs[it], som, curr_loc, 
+                                        flags); 
+        DEBUG_PRINTF("DONE groups=0x%016llx\n", tctxt->groups); 
+
+        /* anchored literals can't safely set groups. 
+         * However we may be setting groups that successors already 
          * have worked out that we don't need to match the group */
         DEBUG_PRINTF("groups in %016llx out %016llx\n", old_groups,
                      tctxt->groups);
@@ -333,22 +333,22 @@ hwlmcb_rv_t flushAnchoredLiteralAtLoc(const struct RoseEngine *t,
 }
 
 static really_inline
-u32 anchored_it_begin(struct hs_scratch *scratch) {
-    struct RoseContext *tctxt = &scratch->tctxt;
+u32 anchored_it_begin(struct hs_scratch *scratch) { 
+    struct RoseContext *tctxt = &scratch->tctxt; 
     if (tctxt->lastEndOffset >= scratch->anchored_literal_region_len) {
         return MMB_INVALID;
     }
     u32 begin = tctxt->lastEndOffset;
     begin--;
 
-    return bf64_iterate(scratch->al_log_sum, begin);
+    return bf64_iterate(scratch->al_log_sum, begin); 
 }
 
 static really_inline
-hwlmcb_rv_t flushAnchoredLiterals(const struct RoseEngine *t,
-                                  struct hs_scratch *scratch,
+hwlmcb_rv_t flushAnchoredLiterals(const struct RoseEngine *t, 
+                                  struct hs_scratch *scratch, 
                                   u32 *anchored_it_param, u64a to_off) {
-    struct RoseContext *tctxt = &scratch->tctxt;
+    struct RoseContext *tctxt = &scratch->tctxt; 
     u32 anchored_it = *anchored_it_param;
     /* catch up any remaining anchored matches */
     for (; anchored_it != MMB_INVALID && anchored_it < to_off;
@@ -356,10 +356,10 @@ hwlmcb_rv_t flushAnchoredLiterals(const struct RoseEngine *t,
         assert(anchored_it < scratch->anchored_literal_region_len);
         DEBUG_PRINTF("loc_it = %u\n", anchored_it);
         u32 curr_off = anchored_it + 1;
-        roseFlushLastByteHistory(t, scratch, curr_off);
+        roseFlushLastByteHistory(t, scratch, curr_off); 
         tctxt->lastEndOffset = curr_off;
 
-        if (flushAnchoredLiteralAtLoc(t, scratch, curr_off)
+        if (flushAnchoredLiteralAtLoc(t, scratch, curr_off) 
             == HWLM_TERMINATE_MATCHING) {
             return HWLM_TERMINATE_MATCHING;
         }
@@ -370,21 +370,21 @@ hwlmcb_rv_t flushAnchoredLiterals(const struct RoseEngine *t,
 }
 
 static really_inline
-hwlmcb_rv_t playVictims(const struct RoseEngine *t, struct hs_scratch *scratch,
-                        u32 *anchored_it, u64a lastEnd, u64a victimDelaySlots,
-                        struct fatbit **delaySlots) {
+hwlmcb_rv_t playVictims(const struct RoseEngine *t, struct hs_scratch *scratch, 
+                        u32 *anchored_it, u64a lastEnd, u64a victimDelaySlots, 
+                        struct fatbit **delaySlots) { 
     while (victimDelaySlots) {
         u32 vic = findAndClearLSB_64(&victimDelaySlots);
         DEBUG_PRINTF("vic = %u\n", vic);
         u64a vicOffset = vic + (lastEnd & ~(u64a)DELAY_MASK);
 
-        if (flushAnchoredLiterals(t, scratch, anchored_it, vicOffset)
+        if (flushAnchoredLiterals(t, scratch, anchored_it, vicOffset) 
             == HWLM_TERMINATE_MATCHING) {
             return HWLM_TERMINATE_MATCHING;
         }
 
-        if (playDelaySlot(t, scratch, delaySlots, vic % DELAY_SLOT_COUNT,
-                          vicOffset) == HWLM_TERMINATE_MATCHING) {
+        if (playDelaySlot(t, scratch, delaySlots, vic % DELAY_SLOT_COUNT, 
+                          vicOffset) == HWLM_TERMINATE_MATCHING) { 
             return HWLM_TERMINATE_MATCHING;
         }
     }
@@ -393,16 +393,16 @@ hwlmcb_rv_t playVictims(const struct RoseEngine *t, struct hs_scratch *scratch,
 }
 
 /* call flushQueuedLiterals instead */
-hwlmcb_rv_t flushQueuedLiterals_i(const struct RoseEngine *t,
-                                  struct hs_scratch *scratch, u64a currEnd) {
-    struct RoseContext *tctxt = &scratch->tctxt;
+hwlmcb_rv_t flushQueuedLiterals_i(const struct RoseEngine *t, 
+                                  struct hs_scratch *scratch, u64a currEnd) { 
+    struct RoseContext *tctxt = &scratch->tctxt; 
     u64a lastEnd = tctxt->delayLastEndOffset;
     DEBUG_PRINTF("flushing backed up matches @%llu up from %llu\n", currEnd,
                  lastEnd);
 
     assert(currEnd != lastEnd); /* checked in main entry point */
 
-    u32 anchored_it = anchored_it_begin(scratch);
+    u32 anchored_it = anchored_it_begin(scratch); 
 
     if (!tctxt->filledDelayedSlots) {
         DEBUG_PRINTF("no delayed, no flush\n");
@@ -410,7 +410,7 @@ hwlmcb_rv_t flushQueuedLiterals_i(const struct RoseEngine *t,
     }
 
     {
-        struct fatbit **delaySlots = getDelaySlots(scratch);
+        struct fatbit **delaySlots = getDelaySlots(scratch); 
 
         u32 lastIndex = lastEnd & DELAY_MASK;
         u32 currIndex = currEnd & DELAY_MASK;
@@ -463,45 +463,45 @@ hwlmcb_rv_t flushQueuedLiterals_i(const struct RoseEngine *t,
                          second_half, victimDelaySlots, lastIndex);
         }
 
-        if (playVictims(t, scratch, &anchored_it, lastEnd, victimDelaySlots,
-                        delaySlots) == HWLM_TERMINATE_MATCHING) {
+        if (playVictims(t, scratch, &anchored_it, lastEnd, victimDelaySlots, 
+                        delaySlots) == HWLM_TERMINATE_MATCHING) { 
             return HWLM_TERMINATE_MATCHING;
         }
     }
 
 anchored_leftovers:;
-    hwlmcb_rv_t rv = flushAnchoredLiterals(t, scratch, &anchored_it, currEnd);
+    hwlmcb_rv_t rv = flushAnchoredLiterals(t, scratch, &anchored_it, currEnd); 
     tctxt->delayLastEndOffset = currEnd;
     return rv;
 }
 
-static really_inline
-hwlmcb_rv_t roseCallback_i(size_t end, u32 id, struct hs_scratch *scratch) {
-    struct RoseContext *tctx = &scratch->tctxt;
-    const struct RoseEngine *t = scratch->core_info.rose;
-
+static really_inline 
+hwlmcb_rv_t roseCallback_i(size_t end, u32 id, struct hs_scratch *scratch) { 
+    struct RoseContext *tctx = &scratch->tctxt; 
+    const struct RoseEngine *t = scratch->core_info.rose; 
+ 
     u64a real_end = end + tctx->lit_offset_adjust;
 
 #if defined(DEBUG)
-    DEBUG_PRINTF("MATCH id=%u end offset@%llu: ", id, real_end);
-    u64a start = real_end < 8 ? 1 : real_end - 7;
-    printMatch(&scratch->core_info, start, real_end);
+    DEBUG_PRINTF("MATCH id=%u end offset@%llu: ", id, real_end); 
+    u64a start = real_end < 8 ? 1 : real_end - 7; 
+    printMatch(&scratch->core_info, start, real_end); 
     printf("\n");
 #endif
     DEBUG_PRINTF("last end %llu\n", tctx->lastEndOffset);
 
-    DEBUG_PRINTF("STATE groups=0x%016llx\n", tctx->groups);
+    DEBUG_PRINTF("STATE groups=0x%016llx\n", tctx->groups); 
 
-    if (can_stop_matching(scratch)) {
+    if (can_stop_matching(scratch)) { 
         DEBUG_PRINTF("received a match when we're already dead!\n");
         return HWLM_TERMINATE_MATCHING;
     }
 
-    hwlmcb_rv_t rv = flushQueuedLiterals(t, scratch, real_end);
+    hwlmcb_rv_t rv = flushQueuedLiterals(t, scratch, real_end); 
     /* flushDelayed may have advanced tctx->lastEndOffset */
 
-    if (real_end >= t->floatingMinLiteralMatchOffset) {
-        roseFlushLastByteHistory(t, scratch, real_end);
+    if (real_end >= t->floatingMinLiteralMatchOffset) { 
+        roseFlushLastByteHistory(t, scratch, real_end); 
         tctx->lastEndOffset = real_end;
     }
 
@@ -509,72 +509,72 @@ hwlmcb_rv_t roseCallback_i(size_t end, u32 id, struct hs_scratch *scratch) {
         return HWLM_TERMINATE_MATCHING;
     }
 
-    rv = roseProcessMatchInline(t, scratch, real_end, id);
+    rv = roseProcessMatchInline(t, scratch, real_end, id); 
 
-    DEBUG_PRINTF("DONE groups=0x%016llx\n", tctx->groups);
+    DEBUG_PRINTF("DONE groups=0x%016llx\n", tctx->groups); 
 
     if (rv != HWLM_TERMINATE_MATCHING) {
         return tctx->groups;
     }
 
-    assert(can_stop_matching(scratch));
+    assert(can_stop_matching(scratch)); 
     DEBUG_PRINTF("user requested halt\n");
     return HWLM_TERMINATE_MATCHING;
 }
 
-hwlmcb_rv_t roseCallback(size_t end, u32 id, struct hs_scratch *scratch) {
-    return roseCallback_i(end, id, scratch);
-}
-
-hwlmcb_rv_t roseFloatingCallback(size_t end, u32 id,
-                                 struct hs_scratch *scratch) {
-    const struct RoseEngine *t = scratch->core_info.rose;
-
-    return roseCallback_i(end, id, scratch) & t->floating_group_mask;
+hwlmcb_rv_t roseCallback(size_t end, u32 id, struct hs_scratch *scratch) { 
+    return roseCallback_i(end, id, scratch); 
+} 
+
+hwlmcb_rv_t roseFloatingCallback(size_t end, u32 id, 
+                                 struct hs_scratch *scratch) { 
+    const struct RoseEngine *t = scratch->core_info.rose; 
+
+    return roseCallback_i(end, id, scratch) & t->floating_group_mask; 
+} 
+
+/** 
+ * \brief Execute a boundary report program. 
+ * 
+ * Returns MO_HALT_MATCHING if the stream is exhausted or the user has 
+ * instructed us to halt, or MO_CONTINUE_MATCHING otherwise. 
+ */ 
+int roseRunBoundaryProgram(const struct RoseEngine *rose, u32 program, 
+                           u64a stream_offset, struct hs_scratch *scratch) { 
+    DEBUG_PRINTF("running boundary program at offset %u\n", program); 
+
+    if (can_stop_matching(scratch)) { 
+        DEBUG_PRINTF("can stop matching\n"); 
+        return MO_HALT_MATCHING; 
+    } 
+
+    if (rose->hasSom && scratch->deduper.current_report_offset == ~0ULL) { 
+        /* we cannot delay the initialization of the som deduper logs any longer 
+         * as we are reporting matches. This is done explicitly as we are 
+         * shortcutting the som handling in the vacuous repeats as we know they 
+         * all come from non-som patterns. */ 
+        fatbit_clear(scratch->deduper.som_log[0]); 
+        fatbit_clear(scratch->deduper.som_log[1]); 
+        scratch->deduper.som_log_dirty = 0; 
+    } 
+
+    // Keep assertions in program report path happy. At offset zero, there can 
+    // have been no earlier reports. At EOD, all earlier reports should have 
+    // been handled and we will have been caught up to the stream offset by the 
+    // time we are running boundary report programs. 
+    scratch->tctxt.minMatchOffset = stream_offset; 
+
+    const u64a som = 0; 
+    const u8 flags = 0; 
+    hwlmcb_rv_t rv = roseRunProgram(rose, scratch, program, som, stream_offset, 
+                                    flags); 
+    if (rv == HWLM_TERMINATE_MATCHING) { 
+        return MO_HALT_MATCHING; 
+    } 
+ 
+    return MO_CONTINUE_MATCHING; 
 }
-
-/**
- * \brief Execute a boundary report program.
- *
- * Returns MO_HALT_MATCHING if the stream is exhausted or the user has
- * instructed us to halt, or MO_CONTINUE_MATCHING otherwise.
- */
-int roseRunBoundaryProgram(const struct RoseEngine *rose, u32 program,
-                           u64a stream_offset, struct hs_scratch *scratch) {
-    DEBUG_PRINTF("running boundary program at offset %u\n", program);
-
-    if (can_stop_matching(scratch)) {
-        DEBUG_PRINTF("can stop matching\n");
-        return MO_HALT_MATCHING;
-    }
-
-    if (rose->hasSom && scratch->deduper.current_report_offset == ~0ULL) {
-        /* we cannot delay the initialization of the som deduper logs any longer
-         * as we are reporting matches. This is done explicitly as we are
-         * shortcutting the som handling in the vacuous repeats as we know they
-         * all come from non-som patterns. */
-        fatbit_clear(scratch->deduper.som_log[0]);
-        fatbit_clear(scratch->deduper.som_log[1]);
-        scratch->deduper.som_log_dirty = 0;
-    }
-
-    // Keep assertions in program report path happy. At offset zero, there can
-    // have been no earlier reports. At EOD, all earlier reports should have
-    // been handled and we will have been caught up to the stream offset by the
-    // time we are running boundary report programs.
-    scratch->tctxt.minMatchOffset = stream_offset;
-
-    const u64a som = 0;
-    const u8 flags = 0;
-    hwlmcb_rv_t rv = roseRunProgram(rose, scratch, program, som, stream_offset,
-                                    flags);
-    if (rv == HWLM_TERMINATE_MATCHING) {
-        return MO_HALT_MATCHING;
-    }
-
-    return MO_CONTINUE_MATCHING;
-}
-
+ 
 /**
  * \brief Execute a flush combination program.
  *
@@ -608,26 +608,26 @@ int roseRunLastFlushCombProgram(const struct RoseEngine *rose,
     return MO_CONTINUE_MATCHING;
 }
 
-int roseReportAdaptor(u64a start, u64a end, ReportID id, void *context) {
-    struct hs_scratch *scratch = context;
-    assert(scratch && scratch->magic == SCRATCH_MAGIC);
-
-    DEBUG_PRINTF("id=%u matched at [%llu,%llu]\n", id, start, end);
-
-    const struct RoseEngine *rose = scratch->core_info.rose;
-
-    // Our match ID is the program offset.
-    const u32 program = id;
-    const u8 flags = ROSE_PROG_FLAG_SKIP_MPV_CATCHUP;
+int roseReportAdaptor(u64a start, u64a end, ReportID id, void *context) { 
+    struct hs_scratch *scratch = context; 
+    assert(scratch && scratch->magic == SCRATCH_MAGIC); 
+ 
+    DEBUG_PRINTF("id=%u matched at [%llu,%llu]\n", id, start, end); 
+ 
+    const struct RoseEngine *rose = scratch->core_info.rose; 
+ 
+    // Our match ID is the program offset. 
+    const u32 program = id; 
+    const u8 flags = ROSE_PROG_FLAG_SKIP_MPV_CATCHUP; 
     hwlmcb_rv_t rv;
     if (rose->pureLiteral) {
         rv = roseRunProgram_l(rose, scratch, program, start, end, flags);
     } else {
         rv = roseRunProgram(rose, scratch, program, start, end, flags);
     }
-    if (rv == HWLM_TERMINATE_MATCHING) {
-        return MO_HALT_MATCHING;
-    }
-
-    return can_stop_matching(scratch) ? MO_HALT_MATCHING : MO_CONTINUE_MATCHING;
-}
+    if (rv == HWLM_TERMINATE_MATCHING) { 
+        return MO_HALT_MATCHING; 
+    } 
+ 
+    return can_stop_matching(scratch) ? MO_HALT_MATCHING : MO_CONTINUE_MATCHING; 
+}