commit 31f1f340ff01c3f59c0aa961dd0a8e9db2c59993
author A R Karthick <kramanar@ciena.com> Fri May 19 13:55:10 2017 -0700
committer A R Karthick <kramanar@ciena.com> Fri May 19 13:55:10 2017 -0700
tree 0e4bef241297758a0ca1355aa5a7d64faa4b1dbe
parent 49529c5f17b03064bb18380cbb26a034bea5910f

Test only igmp leaves

Change-Id: I6dac6b6e2c2b782d68b3e41bc01170577cc68dde

src/test/cordSubscriber/cordSubscriberTest.py

diff --git a/src/test/cordSubscriber/cordSubscriberTest.py b/src/test/cordSubscriber/cordSubscriberTest.py
index f1e310d..724453f 100644
--- a/src/test/cordSubscriber/cordSubscriberTest.py
+++ b/src/test/cordSubscriber/cordSubscriberTest.py
@@ -562,6 +562,23 @@
                   self.test_status = True
                   return self.test_status
 
+      def igmp_leave_verify(self, subscriber):
+            if subscriber.has_service('IGMP'):
+                  for chan in xrange(subscriber.num):
+                        subscriber.channel_leave(chan)
+                        time.sleep(2)
+                        log_test.info('Left channel %d for subscriber %s' %(chan, subscriber.name))
+                        #self.recv_timeout = True
+                        #subscriber.recv_timeout = True
+                        #subscriber.channel_receive(chan, cb = subscriber.recv_channel_cb, count=1)
+                        #self.recv_timeout = False
+                        #subscriber.recv_timeout = False
+                        #log_test.info('Verified receive for channel %d, subscriber %s' %(chan, subscriber.name))
+                        #time.sleep(1)
+
+                  self.test_status = True
+                  return self.test_status
+
       def generate_port_list(self, subscribers, channels):
             return self.port_list[:subscribers]
 
@@ -1199,6 +1216,18 @@
           self.leave_flag = True
           assert_equal(test_status, True)
 
+      def test_cord_subscriber_leave(self):
+          """Test subscriber leaves for all the join nexts before"""
+          self.num_subscribers = self.num_ports * len(self.switches)
+          self.num_channels = 5
+          test_status = self.subscriber_join_verify(num_subscribers = self.num_subscribers,
+                                                    num_channels = self.num_channels,
+                                                    cbs = (self.tls_verify, self.dhcp_next_verify,
+                                                           self.igmp_leave_verify, self.traffic_verify),
+                                                    port_list = self.generate_port_list(self.num_subscribers,
+                                                                                        self.num_channels))
+          assert_equal(test_status, True)
+
       #@deferred(SUBSCRIBER_TIMEOUT)
       def test_cord_subscriber_authentication_with_invalid_certificate_and_channel_surfing(self):
           ### """Test subscriber to auth with invalidCertification and join channel"""