diff options
author | Patrick McHardy <kaber@trash.net> | 2010-04-15 07:29:28 -0400 |
---|---|---|
committer | Patrick McHardy <kaber@trash.net> | 2010-04-15 07:31:29 -0400 |
commit | b0ebb739a8f68039f03e80b3476b204fe5adf0d7 (patch) | |
tree | 45921e2969657f6a35fbac751218ea78e1f3be9b /net/ipv4/ipmr.c | |
parent | 66496d4973dcb848d163805fa6b485850b7555e3 (diff) |
ipv4: ipmr: fix invalid cache resolving when adding a non-matching entry
The patch to convert struct mfc_cache to list_heads (ipv4: ipmr: convert
struct mfc_cache to struct list_head) introduced a bug when adding new
cache entries that don't match any unresolved entries.
The unres queue is searched for a matching entry, which is then resolved.
When no matching entry is present, the iterator points to the head of the
list, but is treated as a matching entry. Use a seperate variable to
indicate that a matching entry was found.
Signed-off-by: Patrick McHardy <kaber@trash.net>
Diffstat (limited to 'net/ipv4/ipmr.c')
-rw-r--r-- | net/ipv4/ipmr.c | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/net/ipv4/ipmr.c b/net/ipv4/ipmr.c index 5df5fd74c6d1..0643fb6d47c4 100644 --- a/net/ipv4/ipmr.c +++ b/net/ipv4/ipmr.c | |||
@@ -1089,12 +1089,14 @@ static int ipmr_mfc_add(struct net *net, struct mr_table *mrt, | |||
1089 | * Check to see if we resolved a queued list. If so we | 1089 | * Check to see if we resolved a queued list. If so we |
1090 | * need to send on the frames and tidy up. | 1090 | * need to send on the frames and tidy up. |
1091 | */ | 1091 | */ |
1092 | found = false; | ||
1092 | spin_lock_bh(&mfc_unres_lock); | 1093 | spin_lock_bh(&mfc_unres_lock); |
1093 | list_for_each_entry(uc, &mrt->mfc_unres_queue, list) { | 1094 | list_for_each_entry(uc, &mrt->mfc_unres_queue, list) { |
1094 | if (uc->mfc_origin == c->mfc_origin && | 1095 | if (uc->mfc_origin == c->mfc_origin && |
1095 | uc->mfc_mcastgrp == c->mfc_mcastgrp) { | 1096 | uc->mfc_mcastgrp == c->mfc_mcastgrp) { |
1096 | list_del(&uc->list); | 1097 | list_del(&uc->list); |
1097 | atomic_dec(&mrt->cache_resolve_queue_len); | 1098 | atomic_dec(&mrt->cache_resolve_queue_len); |
1099 | found = true; | ||
1098 | break; | 1100 | break; |
1099 | } | 1101 | } |
1100 | } | 1102 | } |
@@ -1102,7 +1104,7 @@ static int ipmr_mfc_add(struct net *net, struct mr_table *mrt, | |||
1102 | del_timer(&mrt->ipmr_expire_timer); | 1104 | del_timer(&mrt->ipmr_expire_timer); |
1103 | spin_unlock_bh(&mfc_unres_lock); | 1105 | spin_unlock_bh(&mfc_unres_lock); |
1104 | 1106 | ||
1105 | if (uc) { | 1107 | if (found) { |
1106 | ipmr_cache_resolve(net, mrt, uc, c); | 1108 | ipmr_cache_resolve(net, mrt, uc, c); |
1107 | ipmr_cache_free(uc); | 1109 | ipmr_cache_free(uc); |
1108 | } | 1110 | } |