rasdaman complete source
|
#include <rnpservercomm.hh>
Public Member Functions | |
RnpRasDaManComm () throw () | |
~RnpRasDaManComm () throw () | |
void | processRequest (CommBuffer *receiverBuffer, CommBuffer *transmiterBuffer, RnpTransport::CarrierProtocol, RnpServerJob *callingJob) throw () |
void | setTimeoutInterval (int seconds) |
void | checkForTimeout () |
![]() | |
RnpBaseServerComm () throw () | |
Default constructor - 1 server job. More... | |
virtual | ~RnpBaseServerComm () throw () |
Destructor. More... | |
bool | setServerJobs (int nrOfServerJobs) throw () |
int | countServerJobs () throw () |
Returns the number of server jobs. More... | |
void | connectToCommunicator (NbCommunicator &) |
Connect to the communicator. It also creates the jobs. Throws whatever new throws. Assert: no other connection! More... | |
bool | disconnectFromCommunicator () throw () |
void | setTransmitterBufferSize (int) throw () |
Set the transmitter buffer size. More... | |
int | getTransmitterBufferSize () throw () |
Returns the transmitter buffer size. More... | |
void | communicatorShouldExit () throw () |
Additional Inherited Members | |
![]() | |
const char * | getNextAsString (RnpQuark parameterType) const |
Returns next parameter as string(can be NULL), verifying the parameter type. More... | |
int | getNextAsInteger (RnpQuark parameterType) const |
Returns next parameter as integer, verifying the parameter type. More... | |
float | getNextAsFloat (RnpQuark parameterType) const |
Returns next parameter as float, verifying the parameter type. More... | |
double | getNextAsDouble (RnpQuark parameterType) const |
Returns next parameter as double, verifying the parameter type. More... | |
const void * | getNextAsOpaque (RnpQuark parameterType) const |
Returns next parameter as const void* (can be NULL), verifying the parameter type. More... | |
int | getCurrentParameterLength () const throw () |
Returns the length of the data of the current parameter. More... | |
void | answerAkgSerializable (AkgSerializableException &) throw () |
Helper function to serialize an 'AkgException'. More... | |
void | answerSTLException (exception &) throw () |
Helper function to serialize an 'exception' (based on it's 'what()'-member. More... | |
void | answerUnknownError () throw () |
Helper function to serialize an unknown exception. More... | |
void | discardFragment () throw () |
Helper function to discard a fragment. More... | |
void | startOkAnswer () throw () |
Start building an OK-answer. More... | |
void | endOkAnswer () throw () |
Just for completeness, it's only an 'encoder.endFragment()'. More... | |
![]() | |
RnpProtocolDecoder | decoder |
RnpTransmitter | encoder |
RnpRasDaManComm::RnpRasDaManComm | ( | ) | ||
throw | ( | |||
) |
RnpRasDaManComm::~RnpRasDaManComm | ( | ) | ||
throw | ( | |||
) |
void RnpRasDaManComm::checkForTimeout | ( | ) |
|
virtual |
The heart of the class. It takes the request, decodes it, sends every fragment to the 'decodeFragment()', which has to dispatch the commands to the specific functions. These functions have to use 'decoder' and 'encoder' to do their job and might throw whatever is appropriate. 'processRequest()' catches 'AkgException', 'exception' and (...) and converts them for transmission. If you don't like this version, make another one
Reimplemented from rnp::RnpBaseServerComm.
void RnpRasDaManComm::setTimeoutInterval | ( | int | seconds | ) |