X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fyaz-socket-manager.cpp;h=89dc9bbf696719401cd43694892c1dcafe88b725;hb=d3d51bee2100324025f7530d4e3ff3502397fd83;hp=d8e1ef2f9ee52a8d4f89f4f13765a3429e7c3e57;hpb=e3133d2f2c580f76c9da2e7621c74a064f0955c9;p=yazpp-moved-to-github.git diff --git a/src/yaz-socket-manager.cpp b/src/yaz-socket-manager.cpp index d8e1ef2..89dc9bb 100644 --- a/src/yaz-socket-manager.cpp +++ b/src/yaz-socket-manager.cpp @@ -1,45 +1,8 @@ /* - * Copyright (c) 1998-2000, Index Data. + * Copyright (c) 1998-2004, Index Data. * See the file LICENSE for details. * - * $Log: yaz-socket-manager.cpp,v $ - * Revision 1.11 2000-10-11 11:58:17 adam - * Moved header files to include/yaz++. Switched to libtool and automake. - * Configure script creates yaz++-config script. - * - * Revision 1.10 2000/09/08 10:23:42 adam - * Added skeleton of yaz-z-server. - * - * Revision 1.9 2000/08/07 14:19:59 adam - * Fixed serious bug regarding timeouts. Improved logging for proxy. - * - * Revision 1.8 1999/12/06 13:52:45 adam - * Modified for new location of YAZ header files. Experimental threaded - * operation. - * - * Revision 1.7 1999/04/28 13:02:08 adam - * Added include of string.h. - * - * Revision 1.6 1999/04/21 12:09:01 adam - * Many improvements. Modified to proxy server to work with "sessions" - * based on cookies. - * - * Revision 1.5 1999/04/09 11:46:57 adam - * Added object Yaz_Z_Assoc. Much more functional client. - * - * Revision 1.4 1999/03/23 14:17:57 adam - * More work on timeout handling. Work on yaz-client. - * - * Revision 1.3 1999/02/02 14:01:23 adam - * First WIN32 port of YAZ++. - * - * Revision 1.2 1999/01/28 13:08:48 adam - * Yaz_PDU_Assoc better encapsulated. Memory leak fix in - * yaz-socket-manager.cc. - * - * Revision 1.1.1.1 1999/01/28 09:41:07 adam - * First implementation of YAZ++. - * + * $Id: yaz-socket-manager.cpp,v 1.27 2004-02-26 23:42:27 adam Exp $ */ #include #ifdef WIN32 @@ -53,7 +16,7 @@ #include #include -#include +#include Yaz_SocketManager::YazSocketEntry **Yaz_SocketManager::lookupObserver( IYazSocketObserver *observer) @@ -81,7 +44,7 @@ void Yaz_SocketManager::addObserver(int fd, IYazSocketObserver *observer) se->fd = fd; se->mask = 0; se->last_activity = 0; - se->timeout = 0; + se->timeout = -1; } void Yaz_SocketManager::deleteObserver(IYazSocketObserver *observer) @@ -113,13 +76,18 @@ void Yaz_SocketManager::maskObserver(IYazSocketObserver *observer, int mask) { YazSocketEntry *se; + yaz_log(m_log, "obs=%p read=%d write=%d except=%d", observer, + mask & YAZ_SOCKET_OBSERVE_READ, + mask & YAZ_SOCKET_OBSERVE_WRITE, + mask & YAZ_SOCKET_OBSERVE_EXCEPT); + se = *lookupObserver(observer); if (se) se->mask = mask; } void Yaz_SocketManager::timeoutObserver(IYazSocketObserver *observer, - unsigned timeout) + int timeout) { YazSocketEntry *se; @@ -132,8 +100,8 @@ int Yaz_SocketManager::processEvent() { YazSocketEntry *p; YazSocketEvent *event = getEvent(); - unsigned timeout = 0; - logf (m_log, "processEvent"); + int timeout = -1; + yaz_log (m_log, "Yaz_SocketManager::processEvent manager=%p", this); if (event) { event->observer->socketNotify(event->event); @@ -157,30 +125,45 @@ int Yaz_SocketManager::processEvent() if (p->mask) no++; if (p->mask & YAZ_SOCKET_OBSERVE_READ) + { + yaz_log (m_log, "Yaz_SocketManager::select fd=%d read", fd); FD_SET(fd, &in); + } if (p->mask & YAZ_SOCKET_OBSERVE_WRITE) + { + yaz_log (m_log, "Yaz_SocketManager::select fd=%d write", fd); FD_SET(fd, &out); + } if (p->mask & YAZ_SOCKET_OBSERVE_EXCEPT) + { + yaz_log (m_log, "Yaz_SocketManager::select fd=%d except", fd); FD_SET(fd, &except); + } if (fd > max) max = fd; - if (p->timeout) + if (p->timeout > 0 || + (p->timeout == 0 && (p->mask & YAZ_SOCKET_OBSERVE_WRITE) == 0)) { - unsigned timeout_this; + int timeout_this; timeout_this = p->timeout; if (p->last_activity) timeout_this -= now - p->last_activity; - if (timeout_this < 1) - timeout_this = 1; - if (!timeout || timeout_this < timeout) + else + p->last_activity = now; + if (timeout_this < 0 || timeout_this > 2147483646) + timeout_this = 0; + if (timeout == -1 || timeout_this < timeout) timeout = timeout_this; + p->timeout_this = timeout_this; + yaz_log (m_log, "Yaz_SocketManager::select timeout_this=%d", + p->timeout_this); } } if (!no) { - logf (m_log, "no pending events return 0"); + yaz_log (m_log, "no pending events return 0"); if (!m_observers) - logf (m_log, "no observers"); + yaz_log (m_log, "no observers"); return 0; } @@ -188,10 +171,20 @@ int Yaz_SocketManager::processEvent() to.tv_sec = timeout; to.tv_usec = 0; - logf (m_log, "select pending=%d timeout=%d", no, timeout); - while ((res = select(max + 1, &in, &out, &except, timeout ? &to : 0)) < 0) + yaz_log (m_log, "Yaz_SocketManager::select begin no=%d timeout=%d", + no, timeout); + int pass = 0; + while ((res = select(max + 1, &in, &out, &except, + timeout== -1 ? 0 : &to)) < 0) if (errno != EINTR) - return -1; + { + yaz_log(LOG_ERRNO|LOG_WARN, "select"); + yaz_log(LOG_WARN, "errno=%d max=%d timeout=%d", + errno, max, timeout); + if (++pass > 10) + return -1; + } + yaz_log(m_log, "select returned res=%d", res); now = time(0); for (p = m_observers; p; p = p->next) { @@ -213,13 +206,19 @@ int Yaz_SocketManager::processEvent() event->observer = p->observer; event->event = mask; putEvent (event); + + yaz_log (m_log, "putEvent I/O mask=%d", mask); } - else if (p->timeout && p->last_activity && - now >= p->last_activity + (int) (p->timeout)) + else if ( + (p->timeout > 0 || + (p->timeout == 0 && (p->mask & YAZ_SOCKET_OBSERVE_WRITE) == 0)) + && + (now - p->last_activity) >= p->timeout) { YazSocketEvent *event = new YazSocketEvent; - logf (LOG_LOG, "timeout now = %ld last_activity=%ld timeout=%d", - now, p->last_activity, p->timeout); + assert (p->last_activity); + yaz_log (m_log, "putEvent timeout, now = %ld last_activity=%ld timeout=%d", + now, p->last_activity, p->timeout); p->last_activity = now; event->observer = p->observer; event->event = YAZ_SOCKET_OBSERVE_TIMEOUT; @@ -232,9 +231,14 @@ int Yaz_SocketManager::processEvent() delete event; return 1; } - return 0; + yaz_log (LOG_WARN, "unhandled event in processEvent"); + return 1; } + +// n p n p ...... n p n p +// front back + void Yaz_SocketManager::putEvent(YazSocketEvent *event) { // put in back of queue