2 * Copyright (c) 1998-2005, Index Data.
3 * See the file LICENSE for details.
5 * $Id: t-server.cpp,v 1.4 2005-09-12 20:09:14 adam Exp $
11 #include <yaz/diagbib1.h>
12 #include <yaz/options.h>
13 #include "msg-thread.h"
14 #include <yaz++/z-assoc.h>
15 #include <yaz++/pdu-assoc.h>
16 #include <yaz++/gdu.h>
17 #include <yaz++/socket-manager.h>
19 using namespace yazpp_1;
23 class Auth_Msg : public IMsg_Thread {
29 IMsg_Thread *handle();
31 Auth_Msg(GDU *gdu, MyServer *front);
35 Auth_Msg::Auth_Msg(GDU *gdu, MyServer *front)
49 IMsg_Thread *Auth_Msg::handle()
51 ODR odr = odr_createmem(ODR_ENCODE);
52 yaz_log(YLOG_LOG, "Auth_Msg:handle begin");
53 Z_GDU *z_gdu = m_gdu->get();
54 if (z_gdu->which == Z_GDU_Z3950)
57 switch(z_gdu->u.z3950->which)
59 case Z_APDU_initRequest:
60 apdu = zget_APDU(odr, Z_APDU_initResponse);
62 case Z_APDU_searchRequest:
64 apdu = zget_APDU(odr, Z_APDU_searchResponse);
67 apdu = zget_APDU(odr, Z_APDU_close);
72 m_output = new GDU(apdu);
74 yaz_log(YLOG_LOG, "Auth_Msg:handle end");
79 class MyServer : public Z_Assoc {
82 MyServer(IPDU_Observable *the_PDU_Observable,
83 Msg_Thread *m_my_thread
85 IPDU_Observer* sessionNotify(IPDU_Observable *the_PDU_Observable,
88 void recv_GDU(Z_GDU *apdu, int len);
97 yazpp_1::GDUQueue m_in_queue;
98 Msg_Thread *m_my_thread;
101 void Auth_Msg::result()
103 m_front->m_no_requests--;
104 if (!m_front->m_delete_flag)
109 m_front->send_GDU(m_output->get(), &len);
114 m_front->m_delete_flag = 1;
117 if (m_front->m_delete_flag && m_front->m_no_requests == 0)
121 MyServer::MyServer(IPDU_Observable *the_PDU_Observable,
122 Msg_Thread *my_thread
124 : Z_Assoc(the_PDU_Observable)
126 m_my_thread = my_thread;
129 yaz_log(YLOG_LOG, "Construct Myserver=%p", this);
132 IPDU_Observer *MyServer::sessionNotify(IPDU_Observable
133 *the_PDU_Observable, int fd)
135 MyServer *my = new MyServer(the_PDU_Observable, m_my_thread);
136 yaz_log(YLOG_LOG, "New session %s", the_PDU_Observable->getpeername());
140 MyServer::~MyServer()
142 yaz_log(YLOG_LOG, "Destroy Myserver=%p", this);
145 void MyServer::recv_GDU(Z_GDU *apdu, int len)
147 GDU *gdu = new GDU(apdu);
148 Auth_Msg *m = new Auth_Msg(gdu, this);
153 void MyServer::failNotify()
156 if (m_no_requests == 0)
161 void MyServer::timeoutNotify()
164 if (m_no_requests == 0)
168 void MyServer::connectNotify()
173 void usage(const char *prog)
175 fprintf (stderr, "%s: [-a log] [-v level] [-T] @:port\n", prog);
179 int main(int argc, char **argv)
185 const char *addr = "tcp:@:9999";
189 while ((ret = options("n:a:v:T", argv, argc, &arg)) != -2)
197 no_threads = atoi(arg);
200 apdu_log = xstrdup(arg);
203 yaz_log_init_level (yaz_log_mask_str(arg));
214 SocketManager mySocketManager;
216 PDU_Assoc *my_PDU_Assoc = 0;
220 Msg_Thread *my_thread = new Msg_Thread(&mySocketManager, no_threads);
222 #if YAZ_POSIX_THREADS
224 my_PDU_Assoc = new PDU_AssocThread(&mySocketManager);
226 my_PDU_Assoc = new PDU_Assoc(&mySocketManager);
228 my_PDU_Assoc = new PDU_Assoc(&mySocketManager);
231 z = new MyServer(my_PDU_Assoc, my_thread);
235 yaz_log (YLOG_LOG, "set_APDU_log %s", apdu_log);
236 z->set_APDU_log(apdu_log);
239 while (mySocketManager.processEvent() > 0)
248 * indent-tabs-mode: nil
250 * vim: shiftwidth=4 tabstop=8 expandtab