#include "config.hpp"#include <yaz/log.h>#include <yaz/options.h>#include <yaz/daemon.h>#include <yaz/sc.h>#include <iostream>#include <stdexcept>#include <libxml/xinclude.h>#include <metaproxy/filter.hpp>#include <metaproxy/package.hpp>#include <metaproxy/util.hpp>#include "router_flexml.hpp"#include "factory_static.hpp"#include <unistd.h>#include <signal.h>
Include dependency graph for metaproxy_prog.cpp:
Go to the source code of this file.
Functions | |
| static void | set_log_prefix (void) |
| static void | sig_usr1_handler (int s) |
| static void | sig_term_handler (int s) |
| static void | work_common (void *data) |
| static void | work_debug (void *data) |
| static void | work_normal (void *data) |
| static int | sc_main (yaz_sc_t s, int argc, char **argv) |
| static void | sc_stop (yaz_sc_t s) |
| int | main (int argc, char **argv) |
Variables | |
| mp::RouterFleXML * | routerp = 0 |
| static pid_t | process_group = 0 |
Function Documentation
| int main | ( | int | argc, |
| char ** | argv | ||
| ) |
|
static |
Definition at line 113 of file metaproxy_prog.cpp.
References set_log_prefix(), VERSION, VERSION_SHA1, work_debug(), and work_normal().
Referenced by main().
{
bool test_config = false;
const char *fname = 0;
int ret;
char *arg;
unsigned mode = 0;
const char *pidfile = 0;
const char *uid = 0;
while ((ret = options("c{config}:Dh{help}l:m:p:tu:V{version}w:X",
argv, argc, &arg)) != -2)
{
switch (ret)
{
case 'c':
fname = arg;
break;
case 'D':
mode = YAZ_DAEMON_FORK|YAZ_DAEMON_KEEPALIVE;
break;
case 'h':
std::cerr << "metaproxy\n"
" -h|--help help\n"
" -V|--version version\n"
" -c|--config f config filename\n"
" -D daemon and keepalive operation\n"
" -l f log file f\n"
" -m logformat log time format (strftime)\n"
" -p f pid file f\n"
" -t test configuration\n"
" -u id change uid to id\n"
" -w dir changes working directory to dir\n"
" -X debug mode (no fork/daemon mode)\n"
#ifdef WIN32
" -install install windows service\n"
" -remove remove windows service\n"
#endif
<< std::endl;
break;
case 'l':
yaz_log_init_file(arg);
break;
case 'm':
yaz_log_time_format(arg);
break;
case 'p':
pidfile = arg;
break;
case 't':
test_config = true;
break;
case 'u':
uid = arg;
break;
case 'V':
std::cout << VERSION;
#ifdef VERSION_SHA1
std::cout << " " VERSION_SHA1;
#endif
std::cout << "\n";
return 0;
break;
case 'w':
if (
#ifdef WIN32
_chdir(arg)
#else
chdir(arg)
#endif
)
{
std::cerr << "chdir " << arg << " failed" << std::endl;
return 1;
}
case 'X':
mode = YAZ_DAEMON_DEBUG;
break;
case -1:
std::cerr << "bad option: " << arg << std::endl;
return 1;
}
}
if (!fname)
{
std::cerr << "No configuration given; use -h for help\n";
return 1;
}
yaz_log(YLOG_LOG, "metaproxy %s " VERSION
#ifdef VERSION_SHA1
" " VERSION_SHA1
#endif
, test_config ? "test" : "start"
);
yaz_log_xml_errors(0, YLOG_LOG);
xmlDocPtr doc = xmlReadFile(fname,
NULL,
XML_PARSE_XINCLUDE + XML_PARSE_NOBLANKS
+ XML_PARSE_NSCLEAN + XML_PARSE_NONET );
if (!doc)
{
yaz_log(YLOG_FATAL,"XML parsing failed");
return 1;
}
// and perform Xinclude then
int r = xmlXIncludeProcess(doc);
if (r == -1)
{
yaz_log(YLOG_FATAL, "XInclude processing failed");
return 1;
}
mp::wrbuf base_path;
const char *last_p = strrchr(fname,
#ifdef WIN32
'\\'
#else
'/'
#endif
);
if (last_p)
wrbuf_write(base_path, fname, last_p - fname);
else
wrbuf_puts(base_path, ".");
ret = 0;
try {
mp::FactoryStatic factory;
mp::RouterFleXML *router =
new mp::RouterFleXML(doc, factory, test_config, wrbuf_cstr(base_path));
if (!test_config)
{
yaz_sc_running(s);
yaz_daemon("metaproxy", mode, mode == YAZ_DAEMON_DEBUG ?
work_debug : work_normal, router, pidfile, uid);
}
}
catch (std::logic_error &e) {
yaz_log(YLOG_FATAL,"std::logic error: %s" , e.what() );
ret = 1;
}
catch (std::runtime_error &e) {
yaz_log(YLOG_FATAL, "std::runtime error: %s" , e.what() );
ret = 1;
}
catch ( ... ) {
yaz_log(YLOG_FATAL, "Unknown Exception");
ret = 1;
}
xmlFreeDoc(doc);
if (test_config)
yaz_log(YLOG_LOG, "metaproxy test exit code %d", ret);
return ret;
}
Here is the call graph for this function:
|
static |
|
static |
Definition at line 50 of file metaproxy_prog.cpp.
Referenced by sc_main(), and work_common().
{
#if HAVE_UNISTD_H
char str[80];
sprintf(str, "%lld", (long long) getpid());
yaz_log_init_prefix(str);
#endif
}
|
static |
Definition at line 69 of file metaproxy_prog.cpp.
References process_group.
Referenced by work_common().
{
yaz_log(YLOG_LOG, "metaproxy received SIGTERM");
yaz_log(YLOG_LOG, "metaproxy stop");
kill(-process_group, SIGTERM); /* kill all children processes as well */
_exit(0);
}
|
static |
Definition at line 63 of file metaproxy_prog.cpp.
References metaproxy_1::RouterFleXML::stop().
Referenced by work_common().
Here is the call graph for this function:
|
static |
Definition at line 78 of file metaproxy_prog.cpp.
References process_group, set_log_prefix(), sig_term_handler(), sig_usr1_handler(), and metaproxy_1::RouterFleXML::start().
Referenced by work_debug(), and work_normal().
{
#if HAVE_UNISTD_H
process_group = getpgid(0); // save process group ID
signal(SIGTERM, sig_term_handler);
signal(SIGUSR1, sig_usr1_handler);
#endif
routerp = (mp::RouterFleXML*) data;
mp::Package pack;
pack.router(*routerp).move();
yaz_log(YLOG_LOG, "metaproxy stop"); /* only for graceful stop */
#if HAVE_UNISTD_H
kill(-process_group, SIGTERM); /* kill all children processes as well */
#endif
_exit(0);
}
Here is the call graph for this function:
|
static |
Definition at line 99 of file metaproxy_prog.cpp.
References work_common().
Referenced by sc_main().
Here is the call graph for this function:
|
static |
Definition at line 104 of file metaproxy_prog.cpp.
References work_common().
Referenced by sc_main().
{
#if HAVE_UNISTD_H
/* make the current working process group leader */
setpgid(0, 0);
#endif
work_common(data);
}
Here is the call graph for this function:
Variable Documentation
|
static |
Definition at line 61 of file metaproxy_prog.cpp.
Referenced by sig_term_handler(), and work_common().
| mp::RouterFleXML* routerp = 0 |
Definition at line 48 of file metaproxy_prog.cpp.
