#include<stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <string.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <signal.h>
#include<stdlib.h>
#include <fcntl.h>
#define SERVER_PORT 8888
int pipefd[2]={0,0};
char g_msg[1000];
void SigHandler(int sig)
{
char cMsfBuf[500]={""};
ssize_t ret;
ret = read(pipefd[0],cMsfBuf ,sizeof(cMsfBuf)-1);
if(ret >0)
{
strcat(g_msg , cMsfBuf);
printf("saved msg :\n %s by SigHandler \n \n ",g_msg);
}
}
int main(int argc, char **argv)
{
int fd;
struct sockaddr_in tSockServerAddr;
int ret;
struct sockaddr_in tSockClientAddr;
int new_fd;
int iClientlen;
int iRecvLen;
unsigned char ucRecvBuf[1000];
int piperet;
piperet = pipe(pipefd);
if (piperet == -1)
{
printf("pipe err \n");
return -1;
}
signal(SIGCHLD,SIG_IGN);
fd = socket(AF_INET,SOCK_STREAM,0);
if (fd == -1)
{
printf("socket err \n");
return -1;
}
else
printf("socket fd = %d \n",fd);
tSockServerAddr.sin_family = AF_INET;
tSockServerAddr.sin_port = htons(SERVER_PORT);
tSockServerAddr.sin_addr.s_addr = INADDR_ANY;
memset(tSockServerAddr.sin_zero , 0 , 8);
ret = bind(fd, (const struct sockaddr *)&tSockServerAddr, sizeof(struct sockaddr));
printf("bind ret = %d\n",ret);
ret =listen(fd , 10);
printf("listen ret = %d\n",ret);
while(1)
{
iClientlen = sizeof(struct sockaddr) ;
new_fd = accept(fd ,( struct sockaddr *)&tSockClientAddr, &iClientlen);
if( new_fd == -1)
{
printf("accept err \n");
return -1;
}
printf("accept connect from: %s \n",inet_ntoa(tSockClientAddr.sin_addr));
if(!fork()) {
close(pipefd[0]);//not read
while (1){
iRecvLen = recv(new_fd , ucRecvBuf , 999 ,0);
if(iRecvLen <= 0){
printf("receive len <= 0 \n");
close(new_fd);
return -1;
}
else{
ucRecvBuf[iRecvLen] ='\0' ;
write(pipefd[1], ucRecvBuf , strlen(ucRecvBuf));
printf("get msg about : %s \n",ucRecvBuf);
printf(" msg in son progress is : [%s ]\n",g_msg);
}
}
}
else{
close(pipefd[1]);//not write
int flags;
signal(SIGIO, SigHandler);
fcntl(pipefd[0] , __F_SETOWN ,getpid() );
flags = fcntl(pipefd[0] , F_GETFL);
fcntl(pipefd[0] , F_SETFL , flags | O_ASYNC );
printf("main process \n");
}
close(new_fd);
}
close(fd);
return 0;
}
/*
struct sigaction sigAct;
sigAct.sa_flags = SA_SIGINFO ;
sigAct.sa_sigaction = SigHandler ;
if(sigaction(SIGUSR1, &sigAct, NULL) == -1)
{
printf("sigaction err \n");
return -1;
}
sigval_t val;
char pMsg[] = "hello sig";
val.sival_ptr = pMsg;
if(sigqueue(getpid(),SIGUSR1,val) == -1)
{
printf("sigqueue err \n");
return -1;
}
*/
基于韦东山的嵌入式Linux应用开发基础知识视频教程，我所练习而写的代码
需积分: 9 166 浏览量
2022-07-22
20:46:27
上传
评论
收藏 64KB ZIP 举报
代码.zip （37个子文件） 
test4.2 UDP 
TCP_Client 13KB TCP_Client.c 2KB TCP_Server.c 2KB TCP_Server 9KB TCP_Client.o 3KB TCP_Server.o 3KB test3.1 input [with nonblock] read_dev.c 2KB test2 readDevMsg read_dev.c 601B read_dev 12KB read_dev.o 2KB test5.4 pthread mutexLock pthread 13KB pthread.c 788B test1 hello hello.c 143B hello.o 1KB hello 12KB .vscode tasks.json 718B test5.1 pthread create pthread.o 2KB pthread 9KB pthread.c 399B test4.1 TCP TCP_Client.c 2KB TCP_Server.c 2KB test5.5 pthread cond_mutex pthread 9KB pthread.c 825B test3.2 input with poll read_dev.c 2KB read_dev 13KB read_dev.o 4KB test6 TCP_pipe_signal TCP_Client 13KB TCP_Client.c 2KB TCP_Server.c 4KB TCP_Server 14KB test5.3 pthread sem pthread 9KB pthread.c 539B test5.2 pthread while_fgets pthread 9KB pthread.c 513B test3.3 input with fcntl() read_dev.c 2KB read_dev 13KB read_dev.o 4KB
评论0