lua_gc is called every 10s

.github/workflows/package-collect.yml

@@ -182,7 +182,7 @@ jobs:
         run: rm -rf *-debuginfo*.${{ matrix.package_extension }}
 
       # set condition to true if artifacts are needed
-      - if: ${{ false }}
+      - if: ${{ true }}
         name: Upload package artifacts
         uses: actions/upload-artifact@694cdabd8bdb0f10b2cea11669e1bf5453eed0a6 # v4.2.0
         with:

broker/lua/inc/com/centreon/broker/lua/luabinding.hh

@@ -106,6 +106,9 @@ class luabinding {
   void _init_script(std::map<std::string, misc::variant> const& conf_params);
   void _update_lua_path(std::string const& path);
 
+  unsigned _gc_broker_event_cpt;
+  time_t _gc_last_full_gc;
+
  public:
   luabinding(std::string const& lua_script,
              std::map<std::string, misc::variant> const& conf_params,

broker/lua/src/broker_event.cc

@@ -1,20 +1,20 @@
 /**
-* Copyright 2020-2021 Centreon
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-* For more information : [email protected]
-*/
+ * Copyright 2020-2021 Centreon
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * For more information : [email protected]
+ */
 
 #include "com/centreon/broker/lua/broker_event.hh"
 #include <google/protobuf/message.h>
@@ -32,6 +32,7 @@ static void _write_item(lua_State* L,
                         const google::protobuf::Message* p,
                         const google::protobuf::FieldDescriptor* f);
 
+
 /**
  *  The Lua broker_event constructor
  *

broker/lua/src/luabinding.cc

@@ -61,7 +61,9 @@ luabinding::luabinding(std::string const& lua_script,
       _flush{false},
       _cache(cache),
       _total{0},
-      _broker_api_version{1} {
+      _broker_api_version{1},
+      _gc_broker_event_cpt(0),
+      _gc_last_full_gc(time(nullptr)) {
   size_t pos(lua_script.find_last_of('/'));
   std::string path(lua_script.substr(0, pos));
   _L = _load_interpreter();
@@ -396,6 +398,19 @@ int luabinding::write(std::shared_ptr<io::data> const& data) noexcept {
     } break;
     case 2:
       broker_event::create(_L, data);
+      /*In V2, lua stores only a userdata that contains a shared_ptr of event
+       * (16 bytes). So garbage collector don't see amount of memory used by
+       * events.
+       * So we need to call garbage collector ourselves to reduce memory
+       * consumption */
+      time_t now = time(nullptr);
+      if ((++_gc_broker_event_cpt > 1000 && _gc_last_full_gc + 5 < now) ||
+          (_gc_last_full_gc + 30 < now)) {
+        _gc_broker_event_cpt = 0;
+        _gc_last_full_gc = now;
+        lua_gc(_L, LUA_GCCOLLECT, 0);
+      }
+
       break;
   }