src/app/netschedule/netscheduled.cpp File Reference

#include <ncbi_pch.hpp>
#include <stdio.h>
#include <corelib/ncbiapp.hpp>
#include <corelib/ncbienv.hpp>
#include <corelib/ncbireg.hpp>
#include <corelib/ncbiargs.hpp>
#include <corelib/ncbistr.hpp>
#include <corelib/ncbimisc.hpp>
#include <corelib/ncbi_config.hpp>
#include <corelib/ncbimtx.hpp>
#include <corelib/ncbidiag.hpp>
#include <corelib/request_ctx.hpp>
#include <util/bitset/ncbi_bitset.hpp>
#include <connect/ncbi_core_cxx.hpp>
#include <connect/server.hpp>
#include <connect/ncbi_socket.hpp>
#include <connect/services/netservice_protocol_parser.hpp>
#include <connect/ncbi_conn_stream.hpp>
#include <db/bdb/bdb_expt.hpp>
#include "ns_queue.hpp"
#include "queue_coll.hpp"
#include "ns_types.hpp"
#include "ns_util.hpp"
#include "job_status.hpp"
#include "access_list.hpp"
#include "background_host.hpp"
#include "worker_node.hpp"
#include "netschedule_version.hpp"

Include dependency graph for netscheduled.cpp:

Go to the source code of this file.

Classes

struct  SJS_Request
class  CNSRequestContextFactory
class  CNetScheduleHandler
 ConnectionHandler for NetScheduler. More...
struct  CNetScheduleHandler::SCommandExtra
class  CNetScheduleConnectionFactory
 CNetScheduleConnectionFactory::. More...
class  CNetScheduleBackgroundHost
 Host for background threads. More...
class  CNetScheduleRequestExecutor
 Executor for long-standing requests. More...
struct  SNS_Parameters
 Parameters for server. More...
struct  CRequestContextPoolFactory
class  CNetScheduleServer
 NetScheduler threaded server. More...
class  CRequestContextGuard
class  CRequestContextSubmitGuard
class  CNetScheduleDApp
 NetSchedule daemon application. More...

Defines

#define NETSCHEDULED_FEATURES   "fast_status=1;dyn_queues=1;tags=1;read_confirm=1;version=" NETSCHEDULED_VERSION
#define NETSCHEDULED_FULL_VERSION
#define GetIntNoErr(name, dflt)   reg.GetInt(sname, name, dflt, 0, IRegistry::eReturn)
#define GetBoolNoErr(name, dflt)   reg.GetBool(sname, name, dflt, 0, IRegistry::eReturn)

Functions

static void s_BufReadHelper (void *data, void *ptr, size_t size)
static void s_ReadBufToString (BUF buf, string &str)
void Threaded_Server_SignalHandler (int signum)
int main (int argc, const char *argv[])

Variables

 USING_NCBI_SCOPE
static CNetScheduleServer * s_netschedule_server = 0
const unsigned kMaxMessageSize = kNetScheduleMaxDBErrSize * 4

Define Documentation

#define GetBoolNoErr (  name,
dflt   )     reg.GetBool(sname, name, dflt, 0, IRegistry::eReturn)
 

Referenced by SNSDBEnvironmentParams::Read(), and SNS_Parameters::Read().

#define GetIntNoErr (  name,
dflt   )     reg.GetInt(sname, name, dflt, 0, IRegistry::eReturn)
 

Referenced by SQueueParameters::Read(), and SNS_Parameters::Read().

#define NETSCHEDULED_FEATURES   "fast_status=1;dyn_queues=1;tags=1;read_confirm=1;version=" NETSCHEDULED_VERSION
 

Definition at line 67 of file netscheduled.cpp.

Referenced by CNetScheduleHandler::ProcessGetParam().

#define NETSCHEDULED_FULL_VERSION
 

Value:

"NCBI NetSchedule server Version " NETSCHEDULED_VERSION \
    " Storage version " NETSCHEDULED_STORAGE_VERSION \
    " Protocol version " NETSCHEDULED_PROTOCOL_VERSION \
    " build " __DATE__ " " __TIME__

Definition at line 79 of file netscheduled.cpp.

Referenced by CNetScheduleHandler::ProcessDump(), CNetScheduleHandler::ProcessMonitor(), CNetScheduleHandler::ProcessVersion(), and CNetScheduleDApp::Run().

Function Documentation

int main (  int  argc,
const char *  argv[]
) 
 

Definition at line 3198 of file netscheduled.cpp.

References eDS_ToStdlog, CDiagContext::GetRequestContext(), CRequestContext::SetAutoIncRequestIDOnPost(), CRequestContext::SetDefaultAutoIncRequestIDOnPost(), and CDiagContext::SetOldPostFormat().

static void s_BufReadHelper (  void *  data,
void *  ptr,
size_t  size
)  [static]
 

Definition at line 792 of file netscheduled.cpp.

Referenced by s_ReadBufToString().

static void s_ReadBufToString (  BUF  buf,
string &  str
)  [static]
 

Definition at line 798 of file netscheduled.cpp.

References buf, BUF_PeekAtCB(), BUF_Read(), BUF_Size(), s_BufReadHelper(), and size.

Referenced by CNetScheduleHandler::ProcessMsgAuth(), CNetScheduleHandler::ProcessMsgBatchJob(), CNetScheduleHandler::ProcessMsgQueue(), and CNetScheduleHandler::ProcessMsgRequest().

void Threaded_Server_SignalHandler (  int  signum  ) 
 

Definition at line 3010 of file netscheduled.cpp.

References s_netschedule_server, CNetScheduleServer::SetShutdownFlag(), and CNetScheduleServer::ShutdownRequested().

Referenced by CNetScheduleDApp::Run().

Variable Documentation

const unsigned kMaxMessageSize = kNetScheduleMaxDBErrSize * 4
 

Definition at line 268 of file netscheduled.cpp.

Referenced by CNetScheduleHandler::WriteMsg().

CNetScheduleServer* s_netschedule_server = 0 [static]
 

Definition at line 86 of file netscheduled.cpp.

Referenced by CNetScheduleServer::CNetScheduleServer(), and Threaded_Server_SignalHandler().

USING_NCBI_SCOPE
 

Definition at line 77 of file netscheduled.cpp.

Generated on Mon Dec 7 07:24:05 2009 for NCBI C++ ToolKit by  doxygen 1.4.6
Modified on Mon Dec 07 16:21:42 2009 by modify_doxy.py rev. 173732