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.6 1999-04-21 12:09:01 adam
8 * Many improvements. Modified to proxy server to work with "sessions"
11 * Revision 1.5 1999/04/09 11:46:57 adam
12 * Added object Yaz_Z_Assoc. Much more functional client.
14 * Revision 1.4 1999/03/23 14:17:57 adam
15 * More work on timeout handling. Work on yaz-client.
17 * Revision 1.3 1999/02/02 14:01:23 adam
18 * First WIN32 port of YAZ++.
20 * Revision 1.2 1999/01/28 13:08:48 adam
21 * Yaz_PDU_Assoc better encapsulated. Memory leak fix in
22 * yaz-socket-manager.cc.
24 * Revision 1.1.1.1 1999/01/28 09:41:07 adam
25 * First implementation of YAZ++.
33 #include <sys/types.h>
39 #include <yaz-socket-manager.h>
42 Yaz_SocketManager::YazSocketEntry **Yaz_SocketManager::lookupObserver(
43 IYazSocketObserver *observer)
47 for (se = &m_observers; *se; se = &(*se)->next)
48 if ((*se)->observer == observer)
53 void Yaz_SocketManager::addObserver(int fd, IYazSocketObserver *observer)
57 se = *lookupObserver(observer);
60 se = new YazSocketEntry;
61 se->next= m_observers;
63 se->observer = observer;
67 se->last_activity = 0;
71 void Yaz_SocketManager::deleteObserver(IYazSocketObserver *observer)
73 YazSocketEntry **se = lookupObserver(observer);
76 removeEvent (observer);
77 YazSocketEntry *se_tmp = *se;
83 void Yaz_SocketManager::deleteObservers()
85 YazSocketEntry *se = m_observers;
89 YazSocketEntry *se_next = se->next;
96 void Yaz_SocketManager::maskObserver(IYazSocketObserver *observer, int mask)
100 se = *lookupObserver(observer);
105 void Yaz_SocketManager::timeoutObserver(IYazSocketObserver *observer,
110 se = *lookupObserver(observer);
112 se->timeout = timeout;
115 int Yaz_SocketManager::processEvent()
118 YazSocketEvent *event = getEvent();
119 unsigned timeout = 0;
120 logf (LOG_LOG, "processEvent");
123 event->observer->socketNotify(event->event);
128 fd_set in, out, except;
137 time_t now = time(0);
138 for (p = m_observers; p; p = p->next)
143 if (p->mask & YAZ_SOCKET_OBSERVE_READ)
145 if (p->mask & YAZ_SOCKET_OBSERVE_WRITE)
147 if (p->mask & YAZ_SOCKET_OBSERVE_EXCEPT)
153 unsigned timeout_this;
154 timeout_this = p->timeout;
155 if (p->last_activity)
156 timeout_this -= now - p->last_activity;
157 if (timeout_this < 1)
159 if (!timeout || timeout_this < timeout)
160 timeout = timeout_this;
165 logf (LOG_LOG, "no pending events return 0");
167 logf (LOG_LOG, "no observers");
175 logf (LOG_LOG, "timeout=%d", timeout);
176 while ((res = select(max + 1, &in, &out, &except, timeout ? &to : 0)) < 0)
180 for (p = m_observers; p; p = p->next)
184 if (FD_ISSET(fd, &in))
185 mask |= YAZ_SOCKET_OBSERVE_READ;
187 if (FD_ISSET(fd, &out))
188 mask |= YAZ_SOCKET_OBSERVE_WRITE;
190 if (FD_ISSET(fd, &except))
191 mask |= YAZ_SOCKET_OBSERVE_EXCEPT;
195 YazSocketEvent *event = new YazSocketEvent;
196 p->last_activity = now;
197 event->observer = p->observer;
201 else if (p->timeout && now >= p->last_activity + (int) (p->timeout))
203 YazSocketEvent *event = new YazSocketEvent;
204 p->last_activity = now;
205 event->observer = p->observer;
206 event->event = YAZ_SOCKET_OBSERVE_TIMEOUT;
210 if ((event = getEvent()))
212 event->observer->socketNotify(event->event);
219 void Yaz_SocketManager::putEvent(YazSocketEvent *event)
221 // put in back of queue
224 m_queue_back->prev = event;
225 assert (m_queue_front);
229 assert (!m_queue_front);
230 m_queue_front = event;
232 event->next = m_queue_back;
234 m_queue_back = event;
237 Yaz_SocketManager::YazSocketEvent *Yaz_SocketManager::getEvent()
239 // get from front of queue
240 YazSocketEvent *event = m_queue_front;
243 assert (m_queue_back);
244 m_queue_front = event->prev;
247 assert (m_queue_back);
248 m_queue_front->next = 0;
255 void Yaz_SocketManager::removeEvent(IYazSocketObserver *observer)
257 YazSocketEvent *ev = m_queue_back;
260 YazSocketEvent *ev_next = ev->next;
261 if (observer == ev->observer)
264 ev->prev->next = ev->next;
266 m_queue_back = ev->next;
268 ev->next->prev = ev->prev;
270 m_queue_front = ev->prev;
277 Yaz_SocketManager::Yaz_SocketManager()
284 Yaz_SocketManager::~Yaz_SocketManager()