Expire lost items at the update instead of continuously

Replace thread DeleteItems running delete_lostitems() by simple
function delete_old_lostitems(), and call it from update_main().
This commit is contained in:
Markus Armbruster 2008-09-10 07:30:48 -04:00
parent b72fd20674
commit 7441e2499f
6 changed files with 21 additions and 71 deletions

View file

@ -58,5 +58,6 @@ struct loststr {
extern void lost_and_found(int, natid, natid, int, coord, coord); extern void lost_and_found(int, natid, natid, int, coord, coord);
extern void makelost(short, natid, short, coord, coord); extern void makelost(short, natid, short, coord, coord);
extern void makenotlost(short, natid, short, coord, coord); extern void makenotlost(short, natid, short, coord, coord);
extern void delete_old_lostitems(void);
#endif #endif

View file

@ -53,7 +53,6 @@ int run_hook(char *, char *);
int shutdown_initiate(int); int shutdown_initiate(int);
/* thread entry points */ /* thread entry points */
void delete_lostitems(void *);
void player_kill_idle(void *); void player_kill_idle(void *);
#endif #endif

View file

@ -36,6 +36,8 @@
#include "file.h" #include "file.h"
#include "lost.h" #include "lost.h"
#include "misc.h"
#include "optlist.h"
static int findlost(short, natid, short, coord, coord, int); static int findlost(short, natid, short, coord, coord, int);
@ -118,3 +120,20 @@ findlost(short type, natid owner, short id, coord x, coord y, int free)
return -1; return -1;
} }
void
delete_old_lostitems(void)
{
time_t expiry_time = time(NULL) - hours(lost_keep_hours);
struct loststr lost;
int i;
for (i = 0; getlost(i, &lost); i++) {
if (!lost.lost_owner)
continue;
if (lost.lost_timestamp >= expiry_time)
continue;
lost.lost_owner = 0;
putlost(i, &lost);
}
}

View file

@ -173,6 +173,7 @@ update_main(void)
unit_cargo_init(); unit_cargo_init();
delete_old_announcements(); delete_old_announcements();
delete_old_news(); delete_old_news();
delete_old_lostitems();
/* Clear all the telegram flags */ /* Clear all the telegram flags */
for (cn = 0; cn < MAXNOC; cn++) for (cn = 0; cn < MAXNOC; cn++)
clear_telegram_is_new(cn); clear_telegram_is_new(cn);

View file

@ -1,69 +0,0 @@
/*
* Empire - A multi-player, client/server Internet based war game.
* Copyright (C) 1986-2008, Dave Pare, Jeff Bailey, Thomas Ruschak,
* Ken Stevens, Steve McClure
*
* This program 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
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* 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
*
* ---
*
* See files README, COPYING and CREDITS in the root of the source
* tree for related information and legal notices. It is expected
* that future projects/authors will amend these files as needed.
*
* ---
*
* lostitem.c: This deletes the old lost items
*
* Known contributors to this file:
* Steve McClure, 1997
*/
#include <config.h>
#include "empthread.h"
#include "file.h"
#include "lost.h"
#include "optlist.h"
#include "server.h"
/*ARGSUSED*/
void
delete_lostitems(void *unused)
{
time_t now;
struct loststr lost;
int n;
int ncnt;
while (1) {
time(&now);
/* logerror("Deleting lost items at %s", ctime(&now));*/
ncnt = 0;
for (n = 0; getlost(n, &lost); n++) {
if (!lost.lost_owner)
continue;
if (lost.lost_timestamp > (now - hours(lost_keep_hours)))
continue;
lost.lost_owner = 0;
putlost(n, &lost);
ncnt++;
}
/* logerror("Deleted %d lost items", ncnt, ctime(&now));*/
now = now + 900; /* Every 15 minutes */
empth_sleep(now);
}
/*NOTREACHED*/
}

View file

@ -383,7 +383,6 @@ start_server(int flags)
empth_create(player_accept, 50 * 1024, flags, "AcceptPlayers", 0); empth_create(player_accept, 50 * 1024, flags, "AcceptPlayers", 0);
empth_create(player_kill_idle, 50 * 1024, flags, "KillIdle", 0); empth_create(player_kill_idle, 50 * 1024, flags, "KillIdle", 0);
empth_create(delete_lostitems, 50 * 1024, flags, "DeleteItems", 0);
market_init(); market_init();
update_init(); update_init();