diff --git a/Gsm_SockInt_Open.c b/Gsm_SockInt_Open.c index 74d808b..5a18d0b 100755 --- a/Gsm_SockInt_Open.c +++ b/Gsm_SockInt_Open.c @@ -6,6 +6,7 @@ #include "SocketInterface.h" #include "SocketSerialPort_Telit.h" #include "AtGsmTelitLe910_Socket.h" +#include "GsmSocketTimeouts.h" #define LOG_SIGN "GSM SOCK" #define LOGGER &env->slog->logger @@ -120,7 +121,7 @@ uint8_t Gsm_Socket_open(tSocketGsm *env, eSocketType type, char *addr, size_t ad void Gsm_Socket_close(tSocketGsm *env, uint8_t contextId) { - if (osMutexAcquire(env->access, 2000) == osOK) { + if (osMutexAcquire(env->access, defaultSocketTimeout) == osOK) { if (contextId != SOCKET_WRONG_CONTEXT) { AtGsmTelitLe910_CloseConnection(env->gsmAt, contextId); GsmSocketSlot_Clear(env->slots + contextId); @@ -143,7 +144,7 @@ void Gsm_Socket_close(tSocketGsm *env, uint8_t contextId) { eSocketStatus Gsm_Socket_status(tSocketGsm *env, uint8_t contextId) { bool connected = false; - if (osMutexAcquire(env->access, 2000) == osOK) { + if (osMutexAcquire(env->access, defaultSocketTimeout) == osOK) { AtGsmTelitLe910_HasConnection(env->gsmAt, contextId, &connected); osMutexRelease(env->access); } else { diff --git a/SocketSerialPort_Telit.c b/SocketSerialPort_Telit.c index 9c8c23c..56f7b85 100644 --- a/SocketSerialPort_Telit.c +++ b/SocketSerialPort_Telit.c @@ -29,14 +29,16 @@ static void rxGsm(tAtCmd *env, osMessageQueueId_t rxDataQueue, uint8_t id) { AtCmdTxAddDecimalIntWithLimit(env, 1500, 4); AtCmdTxSendLn(env); */ - uint8_t dataRead[1500]; + uint8_t dataRead[512]; uint32_t len; xAtGsmTelit_ReadSocket(env, id, dataRead, sizeof(dataRead), &len); for (uint32_t i = 0; i < len; ++i) { - osMessageQueuePut(rxDataQueue, &dataRead[i], 0x0, 0U); + osStatus_t res = osMessageQueuePut(rxDataQueue, &dataRead[i], 0x0, 0U); + asm("nop"); } + } void SocketSocketGsm_UrcProcessor_SRING(tSocketGsm *env, tAtBuffer *buff) {