ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/socket/image.C
Revision: 1.47
Committed: Thu Jul 12 08:40:14 2007 UTC (16 years, 11 months ago) by root
Content type: text/plain
Branch: MAIN
Changes since 1.46: +1 -3 lines
Log Message:
first workable server-side music implementation

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.46 auto (pos, ns->ixface.end ());
217    
218     if (ns->fxix < 2)
219     {
220     // gcfclient does not support prioritising, older cfplus versions
221     // do not support interleaved transfers.
222     if (!ns->ixface.empty ())
223     pos = ns->ixface.end () - 1;
224     }
225     else
226     {
227     // the by far most common case will be to insert
228     // near the end, so little looping.
229     while (pos != ns->ixface.begin ())
230     {
231     --pos;
232    
233     // sort within 2k bins, to slightly prefer smaller images
234     if (pri > pos->pri || (pri == pos->pri && (ix.ofs >> 11) <= (pos->ofs >> 11)))
235     {
236     ++pos;
237     break;
238     }
239     }
240     }
241    
242     ns->ixface.insert (pos, ix);
243 root 1.45
244     #if 0
245 root 1.46 for (auto (i, ns->ixface.begin ()); i != ns->ixface.end (); ++i)
246     fprintf (stderr, "<%d,%d> ", i->pri, i->ofs);
247     fprintf (stderr, "\n");
248 root 1.45 #endif
249 root 1.43 }
250    
251     /**
252     * Tells client the picture it has to use
253     * to smooth a picture number given as argument.
254     */
255     void
256     AskSmooth (char *buf, int len, client *ns)
257     {
258     ns->send_face (atoi (buf));
259     ns->flush_fx ();
260 elmex 1.1 }
261    
262 root 1.24 // how lame
263     static void print_facename (packet &sl, const facedata &d)
264     {
265 root 1.25 for (int i = 0; i < CHKSUM_SIZE; ++i)
266     sl.printf ("%02x", d.chksum [i]);
267 root 1.24 }
268    
269 root 1.32 // gcfclient uses the server-provided checksum for comparison, but always
270     // writes a broken checksum to its cache file, so we have to provide
271     // gcfclient with the same broken (and useless) checksum just to have it
272     // cache the image despite its bugs.
273 root 1.26 static uint32 gcfclient_checksum (const facedata *d)
274     {
275     uint32 csum = 0;
276    
277     for (std::string::const_iterator i = d->data.begin ();
278     i != d->data.end ();
279     ++i)
280     {
281     csum = rotate_right (csum);
282     csum += *(uint8 *)&*i;
283     }
284    
285     return csum;
286     }
287    
288 elmex 1.1 /**
289     * Sends a face to a client if they are in pixmap mode
290     * nothing gets sent in bitmap mode.
291     * If nocache is true (nonzero), ignore the cache setting from the client -
292     * this is needed for the askface, in which we really do want to send the
293     * face (and askface is the only place that should be setting it). Otherwise,
294     * we look at the facecache, and if set, send the image name.
295     */
296 root 1.3 void
297 root 1.32 client::send_face (faceidx facenum)
298 elmex 1.1 {
299 root 1.28 // never send face 0. ever. it does not exist.
300     if (!facenum)
301     return;
302    
303     const facedata *d = face_data (facenum, faceset);
304    
305     if (!d)
306 root 1.3 {
307 root 1.28 LOG (llevError, "client::send_face (%d) out of bounds??\n", facenum);
308 root 1.3 return;
309     }
310    
311 root 1.47 if (!must_send_face (facenum))
312 root 1.32 return;
313    
314 root 1.38 // if for some reason we let a client without face caching connect,
315     // we better support that decision here and implement it.
316 root 1.33 if (!facecache)
317 root 1.38 return send_image (facenum);
318 root 1.33
319 root 1.39 if (fxix)
320     {
321     fxface.push_back (facenum);
322     return;
323     }
324    
325 root 1.8 packet sl;
326 root 1.3
327 root 1.32 if (force_face0)
328     sl << "face " << uint16 (facenum);
329     else if (image2)
330     sl << "face2 " << uint16 (facenum) << uint8 (0) << uint32 (force_bad_checksum ? gcfclient_checksum (d) : 0);
331     else
332     sl << "face1 " << uint16 (facenum) << uint32 (force_bad_checksum ? gcfclient_checksum (d) : 0);
333    
334     // how lame
335     print_facename (sl, *d);
336     send_packet (sl);
337    
338 root 1.40 if (EMI_smooth)
339 root 1.3 {
340 root 1.40 faceinfo *f = face_info (facenum);
341 root 1.28
342 root 1.40 if (f->smooth)
343     {
344     send_face (f->smooth);
345    
346     packet sl ("smooth");
347 root 1.30
348 root 1.40 sl << uint16 (facenum)
349     << uint16 (f->smooth);
350 root 1.31
351 root 1.40 send_packet (sl);
352     }
353 root 1.32 }
354     }
355    
356 root 1.39 void client::flush_fx ()
357     {
358     while (!fxface.empty ())
359     {
360 root 1.40 packet fx ("fx");
361     packet sx ("sx");
362 root 1.39
363     do
364     {
365     faceidx facenum = fxface.back (); fxface.pop_back ();
366    
367     const facedata *d = face_data (facenum, faceset);
368    
369     if (d)
370     {
371 root 1.40 fx << ber32 (facenum)
372 root 1.39 << data8 (d->chksum, CHKSUM_SIZE);
373    
374 root 1.40 if (smoothing)
375     {
376     faceinfo *f = face_info (facenum);
377    
378     if (f->smooth)
379     {
380     send_face (f->smooth);
381     sx << ber32 (facenum)
382     << ber32 (f->smooth)
383     << ber32 (f->smoothlevel);
384     }
385     }
386 root 1.39 }
387     }
388 root 1.40 while (!fxface.empty ()
389     && fx.room () > ber32::size + CHKSUM_SIZE + 1
390     && sx.room () > ber32::size * 3);
391 root 1.39
392 root 1.40 send_packet (fx);
393     if (sx.length () > 3) send_packet (sx);
394 root 1.39 }
395     }
396    
397 root 1.32 void
398     client::send_image (faceidx facenum)
399     {
400     // never send face 0. ever. it does not exist.
401     if (!facenum)
402     return;
403 root 1.31
404 root 1.32 const facedata *d = face_data (facenum, faceset);
405 root 1.30
406 root 1.43 faces_sent[facenum] = true;
407    
408 root 1.32 if (!d)
409     {
410     LOG (llevError, "client::send_image (%d) out of bounds??\n", facenum);
411     return;
412     }
413 root 1.43
414     //TODO: check type here?
415 root 1.34
416 root 1.36 if (force_image_newmap)
417     force_newmap = true;
418    
419 root 1.32 packet sl;
420 root 1.30
421 root 1.32 sl << (image2 ? "image2 " : "image ")
422     << uint32 (facenum);
423 root 1.6
424 root 1.32 if (image2)
425     sl << uint8 (0);
426 root 1.6
427 root 1.32 sl << uint32 (d->data.size ())
428     << data (d->data.data (), d->data.size ());
429 root 1.31
430 root 1.32 send_packet (sl);
431 root 1.28 }
432    
433     // send all faces of this object to the client
434     // this uses more bandwidth initially, but makes
435     // animations look much smoother, and every client
436     // is supposed to do client-side caching anyways.
437     void
438     client::send_faces (object *ob)
439     {
440     send_face (ob->face);
441    
442     if (ob->animation_id)
443     {
444     animation &anim = animations [ob->animation_id];
445    
446     for (int i = 0; i < anim.num_animations; i++)
447     send_face (anim.faces [i]);
448     }
449     }
450    
451     /**
452     * Need to send an animation sequence to the client.
453     * We will send appropriate face commands to the client if we haven't
454     * sent them the face yet (this can become quite costly in terms of
455     * how much we are sending - on the other hand, this should only happen
456     * when the player logs in and picks stuff up.
457     */
458     void
459     client::send_animation (short anim_num)
460     {
461     /* Do some checking on the anim_num we got. Note that the animations
462     * are added in contigous order, so if the number is in the valid
463     * range, it must be a valid animation.
464     */
465 root 1.41 if (anim_num < 0 || anim_num >= animations.size ())
466 root 1.28 {
467     LOG (llevError, "esrv_send_anim (%d) out of bounds??\n", anim_num);
468     return;
469     }
470    
471     packet sl ("anim");
472    
473     sl << uint16 (anim_num)
474     << uint16 (0); /* flags - not used right now */
475    
476     /* Build up the list of faces. Also, send any information (ie, the
477     * the face itself) down to the client.
478     */
479     for (int i = 0; i < animations[anim_num].num_animations; i++)
480     {
481     send_face (animations[anim_num].faces[i]);
482     sl << uint16 (animations[anim_num].faces[i]); /* flags - not used right now */
483 elmex 1.1 }
484 root 1.6
485 root 1.28 send_packet (sl);
486    
487     anims_sent[anim_num] = 1;
488 elmex 1.1 }
489    
490     /**
491     * Sends the number of images, checksum of the face file,
492     * and the image_info file information. See the doc/Developers/protocol
493     * if you want further detail.
494     */
495 root 1.3 void
496 root 1.15 send_image_info (client *ns, char *params)
497 elmex 1.1 {
498 root 1.8 packet sl;
499 elmex 1.1
500 root 1.24 //TODO: second parameter is a checksum, but it makes no sense in this current framework
501     sl.printf ("replyinfo image_info\n%d\n%u\n", MAX_FACES, 0);
502 root 1.6
503 root 1.24 sl << "0:base:standard:0:32x32:none:The old 32x32 faceset.\n";
504 elmex 1.1
505 root 1.11 ns->send_packet (sl);
506 elmex 1.1 }
507    
508     /**
509     * Sends requested face information.
510     * \param ns socket to send to
511     * \param params contains first and last index of face
512     *
513     * For each image in [start..stop] sends
514     * - checksum
515     * - name
516     */
517 root 1.3 void
518 root 1.15 send_image_sums (client *ns, char *params)
519 elmex 1.1 {
520 root 1.3 int start, stop;
521 pippijn 1.22 char *cp;
522 root 1.3
523 root 1.8 packet sl;
524 root 1.3
525     start = atoi (params);
526     for (cp = params; *cp != '\0'; cp++)
527     if (*cp == ' ')
528     break;
529    
530     stop = atoi (cp);
531 root 1.24 if (stop < start || *cp == '\0' || (stop - start) > 1000 || stop >= MAX_FACES)
532 root 1.3 {
533 root 1.7 sl.printf ("replyinfo image_sums %d %d", start, stop);
534     ns->send_packet (sl);
535     sl.reset ();
536 root 1.3 return;
537     }
538    
539 root 1.6 sl.printf ("replyinfo image_sums %d %d ", start, stop);
540 root 1.3
541 root 1.24 for (int i = start; i <= stop && i < faces.size (); i++)
542 root 1.3 {
543 root 1.30 ns->faces_sent[i] = true;
544 root 1.3
545 root 1.24 const facedata *d = face_data (i, ns->faceset);
546 root 1.6
547 root 1.24 if (sl.room () < 2 + 4 + 1 + d->data.size () + 1)
548 root 1.23 break;
549    
550 root 1.6 sl << uint16 (i)
551 root 1.24 << uint32 (0) // checksum
552     << uint8 (ns->faceset);
553    
554     print_facename (sl, *d); sl << uint8 (0);
555 root 1.3 }
556 root 1.6
557 root 1.3 /* It would make more sense to catch this pre-emptively in the code above.
558     * however, if this really happens, we probably just want to cut down the
559     * size to less than 1000, since that is what we claim the protocol would
560     * support.
561     */
562 root 1.23 //TODO: taken care of above, should simply abort or make sure the above code is correct
563 root 1.9 if (sl.length () >= MAXSOCKBUF)
564 root 1.3 {
565 root 1.9 LOG (llevError, "send_image_send: buffer overrun, %d > %d\n", sl.length (), MAXSOCKBUF);
566 root 1.3 abort ();
567 elmex 1.1 }
568 root 1.6
569 root 1.11 ns->send_packet (sl);
570 elmex 1.1 }
571 root 1.6