|
@@ -371,6 +371,7 @@ static int tipc_conn_rcv_sub(struct tipc_topsrv *srv,
|
|
|
struct tipc_subscription *sub;
|
|
struct tipc_subscription *sub;
|
|
|
|
|
|
|
|
if (tipc_sub_read(s, filter) & TIPC_SUB_CANCEL) {
|
|
if (tipc_sub_read(s, filter) & TIPC_SUB_CANCEL) {
|
|
|
|
|
+ s->filter &= __constant_ntohl(~TIPC_SUB_CANCEL);
|
|
|
tipc_conn_delete_sub(con, s);
|
|
tipc_conn_delete_sub(con, s);
|
|
|
return 0;
|
|
return 0;
|
|
|
}
|
|
}
|