#include <APIServer.hpp>

Public Member Functions
	APIServer ()

virtual	~APIServer ()

void	terminateServer ()

void	initServer ()

void	listenForConnections ()

void	processMessages (SysServerConnection *connection)

ServiceReturn	shutdown ()

virtual bool	isStoppable ()

void	cleanupProcessResources (ServiceMessage &message)

virtual void	stop ()

void	requestLock ()

void	releaseLock ()

APIServerInstance *	getInstance (ServiceMessage &m)

void	dispatch (ServiceMessage &message)

void	sessionTerminated (APIServerThread *thread)

void	cleanupTerminatedSessions ()

Protected Attributes
SysMutex	lock

SysServerStream	server

bool	serverActive

APIServerInstance *	instances

std::list< APIServerThread * >	terminatedThreads

Detailed Description

Definition at line 52 of file APIServer.hpp.

Constructor & Destructor Documentation

◆ APIServer()

APIServer::APIServer ( )

inline

Definition at line 55 of file APIServer.hpp.

◆ ~APIServer()

virtual APIServer::~APIServer ( )

inlinevirtual

Definition at line 56 of file APIServer.hpp.

Member Function Documentation

◆ cleanupProcessResources()

void APIServer::cleanupProcessResources ( ServiceMessage & message )

Cleanup sessions specific resources after a Rexx process terminates.

Parameters

message The service message with the session information.

Definition at line 344 of file APIServer.cpp.

References APIServerInstance::cleanupProcessResources(), and getInstance().

Referenced by dispatch().

◆ cleanupTerminatedSessions()

void APIServer::cleanupTerminatedSessions ( )

Cleanup the resources devoted to threads that have terminated.

Definition at line 124 of file APIServer.cpp.

References SysThread::terminate(), and terminatedThreads.

Referenced by listenForConnections().

◆ dispatch()

void APIServer::dispatch ( ServiceMessage & message )

Dispatch an API server control message.

Parameters

message The control message parameter.

Definition at line 307 of file APIServer.cpp.

References cleanupProcessResources(), CONNECTION_ACTIVE, MESSAGE_OK, ServiceMessage::operation, ServiceMessage::parameter1, PROCESS_CLEANUP, ServiceMessage::result, REXXAPI_VERSION, SERVER_FAILURE, ServiceMessage::setExceptionInfo(), shutdown(), and SHUTDOWN_SERVER.

Referenced by processMessages().

◆ getInstance()

APIServerInstance * APIServer::getInstance ( ServiceMessage & m )

Get the server instance associate with a particular userid, creating a new instance if this is the first time we've processed a request for this id.

Parameters

m	The service message associated with the request.

Returns: A pointer to the correct instance.

Definition at line 407 of file APIServer.cpp.

References instances, APIServerInstance::isUser(), and APIServerInstance::next.

Referenced by cleanupProcessResources(), and processMessages().

◆ initServer()

void APIServer::initServer ( )

Initialize the server side of the operation.

Definition at line 53 of file APIServer.cpp.

References SysMutex::create(), lock, SysServerStream::make(), REXX_API_PORT, server, SERVER_FAILURE, and serverActive.

Referenced by Run().

◆ isStoppable()

bool APIServer::isStoppable ( )

virtual

Test to see if the api server is in a state where it can be stopped. A stoppable state implies there are no session specific resources currently active in the server.

Returns: True if the server is stoppable, false otherwise.

Definition at line 383 of file APIServer.cpp.

References instances, APIServerInstance::isStoppable(), and APIServerInstance::next.

Referenced by shutdown().

◆ listenForConnections()

void APIServer::listenForConnections ( )

Process the Rexx API requests as a queue of messages. Each message is handled through to completion, so the message queue is the synchronization point.

Definition at line 82 of file APIServer.cpp.

References cleanupTerminatedSessions(), SysServerStream::connect(), server, serverActive, and APIServerThread::start().

Referenced by Run().

◆ processMessages()

void APIServer::processMessages ( SysServerConnection * connection )

Process the Rexx API requests as a queue of messages. Each message is handled through to completion, so the message queue is the synchronization point.

Definition at line 215 of file APIServer.cpp.

References APIManager, CLOSE_CONNECTION, CONCURRENCY_TRACE, Utilities::currentThreadId(), dbgprintf(), SysServerConnection::disconnect(), dispatch(), APIServerInstance::dispatch(), getInstance(), MacroSpaceManager, MESSAGE_OK, ServiceMessage::messageTarget, ServiceMessage::nameArg, ServiceMessage::operation, QueueManager, ServiceMessage::readMessage(), RegistrationManager, ServiceMessage::result, rxapiCounter, SERVER_ERROR, serverActive, ServerManagerText(), ServerOperationText(), ServiceMessage::session, Utilities::traceConcurrency(), ServiceMessage::userid, and ServiceMessage::writeResult().