Commit 839349d1 authored by Sricharan Ramabadhran's avatar Sricharan Ramabadhran Committed by David S. Miller

net: qrtr: Do not do DEL_SERVER broadcast after DEL_CLIENT

On the remote side, when QRTR socket is removed, af_qrtr will call
qrtr_port_remove() which broadcasts the DEL_CLIENT packet to all neighbours
including local NS. NS upon receiving the DEL_CLIENT packet, will remove
the lookups associated with the node:port and broadcasts the DEL_SERVER
packet.

But on the host side, due to the arrival of the DEL_CLIENT packet, the NS
would've already deleted the server belonging to that port. So when the
remote's NS again broadcasts the DEL_SERVER for that port, it throws below
error message on the host:

"failed while handling packet from 2:-2"

So fix this error by not broadcasting the DEL_SERVER packet when the
DEL_CLIENT packet gets processed."

Fixes: 0c2204a4 ("net: qrtr: Migrate nameservice to kernel from userspace")
Reviewed-by: default avatarManivannan Sadhasivam <mani@kernel.org>
Signed-off-by: default avatarRam Kumar Dharuman <quic_ramd@quicinc.com>
Signed-off-by: default avatarSricharan Ramabadhran <quic_srichara@quicinc.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent ad651d68
...@@ -274,7 +274,7 @@ static struct qrtr_server *server_add(unsigned int service, ...@@ -274,7 +274,7 @@ static struct qrtr_server *server_add(unsigned int service,
return NULL; return NULL;
} }
static int server_del(struct qrtr_node *node, unsigned int port) static int server_del(struct qrtr_node *node, unsigned int port, bool bcast)
{ {
struct qrtr_lookup *lookup; struct qrtr_lookup *lookup;
struct qrtr_server *srv; struct qrtr_server *srv;
...@@ -287,7 +287,7 @@ static int server_del(struct qrtr_node *node, unsigned int port) ...@@ -287,7 +287,7 @@ static int server_del(struct qrtr_node *node, unsigned int port)
radix_tree_delete(&node->servers, port); radix_tree_delete(&node->servers, port);
/* Broadcast the removal of local servers */ /* Broadcast the removal of local servers */
if (srv->node == qrtr_ns.local_node) if (srv->node == qrtr_ns.local_node && bcast)
service_announce_del(&qrtr_ns.bcast_sq, srv); service_announce_del(&qrtr_ns.bcast_sq, srv);
/* Announce the service's disappearance to observers */ /* Announce the service's disappearance to observers */
...@@ -373,7 +373,7 @@ static int ctrl_cmd_bye(struct sockaddr_qrtr *from) ...@@ -373,7 +373,7 @@ static int ctrl_cmd_bye(struct sockaddr_qrtr *from)
} }
slot = radix_tree_iter_resume(slot, &iter); slot = radix_tree_iter_resume(slot, &iter);
rcu_read_unlock(); rcu_read_unlock();
server_del(node, srv->port); server_del(node, srv->port, true);
rcu_read_lock(); rcu_read_lock();
} }
rcu_read_unlock(); rcu_read_unlock();
...@@ -459,10 +459,13 @@ static int ctrl_cmd_del_client(struct sockaddr_qrtr *from, ...@@ -459,10 +459,13 @@ static int ctrl_cmd_del_client(struct sockaddr_qrtr *from,
kfree(lookup); kfree(lookup);
} }
/* Remove the server belonging to this port */ /* Remove the server belonging to this port but don't broadcast
* DEL_SERVER. Neighbours would've already removed the server belonging
* to this port due to the DEL_CLIENT broadcast from qrtr_port_remove().
*/
node = node_get(node_id); node = node_get(node_id);
if (node) if (node)
server_del(node, port); server_del(node, port, false);
/* Advertise the removal of this client to all local servers */ /* Advertise the removal of this client to all local servers */
local_node = node_get(qrtr_ns.local_node); local_node = node_get(qrtr_ns.local_node);
...@@ -567,7 +570,7 @@ static int ctrl_cmd_del_server(struct sockaddr_qrtr *from, ...@@ -567,7 +570,7 @@ static int ctrl_cmd_del_server(struct sockaddr_qrtr *from,
if (!node) if (!node)
return -ENOENT; return -ENOENT;
return server_del(node, port); return server_del(node, port, true);
} }
static int ctrl_cmd_new_lookup(struct sockaddr_qrtr *from, static int ctrl_cmd_new_lookup(struct sockaddr_qrtr *from,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment