Mercurial > pidgin.yaz
annotate libpurple/protocols/qq/qq_network.c @ 24020:2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
* Bugfix: can not send message to the QUN blocked adding
* Tickets:
Fixes #6957
Fixes #6990
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
* Use new tactics of information update:
1. send next package till the previous package received
2. fix duplicated get_room_info and get_room_buddies command
author | SHiNE CsyFeK <csyfek@gmail.com> |
---|---|
date | Thu, 11 Sep 2008 13:29:26 +0000 |
parents | 147ada94a1d8 |
children | 6408be948d56 5f964757f517 |
rev | line source |
---|---|
23052 | 1 /** |
2 * @file qq_network.c | |
3 * | |
4 * purple | |
5 * | |
6 * Purple is the legal property of its developers, whose names are too numerous | |
7 * to list here. Please refer to the COPYRIGHT file distributed with this | |
8 * source distribution. | |
9 * | |
10 * This program is free software; you can redistribute it and/or modify | |
11 * it under the terms of the GNU General Public License as published by | |
12 * the Free Software Foundation; either version 2 of the License, or | |
13 * (at your option) any later version. | |
14 * | |
15 * This program is distributed in the hope that it will be useful, | |
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of | |
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
18 * GNU General Public License for more details. | |
19 * | |
20 * You should have received a copy of the GNU General Public License | |
21 * along with this program; if not, write to the Free Software | |
22 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02111-1301 USA | |
23 */ | |
24 | |
25 #include "cipher.h" | |
26 #include "debug.h" | |
27 #include "internal.h" | |
28 | |
29 #include "buddy_info.h" | |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
30 #include "group_info.h" |
23052 | 31 #include "group_free.h" |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
32 #include "qq_crypt.h" |
23052 | 33 #include "header_info.h" |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
34 #include "qq_base.h" |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
35 #include "buddy_list.h" |
23052 | 36 #include "packet_parse.h" |
37 #include "qq_network.h" | |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
38 #include "qq_trans.h" |
23052 | 39 #include "utils.h" |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
40 #include "qq_process.h" |
23052 | 41 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
42 #define QQ_DEFAULT_PORT 8000 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
43 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
44 /* set QQ_CONNECT_MAX to 1, when test reconnecting */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
45 #define QQ_CONNECT_MAX 3 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
46 #define QQ_CONNECT_INTERVAL 2 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
47 #define QQ_CONNECT_CHECK 5 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
48 #define QQ_KEEP_ALIVE_INTERVAL 60 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
49 #define QQ_TRANS_INTERVAL 10 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
50 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
51 gboolean connect_to_server(PurpleConnection *gc, gchar *server, gint port); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
52 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
53 static qq_connection *connection_find(qq_data *qd, int fd) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
54 qq_connection *ret = NULL; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
55 GSList *entry = qd->openconns; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
56 while(entry) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
57 ret = entry->data; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
58 if(ret->fd == fd) return ret; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
59 entry = entry->next; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
60 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
61 return NULL; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
62 } |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
63 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
64 static qq_connection *connection_create(qq_data *qd, int fd) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
65 qq_connection *ret = g_new0(qq_connection, 1); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
66 ret->fd = fd; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
67 qd->openconns = g_slist_append(qd->openconns, ret); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
68 return ret; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
69 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
70 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
71 static void connection_remove(qq_data *qd, int fd) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
72 qq_connection *conn = connection_find(qd, fd); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
73 qd->openconns = g_slist_remove(qd->openconns, conn); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
74 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
75 g_return_if_fail( conn != NULL ); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
76 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
77 purple_debug_info("QQ", "Close socket %d\n", conn->fd); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
78 if(conn->input_handler > 0) purple_input_remove(conn->input_handler); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
79 if(conn->can_write_handler > 0) purple_input_remove(conn->can_write_handler); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
80 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
81 if (conn->fd >= 0) close(conn->fd); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
82 if(conn->tcp_txbuf != NULL) purple_circ_buffer_destroy(conn->tcp_txbuf); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
83 if (conn->tcp_rxqueue != NULL) g_free(conn->tcp_rxqueue); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
84 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
85 g_free(conn); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
86 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
87 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
88 static void connection_free_all(qq_data *qd) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
89 qq_connection *ret = NULL; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
90 GSList *entry = qd->openconns; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
91 while(entry) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
92 ret = entry->data; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
93 connection_remove(qd, ret->fd); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
94 entry = qd->openconns; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
95 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
96 } |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
97 static gboolean set_new_server(qq_data *qd) |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
98 { |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
99 gint count; |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
100 gint index; |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
101 GList *it = NULL; |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
102 |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
103 g_return_val_if_fail(qd != NULL, FALSE); |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
104 |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
105 if (qd->servers == NULL) { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
106 purple_debug_info("QQ", "Server list is NULL\n"); |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
107 return FALSE; |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
108 } |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
109 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
110 /* remove server used before */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
111 if (qd->curr_server != NULL) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
112 purple_debug_info("QQ", |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
113 "Remove current [%s] from server list\n", qd->curr_server); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
114 qd->servers = g_list_remove(qd->servers, qd->curr_server); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
115 qd->curr_server = NULL; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
116 } |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
117 |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
118 count = g_list_length(qd->servers); |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
119 purple_debug_info("QQ", "Server list has %d\n", count); |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
120 if (count <= 0) { |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
121 /* no server left, disconnect when result is false */ |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
122 qd->servers = NULL; |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
123 return FALSE; |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
124 } |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
125 |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
126 /* get new server */ |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
127 index = rand() % count; |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
128 it = g_list_nth(qd->servers, index); |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
129 qd->curr_server = it->data; /* do not free server_name */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
130 if (qd->curr_server == NULL || strlen(qd->curr_server) <= 0 ) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
131 purple_debug_info("QQ", "Server name at %d is empty\n", index); |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
132 return FALSE; |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
133 } |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
134 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
135 purple_debug_info("QQ", "set new server to %s\n", qd->curr_server); |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
136 return TRUE; |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
137 } |
23052 | 138 |
139 static gint packet_get_header(guint8 *header_tag, guint16 *source_tag, | |
140 guint16 *cmd, guint16 *seq, guint8 *buf) | |
141 { | |
142 gint bytes = 0; | |
143 bytes += qq_get8(header_tag, buf + bytes); | |
144 bytes += qq_get16(source_tag, buf + bytes); | |
145 bytes += qq_get16(cmd, buf + bytes); | |
146 bytes += qq_get16(seq, buf + bytes); | |
147 return bytes; | |
148 } | |
149 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
150 static gboolean connect_check(gpointer data) |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
151 { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
152 PurpleConnection *gc = (PurpleConnection *) data; |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
153 qq_data *qd; |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
154 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
155 g_return_val_if_fail(gc != NULL && gc->proto_data != NULL, FALSE); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
156 qd = (qq_data *) gc->proto_data; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
157 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
158 if (qd->connect_watcher > 0) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
159 purple_timeout_remove(qd->connect_watcher); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
160 qd->connect_watcher = 0; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
161 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
162 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
163 if (qd->fd >= 0 && qd->token != NULL && qd->token_len >= 0) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
164 purple_debug_info("QQ", "Connect ok\n"); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
165 return FALSE; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
166 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
167 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
168 qd->connect_watcher = purple_timeout_add_seconds(0, qq_connect_later, gc); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
169 return FALSE; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
170 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
171 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
172 /* Warning: qq_connect_later destory all connection |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
173 * Any function should be care of use qq_data after call this function |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
174 * Please conside tcp_pending and udp_pending */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
175 gboolean qq_connect_later(gpointer data) |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
176 { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
177 PurpleConnection *gc = (PurpleConnection *) data; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
178 qq_data *qd; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
179 char *server; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
180 int port; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
181 gchar **segments; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
182 |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
183 g_return_val_if_fail(gc != NULL && gc->proto_data != NULL, FALSE); |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
184 qd = (qq_data *) gc->proto_data; |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
185 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
186 if (qd->check_watcher > 0) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
187 purple_timeout_remove(qd->check_watcher); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
188 qd->check_watcher = 0; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
189 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
190 qq_disconnect(gc); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
191 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
192 if (qd->redirect_ip.s_addr != 0) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
193 /* redirect to new server */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
194 server = g_strdup_printf("%s:%d", inet_ntoa(qd->redirect_ip), qd->redirect_port); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
195 qd->servers = g_list_append(qd->servers, server); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
196 qd->curr_server = server; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
197 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
198 qd->redirect_ip.s_addr = 0; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
199 qd->redirect_port = 0; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
200 qd->connect_retry = QQ_CONNECT_MAX; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
201 } |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
202 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
203 if (qd->curr_server == NULL || strlen (qd->curr_server) == 0 || qd->connect_retry <= 0) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
204 if ( set_new_server(qd) != TRUE) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
205 purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR, |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
206 _("Failed to connect all servers")); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
207 return FALSE; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
208 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
209 qd->connect_retry = QQ_CONNECT_MAX; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
210 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
211 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
212 segments = g_strsplit_set(qd->curr_server, ":", 0); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
213 server = g_strdup(segments[0]); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
214 port = atoi(segments[1]); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
215 if (port <= 0) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
216 purple_debug_info("QQ", "Port not define in %s\n", qd->curr_server); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
217 port = QQ_DEFAULT_PORT; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
218 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
219 g_strfreev(segments); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
220 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
221 qd->connect_retry--; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
222 if ( !connect_to_server(gc, server, port) ) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
223 purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR, |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
224 _("Unable to connect.")); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
225 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
226 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
227 qd->check_watcher = purple_timeout_add_seconds(QQ_CONNECT_CHECK, connect_check, gc); |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
228 return FALSE; /* timeout callback stops */ |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
229 } |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
230 |
23052 | 231 /* process the incoming packet from qq_pending */ |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
232 static gboolean packet_process(PurpleConnection *gc, guint8 *buf, gint buf_len) |
23052 | 233 { |
234 qq_data *qd; | |
235 gint bytes, bytes_not_read; | |
236 | |
237 guint8 header_tag; | |
238 guint16 source_tag; | |
239 guint16 cmd; | |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
240 guint16 seq; /* May be ack_seq or send_seq, depends on cmd */ |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
241 guint8 room_cmd; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
242 guint32 room_id; |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
243 gint update_class; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
244 guint32 ship32; |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
245 |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
246 qq_transaction *trans; |
23052 | 247 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
248 g_return_val_if_fail(buf != NULL && buf_len > 0, TRUE); |
23052 | 249 |
250 qd = (qq_data *) gc->proto_data; | |
251 | |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
252 /* Len, header and tail tag have been checked before */ |
23052 | 253 bytes = 0; |
254 bytes += packet_get_header(&header_tag, &source_tag, &cmd, &seq, buf + bytes); | |
255 | |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
256 #if 1 |
24020
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
257 purple_debug_info("QQ", "==> [%05d] %s 0x%04X, source tag 0x%04X len %d\n", |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
258 seq, qq_get_cmd_desc(cmd), cmd, source_tag, buf_len); |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
259 #endif |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
260 /* this is the length of all the encrypted data (also remove tail tag) */ |
23052 | 261 bytes_not_read = buf_len - bytes - 1; |
262 | |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
263 /* ack packet, we need to update send tranactions */ |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
264 /* we do not check duplication for server ack */ |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
265 trans = qq_trans_find_rcved(gc, cmd, seq); |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
266 if (trans == NULL) { |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
267 /* new server command */ |
24020
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
268 if ( !qd->is_login ) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
269 qq_trans_add_remain(gc, cmd, seq, buf + bytes, bytes_not_read); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
270 } else { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
271 qq_trans_add_server_cmd(gc, cmd, seq, buf + bytes, bytes_not_read); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
272 qq_proc_server_cmd(gc, cmd, seq, buf + bytes, bytes_not_read); |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
273 } |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
274 return TRUE; |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
275 } |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
276 |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
277 if (qq_trans_is_dup(trans)) { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
278 purple_debug_info("QQ", "dup [%05d] %s, discard...\n", seq, qq_get_cmd_desc(cmd)); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
279 return TRUE; |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
280 } |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
281 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
282 update_class = qq_trans_get_class(trans); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
283 ship32 = qq_trans_get_ship(trans); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
284 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
285 switch (cmd) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
286 case QQ_CMD_TOKEN: |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
287 if (qq_process_token_reply(gc, buf + bytes, bytes_not_read) == QQ_TOKEN_REPLY_OK) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
288 qq_send_packet_login(gc); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
289 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
290 break; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
291 case QQ_CMD_LOGIN: |
24020
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
292 qq_proc_login_cmd(gc, buf + bytes, bytes_not_read); |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
293 /* check is redirect or not, and do it now */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
294 if (qd->redirect_ip.s_addr != 0) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
295 if (qd->check_watcher > 0) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
296 purple_timeout_remove(qd->check_watcher); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
297 qd->check_watcher = 0; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
298 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
299 if (qd->connect_watcher > 0) purple_timeout_remove(qd->connect_watcher); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
300 qd->connect_watcher = purple_timeout_add_seconds(QQ_CONNECT_INTERVAL, qq_connect_later, gc); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
301 return FALSE; /* do nothing after this function and return now */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
302 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
303 break; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
304 case QQ_CMD_ROOM: |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
305 room_cmd = qq_trans_get_room_cmd(trans); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
306 room_id = qq_trans_get_room_id(trans); |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
307 #if 1 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
308 purple_debug_info("QQ", "%s (0x%02X) for room %d, len %d\n", |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
309 qq_get_room_cmd_desc(room_cmd), room_cmd, room_id, buf_len); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
310 #endif |
24020
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
311 qq_proc_room_cmd(gc, seq, room_cmd, room_id, buf + bytes, bytes_not_read, update_class, ship32); |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
312 break; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
313 default: |
24020
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
314 qq_proc_client_cmd(gc, cmd, seq, buf + bytes, bytes_not_read, update_class, ship32); |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
315 break; |
23052 | 316 } |
317 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
318 return TRUE; |
23052 | 319 } |
320 | |
321 static void tcp_pending(gpointer data, gint source, PurpleInputCondition cond) | |
322 { | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
323 PurpleConnection *gc = (PurpleConnection *) data; |
23052 | 324 qq_data *qd; |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
325 qq_connection *conn; |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
326 guint8 buf[1024]; /* set to 16 when test tcp_rxqueue */ |
23052 | 327 gint buf_len; |
328 gint bytes; | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
329 |
23052 | 330 guint8 *pkt; |
331 guint16 pkt_len; | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
332 |
23052 | 333 gchar *error_msg; |
334 guint8 *jump; | |
335 gint jump_len; | |
336 | |
337 g_return_if_fail(gc != NULL && gc->proto_data != NULL); | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
338 qd = (qq_data *) gc->proto_data; |
23052 | 339 |
340 if(cond != PURPLE_INPUT_READ) { | |
341 purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR, | |
342 _("Socket error")); | |
343 return; | |
344 } | |
345 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
346 conn = connection_find(qd, source); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
347 g_return_if_fail(conn != NULL); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
348 |
23052 | 349 /* test code, not using tcp_rxqueue |
350 memset(pkt,0, sizeof(pkt)); | |
351 buf_len = read(qd->fd, pkt, sizeof(pkt)); | |
352 if (buf_len > 2) { | |
353 packet_process(gc, pkt + 2, buf_len - 2); | |
354 } | |
355 return; | |
356 */ | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
357 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
358 buf_len = read(source, buf, sizeof(buf)); |
23052 | 359 if (buf_len < 0) { |
360 if (errno == EAGAIN) | |
361 /* No worries */ | |
362 return; | |
363 | |
364 error_msg = g_strdup_printf(_("Lost connection with server:\n%d, %s"), errno, g_strerror(errno)); | |
365 purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR, error_msg); | |
366 g_free(error_msg); | |
367 return; | |
368 } else if (buf_len == 0) { | |
369 purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR, | |
370 _("Server closed the connection.")); | |
371 return; | |
372 } | |
373 | |
23606
bdb38a8bf721
20080717-05-1-fix-keep-alive ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23054
diff
changeset
|
374 /* keep alive will be sent in 30 seconds since last_receive |
bdb38a8bf721
20080717-05-1-fix-keep-alive ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23054
diff
changeset
|
375 * QQ need a keep alive packet in every 60 seconds |
bdb38a8bf721
20080717-05-1-fix-keep-alive ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23054
diff
changeset
|
376 gc->last_received = time(NULL); |
bdb38a8bf721
20080717-05-1-fix-keep-alive ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23054
diff
changeset
|
377 */ |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
378 /* purple_debug_info("TCP_PENDING", "Read %d bytes, rxlen is %d\n", buf_len, conn->tcp_rxlen); */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
379 conn->tcp_rxqueue = g_realloc(conn->tcp_rxqueue, buf_len + conn->tcp_rxlen); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
380 memcpy(conn->tcp_rxqueue + conn->tcp_rxlen, buf, buf_len); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
381 conn->tcp_rxlen += buf_len; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
382 |
23052 | 383 pkt = g_newa(guint8, MAX_PACKET_SIZE); |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
384 while (PURPLE_CONNECTION_IS_VALID(gc)) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
385 if (qd->openconns == NULL) { |
23052 | 386 break; |
387 } | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
388 if (conn->tcp_rxqueue == NULL) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
389 conn->tcp_rxlen = 0; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
390 break; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
391 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
392 if (conn->tcp_rxlen < QQ_TCP_HEADER_LENGTH) { |
23052 | 393 break; |
394 } | |
395 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
396 bytes = 0; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
397 bytes += qq_get16(&pkt_len, conn->tcp_rxqueue + bytes); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
398 if (conn->tcp_rxlen < pkt_len) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
399 break; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
400 } |
23052 | 401 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
402 /* purple_debug_info("TCP_PENDING", "Packet len=%d, rxlen=%d\n", pkt_len, conn->tcp_rxlen); */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
403 if ( pkt_len < QQ_TCP_HEADER_LENGTH |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
404 || *(conn->tcp_rxqueue + bytes) != QQ_PACKET_TAG |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
405 || *(conn->tcp_rxqueue + pkt_len - 1) != QQ_PACKET_TAIL) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
406 /* HEY! This isn't even a QQ. What are you trying to pull? */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
407 purple_debug_warning("TCP_PENDING", "Packet error, no header or tail tag\n"); |
23052 | 408 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
409 jump = memchr(conn->tcp_rxqueue + 1, QQ_PACKET_TAIL, conn->tcp_rxlen - 1); |
23052 | 410 if ( !jump ) { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
411 purple_debug_warning("TCP_PENDING", "Failed to find next tail, clear receive buffer\n"); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
412 g_free(conn->tcp_rxqueue); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
413 conn->tcp_rxqueue = NULL; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
414 conn->tcp_rxlen = 0; |
23052 | 415 return; |
416 } | |
417 | |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
418 /* jump and over QQ_PACKET_TAIL */ |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
419 jump_len = (jump - conn->tcp_rxqueue) + 1; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
420 purple_debug_warning("TCP_PENDING", "Find next tail at %d, jump %d\n", jump_len, jump_len + 1); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
421 g_memmove(conn->tcp_rxqueue, jump, conn->tcp_rxlen - jump_len); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
422 conn->tcp_rxlen -= jump_len; |
23052 | 423 continue; |
424 } | |
425 | |
426 memset(pkt, 0, MAX_PACKET_SIZE); | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
427 g_memmove(pkt, conn->tcp_rxqueue + bytes, pkt_len - bytes); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
428 |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
429 /* jump to next packet */ |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
430 conn->tcp_rxlen -= pkt_len; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
431 if (conn->tcp_rxlen) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
432 /* purple_debug_info("TCP_PENDING", "shrink tcp_rxqueue to %d\n", conn->tcp_rxlen); */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
433 jump = g_memdup(conn->tcp_rxqueue + pkt_len, conn->tcp_rxlen); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
434 g_free(conn->tcp_rxqueue); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
435 conn->tcp_rxqueue = jump; |
23052 | 436 } else { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
437 /* purple_debug_info("TCP_PENDING", "free tcp_rxqueue\n"); */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
438 g_free(conn->tcp_rxqueue); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
439 conn->tcp_rxqueue = NULL; |
23052 | 440 } |
441 | |
442 if (pkt == NULL) { | |
443 continue; | |
444 } | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
445 /* packet_process may call disconnect and destory data like conn |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
446 * do not call packet_process before jump, |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
447 * break if packet_process return FALSE */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
448 if (packet_process(gc, pkt, pkt_len - bytes) == FALSE) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
449 purple_debug_info("TCP_PENDING", "Connection has been destory\n"); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
450 break; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
451 } |
23052 | 452 } |
453 } | |
454 | |
455 static void udp_pending(gpointer data, gint source, PurpleInputCondition cond) | |
456 { | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
457 PurpleConnection *gc = (PurpleConnection *) data; |
23052 | 458 qq_data *qd; |
459 guint8 *buf; | |
460 gint buf_len; | |
461 | |
462 gc = (PurpleConnection *) data; | |
463 g_return_if_fail(gc != NULL && gc->proto_data != NULL); | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
464 qd = (qq_data *) gc->proto_data; |
23052 | 465 |
466 if(cond != PURPLE_INPUT_READ) { | |
467 purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR, | |
468 _("Socket error")); | |
469 return; | |
470 } | |
471 | |
472 buf = g_newa(guint8, MAX_PACKET_SIZE); | |
473 | |
474 /* here we have UDP proxy suppport */ | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
475 buf_len = read(source, buf, MAX_PACKET_SIZE); |
23052 | 476 if (buf_len <= 0) { |
477 purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR, | |
478 _("Unable to read from socket")); | |
479 return; | |
480 } | |
481 | |
23606
bdb38a8bf721
20080717-05-1-fix-keep-alive ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23054
diff
changeset
|
482 /* keep alive will be sent in 30 seconds since last_receive |
bdb38a8bf721
20080717-05-1-fix-keep-alive ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23054
diff
changeset
|
483 * QQ need a keep alive packet in every 60 seconds |
bdb38a8bf721
20080717-05-1-fix-keep-alive ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23054
diff
changeset
|
484 gc->last_received = time(NULL); |
bdb38a8bf721
20080717-05-1-fix-keep-alive ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23054
diff
changeset
|
485 */ |
23052 | 486 |
487 if (buf_len < QQ_UDP_HEADER_LENGTH) { | |
488 if (buf[0] != QQ_PACKET_TAG || buf[buf_len - 1] != QQ_PACKET_TAIL) { | |
489 qq_hex_dump(PURPLE_DEBUG_ERROR, "UDP_PENDING", | |
490 buf, buf_len, | |
491 "Received packet is too short, or no header and tail tag"); | |
492 return; | |
493 } | |
494 } | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
495 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
496 /* packet_process may call disconnect and destory data like conn |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
497 * do not call packet_process before jump, |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
498 * break if packet_process return FALSE */ |
23052 | 499 packet_process(gc, buf, buf_len); |
500 } | |
501 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
502 static gint udp_send_out(PurpleConnection *gc, guint8 *data, gint data_len) |
23052 | 503 { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
504 qq_data *qd; |
23052 | 505 gint ret; |
506 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
507 g_return_val_if_fail(data != NULL && data_len > 0, -1); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
508 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
509 g_return_val_if_fail(gc != NULL && gc->proto_data != NULL, -1); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
510 qd = (qq_data *) gc->proto_data; |
23052 | 511 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
512 #if 0 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
513 purple_debug_info("UDP_SEND_OUT", "Send %d bytes to socket %d\n", data_len, qd->fd); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
514 #endif |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
515 |
23052 | 516 errno = 0; |
517 ret = send(qd->fd, data, data_len, 0); | |
518 if (ret < 0 && errno == EAGAIN) { | |
519 return ret; | |
520 } | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
521 |
23052 | 522 if (ret < 0) { |
523 /* TODO: what to do here - do we really have to disconnect? */ | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
524 purple_debug_error("UDP_SEND_OUT", "Send failed: %d, %s\n", errno, g_strerror(errno)); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
525 purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR, g_strerror(errno)); |
23052 | 526 } |
527 return ret; | |
528 } | |
529 | |
530 static void tcp_can_write(gpointer data, gint source, PurpleInputCondition cond) | |
531 { | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
532 PurpleConnection *gc = (PurpleConnection *) data; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
533 qq_data *qd; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
534 qq_connection *conn; |
23052 | 535 int ret, writelen; |
536 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
537 g_return_if_fail(gc != NULL && gc->proto_data != NULL); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
538 qd = (qq_data *) gc->proto_data; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
539 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
540 conn = connection_find(qd, source); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
541 g_return_if_fail(conn != NULL); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
542 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
543 writelen = purple_circ_buffer_get_max_read(conn->tcp_txbuf); |
23052 | 544 if (writelen == 0) { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
545 purple_input_remove(conn->can_write_handler); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
546 conn->can_write_handler = 0; |
23052 | 547 return; |
548 } | |
549 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
550 ret = write(source, conn->tcp_txbuf->outptr, writelen); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
551 purple_debug_info("TCP_CAN_WRITE", "total %d bytes is sent %d\n", writelen, ret); |
23052 | 552 |
553 if (ret < 0 && errno == EAGAIN) | |
554 return; | |
555 else if (ret < 0) { | |
556 /* TODO: what to do here - do we really have to disconnect? */ | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
557 purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR, |
23052 | 558 _("Write Error")); |
559 return; | |
560 } | |
561 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
562 purple_circ_buffer_mark_read(conn->tcp_txbuf, ret); |
23052 | 563 } |
564 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
565 static gint tcp_send_out(PurpleConnection *gc, guint8 *data, gint data_len) |
23052 | 566 { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
567 qq_data *qd; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
568 qq_connection *conn; |
23052 | 569 gint ret; |
570 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
571 g_return_val_if_fail(data != NULL && data_len > 0, -1); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
572 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
573 g_return_val_if_fail(gc != NULL && gc->proto_data != NULL, -1); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
574 qd = (qq_data *) gc->proto_data; |
23052 | 575 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
576 conn = connection_find(qd, qd->fd); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
577 g_return_val_if_fail(conn, -1); |
23052 | 578 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
579 #if 0 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
580 purple_debug_info("TCP_SEND_OUT", "Send %d bytes to socket %d\n", data_len, qd->fd); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
581 #endif |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
582 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
583 if (conn->can_write_handler == 0) { |
23052 | 584 ret = write(qd->fd, data, data_len); |
585 } else { | |
586 ret = -1; | |
587 errno = EAGAIN; | |
588 } | |
589 | |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
590 /* |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
591 purple_debug_info("TCP_SEND_OUT", |
23052 | 592 "Socket %d, total %d bytes is sent %d\n", qd->fd, data_len, ret); |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
593 */ |
23052 | 594 if (ret < 0 && errno == EAGAIN) { |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
595 /* socket is busy, send later */ |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
596 purple_debug_info("TCP_SEND_OUT", "Socket is busy and send later\n"); |
23052 | 597 ret = 0; |
598 } else if (ret <= 0) { | |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
599 /* TODO: what to do here - do we really have to disconnect? */ |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
600 purple_debug_error("TCP_SEND_OUT", |
23052 | 601 "Send to socket %d failed: %d, %s\n", qd->fd, errno, g_strerror(errno)); |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
602 purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR, g_strerror(errno)); |
23052 | 603 return ret; |
604 } | |
605 | |
606 if (ret < data_len) { | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
607 purple_debug_info("TCP_SEND_OUT", |
23052 | 608 "Add %d bytes to buffer\n", data_len - ret); |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
609 if (conn->can_write_handler == 0) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
610 conn->can_write_handler = purple_input_add(qd->fd, PURPLE_INPUT_WRITE, tcp_can_write, gc); |
23052 | 611 } |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
612 purple_circ_buffer_append(conn->tcp_txbuf, data + ret, data_len - ret); |
23052 | 613 } |
614 return ret; | |
615 } | |
616 | |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
617 static gboolean network_timeout(gpointer data) |
23052 | 618 { |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
619 PurpleConnection *gc = (PurpleConnection *) data; |
23052 | 620 qq_data *qd; |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
621 gboolean is_lost_conn; |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
622 |
23052 | 623 g_return_val_if_fail(gc != NULL && gc->proto_data != NULL, TRUE); |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
624 qd = (qq_data *) gc->proto_data; |
23052 | 625 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
626 is_lost_conn = qq_trans_scan(gc); |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
627 if (is_lost_conn) { |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
628 purple_connection_error_reason(gc, |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
629 PURPLE_CONNECTION_ERROR_NETWORK_ERROR, _("Connection lost")); |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
630 return TRUE; |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
631 } |
23052 | 632 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
633 if ( !qd->is_login ) { |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
634 return TRUE; |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
635 } |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
636 |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
637 qd->itv_count.keep_alive--; |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
638 if (qd->itv_count.keep_alive <= 0) { |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
639 qd->itv_count.keep_alive = qd->itv_config.keep_alive; |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
640 qq_send_packet_keep_alive(gc); |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
641 return TRUE; |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
642 } |
23052 | 643 |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
644 if (qd->itv_config.update <= 0) { |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
645 return TRUE; |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
646 } |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
647 |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
648 qd->itv_count.update--; |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
649 if (qd->itv_count.update <= 0) { |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
650 qd->itv_count.update = qd->itv_config.update; |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
651 qq_update_online(gc, 0); |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
652 return TRUE; |
23052 | 653 } |
654 | |
655 return TRUE; /* if return FALSE, timeout callback stops */ | |
656 } | |
657 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
658 static void do_request_token(PurpleConnection *gc) |
23052 | 659 { |
660 qq_data *qd; | |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
661 gchar *conn_msg; |
23052 | 662 const gchar *passwd; |
663 | |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
664 /* _qq_show_socket("Got login socket", source); */ |
23052 | 665 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
666 g_return_if_fail(gc != NULL && gc->proto_data != NULL); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
667 qd = (qq_data *) gc->proto_data; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
668 |
23052 | 669 /* QQ use random seq, to minimize duplicated packets */ |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
670 srand(time(NULL)); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
671 qd->send_seq = rand() & 0xffff; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
672 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
673 qd->is_login = FALSE; |
23052 | 674 qd->channel = 1; |
675 qd->uid = strtol(purple_account_get_username(purple_connection_get_account(gc)), NULL, 10); | |
676 | |
677 /* now generate md5 processed passwd */ | |
678 passwd = purple_account_get_password(purple_connection_get_account(gc)); | |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
679 |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
680 /* use twice-md5 of user password as session key since QQ 2003iii */ |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
681 qq_get_md5(qd->password_twice_md5, sizeof(qd->password_twice_md5), |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
682 (guint8 *)passwd, strlen(passwd)); |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
683 qq_get_md5(qd->password_twice_md5, sizeof(qd->password_twice_md5), |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
684 qd->password_twice_md5, sizeof(qd->password_twice_md5)); |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
685 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
686 g_return_if_fail(qd->network_watcher == 0); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
687 qd->network_watcher = purple_timeout_add_seconds(qd->itv_config.resend, network_timeout, gc); |
23052 | 688 |
689 /* Update the login progress status display */ | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
690 conn_msg = g_strdup_printf(_("Request token")); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
691 purple_connection_update_progress(gc, conn_msg, 2, QQ_CONNECT_STEPS); |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
692 g_free(conn_msg); |
23052 | 693 |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
694 qq_send_packet_token(gc); |
23052 | 695 } |
696 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
697 /* the callback function after socket is built |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
698 * we setup the qq protocol related configuration here */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
699 static void connect_cb(gpointer data, gint source, const gchar *error_message) |
23052 | 700 { |
701 PurpleConnection *gc; | |
702 qq_data *qd; | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
703 PurpleAccount *account ; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
704 qq_connection *conn; |
23052 | 705 |
706 gc = (PurpleConnection *) data; | |
707 g_return_if_fail(gc != NULL && gc->proto_data != NULL); | |
708 | |
709 qd = (qq_data *) gc->proto_data; | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
710 account = purple_connection_get_account(gc); |
23052 | 711 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
712 /* conn_data will be destoryed */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
713 qd->conn_data = NULL; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
714 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
715 if (!PURPLE_CONNECTION_IS_VALID(gc)) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
716 purple_debug_info("QQ_CONN", "Invalid connection\n"); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
717 close(source); |
23052 | 718 return; |
719 } | |
720 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
721 if (source < 0) { /* socket returns -1 */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
722 purple_debug_info("QQ_CONN", |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
723 "Could not establish a connection with the server:\n%s\n", |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
724 error_message); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
725 if (qd->connect_watcher > 0) purple_timeout_remove(qd->connect_watcher); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
726 qd->connect_watcher = purple_timeout_add_seconds(QQ_CONNECT_INTERVAL, qq_connect_later, gc); |
23052 | 727 return; |
728 } | |
729 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
730 /* _qq_show_socket("Got login socket", source); */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
731 qd->fd = source; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
732 conn = connection_create(qd, source); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
733 if (qd->use_tcp) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
734 conn->input_handler = purple_input_add(source, PURPLE_INPUT_READ, tcp_pending, gc); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
735 } else { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
736 conn->input_handler = purple_input_add(source, PURPLE_INPUT_READ, udp_pending, gc); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
737 } |
23052 | 738 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
739 do_request_token( gc ); |
23052 | 740 } |
741 | |
24020
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
742 #ifndef purple_proxy_connect_udp |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
743 static void udp_can_write(gpointer data, gint source, PurpleInputCondition cond) |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
744 { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
745 PurpleConnection *gc; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
746 qq_data *qd; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
747 socklen_t len; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
748 int error=0, ret; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
749 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
750 gc = (PurpleConnection *) data; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
751 g_return_if_fail(gc != NULL && gc->proto_data != NULL); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
752 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
753 qd = (qq_data *) gc->proto_data; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
754 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
755 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
756 purple_debug_info("proxy", "Connected.\n"); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
757 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
758 /* |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
759 * getsockopt after a non-blocking connect returns -1 if something is |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
760 * really messed up (bad descriptor, usually). Otherwise, it returns 0 and |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
761 * error holds what connect would have returned if it blocked until now. |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
762 * Thus, error == 0 is success, error == EINPROGRESS means "try again", |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
763 * and anything else is a real error. |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
764 * |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
765 * (error == EINPROGRESS can happen after a select because the kernel can |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
766 * be overly optimistic sometimes. select is just a hint that you might be |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
767 * able to do something.) |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
768 */ |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
769 len = sizeof(error); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
770 ret = getsockopt(source, SOL_SOCKET, SO_ERROR, &error, &len); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
771 if (ret == 0 && error == EINPROGRESS) |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
772 return; /* we'll be called again later */ |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
773 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
774 purple_input_remove(qd->udp_can_write_handler); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
775 qd->udp_can_write_handler = 0; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
776 if (ret < 0 || error != 0) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
777 if(ret != 0) |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
778 error = errno; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
779 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
780 close(source); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
781 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
782 purple_debug_error("proxy", "getsockopt SO_ERROR check: %s\n", g_strerror(error)); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
783 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
784 connect_cb(gc, -1, _("Unable to connect")); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
785 return; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
786 } |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
787 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
788 connect_cb(gc, source, NULL); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
789 } |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
790 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
791 static void udp_host_resolved(GSList *hosts, gpointer data, const char *error_message) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
792 PurpleConnection *gc; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
793 qq_data *qd; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
794 struct sockaddr server_addr; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
795 int addr_size; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
796 gint fd = -1; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
797 int flags; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
798 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
799 gc = (PurpleConnection *) data; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
800 g_return_if_fail(gc != NULL && gc->proto_data != NULL); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
801 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
802 qd = (qq_data *) gc->proto_data; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
803 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
804 /* udp_query_data must be set as NULL. |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
805 * Otherwise purple_dnsquery_destroy in qq_disconnect cause glib double free error */ |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
806 qd->udp_query_data = NULL; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
807 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
808 if (!hosts || !hosts->data) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
809 purple_connection_error_reason(gc, |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
810 PURPLE_CONNECTION_ERROR_NETWORK_ERROR, |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
811 _("Couldn't resolve host")); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
812 return; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
813 } |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
814 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
815 addr_size = GPOINTER_TO_INT(hosts->data); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
816 hosts = g_slist_remove(hosts, hosts->data); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
817 memcpy(&server_addr, hosts->data, addr_size); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
818 g_free(hosts->data); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
819 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
820 hosts = g_slist_remove(hosts, hosts->data); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
821 while(hosts) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
822 hosts = g_slist_remove(hosts, hosts->data); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
823 g_free(hosts->data); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
824 hosts = g_slist_remove(hosts, hosts->data); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
825 } |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
826 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
827 fd = socket(PF_INET, SOCK_DGRAM, 0); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
828 if (fd < 0) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
829 purple_debug_error("QQ", |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
830 "Unable to create socket: %s\n", g_strerror(errno)); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
831 return; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
832 } |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
833 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
834 /* we use non-blocking mode to speed up connection */ |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
835 flags = fcntl(fd, F_GETFL); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
836 fcntl(fd, F_SETFL, flags | O_NONBLOCK); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
837 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
838 /* From Unix-socket-FAQ: http://www.faqs.org/faqs/unix-faq/socket/ |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
839 * |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
840 * If a UDP socket is unconnected, which is the normal state after a |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
841 * bind() call, then send() or write() are not allowed, since no |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
842 * destination is available; only sendto() can be used to send data. |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
843 * |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
844 * Calling connect() on the socket simply records the specified address |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
845 * and port number as being the desired communications partner. That |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
846 * means that send() or write() are now allowed; they use the destination |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
847 * address and port given on the connect call as the destination of packets. |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
848 */ |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
849 if (connect(fd, &server_addr, addr_size) >= 0) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
850 purple_debug_info("QQ", "Connected.\n"); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
851 flags = fcntl(fd, F_GETFL); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
852 fcntl(fd, F_SETFL, flags & ~O_NONBLOCK); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
853 connect_cb(gc, fd, NULL); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
854 return; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
855 } |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
856 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
857 /* [EINPROGRESS] |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
858 * The socket is marked as non-blocking and the connection cannot be |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
859 * completed immediately. It is possible to select for completion by |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
860 * selecting the socket for writing. |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
861 * [EINTR] |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
862 * A signal interrupted the call. |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
863 * The connection is established asynchronously. |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
864 */ |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
865 if ((errno == EINPROGRESS) || (errno == EINTR)) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
866 purple_debug_warning( "QQ", "Connect in asynchronous mode.\n"); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
867 qd->udp_can_write_handler = purple_input_add(fd, PURPLE_INPUT_WRITE, udp_can_write, gc); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
868 return; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
869 } |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
870 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
871 purple_debug_error("QQ", "Connection failed: %s\n", g_strerror(errno)); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
872 close(fd); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
873 } |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
874 #endif |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
875 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
876 gboolean connect_to_server(PurpleConnection *gc, gchar *server, gint port) |
23052 | 877 { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
878 PurpleAccount *account ; |
23052 | 879 qq_data *qd; |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
880 gchar *conn_msg; |
23052 | 881 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
882 g_return_val_if_fail(gc != NULL && gc->proto_data != NULL, FALSE); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
883 account = purple_connection_get_account(gc); |
23052 | 884 qd = (qq_data *) gc->proto_data; |
885 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
886 if (server == NULL || strlen(server) == 0 || port == 0) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
887 purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR, |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
888 _("Invalid server or port")); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
889 return FALSE; |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
890 } |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
891 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
892 conn_msg = g_strdup_printf( _("Connecting server %s, retries %d"), server, port); |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
893 purple_connection_update_progress(gc, conn_msg, 1, QQ_CONNECT_STEPS); |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
894 g_free(conn_msg); |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
895 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
896 purple_debug_info("QQ", "Connect to %s:%d\n", server, port); |
23052 | 897 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
898 if (qd->conn_data != NULL) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
899 purple_proxy_connect_cancel(qd->conn_data); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
900 qd->conn_data = NULL; |
23052 | 901 } |
24020
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
902 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
903 #ifdef purple_proxy_connect_udp |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
904 if (qd->use_tcp) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
905 qd->conn_data = purple_proxy_connect(gc, account, server, port, connect_cb, gc); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
906 } else { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
907 qd->conn_data = purple_proxy_connect_udp(gc, account, server, port, connect_cb, gc); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
908 } |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
909 if ( qd->conn_data == NULL ) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
910 purple_debug_error("QQ", _("Couldn't create socket")); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
911 return FALSE; |
23052 | 912 } |
24020
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
913 #else |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
914 /* QQ connection via UDP/TCP. |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
915 * Now use Purple proxy function to provide TCP proxy support, |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
916 * and qq_udp_proxy.c to add UDP proxy support (thanks henry) */ |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
917 if(qd->use_tcp) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
918 qd->conn_data = purple_proxy_connect(gc, account, server, port, connect_cb, gc); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
919 if ( qd->conn_data == NULL ) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
920 purple_debug_error("QQ", "Unable to connect."); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
921 return FALSE; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
922 } |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
923 return TRUE; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
924 } |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
925 |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
926 purple_debug_info("QQ", "UDP Connect to %s:%d\n", server, port); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
927 qd->udp_query_data = purple_dnsquery_a(server, port, udp_host_resolved, gc); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
928 if ( qd->udp_query_data == NULL ) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
929 purple_debug_error("QQ", "Could not resolve hostname"); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
930 return FALSE; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
931 } |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
932 #endif |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
933 return TRUE; |
23052 | 934 } |
935 | |
936 /* clean up qq_data structure and all its components | |
937 * always used before a redirectly connection */ | |
938 void qq_disconnect(PurpleConnection *gc) | |
939 { | |
940 qq_data *qd; | |
941 | |
942 g_return_if_fail(gc != NULL && gc->proto_data != NULL); | |
943 qd = (qq_data *) gc->proto_data; | |
944 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
945 purple_debug_info("QQ", "Disconnecting ...\n"); |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
946 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
947 if (qd->network_watcher > 0) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
948 purple_debug_info("QQ", "Remove network watcher\n"); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
949 purple_timeout_remove(qd->network_watcher); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
950 qd->network_watcher = 0; |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
951 } |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
952 |
23052 | 953 /* finish all I/O */ |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
954 if (qd->fd >= 0 && qd->is_login) { |
23052 | 955 qq_send_packet_logout(gc); |
956 } | |
957 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
958 /* not connected */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
959 if (qd->conn_data != NULL) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
960 purple_debug_info("QQ", "Connect cancel\n"); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
961 purple_proxy_connect_cancel(qd->conn_data); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
962 qd->conn_data = NULL; |
23052 | 963 } |
24020
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
964 #ifndef purple_proxy_connect_udp |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
965 if (qd->udp_can_write_handler) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
966 purple_input_remove(qd->udp_can_write_handler); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
967 qd->udp_can_write_handler = 0; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
968 } |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
969 if (qd->udp_query_data != NULL) { |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
970 purple_debug_info("QQ", "destroy udp_query_data\n"); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
971 purple_dnsquery_destroy(qd->udp_query_data); |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
972 qd->udp_query_data = NULL; |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
973 } |
2f5a7edd8f68
2008.09.02 - ccpaging <ccpaging(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
24019
diff
changeset
|
974 #endif |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
975 connection_free_all(qd); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
976 qd->fd = -1; |
23052 | 977 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
978 qq_trans_remove_all(gc); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
979 |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
980 if (qd->token) { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
981 purple_debug_info("QQ", "free token\n"); |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
982 g_free(qd->token); |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
983 qd->token = NULL; |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
984 qd->token_len = 0; |
23052 | 985 } |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
986 memset(qd->inikey, 0, sizeof(qd->inikey)); |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
987 memset(qd->password_twice_md5, 0, sizeof(qd->password_twice_md5)); |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
988 memset(qd->session_key, 0, sizeof(qd->session_key)); |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
989 memset(qd->session_md5, 0, sizeof(qd->session_md5)); |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
990 |
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
991 qd->my_ip.s_addr = 0; |
23052 | 992 |
993 qq_group_free_all(qd); | |
994 qq_add_buddy_request_free(qd); | |
995 qq_info_query_free(qd); | |
996 qq_buddies_list_free(gc->account, qd); | |
997 } | |
998 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
999 static gint packet_encap(qq_data *qd, guint8 *buf, gint maxlen, guint16 cmd, guint16 seq, |
23052 | 1000 guint8 *data, gint data_len) |
1001 { | |
1002 gint bytes = 0; | |
1003 g_return_val_if_fail(qd != NULL && buf != NULL && maxlen > 0, -1); | |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1004 g_return_val_if_fail(data != NULL && data_len > 0, -1); |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1005 |
23052 | 1006 /* QQ TCP packet has two bytes in the begining defines packet length |
1007 * so leave room here to store packet size */ | |
1008 if (qd->use_tcp) { | |
1009 bytes += qq_put16(buf + bytes, 0x0000); | |
1010 } | |
1011 /* now comes the normal QQ packet as UDP */ | |
1012 bytes += qq_put8(buf + bytes, QQ_PACKET_TAG); | |
1013 bytes += qq_put16(buf + bytes, QQ_CLIENT); | |
1014 bytes += qq_put16(buf + bytes, cmd); | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1015 |
23052 | 1016 bytes += qq_put16(buf + bytes, seq); |
1017 | |
1018 bytes += qq_put32(buf + bytes, qd->uid); | |
1019 bytes += qq_putdata(buf + bytes, data, data_len); | |
1020 bytes += qq_put8(buf + bytes, QQ_PACKET_TAIL); | |
1021 | |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
1022 /* set TCP packet length at begin of the packet */ |
23052 | 1023 if (qd->use_tcp) { |
1024 qq_put16(buf, bytes); | |
1025 } | |
1026 | |
1027 return bytes; | |
1028 } | |
1029 | |
23683
1c50f12b1c52
2008.08.02 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23606
diff
changeset
|
1030 /* data has been encrypted before */ |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1031 static gint packet_send_out(PurpleConnection *gc, guint16 cmd, guint16 seq, guint8 *data, gint data_len) |
23052 | 1032 { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1033 qq_data *qd; |
23052 | 1034 guint8 *buf; |
1035 gint buf_len; | |
1036 gint bytes_sent; | |
1037 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1038 g_return_val_if_fail(gc != NULL && gc->proto_data != NULL, -1); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1039 qd = (qq_data *)gc->proto_data; |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
1040 g_return_val_if_fail(data != NULL && data_len > 0, -1); |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
1041 |
23052 | 1042 buf = g_newa(guint8, MAX_PACKET_SIZE); |
1043 memset(buf, 0, MAX_PACKET_SIZE); | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1044 buf_len = packet_encap(qd, buf, MAX_PACKET_SIZE, cmd, seq, data, data_len); |
23052 | 1045 if (buf_len <= 0) { |
1046 return -1; | |
1047 } | |
1048 | |
1049 if (qd->use_tcp) { | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1050 bytes_sent = tcp_send_out(gc, buf, buf_len); |
23052 | 1051 } else { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1052 bytes_sent = udp_send_out(gc, buf, buf_len); |
23052 | 1053 } |
1054 | |
1055 return bytes_sent; | |
1056 } | |
1057 | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1058 gint qq_send_cmd_encrypted(PurpleConnection *gc, guint16 cmd, guint16 seq, |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1059 guint8 *data, gint data_len, gboolean need_ack) |
23052 | 1060 { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1061 gint send_len; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1062 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1063 #if 1 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1064 purple_debug_info("QQ", "<== [%05d], %s(0x%04X), datalen %d\n", |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1065 seq, qq_get_cmd_desc(cmd), cmd, data_len); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1066 #endif |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1067 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1068 send_len = packet_send_out(gc, cmd, seq, data, data_len); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1069 if (need_ack) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1070 qq_trans_add_client_cmd(gc, cmd, seq, data, data_len, 0, 0); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1071 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1072 return send_len; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1073 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1074 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1075 /* Encrypt data with session_key, and send packet out */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1076 static gint send_cmd_detail(PurpleConnection *gc, guint16 cmd, guint16 seq, |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1077 guint8 *data, gint data_len, gboolean need_ack, gint update_class, guint32 ship32) |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1078 { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1079 qq_data *qd; |
23052 | 1080 guint8 *encrypted_data; |
1081 gint encrypted_len; | |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1082 gint bytes_sent; |
23052 | 1083 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1084 g_return_val_if_fail(gc != NULL && gc->proto_data != NULL, -1); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1085 qd = (qq_data *)gc->proto_data; |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
1086 g_return_val_if_fail(data != NULL && data_len > 0, -1); |
23052 | 1087 |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1088 /* at most 16 bytes more */ |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1089 encrypted_data = g_newa(guint8, data_len + 16); |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1090 encrypted_len = qq_encrypt(encrypted_data, data, data_len, qd->session_key); |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1091 if (encrypted_len < 16) { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1092 purple_debug_error("QQ_ENCRYPT", "Error len %d: [%05d] 0x%04X %s\n", |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1093 encrypted_len, seq, cmd, qq_get_cmd_desc(cmd)); |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1094 return -1; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1095 } |
23052 | 1096 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1097 bytes_sent = packet_send_out(gc, cmd, seq, encrypted_data, encrypted_len); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1098 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1099 if (need_ack) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1100 qq_trans_add_client_cmd(gc, cmd, seq, encrypted_data, encrypted_len, update_class, ship32); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1101 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1102 return bytes_sent; |
23052 | 1103 } |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
1104 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1105 gint qq_send_cmd_mess(PurpleConnection *gc, guint16 cmd, guint8 *data, gint data_len, |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1106 gint update_class, guint32 ship32) |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
1107 { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1108 qq_data *qd; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1109 guint16 seq; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1110 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1111 g_return_val_if_fail(gc != NULL && gc->proto_data != NULL, -1); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1112 qd = (qq_data *) gc->proto_data; |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
1113 g_return_val_if_fail(data != NULL && data_len > 0, -1); |
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
1114 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1115 seq = ++qd->send_seq; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1116 #if 1 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1117 purple_debug_info("QQ", "<== [%05d], %s(0x%04X), datalen %d\n", |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1118 seq, qq_get_cmd_desc(cmd), cmd, data_len); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1119 #endif |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1120 return send_cmd_detail(gc, cmd, seq, data, data_len, TRUE, update_class, ship32); |
23053
55f986ccbb6a
patch-05-reconnect-and-code-cleanup
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23052
diff
changeset
|
1121 } |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1122 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1123 /* set seq and need_ack, then call send_cmd_detail */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1124 gint qq_send_cmd(PurpleConnection *gc, guint16 cmd, guint8 *data, gint data_len) |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1125 { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1126 qq_data *qd; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1127 guint16 seq; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1128 gboolean need_ack; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1129 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1130 g_return_val_if_fail(gc != NULL && gc->proto_data != NULL, -1); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1131 qd = (qq_data *) gc->proto_data; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1132 g_return_val_if_fail(data != NULL && data_len > 0, -1); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1133 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1134 if (cmd != QQ_CMD_LOGOUT) { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1135 seq = ++qd->send_seq; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1136 need_ack = TRUE; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1137 } else { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1138 seq = 0xFFFF; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1139 need_ack = FALSE; |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1140 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1141 #if 1 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1142 purple_debug_info("QQ", "<== [%05d], %s(0x%04X), datalen %d\n", |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1143 seq, qq_get_cmd_desc(cmd), cmd, data_len); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1144 #endif |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1145 return send_cmd_detail(gc, cmd, seq, data, data_len, need_ack, 0, 0); |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1146 } |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1147 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1148 /* set seq and need_ack, then call send_cmd_detail */ |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1149 gint qq_send_server_reply(PurpleConnection *gc, guint16 cmd, guint16 seq, guint8 *data, gint data_len) |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1150 { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1151 #if 1 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1152 purple_debug_info("QQ", "<== [SRV-%05d], %s(0x%04X), datalen %d\n", |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1153 seq, qq_get_cmd_desc(cmd), cmd, data_len); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1154 #endif |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1155 return send_cmd_detail(gc, cmd, seq, data, data_len, FALSE, 0, 0); |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1156 } |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1157 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1158 static gint send_room_cmd(PurpleConnection *gc, guint8 room_cmd, guint32 room_id, |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1159 guint8 *data, gint data_len, gint update_class, guint32 ship32) |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1160 { |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1161 qq_data *qd; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1162 guint8 *buf; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1163 gint buf_len; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1164 guint8 *encrypted_data; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1165 gint encrypted_len; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1166 gint bytes_sent; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1167 guint16 seq; |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1168 |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1169 g_return_val_if_fail(gc != NULL && gc->proto_data != NULL, -1); |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1170 qd = (qq_data *) gc->proto_data; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1171 |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1172 buf = g_newa(guint8, MAX_PACKET_SIZE); |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1173 memset(buf, 0, MAX_PACKET_SIZE); |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1174 |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1175 /* encap room_cmd and room id to buf*/ |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1176 buf_len = 0; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1177 buf_len += qq_put8(buf + buf_len, room_cmd); |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1178 if (room_id != 0) { |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1179 /* id 0 is for QQ Demo Group, now there are not existed*/ |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1180 buf_len += qq_put32(buf + buf_len, room_id); |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1181 } |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1182 if (data != NULL && data_len > 0) { |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1183 buf_len += qq_putdata(buf + buf_len, data, data_len); |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1184 } |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1185 |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1186 qd->send_seq++; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1187 seq = qd->send_seq; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1188 |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1189 /* Encrypt to encrypted_data with session_key */ |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1190 /* at most 16 bytes more */ |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1191 encrypted_data = g_newa(guint8, buf_len + 16); |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1192 encrypted_len = qq_encrypt(encrypted_data, buf, buf_len, qd->session_key); |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1193 if (encrypted_len < 16) { |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1194 purple_debug_error("QQ_ENCRYPT", "Error len %d: [%05d] %s (0x%02X)\n", |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1195 encrypted_len, seq, qq_get_room_cmd_desc(room_cmd), room_cmd); |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1196 return -1; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1197 } |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1198 |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1199 bytes_sent = packet_send_out(gc, QQ_CMD_ROOM, seq, encrypted_data, encrypted_len); |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1200 #if 1 |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1201 /* qq_show_packet("QQ_SEND_DATA", buf, buf_len); */ |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1202 purple_debug_info("QQ", |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1203 "<== [%05d], %s (0x%02X) to room %d, datalen %d\n", |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1204 seq, qq_get_room_cmd_desc(room_cmd), room_cmd, room_id, buf_len); |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1205 #endif |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1206 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1207 qq_trans_add_room_cmd(gc, seq, room_cmd, room_id, buf, buf_len, update_class, ship32); |
23753
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1208 return bytes_sent; |
5f454b975a99
2008.08.10 - csyfek <csyfek(at)gmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23683
diff
changeset
|
1209 } |
24019
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1210 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1211 gint qq_send_room_cmd_mess(PurpleConnection *gc, guint8 room_cmd, guint32 room_id, |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1212 guint8 *data, gint data_len, gint update_class, guint32 ship32) |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1213 { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1214 return send_room_cmd(gc, room_cmd, room_id, data, data_len, update_class, ship32); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1215 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1216 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1217 gint qq_send_room_cmd(PurpleConnection *gc, guint8 room_cmd, guint32 room_id, |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1218 guint8 *data, gint data_len) |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1219 { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1220 return send_room_cmd(gc, room_cmd, room_id, data, data_len, 0, 0); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1221 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1222 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1223 gint qq_send_room_cmd_noid(PurpleConnection *gc, guint8 room_cmd, |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1224 guint8 *data, gint data_len) |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1225 { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1226 return send_room_cmd(gc, room_cmd, 0, data, data_len, 0, 0); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1227 } |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1228 |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1229 gint qq_send_room_cmd_only(PurpleConnection *gc, guint8 room_cmd, guint32 room_id) |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1230 { |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1231 g_return_val_if_fail(room_cmd > 0 && room_id > 0, -1); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1232 return send_room_cmd(gc, room_cmd, room_id, NULL, 0, 0, 0); |
147ada94a1d8
2008.08.16 - ccpaging <ecc_hy(at)hotmail.com>
SHiNE CsyFeK <csyfek@gmail.com>
parents:
23774
diff
changeset
|
1233 } |