#include <stdlib.h>
#include <signal.h>
#include <Basics.H>
#include <OS.H>
#include <FdStream.H>
#include <VestaConfig.H>
#include <TCP_sock.H>
#include <SRPC.H>
#include <VestaSource.H>
#include <UniqueId.H>
#include <sys/utsname.h>
#include <sys/sysinfo.h>
#include <sstream>
#include "RunToolClient.H"
#include "RunToolDaemon.H"
#include "Launcher.h"
#include "get_load.h"
Go to the source code of this file.
Typedefs | |
typedef Sequence< Basics::cond * > | CondSeq |
Functions | |
void | Info (SRPC *srpc, int intfVersion, int procId) throw (SRPC::failure) |
void | RunToolServer (SRPC *srpc, int intfVersion, int procId, void *arg) throw (SRPC::failure) |
void | RunToolServerInit (int maxTools, int maxPending) throw (SRPC::failure) |
void | RunToolServerCleanup () throw () |
Variables | |
const Text | DEVNULL ("/dev/null") |
const int | UNUSED = SYSERROR |
|
Definition at line 110 of file RunToolDaemon.C. |
|
Definition at line 915 of file RunToolDaemon.C. References implementation_error, Basics::mutex::lock(), children::maxChildren, children::maxPending, children::mu, children::nInUse, children::nPending, RUN_TOOL_LOAD_VERSION, RUN_TOOL_OLDINFO, FP::Tag::Send(), Basics::mutex::unlock(), and VestaSourceSRPC::version. Referenced by RunToolServer(). |
|
Definition at line 961 of file RunToolDaemon.C. References SRPC::default_proc_id, Info(), RUN_TOOL_DOIT, RUN_TOOL_INFO, RUN_TOOL_INTERFACE_VERSION, RUN_TOOL_OLDINFO, RunTool(), and SRPC::version_skew. Referenced by main(). |
|
Definition at line 1270 of file RunToolDaemon.C. Referenced by main(), and SigHandler(). |
|
Definition at line 1139 of file RunToolDaemon.C. References Text::cchars(), Text::chars(), VestaConfig::get(), VestaConfig::get_int(), VestaConfig::get_Text(), children::init(), chars_seq::length(), call_failure::msg, RUN_TOOL_CONFIG_SECTION, SYSERROR, UniqueId(), and VestaSourceSRPC::version. Referenced by main(). |
|
|
|
Definition at line 79 of file RunToolDaemon.C. Referenced by children::child_info::child_info(), children::killer_body(), and children::wait_for(). |