Mercurial > pidgin
annotate libfaim/aim_rxqueue.c @ 829:9a123b171f46
[gaim-migrate @ 839]
yay. i have a secret. but basically this should fix most outstanding libfaim issues in gaim.
committer: Tailor Script <tailor@pidgin.im>
author | Eric Warmenhoven <eric@warmenhoven.org> |
---|---|
date | Sat, 02 Sep 2000 02:41:57 +0000 |
parents | 6e318907bcce |
children | 88f8f98de02d |
rev | line source |
---|---|
2 | 1 /* |
237 | 2 * aim_rxqueue.c |
3 * | |
4 * This file contains the management routines for the receive | |
5 * (incoming packet) queue. The actual packet handlers are in | |
6 * aim_rxhandlers.c. | |
2 | 7 */ |
8 | |
283
0f14e6d8a51b
[gaim-migrate @ 293]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
279
diff
changeset
|
9 #include <faim/aim.h> |
2 | 10 |
11 /* | |
237 | 12 * Grab a single command sequence off the socket, and enqueue |
13 * it in the incoming event queue in a seperate struct. | |
14 */ | |
15 int aim_get_command(struct aim_session_t *sess, struct aim_conn_t *conn) | |
2 | 16 { |
445
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
17 unsigned char generic[6]; |
237 | 18 struct command_rx_struct *newrx = NULL; |
2 | 19 |
237 | 20 if (!sess || !conn) |
21 return 0; | |
2 | 22 |
237 | 23 if (conn->fd < 3) /* can happen when people abuse the interface */ |
24 return 0; | |
2 | 25 |
237 | 26 /* |
338
9d258a0aa560
[gaim-migrate @ 348]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
283
diff
changeset
|
27 * Rendezvous (client-client) connections do not speak |
9d258a0aa560
[gaim-migrate @ 348]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
283
diff
changeset
|
28 * FLAP, so this function will break on them. |
9d258a0aa560
[gaim-migrate @ 348]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
283
diff
changeset
|
29 */ |
445
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
30 if (conn->type == AIM_CONN_TYPE_RENDEZVOUS) |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
31 return aim_get_command_rendezvous(sess, conn); |
503
6e318907bcce
[gaim-migrate @ 513]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
445
diff
changeset
|
32 if (conn->type == AIM_CONN_TYPE_RENDEZVOUS_OUT) |
6e318907bcce
[gaim-migrate @ 513]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
445
diff
changeset
|
33 return 0; |
338
9d258a0aa560
[gaim-migrate @ 348]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
283
diff
changeset
|
34 |
9d258a0aa560
[gaim-migrate @ 348]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
283
diff
changeset
|
35 /* |
237 | 36 * Read FLAP header. Six bytes: |
37 * | |
38 * 0 char -- Always 0x2a | |
39 * 1 char -- Channel ID. Usually 2 -- 1 and 4 are used during login. | |
40 * 2 short -- Sequence number | |
41 * 4 short -- Number of data bytes that follow. | |
42 */ | |
279
501e09c51cbc
[gaim-migrate @ 289]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
237
diff
changeset
|
43 faim_mutex_lock(&conn->active); |
829
9a123b171f46
[gaim-migrate @ 839]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
503
diff
changeset
|
44 if (recv(conn->fd, generic, 6, MSG_WAITALL) < 6){ |
9a123b171f46
[gaim-migrate @ 839]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
503
diff
changeset
|
45 printf("faim: flap: read underflow (header)\n"); |
503
6e318907bcce
[gaim-migrate @ 513]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
445
diff
changeset
|
46 aim_conn_close(conn); |
279
501e09c51cbc
[gaim-migrate @ 289]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
237
diff
changeset
|
47 faim_mutex_unlock(&conn->active); |
237 | 48 return -1; |
49 } | |
2 | 50 |
237 | 51 /* |
52 * This shouldn't happen unless the socket breaks, the server breaks, | |
53 * or we break. We must handle it just in case. | |
54 */ | |
55 if (generic[0] != 0x2a) { | |
56 faimdprintf(1, "Bad incoming data!"); | |
503
6e318907bcce
[gaim-migrate @ 513]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
445
diff
changeset
|
57 aim_conn_close(conn); |
445
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
58 faim_mutex_unlock(&conn->active); |
237 | 59 return -1; |
60 } | |
2 | 61 |
62 /* allocate a new struct */ | |
445
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
63 if (!(newrx = (struct command_rx_struct *)malloc(sizeof(struct command_rx_struct)))) { |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
64 faim_mutex_unlock(&conn->active); |
237 | 65 return -1; |
445
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
66 } |
237 | 67 memset(newrx, 0x00, sizeof(struct command_rx_struct)); |
2 | 68 |
237 | 69 newrx->lock = 1; /* lock the struct */ |
70 | |
445
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
71 /* we're doing OSCAR if we're here */ |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
72 newrx->hdrtype = AIM_FRAMETYPE_OSCAR; |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
73 |
237 | 74 /* store channel -- byte 2 */ |
445
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
75 newrx->hdr.oscar.type = (char) generic[1]; |
2 | 76 |
77 /* store seqnum -- bytes 3 and 4 */ | |
445
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
78 newrx->hdr.oscar.seqnum = aimutil_get16(generic+2); |
2 | 79 |
80 /* store commandlen -- bytes 5 and 6 */ | |
237 | 81 newrx->commandlen = aimutil_get16(generic+4); |
82 | |
83 newrx->nofree = 0; /* free by default */ | |
2 | 84 |
85 /* malloc for data portion */ | |
445
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
86 if (!(newrx->data = (u_char *) malloc(newrx->commandlen))) { |
237 | 87 free(newrx); |
445
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
88 faim_mutex_unlock(&conn->active); |
237 | 89 return -1; |
90 } | |
2 | 91 |
92 /* read the data portion of the packet */ | |
829
9a123b171f46
[gaim-migrate @ 839]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
503
diff
changeset
|
93 if (recv(conn->fd, newrx->data, newrx->commandlen, MSG_WAITALL) < newrx->commandlen){ |
9a123b171f46
[gaim-migrate @ 839]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
503
diff
changeset
|
94 printf("faim: flap: read underflow (payload)\n"); |
237 | 95 free(newrx->data); |
96 free(newrx); | |
503
6e318907bcce
[gaim-migrate @ 513]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
445
diff
changeset
|
97 aim_conn_close(conn); |
279
501e09c51cbc
[gaim-migrate @ 289]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
237
diff
changeset
|
98 faim_mutex_unlock(&conn->active); |
237 | 99 return -1; |
100 } | |
279
501e09c51cbc
[gaim-migrate @ 289]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
237
diff
changeset
|
101 faim_mutex_unlock(&conn->active); |
2 | 102 |
237 | 103 newrx->conn = conn; |
2 | 104 |
237 | 105 newrx->next = NULL; /* this will always be at the bottom */ |
106 newrx->lock = 0; /* unlock */ | |
2 | 107 |
108 /* enqueue this packet */ | |
237 | 109 if (sess->queue_incoming == NULL) { |
110 sess->queue_incoming = newrx; | |
111 } else { | |
112 struct command_rx_struct *cur; | |
113 | |
114 /* | |
115 * This append operation takes a while. It might be faster | |
116 * if we maintain a pointer to the last entry in the queue | |
117 * and just update that. Need to determine if the overhead | |
118 * to maintain that is lower than the overhead for this loop. | |
119 */ | |
120 for (cur = sess->queue_incoming; cur->next; cur = cur->next) | |
121 ; | |
122 cur->next = newrx; | |
123 } | |
124 | |
125 newrx->conn->lastactivity = time(NULL); | |
2 | 126 |
127 return 0; | |
128 } | |
129 | |
130 /* | |
237 | 131 * Purge recieve queue of all handled commands (->handled==1). Also |
132 * allows for selective freeing using ->nofree so that the client can | |
133 * keep the data for various purposes. | |
134 * | |
135 * If ->nofree is nonzero, the frame will be delinked from the global list, | |
136 * but will not be free'ed. The client _must_ keep a pointer to the | |
137 * data -- libfaim will not! If the client marks ->nofree but | |
138 * does not keep a pointer, it's lost forever. | |
139 * | |
2 | 140 */ |
237 | 141 void aim_purge_rxqueue(struct aim_session_t *sess) |
2 | 142 { |
237 | 143 struct command_rx_struct *cur = NULL; |
144 struct command_rx_struct *tmp; | |
2 | 145 |
237 | 146 if (sess->queue_incoming == NULL) |
147 return; | |
148 | |
149 if (sess->queue_incoming->next == NULL) { | |
150 if (sess->queue_incoming->handled) { | |
151 tmp = sess->queue_incoming; | |
152 sess->queue_incoming = NULL; | |
153 | |
154 if (!tmp->nofree) { | |
445
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
155 if (tmp->hdrtype == AIM_FRAMETYPE_OFT) |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
156 free(tmp->hdr.oft.hdr2); |
237 | 157 free(tmp->data); |
158 free(tmp); | |
159 } else | |
160 tmp->next = NULL; | |
2 | 161 } |
237 | 162 return; |
163 } | |
2 | 164 |
237 | 165 for(cur = sess->queue_incoming; cur->next != NULL; ) { |
166 if (cur->next->handled) { | |
167 tmp = cur->next; | |
168 cur->next = tmp->next; | |
169 if (!tmp->nofree) { | |
445
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
170 if (tmp->hdrtype == AIM_FRAMETYPE_OFT) |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
171 free(tmp->hdr.oft.hdr2); |
237 | 172 free(tmp->data); |
173 free(tmp); | |
174 } else | |
175 tmp->next = NULL; | |
176 } | |
177 cur = cur->next; | |
2 | 178 |
237 | 179 /* |
180 * Be careful here. Because of the way we just | |
181 * manipulated the pointer, cur may be NULL and | |
182 * the for() will segfault doing the check unless | |
183 * we find this case first. | |
184 */ | |
185 if (cur == NULL) | |
186 break; | |
187 } | |
188 | |
189 return; | |
2 | 190 } |
445
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
191 |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
192 /* |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
193 * Since aim_get_command will aim_conn_kill dead connections, we need |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
194 * to clean up the rxqueue of unprocessed connections on that socket. |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
195 * |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
196 * XXX: this is something that was handled better in the old connection |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
197 * handling method, but eh. |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
198 */ |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
199 void aim_rxqueue_cleanbyconn(struct aim_session_t *sess, struct aim_conn_t *conn) |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
200 { |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
201 struct command_rx_struct *currx; |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
202 |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
203 for (currx = sess->queue_incoming; currx; currx = currx->next) { |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
204 if ((!currx->handled) && (currx->conn == conn)) |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
205 currx->handled = 1; |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
206 } |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
207 return; |
e4c34ca88d9b
[gaim-migrate @ 455]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
338
diff
changeset
|
208 } |