X-Git-Url: https://git.distorted.org.uk/~mdw/mLib/blobdiff_plain/d320826dff9b92551d8530fafeb2e54510973dfa..9df1e2106928f0ff775e52b213c5a7783cb6e176:/conn.c diff --git a/conn.c b/conn.c index 8fe92a3..081b6fc 100644 --- a/conn.c +++ b/conn.c @@ -1,6 +1,6 @@ /* -*-c-*- * - * $Id: conn.c,v 1.5 2000/10/08 11:17:26 mdw Exp $ + * $Id: conn.c,v 1.7 2002/01/13 13:28:44 mdw Exp $ * * Nonblocking connect handling * @@ -30,6 +30,16 @@ /*----- Revision history --------------------------------------------------* * * $Log: conn.c,v $ + * Revision 1.7 2002/01/13 13:28:44 mdw + * Rearrange @conn_init@ to be a bit more comprehensible. + * + * Revision 1.6 2001/06/22 19:35:20 mdw + * Interface change to @conn_init@ -- return error rather than calling the + * function. This reduces the number of different environments the + * callback has to cope with, and the old behaviour is easily simulatable + * with the new, while simulating the new behaviour was awkward and + * painful. + * * Revision 1.5 2000/10/08 11:17:26 mdw * (conn_connect): Change sizes to be @size_t@. * @@ -112,7 +122,7 @@ static void conn_connect(int fd, unsigned mode, void *p) * @void (*func)(int fd, void *p) = handler function * @void *p@ = argument for the handler function * - * Returns: --- + * Returns: Zero on success, nonzero on failure. * * Use: Sets up a nonblocking connect job. The socket should already * be bound if you care about that sort of thing. When the @@ -123,10 +133,10 @@ static void conn_connect(int fd, unsigned mode, void *p) * In either case, the select job is then removed. */ -void conn_init(conn *c, sel_state *s, int fd, - struct sockaddr *dst, int dsz, - void (*func)(int /*fd*/, void */*p*/), - void *p) +int conn_init(conn *c, sel_state *s, int fd, + struct sockaddr *dst, int dsz, + void (*func)(int /*fd*/, void */*p*/), + void *p) { int f; @@ -134,23 +144,23 @@ void conn_init(conn *c, sel_state *s, int fd, fcntl(fd, F_SETFL, f | O_NONBLOCK)) goto fail; - if (connect(fd, dst, dsz) < 0) { - if (errno != EINPROGRESS) - goto fail; + if (!connect(fd, dst, dsz)) + func(fd, p); + else if (errno != EINPROGRESS) + goto fail; + else { c->func = func; c->p = p; sel_initfile(s, &c->writer, fd, SEL_WRITE, conn_connect, c); sel_addfile(&c->writer); - } else - func(fd, p); - - return; + } + return (0); /* --- Something went pear-shaped --- */ fail: close(fd); - func(-1, p); + return (-1); } /* --- @conn_kill@ --- *