- if (event & YAZ_SOCKET_OBSERVE_READ &&
- event & YAZ_SOCKET_OBSERVE_WRITE)
- {
- // For Unix: if both read and write is set, then connect failed.
- close();
- m_PDU_Observer->failNotify();
- }
- else
- {
- yaz_log (m_log, "cs_rcvconnect");
- int res = cs_rcvconnect (m_cs);
- if (res == 1)
- {
- unsigned mask = YAZ_SOCKET_OBSERVE_EXCEPT;
- if (m_cs->io_pending & CS_WANT_WRITE)
- mask |= YAZ_SOCKET_OBSERVE_WRITE;
- if (m_cs->io_pending & CS_WANT_READ)
- mask |= YAZ_SOCKET_OBSERVE_READ;
- yaz_log(m_log, "maskObserver 3");
- m_socketObservable->maskObserver(this, mask);
- }
- else
- {
- m_state = Ready;
- if (m_PDU_Observer)
- m_PDU_Observer->connectNotify();
- flush_PDU();
- }
- }
- break;
+ if (event & SOCKET_OBSERVE_READ &&
+ event & SOCKET_OBSERVE_WRITE)
+ {
+ // For Unix: if both read and write is set, then connect failed.
+ shutdown();
+ m_PDU_Observer->failNotify();
+ }
+ else
+ {
+ yaz_log (m_log, "cs_rcvconnect");
+ int res = cs_rcvconnect (m_cs);
+ if (res == 1)
+ {
+ unsigned mask = SOCKET_OBSERVE_EXCEPT;
+ if (m_cs->io_pending & CS_WANT_WRITE)
+ mask |= SOCKET_OBSERVE_WRITE;
+ if (m_cs->io_pending & CS_WANT_READ)
+ mask |= SOCKET_OBSERVE_READ;
+ yaz_log(m_log, "maskObserver 3");
+ m_socketObservable->maskObserver(this, mask);
+ }
+ else
+ {
+ m_state = Ready;
+ if (m_PDU_Observer)
+ m_PDU_Observer->connectNotify();
+ flush_PDU();
+ }
+ }
+ break;