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.2 1999-01-28 13:08:48 adam
8 * Yaz_PDU_Assoc better encapsulated. Memory leak fix in
9 * yaz-socket-manager.cc.
11 * Revision 1.1.1.1 1999/01/28 09:41:07 adam
12 * First implementation of YAZ++.
20 #include <sys/types.h>
26 #include <yaz-socket-manager.h>
29 Yaz_SocketManager::YazSocketEntry **Yaz_SocketManager::lookupObserver(
30 IYazSocketObserver *observer)
34 for (se = &m_observers; *se; se = &(*se)->next)
35 if ((*se)->observer == observer)
40 void Yaz_SocketManager::addObserver(int fd, IYazSocketObserver *observer)
44 se = *lookupObserver(observer);
47 se = new YazSocketEntry;
48 se->next= m_observers;
50 se->observer = observer;
56 void Yaz_SocketManager::deleteObserver(IYazSocketObserver *observer)
58 YazSocketEntry **se = lookupObserver(observer);
61 removeEvent (observer);
62 YazSocketEntry *se_tmp = *se;
68 void Yaz_SocketManager::deleteObservers()
70 YazSocketEntry *se = m_observers;
74 YazSocketEntry *se_next = se->next;
81 void Yaz_SocketManager::maskObserver(IYazSocketObserver *observer, int mask)
85 se = *lookupObserver(observer);
90 void Yaz_SocketManager::timeoutObserver(IYazSocketObserver *observer,
95 se = *lookupObserver(observer);
97 se->timeout = timeout;
100 int Yaz_SocketManager::processEvent()
102 YazSocketEvent *event = getEvent();
105 event->observer->socketNotify(event->event);
110 fd_set in, out, except;
115 struct timeval *timeout = &to;
121 timeout = &to; /* hang on select */
125 for (YazSocketEntry *p = m_observers; p; p = p->next)
128 logf (LOG_LOG, "fd = %d mask=%d", fd, p->mask);
131 if (p->mask & YAZ_SOCKET_OBSERVE_READ)
133 if (p->mask & YAZ_SOCKET_OBSERVE_WRITE)
135 if (p->mask & YAZ_SOCKET_OBSERVE_EXCEPT)
142 while ((res = select(max + 1, &in, &out, &except, timeout)) < 0)
146 for (YazSocketEntry * p = m_observers; p; p = p->next)
150 if (FD_ISSET(fd, &in))
151 mask |= YAZ_SOCKET_OBSERVE_READ;
153 if (FD_ISSET(fd, &out))
154 mask |= YAZ_SOCKET_OBSERVE_WRITE;
156 if (FD_ISSET(fd, &except))
157 mask |= YAZ_SOCKET_OBSERVE_EXCEPT;
161 YazSocketEvent *event = new YazSocketEvent;
162 event->observer = p->observer;
167 if ((event = getEvent()))
169 event->observer->socketNotify(event->event);
176 void Yaz_SocketManager::putEvent(YazSocketEvent *event)
178 // put in back of queue
181 m_queue_back->prev = event;
182 assert (m_queue_front);
186 assert (!m_queue_front);
187 m_queue_front = event;
189 event->next = m_queue_back;
191 m_queue_back = event;
194 Yaz_SocketManager::YazSocketEvent *Yaz_SocketManager::getEvent()
196 // get from front of queue
197 YazSocketEvent *event = m_queue_front;
200 assert (m_queue_back);
201 m_queue_front = event->prev;
204 assert (m_queue_back);
205 m_queue_front->next = 0;
212 void Yaz_SocketManager::removeEvent(IYazSocketObserver *observer)
214 YazSocketEvent *ev = m_queue_back;
217 YazSocketEvent *ev_next = ev->next;
218 if (observer == ev->observer)
221 ev->prev->next = ev->next;
223 m_queue_back = ev->next;
225 ev->next->prev = ev->prev;
227 m_queue_front = ev->prev;
234 Yaz_SocketManager::Yaz_SocketManager()
241 Yaz_SocketManager::~Yaz_SocketManager()