hurricos/openwrt-mirror
1
0
Fork 0
mirror of git://git.openwrt.org/openwrt/openwrt.git synced 2026-06-11 05:07:26 -04:00
Code Issues Projects Releases Wiki Activity

unetmsg: only send publish notifications for remote publisher changes

Browse Source 
handle_publish() notifies local subscribers about publisher state
changes. The publish/subscribe handler in network_socket_handle_request()
was calling it for both remote publish and subscribe changes, but
subscriber changes are not relevant to local subscribers.

Guard the handle_publish() calls with a msgtype == "publish" check,
matching the local client paths in unetmsgd-client.uc which already
have this guard.

Signed-off-by: Felix Fietkau <nbd@nbd.name>
(cherry picked from commit e0722d0ac4)
This commit is contained in:
Felix Fietkau
2026-02-07 08:02:24 +00:00
parent 41ec0c16a7
commit 40a7b55d70
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
package/network/services/unetmsg/files/usr/share/ucode/unetmsg/unetmsgd-remote.uc
View File

@@ -104,7 +104,7 @@ function network_socket_handle_request(sock_data, req)
return;
if (args.enabled) {
if (list[name]) {
if (tx_auth)
if (tx_auth && msgtype == "publish")
core.handle_publish(null, name);
return 0;
}
@@ -124,13 +124,14 @@ function network_socket_handle_request(sock_data, req)
network: sock_data.network,
name: host,
}, pubsub_proto);
if (tx_auth)
if (tx_auth && msgtype == "publish")
core.handle_publish(null, name);
list[name] = true;
} else {
if (!list[name])
return 0;
core.handle_publish(null, name);
if (msgtype == "publish")
core.handle_publish(null, name);
delete core["remote_" + msgtype][name][host];
delete list[name];
}