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.1 1999-01-28 09:41:07 adam
16 #include <sys/types.h>
22 #include <yaz-socket-manager.h>
25 Yaz_SocketManager::YazSocketEntry **Yaz_SocketManager::lookupObserver(
26 IYazSocketObserver *observer)
30 for (se = &m_observers; *se; se = &(*se)->next)
31 if ((*se)->observer == observer)
36 void Yaz_SocketManager::addObserver(int fd, IYazSocketObserver *observer)
40 se = *lookupObserver(observer);
43 se = new YazSocketEntry;
44 se->next= m_observers;
46 se->observer = observer;
52 void Yaz_SocketManager::deleteObserver(IYazSocketObserver *observer)
54 YazSocketEntry **se = lookupObserver(observer);
57 removeEvent (observer);
58 YazSocketEntry *se_tmp = *se;
64 void Yaz_SocketManager::deleteObservers()
66 YazSocketEntry *se = m_observers;
70 YazSocketEntry *se_next = se->next;
77 void Yaz_SocketManager::maskObserver(IYazSocketObserver *observer, int mask)
81 se = *lookupObserver(observer);
86 void Yaz_SocketManager::timeoutObserver(IYazSocketObserver *observer,
91 se = *lookupObserver(observer);
93 se->timeout = timeout;
96 int Yaz_SocketManager::processEvent()
98 YazSocketEvent *event = getEvent();
101 event->observer->socketNotify(event->event);
105 fd_set in, out, except;
110 struct timeval *timeout = &to;
116 timeout = &to; /* hang on select */
120 for (YazSocketEntry *p = m_observers; p; p = p->next)
123 logf (LOG_LOG, "fd = %d mask=%d", fd, p->mask);
126 if (p->mask & YAZ_SOCKET_OBSERVE_READ)
128 if (p->mask & YAZ_SOCKET_OBSERVE_WRITE)
130 if (p->mask & YAZ_SOCKET_OBSERVE_EXCEPT)
137 while ((res = select(max + 1, &in, &out, &except, timeout)) < 0)
141 for (YazSocketEntry * p = m_observers; p; p = p->next)
145 if (FD_ISSET(fd, &in))
146 mask |= YAZ_SOCKET_OBSERVE_READ;
148 if (FD_ISSET(fd, &out))
149 mask |= YAZ_SOCKET_OBSERVE_WRITE;
151 if (FD_ISSET(fd, &except))
152 mask |= YAZ_SOCKET_OBSERVE_EXCEPT;
156 YazSocketEvent *event = new YazSocketEvent;
157 event->observer = p->observer;
162 if ((event = getEvent()))
164 event->observer->socketNotify(event->event);
170 void Yaz_SocketManager::putEvent(YazSocketEvent *event)
172 logf (LOG_LOG, "putEvent p=%p event=%d", event, event->event);
173 // put in back of queue
176 m_queue_back->prev = event;
177 assert (m_queue_front);
181 assert (!m_queue_front);
182 m_queue_front = event;
184 event->next = m_queue_back;
186 m_queue_back = event;
189 Yaz_SocketManager::YazSocketEvent *Yaz_SocketManager::getEvent()
191 // get from front of queue
192 YazSocketEvent *event = m_queue_front;
195 assert (m_queue_back);
196 m_queue_front = event->prev;
199 assert (m_queue_back);
200 m_queue_front->next = 0;
207 void Yaz_SocketManager::removeEvent(IYazSocketObserver *observer)
209 YazSocketEvent *ev = m_queue_back;
212 YazSocketEvent *ev_next = ev->next;
213 if (observer == ev->observer)
216 ev->prev->next = ev->next;
218 m_queue_back = ev->next;
220 ev->next->prev = ev->prev;
222 m_queue_front = ev->prev;
229 Yaz_SocketManager::Yaz_SocketManager()
236 Yaz_SocketManager::~Yaz_SocketManager()