2 * Copyright (c) 1998-2001, Index Data.
3 * See the file LICENSE for details.
5 * $Id: yaz-socket-manager.cpp,v 1.21 2003-12-16 11:26:14 adam Exp $
12 #include <sys/types.h>
19 #include <yaz++/socket-manager.h>
21 Yaz_SocketManager::YazSocketEntry **Yaz_SocketManager::lookupObserver(
22 IYazSocketObserver *observer)
26 for (se = &m_observers; *se; se = &(*se)->next)
27 if ((*se)->observer == observer)
32 void Yaz_SocketManager::addObserver(int fd, IYazSocketObserver *observer)
36 se = *lookupObserver(observer);
39 se = new YazSocketEntry;
40 se->next= m_observers;
42 se->observer = observer;
46 se->last_activity = 0;
50 void Yaz_SocketManager::deleteObserver(IYazSocketObserver *observer)
52 YazSocketEntry **se = lookupObserver(observer);
55 removeEvent (observer);
56 YazSocketEntry *se_tmp = *se;
62 void Yaz_SocketManager::deleteObservers()
64 YazSocketEntry *se = m_observers;
68 YazSocketEntry *se_next = se->next;
75 void Yaz_SocketManager::maskObserver(IYazSocketObserver *observer, int mask)
79 yaz_log(m_log, "obs=%p read=%d write=%d except=%d", observer,
80 mask & YAZ_SOCKET_OBSERVE_READ,
81 mask & YAZ_SOCKET_OBSERVE_WRITE,
82 mask & YAZ_SOCKET_OBSERVE_EXCEPT);
84 se = *lookupObserver(observer);
89 void Yaz_SocketManager::timeoutObserver(IYazSocketObserver *observer,
94 se = *lookupObserver(observer);
96 se->timeout = timeout;
99 int Yaz_SocketManager::processEvent()
102 YazSocketEvent *event = getEvent();
103 unsigned timeout = 0;
104 yaz_log (m_log, "Yaz_SocketManager::processEvent manager=%p", this);
107 event->observer->socketNotify(event->event);
112 fd_set in, out, except;
121 time_t now = time(0);
122 for (p = m_observers; p; p = p->next)
127 if (p->mask & YAZ_SOCKET_OBSERVE_READ)
129 yaz_log (m_log, "Yaz_SocketManager::select fd=%d read", fd);
132 if (p->mask & YAZ_SOCKET_OBSERVE_WRITE)
134 yaz_log (m_log, "Yaz_SocketManager::select fd=%d write", fd);
137 if (p->mask & YAZ_SOCKET_OBSERVE_EXCEPT)
139 yaz_log (m_log, "Yaz_SocketManager::select fd=%d except", fd);
146 unsigned timeout_this;
147 timeout_this = p->timeout;
148 if (p->last_activity)
149 timeout_this -= now - p->last_activity;
151 p->last_activity = now;
152 if (timeout_this < 1 || timeout_this > 2147483646)
154 if (!timeout || timeout_this < timeout)
155 timeout = timeout_this;
156 p->timeout_this = timeout_this;
157 yaz_log (m_log, "Yaz_SocketManager::select timeout_this=%d",
163 yaz_log (m_log, "no pending events return 0");
165 yaz_log (m_log, "no observers");
173 yaz_log (m_log, "Yaz_SocketManager::select begin no=%d timeout=%d",
175 while ((res = select(max + 1, &in, &out, &except, timeout ? &to : 0)) < 0)
178 yaz_log (LOG_LOG|LOG_WARN, "select");
182 for (p = m_observers; p; p = p->next)
186 if (FD_ISSET(fd, &in))
187 mask |= YAZ_SOCKET_OBSERVE_READ;
189 if (FD_ISSET(fd, &out))
190 mask |= YAZ_SOCKET_OBSERVE_WRITE;
192 if (FD_ISSET(fd, &except))
193 mask |= YAZ_SOCKET_OBSERVE_EXCEPT;
197 YazSocketEvent *event = new YazSocketEvent;
198 p->last_activity = now;
199 event->observer = p->observer;
203 yaz_log (m_log, "putEvent I/O mask=%d", mask);
205 else if (p->timeout && (now - p->last_activity) >= p->timeout)
207 YazSocketEvent *event = new YazSocketEvent;
208 assert (p->last_activity);
209 yaz_log (m_log, "putEvent timeout, now = %ld last_activity=%ld timeout=%d",
210 now, p->last_activity, p->timeout);
211 p->last_activity = now;
212 event->observer = p->observer;
213 event->event = YAZ_SOCKET_OBSERVE_TIMEOUT;
217 if ((event = getEvent()))
219 event->observer->socketNotify(event->event);
223 yaz_log (LOG_WARN, "unhandled event in processEvent");
228 // n p n p ...... n p n p
231 void Yaz_SocketManager::putEvent(YazSocketEvent *event)
233 // put in back of queue
236 m_queue_back->prev = event;
237 assert (m_queue_front);
241 assert (!m_queue_front);
242 m_queue_front = event;
244 event->next = m_queue_back;
246 m_queue_back = event;
249 Yaz_SocketManager::YazSocketEvent *Yaz_SocketManager::getEvent()
251 // get from front of queue
252 YazSocketEvent *event = m_queue_front;
255 assert (m_queue_back);
256 m_queue_front = event->prev;
259 assert (m_queue_back);
260 m_queue_front->next = 0;
267 void Yaz_SocketManager::removeEvent(IYazSocketObserver *observer)
269 YazSocketEvent *ev = m_queue_back;
272 YazSocketEvent *ev_next = ev->next;
273 if (observer == ev->observer)
276 ev->prev->next = ev->next;
278 m_queue_back = ev->next;
280 ev->next->prev = ev->prev;
282 m_queue_front = ev->prev;
289 Yaz_SocketManager::Yaz_SocketManager()
297 Yaz_SocketManager::~Yaz_SocketManager()