  def xxx_test_reopen_on_same_session(self):
    ssn1 = self.snd.session
    ssn2 = self.rcv.session

    self.snd.open()
    self.rcv.open()
    self.pump()

    assert self.snd.state == Endpoint.LOCAL_ACTIVE | Endpoint.REMOTE_ACTIVE
    assert self.rcv.state == Endpoint.LOCAL_ACTIVE | Endpoint.REMOTE_ACTIVE

    self.snd.close()
    self.rcv.close()
    self.pump()

    assert self.snd.state == Endpoint.LOCAL_CLOSED | Endpoint.REMOTE_CLOSED
    assert self.rcv.state == Endpoint.LOCAL_CLOSED | Endpoint.REMOTE_CLOSED

    print self.snd._link
    self.snd = ssn1.sender("test-link")
    print self.snd._link
    self.rcv = ssn2.receiver("test-link")
    self.snd.open()
    self.rcv.open()
    self.pump()

    assert self.snd.state == Endpoint.LOCAL_ACTIVE | Endpoint.REMOTE_ACTIVE
    assert self.rcv.state == Endpoint.LOCAL_ACTIVE | Endpoint.REMOTE_ACTIVE

class SessionPipelineTest(PeerTest):

  def xxx_test(self):
    self.connection.open()
    self.peer.open()
    self.pump()
    ssn = self.connection.session()
    ssn.open()
    self.pump()
    peer_ssn = self.peer.session_head(0)
    ssn.close()
    self.pump()
    peer_ssn.close()
    self.peer.close()
    self.pump()