2 * Copyright (c) 1998-1999, Index Data.
3 * See the file LICENSE for details.
4 * Sebastian Hammer, Adam Dickmeiss
6 * $Log: yaz-socket-manager.cpp,v $
7 * Revision 1.9 2000-08-07 14:19:59 adam
8 * Fixed serious bug regarding timeouts. Improved logging for proxy.
10 * Revision 1.8 1999/12/06 13:52:45 adam
11 * Modified for new location of YAZ header files. Experimental threaded
14 * Revision 1.7 1999/04/28 13:02:08 adam
15 * Added include of string.h.
17 * Revision 1.6 1999/04/21 12:09:01 adam
18 * Many improvements. Modified to proxy server to work with "sessions"
21 * Revision 1.5 1999/04/09 11:46:57 adam
22 * Added object Yaz_Z_Assoc. Much more functional client.
24 * Revision 1.4 1999/03/23 14:17:57 adam
25 * More work on timeout handling. Work on yaz-client.
27 * Revision 1.3 1999/02/02 14:01:23 adam
28 * First WIN32 port of YAZ++.
30 * Revision 1.2 1999/01/28 13:08:48 adam
31 * Yaz_PDU_Assoc better encapsulated. Memory leak fix in
32 * yaz-socket-manager.cc.
34 * Revision 1.1.1.1 1999/01/28 09:41:07 adam
35 * First implementation of YAZ++.
43 #include <sys/types.h>
50 #include <yaz-socket-manager.h>
53 Yaz_SocketManager::YazSocketEntry **Yaz_SocketManager::lookupObserver(
54 IYazSocketObserver *observer)
58 for (se = &m_observers; *se; se = &(*se)->next)
59 if ((*se)->observer == observer)
64 void Yaz_SocketManager::addObserver(int fd, IYazSocketObserver *observer)
68 se = *lookupObserver(observer);
71 se = new YazSocketEntry;
72 se->next= m_observers;
74 se->observer = observer;
78 se->last_activity = 0;
82 void Yaz_SocketManager::deleteObserver(IYazSocketObserver *observer)
84 YazSocketEntry **se = lookupObserver(observer);
87 removeEvent (observer);
88 YazSocketEntry *se_tmp = *se;
94 void Yaz_SocketManager::deleteObservers()
96 YazSocketEntry *se = m_observers;
100 YazSocketEntry *se_next = se->next;
107 void Yaz_SocketManager::maskObserver(IYazSocketObserver *observer, int mask)
111 se = *lookupObserver(observer);
116 void Yaz_SocketManager::timeoutObserver(IYazSocketObserver *observer,
121 se = *lookupObserver(observer);
123 se->timeout = timeout;
126 int Yaz_SocketManager::processEvent()
129 YazSocketEvent *event = getEvent();
130 unsigned timeout = 0;
131 logf (m_log, "processEvent");
134 event->observer->socketNotify(event->event);
139 fd_set in, out, except;
148 time_t now = time(0);
149 for (p = m_observers; p; p = p->next)
154 if (p->mask & YAZ_SOCKET_OBSERVE_READ)
156 if (p->mask & YAZ_SOCKET_OBSERVE_WRITE)
158 if (p->mask & YAZ_SOCKET_OBSERVE_EXCEPT)
164 unsigned timeout_this;
165 timeout_this = p->timeout;
166 if (p->last_activity)
167 timeout_this -= now - p->last_activity;
168 if (timeout_this < 1)
170 if (!timeout || timeout_this < timeout)
171 timeout = timeout_this;
176 logf (m_log, "no pending events return 0");
178 logf (m_log, "no observers");
186 logf (m_log, "select pending=%d timeout=%d", no, timeout);
187 while ((res = select(max + 1, &in, &out, &except, timeout ? &to : 0)) < 0)
191 for (p = m_observers; p; p = p->next)
195 if (FD_ISSET(fd, &in))
196 mask |= YAZ_SOCKET_OBSERVE_READ;
198 if (FD_ISSET(fd, &out))
199 mask |= YAZ_SOCKET_OBSERVE_WRITE;
201 if (FD_ISSET(fd, &except))
202 mask |= YAZ_SOCKET_OBSERVE_EXCEPT;
206 YazSocketEvent *event = new YazSocketEvent;
207 p->last_activity = now;
208 event->observer = p->observer;
212 else if (p->timeout && p->last_activity &&
213 now >= p->last_activity + (int) (p->timeout))
215 YazSocketEvent *event = new YazSocketEvent;
216 logf (LOG_LOG, "timeout now = %ld last_activity=%ld timeout=%d",
217 now, p->last_activity, p->timeout);
218 p->last_activity = now;
219 event->observer = p->observer;
220 event->event = YAZ_SOCKET_OBSERVE_TIMEOUT;
224 if ((event = getEvent()))
226 event->observer->socketNotify(event->event);
233 void Yaz_SocketManager::putEvent(YazSocketEvent *event)
235 // put in back of queue
238 m_queue_back->prev = event;
239 assert (m_queue_front);
243 assert (!m_queue_front);
244 m_queue_front = event;
246 event->next = m_queue_back;
248 m_queue_back = event;
251 Yaz_SocketManager::YazSocketEvent *Yaz_SocketManager::getEvent()
253 // get from front of queue
254 YazSocketEvent *event = m_queue_front;
257 assert (m_queue_back);
258 m_queue_front = event->prev;
261 assert (m_queue_back);
262 m_queue_front->next = 0;
269 void Yaz_SocketManager::removeEvent(IYazSocketObserver *observer)
271 YazSocketEvent *ev = m_queue_back;
274 YazSocketEvent *ev_next = ev->next;
275 if (observer == ev->observer)
278 ev->prev->next = ev->next;
280 m_queue_back = ev->next;
282 ev->next->prev = ev->prev;
284 m_queue_front = ev->prev;
291 Yaz_SocketManager::Yaz_SocketManager()
299 Yaz_SocketManager::~Yaz_SocketManager()