rasdaman complete source
|
#include <rnpservercomm.hh>
Public Member Functions | |
RnpRasserverJob () throw () | |
![]() | |
RnpServerJob () throw () | |
Default constructor. More... | |
void | init (RnpBaseServerComm *) throw () |
void | processRequest () throw () |
Calls the 'RnpBaseServerComm->processRequest()' and than initiates the transmission. More... | |
![]() | |
NbServerJob () throw () | |
Default constructor. More... | |
void | initOnAttach (Selector *pselector) throw () |
acceptStatus | acceptConnection (ListenSocket &listenSocket) throw () |
SocketAddress | getClientSocketAddress () throw () |
Returns the SocketAddress of the client. More... | |
HostAddress | getClientHostAddress () throw () |
Returns the HostAddress of the client. More... | |
![]() | |
virtual | ~NbJob () throw () |
workingStatus | getStatus () throw () |
Returns the working status. More... | |
bool | isOperationPending () throw () |
bool | isAccepting () throw () |
Returns true if the job is ready to accept a connection. More... | |
bool | isReading () throw () |
Returns true if the job is reading data. More... | |
bool | isWriting () throw () |
Returns true if the job is writing data. More... | |
bool | isProcessing () throw () |
Returns true if the job is processing. More... | |
bool | readPartialMessage () throw () |
bool | writePartialMessage () throw () |
void | clearConnection () throw () |
Clears the connection - closes the socket and removes it from the Selector. More... | |
int | getSocket () throw () |
Returns the OS file descriptor for the socket. More... | |
int | getErrno () throw () |
Returns the errno of the last socket operation. More... | |
virtual bool | cleanUpIfTimeout () throw () |
Additional Inherited Members | |
![]() | |
enum | acceptStatus { acs_nopending = 0, acs_Iambusy = 1, acs_accepted = 2 } |
Status regarding accepting a new job. More... | |
enum | workingStatus { wks_notdefined = 0, wks_accepting = 1, wks_reading = 2, wks_writing = 3, wks_processing = 4 } |
Status during the lifetime of a job. More... | |
![]() | |
static void | setCurrentTime () throw () |
static void | setTimeoutInterval (time_t x) throw () |
static time_t | getTimeoutInterval () throw () |
Returns the timeout interval set for the jobs. More... | |
![]() | |
void | resetJob () throw () |
![]() | |
void | readyToWriteAnswer () throw () |
helper function, call it in "processRequest" to switch to writing More... | |
![]() | |
NbJob (FileDescriptor &) throw () | |
Protected constructor, taking a FileDescriptor, usually a Socket. More... | |
bool | setReading () throw () |
Helper function for setting the job in read modus. More... | |
bool | setWriting () throw () |
Helper function for setting the job in write modus. More... | |
void | action () throw () |
Helper function which marks the current moment, so timeout counter is reset. More... | |
![]() | |
RnpBaseServerComm * | serverCommPtr |
RnpReceiver | rnpReceiver |
CommBuffer | transmiterBuffer |
![]() | |
ServerSocket | serverSocket |
![]() | |
workingStatus | status |
FileDescriptor & | fdRef |
Selector * | selectorPtr |
CommBuffer * | currentBufferPtr |
time_t | lastActionTime |
![]() | |
static time_t | timeOutInterv |
static time_t | currentTime |
RnpRasserverJob::RnpRasserverJob | ( | ) | ||
throw | ( | |||
) |