---
src/log/logd/lgs_evt.cc | 3 +++
src/log/logd/lgs_mbcsv_cache.cc | 2 ++
2 files changed, 5 insertions(+)
diff --git a/src/log/logd/lgs_evt.cc b/src/log/logd/lgs_evt.cc
index 7501a282b..f169ea1e9 100644
--- a/src/log/logd/lgs_evt.cc
+++ b/src/log/logd/lgs_evt.cc
@@ -1348,6 +1348,7 @@ static uint32_t proc_write_log_async_msg(lgs_cb_t *cb,
lgsv_lgs_evt_t *evt) {
stream->fixedLogRecordSize, buf_size, logOutputString,
++stream->logRecordId, node_name)) == 0) {
AckToWriteAsync(param, evt->fr_dest, SA_AIS_ERR_INVALID_PARAM);
+ free(logOutputString);
return NCSCC_RC_SUCCESS;
}
@@ -1356,6 +1357,8 @@ static uint32_t proc_write_log_async_msg(lgs_cb_t *cb,
lgsv_lgs_evt_t *evt) {
evt->fr_dest, node_name);
auto data = std::make_shared<Cache::Data>(info, logOutputString, n);
Cache::instance()->Write(data);
+
+ lgs_free_write_log(param);
return NCSCC_RC_SUCCESS;
}
diff --git a/src/log/logd/lgs_mbcsv_cache.cc b/src/log/logd/lgs_mbcsv_cache.cc
index cde26432a..b190c5bea 100644
--- a/src/log/logd/lgs_mbcsv_cache.cc
+++ b/src/log/logd/lgs_mbcsv_cache.cc
@@ -230,6 +230,8 @@ uint32_t ckpt_proc_pop_write_async(lgs_cb_t* cb, void*
data) {
if (top->seq_id_ != seq_id) {
LOG_ER("Out of sync! Expected seq: (%" PRIu64 "), Got: (%" PRIu64 ")",
seq_id, top->seq_id_);
+ lgs_free_edu_mem(param->log_record);
+ lgs_free_edu_mem(param->log_file);
return NCSCC_RC_FAILURE;
}
--
2.17.1
_______________________________________________
Opensaf-devel mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/opensaf-devel
