| 600 | assert self.rcv.state == Endpoint.LOCAL_CLOSED | Endpoint.REMOTE_CLOSED |
| 601 | |
| 602 | def test_multiple(self): |
| 603 | rcv = self.snd.session.receiver("second-rcv") |
| 604 | assert rcv.name == "second-rcv" |
| 605 | self.snd.open() |
| 606 | rcv.open() |
| 607 | self.pump() |
| 608 | c2 = self.rcv.session.connection |
| 609 | link = c2.link_head(Endpoint.LOCAL_UNINIT | Endpoint.REMOTE_ACTIVE) |
| 610 | while link: |
| 611 | link.open() |
| 612 | link = link.next(Endpoint.LOCAL_UNINIT | Endpoint.REMOTE_ACTIVE) |
| 613 | self.pump() |
| 614 | |
| 615 | assert self.snd |
| 616 | assert rcv |
| 617 | self.snd.close() |
| 618 | rcv.close() |
| 619 | ssn = rcv.session |
| 620 | conn = ssn.connection |
| 621 | ssn.close() |
| 622 | conn.close() |
| 623 | self.pump() |
| 624 | |
| 625 | def test_closing_session(self): |
| 626 | self.snd.open() |