Skip to content

Commit f97383b

Browse files
committed
fix code lint check
1 parent eb5f8d6 commit f97383b

File tree

1 file changed

+9
-16
lines changed

1 file changed

+9
-16
lines changed

analytical_engine/apps/property/wcc_property.h

Lines changed: 9 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -140,21 +140,7 @@ class WCCProperty : public PropertyAppBase<FRAG_T, WCCPropertyContext<FRAG_T>> {
140140
}
141141
}
142142

143-
for (label_id_t i = 0; i < v_label_num; ++i) {
144-
auto iv = frag.InnerVertices(i);
145-
bool ok = false;
146-
for (auto v : iv) {
147-
if (ctx.next_modified[i][v]) {
148-
messages.ForceContinue();
149-
ok = true;
150-
break;
151-
}
152-
}
153-
if (ok) {
154-
break;
155-
}
156-
}
157-
143+
HandleMessageForceContinue(frag, ctx, messages);
158144
ctx.curr_modified.swap(ctx.next_modified);
159145
}
160146

@@ -220,6 +206,14 @@ class WCCProperty : public PropertyAppBase<FRAG_T, WCCPropertyContext<FRAG_T>> {
220206
}
221207
}
222208
}
209+
210+
HandleMessageForceContinue(frag, ctx, messages);
211+
ctx.curr_modified.swap(ctx.next_modified);
212+
}
213+
214+
void HandleMessageForceContinue(const fragment_t& frag, context_t& ctx,
215+
message_manager_t& messages) {
216+
label_id_t v_label_num = frag.vertex_label_num();
223217
for (label_id_t i = 0; i < v_label_num; ++i) {
224218
auto iv = frag.InnerVertices(i);
225219
bool ok = false;
@@ -234,7 +228,6 @@ class WCCProperty : public PropertyAppBase<FRAG_T, WCCPropertyContext<FRAG_T>> {
234228
break;
235229
}
236230
}
237-
ctx.curr_modified.swap(ctx.next_modified);
238231
}
239232
};
240233

0 commit comments

Comments
 (0)