Mirrors_Framework/nuttx
1
0
Fork 0
mirror of https://github.com/apache/nuttx.git synced 2026-06-06 00:14:22 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

socket_rpmsg: fix save rp_name error when accept

Browse Source 
Signed-off-by: ligd <liguiding1@xiaomi.com>
This commit is contained in:
ligd
2021-10-18 23:06:10 +08:00
committed by Xiang Xiao
parent 00ef4fca51
commit 883d66b906
2 changed files with 28 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
drivers/rptun/Kconfig
+6 -2
View File
@@ -21,7 +21,11 @@ config RPTUN_STACKSIZE
default DEFAULT_TASK_STACKSIZE default DEFAULT_TASK_STACKSIZE
config RPTUN_LOADER config RPTUN_LOADER
bool "rptun loader support" bool "rptun loader support"
default n default n
config RPTUN_LOCAL_CPUNAME
string "rptun local cpuname"
default LIBC_HOSTNAME
endif # RPTUN endif # RPTUN
net/rpmsg/rpmsg_sockif.c
+22 -12
View File
@@ -48,12 +48,13 @@
# define MIN(a, b) ((a) < (b) ? (a) : (b)) # define MIN(a, b) ((a) < (b) ? (a) : (b))
#endif #endif
#define RPMSG_SOCKET_CMD_SYNC 1 #define RPMSG_SOCKET_CMD_SYNC 1
#define RPMSG_SOCKET_CMD_DATA 2 #define RPMSG_SOCKET_CMD_DATA 2
#define RPMSG_SOCKET_NAME_PREFIX "rpmsg-socket" #define RPMSG_SOCKET_NAME_PREFIX "rpmsg-socket:"
#define RPMSG_SOCKET_NAME_PREFIX_LEN 13
static_assert(RPMSG_SOCKET_NAME_SIZE + 13 <= RPMSG_NAME_SIZE, static_assert(RPMSG_SOCKET_NAME_SIZE + RPMSG_SOCKET_NAME_PREFIX_LEN
"socket name size should NOT bigger then RPMSG_NAME_SIZE"); <= RPMSG_NAME_SIZE, "socket name size config error");
/**************************************************************************** /****************************************************************************
* Private Types * Private Types
@@ -420,7 +421,7 @@ static void rpmsg_socket_device_created(FAR struct rpmsg_device *rdev,
if (strcmp(conn->rpaddr.rp_cpu, rpmsg_get_cpuname(rdev)) == 0) if (strcmp(conn->rpaddr.rp_cpu, rpmsg_get_cpuname(rdev)) == 0)
{ {
conn->ept.priv = conn; conn->ept.priv = conn;
snprintf(buf, sizeof(buf), "%s:%s", RPMSG_SOCKET_NAME_PREFIX, snprintf(buf, sizeof(buf), "%s%s", RPMSG_SOCKET_NAME_PREFIX,
conn->rpaddr.rp_name); conn->rpaddr.rp_name);
rpmsg_create_ept(&conn->ept, rdev, buf, rpmsg_create_ept(&conn->ept, rdev, buf,
@@ -464,7 +465,7 @@ static void rpmsg_socket_ns_bind(FAR struct rpmsg_device *rdev,
int cnt = 0; int cnt = 0;
int ret; int ret;
snprintf(buf, sizeof(buf), "%s:%s", RPMSG_SOCKET_NAME_PREFIX, snprintf(buf, sizeof(buf), "%s%s", RPMSG_SOCKET_NAME_PREFIX,
server->rpaddr.rp_name); server->rpaddr.rp_name);
if (strncmp(name, buf, strlen(buf))) if (strncmp(name, buf, strlen(buf)))
{ {
@@ -503,7 +504,7 @@ static void rpmsg_socket_ns_bind(FAR struct rpmsg_device *rdev,
} }
strcpy(new->rpaddr.rp_cpu, rpmsg_get_cpuname(rdev)); strcpy(new->rpaddr.rp_cpu, rpmsg_get_cpuname(rdev));
strcpy(new->rpaddr.rp_name, name); strcpy(new->rpaddr.rp_name, name + RPMSG_SOCKET_NAME_PREFIX_LEN);
rpmsg_socket_lock(&server->recvlock); rpmsg_socket_lock(&server->recvlock);
@@ -606,17 +607,26 @@ static int rpmsg_socket_bind(FAR struct socket *psock,
} }
static int rpmsg_socket_getsockname(FAR struct socket *psock, static int rpmsg_socket_getsockname(FAR struct socket *psock,
FAR struct sockaddr *addr, FAR struct sockaddr *addr,
FAR socklen_t *addrlen) FAR socklen_t *addrlen)
{ {
return rpmsg_socket_getaddr(psock->s_conn, addr, addrlen); int ret;
ret = rpmsg_socket_getaddr(psock->s_conn, addr, addrlen);
if (ret >= 0)
{
strncpy(((struct sockaddr_rpmsg *)addr)->rp_cpu,
CONFIG_RPTUN_LOCAL_CPUNAME, RPMSG_SOCKET_CPU_SIZE);
}
return ret;
} }
static int rpmsg_socket_getconnname(FAR struct socket *psock, static int rpmsg_socket_getconnname(FAR struct socket *psock,
FAR struct sockaddr *addr, FAR struct sockaddr *addr,
FAR socklen_t *addrlen) FAR socklen_t *addrlen)
{ {
return rpmsg_socket_getsockname(psock, addr, addrlen); return rpmsg_socket_getaddr(psock->s_conn, addr, addrlen);
} }
static int rpmsg_socket_listen(FAR struct socket *psock, int backlog) static int rpmsg_socket_listen(FAR struct socket *psock, int backlog)