OPeNDAP Hyrax Back End Server (BES)
Updated for version 3.8.3
|
#include <PPTServer.h>
Public Member Functions | |
virtual void | brokenPipe () |
virtual void | closeConnection () |
virtual void | dump (ostream &strm) const |
dumps information about this object | |
virtual string | exit () |
virtual ostream * | getOutputStream () |
virtual unsigned int | getRecvChunkSize () |
virtual unsigned int | getSendChunkSize () |
virtual Socket * | getSocket () |
virtual void | initConnection () |
Using the info passed into the SocketLister, wait for an inbound request (see SocketListener::accept()). | |
virtual bool | isConnected () |
PPTServer (ServerHandler *handler, SocketListener *listener, bool isSecure) | |
virtual bool | receive (map< string, string > &extensions, ostream *strm=0) |
receive a chunk of either extensions into the specified map or data into the specified stream | |
virtual void | send (const string &buffer, map< string, string > &extensions) |
Send a message to the server. | |
virtual void | sendExit () |
Send the exit token as an extension. | |
virtual void | sendExtensions (map< string, string > &extensions) |
send the specified extensions | |
virtual void | setOutputStream (ostream *strm) |
virtual | ~PPTServer () |
Protected Member Functions | |
virtual void | read_extensions (map< string, string > &extensions, const string &xstr) |
the string passed are extensions, read them and store the name/value pairs into the passed map | |
virtual int | readBufferNonBlocking (char *inBuff, const int buff_size) |
read a buffer of data from the socket without blocking | |
virtual void | send (const string &buffer) |
sends the buffer to the socket | |
Protected Attributes | |
bool | _brokenPipe |
Socket * | _mySock |
ostream * | _out |
Definition at line 42 of file PPTServer.h.
PPTServer::PPTServer | ( | ServerHandler * | handler, |
SocketListener * | listener, | ||
bool | isSecure | ||
) |
Definition at line 59 of file PPTServer.cc.
PPTServer::~PPTServer | ( | ) | [virtual] |
Definition at line 92 of file PPTServer.cc.
virtual void Connection::brokenPipe | ( | ) | [inline, virtual, inherited] |
Definition at line 98 of file Connection.h.
References Connection::_brokenPipe.
Referenced by CmdClient::brokenPipe().
void PPTServer::closeConnection | ( | ) | [virtual] |
Implements PPTConnection.
Definition at line 171 of file PPTServer.cc.
References Connection::_mySock, and Socket::close().
Referenced by ServerApp::terminate().
void PPTServer::dump | ( | ostream & | strm | ) | const [virtual] |
dumps information about this object
Displays the pointer value of this instance
strm | C++ i/o stream to dump the information to |
Reimplemented from PPTConnection.
Definition at line 277 of file PPTServer.cc.
References ServerHandler::dump(), SocketListener::dump(), BESIndent::Indent(), BESIndent::LMarg(), and BESIndent::UnIndent().
Referenced by ServerApp::dump().
virtual string PPTConnection::exit | ( | ) | [inline, virtual, inherited] |
Implements Connection.
Definition at line 85 of file PPTConnection.h.
References PPTProtocol::PPT_EXIT_NOW.
virtual ostream* Connection::getOutputStream | ( | ) | [inline, virtual, inherited] |
Definition at line 93 of file Connection.h.
References Connection::_out.
unsigned int PPTConnection::getRecvChunkSize | ( | ) | [virtual, inherited] |
Implements Connection.
Definition at line 489 of file PPTConnection.cc.
References Connection::_mySock, Socket::getRecvBufferSize(), and PPT_CHUNK_HEADER_SPACE.
unsigned int PPTConnection::getSendChunkSize | ( | ) | [virtual, inherited] |
Implements Connection.
Definition at line 495 of file PPTConnection.cc.
References Connection::_mySock, Socket::getSendBufferSize(), and PPT_CHUNK_HEADER_SPACE.
virtual Socket* Connection::getSocket | ( | ) | [inline, virtual, inherited] |
Definition at line 77 of file Connection.h.
References Connection::_mySock.
Referenced by PPTConnection::readBufferNonBlocking().
void PPTServer::initConnection | ( | ) | [virtual] |
Using the info passed into the SocketLister, wait for an inbound request (see SocketListener::accept()).
When one is found, do the welcome message stuff (welcomeClient()) and then pass this
to the handler's handle
method. Note that this
is a pointer to a PPTServer which is a kind of Connection.
Implements PPTConnection.
Definition at line 146 of file PPTServer.cc.
References Connection::_mySock, SocketListener::accept(), Socket::allowConnection(), Socket::close(), and ServerHandler::handle().
Referenced by ServerApp::run().
virtual bool Connection::isConnected | ( | ) | [inline, virtual, inherited] |
Definition at line 82 of file Connection.h.
References Connection::_mySock, and Socket::isConnected().
Referenced by CmdClient::isConnected().
void PPTConnection::read_extensions | ( | map< string, string > & | extensions, |
const string & | xstr | ||
) | [protected, virtual, inherited] |
the string passed are extensions, read them and store the name/value pairs into the passed map
It has already been determined that extensions were read in the chunk. Deconstruct the name/value pairs and store them into the map passed. Each extension ends with a semicolon.
extensions | map to store the name/value pairs in |
xstr | string of extensions in the form *(name[=value];) |
Definition at line 393 of file PPTConnection.cc.
Referenced by PPTConnection::receive().
int PPTConnection::readBufferNonBlocking | ( | char * | inBuff, |
const int | buffer_size | ||
) | [protected, virtual, inherited] |
read a buffer of data from the socket without blocking
Try to read a buffer of data without blocking. We will try _timeout times, waiting 1000 milliseconds between each try. The variable _timeout is passed into the constructor.
inBuff | buffer to store the data into |
buffer_size | the size of the passed buffer |
Definition at line 451 of file PPTConnection.cc.
References Connection::getSocket(), and Socket::getSocketDescriptor().
Referenced by PPTClient::initConnection().
bool PPTConnection::receive | ( | map< string, string > & | extensions, |
ostream * | strm = 0 |
||
) | [virtual, inherited] |
receive a chunk of either extensions into the specified map or data into the specified stream
This receive will read a chunk of information from the socket and determine if what is read are extensions, where they are stored in the extensions map passed, or data, which is written to the specified stream
The first 7 bytes is the length of the information that was passed. The 5th character is either the character 'x', signifying that extensions were sent, or 'd', signifying that data was sent.
extensions | map to store the name/value paris into |
strm | output stream to write the received data into |
Implements Connection.
Definition at line 261 of file PPTConnection.cc.
References Connection::_mySock, Connection::_out, BESDEBUG, Socket::getRecvBufferSize(), and PPTConnection::read_extensions().
void PPTConnection::send | ( | const string & | buffer | ) | [protected, virtual, inherited] |
sends the buffer to the socket
the buffer includes the length, extensions, data, whatever is to be sent
buffer | data buffer to send to the socket |
Implements Connection.
Definition at line 190 of file PPTConnection.cc.
References Connection::_mySock, BESDEBUG, and Socket::send().
Referenced by PPTClient::initConnection(), PPTConnection::sendExit(), and PPTConnection::sendExtensions().
void PPTConnection::send | ( | const string & | buffer, |
map< string, string > & | extensions | ||
) | [virtual, inherited] |
Send a message to the server.
Sends the specified message buffer to the server followed by a buffer of length 0 to signify the end of the message
A buffer sent to the server will follow the following form:
Chunked-Body = chunk-extensions chunk last-chunk chunk-extensions= chunk-size 'x' *( chunk-ext-name [ "=" chunk-ext-val ] ; chunk = chunk-size 'd' chunk-data chunk-size = 8HEX last-chunk = 7("0") d chunk-ext-name = token chunk-ext-val = token | quoted-string chunk-data = chunk-size(OCTET)
If there are extensions then they are sent first. The length of the extensions is sent first, followed by the character 'x', and then the extensions in the format name[=value];
Then the buffer itself is sent. The length of the buffer is sent followed by the character 'd' signifying data is being transmitted.
if the buffer is empty then this represents the last chunk
buffer | buffer of data to send |
extensions | list of name/value pairs sent |
Implements Connection.
Definition at line 101 of file PPTConnection.cc.
void PPTConnection::sendExit | ( | ) | [virtual, inherited] |
Send the exit token as an extension.
Implements Connection.
Definition at line 121 of file PPTConnection.cc.
References PPTProtocol::PPT_EXIT_NOW, and PPTConnection::send().
Referenced by PPTClient::closeConnection().
void PPTConnection::sendExtensions | ( | map< string, string > & | extensions | ) | [virtual, inherited] |
send the specified extensions
extensions | name/value paris to be sent |
Implements Connection.
Definition at line 158 of file PPTConnection.cc.
References PPTConnection::send().
virtual void Connection::setOutputStream | ( | ostream * | strm | ) | [inline, virtual, inherited] |
Definition at line 89 of file Connection.h.
References Connection::_out.
bool Connection::_brokenPipe [protected, inherited] |
Definition at line 52 of file Connection.h.
Referenced by Connection::brokenPipe(), PPTClient::closeConnection(), and Connection::dump().
Socket* Connection::_mySock [protected, inherited] |
Definition at line 50 of file Connection.h.
Referenced by PPTClient::closeConnection(), closeConnection(), Connection::dump(), PPTConnection::getRecvChunkSize(), PPTConnection::getSendChunkSize(), Connection::getSocket(), initConnection(), Connection::isConnected(), PPTClient::PPTClient(), PPTConnection::receive(), PPTConnection::send(), and PPTClient::~PPTClient().
ostream* Connection::_out [protected, inherited] |
Definition at line 51 of file Connection.h.
Referenced by Connection::dump(), Connection::getOutputStream(), PPTConnection::receive(), and Connection::setOutputStream().