34         self.inner.now = timestamp;  in join_multicast_group()
39                     .inner  in join_multicast_group()
46                 } else if let Some(pkt) = self.inner.igmp_report_packet(IgmpVersion::Version2, addr)  in join_multicast_group()
54                     self.inner  in join_multicast_group()
82         self.inner.now = timestamp;  in leave_multicast_group()
86                 let was_not_present = self.inner.ipv4_multicast_groups.remove(&addr).is_none();  in leave_multicast_group()
89                 } else if let Some(pkt) = self.inner.igmp_leave_packet(addr) {  in leave_multicast_group()
96                     self.inner  in leave_multicast_group()
113         self.inner.has_multicast_group(addr)  in has_multicast_group()
122         match self.inner.igmp_report_state {  in igmp_egress()
127             } if self.inner.now >= timeout => {  in igmp_egress()
128                 if let Some(pkt) = self.inner.igmp_report_packet(version, group) {  in igmp_egress()
130                     if let Some(tx_token) = device.transmit(self.inner.now) {  in igmp_egress()
132                         self.inner  in igmp_egress()
140                 self.inner.igmp_report_state = IgmpReportState::Inactive;  in igmp_egress()
148             } if self.inner.now >= timeout => {  in igmp_egress()
150                     .inner  in igmp_egress()
158                         if let Some(pkt) = self.inner.igmp_report_packet(version, addr) {  in igmp_egress()
160                             if let Some(tx_token) = device.transmit(self.inner.now) {  in igmp_egress()
162                                 self.inner  in igmp_egress()
170                         let next_timeout = (timeout + interval).max(self.inner.now);  in igmp_egress()
171                         self.inner.igmp_report_state = IgmpReportState::ToGeneralQuery {  in igmp_egress()
181                         self.inner.igmp_report_state = IgmpReportState::Inactive;  in igmp_egress()