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... | |
virtual void | processRequest (CommBuffer *receiverBuffer, CommBuffer *transmiterBuffer, RnpTransport::CarrierProtocol, RnpServerJob *callingJob) throw () |
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 | ( | ) |
void RnpRasDaManComm::processRequest | ( | CommBuffer * | receiverBuffer, |
CommBuffer * | transmiterBuffer, | ||
RnpTransport::CarrierProtocol | , | ||
RnpServerJob * | callingJob | ||
) | |||
throw | ( | ||
) |
void RnpRasDaManComm::setTimeoutInterval | ( | int | seconds | ) |