Commit 1b7bbdf 1 parent 1433cee commit 1b7bbdf Copy full SHA for 1b7bbdf
File tree 1 file changed +6
-7
lines changed
1 file changed +6
-7
lines changed Original file line number Diff line number Diff line change @@ -131,16 +131,15 @@ class CMQMaster {
131
131
auto &via_env = peers[w.via ].env ;
132
132
for (auto &str : new_env) {
133
133
w.env .insert (str);
134
- if (via_env.find (str) != via_env.end ()) {
135
- // std::cout << "+from_proxy " << str << "\n";
136
- proxy_add_env.push_back (str);
137
- continue ;
138
- } else {
134
+ if (via_env.find (str) == via_env.end ()) {
139
135
// std::cout << "+from_master " << str << "\n";
140
136
via_env.insert (str);
137
+ mp.push_back (zmq::message_t (str));
138
+ mp.push_back (zmq::message_t (env[str].data (), env[str].size ()));
139
+ } else {
140
+ // std::cout << "+from_proxy " << str << "\n";
141
+ proxy_add_env.push_back (str);
141
142
}
142
- mp.push_back (zmq::message_t (str));
143
- mp.push_back (zmq::message_t (env[str].data (), env[str].size ()));
144
143
}
145
144
mp.push_back (r2msg (Rcpp::wrap (proxy_add_env)));
146
145
}
You can’t perform that action at this time.
0 commit comments