标签：udp return addr server pthread sockfd udpserver 嵌入式 socket

static pthread_t udp_server_thread;
static pthread_attr_t udp_server_attr;

static int udp_sock_init(void)
{
int sockfd;
int ret = 0;
struct sockaddr_in ser_addr;

sockfd = socket(AF_INET, SOCK_DGRAM, 0);
if(sockfd < 0)
{
printf("create socket fail!\n");
return -1;
}
memset(&ser_addr, 0, sizeof(ser_addr));
ser_addr.sin_family = AF_INET;
ser_addr.sin_addr.s_addr = htonl(INADDR_ANY);
ser_addr.sin_port = htons(5688);
ret = bind(sockfd, (struct sockaddr*)&ser_addr, sizeof(ser_addr));
if(ret < 0)
{
printf("socket bind fail!\n");
return -1;
}
return sockfd;
}

/*******************************************************************
* function name : udp_server
* desc : server 主任务入口(以后功能的拓展)，作为配置通道
* input param :
* output param :
* return value :
* writer : wishdom.zzzx
* data : 2020/12/15
********************************************************************/
void *udp_server(void *parameter)
{

int sockfd;
sockfd = udp_sock_init();

if (sockfd <= 0)
{
printf("socket init error!\n");
return 0;
}

while(1)
{
struct sockaddr_in src;
socklen_t src_len = sizeof(src);

static char udp_str[1024] = {0};
int udp_len = 0;

udp_len = recvfrom(sockfd, udp_str, sizeof(udp_str), 0, (struct sockaddr *)&src, &src_len);

if (udp_len > 0)
{
uint32_t json_ret = 0;
printf("unix recv len %d %s \n", udp_len, udp_str);
pthread_mutex_lock(&cfg_mutex);
json_ret = mm_load_cfg_from_str(udp_str);
pthread_mutex_unlock(&cfg_mutex);

if (0 == json_ret ) //(json_ret & IS_CONFIG_MSG)
{
printf("recv config msg\n");
pthread_mutex_lock(&cfg_mutex);
mm_config_save();
pthread_mutex_unlock(&cfg_mutex);
}
}
}
return 0;
}

/*******************************************************************
* function name : udp_server_init
* desc : server 任务初始化
* input param :
* output param :
* return value :
* writer : wishdom.zzzx
* data : 2020/12/15
********************************************************************/
int udp_server_init(void)
{
int rc;

pthread_attr_init(&udp_server_attr);
pthread_attr_setdetachstate(&udp_server_attr, PTHREAD_CREATE_DETACHED);

rc = pthread_create(&udp_server_thread, &udp_server_attr, udp_server, NULL);

if (rc)
{
printf("Error : unable to create thread socket_server\n");
return 1;
}
pthread_attr_destroy(&udp_server_attr);
return 0;
}

标签：udp,return,addr,server,pthread,sockfd,udpserver,嵌入式,socket
来源： https://www.cnblogs.com/wishdom-zzzx/p/14490144.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。