devs/libstrophe-gh
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add disconnection notification on send/recv errors.

Browse Source
This commit is contained in:
Jack Moffitt
2005-11-19 22:05:00 +00:00
parent 6180bbcc0a
commit 003b0528cd
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/event.c
View File

@@ -83,9 +83,8 @@ void xmpp_run_once(xmpp_ctx_t *ctx, const unsigned long timeout)
if (conn->error) {
/* FIXME: need to tear down send queues and random other things
* maybe this should be abstracted */
xmpp_debug(ctx, "xmpp", "send error occured, tear down socket");
sock_close(conn->sock);
conn->state = XMPP_STATE_DISCONNECTED;
xmpp_debug(ctx, "xmpp", "send error occured, disconnecting");
conn_disconnect(conn);
}
connitem = connitem->next;
@@ -161,11 +160,7 @@ void xmpp_run_once(xmpp_ctx_t *ctx, const unsigned long timeout)
if (sock_connect_error(conn->sock) != 0) {
/* connection failed */
xmpp_debug(ctx, "xmpp", "connection failed");
conn->state = XMPP_STATE_DISCONNECTED;
sock_close(conn->sock);
/* notify the connection handler */
conn->conn_handler(conn, XMPP_CONN_FAIL, conn->error,
conn->stream_error, conn->userdata);
conn_disconnect(conn);
break;
}
@@ -186,9 +181,14 @@ void xmpp_run_once(xmpp_ctx_t *ctx, const unsigned long timeout)
if (!ret) {
/* parse error, we need to shut down */
/* FIXME */
xmpp_debug(ctx, "xmpp", "parse error, disconnecting");
conn_disconnect(conn);
}
} else {
/* return of 0 means socket closed by server */
xmpp_debug(ctx, "xmpp", "socket closed by remote host");
conn_disconnect(conn);
}
/* return of 0 means socket closed by server */
}
break;