ulp/ipoib/ipoib_multicast.c

74 					       struct ipoib_mcast *mcast,
85 	if (mcast && delay) {
89 		mcast->backoff *= 2;
90 		if (mcast->backoff > IPOIB_MAX_BACKOFF_SECONDS)
91 			mcast->backoff = IPOIB_MAX_BACKOFF_SECONDS;
92 		mcast->delay_until = jiffies + (mcast->backoff * HZ);
94 		 * Mark this mcast for its delay, but restart the
112 static void ipoib_mcast_free(struct ipoib_mcast *mcast)
114 	struct net_device *dev = mcast->dev;
118 			mcast->mcmember.mgid.raw);
120 	/* remove all neigh connected to this mcast */
121 	ipoib_del_neighs_by_gid(dev, mcast->mcmember.mgid.raw);
123 	if (mcast->ah)
124 		ipoib_put_ah(mcast->ah);
126 	while (!skb_queue_empty(&mcast->pkt_queue)) {
128 		dev_kfree_skb_any(skb_dequeue(&mcast->pkt_queue));
135 	kfree(mcast);
140 	struct ipoib_mcast *mcast;
142 	mcast = kzalloc(sizeof(*mcast), GFP_ATOMIC);
143 	if (!mcast)
146 	mcast->dev = dev;
147 	mcast->created = jiffies;
148 	mcast->delay_until = jiffies;
149 	mcast->backoff = 1;
151 	INIT_LIST_HEAD(&mcast->list);
152 	INIT_LIST_HEAD(&mcast->neigh_list);
153 	skb_queue_head_init(&mcast->pkt_queue);
155 	return mcast;
164 		struct ipoib_mcast *mcast;
167 		mcast = rb_entry(n, struct ipoib_mcast, rb_node);
169 		ret = memcmp(mgid, mcast->mcmember.mgid.raw,
176 			return mcast;
182 static int __ipoib_mcast_add(struct net_device *dev, struct ipoib_mcast *mcast)
194 		ret = memcmp(mcast->mcmember.mgid.raw, tmcast->mcmember.mgid.raw,
204 	rb_link_node(&mcast->rb_node, pn, n);
205 	rb_insert_color(&mcast->rb_node, &priv->multicast_tree);
210 static int ipoib_mcast_join_finish(struct ipoib_mcast *mcast,
213 	struct net_device *dev = mcast->dev;
222 	mcast->mcmember = *mcmember;
227 	if (!memcmp(mcast->mcmember.mgid.raw, priv->dev->broadcast + 4,
234 		/*update priv member according to the new mcast*/
242 		/* assume if the admin and the mcast are the same both can be changed */
256 	if (!test_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags)) {
257 		if (test_and_set_bit(IPOIB_MCAST_FLAG_ATTACHED, &mcast->flags)) {
259 				   mcast->mcmember.mgid.raw);
264 		ret = rn->attach_mcast(dev, priv->ca, &mcast->mcmember.mgid,
265 				       be16_to_cpu(mcast->mcmember.mlid),
269 				   mcast->mcmember.mgid.raw);
271 			clear_bit(IPOIB_MCAST_FLAG_ATTACHED, &mcast->flags);
278 	rdma_ah_set_dlid(&av, be16_to_cpu(mcast->mcmember.mlid));
280 	rdma_ah_set_sl(&av, mcast->mcmember.sl);
281 	rdma_ah_set_static_rate(&av, mcast->mcmember.rate);
283 	rdma_ah_set_grh(&av, &mcast->mcmember.mgid,
284 			be32_to_cpu(mcast->mcmember.flow_label),
285 			0, mcast->mcmember.hop_limit,
286 			mcast->mcmember.traffic_class);
295 	mcast->ah = ah;
299 			mcast->mcmember.mgid.raw,
300 			mcast->ah->ah,
301 			be16_to_cpu(mcast->mcmember.mlid),
302 			mcast->mcmember.sl);
306 	while (!skb_queue_empty(&mcast->pkt_queue)) {
307 		struct sk_buff *skb = skb_dequeue(&mcast->pkt_queue);
359 	struct ipoib_mcast *mcast = multicast->context;
360 	struct net_device *dev = mcast->dev;
364 			test_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags) ?
366 			mcast->mcmember.mgid.raw, status);
375 		status = ipoib_mcast_join_finish(mcast, &multicast->rec);
378 		mcast->backoff = 1;
379 		mcast->delay_until = jiffies;
388 		if (mcast == priv->broadcast) {
396 		    test_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags) &&
399 		if (mcast->logcount < 20) {
403 						test_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags) ? "sendonly " : "",
404 						mcast->mcmember.mgid.raw, status);
407 						test_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags) ? "sendonly " : "",
408 					   mcast->mcmember.mgid.raw, status);
412 				mcast->logcount++;
415 		if (test_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags) &&
416 		    mcast->backoff >= 2) {
421 			 * mcast list as an unjoined group.  If we want to
426 			mcast->backoff = 1;
428 			while (!skb_queue_empty(&mcast->pkt_queue)) {
430 				dev_kfree_skb_any(skb_dequeue(&mcast->pkt_queue));
436 			__ipoib_mcast_schedule_join_thread(priv, mcast, 1);
444 	 * Make sure to set mcast->mc before we clear the busy flag to avoid
445 	 * racing with code that checks for BUSY before checking mcast->mc
448 		mcast->mc = NULL;
450 		mcast->mc = multicast;
451 	clear_bit(IPOIB_MCAST_FLAG_BUSY, &mcast->flags);
453 	complete(&mcast->done);
461 static int ipoib_mcast_join(struct net_device *dev, struct ipoib_mcast *mcast)
475 	init_completion(&mcast->done);
476 	set_bit(IPOIB_MCAST_FLAG_BUSY, &mcast->flags);
478 	ipoib_dbg_mcast(priv, "joining MGID %pI6\n", mcast->mcmember.mgid.raw);
480 	rec.mgid     = mcast->mcmember.mgid;
490 	if (mcast != priv->broadcast) {
530 		if (test_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags))
536 					 ipoib_mcast_join_complete, mcast);
541 		__ipoib_mcast_schedule_join_thread(priv, mcast, 1);
542 		clear_bit(IPOIB_MCAST_FLAG_BUSY, &mcast->flags);
543 		complete(&mcast->done);
556 	struct ipoib_mcast *mcast = NULL;
609 			mcast = priv->broadcast;
610 			if (mcast->backoff > 1 &&
611 			    time_before(jiffies, mcast->delay_until)) {
612 				delay_until = mcast->delay_until;
613 				mcast = NULL;
623 	list_for_each_entry(mcast, &priv->multicast_list, list) {
624 		if (IS_ERR_OR_NULL(mcast->mc) &&
625 		    !test_bit(IPOIB_MCAST_FLAG_BUSY, &mcast->flags) &&
626 		    (!test_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags) ||
627 		     !skb_queue_empty(&mcast->pkt_queue))) {
628 			if (mcast->backoff == 1 ||
629 			    time_after_eq(jiffies, mcast->delay_until)) {
631 				if (ipoib_mcast_join(dev, mcast)) {
636 				 time_before(mcast->delay_until, delay_until))
637 				delay_until = mcast->delay_until;
641 	mcast = NULL;
650 	if (mcast)
651 		ipoib_mcast_join(dev, mcast);
677 static int ipoib_mcast_leave(struct net_device *dev, struct ipoib_mcast *mcast)
683 	if (test_and_clear_bit(IPOIB_MCAST_FLAG_BUSY, &mcast->flags))
686 	if (!IS_ERR_OR_NULL(mcast->mc))
687 		ib_sa_free_multicast(mcast->mc);
689 	if (test_and_clear_bit(IPOIB_MCAST_FLAG_ATTACHED, &mcast->flags)) {
691 				mcast->mcmember.mgid.raw);
694 		ret = rn->detach_mcast(dev, priv->ca, &mcast->mcmember.mgid,
695 				       be16_to_cpu(mcast->mcmember.mlid));
698 	} else if (!test_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags))
714 		struct ipoib_mcast *mcast = __ipoib_mcast_find(priv->dev, mgid);
716 		if (mcast && test_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags)) {
717 			list_del(&mcast->list);
718 			rb_erase(&mcast->rb_node, &priv->multicast_tree);
719 			list_add_tail(&mcast->list, remove_list);
726 	struct ipoib_mcast *mcast, *tmcast;
732 	list_for_each_entry_safe(mcast, tmcast, remove_list, list)
733 		if (test_bit(IPOIB_MCAST_FLAG_BUSY, &mcast->flags))
734 			wait_for_completion(&mcast->done);
736 	list_for_each_entry_safe(mcast, tmcast, remove_list, list) {
737 		ipoib_mcast_leave(mcast->dev, mcast);
738 		ipoib_mcast_free(mcast);
746 	struct ipoib_mcast *mcast;
760 	mcast = __ipoib_mcast_find(dev, mgid);
761 	if (!mcast || !mcast->ah) {
762 		if (!mcast) {
767 			mcast = ipoib_mcast_alloc(dev);
768 			if (!mcast) {
776 			set_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags);
777 			memcpy(mcast->mcmember.mgid.raw, mgid,
779 			__ipoib_mcast_add(dev, mcast);
780 			list_add_tail(&mcast->list, &priv->multicast_list);
782 		if (skb_queue_len(&mcast->pkt_queue) < IPOIB_MAX_MCAST_QUEUE) {
785 			skb_queue_tail(&mcast->pkt_queue, skb);
790 		if (!test_bit(IPOIB_MCAST_FLAG_BUSY, &mcast->flags)) {
802 			 * once to mcast list.
805 				kref_get(&mcast->ah->ref);
806 				neigh->ah	= mcast->ah;
808 				list_add_tail(&neigh->list, &mcast->neigh_list);
812 		mcast->ah->last_send = rn->send(dev, skb, mcast->ah->ah,
827 	struct ipoib_mcast *mcast, *tmcast;
835 	list_for_each_entry_safe(mcast, tmcast, &priv->multicast_list, list) {
836 		list_del(&mcast->list);
837 		rb_erase(&mcast->rb_node, &priv->multicast_tree);
838 		list_add_tail(&mcast->list, &remove_list);
870 	struct ipoib_mcast *mcast, *tmcast;
893 	list_for_each_entry(mcast, &priv->multicast_list, list)
894 		clear_bit(IPOIB_MCAST_FLAG_FOUND, &mcast->flags);
905 		mcast = __ipoib_mcast_find(dev, &mgid);
906 		if (!mcast || test_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags)) {
931 			if (mcast) {
933 				list_move_tail(&mcast->list, &remove_list);
935 				rb_replace_node(&mcast->rb_node,
944 		if (mcast)
945 			set_bit(IPOIB_MCAST_FLAG_FOUND, &mcast->flags);
949 	list_for_each_entry_safe(mcast, tmcast, &priv->multicast_list, list) {
950 		if (!test_bit(IPOIB_MCAST_FLAG_FOUND, &mcast->flags) &&
951 		    !test_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags)) {
953 					mcast->mcmember.mgid.raw);
955 			rb_erase(&mcast->rb_node, &priv->multicast_tree);
958 			list_move_tail(&mcast->list, &remove_list);
1002 	struct ipoib_mcast *mcast;
1010 		mcast = rb_entry(n, struct ipoib_mcast, rb_node);
1012 		if (memcmp(iter->mgid.raw, mcast->mcmember.mgid.raw,
1014 			iter->mgid      = mcast->mcmember.mgid;
1015 			iter->created   = mcast->created;
1016 			iter->queuelen  = skb_queue_len(&mcast->pkt_queue);
1017 			iter->complete  = !!mcast->ah;
1018 			iter->send_only = !!(mcast->flags & (1 << IPOIB_MCAST_FLAG_SENDONLY));