Commit 0f2b33f9 authored by Pavel Vainerman's avatar Pavel Vainerman

(Modbus): немного поменял вывод логов (сделал вывод продробных в level9)

parent eb6f42a3
...@@ -412,9 +412,7 @@ mbErrCode ModbusClient::recv_pdu( ModbusByte qfunc, ModbusMessage& rbuf, timeout ...@@ -412,9 +412,7 @@ mbErrCode ModbusClient::recv_pdu( ModbusByte qfunc, ModbusMessage& rbuf, timeout
if( k < sizeof(rbuf.pduhead.func) ) if( k < sizeof(rbuf.pduhead.func) )
{ {
if( dlog->is_warn() ) if( dlog->is_warn() )
{
dlog->warn() << "(recv): receive " << k << " bytes < " << sizeof(rbuf.pduhead.func) << endl; dlog->warn() << "(recv): receive " << k << " bytes < " << sizeof(rbuf.pduhead.func) << endl;
}
cleanupChannel(); cleanupChannel();
return erInvalidFormat; return erInvalidFormat;
...@@ -423,8 +421,8 @@ mbErrCode ModbusClient::recv_pdu( ModbusByte qfunc, ModbusMessage& rbuf, timeout ...@@ -423,8 +421,8 @@ mbErrCode ModbusClient::recv_pdu( ModbusByte qfunc, ModbusMessage& rbuf, timeout
bcnt += k; bcnt += k;
rbuf.dlen = 0; rbuf.dlen = 0;
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(recv): PDU: " << rbuf.pduhead << endl; dlog->level9() << "(recv): PDU: " << rbuf.pduhead << endl;
// обработка сообщения об ошибке... // обработка сообщения об ошибке...
if( rbuf.func() == (qfunc | MBErrMask) ) if( rbuf.func() == (qfunc | MBErrMask) )
......
...@@ -666,8 +666,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -666,8 +666,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
bcnt += k; bcnt += k;
rbuf.dlen = 0; rbuf.dlen = 0;
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(recv): header: " << rbuf.pduhead << endl; dlog->level9() << "(recv): header: " << rbuf.pduhead << endl;
// Определяем тип сообщения // Определяем тип сообщения
switch( rbuf.func() ) switch( rbuf.func() )
...@@ -789,8 +789,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -789,8 +789,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
{ {
ReadCoilMessage mRead(rbuf); ReadCoilMessage mRead(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(0x01): recv buf: " << rbuf << endl; dlog->level9() << "(0x01): recv buf: " << rbuf << endl;
// Проверяем контрольную сумму // Проверяем контрольную сумму
// от начала(включая заголовок) и до конца (исключив последний элемент содержащий CRC) // от начала(включая заголовок) и до конца (исключив последний элемент содержащий CRC)
...@@ -819,8 +819,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -819,8 +819,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
{ {
ReadInputStatusMessage mRead(rbuf); ReadInputStatusMessage mRead(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(r0x02): recv buf: " << rbuf << endl; dlog->level9() << "(r0x02): recv buf: " << rbuf << endl;
// Проверяем контрольную сумму // Проверяем контрольную сумму
// от начала(включая заголовок) и до конца (исключив последний элемент содержащий CRC) // от начала(включая заголовок) и до конца (исключив последний элемент содержащий CRC)
...@@ -849,8 +849,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -849,8 +849,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
{ {
ReadOutputMessage mRead(rbuf); ReadOutputMessage mRead(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(0x03): recv buf: " << rbuf << endl; dlog->level9() << "(0x03): recv buf: " << rbuf << endl;
if( crcNoCheckit ) if( crcNoCheckit )
return erNoError; return erNoError;
...@@ -879,8 +879,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -879,8 +879,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
{ {
ReadInputMessage mRead(rbuf); ReadInputMessage mRead(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(0x04): recv buf: " << rbuf << endl; dlog->level9() << "(0x04): recv buf: " << rbuf << endl;
if( crcNoCheckit ) if( crcNoCheckit )
return erNoError; return erNoError;
...@@ -938,8 +938,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -938,8 +938,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
ForceCoilsMessage mWrite(rbuf); ForceCoilsMessage mWrite(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(0x0F): recv buf: " << rbuf << endl; dlog->level9() << "(0x0F): recv buf: " << rbuf << endl;
if( !crcNoCheckit ) if( !crcNoCheckit )
{ {
...@@ -1008,8 +1008,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -1008,8 +1008,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
WriteOutputMessage mWrite(rbuf); WriteOutputMessage mWrite(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(0x10): recv buf: " << rbuf << endl; dlog->level9() << "(0x10): recv buf: " << rbuf << endl;
if( !crcNoCheckit ) if( !crcNoCheckit )
{ {
...@@ -1078,8 +1078,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -1078,8 +1078,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
ForceSingleCoilMessage mWrite(rbuf); ForceSingleCoilMessage mWrite(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(0x05): recv buf: " << rbuf << endl; dlog->level9() << "(0x05): recv buf: " << rbuf << endl;
if( !crcNoCheckit ) if( !crcNoCheckit )
{ {
...@@ -1148,8 +1148,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -1148,8 +1148,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
WriteSingleOutputMessage mWrite(rbuf); WriteSingleOutputMessage mWrite(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(0x06): recv buf: " << rbuf << endl; dlog->level9() << "(0x06): recv buf: " << rbuf << endl;
if( !crcNoCheckit ) if( !crcNoCheckit )
{ {
...@@ -1218,8 +1218,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -1218,8 +1218,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
DiagnosticMessage mDiag(rbuf); DiagnosticMessage mDiag(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(0x08): recv buf: " << rbuf << endl; dlog->level9() << "(0x08): recv buf: " << rbuf << endl;
if( !crcNoCheckit ) if( !crcNoCheckit )
{ {
...@@ -1244,16 +1244,6 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -1244,16 +1244,6 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
} }
} }
/*
if( !mDiag.checkFormat() )
{
dlog->warn() << "(0x08): (" << rbuf.func
<< ")(fnDiagnostics): "
<< ": некорректный формат сообщения..." << endl;
cleanupChannel();
return erInvalidFormat;
}
*/
return erNoError; return erNoError;
} }
else if( rbuf.func() == fnMEI ) else if( rbuf.func() == fnMEI )
...@@ -1284,8 +1274,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -1284,8 +1274,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
MEIMessageRDI mRDI(rbuf); MEIMessageRDI mRDI(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(0x2B/0x0E): recv buf: " << rbuf << endl; dlog->level9() << "(0x2B/0x0E): recv buf: " << rbuf << endl;
if( crcNoCheckit ) if( crcNoCheckit )
return erNoError; return erNoError;
...@@ -1316,8 +1306,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -1316,8 +1306,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
{ {
JournalCommandMessage mRead(rbuf); JournalCommandMessage mRead(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(0x65): recv buf: " << rbuf << endl; dlog->level9() << "(0x65): recv buf: " << rbuf << endl;
if( crcNoCheckit ) if( crcNoCheckit )
return erNoError; return erNoError;
...@@ -1347,8 +1337,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -1347,8 +1337,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
{ {
SetDateTimeMessage mSet(rbuf); SetDateTimeMessage mSet(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(0x50): recv buf: " << rbuf << endl; dlog->level9() << "(0x50): recv buf: " << rbuf << endl;
if( !crcNoCheckit ) if( !crcNoCheckit )
{ {
...@@ -1414,8 +1404,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -1414,8 +1404,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
RemoteServiceMessage mRServ(rbuf); RemoteServiceMessage mRServ(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(0x53): recv buf: " << rbuf << endl; dlog->level9() << "(0x53): recv buf: " << rbuf << endl;
if( crcNoCheckit ) if( crcNoCheckit )
return erNoError; return erNoError;
...@@ -1446,8 +1436,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -1446,8 +1436,8 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
{ {
FileTransferMessage mFT(rbuf); FileTransferMessage mFT(rbuf);
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(0x66): recv buf: " << rbuf << endl; dlog->level9() << "(0x66): recv buf: " << rbuf << endl;
if( crcNoCheckit ) if( crcNoCheckit )
return erNoError; return erNoError;
...@@ -1482,7 +1472,7 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -1482,7 +1472,7 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
} }
catch( ModbusRTU::mbException& ex ) // SystemError catch( ModbusRTU::mbException& ex ) // SystemError
{ {
if( dlog->debugging(Debug::CRIT) ) if( dlog->is_crit() )
dlog->crit() << "(recv): mbException: " << ex << endl; dlog->crit() << "(recv): mbException: " << ex << endl;
cleanupChannel(); cleanupChannel();
...@@ -1494,7 +1484,7 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout ) ...@@ -1494,7 +1484,7 @@ mbErrCode ModbusServer::recv_pdu( ModbusMessage& rbuf, timeout_t timeout )
} }
catch( UniSetTypes::Exception& ex ) // SystemError catch( UniSetTypes::Exception& ex ) // SystemError
{ {
if( dlog->debugging(Debug::CRIT) ) if( dlog->is_crit() )
dlog->crit() << "(recv): " << ex << endl; dlog->crit() << "(recv): " << ex << endl;
cleanupChannel(); cleanupChannel();
...@@ -1770,8 +1760,8 @@ mbErrCode ModbusServer::send( ModbusMessage& msg ) ...@@ -1770,8 +1760,8 @@ mbErrCode ModbusServer::send( ModbusMessage& msg )
return erTimeOut; return erTimeOut;
} }
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(ModbusServer::send): ADU len=" << msg.aduLen() << " data[" << msg.len() << " bytes]: " << msg << endl; dlog->level9() << "(ModbusServer::send): ADU len=" << msg.aduLen() << " data[" << msg.len() << " bytes]: " << msg << endl;
try try
{ {
......
...@@ -206,8 +206,8 @@ mbErrCode ModbusTCPMaster::query( ModbusAddr addr, ModbusMessage& msg, ...@@ -206,8 +206,8 @@ mbErrCode ModbusTCPMaster::query( ModbusAddr addr, ModbusMessage& msg,
reply.swapHead(); reply.swapHead();
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(ModbusTCPMaster::query): ADU len=" << reply.aduLen() dlog->level9() << "(ModbusTCPMaster::query): ADU len=" << reply.aduLen()
<< endl; << endl;
if( reply.tID() != msg.tID() ) if( reply.tID() != msg.tID() )
......
...@@ -230,8 +230,8 @@ ModbusRTU::mbErrCode ModbusTCPSession::realReceive( const std::unordered_set<Mod ...@@ -230,8 +230,8 @@ ModbusRTU::mbErrCode ModbusTCPSession::realReceive( const std::unordered_set<Mod
// для формирования ответа (см. make_adu_header) // для формирования ответа (см. make_adu_header)
curQueryHeader = buf.aduhead; curQueryHeader = buf.aduhead;
if( dlog->is_info() ) if( dlog->is_level9() )
dlog->info() << "(ModbusTCPSession::recv): ADU len=" << curQueryHeader.len << endl; dlog->level9() << "(ModbusTCPSession::recv): ADU len=" << curQueryHeader.len << endl;
res = recv( vmbaddr, buf, msec ); res = recv( vmbaddr, buf, msec );
...@@ -323,11 +323,11 @@ mbErrCode ModbusTCPSession::tcp_processing( ModbusRTU::ADUHeader& mhead ) ...@@ -323,11 +323,11 @@ mbErrCode ModbusTCPSession::tcp_processing( ModbusRTU::ADUHeader& mhead )
mhead.swapdata(); mhead.swapdata();
if( dlog->is_info() ) if( dlog->is_level9() )
{ {
dlog->info() << peername << "(tcp_processing): recv tcp header(" << len << "): "; dlog->level9() << peername << "(tcp_processing): recv tcp header(" << len << "): ";
mbPrintMessage( dlog->info(false), (ModbusByte*)(&mhead), sizeof(mhead)); mbPrintMessage( dlog->level9(false), (ModbusByte*)(&mhead), sizeof(mhead));
dlog->info(false) << endl; dlog->level9(false) << endl;
} }
// check header // check header
...@@ -336,16 +336,16 @@ mbErrCode ModbusTCPSession::tcp_processing( ModbusRTU::ADUHeader& mhead ) ...@@ -336,16 +336,16 @@ mbErrCode ModbusTCPSession::tcp_processing( ModbusRTU::ADUHeader& mhead )
if( mhead.len == 0 ) if( mhead.len == 0 )
{ {
if( dlog->is_info() ) if( dlog->is_warn() )
dlog->info() << "(ModbusTCPServer::tcp_processing): BAD FORMAT: len=0!" << endl; dlog->warn() << "(ModbusTCPServer::tcp_processing): BAD FORMAT: len=0!" << endl;
return erInvalidFormat; return erInvalidFormat;
} }
if( mhead.len > ModbusRTU::MAXLENPACKET ) if( mhead.len > ModbusRTU::MAXLENPACKET )
{ {
if( dlog->is_info() ) if( dlog->is_warn() )
dlog->info() << "(ModbusTCPServer::tcp_processing): len(" << (int)mhead.len dlog->warn() << "(ModbusTCPServer::tcp_processing): len(" << (int)mhead.len
<< ") < MAXLENPACKET(" << ModbusRTU::MAXLENPACKET << ")" << endl; << ") < MAXLENPACKET(" << ModbusRTU::MAXLENPACKET << ")" << endl;
return erInvalidFormat; return erInvalidFormat;
...@@ -364,8 +364,8 @@ mbErrCode ModbusTCPSession::tcp_processing( ModbusRTU::ADUHeader& mhead ) ...@@ -364,8 +364,8 @@ mbErrCode ModbusTCPSession::tcp_processing( ModbusRTU::ADUHeader& mhead )
if( len < mhead.len ) if( len < mhead.len )
{ {
if( dlog->is_info() ) if( dlog->is_warn() )
dlog->info() << peername << "(tcp_processing): len(" << (int)len dlog->warn() << peername << "(tcp_processing): len(" << (int)len
<< ") < mhead.len(" << (int)mhead.len << ")" << endl; << ") < mhead.len(" << (int)mhead.len << ")" << endl;
return erInvalidFormat; return erInvalidFormat;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment