提交 3be5e8a2 编写于 作者: O obdev 提交者: ob-robot

[bugfix] fix memory leak in replayservice

上级 bd109eae
......@@ -1089,7 +1089,7 @@ int ObReplayStatus::push_log_replay_task(ObLogReplayTask &task)
if (OB_UNLIKELY(NULL == (task_buf = rp_sv_->alloc_replay_task(task_size)))) {
ret = OB_EAGAIN;
if (REACH_TIME_INTERVAL(1 * 1000 * 1000)) {
CLOG_LOG(WARN, "failed to alloc replay task buf when broadcast pre barrier", K(ret));
CLOG_LOG(WARN, "failed to alloc replay task buf when broadcast pre barrier", K(i), K(ret));
}
} else {
ObLogReplayTask *replay_task = new (task_buf) ObLogReplayTask();
......@@ -1120,7 +1120,7 @@ int ObReplayStatus::push_log_replay_task(ObLogReplayTask &task)
task_queues_[index].set_batch_push_finish();
}
} else {
for (int64_t i = 1; OB_SUCC(ret) && i < broadcast_task_array.count(); ++i) {
for (int64_t i = 1; i < broadcast_task_array.count(); ++i) {
free_replay_task(broadcast_task_array[i]);
}
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册