- yaz_log(m_p->log, "cs_rcvconnect");
- int res = cs_rcvconnect(m_p->cs);
- if (res == 1)
- {
- unsigned mask = SOCKET_OBSERVE_EXCEPT;
- if (m_p->cs->io_pending & CS_WANT_WRITE)
- mask |= SOCKET_OBSERVE_WRITE;
- if (m_p->cs->io_pending & CS_WANT_READ)
- mask |= SOCKET_OBSERVE_READ;
- yaz_log(m_p->log, "maskObserver 3");
- m_p->m_socketObservable->maskObserver(this, mask);
- }
- else
- {
- m_p->state = PDU_Assoc_priv::Ready;
- if (m_PDU_Observer)
- m_PDU_Observer->connectNotify();
- flush_PDU();
- }