libs/rt-thread-official
libs
/
rt-thread-official
mirror of https://github.com/RT-Thread/rt-thread.git
4
0
Fork 0
Code Issues Releases Wiki Activity

[components/net/at]修复at socket信号量释放异常

This commit is contained in:
yangpeng 2024-11-04 15:57:11 +08:00 committed by Meco Man
parent 4fe86c9439
commit a939e8e4ea
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
components/net/at/at_socket/at_socket.c
View File

@ -439,12 +439,14 @@ static struct at_socket *alloc_socket_by_device(struct at_device *device, enum a
#endif #endif
rt_snprintf(name, RT_NAME_MAX, "%s%d", "at_skt", idx); rt_snprintf(name, RT_NAME_MAX, "%s%d", "at_skt", idx);
/* create AT socket receive mailbox */ /* create AT socket receive semaphore */
if ((sock->recv_notice = rt_sem_create(name, 0, RT_IPC_FLAG_FIFO)) == RT_NULL) if ((sock->recv_notice = rt_sem_create(name, 0, RT_IPC_FLAG_FIFO)) == RT_NULL)
{ {
LOG_E("No memory socket receive notic semaphore create."); LOG_E("No memory socket receive notic semaphore create.");
goto __err; goto __err;
} }
/* set AT socket receive semaphore 'max_value' to 1 */
rt_sem_control(sock->recv_notice, RT_IPC_CMD_SET_VLIMIT, (void *)1);
rt_snprintf(name, RT_NAME_MAX, "%s%d", "at_skt", idx); rt_snprintf(name, RT_NAME_MAX, "%s%d", "at_skt", idx);
/* create AT socket receive ring buffer lock */ /* create AT socket receive ring buffer lock */
@ -823,7 +825,7 @@ static void at_recv_notice_cb(struct at_socket *sock, at_socket_evt_t event, con
} }
rt_mutex_release(sock->recv_lock); rt_mutex_release(sock->recv_lock);
rt_sem_control(sock->recv_notice, RT_IPC_CMD_RESET, (void*)1); rt_sem_release(sock->recv_notice);
at_do_event_changes(sock, AT_EVENT_RECV, RT_TRUE); at_do_event_changes(sock, AT_EVENT_RECV, RT_TRUE);
} }
@ -842,7 +844,7 @@ static void at_closed_notice_cb(struct at_socket *sock, at_socket_evt_t event, c
at_do_event_changes(sock, AT_EVENT_ERROR, RT_TRUE); at_do_event_changes(sock, AT_EVENT_ERROR, RT_TRUE);
sock->state = AT_SOCKET_CLOSED; sock->state = AT_SOCKET_CLOSED;
rt_sem_control(sock->recv_notice, RT_IPC_CMD_RESET, (void*)1); rt_sem_release(sock->recv_notice);
} }
#ifdef AT_USING_SOCKET_SERVER #ifdef AT_USING_SOCKET_SERVER