ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/socket/image.C
Revision: 1.45
Committed: Thu Jul 5 10:34:08 2007 UTC (16 years, 11 months ago) by root
Content type: text/plain
Branch: MAIN
Changes since 1.44: +6 -0 lines
Log Message:
- fix rate limiting _again_ (and this time it was an infamous
  unsigned comparison bug...)
- send images strictly in order. this is a bit ugly but temporarily works
  around older cfplus clients not supporting interleaved transfers.

File Contents

# User Rev Content
1 elmex 1.1 /*
2 root 1.44 * This file is part of Crossfire TRT, the Roguelike Realtime MORPG.
3 root 1.42 *
4     * Copyright (©) 2005,2006,2007 Marc Alexander Lehmann / Robin Redeker / the Crossfire TRT team
5     * Copyright (©) 2001,2007 Mark Wedel
6     * Copyright (©) 1992,2007 Frank Tore Johansen
7     *
8 root 1.44 * Crossfire TRT is free software: you can redistribute it and/or modify
9     * it under the terms of the GNU General Public License as published by
10     * the Free Software Foundation, either version 3 of the License, or
11     * (at your option) any later version.
12 root 1.42 *
13 root 1.44 * This program is distributed in the hope that it will be useful,
14     * but WITHOUT ANY WARRANTY; without even the implied warranty of
15     * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16     * GNU General Public License for more details.
17 root 1.42 *
18 root 1.44 * You should have received a copy of the GNU General Public License
19     * along with this program. If not, see <http://www.gnu.org/licenses/>.
20 root 1.42 *
21     * The authors can be reached via e-mail to <crossfire@schmorp.de>
22 root 1.17 */
23 elmex 1.1
24     /** \file
25     * Image related communication
26     *
27     * \date 2003-12-02
28     *
29     * This file deals with the image related communication to the
30     * client. I've located all the functions in this file - this
31     * localizes it more, and means that we don't need to declare
32     * things like all the structures as globals.
33     */
34    
35     #include <global.h>
36     #include <sproto.h>
37    
38 root 1.20 #include "crc.h"
39    
40 elmex 1.1 #define MAX_FACE_SETS 20 /**< Maximum number of image sets the program will handle */
41    
42     /** Information about one image */
43 root 1.3 typedef struct FaceInfo
44     {
45     uint8 *data; /**< image data */
46     uint16 datalen; /**< length of the xpm data */
47     uint32 checksum; /**< Checksum of face data */
48 elmex 1.1 } FaceInfo;
49    
50     /** Information about one face set */
51 root 1.3 typedef struct
52     {
53     char *prefix; /**< */
54     char *fullname;
55    
56     uint8 fallback; /**< faceset to use when an image is not found in this faceset */
57     char *size;
58     char *extension;
59     char *comment;
60    
61     FaceInfo *faces; /**< images in this faceset */
62 elmex 1.1 } FaceSets;
63    
64     static FaceSets facesets[MAX_FACE_SETS]; /**< All facesets */
65    
66     /**
67     * Checks specified faceset is valid
68     * \param fsn faceset number
69     */
70 root 1.3 int
71     is_valid_faceset (int fsn)
72 elmex 1.1 {
73 root 1.3 if (fsn >= 0 && fsn < MAX_FACE_SETS && facesets[fsn].prefix)
74     return TRUE;
75     return FALSE;
76 elmex 1.1 }
77    
78     /**
79     * Frees all faceset information
80     */
81 root 1.3 void
82     free_socket_images (void)
83 elmex 1.1 {
84 root 1.3 int num, q;
85 elmex 1.1
86 root 1.3 for (num = 0; num < MAX_FACE_SETS; num++)
87     {
88     if (facesets[num].prefix)
89     {
90 root 1.24 for (q = 0; q < faces.size (); q++)
91 root 1.3 if (facesets[num].faces[q].data)
92     free (facesets[num].faces[q].data);
93 root 1.15
94 root 1.3 free (facesets[num].prefix);
95     free (facesets[num].fullname);
96     free (facesets[num].size);
97     free (facesets[num].extension);
98     free (facesets[num].comment);
99     free (facesets[num].faces);
100 root 1.2 }
101 elmex 1.1 }
102     }
103    
104     /**
105     * This returns the set we will actually use when sending
106     * a face. This is used because the image files may be sparse.
107     * This function is recursive. imageno is the face number we are
108     * trying to send
109     *
110     * If face is not found in specified faceset, tries with 'fallback' faceset.
111     *
112     * \param faceset faceset to check
113     * \param imageno image number
114     *
115     */
116 root 1.3 static int
117     get_face_fallback (int faceset, int imageno)
118 elmex 1.1 {
119 root 1.3 /* faceset 0 is supposed to have every image, so just return. Doing
120     * so also prevents infinite loops in the case if it not having
121     * the face, but in that case, we are likely to crash when we try
122     * to access the data, but that is probably preferable to an infinite
123     * loop.
124     */
125     if (faceset == 0)
126     return 0;
127    
128     if (!facesets[faceset].prefix)
129     {
130     LOG (llevError, "get_face_fallback called with unused set (%d)?\n", faceset);
131     return 0; /* use default set */
132     }
133 root 1.15
134 root 1.3 if (facesets[faceset].faces[imageno].data)
135     return faceset;
136 root 1.15
137 root 1.3 return get_face_fallback (facesets[faceset].fallback, imageno);
138 elmex 1.1 }
139    
140     /**
141     * Checks fallback are correctly defined.
142     * This is a simple recursive function that makes sure the fallbacks
143     * are all proper (eg, the fall back to defined sets, and also
144     * eventually fall back to 0). At the top level, togo is set to MAX_FACE_SETS,
145     * if togo gets to zero, it means we have a loop.
146     * This is only run when we first load the facesets.
147     */
148 root 1.3 static void
149     check_faceset_fallback (int faceset, int togo)
150 elmex 1.1 {
151 root 1.3 int fallback = facesets[faceset].fallback;
152 elmex 1.1
153 root 1.3 /* proper case - falls back to base set */
154     if (fallback == 0)
155     return;
156    
157     if (!facesets[fallback].prefix)
158     {
159     LOG (llevError, "Face set %d falls to non set faceset %d\n", faceset, fallback);
160     abort ();
161     }
162 root 1.15
163 root 1.3 togo--;
164     if (togo == 0)
165     {
166     LOG (llevError, "Infinite loop found in facesets. aborting.\n");
167     abort ();
168 elmex 1.1 }
169 root 1.15
170 root 1.3 check_faceset_fallback (fallback, togo);
171 elmex 1.1 }
172    
173     #define MAX_IMAGE_SIZE 10000
174    
175     /**
176     * Client tells us what type of faces it wants. Also sets
177     * the caching attribute.
178     *
179     */
180 root 1.3 void
181 root 1.13 SetFaceMode (char *buf, int len, client *ns)
182 elmex 1.1 {
183 root 1.3 int mask = (atoi (buf) & CF_FACE_CACHE), mode = (atoi (buf) & ~CF_FACE_CACHE);
184 elmex 1.1
185 root 1.3 if (mode == CF_FACE_NONE)
186 root 1.7 ns->facecache = 1;
187 root 1.3 else if (mode != CF_FACE_PNG)
188 root 1.14 ns->send_packet_printf ("drawinfo %d %s", NDI_RED, "Warning - send unsupported face mode. Will use Png");
189 root 1.7
190 root 1.3 if (mask)
191 root 1.7 ns->facecache = 1;
192 elmex 1.1 }
193    
194     /**
195 root 1.43 * client requested an image. send it rate-limited
196     * before flushing.
197 elmex 1.1 */
198 root 1.3 void
199 root 1.43 AskFaceCmd (char *buf, int len, client *ns)
200 elmex 1.1 {
201 root 1.43 int idx = 0, pri = 0;
202    
203     sscanf (buf, "%d %d", &idx, &pri);
204    
205     const facedata *d = face_data (idx, ns->faceset);
206    
207     if (!d)
208     return; // doh
209    
210     client::ixsend ix;
211    
212     ix.pri = pri;
213     ix.idx = idx;
214     ix.ofs = d->data.size ();
215    
216 root 1.45 // this is (hopefully) a temporary fix around older cfplus versions not
217     // supporting interleaved transfers
218     ns->ixface.insert (ns->ixface.begin (), ix);
219    
220     #if 0
221 root 1.43 // the by far most common case will be to insert
222     // right at the end, so no looping.
223     auto (i, ns->ixface.end ());
224     for (; i != ns->ixface.begin (); )
225     if (pri >= (--i)->pri)
226     break;
227    
228     ns->ixface.insert (i, ix);
229 root 1.45 #endif
230 root 1.43 }
231    
232     /**
233     * Tells client the picture it has to use
234     * to smooth a picture number given as argument.
235     */
236     void
237     AskSmooth (char *buf, int len, client *ns)
238     {
239     ns->send_face (atoi (buf));
240     ns->flush_fx ();
241 elmex 1.1 }
242    
243 root 1.24 // how lame
244     static void print_facename (packet &sl, const facedata &d)
245     {
246 root 1.25 for (int i = 0; i < CHKSUM_SIZE; ++i)
247     sl.printf ("%02x", d.chksum [i]);
248 root 1.24 }
249    
250 root 1.32 // gcfclient uses the server-provided checksum for comparison, but always
251     // writes a broken checksum to its cache file, so we have to provide
252     // gcfclient with the same broken (and useless) checksum just to have it
253     // cache the image despite its bugs.
254 root 1.26 static uint32 gcfclient_checksum (const facedata *d)
255     {
256     uint32 csum = 0;
257    
258     for (std::string::const_iterator i = d->data.begin ();
259     i != d->data.end ();
260     ++i)
261     {
262     csum = rotate_right (csum);
263     csum += *(uint8 *)&*i;
264     }
265    
266     return csum;
267     }
268    
269 elmex 1.1 /**
270     * Sends a face to a client if they are in pixmap mode
271     * nothing gets sent in bitmap mode.
272     * If nocache is true (nonzero), ignore the cache setting from the client -
273     * this is needed for the askface, in which we really do want to send the
274     * face (and askface is the only place that should be setting it). Otherwise,
275     * we look at the facecache, and if set, send the image name.
276     */
277 root 1.3 void
278 root 1.32 client::send_face (faceidx facenum)
279 elmex 1.1 {
280 root 1.28 // never send face 0. ever. it does not exist.
281     if (!facenum)
282     return;
283    
284     const facedata *d = face_data (facenum, faceset);
285    
286     if (!d)
287 root 1.3 {
288 root 1.28 LOG (llevError, "client::send_face (%d) out of bounds??\n", facenum);
289 root 1.3 return;
290     }
291    
292 root 1.32 if (faces_sent[facenum])
293     return;
294    
295     faces_sent[facenum] = true;
296    
297 root 1.38 // if for some reason we let a client without face caching connect,
298     // we better support that decision here and implement it.
299 root 1.33 if (!facecache)
300 root 1.38 return send_image (facenum);
301 root 1.33
302 root 1.39 if (fxix)
303     {
304     fxface.push_back (facenum);
305     return;
306     }
307    
308 root 1.8 packet sl;
309 root 1.3
310 root 1.32 if (force_face0)
311     sl << "face " << uint16 (facenum);
312     else if (image2)
313     sl << "face2 " << uint16 (facenum) << uint8 (0) << uint32 (force_bad_checksum ? gcfclient_checksum (d) : 0);
314     else
315     sl << "face1 " << uint16 (facenum) << uint32 (force_bad_checksum ? gcfclient_checksum (d) : 0);
316    
317     // how lame
318     print_facename (sl, *d);
319     send_packet (sl);
320    
321 root 1.40 if (EMI_smooth)
322 root 1.3 {
323 root 1.40 faceinfo *f = face_info (facenum);
324 root 1.28
325 root 1.40 if (f->smooth)
326     {
327     send_face (f->smooth);
328    
329     packet sl ("smooth");
330 root 1.30
331 root 1.40 sl << uint16 (facenum)
332     << uint16 (f->smooth);
333 root 1.31
334 root 1.40 send_packet (sl);
335     }
336 root 1.32 }
337     }
338    
339 root 1.39 void client::flush_fx ()
340     {
341     while (!fxface.empty ())
342     {
343 root 1.40 packet fx ("fx");
344     packet sx ("sx");
345 root 1.39
346     do
347     {
348     faceidx facenum = fxface.back (); fxface.pop_back ();
349    
350     const facedata *d = face_data (facenum, faceset);
351    
352     if (d)
353     {
354 root 1.40 fx << ber32 (facenum)
355 root 1.39 << data8 (d->chksum, CHKSUM_SIZE);
356    
357 root 1.40 if (smoothing)
358     {
359     faceinfo *f = face_info (facenum);
360    
361     if (f->smooth)
362     {
363     send_face (f->smooth);
364     sx << ber32 (facenum)
365     << ber32 (f->smooth)
366     << ber32 (f->smoothlevel);
367     }
368     }
369 root 1.39 }
370     }
371 root 1.40 while (!fxface.empty ()
372     && fx.room () > ber32::size + CHKSUM_SIZE + 1
373     && sx.room () > ber32::size * 3);
374 root 1.39
375 root 1.40 send_packet (fx);
376     if (sx.length () > 3) send_packet (sx);
377 root 1.39 }
378     }
379    
380 root 1.32 void
381     client::send_image (faceidx facenum)
382     {
383     // never send face 0. ever. it does not exist.
384     if (!facenum)
385     return;
386 root 1.31
387 root 1.32 const facedata *d = face_data (facenum, faceset);
388 root 1.30
389 root 1.43 faces_sent[facenum] = true;
390    
391 root 1.32 if (!d)
392     {
393     LOG (llevError, "client::send_image (%d) out of bounds??\n", facenum);
394     return;
395     }
396 root 1.43
397     //TODO: check type here?
398 root 1.34
399 root 1.36 if (force_image_newmap)
400     force_newmap = true;
401    
402 root 1.32 packet sl;
403 root 1.30
404 root 1.32 sl << (image2 ? "image2 " : "image ")
405     << uint32 (facenum);
406 root 1.6
407 root 1.32 if (image2)
408     sl << uint8 (0);
409 root 1.6
410 root 1.32 sl << uint32 (d->data.size ())
411     << data (d->data.data (), d->data.size ());
412 root 1.31
413 root 1.32 send_packet (sl);
414 root 1.28 }
415    
416     // send all faces of this object to the client
417     // this uses more bandwidth initially, but makes
418     // animations look much smoother, and every client
419     // is supposed to do client-side caching anyways.
420     void
421     client::send_faces (object *ob)
422     {
423     send_face (ob->face);
424    
425     if (ob->animation_id)
426     {
427     animation &anim = animations [ob->animation_id];
428    
429     for (int i = 0; i < anim.num_animations; i++)
430     send_face (anim.faces [i]);
431     }
432     }
433    
434     /**
435     * Need to send an animation sequence to the client.
436     * We will send appropriate face commands to the client if we haven't
437     * sent them the face yet (this can become quite costly in terms of
438     * how much we are sending - on the other hand, this should only happen
439     * when the player logs in and picks stuff up.
440     */
441     void
442     client::send_animation (short anim_num)
443     {
444     /* Do some checking on the anim_num we got. Note that the animations
445     * are added in contigous order, so if the number is in the valid
446     * range, it must be a valid animation.
447     */
448 root 1.41 if (anim_num < 0 || anim_num >= animations.size ())
449 root 1.28 {
450     LOG (llevError, "esrv_send_anim (%d) out of bounds??\n", anim_num);
451     return;
452     }
453    
454     packet sl ("anim");
455    
456     sl << uint16 (anim_num)
457     << uint16 (0); /* flags - not used right now */
458    
459     /* Build up the list of faces. Also, send any information (ie, the
460     * the face itself) down to the client.
461     */
462     for (int i = 0; i < animations[anim_num].num_animations; i++)
463     {
464     send_face (animations[anim_num].faces[i]);
465     sl << uint16 (animations[anim_num].faces[i]); /* flags - not used right now */
466 elmex 1.1 }
467 root 1.6
468 root 1.28 send_packet (sl);
469    
470     anims_sent[anim_num] = 1;
471 elmex 1.1 }
472    
473     /**
474     * Sends the number of images, checksum of the face file,
475     * and the image_info file information. See the doc/Developers/protocol
476     * if you want further detail.
477     */
478 root 1.3 void
479 root 1.15 send_image_info (client *ns, char *params)
480 elmex 1.1 {
481 root 1.8 packet sl;
482 elmex 1.1
483 root 1.24 //TODO: second parameter is a checksum, but it makes no sense in this current framework
484     sl.printf ("replyinfo image_info\n%d\n%u\n", MAX_FACES, 0);
485 root 1.6
486 root 1.24 sl << "0:base:standard:0:32x32:none:The old 32x32 faceset.\n";
487 elmex 1.1
488 root 1.11 ns->send_packet (sl);
489 elmex 1.1 }
490    
491     /**
492     * Sends requested face information.
493     * \param ns socket to send to
494     * \param params contains first and last index of face
495     *
496     * For each image in [start..stop] sends
497     * - checksum
498     * - name
499     */
500 root 1.3 void
501 root 1.15 send_image_sums (client *ns, char *params)
502 elmex 1.1 {
503 root 1.3 int start, stop;
504 pippijn 1.22 char *cp;
505 root 1.3
506 root 1.8 packet sl;
507 root 1.3
508     start = atoi (params);
509     for (cp = params; *cp != '\0'; cp++)
510     if (*cp == ' ')
511     break;
512    
513     stop = atoi (cp);
514 root 1.24 if (stop < start || *cp == '\0' || (stop - start) > 1000 || stop >= MAX_FACES)
515 root 1.3 {
516 root 1.7 sl.printf ("replyinfo image_sums %d %d", start, stop);
517     ns->send_packet (sl);
518     sl.reset ();
519 root 1.3 return;
520     }
521    
522 root 1.6 sl.printf ("replyinfo image_sums %d %d ", start, stop);
523 root 1.3
524 root 1.24 for (int i = start; i <= stop && i < faces.size (); i++)
525 root 1.3 {
526 root 1.30 ns->faces_sent[i] = true;
527 root 1.3
528 root 1.24 const facedata *d = face_data (i, ns->faceset);
529 root 1.6
530 root 1.24 if (sl.room () < 2 + 4 + 1 + d->data.size () + 1)
531 root 1.23 break;
532    
533 root 1.6 sl << uint16 (i)
534 root 1.24 << uint32 (0) // checksum
535     << uint8 (ns->faceset);
536    
537     print_facename (sl, *d); sl << uint8 (0);
538 root 1.3 }
539 root 1.6
540 root 1.3 /* It would make more sense to catch this pre-emptively in the code above.
541     * however, if this really happens, we probably just want to cut down the
542     * size to less than 1000, since that is what we claim the protocol would
543     * support.
544     */
545 root 1.23 //TODO: taken care of above, should simply abort or make sure the above code is correct
546 root 1.9 if (sl.length () >= MAXSOCKBUF)
547 root 1.3 {
548 root 1.9 LOG (llevError, "send_image_send: buffer overrun, %d > %d\n", sl.length (), MAXSOCKBUF);
549 root 1.3 abort ();
550 elmex 1.1 }
551 root 1.6
552 root 1.11 ns->send_packet (sl);
553 elmex 1.1 }
554 root 1.6