ICP
1
|
#include <Qxtrm_driver.h>
Public Member Functions | |
Qxtrm_channel (Poco::SharedPtr< Quixtream > qx, const std::string &chan_name) | |
virtual | ~Qxtrm_channel () |
void | RDMAWrite (uint32_t value, unsigned int remote_address) |
void | RDMARead (uint32_t &value, unsigned int remote_address) |
void | RDMARead (void *buffer, unsigned int len, unsigned int remote_address) |
void | RDMAWrite (const void *buffer, unsigned int len, unsigned int remote_address) |
void | blockSend (const void *buffer, unsigned int len) |
void | blockReceive (void *buffer, unsigned int len) |
void | streamSend (const void *buffer, unsigned int len) |
void | streamReceive (qxtrmStreamCallbackFunc pCallback, unsigned int interval) |
receives one segment More... | |
void | streamReceive () |
receives one segment More... | |
void | RDMARegisterMemory (void *local_address, unsigned int len, unsigned int rdmaAddr) |
void | RDMAUnregisterMemory (unsigned int rdmaAddr) |
std::string | channelStatus () const |
std::ostream & | channelTransferStats (std::ostream &os) const |
std::ostream & | channelStatus (std::ostream &os) const |
Static Public Member Functions | |
static void | outputStreamDataCallback (char *pDataBuffer, unsigned int callbackSize, bool segmentEnd) |
Static Public Attributes | |
static FILE * | m_outstream = NULL |
static int | m_outstream_word_size = 4 |
static int | m_outstream_columns = 10 |
Private Member Functions | |
void | channelStatsHelper (int chan, qxtrmTransStatsCmd cmd, const char *mess, std::ostream &oss) const |
Private Attributes | |
Poco::SharedPtr< Quixtream > | m_qx |
int | m_chan_id |
std::string | m_chan_name |
Additional Inherited Members | |
Protected Member Functions inherited from ISIS::Base | |
Base (const std::string &logger_name="UNKNOWN") | |
void | setLoggerName (const std::string &logger_name) |
virtual | ~Base () |
virtual std::string | loggingPrefix () const |
void | setThisLoggerLevel (int level) |
Static Protected Member Functions inherited from ISIS::Base | |
static void | setAllLoggerLevel (int level) |
Protected Attributes inherited from ISIS::Base | |
Poco::Logger * | m_logger |
Poco::LogStream * | m_logstr |
Poco::Mutex | m_logger_lock |
Definition at line 24 of file Qxtrm_driver.h.
Qxtrm_channel::Qxtrm_channel | ( | Poco::SharedPtr< Quixtream > | qx, |
const std::string & | chan_name | ||
) |
Definition at line 39 of file Qxtrm_driver.cpp.
References INVALID_QXTRM_CHANNEL, LOGSTR_INFORMATION, m_chan_id, m_chan_name, and ISIS::Base::setLoggerName().
|
virtual |
Definition at line 50 of file Qxtrm_driver.cpp.
void Qxtrm_channel::blockReceive | ( | void * | buffer, |
unsigned int | len | ||
) |
Definition at line 136 of file Qxtrm_driver.cpp.
References LOGSTR_INFORMATION, m_chan_id, m_chan_name, and m_qx.
void Qxtrm_channel::blockSend | ( | const void * | buffer, |
unsigned int | len | ||
) |
Definition at line 125 of file Qxtrm_driver.cpp.
References LOGSTR_INFORMATION, m_chan_id, m_chan_name, and m_qx.
|
private |
Definition at line 92 of file Qxtrm_driver.cpp.
References m_qx, and Qxtrm_driver::qxtrmStatusMessage().
Referenced by channelTransferStats().
std::string Qxtrm_channel::channelStatus | ( | ) | const |
Definition at line 77 of file Qxtrm_driver.cpp.
References m_chan_id, m_qx, Qxtrm_driver::qxtrmChannelStatusMessage(), and Qxtrm_driver::qxtrmStatusMessage().
Referenced by channelStatus().
std::ostream & Qxtrm_channel::channelStatus | ( | std::ostream & | os | ) | const |
Definition at line 118 of file Qxtrm_driver.cpp.
References channelStatus(), m_chan_id, and m_chan_name.
std::ostream & Qxtrm_channel::channelTransferStats | ( | std::ostream & | os | ) | const |
Definition at line 106 of file Qxtrm_driver.cpp.
References channelStatsHelper(), m_chan_id, and m_chan_name.
|
static |
Definition at line 232 of file Qxtrm_driver.cpp.
References m_outstream, m_outstream_columns, and m_outstream_word_size.
Referenced by streamReceive().
|
inline |
void Qxtrm_channel::RDMARead | ( | void * | buffer, |
unsigned int | len, | ||
unsigned int | remote_address | ||
) |
Definition at line 54 of file Qxtrm_driver.cpp.
References LOGSTR_INFORMATION, m_chan_id, m_chan_name, and m_qx.
void Qxtrm_channel::RDMARegisterMemory | ( | void * | local_address, |
unsigned int | len, | ||
unsigned int | rdmaAddr | ||
) |
Definition at line 273 of file Qxtrm_driver.cpp.
void Qxtrm_channel::RDMAUnregisterMemory | ( | unsigned int | rdmaAddr | ) |
Definition at line 282 of file Qxtrm_driver.cpp.
|
inline |
void Qxtrm_channel::RDMAWrite | ( | const void * | buffer, |
unsigned int | len, | ||
unsigned int | remote_address | ||
) |
Definition at line 65 of file Qxtrm_driver.cpp.
References LOGSTR_INFORMATION, m_chan_id, m_chan_name, and m_qx.
void Qxtrm_channel::streamReceive | ( | qxtrmStreamCallbackFunc | pCallback, |
unsigned int | interval | ||
) |
receives one segment
Definition at line 210 of file Qxtrm_driver.cpp.
References LOGSTR_INFORMATION, m_chan_id, m_chan_name, and m_qx.
void Qxtrm_channel::streamReceive | ( | ) |
receives one segment
Definition at line 167 of file Qxtrm_driver.cpp.
References LOGSTR_INFORMATION, m_chan_id, m_chan_name, m_qx, and outputStreamDataCallback().
void Qxtrm_channel::streamSend | ( | const void * | buffer, |
unsigned int | len | ||
) |
Definition at line 148 of file Qxtrm_driver.cpp.
References LOGSTR_INFORMATION, m_chan_id, m_chan_name, and m_qx.
|
private |
Definition at line 27 of file Qxtrm_driver.h.
Referenced by blockReceive(), blockSend(), channelStatus(), channelTransferStats(), Qxtrm_channel(), RDMARead(), RDMARegisterMemory(), RDMAUnregisterMemory(), RDMAWrite(), streamReceive(), and streamSend().
|
private |
Definition at line 28 of file Qxtrm_driver.h.
Referenced by blockReceive(), blockSend(), channelStatus(), channelTransferStats(), Qxtrm_channel(), RDMARead(), RDMAWrite(), streamReceive(), and streamSend().
|
static |
Definition at line 48 of file Qxtrm_driver.h.
Referenced by outputStreamDataCallback().
|
static |
Definition at line 50 of file Qxtrm_driver.h.
Referenced by outputStreamDataCallback().
|
static |
Definition at line 49 of file Qxtrm_driver.h.
Referenced by outputStreamDataCallback().
|
private |
Definition at line 26 of file Qxtrm_driver.h.
Referenced by blockReceive(), blockSend(), channelStatsHelper(), channelStatus(), RDMARead(), RDMARegisterMemory(), RDMAUnregisterMemory(), RDMAWrite(), streamReceive(), and streamSend().