libev migration

[citadel.git] / citadel / event_client.c

diff --git a/citadel/event_client.c b/citadel/event_client.c
index c923e5fe647dccf364089d45f5786aa1e2d7561a..2cf6dcea9ff8543bf2fa78174fe11b28e6c98176 100644 (file)
--- a/citadel/event_client.c
+++ b/citadel/event_client.c
@@ -74,7 +74,6 @@ extern struct ev_loop *event_base;
 
 #define SEND_EVENT 1
 #define RECV_EVENT 2
-#define CONN_EVENT 3
        
 int QueueEventContext(void *Ctx, AsyncIO *IO, EventContextAttach CB)
 {
@@ -155,9 +154,6 @@ void ShutDownCLient(AsyncIO *IO)
        case RECV_EVENT:
                ev_io_stop(event_base, &IO->recv_event);
                break;
-       case CONN_EVENT:
-               ev_io_stop(event_base, &IO->conn_event);
-               break;
        case 0:
                // no event active here; just bail out.
                break;
@@ -339,10 +335,8 @@ IO_recv_callback(struct ev_loop *loop, ev_io *watcher, int revents)
 
 
 static void
-set_start_callback(struct ev_loop *loop, ev_io *watcher, int revents)
+set_start_callback(struct ev_loop *loop, AsyncIO *IO, int revents)
 {
-       AsyncIO *IO = watcher->data;
-
        switch(IO->NextState) {
        case eReadMessage:
                ev_io_start(event_base, &IO->recv_event);
@@ -350,7 +344,7 @@ set_start_callback(struct ev_loop *loop, ev_io *watcher, int revents)
                break;
        case eSendReply:
        case eSendMore:
-               IO_send_callback(loop, watcher, revents);
+               IO_send_callback(loop, &IO->send_event, revents);
                break;
        case eTerminateConnection:
        case eAbort:
@@ -359,16 +353,6 @@ set_start_callback(struct ev_loop *loop, ev_io *watcher, int revents)
        }
 }
 
-static void
-IO_connect_callback(struct ev_loop *loop, ev_io *watcher, int revents)
-{
-       AsyncIO *IO = watcher->data;
-
-       ev_io_stop(event_base, &IO->conn_event);
-       IO->active_event = 0;
-       set_start_callback(loop, watcher, revents);
-}
-
 int event_connect_socket(AsyncIO *IO)
 {
        int fdflags; 
@@ -429,30 +413,12 @@ IO->curr_ai->ai_family,
 /// TODO: ipv6??                    (IO->HEnt->h_addrtype == AF_INET6)?
                     /*     sizeof(in6_addr):*/
                     sizeof(struct sockaddr_in));
-       if (rc >= 0) {
+       if ((rc >= 0) || (errno == EINPROGRESS)){
 ////           freeaddrinfo(res);
-               ev_io_init(&IO->conn_event, IO_send_callback, IO->sock, EV_WRITE);
-               IO->conn_event.data = IO;
-               set_start_callback(event_base, &IO->conn_event, 0);
+               set_start_callback(event_base, IO, 0);
                
                return 0;
        }
-       else if (errno == EINPROGRESS) {
-               ev_io_init(&IO->conn_event, IO_connect_callback, IO->sock, EV_WRITE);
-               IO->conn_event.data = IO;
-/* TODO
-
-               event_set(&IO->conn_event, 
-                         IO->sock,
-                         EV_READ|EV_WRITE|EV_PERSIST,
-                         IO_connect_callback, 
-                         IO);
-*/
-               ev_io_start(event_base, &IO->conn_event);
-
-               IO->active_event = CONN_EVENT;
-               return 1;
-       }
        else {
                CtdlLogPrintf(CTDL_ERR, "connect() failed: %s\n", strerror(errno));
                StrBufPrintf(IO->ErrMsg, "Failed to connect: %s", strerror(errno));
@@ -480,7 +446,7 @@ void InitEventIO(AsyncIO *IO,
        IO->ReadDone = ReadDone;
        IO->Terminate = Terminate;
        IO->LineReader = LineReader;
-
+       
        if (ReadFirst) {
                IO->NextState = eReadMessage;
        }