Update copyright notice

[empserver] / src / lib / update / anno.c

diff --git a/src/lib/update/anno.c b/src/lib/update/anno.c
index a9244fdca610eea3d0a1ec3c4c4de498a3250e49..97ff74858cd39ca415c2e30cafd484870bf3b6bf 100644 (file)
--- a/src/lib/update/anno.c
+++ b/src/lib/update/anno.c
@@ -1,11 +1,11 @@
 /*
  *  Empire - A multi-player, client/server Internet based war game.
- *  Copyright (C) 1986-2006, Dave Pare, Jeff Bailey, Thomas Ruschak,
- *                           Ken Stevens, Steve McClure
+ *  Copyright (C) 1986-2015, Dave Pare, Jeff Bailey, Thomas Ruschak,
+ *                Ken Stevens, Steve McClure, Markus Armbruster
  *
- *  This program is free software; you can redistribute it and/or modify
+ *  Empire is free software: you can redistribute it and/or modify
  *  it under the terms of the GNU General Public License as published by
- *  the Free Software Foundation; either version 2 of the License, or
+ *  the Free Software Foundation, either version 3 of the License, or
  *  (at your option) any later version.
  *
  *  This program is distributed in the hope that it will be useful,
@@ -14,8 +14,7 @@
  *  GNU General Public License for more details.
  *
  *  You should have received a copy of the GNU General Public License
- *  along with this program; if not, write to the Free Software
- *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ *  along with this program.  If not, see <http://www.gnu.org/licenses/>.
  *
  *  ---
  *
@@ -26,30 +25,27 @@
  *  ---
  *
  *  anno.c: Delete announcements older than ANNO_KEEP_DAYS
- * 
+ *
  *  Known contributors to this file:
  *     Ken Stevens, 1995
  *     Doug Hay, 1998
  *     Steve McClure, 2000
- *     Ron Koenderink, 2004
+ *     Ron Koenderink, 2004-2006
+ *     Markus Armbruster, 2004-2010
  */
 
 #include <config.h>
 
-#include "misc.h"
-#include "tel.h"
-#include <fcntl.h>
+#if defined(_WIN32) && defined(__GNUC__)
+#include <io.h>
+#endif
 #include <stdio.h>
 #include <time.h>
-#if !defined(_WIN32)
-#include <unistd.h>
-#endif
+#include "tel.h"
 #include "update.h"
-#include "optlist.h"
-#include "common.h"
 
-static int copy_and_expire(FILE *annfp, FILE *tmpfp,
-                          char *tmp_filename, time_t expiry_time);
+static int copy_and_expire(FILE *, FILE *, char *, time_t);
+static int copy_sink(char *, size_t, void *);
 
 void
 delete_old_announcements(void)
@@ -74,8 +70,7 @@ delete_old_announcements(void)
     }
     sprintf(tmp_filename, "%s.tmp", annfil);
     if ((tmpfp = fopen(tmp_filename, "wb")) == NULL) {
-       logerror("can't open telegram file %s for writing",
-                tmp_filename);
+       logerror("can't open telegram file %s for writing", tmp_filename);
        if (fclose(annfp) != 0)
            logerror("can't close telegram file %s", annfil);
        return;
@@ -87,8 +82,7 @@ delete_old_announcements(void)
        copy_file = 0;
     }
     if (fclose(tmpfp) != 0) {
-       logerror("can't close temporary telegram file %s",
-                tmp_filename);
+       logerror("can't close temporary telegram file %s", tmp_filename);
        copy_file = 0;
     }
 #if defined(_WIN32)
@@ -103,6 +97,9 @@ delete_old_announcements(void)
        if (rename(tmp_filename, annfil) != 0)
            logerror("can't move temporary telegram file %s "
                     "to telegram file %s", tmp_filename, annfil);
+    } else {
+       if (remove(tmp_filename) < 0)
+           logerror("can't delete telegram file %s", tmp_filename);
     }
 }
 
@@ -111,33 +108,18 @@ copy_and_expire(FILE *annfp, FILE *tmpfp, char *tmp_filename,
                time_t expiry_time)
 {
     struct telstr tgm;
-    int writeit;
-    char message[MAXTELSIZE];  /* UTF-8 */
+    int res, writeit;
     int deleted = 0;
     int saved = 0;
     int first = 1;
 
-    while (fread(&tgm, sizeof(tgm), 1, annfp) == 1) {
-       writeit = 1;
-       if (tgm.tel_length < 0 || tgm.tel_length > MAXTELSIZE) {
-           logerror("bad telegram file header (length=%ld)",
-                    tgm.tel_length);
-           return 0;
-       }
-       if (tgm.tel_type < 0 || tgm.tel_type > TEL_LAST) {
-           logerror("bad telegram file header (type=%d)",
-                    tgm.tel_type);
-           return 0;
-       }
-
+    while ((res = tel_read_header(annfp, annfil, &tgm)) > 0) {
+       writeit = tgm.tel_date >= expiry_time;
        if (first) {
            first = 0;
-           if (tgm.tel_date >= expiry_time)
+           if (writeit)
                return 0;
        }
-       if (tgm.tel_date < expiry_time)
-           writeit = 0;
-
        if (writeit) {
            if (fwrite(&tgm, sizeof(tgm), 1, tmpfp) != 1) {
                logerror("error writing header to temporary "
@@ -147,22 +129,25 @@ copy_and_expire(FILE *annfp, FILE *tmpfp, char *tmp_filename,
            ++saved;
        } else
            ++deleted;
-       if (fread(message, sizeof(char), tgm.tel_length, annfp) !=
-           (size_t)tgm.tel_length) {
-           logerror("error reading body from telegram file %s",
-                    annfil);
+       res = tel_read_body(annfp, annfil, &tgm,
+                           writeit ? copy_sink : NULL, tmpfp);
+       if (res < 0)
            return 0;
-       }
-       if (writeit) {
-           if (fwrite(message, sizeof(char), tgm.tel_length, tmpfp) !=
-               (size_t)tgm.tel_length) {
-               logerror("error writing body to temporary telegram "
-                        "file %s", tmp_filename);
-               return 0;
-           }
-       }
     }
+
+    if (res < 0)
+       return 0;
     logerror("%d announcements deleted; %d announcements saved",
             deleted, saved);
     return 1;
 }
+
+static int
+copy_sink(char *chunk, size_t sz, void *fp)
+{
+    if (fwrite(chunk, 1, sz, fp) != sz) {
+       logerror("error writing to %s.tmp", annfil);
+       return -1;
+    }
+    return 0;
+}