MCPcopy Create free account
hub / github.com/RedisGraph/RedisGraph / OpBase_PropagateReset

Function OpBase_PropagateReset

src/execution_plan/ops/op.c:175–194  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

173}
174
175void OpBase_PropagateReset
176(
177 OpBase *op
178) {
179 // hold write operations until the read operations have been reset
180 OpBase **write_ops = array_new(OpBase *, 0);
181
182 // reset read operations
183 _OpBase_PropagateReset(op, &write_ops);
184
185 // reset write operations
186 uint write_op_count = array_len(write_ops);
187 for(uint i = 0; i < write_op_count; i++) {
188 OpBase *write_op = write_ops[i];
189 OpResult res = write_op->reset(write_op);
190 ASSERT(res == OP_OK);
191 }
192
193 array_free(write_ops);
194}
195
196static void _OpBase_StatsToString
197(

Callers 14

ApplyConsumeFunction · 0.85
CreateConsumeFunction · 0.85
CallSubqueryConsumeEagerFunction · 0.85
_consume_and_mergeFunction · 0.85
_handoffFunction · 0.85
DeleteConsumeFunction · 0.85
_ResetStreamsFunction · 0.85
MergeCreate_CommitFunction · 0.85
JoinConsumeFunction · 0.85
MergeConsumeFunction · 0.85
SemiApplyConsumeFunction · 0.85
AntiSemiApplyConsumeFunction · 0.85

Calls 3

_OpBase_PropagateResetFunction · 0.85
array_lenFunction · 0.85
array_freeFunction · 0.85

Tested by

no test coverage detected