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.3 1999-02-02 14:01:23 adam
8 * First WIN32 port of YAZ++.
10 * Revision 1.2 1999/01/28 13:08:48 adam
11 * Yaz_PDU_Assoc better encapsulated. Memory leak fix in
12 * yaz-socket-manager.cc.
14 * Revision 1.1.1.1 1999/01/28 09:41:07 adam
15 * First implementation of YAZ++.
23 #include <sys/types.h>
29 #include <yaz-socket-manager.h>
32 Yaz_SocketManager::YazSocketEntry **Yaz_SocketManager::lookupObserver(
33 IYazSocketObserver *observer)
37 for (se = &m_observers; *se; se = &(*se)->next)
38 if ((*se)->observer == observer)
43 void Yaz_SocketManager::addObserver(int fd, IYazSocketObserver *observer)
47 se = *lookupObserver(observer);
50 se = new YazSocketEntry;
51 se->next= m_observers;
53 se->observer = observer;
59 void Yaz_SocketManager::deleteObserver(IYazSocketObserver *observer)
61 YazSocketEntry **se = lookupObserver(observer);
64 removeEvent (observer);
65 YazSocketEntry *se_tmp = *se;
71 void Yaz_SocketManager::deleteObservers()
73 YazSocketEntry *se = m_observers;
77 YazSocketEntry *se_next = se->next;
84 void Yaz_SocketManager::maskObserver(IYazSocketObserver *observer, int mask)
88 se = *lookupObserver(observer);
93 void Yaz_SocketManager::timeoutObserver(IYazSocketObserver *observer,
98 se = *lookupObserver(observer);
100 se->timeout = timeout;
103 int Yaz_SocketManager::processEvent()
106 YazSocketEvent *event = getEvent();
109 event->observer->socketNotify(event->event);
114 fd_set in, out, except;
119 struct timeval *timeout = &to;
125 timeout = &to; /* hang on select */
129 for (p = m_observers; p; p = p->next)
132 logf (LOG_LOG, "fd = %d mask=%d", fd, p->mask);
135 if (p->mask & YAZ_SOCKET_OBSERVE_READ)
137 if (p->mask & YAZ_SOCKET_OBSERVE_WRITE)
139 if (p->mask & YAZ_SOCKET_OBSERVE_EXCEPT)
146 while ((res = select(max + 1, &in, &out, &except, timeout)) < 0)
150 for (p = m_observers; p; p = p->next)
154 if (FD_ISSET(fd, &in))
155 mask |= YAZ_SOCKET_OBSERVE_READ;
157 if (FD_ISSET(fd, &out))
158 mask |= YAZ_SOCKET_OBSERVE_WRITE;
160 if (FD_ISSET(fd, &except))
161 mask |= YAZ_SOCKET_OBSERVE_EXCEPT;
165 YazSocketEvent *event = new YazSocketEvent;
166 event->observer = p->observer;
171 if ((event = getEvent()))
173 event->observer->socketNotify(event->event);
180 void Yaz_SocketManager::putEvent(YazSocketEvent *event)
182 // put in back of queue
185 m_queue_back->prev = event;
186 assert (m_queue_front);
190 assert (!m_queue_front);
191 m_queue_front = event;
193 event->next = m_queue_back;
195 m_queue_back = event;
198 Yaz_SocketManager::YazSocketEvent *Yaz_SocketManager::getEvent()
200 // get from front of queue
201 YazSocketEvent *event = m_queue_front;
204 assert (m_queue_back);
205 m_queue_front = event->prev;
208 assert (m_queue_back);
209 m_queue_front->next = 0;
216 void Yaz_SocketManager::removeEvent(IYazSocketObserver *observer)
218 YazSocketEvent *ev = m_queue_back;
221 YazSocketEvent *ev_next = ev->next;
222 if (observer == ev->observer)
225 ev->prev->next = ev->next;
227 m_queue_back = ev->next;
229 ev->next->prev = ev->prev;
231 m_queue_front = ev->prev;
238 Yaz_SocketManager::Yaz_SocketManager()
245 Yaz_SocketManager::~Yaz_SocketManager()