2 * Copyright (c) 1998-1999, Index Data.
3 * See the file LICENSE for details.
4 * Sebastian Hammer, Adam Dickmeiss
6 * $Log: yaz-pdu-assoc.cpp,v $
7 * Revision 1.6 1999-04-20 10:30:05 adam
8 * Implemented various stuff for client and proxy. Updated calls
9 * to ODR to reflect new name parameter.
11 * Revision 1.5 1999/04/09 11:46:57 adam
12 * Added object Yaz_Z_Assoc. Much more functional client.
14 * Revision 1.4 1999/03/23 14:17:57 adam
15 * More work on timeout handling. Work on yaz-client.
17 * Revision 1.3 1999/02/02 14:01:20 adam
18 * First WIN32 port of YAZ++.
20 * Revision 1.2 1999/01/28 13:08:44 adam
21 * Yaz_PDU_Assoc better encapsulated. Memory leak fix in
22 * yaz-socket-manager.cc.
24 * Revision 1.1.1.1 1999/01/28 09:41:07 adam
25 * First implementation of YAZ++.
31 #include <yaz-pdu-assoc.h>
36 Yaz_PDU_Assoc::Yaz_PDU_Assoc(IYazSocketObservable *socketObservable,
41 m_socketObservable = socketObservable;
52 IYaz_PDU_Observable *Yaz_PDU_Assoc::clone()
54 Yaz_PDU_Assoc *copy = new Yaz_PDU_Assoc(m_socketObservable, 0);
58 Yaz_PDU_Assoc::~Yaz_PDU_Assoc()
63 void Yaz_PDU_Assoc::socketNotify(int event)
65 logf (LOG_LOG, "Yaz_PDU_Assoc::socketNotify p=%p event = %d", this, event);
66 if (m_state == Connected)
69 m_socketObservable->maskObserver(this, YAZ_SOCKET_OBSERVE_READ|
70 YAZ_SOCKET_OBSERVE_EXCEPT);
71 m_PDU_Observer->connectNotify();
74 else if (m_state == Connecting)
76 if (event & YAZ_SOCKET_OBSERVE_READ)
79 m_PDU_Observer->failNotify();
84 m_socketObservable->maskObserver(this, YAZ_SOCKET_OBSERVE_READ|
85 YAZ_SOCKET_OBSERVE_EXCEPT);
86 m_PDU_Observer->connectNotify();
90 else if (m_state == Listen)
92 if (event & YAZ_SOCKET_OBSERVE_READ)
97 if ((res = cs_listen(m_cs, 0, 0)) == 1)
101 logf(LOG_FATAL, "cs_listen failed");
104 if (!(new_line = cs_accept(m_cs)))
107 Yaz_PDU_Assoc *assoc = new Yaz_PDU_Assoc (m_socketObservable,
109 assoc->m_parent = this;
110 assoc->m_next = m_children;
113 assoc->m_PDU_Observer = m_PDU_Observer->clone(assoc);
114 assoc->m_state = Ready;
115 assoc->m_socketObservable->addObserver(cs_fileno(new_line), assoc);
116 assoc->m_socketObservable->maskObserver(assoc,
117 YAZ_SOCKET_OBSERVE_READ|
118 YAZ_SOCKET_OBSERVE_EXCEPT);
120 assoc->m_socketObservable->timeoutObserver(assoc, m_idleTime);
123 else if (m_state == Ready)
125 if (event & YAZ_SOCKET_OBSERVE_WRITE)
129 if (event & YAZ_SOCKET_OBSERVE_READ)
133 int res = cs_get (m_cs, &m_input_buf, &m_input_len);
138 logf (LOG_LOG, "Connection closed by client");
140 m_PDU_Observer->failNotify();
143 // lock it, so we know if recv_PDU deletes it.
145 m_destroyed = &destroyed;
147 m_PDU_Observer->recv_PDU(m_input_buf, res);
148 if (destroyed) // it really was destroyed, return now.
150 } while (m_cs && cs_more (m_cs));
152 if (event & YAZ_SOCKET_OBSERVE_TIMEOUT)
154 m_PDU_Observer->timeoutNotify();
159 void Yaz_PDU_Assoc::close()
161 m_socketObservable->deleteObserver(this);
165 logf (LOG_LOG, "Yaz_PDU_Assoc::close fd=%d", cs_fileno(m_cs));
171 PDU_Queue *q_this = m_queue_out;
172 m_queue_out = m_queue_out->m_next;
175 // free (m_input_buf);
180 void Yaz_PDU_Assoc::destroy()
187 // delete from parent's child list (if any)
190 c = &m_parent->m_children;
198 // delete all children ...
202 Yaz_PDU_Assoc *here = *c;
209 Yaz_PDU_Assoc::PDU_Queue::PDU_Queue(const char *buf, int len)
211 m_buf = (char *) malloc (len);
212 memcpy (m_buf, buf, len);
217 Yaz_PDU_Assoc::PDU_Queue::~PDU_Queue()
222 int Yaz_PDU_Assoc::flush_PDU()
226 logf (LOG_LOG, "Yaz_PDU_Assoc::flush_PDU");
227 if (m_state != Ready)
231 PDU_Queue *q = m_queue_out;
234 m_socketObservable->maskObserver(this, YAZ_SOCKET_OBSERVE_READ|
235 YAZ_SOCKET_OBSERVE_EXCEPT);
238 r = cs_put (m_cs, q->m_buf, q->m_len);
242 m_PDU_Observer->failNotify();
247 m_socketObservable->maskObserver(this, YAZ_SOCKET_OBSERVE_READ|
248 YAZ_SOCKET_OBSERVE_EXCEPT|
249 YAZ_SOCKET_OBSERVE_WRITE);
250 logf (LOG_LOG, "Yaz_PDU_Assoc::flush_PDU put %d bytes (incomplete)",
254 logf (LOG_LOG, "Yaz_PDU_Assoc::flush_PDU put %d bytes", q->m_len);
255 // whole packet sent... delete this and proceed to next ...
256 m_queue_out = q->m_next;
258 // don't select on write if queue is empty ...
260 m_socketObservable->maskObserver(this, YAZ_SOCKET_OBSERVE_READ|
261 YAZ_SOCKET_OBSERVE_EXCEPT);
265 int Yaz_PDU_Assoc::send_PDU(const char *buf, int len)
267 logf (LOG_LOG, "Yaz_PDU_Assoc::send_PDU");
268 PDU_Queue **pq = &m_queue_out;
269 int is_idle = (*pq ? 0 : 1);
273 logf (LOG_LOG, "Yaz_PDU_Assoc::send_PDU failed, m_cs == 0");
278 *pq = new PDU_Queue(buf, len);
282 logf (LOG_LOG, "Yaz_PDU_Assoc::cannot send_PDU fd=%d",
287 COMSTACK Yaz_PDU_Assoc::comstack()
291 CS_TYPE cs_type = tcpip_type;
292 int protocol = PROTO_Z3950;
293 m_cs = cs_create (cs_type, 0, protocol);
298 void Yaz_PDU_Assoc::listen(IYaz_PDU_Observer *observer,
303 COMSTACK cs = comstack();
305 logf (LOG_LOG, "Yaz_PDU_Assoc::listen %s", addr);
306 m_PDU_Observer = observer;
309 ap = cs_straddr (cs, addr);
312 if (cs_bind(cs, ap, CS_SERVER) < 0)
314 m_socketObservable->addObserver(cs_fileno(cs), this);
315 m_socketObservable->maskObserver(this, YAZ_SOCKET_OBSERVE_READ|
316 YAZ_SOCKET_OBSERVE_EXCEPT);
320 void Yaz_PDU_Assoc::idleTime(int idleTime)
322 m_idleTime = idleTime;
325 void Yaz_PDU_Assoc::connect(IYaz_PDU_Observer *observer,
328 logf (LOG_LOG, "Yaz_PDU_Assoc::connect %s", addr);
330 m_PDU_Observer = observer;
331 COMSTACK cs = comstack();
332 void *ap = cs_straddr (cs, addr);
335 logf (LOG_LOG, "cs_straddr failed");
338 int res = cs_connect (cs, ap);
341 logf (LOG_LOG, "Yaz_PDU_Assoc::connect failed");
343 logf (LOG_LOG, "Yaz_PDU_Assoc::connect fd=%d", cs_fileno(cs));
344 m_socketObservable->addObserver(cs_fileno(cs), this);
345 m_socketObservable->maskObserver(this, YAZ_SOCKET_OBSERVE_READ|
346 YAZ_SOCKET_OBSERVE_EXCEPT|
347 YAZ_SOCKET_OBSERVE_WRITE);
348 m_state = Connecting;
355 logf (LOG_LOG, "Yaz_PDU_Assoc::connect fd=%d", cs_fileno(cs));
356 m_socketObservable->addObserver(cs_fileno(cs), this);
357 m_socketObservable->maskObserver(this, YAZ_SOCKET_OBSERVE_READ|
358 YAZ_SOCKET_OBSERVE_EXCEPT|
359 YAZ_SOCKET_OBSERVE_WRITE);
362 logf (LOG_LOG, "Yaz_PDU_Assoc::connect pending");
363 m_state = Connecting;
367 logf (LOG_LOG, "Yaz_PDU_Assoc::Connect complete");