Mercurial > pidgin.yaz
comparison libpurple/protocols/msn/sbconn.c @ 31292:47b6eda87723
propagate from branch 'im.pidgin.pidgin' (head 07d0765c444a097af45c2650f54323afb900a07b)
to branch 'im.pidgin.soc.2010.msn-tlc' (head f3998422a4724ab424e4e2328f58fc0504856557)
author | masca@cpw.pidgin.im |
---|---|
date | Mon, 19 Jul 2010 21:11:32 +0000 |
parents | e358e16e527f |
children | 2de522fa534a |
comparison
equal
deleted
inserted
replaced
30698:e874875a74a7 | 31292:47b6eda87723 |
---|---|
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 data = msn_slpmsgpart_serialize(part, &size); | |
20 msg->part = msn_slpmsgpart_ref(part); | |
21 | |
22 msn_message_set_bin_data(msg, data, size); | |
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 } | |
37 | |
38 /** Called when a message times out. */ | |
39 static void | |
40 msg_timeout(MsnCmdProc *cmdproc, MsnTransaction *trans) | |
41 { | |
42 MsnMessage *msg; | |
43 | |
44 msg = trans->data; | |
45 | |
46 msg_error_helper(cmdproc, msg, MSN_MSG_ERROR_TIMEOUT); | |
47 } | |
48 | |
49 static void | |
50 release_msg(MsnSwitchBoard *swboard, MsnMessage *msg) | |
51 { | |
52 MsnCmdProc *cmdproc; | |
53 MsnTransaction *trans; | |
54 char *payload; | |
55 gsize payload_len; | |
56 char flag; | |
57 | |
58 g_return_if_fail(swboard != NULL); | |
59 g_return_if_fail(msg != NULL); | |
60 | |
61 cmdproc = swboard->cmdproc; | |
62 | |
63 payload = msn_message_gen_payload(msg, &payload_len); | |
64 | |
65 if (purple_debug_is_verbose()) { | |
66 purple_debug_info("msn", "SB length:{%" G_GSIZE_FORMAT "}\n", payload_len); | |
67 msn_message_show_readable(msg, "SB SEND", FALSE); | |
68 } | |
69 | |
70 flag = msn_message_get_flag(msg); | |
71 trans = msn_transaction_new(cmdproc, "MSG", "%c %" G_GSIZE_FORMAT, | |
72 flag, payload_len); | |
73 | |
74 /* Data for callbacks */ | |
75 msn_transaction_set_data(trans, msg); | |
76 | |
77 if (flag != 'U') { | |
78 if (msg->type == MSN_MSG_TEXT) | |
79 { | |
80 msg->ack_ref = TRUE; | |
81 msn_message_ref(msg); | |
82 swboard->ack_list = g_list_append(swboard->ack_list, msg); | |
83 msn_transaction_set_timeout_cb(trans, msg_timeout); | |
84 } | |
85 else if (msg->type == MSN_MSG_SLP) | |
86 { | |
87 msg->ack_ref = TRUE; | |
88 msn_message_ref(msg); | |
89 swboard->ack_list = g_list_append(swboard->ack_list, msg); | |
90 msn_transaction_set_timeout_cb(trans, msg_timeout); | |
91 #if 0 | |
92 if (msg->ack_cb != NULL) | |
93 { | |
94 msn_transaction_add_cb(trans, "ACK", msg_ack); | |
95 msn_transaction_add_cb(trans, "NAK", msg_nak); | |
96 } | |
97 #endif | |
98 } | |
99 } | |
100 | |
101 trans->payload = payload; | |
102 trans->payload_len = payload_len; | |
103 | |
104 msg->trans = trans; | |
105 | |
106 msn_cmdproc_send_trans(cmdproc, trans); | |
107 } | |
108 | |
109 static void | |
110 queue_msg(MsnSwitchBoard *swboard, MsnMessage *msg) | |
111 { | |
112 g_return_if_fail(swboard != NULL); | |
113 g_return_if_fail(msg != NULL); | |
114 | |
115 purple_debug_info("msn", "Appending message to queue.\n"); | |
116 | |
117 g_queue_push_tail(swboard->msg_queue, msg); | |
118 | |
119 msn_message_ref(msg); | |
120 } | |
121 | |
122 void | |
123 msn_sbconn_process_queue(MsnSwitchBoard *swboard) | |
124 { | |
125 MsnMessage *msg; | |
126 | |
127 g_return_if_fail(swboard != NULL); | |
128 | |
129 purple_debug_info("msn", "Processing queue\n"); | |
130 | |
131 while ((msg = g_queue_pop_head(swboard->msg_queue)) != NULL) | |
132 { | |
133 purple_debug_info("msn", "Sending message\n"); | |
134 release_msg(swboard, msg); | |
135 msn_message_unref(msg); | |
136 } | |
137 } | |
138 | |
139 void | |
140 msn_switchboard_send_msg(MsnSwitchBoard *swboard, MsnMessage *msg, | |
141 gboolean queue) | |
142 { | |
143 g_return_if_fail(swboard != NULL); | |
144 g_return_if_fail(msg != NULL); | |
145 | |
146 purple_debug_info("msn", "switchboard send msg..\n"); | |
147 if (msn_switchboard_can_send(swboard)) | |
148 release_msg(swboard, msg); | |
149 else if (queue) | |
150 queue_msg(swboard, msg); | |
151 } |