| 430 | assert rcond == cond, (rcond, cond) |
| 431 | |
| 432 | def test_cleanup(self): |
| 433 | snd, rcv = self.link("test-link") |
| 434 | snd.open() |
| 435 | rcv.open() |
| 436 | self.pump() |
| 437 | snd_ssn = snd.session |
| 438 | rcv_ssn = rcv.session |
| 439 | assert rcv_ssn.state == Endpoint.LOCAL_ACTIVE | Endpoint.REMOTE_ACTIVE |
| 440 | self.ssn = None |
| 441 | snd_ssn.close() |
| 442 | snd_ssn.free() |
| 443 | del snd_ssn |
| 444 | gc.collect() |
| 445 | self.pump() |
| 446 | assert rcv_ssn.state == Endpoint.LOCAL_ACTIVE | Endpoint.REMOTE_CLOSED |
| 447 | |
| 448 | def test_reopen_on_same_session_without_free(self): |
| 449 | """ |