MCPcopy Create free account
hub / github.com/Tencent/phxqueue / ProcessRoutineRun

Function ProcessRoutineRun

phxqueue/producer/batchhelper.cpp:296–302  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

294}
295
296static void *ProcessRoutineRun(void *arg) {
297 co_enable_hook_sys();
298
299 ProcessCtx_t *ctx = static_cast<ProcessCtx_t*>(arg);
300 ctx->batch_helper->Process(ctx);
301 return nullptr;
302}
303
304
305void BatchHelper::Process(ProcessCtx_t *ctx) {

Callers

nothing calls this directly

Calls 1

ProcessMethod · 0.45

Tested by

no test coverage detected