X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fyaz-pdu-assoc.cpp;h=0462f5ae61be58c905e34e04d20dbabac8b43da6;hb=355215b6f2c914f2eb099dda88828b8f0c8cb001;hp=084c4e9ab92e1fafee1c262a1be890f497719966;hpb=35cfa3b3d2c9b8adb8c4bfd4c95620929e35466b;p=yazpp-moved-to-github.git diff --git a/src/yaz-pdu-assoc.cpp b/src/yaz-pdu-assoc.cpp index 084c4e9..0462f5a 100644 --- a/src/yaz-pdu-assoc.cpp +++ b/src/yaz-pdu-assoc.cpp @@ -3,7 +3,17 @@ * See the file LICENSE for details. * * $Log: yaz-pdu-assoc.cpp,v $ - * Revision 1.14 2000-09-12 12:09:53 adam + * Revision 1.17 2000-10-11 11:58:16 adam + * Moved header files to include/yaz++. Switched to libtool and automake. + * Configure script creates yaz++-config script. + * + * Revision 1.16 2000/09/22 09:54:11 heikki + * minor + * + * Revision 1.15 2000/09/21 21:43:20 adam + * Better high-level server API. + * + * Revision 1.14 2000/09/12 12:09:53 adam * More work on high-level server. * * Revision 1.13 2000/09/08 10:23:42 adam @@ -54,7 +64,7 @@ #include -#include +#include #include #include @@ -138,18 +148,8 @@ void Yaz_PDU_Assoc::socketNotify(int event) int fd = cs_fileno(new_line); logf (m_log, "accept ok fd = %d", fd); cs_fileno(new_line) = -1; - cs_close (new_line); /* potential problem ... */ -#if 1 + cs_close (new_line); childNotify(fd); -#else - Yaz_PDU_Assoc *assoc = new Yaz_PDU_Assoc (m_socketObservable); - assoc->m_parent = this; - assoc->m_next = m_children; - m_children = assoc; - - assoc->m_PDU_Observer = m_PDU_Observer->clone(assoc); - socket(fd); -#endif } } else if (m_state == Ready) @@ -398,22 +398,24 @@ void Yaz_PDU_Assoc::socket(IYaz_PDU_Observer *observer, int fd) } #if 1 + // 1 = single-threaded + // 0 = multi-threaded // Single-threaded... Only useful for non-blocking handlers void Yaz_PDU_Assoc::childNotify(int fd) { - /// Clone PDU Observable (keep socket manager) + // Clone PDU Observable (keep socket manager) IYaz_PDU_Observable *new_observable = clone(); - /// Clone PDU Observer + // Clone PDU Observer IYaz_PDU_Observer *observer = m_PDU_Observer->clone(new_observable); - /// Attach new socket to it + // Attach new socket to it new_observable->socket(observer, fd); } #else -#include +#include #ifdef WIN32 #include