2 * Copyright (c) 1998-2000, Index Data.
3 * See the file LICENSE for details.
5 * $Log: yaz-socket-manager.cpp,v $
6 * Revision 1.14 2000-11-20 14:17:36 adam
7 * Yet another WIN32 fix for connect notify.
9 * Revision 1.13 2000/11/20 11:27:33 adam
10 * Fixes for connect operation (timeout and notify fix).
12 * Revision 1.12 2000/10/24 12:29:57 adam
13 * Fixed bug in proxy where a Yaz_ProxyClient could be owned by
14 * two Yaz_Proxy's (fatal).
16 * Revision 1.11 2000/10/11 11:58:17 adam
17 * Moved header files to include/yaz++. Switched to libtool and automake.
18 * Configure script creates yaz++-config script.
20 * Revision 1.10 2000/09/08 10:23:42 adam
21 * Added skeleton of yaz-z-server.
23 * Revision 1.9 2000/08/07 14:19:59 adam
24 * Fixed serious bug regarding timeouts. Improved logging for proxy.
26 * Revision 1.8 1999/12/06 13:52:45 adam
27 * Modified for new location of YAZ header files. Experimental threaded
30 * Revision 1.7 1999/04/28 13:02:08 adam
31 * Added include of string.h.
33 * Revision 1.6 1999/04/21 12:09:01 adam
34 * Many improvements. Modified to proxy server to work with "sessions"
37 * Revision 1.5 1999/04/09 11:46:57 adam
38 * Added object Yaz_Z_Assoc. Much more functional client.
40 * Revision 1.4 1999/03/23 14:17:57 adam
41 * More work on timeout handling. Work on yaz-client.
43 * Revision 1.3 1999/02/02 14:01:23 adam
44 * First WIN32 port of YAZ++.
46 * Revision 1.2 1999/01/28 13:08:48 adam
47 * Yaz_PDU_Assoc better encapsulated. Memory leak fix in
48 * yaz-socket-manager.cc.
50 * Revision 1.1.1.1 1999/01/28 09:41:07 adam
51 * First implementation of YAZ++.
59 #include <sys/types.h>
66 #include <yaz++/yaz-socket-manager.h>
68 Yaz_SocketManager::YazSocketEntry **Yaz_SocketManager::lookupObserver(
69 IYazSocketObserver *observer)
73 for (se = &m_observers; *se; se = &(*se)->next)
74 if ((*se)->observer == observer)
79 void Yaz_SocketManager::addObserver(int fd, IYazSocketObserver *observer)
83 se = *lookupObserver(observer);
86 se = new YazSocketEntry;
87 se->next= m_observers;
89 se->observer = observer;
93 se->last_activity = 0;
97 void Yaz_SocketManager::deleteObserver(IYazSocketObserver *observer)
99 YazSocketEntry **se = lookupObserver(observer);
102 removeEvent (observer);
103 YazSocketEntry *se_tmp = *se;
109 void Yaz_SocketManager::deleteObservers()
111 YazSocketEntry *se = m_observers;
115 YazSocketEntry *se_next = se->next;
122 void Yaz_SocketManager::maskObserver(IYazSocketObserver *observer, int mask)
126 se = *lookupObserver(observer);
131 void Yaz_SocketManager::timeoutObserver(IYazSocketObserver *observer,
136 se = *lookupObserver(observer);
138 se->timeout = timeout;
141 int Yaz_SocketManager::processEvent()
144 YazSocketEvent *event = getEvent();
145 unsigned timeout = 0;
146 logf (m_log, "processEvent");
149 event->observer->socketNotify(event->event);
154 fd_set in, out, except;
163 time_t now = time(0);
164 for (p = m_observers; p; p = p->next)
169 if (p->mask & YAZ_SOCKET_OBSERVE_READ)
171 yaz_log (m_log, "select fd=%d: read fd", fd);
174 if (p->mask & YAZ_SOCKET_OBSERVE_WRITE)
176 yaz_log (m_log, "select fd=%d: write fd", fd);
179 if (p->mask & YAZ_SOCKET_OBSERVE_EXCEPT)
181 yaz_log (m_log, "select fd=%d: except fd", fd);
188 unsigned timeout_this;
189 timeout_this = p->timeout;
190 if (p->last_activity)
191 timeout_this -= now - p->last_activity;
193 p->last_activity = now;
194 if (timeout_this < 1)
196 if (!timeout || timeout_this < timeout)
197 timeout = timeout_this;
202 logf (m_log, "no pending events return 0");
204 logf (m_log, "no observers");
212 logf (m_log, "select pending=%d timeout=%d", no, timeout);
213 while ((res = select(max + 1, &in, &out, &except, timeout ? &to : 0)) < 0)
217 for (p = m_observers; p; p = p->next)
221 if (FD_ISSET(fd, &in))
222 mask |= YAZ_SOCKET_OBSERVE_READ;
224 if (FD_ISSET(fd, &out))
225 mask |= YAZ_SOCKET_OBSERVE_WRITE;
227 if (FD_ISSET(fd, &except))
228 mask |= YAZ_SOCKET_OBSERVE_EXCEPT;
232 YazSocketEvent *event = new YazSocketEvent;
233 p->last_activity = now;
234 event->observer = p->observer;
238 else if (p->timeout && p->last_activity &&
239 now >= p->last_activity + (int) (p->timeout))
241 YazSocketEvent *event = new YazSocketEvent;
242 logf (m_log, "timeout, now = %ld last_activity=%ld timeout=%d",
243 now, p->last_activity, p->timeout);
244 p->last_activity = now;
245 event->observer = p->observer;
246 event->event = YAZ_SOCKET_OBSERVE_TIMEOUT;
250 if ((event = getEvent()))
252 event->observer->socketNotify(event->event);
260 // n p n p ...... n p n p
263 void Yaz_SocketManager::putEvent(YazSocketEvent *event)
265 // put in back of queue
268 m_queue_back->prev = event;
269 assert (m_queue_front);
273 assert (!m_queue_front);
274 m_queue_front = event;
276 event->next = m_queue_back;
278 m_queue_back = event;
281 Yaz_SocketManager::YazSocketEvent *Yaz_SocketManager::getEvent()
283 // get from front of queue
284 YazSocketEvent *event = m_queue_front;
287 assert (m_queue_back);
288 m_queue_front = event->prev;
291 assert (m_queue_back);
292 m_queue_front->next = 0;
299 void Yaz_SocketManager::removeEvent(IYazSocketObserver *observer)
301 YazSocketEvent *ev = m_queue_back;
304 YazSocketEvent *ev_next = ev->next;
305 if (observer == ev->observer)
308 ev->prev->next = ev->next;
310 m_queue_back = ev->next;
312 ev->next->prev = ev->prev;
314 m_queue_front = ev->prev;
321 Yaz_SocketManager::Yaz_SocketManager()
329 Yaz_SocketManager::~Yaz_SocketManager()