version relookee en ivy

1 files changed, 179 insertions, 0 deletions

diff --git a/src/ivyloop.c b/src/ivyloop.c
new file mode 100644
index 0000000..e02800c
--- /dev/null
+++ b/src/ivyloop.c
@@ -0,0 +1,179 @@
+#ifdef WIN32
+#include <windows.h>
+#endif
+#include <stdlib.h>
+#include <errno.h>
+#include <stdio.h>
+#include <stdarg.h>
+#include <string.h>
+
+#ifdef WIN32
+#else
+#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;
+	};
+
+
+
+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 BusLoopChannelClose( Channel channel )
+{
+	channel->tobedeleted = 1;
+}
+
+static void BusLoopChannelDelete( 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  )
+			{
+			BusLoopChannelDelete( channel );
+			}
+		}
+}
+
+Channel BusLoopChannelSetUp(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 BusLoopChannelHandleRead(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 BusLoopChannelHandleExcpt(fd_set *current)
+{
+	Channel channel,next;
+	LIST_EACH_SAFE( channels_list, channel, next )
+		{
+		if (FD_ISSET( channel->fd, current ) )
+			{
+			(*channel->handle_delete)(channel->data);
+//			BusLoopChannelClose( channel );
+			}
+		}
+}
+
+void BusLoopChannelInit(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 BusLoopChannelStop(void)
+{
+	MainLoop = 0;
+}
+void BusLoopChannelMainLoop(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 )
+		{
+		BusLoopChannelHandleExcpt(&exset);
+		BusLoopChannelHandleRead(&rdset);
+		continue;
+		}
+	}
+}
+