← Back to branch summary

~micahg/ubuntu/natty/pidgin/2.7.9-2

« back to all changes in this revision

Viewing changes to libpurple/protocols/msn/sbconn.c

  • Committer: Bazaar Package Importer
  • Author(s): Sebastien Bacher
  • Date: 2010-12-02 16:45:52 UTC
  • mfrom: (2.3.14 sid)
  • Revision ID: james.westby@ubuntu.com-20101202164552-z64wykojzacbb546
Tags: 1:2.7.7-1ubuntu1
New upstream version, drop msn workaround

Show diffs side-by-side

added added

removed removed

Lines of Context:
libpurple/protocols/msn/sbconn.c
 
1
#include "internal.h"
 
2
#include "debug.h"
 
3
 
 
4
#include "msg.h"
 
5
#include "sbconn.h"
 
6
 
 
7
void msn_sbconn_send_part(MsnSlpLink *slplink, MsnSlpMessagePart *part)
 
8
{
 
9
        MsnMessage *msg;
 
10
        const char *passport;
 
11
        char *data;
 
12
        size_t size;
 
13
 
 
14
        msg = msn_message_new_msnslp();
 
15
 
 
16
        passport = purple_normalize(slplink->session->account, slplink->remote_user);
 
17
        msn_message_set_header(msg, "P2P-Dest", passport);
 
18
 
 
19
        msg->part = msn_slpmsgpart_ref(part);
 
20
        data = msn_slpmsgpart_serialize(part, &size);
 
21
        msn_message_set_bin_data(msg, data, size);
 
22
        g_free(data);
 
23
 
 
24
        if (slplink->swboard == NULL)
 
25
        {
 
26
                slplink->swboard = msn_session_get_swboard(slplink->session,
 
27
                                slplink->remote_user, MSN_SB_FLAG_FT);
 
28
 
 
29
                g_return_if_fail(slplink->swboard != NULL);
 
30
 
 
31
                /* If swboard is destroyed we will be too */
 
32
                slplink->swboard->slplinks = g_list_prepend(slplink->swboard->slplinks, slplink);
 
33
        }
 
34
 
 
35
        msn_switchboard_send_msg(slplink->swboard, msg, TRUE);
 
36
        msn_message_destroy(msg);
 
37
}
 
38
 
 
39
/** Called when a message times out. */
 
40
static void
 
41
msg_timeout(MsnCmdProc *cmdproc, MsnTransaction *trans)
 
42
{
 
43
        MsnMessage *msg;
 
44
 
 
45
        msg = trans->data;
 
46
 
 
47
        msg_error_helper(cmdproc, msg, MSN_MSG_ERROR_TIMEOUT);
 
48
}
 
49
 
 
50
static void
 
51
release_msg(MsnSwitchBoard *swboard, MsnMessage *msg)
 
52
{
 
53
        MsnCmdProc *cmdproc;
 
54
        MsnTransaction *trans;
 
55
        char *payload;
 
56
        gsize payload_len;
 
57
        char flag;
 
58
 
 
59
        g_return_if_fail(swboard != NULL);
 
60
        g_return_if_fail(msg     != NULL);
 
61
 
 
62
        cmdproc = swboard->cmdproc;
 
63
 
 
64
        payload = msn_message_gen_payload(msg, &payload_len);
 
65
 
 
66
        if (purple_debug_is_verbose()) {
 
67
                purple_debug_info("msn", "SB length:{%" G_GSIZE_FORMAT "}\n", payload_len);
 
68
                msn_message_show_readable(msg, "SB SEND", FALSE);
 
69
        }
 
70
 
 
71
        flag = msn_message_get_flag(msg);
 
72
        trans = msn_transaction_new(cmdproc, "MSG", "%c %" G_GSIZE_FORMAT,
 
73
                                                                flag, payload_len);
 
74
 
 
75
        /* Data for callbacks */
 
76
        msn_transaction_set_data(trans, msg);
 
77
 
 
78
        if (flag != 'U') {
 
79
                if (msg->type == MSN_MSG_TEXT)
 
80
                {
 
81
                        msg->ack_ref = TRUE;
 
82
                        msn_message_ref(msg);
 
83
                        swboard->ack_list = g_list_append(swboard->ack_list, msg);
 
84
                        msn_transaction_set_timeout_cb(trans, msg_timeout);
 
85
                }
 
86
                else if (msg->type == MSN_MSG_SLP)
 
87
                {
 
88
                        msg->ack_ref = TRUE;
 
89
                        msn_message_ref(msg);
 
90
                        swboard->ack_list = g_list_append(swboard->ack_list, msg);
 
91
                        msn_transaction_set_timeout_cb(trans, msg_timeout);
 
92
#if 0
 
93
                        if (msg->ack_cb != NULL)
 
94
                        {
 
95
                                msn_transaction_add_cb(trans, "ACK", msg_ack);
 
96
                                msn_transaction_add_cb(trans, "NAK", msg_nak);
 
97
                        }
 
98
#endif
 
99
                }
 
100
        }
 
101
 
 
102
        trans->payload = payload;
 
103
        trans->payload_len = payload_len;
 
104
 
 
105
        msg->trans = trans;
 
106
 
 
107
        msn_cmdproc_send_trans(cmdproc, trans);
 
108
}
 
109
 
 
110
static void
 
111
queue_msg(MsnSwitchBoard *swboard, MsnMessage *msg)
 
112
{
 
113
        g_return_if_fail(swboard != NULL);
 
114
        g_return_if_fail(msg     != NULL);
 
115
 
 
116
        purple_debug_info("msn", "Appending message to queue.\n");
 
117
 
 
118
        g_queue_push_tail(swboard->msg_queue, msg);
 
119
 
 
120
        msn_message_ref(msg);
 
121
}
 
122
 
 
123
void
 
124
msn_sbconn_process_queue(MsnSwitchBoard *swboard)
 
125
{
 
126
        MsnMessage *msg;
 
127
 
 
128
        g_return_if_fail(swboard != NULL);
 
129
 
 
130
        purple_debug_info("msn", "Processing queue\n");
 
131
 
 
132
        while ((msg = g_queue_pop_head(swboard->msg_queue)) != NULL)
 
133
        {
 
134
                purple_debug_info("msn", "Sending message\n");
 
135
                release_msg(swboard, msg);
 
136
                msn_message_unref(msg);
 
137
        }
 
138
}
 
139
 
 
140
void
 
141
msn_switchboard_send_msg(MsnSwitchBoard *swboard, MsnMessage *msg,
 
142
                                                 gboolean queue)
 
143
{
 
144
        g_return_if_fail(swboard != NULL);
 
145
        g_return_if_fail(msg     != NULL);
 
146
 
 
147
        purple_debug_info("msn", "switchboard send msg..\n");
 
148
        if (msn_switchboard_can_send(swboard))
 
149
                release_msg(swboard, msg);
 
150
        else if (queue)
 
151
                queue_msg(swboard, msg);
 
152
}