#include <serverbase.h>
Inheritance diagram for WormServerBase:
Public Member Functions | |
HANDLE_STATUS | HandleConfigLine (ConfigSource *p_parser) |
void | StartThreadFunc (void *p_arg) |
WormServerBase () | |
~WormServerBase () | |
WORM_STATUS_CODE | Run () |
Protected Member Functions | |
THREAD_RETURN | Listener (void *p_dummy) |
void | CheckConfig () |
bool | SetMaxThreads (unsigned short p_count) |
int | ListenForMsg (SOCKET p_descriptor, char *p_rcv_buffer, int *p_length, int p_timeoutms=-1) |
WORM_STATUS_CODE | SendMessage (const SOCKET p_descriptor, const char *p_msg, int *p_length) |
void | SendStatus (unsigned char type, short ierr, char *note) |
void | ReleaseServiceThreadInfo (SOCKET p_descriptor) |
virtual bool | PrepareToRun () |
virtual WORM_STATUS_CODE | MainThreadActions () |
virtual void | FinishedRunning () |
virtual THREAD_RETURN | ClientServicer (void *p_socketdescriptor)=0 |
Static Protected Member Functions | |
bool | DoSCNLsMatch (const char *p_s1, const char *p_c1, const char *p_n1, const char *p_l1, const char *p_s2, const char *p_c2, const char *p_n2, const char *p_l2) |
Protected Attributes | |
bool | SocketDebug |
char | ServerIPAddr [20] |
int | ServerPort |
int | SendTimeoutMS |
TO_THREAD_ID | ListenerThreadId |
long | LastListenerPulse |
int | LoggingLevel |
SERVICETHREAD_MAP | ThreadsInfo |
int | RecvTimeoutMS |
WORM_RING_NAME | CommandRingName |
WORM_RING_ID | CommandRingKey |
SHM_INFO | CommandRegion |
bool | Running |
Private Attributes | |
SOCKET | PassiveSocket |
unsigned int | MaxServiceThreads |
|
Definition at line 73 of file serverbase.cpp. References SHM_INFO::addr, CommandRegion, CommandRingKey, TLogger::Logit(), TGlobalUtils::LookupMessageTypeId(), MaxServiceThreads, PassiveSocket, RecvTimeoutMS, Running, SendTimeoutMS, ServerPort, SocketDebug, SocketSysInit(), WORM_MSGTYPE_INVALID, and WORM_RING_INVALID. |
|
Definition at line 109 of file serverbase.cpp. References TTimeFuncs::MSecSleep(), and Running. |
|
Reimplemented from TConfigurable. Reimplemented in DBMutableServer, MutableServerBase, RingReaderServer, and ServerTemplate. Definition at line 363 of file serverbase.cpp. References CommandRingKey, TConfigurable::ConfigState, TGlobalUtils::GetHeartbeatInt(), TLogger::Logit(), MIN_RECV_TIMEOUT_MS, RecvTimeoutMS, SendTimeoutMS, ServerPort, WORM_RING_INVALID, and WORM_STAT_BADSTATE. Referenced by RingReaderServer::CheckConfig(). |
|
Implemented in MutableServerBase. Referenced by StartThreadFunc(). |
|
Definition at line 21 of file serverbase.cpp. |
|
Reimplemented in RingReaderServer. Definition at line 266 of file serverbase.h. Referenced by Run(). |
|
Reimplemented from TConfigurable. Reimplemented in DBMutableServer, MutableServerBase, RingReaderServer, and ServerTemplate. Definition at line 416 of file serverbase.cpp. References CommandRingKey, ConfigSource::GetCurrentLine(), HANDLE_STATUS, HANDLER_INVALID, HANDLER_UNUSED, HANDLER_USED, ConfigSource::Int(), ConfigSource::INVALID_INT, ConfigSource::Its(), TLogger::Logit(), TGlobalUtils::LookupRingKey(), MaxServiceThreads, RecvTimeoutMS, SendTimeoutMS, SERVE_MAX_THREADS, ServerPort, SocketDebug, ConfigSource::String(), and WORM_RING_INVALID. Referenced by RingReaderServer::HandleConfigLine(), and MutableServerBase::HandleConfigLine(). |
|
|
Definition at line 118 of file serverbase.cpp. References TGlobalUtils::GetLoggingLevel(), TLogger::Logit(), recv_ew(), RecvTimeoutMS, THREAD_BLOCKINGSOCKET, THREAD_PROCESSING, ThreadsInfo, WORM_LOG_DETAILS, and WORM_LOG_ERRORS. Referenced by MutableServerBase::ClientServicer(), and MutableServerBase::TransmitRequest(). |
|
Reimplemented in MutableServerBase, and RingReaderServer. Definition at line 260 of file serverbase.h. References WORM_STAT_SUCCESS, and WORM_STATUS_CODE. Referenced by Run(). |
|
Reimplemented in DBMutableServer, MutableServerBase, RingReaderServer, and ServerTemplate. Definition at line 247 of file serverbase.h. References TGlobalUtils::GetLoggingLevel(). Referenced by MutableServerBase::PrepareToRun(), and Run(). |
|
Definition at line 231 of file serverbase.h. |
|
|
Definition at line 292 of file serverbase.cpp. References TGlobalUtils::GetLoggingLevel(), TLogger::Logit(), send_ew(), socketGetError_ew(), WORM_LOG_DEBUG, WORM_LOG_ERRORS, WORM_STAT_FAILURE, WORM_STAT_SUCCESS, and WORM_STATUS_CODE. Referenced by MutableServerBase::TransmitRequest(), and MutableServerBase::TransmitResult(). |
|
Definition at line 547 of file serverbase.cpp. References CommandRingKey, TGlobalUtils::GetThisInstallationId(), TGlobalUtils::GetThisModuleId(), MSG_LOGO::instid, TLogger::Logit(), TGlobalUtils::LookupMessageTypeId(), MSG_LOGO::mod, PUT_OK, tport_putmsg(), type, MSG_LOGO::type, and WORM_RING_INVALID. Referenced by MutableServerBase::CheckForThreadDeath(), RingReaderServer::MainThreadActions(), MutableServerBase::MainThreadActions(), Run(), and MutableServerBase::Stacker(). |
|
Definition at line 152 of file serverbase.h. References SERVE_MAX_THREADS. |
|
Implements ThreadableObject. Reimplemented in MutableServerBase. Definition at line 310 of file serverbase.h. References ClientServicer(), and Listener(). |
|
Definition at line 175 of file serverbase.h. Referenced by MutableServerBase::Handler(), Run(), MutableServerBase::Stacker(), WormServerBase(), and MutableServerBase::~MutableServerBase(). |
|
|
Definition at line 173 of file serverbase.h. |
|
Definition at line 116 of file serverbase.h. Referenced by MutableServerBase::CheckForThreadDeath(), Listener(), MutableServerBase::MainThreadActions(), and Run(). |
|
Definition at line 115 of file serverbase.h. |
|
|
Definition at line 100 of file serverbase.h. Referenced by HandleConfigLine(), Listener(), and WormServerBase(). |
|
Definition at line 98 of file serverbase.h. Referenced by Listener(), and WormServerBase(). |
|
Definition at line 169 of file serverbase.h. Referenced by CheckConfig(), MutableServerBase::CheckConfig(), MutableServerBase::ClientServicer(), HandleConfigLine(), ListenForMsg(), MutableServerBase::TransmitRequest(), and WormServerBase(). |
|
Definition at line 226 of file serverbase.h. Referenced by MutableServerBase::MainThreadActions(), Run(), MutableServerBase::Run(), WormServerBase(), and ~WormServerBase(). |
|
Definition at line 109 of file serverbase.h. Referenced by CheckConfig(), MutableServerBase::CheckConfig(), HandleConfigLine(), and WormServerBase(). |
|
Definition at line 106 of file serverbase.h. Referenced by Listener(). |
|
Definition at line 107 of file serverbase.h. Referenced by CheckConfig(), MutableServerBase::CheckConfig(), HandleConfigLine(), and WormServerBase(). |
|
Definition at line 104 of file serverbase.h. Referenced by HandleConfigLine(), and WormServerBase(). |
|
Definition at line 167 of file serverbase.h. Referenced by MutableServerBase::ClientServicer(), Listener(), ListenForMsg(), and MutableServerBase::TransmitRequest(). |