/*
 *
 * Ivy, C interface
 *
 * Copyright 1997-1999
 * Centre d'Etudes de la Navigation Aerienne
 *
 * Main loop handling around select
 *
 * $Id$
 *
 */

#ifdef WIN32
#include <windows.h>
#endif
#include <stdlib.h>
#include <errno.h>
#include <stdio.h>
#include <stdarg.h>
#include <string.h>

#ifndef WIN32
#include <unistd.h>
#include <sys/time.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <signal.h>
#endif


#include "list.h"
#include "ivychannel.h"
#include "ivyloop.h"
#include "timer.h"

struct _channel {
	Channel next;
	HANDLE fd;
	void *data;
	int tobedeleted;
	ChannelHandleDelete handle_delete;
	ChannelHandleRead handle_read;
};



ChannelInit channel_init = IvyChannelInit;
ChannelSetUp channel_setup = IvyChannelSetUp;
ChannelClose channel_close = IvyChannelClose;


static Channel channels_list = NULL;

static int channel_initialized = 0;

static fd_set open_fds;
static int MainLoop = 1;

#ifdef WIN32
WSADATA					WsaData;
#endif

void IvyChannelClose( Channel channel )
{
	channel->tobedeleted = 1;
}

static void IvyChannelDelete( Channel channel )
{
	if ( channel->handle_delete )
		(*channel->handle_delete)( channel->data );

	FD_CLR(channel->fd, &open_fds);
	LIST_REMOVE( channels_list, channel );
}

static void ChannelDefferedDelete()
{
	Channel channel,next;
	LIST_EACH_SAFE( channels_list, channel,next)
		{
		if ( channel->tobedeleted  )
			{
			IvyChannelDelete( channel );
			}
		}
}

Channel IvyChannelSetUp(HANDLE fd, void *data, 
				ChannelHandleDelete handle_delete,
				ChannelHandleRead handle_read
				)						
{
	Channel channel;

	LIST_ADD( channels_list, channel );
	if ( !channel )
		{
		fprintf(stderr,"NOK Memory Alloc Error\n");
		exit(0);
		}
	channel->fd = fd;
	channel->tobedeleted = 0;
	channel->handle_delete = handle_delete;
	channel->handle_read = handle_read;
	channel->data = data;

	FD_SET( channel->fd, &open_fds );

	return channel;
}

static void IvyChannelHandleRead(fd_set *current)
{
	Channel channel,next;
	
	LIST_EACH_SAFE( channels_list, channel, next )
		{
		if ( FD_ISSET( channel->fd, current ) )
			{
			(*channel->handle_read)(channel,channel->fd,channel->data);
			}
		}
}

static void IvyChannelHandleExcpt(fd_set *current)
{
	Channel channel,next;
	LIST_EACH_SAFE( channels_list, channel, next )
		{
		if (FD_ISSET( channel->fd, current ) )
			{
			(*channel->handle_delete)(channel->data);
//			IvyChannelClose( channel );
			}
		}
}

void IvyChannelInit(void)
{
#ifdef WIN32
	int error;
#else 
	/* pour eviter les plantages quand les autres applis font core-dump */
	signal( SIGPIPE, SIG_IGN);
#endif
	if ( channel_initialized ) return;

	FD_ZERO( &open_fds );

#ifdef WIN32
	error = WSAStartup( 0x0101, &WsaData );
        if ( error == SOCKET_ERROR ) {
            printf( "WSAStartup failed.\n" );
        }
#endif
	channel_initialized = 1;
}


void IvyStop (void)
{
	MainLoop = 0;
}

void IvyMainLoop(void(*hook)(void))
{

	fd_set rdset;
	fd_set exset;
	int ready;



	while (MainLoop) {
		ChannelDefferedDelete();
	   	if ( hook ) (*hook)();
		rdset = open_fds;
		exset = open_fds;
		ready = select(64, &rdset, 0,  &exset, TimerGetSmallestTimeout());
		if ( ready < 0 && ( errno != EINTR ))
		{
			perror("select");
			return;
		}
		TimerScan();
		if ( ready > 0 )
		{
			IvyChannelHandleExcpt(&exset);
			IvyChannelHandleRead(&rdset);
			continue;
		}
	}
}