단순하게 살기

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/epoll.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <fcntl.h>
#include <sys/ioctl.h>
#include <errno.h>

#define EPOLL_SIZE 1000
#define EPOLL_EVENT_SIZE 100
#define OPENPORT 7011

int main(int argc, char **argv) {
 struct epoll_event *events; 
 struct epoll_event ev;
 struct sockaddr_in addr, clientaddr;
 int clilen;
 int sfd, efd, cfd;
 int i, j;
 int max_got_events;
 int result;
 int readn;
 int sendflags = 0;
 char buf_in[256] = { '\0' }; 
 int count = 0;
 // epoll 소켓 생성
 if ((efd = epoll_create(EPOLL_EVENT_SIZE)) < 0) {
  perror("epoll_create (1) error");
  return -1;
 }
 // init pool
 events = (struct epoll_event *) malloc(sizeof(*events) * EPOLL_SIZE);
 if (NULL == events) {
  perror("epoll_create error");
  return -1;
 }
 // 서버 소켓 생성
 clilen = sizeof(clientaddr);
 sfd = socket(AF_INET, SOCK_STREAM, 0);
 if (sfd == -1) {
  perror("socket error :");
  close(sfd);
  return -1;
 }
 // 소켓 정보 넣고 bind, listen 처리
 addr.sin_family = AF_INET;
 addr.sin_port = htons(OPENPORT);
 addr.sin_addr.s_addr = htonl(INADDR_ANY);
 if (bind(sfd, (struct sockaddr *) &addr, sizeof(addr)) == -1) {
  close(sfd);
  return -2;
 }
 listen(sfd, 5);
 if (sfd < 0) {
  perror("init_sock error");
  return 1;
 }
 printf("Running Epoll Server port %d\n", OPENPORT);
 ev.events = EPOLLIN;
 ev.data.fd = sfd;
 result = epoll_ctl(efd, EPOLL_CTL_ADD, sfd, &ev);
 if (result < 0) {
  perror("epoll error");
  return 1;
 }
 // 서버 실제 루트
 while (1) {
  max_got_events = epoll_wait(efd, events, EPOLL_SIZE, -1);
  for (i = 0; i < max_got_events; i++) {
   if (events[i].data.fd == sfd) {
    printf("접속 : %s", buf_in);
    cfd = accept(sfd, (struct sockaddr *) &clientaddr, &clilen);
    if (cfd < 0) {
     perror("Accept error");
     return -1;
    }
    ev.events = EPOLLIN;
    ev.data.fd = cfd;
    epoll_ctl(efd, EPOLL_CTL_ADD, cfd, &ev);
    printf("Accepted socket : %d\n", cfd);
    count++;
   } else {
    cfd = events[i].data.fd;
    memset(buf_in, 0x00, 256);
    readn = read(cfd, buf_in, 255);
    if (readn <= 0) {
     epoll_ctl(efd, EPOLL_CTL_DEL, cfd, &ev);
     close(cfd);
     printf("Close fd %d\n", cfd);
     count--;
    } else {
     printf("%s", buf_in);
     for (j = 5; j < count + 5; j++) {
      if (cfd != j) {
       send(j, buf_in, strlen(buf_in), sendflags);
      }
     }
    }
   }
  }
 }
 return 1;
}