#include <sys/types.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <netinet/in.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <string.h>

#define SERV_PORT 1111
#define MAX_CLIENTS 10
#define chan1 "1"
#define chan2 "2"
#define PERM 0666

int proc[MAX_CLIENTS];
int cntcl = 0;

int ssock, csock;
int flSend;
FILE *log;
int *pip;
int disc[20];

//************
void init();
void run_child();
//************

void long2IP(long l, char *IP){
  unsigned char *c=(unsigned char *) &l;  
  sprintf(IP,"%d.%d.%d.%d",c[0],c[1],c[2],c[3]);
}

main(int argc, char **argv)
{
  struct sockaddr_in caddr, tmp1;
  int addrlen;
  char c;
  char IP[20];
  char msg[80];
  FILE *flog;
  
  strcpy(argv[0], "mud: kernel");
  
  addrlen = sizeof(caddr);
  
// перезапись .log файлов
  fclose(fopen("log/connect.log","w"));
  fclose(fopen("log/input.log","w"));

  init();
  
  listen(ssock, 5);
  while (1) {
    csock = accept(ssock, (struct sockaddr *) &caddr, &addrlen);
    long2IP(caddr.sin_addr.s_addr,IP);
    flog=fopen("log/connect.log","a");
    if (flog!=NULL) {
      fprintf(flog,"%s%s\n","Connect from - ",IP);
      printf("%s%s\n","Connect from - ",IP);
    };
    fclose(flog);
    if (csock<0) {
      perror("Не могу взять соединение");
      close(flog);
    } else {
      run_child();
    }
  }
  close(disc[0]);
  close(disc[1]);
  close(ssock);
}

void init()
{
  struct sockaddr_in saddr;
  memset(proc,-1,2*MAX_CLIENTS);
  ssock = socket(PF_INET, SOCK_STREAM, 0);
  if (ssock<0) {
    perror("Не могу открыть сокет для сервиса\n");
    exit(1);
  }
  bzero((char *) &saddr, sizeof(saddr));
  saddr.sin_port = htons(SERV_PORT);
  saddr.sin_family = AF_INET;
  if (bind(ssock, (struct sockaddr *) &saddr, sizeof(saddr))<0) {
    perror("Не могу посадить сокет на порт");
    exit(1);
  }
}

void run_child()
{
  int pid,i;
  if (cntcl<MAX_CLIENTS) {

    printf("%s\n","==DONE==");
// Создать поименнованные програмные каналы
    if ((mknod(chan1, S_IFIFO | PERM, 0)<0)&&(errno!=EEXIST))
      printf("Can't create fifo 1: %s", chan1);
    if ((mknod(chan2, S_IFIFO | PERM, 0)<0)&&(errno!=EEXIST)) {
      unlink (chan1);
      printf("Can't create fifo 2: %s", chan2);
    }

    printf("%s\n","==DONE==");
// Открыть именнованные программные каналы
    if ((disc[0]=open(chan1,0))<0)
      printf("parent: can't open read fifo: %s", chan1);
    if ((disc[1]=open(chan2,1))<0)
      printf("parent: can't open read fifo: %s",chan2);
    printf("%s\n","==DONE==");
    
    pid = fork();
    if (pid==0) {
      ++cntcl;
      i=0;
      while (proc[i]==-1) i++;
      proc[i] = pid;
    } else {
      dup2(csock,0);
      do {
        execl("m","0","1",NULL);
      } while (errno==EAGAIN);
    }
  }
  close(csock);
}