Mercurial > pidgin
annotate src/protocols/gg/libgg.c @ 2792:9123abd0db92
[gaim-migrate @ 2805]
Arkadiusz Miskiewicz's updates to Gadu-Gadu
committer: Tailor Script <tailor@pidgin.im>
author | Eric Warmenhoven <eric@warmenhoven.org> |
---|---|
date | Mon, 26 Nov 2001 21:22:56 +0000 |
parents | 04a5f68f640c |
children | 4b3f17ca66bf |
rev | line source |
---|---|
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1 /* $Id: libgg.c 2805 2001-11-26 21:22:56Z warmenhoven $ */ |
2393 | 2 |
3 /* | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
4 * (C) Copyright 2001 Wojtek Kaniewski <wojtekka@irc.pl>, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
5 * Robert J. Woźny <speedy@atman.pl> |
2393 | 6 * |
7 * This program is free software; you can redistribute it and/or modify | |
8 * it under the terms of the GNU General Public License Version 2 as | |
9 * published by the Free Software Foundation. | |
10 * | |
11 * This program is distributed in the hope that it will be useful, | |
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of | |
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
14 * GNU General Public License for more details. | |
15 * | |
16 * You should have received a copy of the GNU General Public License | |
17 * along with this program; if not, write to the Free Software | |
18 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. | |
19 */ | |
20 | |
21 #include <stdio.h> | |
22 #include <stdlib.h> | |
23 #include <unistd.h> | |
24 #include <stdio.h> | |
25 #include <sys/socket.h> | |
26 #include <netinet/in.h> | |
27 #include <arpa/inet.h> | |
28 #include <sys/ioctl.h> | |
29 #include <sys/wait.h> | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
30 #include <sys/time.h> |
2393 | 31 #include <netdb.h> |
32 #include <errno.h> | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
33 #ifndef _AIX |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
34 # include <string.h> |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
35 #endif |
2393 | 36 #include <stdarg.h> |
37 #include <pwd.h> | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
38 #include <time.h> |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
39 #ifdef sun |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
40 #include <sys/filio.h> |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
41 #endif |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
42 #include <glib.h> |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
43 #if G_BYTE_ORDER == G_BIG_ENDIAN |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
44 # define WORDS_BIGENDIAN 1 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
45 #endif |
2393 | 46 #include "libgg.h" |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
47 #include "config.h" |
2393 | 48 |
49 int gg_debug_level = 0; | |
50 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
51 #ifndef lint |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
52 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
53 static char rcsid[] |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
54 #ifdef __GNUC__ |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
55 __attribute__ ((unused)) |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
56 #endif |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
57 = "$Id: libgg.c 2805 2001-11-26 21:22:56Z warmenhoven $"; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
58 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
59 #endif |
2393 | 60 |
61 /* | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
62 * gg_debug() |
2393 | 63 * |
64 * wyrzuca komunikat o danym poziomie, o ile użytkownik sobie tego życzy. | |
65 * | |
66 * - level - poziom wiadomości, | |
67 * - format... - treść wiadomości (printf-alike.) | |
68 * | |
69 * niczego nie zwraca. | |
70 */ | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
71 void gg_debug(int level, char *format, ...) |
2393 | 72 { |
73 va_list ap; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
74 |
2393 | 75 if ((gg_debug_level & level)) { |
76 va_start(ap, format); | |
77 vprintf(format, ap); | |
78 va_end(ap); | |
79 } | |
80 } | |
81 | |
82 /* | |
83 * fix32() // funkcja wewnętrzna | |
84 * | |
85 * dla maszyn big-endianowych zamienia kolejność bajtów w ,,long''ach. | |
86 */ | |
87 static inline unsigned long fix32(unsigned long x) | |
88 { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
89 #ifndef WORDS_BIGENDIAN |
2393 | 90 return x; |
91 #else | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
92 return (unsigned long) |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
93 (((x & (unsigned long)0x000000ffU) << 24) | |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
94 ((x & (unsigned long)0x0000ff00U) << 8) | |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
95 ((x & (unsigned long)0x00ff0000U) >> 8) | ((x & (unsigned long)0xff000000U) >> 24)); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
96 #endif |
2393 | 97 } |
98 | |
99 /* | |
100 * fix16() // funkcja wewnętrzna | |
101 * | |
102 * dla maszyn big-endianowych zamienia kolejność bajtów w ,,short''ach. | |
103 */ | |
104 static inline unsigned short fix16(unsigned short x) | |
105 { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
106 #ifndef WORDS_BIGENDIAN |
2393 | 107 return x; |
108 #else | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
109 return (unsigned short) |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
110 (((x & (unsigned short)0x00ffU) << 8) | ((x & (unsigned short)0xff00U) >> 8)); |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
111 #endif |
2393 | 112 } |
113 | |
114 /* | |
115 * gg_alloc_sprintf() // funkcja wewnętrzna | |
116 * | |
117 * robi dokładnie to samo, co sprintf(), tyle że alokuje sobie wcześniej | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
118 * miejsce na dane. powinno działać na tych maszynach, które mają funkcję |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
119 * vsnprintf() zgodną z C99, jak i na wcześniejszych. |
2393 | 120 * |
121 * - format, ... - parametry takie same jak w innych funkcjach *printf() | |
122 * | |
123 * zwraca zaalokowany buforek, który wypadałoby później zwolnić, lub NULL | |
124 * jeśli nie udało się wykonać zadania. | |
125 */ | |
126 char *gg_alloc_sprintf(char *format, ...) | |
127 { | |
128 va_list ap; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
129 char *buf = NULL, *tmp; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
130 int size = 0, res; |
2393 | 131 |
132 va_start(ap, format); | |
133 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
134 if ((size = vsnprintf(buf, 0, format, ap)) < 1) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
135 size = 128; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
136 do { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
137 size *= 2; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
138 if (!(tmp = realloc(buf, size))) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
139 free(buf); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
140 return NULL; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
141 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
142 buf = tmp; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
143 res = vsnprintf(buf, size, format, ap); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
144 } while (res == size - 1); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
145 } else { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
146 if (!(buf = malloc(size + 1))) |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
147 return NULL; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
148 } |
2393 | 149 |
150 vsnprintf(buf, size + 1, format, ap); | |
151 | |
152 va_end(ap); | |
153 | |
154 return buf; | |
155 } | |
156 | |
157 /* | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
158 * gg_get_line() // funkcja wewnętrzna |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
159 * |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
160 * podaje kolejną linię z bufora tekstowego. psuje co bezpowrotnie, dzieląc |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
161 * na kolejne stringi. zdarza się, nie ma potrzeby pisania funkcji dublującej |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
162 * bufor żeby tylko mieć nieruszone dane wejściowe, skoro i tak nie będą nam |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
163 * poźniej potrzebne. obcina `\r\n'. |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
164 * |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
165 * - ptr - wskaźnik do zmiennej, która przechowuje aktualną pozycję |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
166 * w przemiatanym buforze. |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
167 * |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
168 * wskaźnik do kolejnej linii tekstu lub NULL, jeśli to już koniec bufora. |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
169 */ |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
170 char *gg_get_line(char **ptr) |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
171 { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
172 char *foo, *res; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
173 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
174 if (!ptr || !*ptr || !strcmp(*ptr, "")) |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
175 return NULL; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
176 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
177 res = *ptr; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
178 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
179 if (!(foo = strchr(*ptr, '\n'))) |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
180 *ptr += strlen(*ptr); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
181 else { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
182 *ptr = foo + 1; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
183 *foo = 0; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
184 if (res[strlen(res) - 1] == '\r') |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
185 res[strlen(res) - 1] = 0; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
186 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
187 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
188 return res; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
189 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
190 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
191 /* |
2393 | 192 * gg_resolve() // funkcja wewnętrzna |
193 * | |
194 * tworzy pipe'y, forkuje się i w drugim procesie zaczyna resolvować | |
195 * podanego hosta. zapisuje w sesji deskryptor pipe'u. jeśli coś tam | |
196 * będzie gotowego, znaczy, że można wczytać ,,struct in_addr''. jeśli | |
197 * nie znajdzie, zwraca INADDR_NONE. | |
198 * | |
199 * - fd - wskaźnik gdzie wrzucić deskryptor, | |
200 * - pid - gdzie wrzucić pid dzieciaka, | |
201 * - hostname - nazwa hosta do zresolvowania. | |
202 * | |
203 * zwraca 0 jeśli udało się odpalić proces lub -1 w przypadku błędu. | |
204 */ | |
205 int gg_resolve(int *fd, int *pid, char *hostname) | |
206 { | |
207 int pipes[2], res; | |
208 struct in_addr a; | |
209 | |
210 gg_debug(GG_DEBUG_FUNCTION, "** gg_resolve(..., \"%s\");\n", hostname); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
211 |
2393 | 212 if (!fd | !pid) { |
213 errno = EFAULT; | |
214 return -1; | |
215 } | |
216 | |
217 if (pipe(pipes) == -1) | |
218 return -1; | |
219 | |
220 if ((res = fork()) == -1) | |
221 return -1; | |
222 | |
223 if (!res) { | |
224 if ((a.s_addr = inet_addr(hostname)) == INADDR_NONE) { | |
225 struct hostent *he; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
226 |
2393 | 227 if (!(he = gethostbyname(hostname))) |
228 a.s_addr = INADDR_NONE; | |
229 else | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
230 memcpy((char *)&a, he->h_addr, sizeof(a)); |
2393 | 231 } |
232 | |
233 write(pipes[1], &a, sizeof(a)); | |
234 | |
235 exit(0); | |
236 } | |
237 | |
238 close(pipes[1]); | |
239 | |
240 *fd = pipes[0]; | |
241 *pid = res; | |
242 | |
243 return 0; | |
244 } | |
245 | |
246 /* | |
247 * gg_connect() // funkcja wewnętrzna | |
248 * | |
249 * łączy się z serwerem. pierwszy argument jest typu (void *), żeby nie | |
250 * musieć niczego inkludować w libgg.h i nie psuć jakiś głupich zależności | |
251 * na dziwnych systemach. | |
252 * | |
253 * - addr - adres serwera (struct in_addr *), | |
254 * - port - port serwera, | |
255 * - async - ma być asynchroniczne połączenie? | |
256 * | |
257 * zwraca połączonego socketa lub -1 w przypadku błędu. zobacz errno. | |
258 */ | |
259 int gg_connect(void *addr, int port, int async) | |
260 { | |
261 int sock, one = 1; | |
262 struct sockaddr_in sin; | |
263 struct in_addr *a = addr; | |
264 | |
265 gg_debug(GG_DEBUG_FUNCTION, "** gg_connect(%s, %d, %d);\n", inet_ntoa(*a), port, async); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
266 |
2393 | 267 if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1) { |
268 gg_debug(GG_DEBUG_MISC, "-- socket() failed. errno = %d (%s)\n", errno, strerror(errno)); | |
269 return -1; | |
270 } | |
271 | |
272 if (async) { | |
273 if (ioctl(sock, FIONBIO, &one) == -1) { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
274 gg_debug(GG_DEBUG_MISC, "-- ioctl() failed. errno = %d (%s)\n", errno, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
275 strerror(errno)); |
2393 | 276 return -1; |
277 } | |
278 } | |
279 | |
280 sin.sin_port = htons(port); | |
281 sin.sin_family = AF_INET; | |
282 sin.sin_addr.s_addr = a->s_addr; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
283 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
284 if (connect(sock, (struct sockaddr *)&sin, sizeof(sin)) == -1) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
285 if (errno && (!async || errno != EINPROGRESS)) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
286 gg_debug(GG_DEBUG_MISC, "-- connect() failed. errno = %d (%s)\n", errno, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
287 strerror(errno)); |
2393 | 288 return -1; |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
289 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
290 gg_debug(GG_DEBUG_MISC, "-- connect() in progress\n"); |
2393 | 291 } |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
292 |
2393 | 293 return sock; |
294 } | |
295 | |
296 /* | |
297 * gg_read_line() // funkcja wewnętrzna | |
298 * | |
299 * czyta jedną linię tekstu z socketa. | |
300 * | |
301 * - sock - socket, | |
302 * - buf - wskaźnik bufora, | |
303 * - length - długość bufora. | |
304 * | |
305 * olewa błędy. jeśli na jakiś trafi, potraktuje go jako koniec linii. | |
306 */ | |
307 static void gg_read_line(int sock, char *buf, int length) | |
308 { | |
309 int ret; | |
310 | |
311 gg_debug(GG_DEBUG_FUNCTION, "** gg_read_line(...);\n"); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
312 |
2393 | 313 for (; length > 1; buf++, length--) { |
314 do { | |
315 if ((ret = read(sock, buf, 1)) == -1 && errno != EINTR) { | |
316 *buf = 0; | |
317 return; | |
318 } | |
319 } while (ret == -1 && errno == EINTR); | |
320 | |
321 if (*buf == '\n') { | |
322 buf++; | |
323 break; | |
324 } | |
325 } | |
326 | |
327 *buf = 0; | |
328 return; | |
329 } | |
330 | |
331 /* | |
332 * gg_recv_packet() // funkcja wewnętrzna | |
333 * | |
334 * odbiera jeden pakiet gg i zwraca wskaźnik do niego. pamięć po nim | |
335 * wypadałoby uwolnić. | |
336 * | |
337 * - sock - połączony socket. | |
338 * | |
339 * jeśli wystąpił błąd, zwraca NULL. reszta w errno. | |
340 */ | |
341 static void *gg_recv_packet(struct gg_session *sess) | |
342 { | |
343 struct gg_header h; | |
344 char *buf = NULL; | |
345 int ret = 0, offset, size = 0; | |
346 | |
347 gg_debug(GG_DEBUG_FUNCTION, "** gg_recv_packet(...);\n"); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
348 |
2393 | 349 if (!sess) { |
350 errno = EFAULT; | |
351 return NULL; | |
352 } | |
353 | |
354 if (sess->recv_left < 1) { | |
355 while (ret != sizeof(h)) { | |
356 ret = read(sess->fd, &h, sizeof(h)); | |
357 gg_debug(GG_DEBUG_MISC, "-- header recv(..., %d) = %d\n", sizeof(h), ret); | |
358 if (ret < sizeof(h)) { | |
359 if (errno != EINTR) { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
360 gg_debug(GG_DEBUG_MISC, "-- errno = %d (%s)\n", errno, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
361 strerror(errno)); |
2393 | 362 return NULL; |
363 } | |
364 } | |
365 } | |
366 | |
367 h.type = fix32(h.type); | |
368 h.length = fix32(h.length); | |
369 } else { | |
370 memcpy(&h, sess->recv_buf, sizeof(h)); | |
371 } | |
372 | |
373 /* jakieś sensowne limity na rozmiar pakietu */ | |
374 if (h.length < 0 || h.length > 65535) { | |
375 gg_debug(GG_DEBUG_MISC, "-- invalid packet length (%d)\n", h.length); | |
376 errno = ERANGE; | |
377 return NULL; | |
378 } | |
379 | |
380 if (sess->recv_left > 0) { | |
381 gg_debug(GG_DEBUG_MISC, "-- resuming last gg_recv_packet()\n"); | |
382 size = sess->recv_left; | |
383 offset = sess->recv_done; | |
384 buf = sess->recv_buf; | |
385 } else { | |
386 if (!(buf = malloc(sizeof(h) + h.length + 1))) { | |
387 gg_debug(GG_DEBUG_MISC, "-- not enough memory\n"); | |
388 return NULL; | |
389 } | |
390 | |
391 memcpy(buf, &h, sizeof(h)); | |
392 | |
393 offset = 0; | |
394 size = h.length; | |
395 } | |
396 | |
397 while (size > 0) { | |
398 ret = read(sess->fd, buf + sizeof(h) + offset, size); | |
399 gg_debug(GG_DEBUG_MISC, "-- body recv(..., %d) = %d\n", size, ret); | |
400 if (ret > -1 && ret <= size) { | |
401 offset += ret; | |
402 size -= ret; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
403 } else if (ret == -1) { |
2393 | 404 gg_debug(GG_DEBUG_MISC, "-- errno = %d (%s)\n", errno, strerror(errno)); |
405 if (errno == EAGAIN) { | |
406 gg_debug(GG_DEBUG_MISC, "-- %d bytes received, %d left\n", offset, size); | |
407 sess->recv_buf = buf; | |
408 sess->recv_left = size; | |
409 sess->recv_done = offset; | |
410 return NULL; | |
411 } | |
412 if (errno != EINTR) { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
413 // errno = EINVAL; |
2393 | 414 free(buf); |
415 return NULL; | |
416 } | |
417 } | |
418 } | |
419 | |
420 sess->recv_left = 0; | |
421 | |
422 if ((gg_debug_level & GG_DEBUG_DUMP)) { | |
423 int i; | |
424 | |
425 gg_debug(GG_DEBUG_DUMP, ">> received packet (type=%.2x):", h.type); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
426 for (i = 0; i < sizeof(h) + h.length; i++) |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
427 gg_debug(GG_DEBUG_DUMP, " %.2x", (unsigned char)buf[i]); |
2393 | 428 gg_debug(GG_DEBUG_DUMP, "\n"); |
429 } | |
430 | |
431 return buf; | |
432 } | |
433 | |
434 /* | |
435 * gg_send_packet() // funkcja wewnętrzna | |
436 * | |
437 * konstruuje pakiet i wysyła go w do serwera. | |
438 * | |
439 * - sock - połączony socket, | |
440 * - type - typ pakietu, | |
441 * - packet - wskaźnik do struktury pakietu, | |
442 * - length - długość struktury pakietu, | |
443 * - payload - dodatkowy tekst doklejany do pakietu (np. wiadomość), | |
444 * - payload_length - długość dodatkowego tekstu. | |
445 * | |
446 * jeśli poszło dobrze, zwraca 0. w przypadku błędu -1. jeśli errno=ENOMEM, | |
447 * zabrakło pamięci. inaczej był błąd przy wysyłaniu pakietu. dla errno=0 | |
448 * nie wysłano całego pakietu. | |
449 */ | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
450 static int gg_send_packet(int sock, int type, void *packet, int length, void *payload, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
451 int payload_length) |
2393 | 452 { |
453 struct gg_header *h; | |
454 int res, plen; | |
455 char *tmp; | |
456 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
457 gg_debug(GG_DEBUG_FUNCTION, "** gg_send_packet(0x%.2x, %d, %d);\n", type, length, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
458 payload_length); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
459 |
2393 | 460 if (length < 0 || payload_length < 0) { |
461 gg_debug(GG_DEBUG_MISC, "-- invalid packet/payload length\n"); | |
462 errno = ERANGE; | |
463 return -1; | |
464 } | |
465 | |
466 if (!(tmp = malloc(sizeof(struct gg_header) + length + payload_length))) { | |
467 gg_debug(GG_DEBUG_MISC, "-- not enough memory\n"); | |
468 return -1; | |
469 } | |
470 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
471 h = (struct gg_header *)tmp; |
2393 | 472 h->type = fix32(type); |
473 h->length = fix32(length + payload_length); | |
474 | |
475 if (packet) | |
476 memcpy(tmp + sizeof(struct gg_header), packet, length); | |
477 if (payload) | |
478 memcpy(tmp + sizeof(struct gg_header) + length, payload, payload_length); | |
479 | |
480 if ((gg_debug_level & GG_DEBUG_DUMP)) { | |
481 int i; | |
482 | |
483 gg_debug(GG_DEBUG_DUMP, "%%%% sending packet (type=%.2x):", fix32(h->type)); | |
484 for (i = 0; i < sizeof(struct gg_header) + fix32(h->length); i++) | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
485 gg_debug(GG_DEBUG_DUMP, " %.2x", (unsigned char)tmp[i]); |
2393 | 486 gg_debug(GG_DEBUG_DUMP, "\n"); |
487 } | |
488 | |
489 plen = sizeof(struct gg_header) + length + payload_length; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
490 |
2393 | 491 if ((res = write(sock, tmp, plen)) < plen) { |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
492 gg_debug(GG_DEBUG_MISC, "-- write() failed. res = %d, errno = %d (%s)\n", res, errno, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
493 strerror(errno)); |
2393 | 494 free(tmp); |
495 return -1; | |
496 } | |
497 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
498 free(tmp); |
2393 | 499 return 0; |
500 } | |
501 | |
502 | |
503 /* | |
504 * gg_login() | |
505 * | |
506 * rozpoczyna procedurę łączenia się z serwerem. resztę obsłguje się przez | |
507 * gg_watch_event. | |
508 * | |
509 * - uin - numerek usera, | |
510 * - password - jego hasełko, | |
511 * - async - ma być asynchronicznie? | |
512 * | |
513 * UWAGA! program musi obsłużyć SIGCHLD, jeśli łączy się asynchronicznie, | |
514 * żeby zrobić pogrzeb zmarłemu procesowi resolvera. | |
515 * | |
516 * w przypadku błędu zwraca NULL, jeśli idzie dobrze (async) albo poszło | |
517 * dobrze (sync), zwróci wskaźnik do zaalokowanej struktury `gg_session'. | |
518 */ | |
519 struct gg_session *gg_login(uin_t uin, char *password, int async) | |
520 { | |
521 struct gg_session *sess; | |
522 | |
523 gg_debug(GG_DEBUG_FUNCTION, "** gg_login(%u, \"...\", %d);\n", uin, async); | |
524 | |
525 if (!(sess = malloc(sizeof(*sess)))) | |
526 return NULL; | |
527 | |
528 sess->uin = uin; | |
529 if (!(sess->password = strdup(password))) { | |
530 free(sess); | |
531 return NULL; | |
532 } | |
533 sess->state = GG_STATE_RESOLVING; | |
534 sess->check = GG_CHECK_READ; | |
535 sess->async = async; | |
536 sess->seq = 0; | |
537 sess->recv_left = 0; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
538 sess->last_pong = 0; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
539 sess->server_ip = 0; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
540 sess->initial_status = 0; |
2393 | 541 |
542 if (async) { | |
543 if (gg_resolve(&sess->fd, &sess->pid, GG_APPMSG_HOST)) { | |
544 gg_debug(GG_DEBUG_MISC, "-- resolving failed\n"); | |
545 free(sess); | |
546 return NULL; | |
547 } | |
548 } else { | |
549 struct in_addr a; | |
550 | |
551 if ((a.s_addr = inet_addr(GG_APPMSG_HOST)) == INADDR_NONE) { | |
552 struct hostent *he; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
553 |
2393 | 554 if (!(he = gethostbyname(GG_APPMSG_HOST))) { |
555 gg_debug(GG_DEBUG_MISC, "-- host %s not found\n", GG_APPMSG_HOST); | |
556 free(sess); | |
557 return NULL; | |
558 } else | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
559 memcpy((char *)&a, he->h_addr, sizeof(a)); |
2393 | 560 } |
561 | |
562 if (!(sess->fd = gg_connect(&a, GG_APPMSG_PORT, 0)) == -1) { | |
563 gg_debug(GG_DEBUG_MISC, "-- connection failed\n"); | |
564 free(sess); | |
565 return NULL; | |
566 } | |
567 | |
568 sess->state = GG_STATE_CONNECTING_HTTP; | |
569 | |
570 while (sess->state != GG_STATE_CONNECTED) { | |
571 struct gg_event *e; | |
572 | |
573 if (!(e = gg_watch_fd(sess))) { | |
574 gg_debug(GG_DEBUG_MISC, "-- some nasty error in gg_watch_fd()\n"); | |
575 free(sess); | |
576 return NULL; | |
577 } | |
578 | |
579 if (e->type == GG_EVENT_CONN_FAILED) { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
580 errno = EACCES; |
2393 | 581 gg_debug(GG_DEBUG_MISC, "-- could not login\n"); |
582 gg_free_event(e); | |
583 free(sess); | |
584 return NULL; | |
585 } | |
586 | |
587 gg_free_event(e); | |
588 } | |
589 } | |
590 | |
591 return sess; | |
592 } | |
593 | |
594 /* | |
595 * gg_free_session() | |
596 * | |
597 * zwalnia pamięć zajmowaną przez opis sesji. | |
598 * | |
599 * - sess - opis sesji. | |
600 * | |
601 * nie zwraca niczego, bo i po co? | |
602 */ | |
603 void gg_free_session(struct gg_session *sess) | |
604 { | |
605 if (!sess) | |
606 return; | |
607 | |
608 free(sess->password); | |
609 free(sess); | |
610 } | |
611 | |
612 /* | |
613 * gg_change_status() | |
614 * | |
615 * zmienia status użytkownika. przydatne do /away i /busy oraz /quit. | |
616 * | |
617 * - sess - opis sesji, | |
618 * - status - nowy status użytkownika. | |
619 * | |
620 * jeśli wysłał pakiet zwraca 0, jeśli nie udało się, zwraca -1. | |
621 */ | |
622 int gg_change_status(struct gg_session *sess, int status) | |
623 { | |
624 struct gg_new_status p; | |
625 | |
626 if (!sess) { | |
627 errno = EFAULT; | |
628 return -1; | |
629 } | |
630 | |
631 if (sess->state != GG_STATE_CONNECTED) { | |
632 errno = ENOTCONN; | |
633 return -1; | |
634 } | |
635 | |
636 gg_debug(GG_DEBUG_FUNCTION, "** gg_change_status(..., %d);\n", status); | |
637 | |
638 p.status = fix32(status); | |
639 | |
640 return gg_send_packet(sess->fd, GG_NEW_STATUS, &p, sizeof(p), NULL, 0); | |
641 } | |
642 | |
643 /* | |
644 * gg_logoff() | |
645 * | |
646 * wylogowuje użytkownika i zamyka połączenie. | |
647 * | |
648 * - sock - deskryptor socketu. | |
649 * | |
650 * nie zwraca błędów. skoro się żegnamy, to olewamy wszystko. | |
651 */ | |
652 void gg_logoff(struct gg_session *sess) | |
653 { | |
654 if (!sess) | |
655 return; | |
656 | |
657 gg_debug(GG_DEBUG_FUNCTION, "** gg_logoff(...);\n"); | |
658 | |
659 if (sess->state == GG_STATE_CONNECTED) | |
660 gg_change_status(sess, GG_STATUS_NOT_AVAIL); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
661 |
2393 | 662 if (sess->fd) { |
663 shutdown(sess->fd, 2); | |
664 close(sess->fd); | |
665 } | |
666 } | |
667 | |
668 /* | |
669 * gg_send_message() | |
670 * | |
671 * wysyła wiadomość do innego użytkownika. zwraca losowy numer | |
672 * sekwencyjny, który można olać albo wykorzystać do potwierdzenia. | |
673 * | |
674 * - sess - opis sesji, | |
675 * - msgclass - rodzaj wiadomości, | |
676 * - recipient - numer adresata, | |
677 * - message - treść wiadomości. | |
678 * | |
679 * w przypadku błędu zwraca -1, inaczej numer sekwencyjny. | |
680 */ | |
681 int gg_send_message(struct gg_session *sess, int msgclass, uin_t recipient, unsigned char *message) | |
682 { | |
683 struct gg_send_msg s; | |
684 | |
685 if (!sess) { | |
686 errno = EFAULT; | |
687 return -1; | |
688 } | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
689 |
2393 | 690 if (sess->state != GG_STATE_CONNECTED) { |
691 errno = ENOTCONN; | |
692 return -1; | |
693 } | |
694 | |
695 gg_debug(GG_DEBUG_FUNCTION, "** gg_send_message(..., %d, %u, \"...\");\n", msgclass, recipient); | |
696 | |
697 s.recipient = fix32(recipient); | |
698 if (!sess->seq) | |
699 sess->seq = 0x01740000 | (rand() & 0xffff); | |
700 s.seq = fix32(sess->seq); | |
701 s.msgclass = fix32(msgclass); | |
702 sess->seq += (rand() % 0x300) + 0x300; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
703 |
2393 | 704 if (gg_send_packet(sess->fd, GG_SEND_MSG, &s, sizeof(s), message, strlen(message) + 1) == -1) |
705 return -1; | |
706 | |
707 return fix32(s.seq); | |
708 } | |
709 | |
710 /* | |
711 * gg_ping() | |
712 * | |
713 * wysyła do serwera pakiet typu yeah-i'm-still-alive. | |
714 * | |
715 * - sess - zgadnij. | |
716 * | |
717 * jeśli nie powiodło się wysłanie pakietu, zwraca -1. otherwise 0. | |
718 */ | |
719 int gg_ping(struct gg_session *sess) | |
720 { | |
721 if (!sess) { | |
722 errno = EFAULT; | |
723 return -1; | |
724 } | |
725 | |
726 if (sess->state != GG_STATE_CONNECTED) { | |
727 errno = ENOTCONN; | |
728 return -1; | |
729 } | |
730 | |
731 gg_debug(GG_DEBUG_FUNCTION, "** gg_ping(...);\n"); | |
732 | |
733 return gg_send_packet(sess->fd, GG_PING, NULL, 0, NULL, 0); | |
734 } | |
735 | |
736 /* | |
737 * gg_free_event() | |
738 * | |
739 * zwalnia pamięć zajmowaną przez informację o zdarzeniu | |
740 * | |
741 * - event - wskaźnik do informacji o zdarzeniu | |
742 * | |
743 * nie ma czego zwracać. | |
744 */ | |
745 void gg_free_event(struct gg_event *e) | |
746 { | |
747 if (!e) | |
748 return; | |
749 if (e->type == GG_EVENT_MSG) | |
750 free(e->event.msg.message); | |
751 if (e->type == GG_EVENT_NOTIFY) | |
752 free(e->event.notify); | |
753 free(e); | |
754 } | |
755 | |
756 /* | |
757 * gg_notify() | |
758 * | |
759 * wysyła serwerowi listę ludków, za którymi tęsknimy. | |
760 * | |
761 * - sess - identyfikator sesji, | |
762 * - userlist - wskaźnik do tablicy numerów, | |
763 * - count - ilość numerków. | |
764 * | |
765 * jeśli udało się, zwraca 0. jeśli błąd, dostajemy -1. | |
766 */ | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
767 int gg_notify(struct gg_session *sess, uin_t * userlist, int count) |
2393 | 768 { |
769 struct gg_notify *n; | |
770 uin_t *u; | |
771 int i, res = 0; | |
772 | |
773 if (!sess) { | |
774 errno = EFAULT; | |
775 return -1; | |
776 } | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
777 |
2393 | 778 if (sess->state != GG_STATE_CONNECTED) { |
779 errno = ENOTCONN; | |
780 return -1; | |
781 } | |
782 | |
783 gg_debug(GG_DEBUG_FUNCTION, "** gg_notify(..., %d);\n", count); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
784 |
2393 | 785 if (!userlist || !count) |
786 return 0; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
787 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
788 if (!(n = (struct gg_notify *)malloc(sizeof(*n) * count))) |
2393 | 789 return -1; |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
790 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
791 for (u = userlist, i = 0; i < count; u++, i++) { |
2393 | 792 n[i].uin = fix32(*u); |
793 n[i].dunno1 = 3; | |
794 } | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
795 |
2393 | 796 if (gg_send_packet(sess->fd, GG_NOTIFY, n, sizeof(*n) * count, NULL, 0) == -1) |
797 res = -1; | |
798 | |
799 free(n); | |
800 | |
801 return res; | |
802 } | |
803 | |
804 /* | |
805 * gg_add_notify() | |
806 * | |
807 * dodaje w locie do listy ukochanych dany numerek. | |
808 * | |
809 * - sess - identyfikator sesji, | |
810 * - uin - numerek ukochanej. | |
811 * | |
812 * jeśli udało się wysłać, daje 0. inaczej -1. | |
813 */ | |
814 int gg_add_notify(struct gg_session *sess, uin_t uin) | |
815 { | |
816 struct gg_add_remove a; | |
817 | |
818 if (!sess) { | |
819 errno = EFAULT; | |
820 return -1; | |
821 } | |
822 | |
823 if (sess->state != GG_STATE_CONNECTED) { | |
824 errno = ENOTCONN; | |
825 return -1; | |
826 } | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
827 |
2393 | 828 gg_debug(GG_DEBUG_FUNCTION, "** gg_add_notify(..., %u);\n", uin); |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
829 |
2393 | 830 a.uin = fix32(uin); |
831 a.dunno1 = 3; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
832 |
2393 | 833 return gg_send_packet(sess->fd, GG_ADD_NOTIFY, &a, sizeof(a), NULL, 0); |
834 } | |
835 | |
836 /* | |
837 * gg_remove_notify() | |
838 * | |
839 * w locie usuwa z listy zainteresowanych. | |
840 * | |
841 * - sess - id sesji, | |
842 * - uin - numerek. | |
843 * | |
844 * zwraca -1 jeśli był błąd, 0 jeśli się udało wysłać pakiet. | |
845 */ | |
846 int gg_remove_notify(struct gg_session *sess, uin_t uin) | |
847 { | |
848 struct gg_add_remove a; | |
849 | |
850 if (!sess) { | |
851 errno = EFAULT; | |
852 return -1; | |
853 } | |
854 | |
855 if (sess->state != GG_STATE_CONNECTED) { | |
856 errno = ENOTCONN; | |
857 return -1; | |
858 } | |
859 | |
860 gg_debug(GG_DEBUG_FUNCTION, "** gg_remove_notify(..., %u);\n", uin); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
861 |
2393 | 862 a.uin = fix32(uin); |
863 a.dunno1 = 3; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
864 |
2393 | 865 return gg_send_packet(sess->fd, GG_REMOVE_NOTIFY, &a, sizeof(a), NULL, 0); |
866 } | |
867 | |
868 /* | |
869 * gg_watch_fd_connected() // funkcja wewnętrzna | |
870 * | |
871 * patrzy na socketa, odbiera pakiet i wypełnia strukturę zdarzenia. | |
872 * | |
873 * - sock - lalala, trudno zgadnąć. | |
874 * | |
875 * jeśli błąd -1, jeśli dobrze 0. | |
876 */ | |
877 static int gg_watch_fd_connected(struct gg_session *sess, struct gg_event *e) | |
878 { | |
879 struct gg_header *h; | |
880 void *p; | |
881 | |
882 if (!sess) { | |
883 errno = EFAULT; | |
884 return -1; | |
885 } | |
886 | |
887 gg_debug(GG_DEBUG_FUNCTION, "** gg_watch_fd_connected(...);\n"); | |
888 | |
889 if (!(h = gg_recv_packet(sess))) { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
890 gg_debug(GG_DEBUG_MISC, "-- gg_recv_packet failed. errno = %d (%d)\n", errno, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
891 strerror(errno)); |
2393 | 892 return -1; |
893 } | |
894 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
895 p = (void *)h + sizeof(struct gg_header); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
896 |
2393 | 897 if (h->type == GG_RECV_MSG) { |
898 struct gg_recv_msg *r = p; | |
899 | |
900 gg_debug(GG_DEBUG_MISC, "-- received a message\n"); | |
901 | |
902 if (h->length >= sizeof(*r)) { | |
903 e->type = GG_EVENT_MSG; | |
904 e->event.msg.msgclass = fix32(r->msgclass); | |
905 e->event.msg.sender = fix32(r->sender); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
906 e->event.msg.message = strdup((char *)r + sizeof(*r)); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
907 e->event.msg.time = fix32(r->time); |
2393 | 908 } |
909 } | |
910 | |
911 if (h->type == GG_NOTIFY_REPLY) { | |
912 struct gg_notify_reply *n = p; | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
913 int count, i; |
2393 | 914 |
915 gg_debug(GG_DEBUG_MISC, "-- received a notify reply\n"); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
916 |
2393 | 917 e->type = GG_EVENT_NOTIFY; |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
918 if (!(e->event.notify = (void *)malloc(h->length + 2 * sizeof(*n)))) { |
2393 | 919 gg_debug(GG_DEBUG_MISC, "-- not enough memory\n"); |
920 free(h); | |
921 return -1; | |
922 } | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
923 count = h->length / sizeof(*n); |
2393 | 924 memcpy(e->event.notify, p, h->length); |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
925 e->event.notify[count].uin = 0; |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
926 for (i = 0; i < count; i++) { |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
927 e->event.notify[i].uin = fix32(e->event.notify[i].uin); |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
928 e->event.notify[i].status = fix32(e->event.notify[i].status); |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
929 } |
2393 | 930 } |
931 | |
932 if (h->type == GG_STATUS) { | |
933 struct gg_status *s = p; | |
934 | |
935 gg_debug(GG_DEBUG_MISC, "-- received a status change\n"); | |
936 | |
937 if (h->length >= sizeof(*s)) { | |
938 e->type = GG_EVENT_STATUS; | |
939 memcpy(&e->event.status, p, h->length); | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
940 e->event.status.uin = fix32(e->event.status.uin); |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
941 e->event.status.status = fix32(e->event.status.status); |
2393 | 942 } |
943 } | |
944 | |
945 if (h->type == GG_SEND_MSG_ACK) { | |
946 struct gg_send_msg_ack *s = p; | |
947 | |
948 gg_debug(GG_DEBUG_MISC, "-- received a message ack\n"); | |
949 | |
950 if (h->length >= sizeof(*s)) { | |
951 e->type = GG_EVENT_ACK; | |
952 e->event.ack.status = fix32(s->status); | |
953 e->event.ack.recipient = fix32(s->recipient); | |
954 e->event.ack.seq = fix32(s->seq); | |
955 } | |
956 } | |
957 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
958 if (h->type == GG_PONG) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
959 gg_debug(GG_DEBUG_MISC, "-- received a pong\n"); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
960 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
961 sess->last_pong = time(NULL); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
962 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
963 |
2393 | 964 free(h); |
965 | |
966 return 0; | |
967 } | |
968 | |
969 /* | |
970 * gg_chomp() // funkcja wewnętrzna | |
971 * | |
972 * ucina "\r\n" lub "\n" z końca linii. | |
973 * | |
974 * - line - ofiara operacji plastycznej. | |
975 * | |
976 * niczego nie zwraca. | |
977 */ | |
978 static void gg_chomp(char *line) | |
979 { | |
980 if (!line || strlen(line) < 1) | |
981 return; | |
982 | |
983 if (line[strlen(line) - 1] == '\n') | |
984 line[strlen(line) - 1] = 0; | |
985 if (line[strlen(line) - 1] == '\r') | |
986 line[strlen(line) - 1] = 0; | |
987 } | |
988 | |
989 /* | |
990 * gg_watch_fd() | |
991 * | |
992 * funkcja wywoływana, gdy coś się stanie na obserwowanym deskryptorze. | |
993 * zwraca klientowi informację o tym, co się dzieje. | |
994 * | |
995 * - sess - identyfikator sesji. | |
996 * | |
997 * zwraca wskaźnik do struktury gg_event, którą trzeba zwolnić później | |
998 * za pomocą gg_free_event(). jesli rodzaj zdarzenia jest równy | |
999 * GG_EVENT_NONE, należy je olać kompletnie. jeśli zwróciło NULL, | |
1000 * stało się coś niedobrego -- albo brakło pamięci albo zerwało | |
1001 * połączenie albo coś takiego. | |
1002 */ | |
1003 struct gg_event *gg_watch_fd(struct gg_session *sess) | |
1004 { | |
1005 struct gg_event *e; | |
1006 int res = 0; | |
1007 | |
1008 if (!sess) { | |
1009 errno = EFAULT; | |
1010 return NULL; | |
1011 } | |
1012 | |
1013 gg_debug(GG_DEBUG_FUNCTION, "** gg_watch_fd(...);\n"); | |
1014 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1015 if (!(e = (void *)malloc(sizeof(*e)))) { |
2393 | 1016 gg_debug(GG_DEBUG_MISC, "-- not enough memory\n"); |
1017 return NULL; | |
1018 } | |
1019 | |
1020 e->type = GG_EVENT_NONE; | |
1021 | |
1022 switch (sess->state) { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1023 case GG_STATE_RESOLVING: |
2393 | 1024 { |
1025 struct in_addr a; | |
1026 | |
1027 gg_debug(GG_DEBUG_MISC, "== GG_STATE_RESOLVING\n"); | |
1028 | |
1029 if (read(sess->fd, &a, sizeof(a)) < sizeof(a) || a.s_addr == INADDR_NONE) { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1030 gg_debug(GG_DEBUG_MISC, "-- resolving failed\n"); |
2393 | 1031 |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1032 errno = ENOENT; |
2393 | 1033 e->type = GG_EVENT_CONN_FAILED; |
1034 e->event.failure = GG_FAILURE_RESOLVING; | |
1035 sess->state = GG_STATE_IDLE; | |
1036 | |
1037 close(sess->fd); | |
1038 | |
1039 break; | |
1040 } | |
1041 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1042 sess->server_ip = a.s_addr; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1043 |
2393 | 1044 close(sess->fd); |
1045 | |
1046 waitpid(sess->pid, NULL, 0); | |
1047 | |
1048 gg_debug(GG_DEBUG_MISC, "-- resolved, now connecting\n"); | |
1049 | |
1050 if ((sess->fd = gg_connect(&a, GG_APPMSG_PORT, sess->async)) == -1) { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1051 struct in_addr *addr = (struct in_addr *)&sess->server_ip; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1052 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1053 gg_debug(GG_DEBUG_MISC, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1054 "-- connection failed, trying direct connection\n"); |
2393 | 1055 |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1056 if ((sess->fd = gg_connect(addr, GG_DEFAULT_PORT, sess->async)) == -1) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1057 gg_debug(GG_DEBUG_MISC, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1058 "-- connection failed, trying https connection\n"); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1059 if ((sess->fd = |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1060 gg_connect(&a, GG_HTTPS_PORT, sess->async)) == -1) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1061 gg_debug(GG_DEBUG_MISC, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1062 "-- connect() failed. errno = %d (%s)\n", errno, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1063 strerror(errno)); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1064 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1065 e->type = GG_EVENT_CONN_FAILED; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1066 e->event.failure = GG_FAILURE_CONNECTING; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1067 sess->state = GG_STATE_IDLE; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1068 break; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1069 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1070 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1071 sess->state = GG_STATE_CONNECTING_GG; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1072 sess->check = GG_CHECK_WRITE; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1073 } else { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1074 sess->state = GG_STATE_CONNECTING_HTTP; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1075 sess->check = GG_CHECK_WRITE; |
2393 | 1076 } |
1077 | |
1078 break; | |
1079 } | |
1080 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1081 case GG_STATE_CONNECTING_HTTP: |
2393 | 1082 { |
1083 char buf[1024]; | |
1084 int res, res_size = sizeof(res); | |
1085 | |
1086 gg_debug(GG_DEBUG_MISC, "== GG_STATE_CONNECTING_HTTP\n"); | |
1087 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1088 if (sess->async |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1089 && (getsockopt(sess->fd, SOL_SOCKET, SO_ERROR, &res, &res_size) || res)) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1090 struct in_addr *addr = (struct in_addr *)&sess->server_ip; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1091 gg_debug(GG_DEBUG_MISC, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1092 "-- http connection failed, errno = %d (%s), trying direct connection\n", |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1093 res, strerror(res)); |
2393 | 1094 |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1095 if ((sess->fd = gg_connect(addr, GG_DEFAULT_PORT, sess->async)) == -1) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1096 gg_debug(GG_DEBUG_MISC, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1097 "-- connection failed, trying https connection\n"); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1098 if ((sess->fd = |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1099 gg_connect(addr, GG_HTTPS_PORT, sess->async)) == -1) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1100 gg_debug(GG_DEBUG_MISC, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1101 "-- connect() failed. errno = %d (%s)\n", errno, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1102 strerror(errno)); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1103 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1104 e->type = GG_EVENT_CONN_FAILED; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1105 e->event.failure = GG_FAILURE_CONNECTING; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1106 sess->state = GG_STATE_IDLE; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1107 break; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1108 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1109 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1110 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1111 sess->state = GG_STATE_CONNECTING_GG; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1112 sess->check = GG_CHECK_WRITE; |
2393 | 1113 break; |
1114 } | |
1115 | |
1116 gg_debug(GG_DEBUG_MISC, "-- http connection succeded, sending query\n"); | |
1117 | |
1118 snprintf(buf, sizeof(buf) - 1, | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1119 "GET /appsvc/appmsg.asp?fmnumber=%lu HTTP/1.0\r\n" |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1120 "Host: " GG_APPMSG_HOST "\r\n" |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1121 "User-Agent: " GG_HTTP_USERAGENT "\r\n" |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1122 "Pragma: no-cache\r\n" "\r\n", sess->uin); |
2393 | 1123 |
1124 if (write(sess->fd, buf, strlen(buf)) < strlen(buf)) { | |
1125 gg_debug(GG_DEBUG_MISC, "-- sending query failed\n"); | |
1126 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1127 errno = EIO; |
2393 | 1128 e->type = GG_EVENT_CONN_FAILED; |
1129 e->event.failure = GG_FAILURE_WRITING; | |
1130 sess->state = GG_STATE_IDLE; | |
1131 break; | |
1132 } | |
1133 | |
1134 sess->state = GG_STATE_WRITING_HTTP; | |
1135 sess->check = GG_CHECK_READ; | |
1136 | |
1137 break; | |
1138 } | |
1139 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1140 case GG_STATE_WRITING_HTTP: |
2393 | 1141 { |
1142 char buf[1024], *tmp, *host; | |
1143 int port = GG_DEFAULT_PORT; | |
1144 struct in_addr a; | |
1145 | |
1146 gg_debug(GG_DEBUG_MISC, "== GG_STATE_WRITING_HTTP\n"); | |
1147 | |
1148 gg_read_line(sess->fd, buf, sizeof(buf) - 1); | |
1149 gg_chomp(buf); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1150 |
2393 | 1151 gg_debug(GG_DEBUG_TRAFFIC, "-- got http response (%s)\n", buf); |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1152 |
2393 | 1153 if (strncmp(buf, "HTTP/1.", 7) || strncmp(buf + 9, "200", 3)) { |
1154 gg_debug(GG_DEBUG_MISC, "-- but that's not what we've expected\n"); | |
1155 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1156 errno = EINVAL; |
2393 | 1157 e->type = GG_EVENT_CONN_FAILED; |
1158 e->event.failure = GG_FAILURE_INVALID; | |
1159 sess->state = GG_STATE_IDLE; | |
1160 break; | |
1161 } | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1162 |
2393 | 1163 while (strcmp(buf, "\r\n") && strcmp(buf, "")) |
1164 gg_read_line(sess->fd, buf, sizeof(buf) - 1); | |
1165 | |
1166 gg_read_line(sess->fd, buf, sizeof(buf) - 1); | |
1167 gg_chomp(buf); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1168 |
2393 | 1169 close(sess->fd); |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1170 |
2393 | 1171 gg_debug(GG_DEBUG_TRAFFIC, "-- received http data (%s)\n", buf); |
1172 | |
1173 tmp = buf; | |
1174 while (*tmp && *tmp != ' ') | |
1175 tmp++; | |
1176 while (*tmp && *tmp == ' ') | |
1177 tmp++; | |
1178 while (*tmp && *tmp != ' ') | |
1179 tmp++; | |
1180 while (*tmp && *tmp == ' ') | |
1181 tmp++; | |
1182 while (*tmp && *tmp != ' ') | |
1183 tmp++; | |
1184 while (*tmp && *tmp == ' ') | |
1185 tmp++; | |
1186 host = tmp; | |
1187 while (*tmp && *tmp != ' ') | |
1188 tmp++; | |
1189 *tmp = 0; | |
1190 | |
1191 if ((tmp = strchr(host, ':'))) { | |
1192 *tmp = 0; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1193 port = atoi(tmp + 1); |
2393 | 1194 } |
1195 | |
1196 a.s_addr = inet_addr(host); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1197 sess->server_ip = a.s_addr; |
2393 | 1198 |
1199 if ((sess->fd = gg_connect(&a, port, sess->async)) == -1) { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1200 gg_debug(GG_DEBUG_MISC, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1201 "-- connection failed, trying https connection\n"); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1202 if ((sess->fd = gg_connect(&a, GG_HTTPS_PORT, sess->async)) == -1) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1203 gg_debug(GG_DEBUG_MISC, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1204 "-- connection failed, errno = %d (%s)\n", errno, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1205 strerror(errno)); |
2393 | 1206 |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1207 e->type = GG_EVENT_CONN_FAILED; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1208 e->event.failure = GG_FAILURE_CONNECTING; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1209 sess->state = GG_STATE_IDLE; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1210 break; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1211 } |
2393 | 1212 } |
1213 | |
1214 sess->state = GG_STATE_CONNECTING_GG; | |
1215 sess->check = GG_CHECK_WRITE; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1216 |
2393 | 1217 break; |
1218 } | |
1219 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1220 case GG_STATE_CONNECTING_GG: |
2393 | 1221 { |
1222 int res, res_size = sizeof(res); | |
1223 | |
1224 gg_debug(GG_DEBUG_MISC, "== GG_STATE_CONNECTING_GG\n"); | |
1225 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1226 if (sess->async |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1227 && (getsockopt(sess->fd, SOL_SOCKET, SO_ERROR, &res, &res_size) || res)) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1228 struct in_addr *addr = (struct in_addr *)&sess->server_ip; |
2393 | 1229 |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1230 gg_debug(GG_DEBUG_MISC, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1231 "-- connection failed, trying https connection\n"); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1232 if ((sess->fd = gg_connect(addr, GG_HTTPS_PORT, sess->async)) == -1) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1233 gg_debug(GG_DEBUG_MISC, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1234 "-- connection failed, errno = %d (%s)\n", errno, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1235 strerror(errno)); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1236 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1237 e->type = GG_EVENT_CONN_FAILED; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1238 e->event.failure = GG_FAILURE_CONNECTING; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1239 sess->state = GG_STATE_IDLE; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1240 break; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1241 } |
2393 | 1242 } |
1243 | |
1244 gg_debug(GG_DEBUG_MISC, "-- connected\n"); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1245 |
2393 | 1246 sess->state = GG_STATE_WAITING_FOR_KEY; |
1247 sess->check = GG_CHECK_READ; | |
1248 | |
1249 break; | |
1250 } | |
1251 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1252 case GG_STATE_WAITING_FOR_KEY: |
2393 | 1253 { |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1254 struct gg_header *h; |
2393 | 1255 struct gg_welcome *w; |
1256 struct gg_login l; | |
1257 unsigned int hash; | |
1258 char *password = sess->password; | |
1259 | |
1260 gg_debug(GG_DEBUG_MISC, "== GG_STATE_WAITING_FOR_KEY\n"); | |
1261 | |
1262 if (!(h = gg_recv_packet(sess))) { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1263 gg_debug(GG_DEBUG_MISC, "-- gg_recv_packet() failed. errno = %d (%s)\n", |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1264 errno, strerror(errno)); |
2393 | 1265 |
1266 e->type = GG_EVENT_CONN_FAILED; | |
1267 e->event.failure = GG_FAILURE_READING; | |
1268 sess->state = GG_STATE_IDLE; | |
1269 close(sess->fd); | |
1270 break; | |
1271 } | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1272 |
2393 | 1273 if (h->type != GG_WELCOME) { |
1274 gg_debug(GG_DEBUG_MISC, "-- invalid packet received\n"); | |
1275 | |
1276 free(h); | |
1277 close(sess->fd); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1278 errno = EINVAL; |
2393 | 1279 e->type = GG_EVENT_CONN_FAILED; |
1280 e->event.failure = GG_FAILURE_INVALID; | |
1281 sess->state = GG_STATE_IDLE; | |
1282 break; | |
1283 } | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1284 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1285 w = (void *)h + sizeof(struct gg_header); |
2393 | 1286 w->key = fix32(w->key); |
1287 | |
1288 for (hash = 1; *password; password++) | |
1289 hash *= (*password) + 1; | |
1290 hash *= w->key; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1291 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1292 gg_debug(GG_DEBUG_DUMP, "%%%% klucz serwera %.4x, hash hasła %.8x\n", w->key, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1293 hash); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1294 |
2393 | 1295 free(h); |
1296 | |
1297 free(sess->password); | |
1298 sess->password = NULL; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1299 |
2393 | 1300 l.uin = fix32(sess->uin); |
1301 l.hash = fix32(hash); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1302 l.status = fix32(sess->initial_status ? sess->initial_status : GG_STATUS_AVAIL); |
2393 | 1303 l.dunno = fix32(0x0b); |
1304 l.local_ip = 0; | |
1305 l.local_port = 0; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1306 |
2393 | 1307 gg_debug(GG_DEBUG_TRAFFIC, "-- sending GG_LOGIN packet\n"); |
1308 | |
1309 if (gg_send_packet(sess->fd, GG_LOGIN, &l, sizeof(l), NULL, 0) == -1) { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1310 gg_debug(GG_DEBUG_TRAFFIC, "-- oops, failed. errno = %d (%s)\n", errno, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1311 strerror(errno)); |
2393 | 1312 |
1313 close(sess->fd); | |
1314 e->type = GG_EVENT_CONN_FAILED; | |
1315 e->event.failure = GG_FAILURE_WRITING; | |
1316 sess->state = GG_STATE_IDLE; | |
1317 break; | |
1318 } | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1319 |
2393 | 1320 sess->state = GG_STATE_SENDING_KEY; |
1321 | |
1322 break; | |
1323 } | |
1324 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1325 case GG_STATE_SENDING_KEY: |
2393 | 1326 { |
1327 struct gg_header *h; | |
1328 | |
1329 gg_debug(GG_DEBUG_MISC, "== GG_STATE_SENDING_KEY\n"); | |
1330 | |
1331 if (!(h = gg_recv_packet(sess))) { | |
1332 gg_debug(GG_DEBUG_MISC, "-- recv_packet failed\n"); | |
1333 e->type = GG_EVENT_CONN_FAILED; | |
1334 e->event.failure = GG_FAILURE_READING; | |
1335 sess->state = GG_STATE_IDLE; | |
1336 close(sess->fd); | |
1337 break; | |
1338 } | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1339 |
2393 | 1340 if (h->type == GG_LOGIN_OK) { |
1341 gg_debug(GG_DEBUG_MISC, "-- login succeded\n"); | |
1342 e->type = GG_EVENT_CONN_SUCCESS; | |
1343 sess->state = GG_STATE_CONNECTED; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1344 free(h); |
2393 | 1345 break; |
1346 } | |
1347 | |
1348 if (h->type == GG_LOGIN_FAILED) { | |
1349 gg_debug(GG_DEBUG_MISC, "-- login failed\n"); | |
1350 e->event.failure = GG_FAILURE_PASSWORD; | |
1351 errno = EACCES; | |
1352 } else { | |
1353 gg_debug(GG_DEBUG_MISC, "-- invalid packet\n"); | |
1354 e->event.failure = GG_FAILURE_INVALID; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1355 errno = EINVAL; |
2393 | 1356 } |
1357 | |
1358 e->type = GG_EVENT_CONN_FAILED; | |
1359 sess->state = GG_STATE_IDLE; | |
1360 close(sess->fd); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1361 free(h); |
2393 | 1362 |
1363 break; | |
1364 } | |
1365 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1366 case GG_STATE_CONNECTED: |
2393 | 1367 { |
1368 gg_debug(GG_DEBUG_MISC, "== GG_STATE_CONNECTED\n"); | |
1369 | |
1370 if ((res = gg_watch_fd_connected(sess, e)) == -1) { | |
1371 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1372 gg_debug(GG_DEBUG_MISC, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1373 "-- watch_fd_connected failed. errno = %d (%s)\n", errno, |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1374 strerror(errno)); |
2393 | 1375 |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1376 if (errno == EAGAIN) { |
2393 | 1377 e->type = GG_EVENT_NONE; |
1378 res = 0; | |
1379 } else | |
1380 res = -1; | |
1381 } | |
1382 break; | |
1383 } | |
1384 } | |
1385 | |
1386 if (res == -1) { | |
1387 free(e); | |
1388 e = NULL; | |
1389 } | |
1390 | |
1391 return e; | |
1392 } |