Ginan
|
Public Member Functions | |
SisnetStream (const string &path) | |
void | sisnetHandler (const boost::system::error_code &err) |
void | sisnetResponseHandler (const boost::system::error_code &err) |
void | sisnetStartHandler (const boost::system::error_code &err) |
void | requestResponseHandler (const boost::system::error_code &err) override |
~SisnetStream () | |
Public Member Functions inherited from TcpSocket | |
TcpSocket (const string &url_str, const string &readUntil="\r\n\r\n") | |
void | setUrl (const string &url_str) |
void | connect () |
void | disconnect () |
void | startRead (bool chunked) |
void | timeoutHandler (const boost::system::error_code &err) |
void | delayedReconnect () |
void | connectHandler (const boost::system::error_code &err, tcp::resolver::iterator endpoint_iterator) |
void | logChunkError () |
void | dataChunkDownloaded (vector< char > &dataChunk) |
virtual void | readContentDownloaded (vector< char > content) |
virtual void | connected () |
virtual void | messageChunkLog (string message) |
virtual void | networkLog (string message) |
void | getData () override |
void | connectionError (const boost::system::error_code &err, string operation) |
virtual | ~TcpSocket ()=default |
Public Member Functions inherited from NetworkStatistics | |
string | getNetworkStatistics (GTime now, string label) |
void | onConnectedStatistics () |
void | onDisconnectedStatistics () |
void | onChunkSentStatistics () |
void | onChunkReceivedStatistics () |
void | onErrorStatistics (const boost::system::error_code &err, string operation) |
Public Member Functions inherited from SerialStream | |
SerialStream () | |
SerialStream (string path) | |
void | openStream () |
unique_ptr< std::istream > | getIStream_ptr () override |
virtual | ~SerialStream () |
Public Member Functions inherited from Stream | |
virtual bool | isDead () |
Check to see if this stream has run out of data. | |
virtual | ~Stream ()=default |
Additional Inherited Members | |
Static Public Member Functions inherited from TcpSocket | |
static void | runService () |
static void | startClients () |
Data Fields inherited from TcpSocket | |
URL | url |
double | reconnectDelay = 1 |
int | disconnectionCount = 0 |
bool | isConnected = false |
int | numberErroredChunks = 0 |
bool | logHttpSentReceived = false |
unsigned int | content_length = 0 |
B_asio::ssl::context | sslContext |
Data Fields inherited from NetworkStatistics | |
string | streamName |
GTime | startTime |
GTime | endTime |
string | networkTraceFilename |
int | connectCount = 0 |
int | disconnectCount = 0 |
int | chunksSent = 0 |
int | chunksReceived = 0 |
boost::posix_time::time_duration | connectedDuration = boost::posix_time::hours(0) |
boost::posix_time::time_duration | disconnectedDuration = boost::posix_time::hours(0) |
Data Fields inherited from SerialStream | |
string | path |
int | fileDescriptor = -1 |
vector< char > | receivedData |
Data Fields inherited from Stream | |
string | sourceString |
Static Public Attributes inherited from TcpSocket | |
static B_asio::io_service | ioService |
Protected Attributes inherited from TcpSocket | |
std::shared_ptr< tcp::socket > | _socket |
tcp::socket * | socket_ptr |
std::shared_ptr< ssl_socket > | _sslsocket |
std::shared_ptr< tcp::resolver > | _resolver |
boost::asio::deadline_timer | timer |
string | readUntilString |
string | requestString |
string | responseString |
boost::asio::streambuf | request |
boost::asio::streambuf | downloadBuf |
vector< char > | receivedTcpData |
|
inline |
|
inline |
|
overridevirtual |
void SisnetStream::sisnetHandler | ( | const boost::system::error_code & | err | ) |
void SisnetStream::sisnetResponseHandler | ( | const boost::system::error_code & | err | ) |
void SisnetStream::sisnetStartHandler | ( | const boost::system::error_code & | err | ) |