unix.rar_Socket网络编程_UNIX_unix socket_unix 网络编程

#include <stdio.h> #include <time.h> #include <signal.h> #include <errno.h> #include <sys/types.h> #include <sys/wait.h> #include <sys/socket.h> #include <sys/un.h> #include "proto.h" #include "mylist.h" #define POOLSIZE 6L #define STATE_BUSY 1L #define STATE_IDLE 0L struct control_msg_st { pid_t pid; int state; }; struct server_node_st { pid_t pid; int cntl_sd; int state; int use_count; }; static LIST serverlist; void chld_handler(int s) { while(waitpid(-1, NULL, WNOHANG)>0); } void sendtime(int fd) { time_t now_stamp; char *now_str; char pidstr[8]; now_stamp=time(NULL); now_str=ctime(&now_stamp); snprintf(pidstr, 8, "%d", getpid()); write(fd, now_str, strlen(now_str)); write(fd, "\n", 1); write(fd, pidstr, strlen(pidstr)); write(fd, "\n", 1); return; } void server_job(int sd) { int ret; int newsd; struct sockaddr_un hisend; socklen_t hisend_len; hisend_len=sizeof(hisend); while (1) { newsd=accept(sd, (struct sockaddr*)&hisend, &hisend_len); if (newsd==-1) { if (errno==EINTR) { continue; } if (errno==EAGAIN) { continue; } perror("accept()"); exit(1); } sendtime(newsd); close(newsd); } } int add_a_server(int sd) { pid_t pid; struct server_node_st tempnode; int pd[2]; ret=socketpair(PF_UNIX, SOCK_DGRAM, 0, pd); if (ret==-1) { perror(); exit(1); } pid=fork(); if (pid==0) { list_delete(&serverlist); /* !!!! */ close(pd[1]); server_job(sd); exit(0); } close(pd[0]); tempnode.pid=pid; tempnode.cntl_sd=pd[1]; tempnode.state=STATE_IDLE; tempnode.use_count=0; list_node_add(&serverlist, &tempnode); return 0; } void adjust_pool() { } int main() { pid_t pid; int ret, i; struct sockaddr_un myend; struct sigaction sa; struct control_msg ctl_buf; sa.sa_handler=chld_handler; sigemptyset(&sa.sa_mask); sa.sa_flags=SA_RESTART; sigaction(SIGCHLD, &sa, NULL); sd=socket(PF_UNIX, SOCK_STREAM, 0); if (sd==-1) { perror("socket()"); exit(1); } unlink(SOCKPATH); myend.sun_family=AF_UNIX; strncpy(myend.sun_path, SOCKPATH, UNIX_PATH_MAX); ret=bind(sd, (struct sockaddr*)&myend, sizeof(myend)); if (ret==-1) { perror("bind()"); exit(1); } ret=listen(sd, 10); if (ret==-1) { perror("listen()"); exit(1); } list_new(&serverlist, sizeof(struct server_node_st)); for (i=0;i<STARTSERVERS;++i) { add_a_server(sd); } while (1) { recvfrom({fds}, &ctl_buf, sizeof(ctl_buf), 0, .....); /* from many fds */ /* update list data */ } close(sd); exit(0); }