Mercurial > pidgin.yaz
changeset 15272:bc6f650b9c2d
[gaim-migrate @ 18061]
Don't prompt user about dropped packets, just keep resending them.
committer: Tailor Script <tailor@pidgin.im>
author | Mark Huetsch <markhuetsch> |
---|---|
date | Wed, 27 Dec 2006 13:27:55 +0000 |
parents | 4458ed5f8c4c |
children | b3f5d5854017 |
files | libgaim/protocols/qq/sendqueue.c |
diffstat | 1 files changed, 23 insertions(+), 115 deletions(-) [+] |
line wrap: on
line diff
--- a/libgaim/protocols/qq/sendqueue.c Wed Dec 27 10:30:02 2006 +0000 +++ b/libgaim/protocols/qq/sendqueue.c Wed Dec 27 13:27:55 2006 +0000 @@ -78,68 +78,8 @@ gaim_debug(GAIM_DEBUG_INFO, "QQ", "%d packets in sendqueue are freed!\n", i); } -/* packet lost, agree to send again. - * it is removed only when ack-ed by server */ -static void _qq_send_again(gc_and_packet *gp) -{ - GaimConnection *gc; - qq_data *qd; - qq_sendpacket *packet; - GList *list; - - g_return_if_fail(gp != NULL && gp->gc != NULL && gp->packet != NULL); - g_return_if_fail(gp->gc->proto_data != NULL); - - gc = gp->gc; - packet = gp->packet; - qd = (qq_data *) gc->proto_data; - - list = g_list_find(qd->sendqueue, packet); - if (list != NULL) { - packet->resend_times = 0; - packet->sendtime = time(NULL); - qq_proxy_write(qd, packet->buf, packet->len); - } - g_free(gp); -} - -/* packet lost, do not send again */ -static void _qq_send_cancel(gc_and_packet *gp) -{ - GaimConnection *gc; - qq_data *qd; - qq_sendpacket *packet; - GList *list; - - g_return_if_fail(gp != NULL && gp->gc != NULL && gp->packet != NULL); - g_return_if_fail(gp->gc->proto_data != NULL); - - gc = gp->gc; - packet = gp->packet; - qd = (qq_data *) gc->proto_data; - - list = g_list_find(qd->sendqueue, packet); - if (list != NULL) - qq_sendqueue_remove(qd, packet->send_seq); - - g_free(gp); -} - -static void _notify_packets_lost(GaimConnection *gc, const gchar *msg, qq_sendpacket *p) -{ - gc_and_packet *gp; - - gp = g_new0(gc_and_packet, 1); - gp->gc = gc; - gp->packet = p; - gaim_request_action - (gc, NULL, _("Communication timed out"), msg, - 0, gp, 2, _("Try again"), G_CALLBACK(_qq_send_again), - _("Cancel"), G_CALLBACK(_qq_send_cancel)); - /* keep in sendqueue doing nothing until we hear back from the user */ - p->resend_times++; -} - +/* TODO drop get buddy list if we don't know about any buddies... + * I think the server won't ACK a get buddies request if we have none */ gboolean qq_sendqueue_timeout_callback(gpointer data) { GaimConnection *gc; @@ -173,60 +113,28 @@ list = qd->sendqueue; while (list != NULL) { p = (qq_sendpacket *) list->data; - if (p->resend_times >= QQ_RESEND_MAX) { - if (p->resend_times == QQ_RESEND_MAX) { /* reach max */ - switch (p->cmd) { - case QQ_CMD_KEEP_ALIVE: - if (qd->logged_in) { - gaim_debug(GAIM_DEBUG_ERROR, "QQ", "Connection lost!\n"); - gaim_connection_error(gc, _("Connection lost")); - qd->logged_in = FALSE; - } - p->resend_times = -1; - break; - case QQ_CMD_LOGIN: - case QQ_CMD_REQUEST_LOGIN_TOKEN: - if (!qd->logged_in) /* cancel logging progress */ - gaim_connection_error(gc, _("Login failed, no reply")); - p->resend_times = -1; - break; - case QQ_CMD_UPDATE_INFO: - _notify_packets_lost(gc, - _("Your attempt to update your info has timed out. Send the information again?"), p); - break; - case QQ_CMD_GET_USER_INFO: - _notify_packets_lost(gc, - _("Your attempt to view a user's info has timed out. Try again?"), p); - break; - case QQ_CMD_ADD_FRIEND_WO_AUTH: - _notify_packets_lost(gc, - _("Your attempt to add a buddy has timed out. Try again?"), p); - break; - case QQ_CMD_DEL_FRIEND: - _notify_packets_lost(gc, - _("Your attempt to remove a buddy has timed out. Try again?"), p); - break; - case QQ_CMD_BUDDY_AUTH: - _notify_packets_lost(gc, - _("Your attempt to add a buddy has timed out. Try again?"), p); - break; - case QQ_CMD_CHANGE_ONLINE_STATUS: - _notify_packets_lost(gc, - _("Your attempt to change your online status has timed out. Send the information again?"), p); - break; - case QQ_CMD_SEND_IM: - _notify_packets_lost(gc, - _("Your attempt to send an IM has timed out. Send it again?"), p); - break; - case QQ_CMD_REQUEST_KEY: - _notify_packets_lost(gc, - _("Your request for a file transfer key has timed out. Request it again?"), p); - break; - default:{ - p->resend_times = -1; /* it will be removed next time */ - gaim_debug(GAIM_DEBUG_ERROR, "QQ", "%s packet lost!\n", qq_get_cmd_desc(p->cmd)); - } + if (p->resend_times == QQ_RESEND_MAX) { /* reach max */ + switch (p->cmd) { + case QQ_CMD_KEEP_ALIVE: + if (qd->logged_in) { + gaim_debug(GAIM_DEBUG_ERROR, "QQ", "Connection lost!\n"); + gaim_connection_error(gc, _("Connection lost")); + qd->logged_in = FALSE; } + p->resend_times = -1; + break; + case QQ_CMD_LOGIN: + case QQ_CMD_REQUEST_LOGIN_TOKEN: + if (!qd->logged_in) /* cancel login progress */ + gaim_connection_error(gc, _("Login failed, no reply")); + p->resend_times = -1; + break; + default:{ + gaim_debug(GAIM_DEBUG_WARNING, "QQ", + "%s packet sent %d times but not acked. Resetting sendqueue life\n", + qq_get_cmd_desc(p->cmd), QQ_RESEND_MAX); + } + p->resend_times = 0; } } else { /* resend_times < QQ_RESEND_MAX, so sent it again */ wait_time = (gint) (QQ_SENDQUEUE_TIMEOUT / 1000);