IP Tasks do not respond after an arbitrary period of time.

Hi,
is there any solution for this problem?
We have exact the same behaviour of the ip framework. After some time there is no response to any messages..
We are working with SSP version 2.0.0

Hi Josh,

Were you able to find the solution yet,

Pool Depletion happens every now and then and finally the IP stops working.

Regards,

Surojit.

NetX should release the packet when it's fully transmitted - the send case.  On receipt, you release it when it fully processed.  I think the applications that process the packets should free it automatically when processed - eg a packet processed by the web server.  If you are processing packets directly, you have to free.

Are you sending packets to somewhere where the connection is dead - may the packets there are  being consumed and not released?

Larry

NetX should release the packet when it's fully transmitted - the send case.  On receipt, you release it when it fully processed.  I think the applications that process the packets should free it automatically when processed - eg a packet processed by the web server.  If you are processing packets directly, you have to free.

Are you sending packets to somewhere where the connection is dead - may the packets there are  being consumed and not released?

Larry

Hi Larry,

We are using separate pool for recieve.

We are not processing the packets directly,

I have also checked that if send fails due to NX_NOT_CONNECTED or otherwise I am releasing the packet and it works.

I am unable to pin-point the reason for depletion though.

Regards,

Surojit.

// I am Sharing the code which works as a MODBUS Slave over TCP

static BOOL _FnMODBUSTCPSlave(uint16_t u16NoMBSlaveClients, BOOL bMBSlaveFirst)
{
BOOL bCmdBC = FALSE, bCmdValid = FALSE;
ULONG ulactual_events = 0, ulMBSlaveMsg[2], utcp_bytes_received = 0, uStatus = 0,ulqueueNoOfMsg=0;
UINT uiStatus = 0,uiStatusSend=0,uiMBStatusPacketRelease=0,uiIPStatusPacketRelease=0, uiStatusRetrv = 0,uiStatusRetrvLenCheck=0; //,uiStatusReles = 0;
uint16_t u16MsgTransLen = 0, u16RplyMsgsizeL = 0, u16SocketCheckCtr = 0,u16TCPSendError=DEF_TCP_SLAVE_REPLY_ERROR_NONE;
NX_TCP_SOCKET *socket_ptr = NULL;
NX_PACKET *pMB_RX_packet_ptr = NULL;
NX_PACKET *pMB_TX_packet_ptr = NULL;
uint16_t u16NoUsedSoc = 0;

StructMBSlaveCmdExeParams *pMBSlaveCmdExeParams = &sMBSlaveTCPCmdExeParams;
sMBSlaveTCPCmdExeParams.CmdOffset = 6;
uint8_t *pMODBUSSlaveCmdRcv = sMBSlaveTCPCmdExeParams.MBReceiveFrame,u8PoolFreeCtr=0;
uint8_t *pMBTranReplyFrame = sMBSlaveTCPCmdExeParams.MBReplyFrame;
StructMBSlaveClientParam *pMBSlaveClientParam = NULL;

//ssp_err_t g_MBSlave_ip_io_pool_err = SSP_SUCCESS;
sMODBUSSlaveOpr.bMBSlaveSts = TRUE;
sLogMODBUSComm.bMODBUSPoolDepleted=FALSE;
sLogMODBUSComm.bIPPoolDepleted=FALSE;

FnDIRegParamValueInit ();
FnDIRainGaugeParamValueInit ();

/* Start listening on the first available socket */
FnSetMBSlaveStartSocketListen ();
tx_timer_activate (&Timer_MBSlaveClientStatusCheck);

while ((uiStatus = tx_event_flags_get (&EvDevInConfig, EV_FLAG_DEVICE_IN_CONFIG, TX_AND, &ulactual_events,
TX_NO_WAIT)) == TX_NO_EVENTS)
{
uiStatus=tx_queue_info_get(&QMBSlave,NULL,&ulqueueNoOfMsg,NULL,NULL,NULL,NULL);
uiStatus = tx_queue_receive (&QMBSlave, ulMBSlaveMsg, TX_NO_WAIT);
if (TX_SUCCESS == uiStatus)
{
// MBSlave message received . process the same
socket_ptr = (NX_TCP_SOCKET*) ulMBSlaveMsg[0];
pMB_RX_packet_ptr = (NX_PACKET*) ulMBSlaveMsg[1];
if (socket_ptr != NULL && pMB_RX_packet_ptr != NULL)
{
pMBSlaveClientParam = _FnMBSlaveFindClient (socket_ptr);
if (pMBSlaveClientParam != NULL)
{
pMBSlaveClientParam->u16MBSlaveClientInactiveTime=0;
utcp_bytes_received = 0;
//Check Rcv Msg Length
uiStatusRetrvLenCheck = nx_packet_length_get(pMB_RX_packet_ptr,&utcp_bytes_received);
if(uiStatusRetrvLenCheck==NX_SUCCESS && utcp_bytes_received<MAX_MODBUS_SLAVE_MESSAGE_RCV_LEN)
{
//Length is within limit
uiStatusRetrv = nx_packet_data_retrieve (pMB_RX_packet_ptr, pMODBUSSlaveCmdRcv,
&utcp_bytes_received);
}
else
{
//Cannot retrieve.
utcp_bytes_received=0;
}
uiIPStatusPacketRelease=nx_packet_release(pMB_RX_packet_ptr);
u16MsgTransLen = 0;
bCmdValid = FALSE;
//Get Client Socket Status.
nx_tcp_socket_info_get (&pMBSlaveClientParam->NX_TCPServerClientSocket, 0, 0, 0, 0, 0, 0, 0,
&uStatus, 0, 0, 0);
if ((NX_TCP_ESTABLISHED == uStatus || NX_TCP_SYN_RECEIVED == uStatus)
&& (uiStatusRetrv == TX_SUCCESS && utcp_bytes_received > 0))
{
//Command Recvd Process the same..
if (_FnMODBUSTCPSlaveValidateCmd (pMODBUSSlaveCmdRcv, utcp_bytes_received))
{
bCmdValid = TRUE;
pMBSlaveCmdExeParams->MBSlaveAddr = pMODBUSSlaveCmdRcv[6]; //MB Slave address
bCmdBC = FALSE;
if (pMBSlaveCmdExeParams->MBSlaveAddr == 0)
{
bCmdBC = TRUE;
}
pMBSlaveCmdExeParams->RcvMBSlaveCmd = pMODBUSSlaveCmdRcv[7];
//Reset MODBUSReplySend to FALSE
pMBSlaveCmdExeParams->bMODBUSReplySend = FALSE;
pMBSlaveCmdExeParams->bIllegalAddr = FALSE;
//Parse the message and get its response.
FnMBSlaveComdExe (pMBSlaveCmdExeParams, bCmdBC);
if (pMBSlaveCmdExeParams->bIllegalAddr == TRUE)
{
//Create message for illegal address.
FnMBSlaveExcepResp (DEF_MB_ILLEGAL_DATA_ADDRESS, pMBSlaveCmdExeParams);
}
if (pMBSlaveCmdExeParams->bMODBUSReplySend)
{
u16RplyMsgsizeL = pMBSlaveCmdExeParams->RplyMsgsize;
pMBTranReplyFrame[0] = pMODBUSSlaveCmdRcv[0]; //???? Cast using uchar or make both uint8_t
pMBTranReplyFrame[1] = pMODBUSSlaveCmdRcv[1];
pMBTranReplyFrame[2] = pMODBUSSlaveCmdRcv[2];
pMBTranReplyFrame[3] = pMODBUSSlaveCmdRcv[3];
pMBTranReplyFrame[4] = (uint8_t) ((u16RplyMsgsizeL) >> 8);
pMBTranReplyFrame[5] = (uint8_t) ((u16RplyMsgsizeL) & 0x00FF);

u16MsgTransLen = (uint16_t) (pMBSlaveCmdExeParams->RplyMsgsize + 6);
u8PoolFreeCtr = 0;

do
{
// Set Send Timeout Option Place data in the packet.
uiStatus = nx_packet_allocate (&g_MBSlave_ip_io_pool, &pMB_TX_packet_ptr,
NX_TCP_PACKET,
100);
// uiStatus = nx_packet_allocate (&g_packet_pool1, &pMB_TX_packet_ptr,
// NX_TCP_PACKET,
// 100);

if (uiStatus == NX_SUCCESS)
{
break;
}
u8PoolFreeCtr++;
tx_thread_sleep (100);
}
while (uiStatus != NX_SUCCESS && u8PoolFreeCtr < DEF_POOL_FREE_CHECK_COUNT_NO);

u16TCPSendError = 0;
if (uiStatus == NX_SUCCESS)
{
sLogMODBUSComm.bMODBUSPoolDepleted=FALSE;

uiStatus = nx_packet_data_append (pMB_TX_packet_ptr, pMBTranReplyFrame,
(ULONG) (u16MsgTransLen), &g_MBSlave_ip_io_pool, //TODO: Discuss with Sir.
NX_NO_WAIT);
if (uiStatus == NX_SUCCESS)
{
// // Check IP 0 pool status
// nx_packet_pool_info_get (&g_packet_pool1, NULL/*Total Packets*/, &ulfree_packets,NULL,
// NULL /*empty_pool_suspensions*/,
// NULL/*&psMODBUSCommLog->ulinvalid_packet_releases //invalid_packet_releases*/);

uiStatusSend = nx_tcp_socket_send(socket_ptr, pMB_TX_packet_ptr, 100);
if (uiStatusSend != NX_SUCCESS)
{
gulSendFailCtr++;
uiMBStatusPacketRelease = nx_packet_release(pMB_TX_packet_ptr);
if (uiMBStatusPacketRelease != NX_SUCCESS)
{
gulMBPacketReleaseFailCtr++;
u16TCPSendError = DEF_TCP_SLAVE_REPLY_ERROR_POOL_RELEASE_FAIL_SEND;
}
else
{
u16TCPSendError = DEF_TCP_SLAVE_REPLY_ERROR_SEND_FAIL;
}
}
}
else
{

uiMBStatusPacketRelease = nx_packet_release(pMB_TX_packet_ptr);
if (uiMBStatusPacketRelease != NX_SUCCESS)
{
gulMBPacketReleaseFailCtr++;
u16TCPSendError = DEF_TCP_SLAVE_REPLY_ERROR_POOL_RELEASE_FAIL_APPEND;
}
else
{
u16TCPSendError = DEF_TCP_SLAVE_REPLY_ERROR_APPEND_FAIL;
}
}
}
else if(!sLogMODBUSComm.bMODBUSPoolDepleted)
{
sLogMODBUSComm.bMODBUSPoolDepleted=TRUE;
FnAddFaultLog (DEF_FAULT_MBSLAVE_TRANS_POOL_DEPLETE);
//Re-Start the Device.
tx_event_flags_set (&EvDevInConfig, EV_FLAG_DEVICE_RESTART_CMD, TX_OR);
}

}

}

if (sLogMODBUSComm.bMODBUSTCPSlaveLog)
{
FnMODBUSCommMonLog (pMBSlaveClientParam->u16MBSlaveClientID, pMODBUSSlaveCmdRcv,
utcp_bytes_received, pMBTranReplyFrame, u16MsgTransLen, bCmdValid,
u16NoUsedSoc, u16TCPSendError, uiStatusSend,sLogMODBUSComm.bMODBUSPoolDepleted,en_COMM_OK_RESP_VALID,ulqueueNoOfMsg);
}

}
else if (sLogMODBUSComm.bMODBUSTCPSlaveLog)
{
FnMODBUSCommMonLog (pMBSlaveClientParam->u16MBSlaveClientID, pMODBUSSlaveCmdRcv,
utcp_bytes_received, pMBTranReplyFrame, 0, FALSE, u16NoUsedSoc,
DEF_TCP_SLAVE_REPLY_ERROR_SOCKET_NOT_AVAILABLE,
0,sLogMODBUSComm.bMODBUSPoolDepleted,en_COMM_FAIL,0);
}
}
else
{
uiIPStatusPacketRelease=nx_packet_release(pMB_RX_packet_ptr);
}
}
else if (pMB_RX_packet_ptr != NULL)
{
uiIPStatusPacketRelease=nx_packet_release(pMB_RX_packet_ptr);
}
if(uiIPStatusPacketRelease!=NX_SUCCESS)
{
gulIPPacketReleaseFailCtr++;
}
}
tx_thread_sleep (6);//(10);
//Check Client Socket Status
//Uncomment Later 29.06.2022
u16SocketCheckCtr++;
if (u16SocketCheckCtr >= DEF_SOCKET_MON_TIME_SEC)
{
u16SocketCheckCtr = 0;
if ((tx_event_flags_get (&EvMBSlaveClientStatusCheck, EV_FLAG_TIMER_MBSLAVE_CLIENT_STATUS_CHECK,
TX_AND_CLEAR,
&ulactual_events,
TX_NO_WAIT)) == TX_SUCCESS)
{
u16NoUsedSoc = FnMBSlaveTCPClientSocketStatusCheck ();
}
}
}
sMODBUSSlaveOpr.bMBSlaveSts = FALSE;
tx_timer_deactivate (&Timer_MBSlaveClientStatusCheck);
SSP_PARAMETER_NOT_USED(u16NoMBSlaveClients);
bMBSlaveFirst = FALSE;
return bMBSlaveFirst;
}