X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fyaz-proxy-main.cpp;h=e8d594fe518dd7dfaa408b24bdc06f58bfb1ff66;hb=ea5275ed931fa06ac765dfb49e5af2036a6ec8b3;hp=6d981757a7dcc6ac7c9bfee24ab465656064e81e;hpb=87be6c609c22d9620c781b95ab74298b63694055;p=yazpp-moved-to-github.git diff --git a/src/yaz-proxy-main.cpp b/src/yaz-proxy-main.cpp index 6d98175..e8d594f 100644 --- a/src/yaz-proxy-main.cpp +++ b/src/yaz-proxy-main.cpp @@ -1,54 +1,27 @@ /* - * Copyright (c) 1998-1999, Index Data. + * Copyright (c) 1998-2003, Index Data. * See the file LICENSE for details. - * Sebastian Hammer, Adam Dickmeiss * - * $Log: yaz-proxy-main.cpp,v $ - * Revision 1.9 2000-08-07 14:19:59 adam - * Fixed serious bug regarding timeouts. Improved logging for proxy. - * - * Revision 1.8 2000/07/04 13:48:49 adam - * Implemented upper-limit on proxy-to-target sessions. - * - * Revision 1.7 1999/12/06 13:52:45 adam - * Modified for new location of YAZ header files. Experimental threaded - * operation. - * - * Revision 1.6 1999/11/10 10:02:34 adam - * Work on proxy. - * - * Revision 1.5 1999/04/21 12:09:01 adam - * Many improvements. Modified to proxy server to work with "sessions" - * based on cookies. - * - * Revision 1.4 1999/04/09 11:46:57 adam - * Added object Yaz_Z_Assoc. Much more functional client. - * - * Revision 1.3 1999/02/02 14:01:21 adam - * First WIN32 port of YAZ++. - * - * Revision 1.2 1999/01/28 13:08:45 adam - * Yaz_PDU_Assoc better encapsulated. Memory leak fix in - * yaz-socket-manager.cc. - * - * Revision 1.1.1.1 1999/01/28 09:41:07 adam - * First implementation of YAZ++. - * + * $Id: yaz-proxy-main.cpp,v 1.21 2003-10-23 09:08:52 adam Exp $ */ +#include +#include #include #include -#include -#include -#include +#include +#include +#include void usage(char *prog) { - fprintf (stderr, "%s: [-a log] [-c num] [-v level] [-t target] @:port\n", prog); + fprintf (stderr, "%s: [-c config] [-a log] [-m num] [-v level] [-t target] [-i sec] " + "[-u auth] [-o optlevel] @:port\n", prog); exit (1); } +static char *pid_fname = 0; int args(Yaz_Proxy *proxy, int argc, char **argv) { @@ -57,8 +30,9 @@ int args(Yaz_Proxy *proxy, int argc, char **argv) char *prog = argv[0]; int ret; - while ((ret = options("a:t:v:c:", argv, argc, &arg)) != -2) + while ((ret = options("o:a:t:v:c:u:i:m:l:T:p:", argv, argc, &arg)) != -2) { + int err; switch (ret) { case 0: @@ -69,18 +43,50 @@ int args(Yaz_Proxy *proxy, int argc, char **argv) } addr = arg; break; + case 'c': + err = proxy->set_config(arg); + if (err == -2) + { + fprintf(stderr, "Config file support not enabled (proxy not compiled with libxml2 support)\n"); + exit(1); + } + else if (err == -1) + { + fprintf(stderr, "Bad or missing file %s\n", arg); + exit(1); + } + break; case 'a': proxy->set_APDU_log(arg); break; case 't': - proxy->set_proxyTarget(arg); + proxy->set_default_target(arg); + break; + case 'u': + proxy->set_proxy_authentication(arg); + break; + case 'o': + proxy->option("optimize", arg); break; case 'v': - log_init_level (log_mask_str(arg)); + yaz_log_init_level (yaz_log_mask_str(arg)); break; - case 'c': + case 'l': + yaz_log_init_file (arg); + break; + case 'm': proxy->set_max_clients(atoi(arg)); break; + case 'i': + proxy->set_client_idletime(atoi(arg)); + break; + case 'T': + proxy->set_target_idletime(atoi(arg)); + break; + case 'p': + if (!pid_fname) + pid_fname = xstrdup(arg); + break; default: usage(prog); return 1; @@ -98,13 +104,43 @@ int args(Yaz_Proxy *proxy, int argc, char **argv) return 0; } +static Yaz_Proxy *static_yaz_proxy = 0; +static void sighup_handler(int num) +{ + if (static_yaz_proxy) + static_yaz_proxy->reconfig(); +} + int main(int argc, char **argv) { + static int mk_pid = 0; Yaz_SocketManager mySocketManager; Yaz_Proxy proxy(new Yaz_PDU_Assoc(&mySocketManager)); + static_yaz_proxy = &proxy; + + signal(SIGHUP, sighup_handler); + args(&proxy, argc, argv); while (mySocketManager.processEvent() > 0) - ; + if (!mk_pid && pid_fname) + { + FILE *f = fopen(pid_fname, "w"); + if (!f) + { + yaz_log(LOG_ERRNO|LOG_FATAL, "Couldn't create %s", pid_fname); + exit(0); + } + fprintf(f, "%ld", (long) getpid()); + fclose(f); + mk_pid = 1; + } + if (pid_fname) + { + if (mk_pid) + unlink(pid_fname); + xfree(pid_fname); + } + exit (0); return 0; }