Lines Matching refs:qe
288 struct mc_querier_entry *qe;
294 os_hlist_for_each_entry_rcu(qe, h, &rp->igmp_rlist, rlist) {
296 ntohl(rp->igmp_root_qe->sip.u.ip4) > ntohl(qe->sip.u.ip4))
297 rp->igmp_root_qe = qe;
305 struct mc_querier_entry *qe;
311 os_hlist_for_each_entry_rcu(qe, h, &rp->mld_rlist, rlist) {
313 ipv6_addr_cmp(&rp->mld_root_qe->sip.u.ip6, &qe->sip.u.ip6) > 0)
314 rp->mld_root_qe = qe;
322 struct mc_querier_entry *qe;
324 os_hlist_for_each_entry_rcu(qe, h, head, rlist) {
325 if ((__be32)port == (__be32)qe->port)
326 return qe;
333 struct mc_querier_entry *qe =
336 kfree(qe);
339 static void mc_querier_entry_destroy(struct mc_querier_entry *qe)
341 hlist_del_rcu(&qe->rlist);
342 call_rcu(&qe->rcu, mc_querier_entry_rcu_free);
348 struct mc_querier_entry *qe = NULL;
350 qe = kzalloc(sizeof *qe, GFP_ATOMIC);
351 if (qe) {
352 qe->port = port;
353 qe->ageing_timer = jiffies;
354 hlist_add_head_rcu(&qe->rlist, head);
356 return qe;
1833 struct mc_querier_entry *qe = NULL;
1874 qe = mc_querier_entry_find(&rp->igmp_rlist, port);
1875 if (!qe || memcmp(&sip, &qe->sip, sizeof sip)) {
1876 if (qe) {
1877 if (ntohl(sip.u.ip4) < ntohl(qe->sip.u.ip4))
1878 mc_querier_entry_destroy(qe);
1882 qe = mc_querier_entry_create(&rp->igmp_rlist, port, &sip);
1883 if (!qe)
1891 qe->max_resp_time = max_resp_time;
1892 qe->qqic = qqic;
1893 qe->qrv = qrv;
1894 qe->ageing_timer = jiffies;
1915 struct mc_querier_entry *qe = NULL;
1954 qe = mc_querier_entry_find(&rp->mld_rlist, port);
1955 if (!qe || memcmp(&sip, &qe->sip, sizeof sip)) {
1956 if (qe) {
1957 if (ipv6_addr_cmp(&qe->sip.u.ip6, &sip.u.ip6) > 0)
1958 mc_querier_entry_destroy(qe);
1962 qe = mc_querier_entry_create(&rp->mld_rlist, port, &sip);
1963 if (!qe)
1971 qe->max_resp_time = max_resp_time;
1972 qe->qqic = qqic;
1973 qe->qrv = qrv;
1974 qe->ageing_timer = jiffies;
2321 struct mc_querier_entry *qe;
2341 os_hlist_for_each_entry_rcu(qe, h, &mc->rp.igmp_rlist, rlist) {
2342 if (qe->port == p) {
2343 mc_querier_entry_destroy(qe);
2351 os_hlist_for_each_entry_rcu(qe, h, &mc->rp.mld_rlist, rlist) {
2352 if (qe->port == p) {
2353 mc_querier_entry_destroy(qe);
2415 struct mc_querier_entry *qe;
2417 os_hlist_for_each_entry_safe(qe, h, n, &mc->rp.igmp_rlist, rlist) {
2418 mc_querier_entry_destroy(qe);
2422 os_hlist_for_each_entry_safe(qe, h, n, &mc->rp.mld_rlist, rlist) {
2423 mc_querier_entry_destroy(qe);
2557 struct mc_querier_entry *qe;
2561 os_hlist_for_each_entry_rcu(qe, h, &rp->igmp_rlist, rlist) {
2562 unsigned long this_timer = qe->ageing_timer + qe->qqic * qe->qrv + qe->max_resp_time / 2;
2565 mc_querier_entry_destroy(qe);
2576 os_hlist_for_each_entry_rcu(qe, h, &rp->mld_rlist, rlist) {
2577 unsigned long this_timer = qe->ageing_timer + qe->qqic * qe->qrv + qe->max_resp_time / 2;
2580 mc_querier_entry_destroy(qe);