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.4 1999-03-23 14:17:57 adam
8 * More work on timeout handling. Work on yaz-client.
10 * Revision 1.3 1999/02/02 14:01:23 adam
11 * First WIN32 port of YAZ++.
13 * Revision 1.2 1999/01/28 13:08:48 adam
14 * Yaz_PDU_Assoc better encapsulated. Memory leak fix in
15 * yaz-socket-manager.cc.
17 * Revision 1.1.1.1 1999/01/28 09:41:07 adam
18 * First implementation of YAZ++.
26 #include <sys/types.h>
32 #include <yaz-socket-manager.h>
35 Yaz_SocketManager::YazSocketEntry **Yaz_SocketManager::lookupObserver(
36 IYazSocketObserver *observer)
40 for (se = &m_observers; *se; se = &(*se)->next)
41 if ((*se)->observer == observer)
46 void Yaz_SocketManager::addObserver(int fd, IYazSocketObserver *observer)
50 se = *lookupObserver(observer);
53 se = new YazSocketEntry;
54 se->next= m_observers;
56 se->observer = observer;
60 se->last_activity = 0;
64 void Yaz_SocketManager::deleteObserver(IYazSocketObserver *observer)
66 YazSocketEntry **se = lookupObserver(observer);
69 removeEvent (observer);
70 YazSocketEntry *se_tmp = *se;
76 void Yaz_SocketManager::deleteObservers()
78 YazSocketEntry *se = m_observers;
82 YazSocketEntry *se_next = se->next;
89 void Yaz_SocketManager::maskObserver(IYazSocketObserver *observer, int mask)
93 se = *lookupObserver(observer);
98 void Yaz_SocketManager::timeoutObserver(IYazSocketObserver *observer,
103 se = *lookupObserver(observer);
105 se->timeout = timeout;
108 int Yaz_SocketManager::processEvent()
111 YazSocketEvent *event = getEvent();
112 unsigned timeout = 0;
115 event->observer->socketNotify(event->event);
120 fd_set in, out, except;
129 time_t now = time(0);
130 for (p = m_observers; p; p = p->next)
135 if (p->mask & YAZ_SOCKET_OBSERVE_READ)
137 if (p->mask & YAZ_SOCKET_OBSERVE_WRITE)
139 if (p->mask & YAZ_SOCKET_OBSERVE_EXCEPT)
145 unsigned timeout_this;
146 timeout_this = p->timeout;
147 if (p->last_activity)
148 timeout_this -= now - p->last_activity;
149 if (timeout_this < 1)
151 if (!timeout || timeout_this < timeout)
152 timeout = timeout_this;
162 while ((res = select(max + 1, &in, &out, &except, timeout ? &to : 0)) < 0)
166 for (p = m_observers; p; p = p->next)
170 if (FD_ISSET(fd, &in))
171 mask |= YAZ_SOCKET_OBSERVE_READ;
173 if (FD_ISSET(fd, &out))
174 mask |= YAZ_SOCKET_OBSERVE_WRITE;
176 if (FD_ISSET(fd, &except))
177 mask |= YAZ_SOCKET_OBSERVE_EXCEPT;
181 YazSocketEvent *event = new YazSocketEvent;
182 p->last_activity = now;
183 event->observer = p->observer;
187 else if (p->timeout && now >= p->last_activity + (int) (p->timeout))
189 YazSocketEvent *event = new YazSocketEvent;
190 p->last_activity = now;
191 event->observer = p->observer;
192 event->event = YAZ_SOCKET_OBSERVE_TIMEOUT;
196 if ((event = getEvent()))
198 event->observer->socketNotify(event->event);
205 void Yaz_SocketManager::putEvent(YazSocketEvent *event)
207 // put in back of queue
210 m_queue_back->prev = event;
211 assert (m_queue_front);
215 assert (!m_queue_front);
216 m_queue_front = event;
218 event->next = m_queue_back;
220 m_queue_back = event;
223 Yaz_SocketManager::YazSocketEvent *Yaz_SocketManager::getEvent()
225 // get from front of queue
226 YazSocketEvent *event = m_queue_front;
229 assert (m_queue_back);
230 m_queue_front = event->prev;
233 assert (m_queue_back);
234 m_queue_front->next = 0;
241 void Yaz_SocketManager::removeEvent(IYazSocketObserver *observer)
243 YazSocketEvent *ev = m_queue_back;
246 YazSocketEvent *ev_next = ev->next;
247 if (observer == ev->observer)
250 ev->prev->next = ev->next;
252 m_queue_back = ev->next;
254 ev->next->prev = ev->prev;
256 m_queue_front = ev->prev;
263 Yaz_SocketManager::Yaz_SocketManager()
270 Yaz_SocketManager::~Yaz_SocketManager()