src/connect/services/grid_worker.cpp File Reference

#include <ncbi_pch.hpp>
#include "grid_thread_context.hpp"
#include "netservice_params.hpp"
#include "balancing.hpp"
#include <connect/services/grid_globals.hpp>
#include <connect/services/error_codes.hpp>
#include <connect/services/grid_debug_context.hpp>
#include <connect/services/netschedule_api_expt.hpp>
#include <connect/services/grid_worker_app.hpp>
#include <connect/services/grid_control_thread.hpp>
#include <connect/ncbi_socket.hpp>
#include <util/thread_pool.hpp>
#include <corelib/ncbireg.hpp>
#include <corelib/ncbithr.hpp>
#include <corelib/ncbitime.hpp>
#include <corelib/ncbi_config.hpp>
#include <corelib/ncbi_process.hpp>
#include <corelib/ncbiexpt.hpp>
#include <corelib/ncbi_system.hpp>
#include <corelib/ncbi_safe_static.hpp>
#include <corelib/request_ctx.hpp>
#include <corelib/blob_storage.hpp>

Include dependency graph for grid_worker.cpp:

Go to the source code of this file.

Classes
class	CWorkerNodeRequest
class	CRequestStateGuard
class	CWorkerNodeJobWatchers
class	CGridControlThread
class	CGridCleanupThread
class	CWorkerNodeIdleThread
class	CIdleWatcher
Defines
#define	NCBI_USE_ERRCODE_X   ConnServ_WorkerNode
Typedefs
typedef set< IWorkerNodeCleanupEventListener * >	TListeners
Functions
static void	s_TlsCleanup (CGridThreadContext *p_value, void *)
Variables
TListeners	m_Listeners
CFastMutex	m_ListenersLock
CWorkerNodeCleanup *	m_WorkerNodeCleanup
static CStaticTls< CGridThreadContext >	s_tls
static bool	s_ReqEventsDisabled = false
const char *	kServerSec = "server"

---

Define Documentation

#define NCBI_USE_ERRCODE_X   ConnServ_WorkerNode

Definition at line 65 of file grid_worker.cpp.

---

Typedef Documentation

typedef set<IWorkerNodeCleanupEventListener*> TListeners

Definition at line 85 of file grid_worker.cpp.

---

Function Documentation

static void s_TlsCleanup (  CGridThreadContext *  p_value, void *  )  [static]

Definition at line 284 of file grid_worker.cpp. Referenced by CWorkerNodeRequest::Process().

---

Variable Documentation

const char* kServerSec = "server"

Definition at line 876 of file grid_worker.cpp.

TListeners m_Listeners

Definition at line 95 of file grid_worker.cpp.

CFastMutex m_ListenersLock

Definition at line 96 of file grid_worker.cpp.

CWorkerNodeCleanup* m_WorkerNodeCleanup

Definition at line 150 of file grid_worker.cpp.

bool s_ReqEventsDisabled = false [static]

Definition at line 331 of file grid_worker.cpp. Referenced by CGridWorkerNode::DisableDefaultRequestEventLogging().

CStaticTls<CGridThreadContext> s_tls [static]

Definition at line 289 of file grid_worker.cpp. Referenced by CWorkerNodeRequest::Process().

---