This commit is contained in:
cfif 2024-12-09 13:40:18 +03:00
parent ef6021a20d
commit 003afa3861
2 changed files with 7 additions and 4 deletions

View File

@ -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 {

View File

@ -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) {