ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/socket/image.C
Revision: 1.11
Committed: Thu Dec 14 20:39:54 2006 UTC (17 years, 5 months ago) by root
Content type: text/plain
Branch: MAIN
Changes since 1.10: +4 -4 lines
Log Message:
- implement c++ interface to Event->io watchers
- cut number of write()'s the server does in half

File Contents

# User Rev Content
1 elmex 1.1 /*
2     CrossFire, A Multiplayer game for X-windows
3    
4     Copyright (C) 2001 Mark Wedel
5     Copyright (C) 1992 Frank Tore Johansen
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 as published by
9     the Free Software Foundation; either version 2 of the License, or
10     (at your option) any later version.
11    
12     This program is distributed in the hope that it will be useful,
13     but WITHOUT ANY WARRANTY; without even the implied warranty of
14     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15     GNU General Public License for more details.
16    
17     You should have received a copy of the GNU General Public License
18     along with this program; if not, write to the Free Software
19     Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
20    
21 root 1.4 The author can be reached via e-mail to <crossfire@schmorp.de>
22 elmex 1.1 */
23    
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     #include <newclient.h>
39     #include <newserver.h>
40     #include <loader.h>
41    
42     #define MAX_FACE_SETS 20 /**< Maximum number of image sets the program will handle */
43    
44     /** Information about one image */
45 root 1.3 typedef struct FaceInfo
46     {
47    
48     uint8 *data; /**< image data */
49    
50     uint16 datalen; /**< length of the xpm data */
51    
52     uint32 checksum; /**< Checksum of face data */
53 elmex 1.1 } FaceInfo;
54    
55     /** Information about one face set */
56 root 1.3 typedef struct
57     {
58    
59     char *prefix; /**< */
60     char *fullname;
61    
62     uint8 fallback; /**< faceset to use when an image is not found in this faceset */
63     char *size;
64     char *extension;
65     char *comment;
66    
67     FaceInfo *faces; /**< images in this faceset */
68 elmex 1.1 } FaceSets;
69    
70     static FaceSets facesets[MAX_FACE_SETS]; /**< All facesets */
71    
72     /**
73     * Checks specified faceset is valid
74     * \param fsn faceset number
75     */
76 root 1.3 int
77     is_valid_faceset (int fsn)
78 elmex 1.1 {
79 root 1.3 if (fsn >= 0 && fsn < MAX_FACE_SETS && facesets[fsn].prefix)
80     return TRUE;
81     return FALSE;
82 elmex 1.1 }
83    
84     /**
85     * Frees all faceset information
86     */
87 root 1.3 void
88     free_socket_images (void)
89 elmex 1.1 {
90 root 1.3 int num, q;
91 elmex 1.1
92 root 1.3 for (num = 0; num < MAX_FACE_SETS; num++)
93     {
94     if (facesets[num].prefix)
95     {
96     for (q = 0; q < nrofpixmaps; q++)
97     if (facesets[num].faces[q].data)
98     free (facesets[num].faces[q].data);
99     free (facesets[num].prefix);
100     free (facesets[num].fullname);
101     free (facesets[num].size);
102     free (facesets[num].extension);
103     free (facesets[num].comment);
104     free (facesets[num].faces);
105 root 1.2 }
106 elmex 1.1 }
107     }
108    
109     /**
110     * This returns the set we will actually use when sending
111     * a face. This is used because the image files may be sparse.
112     * This function is recursive. imageno is the face number we are
113     * trying to send
114     *
115     * If face is not found in specified faceset, tries with 'fallback' faceset.
116     *
117     * \param faceset faceset to check
118     * \param imageno image number
119     *
120     */
121 root 1.3 static int
122     get_face_fallback (int faceset, int imageno)
123 elmex 1.1 {
124 root 1.3 /* faceset 0 is supposed to have every image, so just return. Doing
125     * so also prevents infinite loops in the case if it not having
126     * the face, but in that case, we are likely to crash when we try
127     * to access the data, but that is probably preferable to an infinite
128     * loop.
129     */
130     if (faceset == 0)
131     return 0;
132    
133     if (!facesets[faceset].prefix)
134     {
135     LOG (llevError, "get_face_fallback called with unused set (%d)?\n", faceset);
136     return 0; /* use default set */
137     }
138     if (facesets[faceset].faces[imageno].data)
139     return faceset;
140     return get_face_fallback (facesets[faceset].fallback, imageno);
141 elmex 1.1 }
142    
143     /**
144     * Checks fallback are correctly defined.
145     * This is a simple recursive function that makes sure the fallbacks
146     * are all proper (eg, the fall back to defined sets, and also
147     * eventually fall back to 0). At the top level, togo is set to MAX_FACE_SETS,
148     * if togo gets to zero, it means we have a loop.
149     * This is only run when we first load the facesets.
150     */
151 root 1.3 static void
152     check_faceset_fallback (int faceset, int togo)
153 elmex 1.1 {
154 root 1.3 int fallback = facesets[faceset].fallback;
155 elmex 1.1
156 root 1.3 /* proper case - falls back to base set */
157     if (fallback == 0)
158     return;
159    
160     if (!facesets[fallback].prefix)
161     {
162     LOG (llevError, "Face set %d falls to non set faceset %d\n", faceset, fallback);
163     abort ();
164     }
165     togo--;
166     if (togo == 0)
167     {
168     LOG (llevError, "Infinite loop found in facesets. aborting.\n");
169     abort ();
170 elmex 1.1 }
171 root 1.3 check_faceset_fallback (fallback, togo);
172 elmex 1.1 }
173    
174     #define MAX_IMAGE_SIZE 10000
175    
176     /**
177     * Loads all the image types into memory.
178     *
179     * This way, we can easily send them to the client. We should really do something
180     * better than abort on any errors - on the other hand, these are all fatal
181     * to the server (can't work around them), but the abort just seems a bit
182     * messy (exit would probably be better.)
183     *
184     * Couple of notes: We assume that the faces are in a continous block.
185     * This works fine for now, but this could perhaps change in the future
186     *
187     * Function largely rewritten May 2000 to be more general purpose.
188     * The server itself does not care what the image data is - to the server,
189     * it is just data it needs to allocate. As such, the code is written
190     * to do such.
191     */
192    
193 root 1.3 void
194     read_client_images (void)
195 elmex 1.1 {
196 root 1.3 char filename[400];
197     char buf[HUGE_BUF];
198     char *cp, *cps[7];
199     FILE *infile;
200     int num, len, compressed, fileno, i, badline;
201    
202     memset (facesets, 0, sizeof (facesets));
203     sprintf (filename, "%s/image_info", settings.datadir);
204     if ((infile = open_and_uncompress (filename, 0, &compressed)) == NULL)
205     {
206     LOG (llevError, "Unable to open %s\n", filename);
207     abort ();
208     }
209     while (fgets (buf, HUGE_BUF - 1, infile) != NULL)
210     {
211     badline = 0;
212    
213     if (buf[0] == '#')
214     continue;
215     if (!(cps[0] = strtok (buf, ":")))
216     badline = 1;
217     for (i = 1; i < 7; i++)
218     {
219     if (!(cps[i] = strtok (NULL, ":")))
220     badline = 1;
221     }
222     if (badline)
223     {
224     LOG (llevError, "Bad line in image_info file, ignoring line:\n %s", buf);
225 root 1.2 }
226 root 1.3 else
227     {
228     len = atoi (cps[0]);
229     if (len >= MAX_FACE_SETS)
230     {
231     LOG (llevError, "To high a setnum in image_info file: %d > %d\n", len, MAX_FACE_SETS);
232     abort ();
233 root 1.2 }
234 root 1.3 facesets[len].prefix = strdup_local (cps[1]);
235     facesets[len].fullname = strdup_local (cps[2]);
236     facesets[len].fallback = atoi (cps[3]);
237     facesets[len].size = strdup_local (cps[4]);
238     facesets[len].extension = strdup_local (cps[5]);
239     facesets[len].comment = strdup_local (cps[6]);
240 root 1.2 }
241 elmex 1.1 }
242 root 1.3 close_and_delete (infile, compressed);
243     for (i = 0; i < MAX_FACE_SETS; i++)
244     {
245     if (facesets[i].prefix)
246     check_faceset_fallback (i, MAX_FACE_SETS);
247     }
248     /* Loaded the faceset information - now need to load up the
249     * actual faces.
250     */
251    
252     for (fileno = 0; fileno < MAX_FACE_SETS; fileno++)
253     {
254     /* if prefix is not set, this is not used */
255     if (!facesets[fileno].prefix)
256     continue;
257     facesets[fileno].faces = (FaceInfo *) calloc (nrofpixmaps, sizeof (FaceInfo));
258    
259     sprintf (filename, "%s/crossfire.%d", settings.datadir, fileno);
260     LOG (llevDebug, "Loading image file %s\n", filename);
261    
262     if ((infile = open_and_uncompress (filename, 0, &compressed)) == NULL)
263     {
264     LOG (llevError, "Unable to open %s\n", filename);
265     abort ();
266 root 1.2 }
267 root 1.3 while (fgets (buf, HUGE_BUF - 1, infile) != NULL)
268     {
269     if (strncmp (buf, "IMAGE ", 6) != 0)
270     {
271     LOG (llevError, "read_client_images:Bad image line - not IMAGE, instead\n%s", buf);
272     abort ();
273 root 1.2 }
274 root 1.3 num = atoi (buf + 6);
275     if (num < 0 || num >= nrofpixmaps)
276     {
277     LOG (llevError, "read_client_images: Image num %d not in 0..%d\n%s", num, nrofpixmaps, buf);
278     abort ();
279 root 1.2 }
280 root 1.3 /* Skip accross the number data */
281     for (cp = buf + 6; *cp != ' '; cp++);
282     len = atoi (cp);
283     if (len == 0 || len > MAX_IMAGE_SIZE)
284     {
285     LOG (llevError, "read_client_images: length not valid: %d > %d \n%s", len, MAX_IMAGE_SIZE, buf);
286     abort ();
287 root 1.2 }
288 root 1.5 /* We don't actualy care about the name of the image that
289 root 1.3 * is embedded in the image file, so just ignore it.
290     */
291     facesets[fileno].faces[num].datalen = len;
292     facesets[fileno].faces[num].data = (uint8 *) malloc (len);
293     if ((i = fread (facesets[fileno].faces[num].data, len, 1, infile)) != 1)
294     {
295     LOG (llevError, "read_client_images: Did not read desired amount of data, wanted %d, got %d\n%s", len, i, buf);
296     abort ();
297 root 1.2 }
298 root 1.3 facesets[fileno].faces[num].checksum = 0;
299     for (i = 0; i < len; i++)
300     {
301     ROTATE_RIGHT (facesets[fileno].faces[num].checksum);
302     facesets[fileno].faces[num].checksum += facesets[fileno].faces[num].data[i];
303     facesets[fileno].faces[num].checksum &= 0xffffffff;
304 root 1.2 }
305     }
306 root 1.3 close_and_delete (infile, compressed);
307     } /* For fileno < MAX_FACE_SETS */
308 elmex 1.1 }
309    
310     /**
311     * Client tells us what type of faces it wants. Also sets
312     * the caching attribute.
313     *
314     */
315    
316 root 1.3 void
317 root 1.10 SetFaceMode (char *buf, int len, client_socket *ns)
318 elmex 1.1 {
319 root 1.3 int mask = (atoi (buf) & CF_FACE_CACHE), mode = (atoi (buf) & ~CF_FACE_CACHE);
320 elmex 1.1
321 root 1.3 if (mode == CF_FACE_NONE)
322 root 1.7 ns->facecache = 1;
323 root 1.3 else if (mode != CF_FACE_PNG)
324     {
325 root 1.8 packet sl;
326 root 1.7 sl.printf ("drawinfo %d %s", NDI_RED, "Warning - send unsupported face mode. Will use Png");
327     ns->send_packet (sl);
328 elmex 1.1 }
329 root 1.7
330 root 1.3 if (mask)
331 root 1.7 ns->facecache = 1;
332 elmex 1.1 }
333    
334     /**
335     * Client has requested pixmap that it somehow missed getting.
336     * This will be called often if the client is
337     * caching images.
338     */
339    
340 root 1.3 void
341 root 1.10 SendFaceCmd (char *buff, int len, client_socket * ns)
342 elmex 1.1 {
343 root 1.3 long tmpnum = atoi (buff);
344     short facenum = tmpnum & 0xffff;
345 elmex 1.1
346 root 1.3 if (facenum != 0)
347     esrv_send_face (ns, facenum, 1);
348 elmex 1.1 }
349    
350     /**
351     * Sends a face to a client if they are in pixmap mode
352     * nothing gets sent in bitmap mode.
353     * If nocache is true (nonzero), ignore the cache setting from the client -
354     * this is needed for the askface, in which we really do want to send the
355     * face (and askface is the only place that should be setting it). Otherwise,
356     * we look at the facecache, and if set, send the image name.
357     */
358    
359 root 1.3 void
360 root 1.10 esrv_send_face (client_socket *ns, short face_num, int nocache)
361 elmex 1.1 {
362 root 1.3 char fallback;
363 elmex 1.1
364 root 1.3 if (face_num <= 0 || face_num >= nrofpixmaps)
365     {
366     LOG (llevError, "esrv_send_face (%d) out of bounds??\n", face_num);
367     return;
368     }
369    
370 root 1.8 packet sl;
371 root 1.3 fallback = get_face_fallback (ns->faceset, face_num);
372    
373     if (facesets[fallback].faces[face_num].data == NULL)
374     {
375     LOG (llevError, "esrv_send_face: faces[%d].data == NULL\n", face_num);
376     return;
377     }
378    
379     if (ns->facecache && !nocache)
380     {
381 root 1.6 sl << (ns->image2 ? "face2 " : "face1 ")
382     << uint16 (face_num);
383    
384 root 1.3 if (ns->image2)
385 root 1.6 sl << uint8 (fallback);
386    
387     sl << uint32 (facesets[fallback].faces[face_num].checksum)
388     << new_faces[face_num].name;
389 root 1.3
390 root 1.11 ns->send_packet (sl);
391 root 1.3 }
392     else
393     {
394 root 1.6 sl << (ns->image2 ? "image2 " : "image ")
395     << uint32 (face_num);
396    
397 root 1.3 if (ns->image2)
398 root 1.6 sl << uint8 (fallback);
399    
400     sl << uint32 (facesets[fallback].faces[face_num].datalen)
401     << data (facesets[fallback].faces[face_num].data, facesets[fallback].faces[face_num].datalen);
402    
403 root 1.11 ns->send_packet (sl);
404 elmex 1.1 }
405 root 1.6
406 root 1.3 ns->faces_sent[face_num] |= NS_FACESENT_FACE;
407 elmex 1.1 }
408    
409     /**
410     * Sends the number of images, checksum of the face file,
411     * and the image_info file information. See the doc/Developers/protocol
412     * if you want further detail.
413     */
414    
415 root 1.3 void
416 root 1.10 send_image_info (client_socket * ns, char *params)
417 elmex 1.1 {
418 root 1.8 packet sl;
419 elmex 1.1
420 root 1.6 sl.printf ("replyinfo image_info\n%d\n%d\n", nrofpixmaps - 1, bmaps_checksum);
421    
422     for (int i = 0; i < MAX_FACE_SETS; i++)
423     if (facesets[i].prefix)
424     sl.printf ("%d:%s:%s:%d:%s:%s:%s",
425     i, facesets[i].prefix, facesets[i].fullname, facesets[i].fallback,
426     facesets[i].size, facesets[i].extension, facesets[i].comment);
427 elmex 1.1
428 root 1.11 ns->send_packet (sl);
429 elmex 1.1 }
430    
431     /**
432     * Sends requested face information.
433     * \param ns socket to send to
434     * \param params contains first and last index of face
435     *
436     * For each image in [start..stop] sends
437     * - checksum
438     * - name
439     */
440 root 1.3 void
441 root 1.10 send_image_sums (client_socket * ns, char *params)
442 elmex 1.1 {
443 root 1.3 int start, stop;
444     char *cp, buf[MAX_BUF];
445    
446 root 1.8 packet sl;
447 root 1.3
448     start = atoi (params);
449     for (cp = params; *cp != '\0'; cp++)
450     if (*cp == ' ')
451     break;
452    
453     stop = atoi (cp);
454     if (stop < start || *cp == '\0' || (stop - start) > 1000 || stop >= nrofpixmaps)
455     {
456 root 1.7 sl.printf ("replyinfo image_sums %d %d", start, stop);
457     ns->send_packet (sl);
458     sl.reset ();
459 root 1.3 return;
460     }
461    
462 root 1.6 sl.printf ("replyinfo image_sums %d %d ", start, stop);
463 root 1.3
464 root 1.6 for (int i = start; i <= stop; i++)
465 root 1.3 {
466     ns->faces_sent[i] |= NS_FACESENT_FACE;
467    
468 root 1.6 int qq = get_face_fallback (ns->faceset, i);
469    
470     sl << uint16 (i)
471     << uint32 (facesets[qq].faces[i].checksum)
472     << uint8 (qq)
473     << data8 (&new_faces[i].name, new_faces[i].name.length () + 1);
474 root 1.3 }
475 root 1.6
476 root 1.3 /* It would make more sense to catch this pre-emptively in the code above.
477     * however, if this really happens, we probably just want to cut down the
478     * size to less than 1000, since that is what we claim the protocol would
479     * support.
480     */
481 root 1.9 if (sl.length () >= MAXSOCKBUF)
482 root 1.3 {
483 root 1.9 LOG (llevError, "send_image_send: buffer overrun, %d > %d\n", sl.length (), MAXSOCKBUF);
484 root 1.3 abort ();
485 elmex 1.1 }
486 root 1.6
487 root 1.11 ns->send_packet (sl);
488 elmex 1.1 }
489 root 1.6