/*
 * comms.c
 *
 * $Id: comms.c,v 1.3 1996/03/29 16:51:01 athan Exp $
 *
 * $Log: comms.c,v $
 * Revision 1.3  1996/03/29 16:51:01  athan
 * Reformatting
 * Moved #define's to config.h
 * Now use MAX_CO[3~NNECTIONS not hard-coded 64
 *
 * Revision 1.2  1996/03/28 20:02:07  athan
 * General cleanups
 *
 *
 */

#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/time.h>
#include <sys/ioctl.h>
#include <malloc.h>
#include <sys/socket.h>
#include <unistd.h>
#if defined(SOLARIS)
#include <sys/filio.h>
#endif /* SOLARIS */

#include "comms.h"
#include "config.h"
#include "file.h"


/* Extern Function Prototypes */

/* Extern Variables */

extern struct afile thefile;
extern int timeout;

/* Local Function Prototypes */

int check_timeout(long thistime, int *count);
void closec(struct connection *c);
void do_login(int newfd, long ltime);
void init_comms(void);
void write_all(char *s);

/* Local Variables */

int mainsock;
struct connection *firstc;
int cons = 0;
char buffer[4096];

const char fullmsg[]="Connections full, sorry!\n";

void init_comms(void)
{
   firstc = NULL;
}

void do_login(int newfd, long ltime)
{
   struct connection *newc, *tc=firstc;

   if (cons == MAX_CONNECTIONS)
   {
      write(newfd, fullmsg, strlen(fullmsg));
      shutdown(newfd, 2);
      close(newfd);
   }
   if (tc != NULL)
   {
      while (tc->next != NULL)
      {
         tc = tc->next;
      }
   }
   if (NULL == (newc = (struct connection*) malloc(sizeof(struct connection))))
   {
      write(newfd, fullmsg, strlen(fullmsg));
      shutdown(newfd, 2);
      close(newfd);
   }
   if (firstc != NULL)
   {
      tc->next = newc;
   } else
   {
      firstc = newc;
   }
   if (firstc != tc)
   {
      newc->prev = tc;
   } else
   {
      newc->prev = NULL;
   }
   newc->next = NULL;
   newc->fd = newfd;
   newc->login_time = ltime;
   newc->count = ltime;
   cons++;
   
   write(newfd, thefile.what, thefile.len);
}

/* Check all current connections for timeout and act upon it if
   necessary */

int check_timeout(long thistime, int *count)
{
   struct connection *i, *n;
   char cnt[64];
   long toread;
   
   if (firstc != NULL)
   {
      for(i = firstc ; i != NULL ; i = n)
      {
         n = i->next;
         if (-1 == ioctl(i->fd, FIONREAD, (caddr_t)&toread))
         {
            closec(i);
            count--;
         } else if ((i->login_time + timeout + 1) <= thistime)
         {
            closec(i);
            count--;
         } else if ((thistime - i->count ) > 0)
         {
            sprintf(cnt, "%2d ", (int)(timeout - (i->count - i->login_time)));
            write(i->fd, &cnt, strlen(cnt));
            i->count = thistime;
         }
      }
   }
   return 0;
}

void closec(struct connection *c)
{
   if ( c->next != NULL )
   {
      c->next->prev=c->prev;
   }
   if ( c->prev != NULL )
   {
      c->prev->next=c->next;
   }
   if ( c == firstc )
   {
      firstc = firstc->next;
   }
   write(c->fd, "  Bye!\n", 7);
   shutdown(c->fd, 2);
   close(c->fd);
   free(c);
   cons--;
}