Log all messages.
This commit is contained in:
@@ -797,6 +797,7 @@ void AQH_NodeServer_HandleTtyMsgs(AQH_OBJECT *o)
|
||||
AQH_MESSAGE *msg;
|
||||
|
||||
while( (msg=AQH_Endpoint_GetNextMsgIn(xo->ttyEndpoint)) ) {
|
||||
_writeTtyMsgToLogFile(xo, msg);
|
||||
AQH_Message_SetObject(msg, xo->ttyEndpoint);
|
||||
if (AQH_Request_Tree2_HandleTtyMsg(xo->requestTree, xo->ttyEndpoint, msg)!=AQH_MSG_REQUEST_RESULT_HANDLED)
|
||||
_handleMsgFromTty(o, xo, msg);
|
||||
@@ -814,7 +815,6 @@ void _handleMsgFromTty(AQH_OBJECT *o, AQH_NODE_SERVER *xo, const AQH_MESSAGE *ms
|
||||
code=AQH_NodeMessage_GetMsgType(msg);
|
||||
DBG_INFO(NULL, "Received Node packet %d (%x)", (int) code, code);
|
||||
AQH_NodeServer_NodeMsgToDb(o, msg);
|
||||
_writeTtyMsgToLogFile(xo, msg);
|
||||
_forwardTtyMsgToBroker(o, xo, msg);
|
||||
_forwardTtyMsgToClients(xo, msg);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user