do not copy env obj messages

mschubert · Jan 9, 2025 · 355906d · 355906d
1 parent ffc1009
commit 355906d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/NEWS.md b/NEWS.md
@@ -1,3 +1,7 @@
+# git head
+
+* Common data will no longer be duplicated when sending to workers
+
 # clustermq 0.9.5
 
 * Fix a bug where an outdated system `libzmq` led to compilation errors (#327)

diff --git a/src/CMQMaster.h b/src/CMQMaster.h
@@ -123,7 +123,7 @@ class CMQMaster {
             for (auto &str : new_env) {
                 w.env.insert(str);
                 mp.push_back(zmq::message_t(str));
-                mp.push_back(zmq::message_t(env[str].data(), env[str].size()));
+                mp.push_back(zmq::message_t(env[str].data(), env[str].size(), [](void*, void*){}));
             }
         } else {
             std::vector<std::string> proxy_add_env;
@@ -134,7 +134,7 @@ class CMQMaster {
 //                    std::cout << "+from_master " << str << "\n";
                     via_env.insert(str);
                     mp.push_back(zmq::message_t(str));
-                    mp.push_back(zmq::message_t(env[str].data(), env[str].size()));
+                    mp.push_back(zmq::message_t(env[str].data(), env[str].size(), [](void*, void*){}));
                 } else {
 //                    std::cout << "+from_proxy " << str << "\n";
                     proxy_add_env.push_back(str);