SelectDataObject::SelectDataObject()
{
- LogDebug("Enter");
+ LoggerD("Enter");
m_colCount = 0;
m_rowCount = 0;
SelectDataObject::~SelectDataObject()
{
- LogDebug("Enter");
+ LoggerD("Enter");
m_istream.close();
if (unlink(m_filePath.c_str()) != 0)
{
- LogError("Error while removing SelectDataObject.");
+ LoggerE("Error while removing SelectDataObject.");
}
}
void SelectDataObject::openResultPath(const std::string& filepath)
{
- LogDebug("Enter");
+ LoggerD("Enter");
m_filePath = filepath;
m_istream.open(m_filePath.c_str(), std::ios::binary);
if (m_istream.is_open())
{
- LogDebug("load header");
+ LoggerD("load header");
loadHeader();
- LogDebug("print header"); // debug
+ LoggerD("print header"); // debug
printHeader();
}
else
{
- LogDebug("fail open" << filepath);
+ LoggerD("fail open" << filepath);
}
}
void SelectDataObject::OnRequestReceived(const EventGetIndexedRowPtr& event)
{
- LogDebug("Enter");
+ LoggerD("Enter");
char *buf = NULL;
try
m_istream.read((char*)&type, sizeof(type)); // skip type
m_istream.read((char*)&size, sizeof(int)); // read size
- LogDebug(type << " - " << size << " ");
+ LoggerD(type << " - " << size << " ");
if (memorizedSize < size)
{
}
catch (const WrtDeviceApis::Commons::Exception& ex)
{
- LogError("Exception: " << ex.GetMessage());
+ LoggerE("Exception: " << ex.GetMessage());
event->setExceptionCode(ex.getCode());
}
}
void SelectDataObject::printHeader()
{
- LogDebug("Eneter");
+ LoggerD("Eneter");
for (size_t index = 0; index < m_headerInfo.size(); index++)
{
- LogDebug(m_headerInfo[index].m_type << " " << m_headerInfo[index].m_name);
+ LoggerD(m_headerInfo[index].m_type << " " << m_headerInfo[index].m_name);
}
}
int index = 0;
if (m_istream.good() == false)
- LogDebug("Error");
+ LoggerD("Error");
for (index = 0; index < m_colCount; index++)
{
size = 0;
m_istream.seekg(sizeof(int), std::ios::cur); // skip type
m_istream.read((char*)&size, sizeof(int)); // read size
- LogDebug(size << " ");
+ LoggerD(size << " ");
m_istream.seekg(size, std::ios::cur); // skip data
}