extern void ef_zapcache(int);
extern int ef_nelem(int);
extern int ef_flags(int);
-extern int ef_lock(int);
-extern int ef_unlock(int);
extern int ef_vars(int, register s_char *, u_char **,
u_char **, u_short **);
extern int ef_byname(s_char *);
extern double multread(natid, natid);
extern int commread(void);
extern int commwrite(void);
-extern int commlock(void);
-extern int communlock(void);
extern int commamt(natid, int, float *);
extern void commset(natid, int, int);
extern void multset(natid, float);
#if !defined(_WIN32)
extern s_char *inet_ntoa(struct in_addr);
#endif
-extern int file_lock(int);
-extern int file_unlock(int);
extern int diffx(int, int);
extern int diffy(int, int);
extern int deltax(int, int);
putloan(ni.cur, &loan);
}
/* clean up commodity and trade for this nation. */
- commlock();
commread();
for (n = 1; n < I_MAX + 1; n++) {
val = commamt(player->cnum, n, &dummy);
commset(player->cnum, n, -val);
}
commwrite();
- communlock();
snxtitem_all(&ni, EF_TRADE);
while (nxtitem(&ni, (s_char *)&trade)) {
if (trade.trd_unitid >= 0 && trade.trd_owner == player->cnum) {
price = minmult;
if (price >= maxmult)
price = maxmult;
- if (!commlock()) {
- pr("Unable to lock commodity file; get help!\n");
- return;
- }
if (commread() < 0) {
- (void)communlock();
pr("Unable to re-read commodity file; get help!\n");
return;
}
if (commwrite() < 0) {
pr("Unable to write out commodity file; get help!\n");
}
- (void)communlock();
}
}
if ((price = atoi(p)) < 0)
continue;
- if (!ef_lock(EF_TRADE)) {
- logerror("can't lock trade file");
- return RET_SYS;
- }
foundslot = -1;
freeslot = -1;
snxtitem_all(&ni_trade, EF_TRADE);
trade_nameof(&trade, &item), ni.cur,
id, foundslot >= 0 ? "reset" : "set", price);
}
- ef_unlock(EF_TRADE);
}
return RET_OK;
}
return empfile[type].flags;
}
-int
-ef_lock(int type)
-{
- return file_lock(empfile[type].fd);
-}
-
-int
-ef_unlock(int type)
-{
- return file_unlock(empfile[type].fd);
-}
-
time_t
ef_mtime(int type)
{
OBJS = atoip.o chance.o copy.o disassoc.o dtable.o \
emp_config.o getstarg.o getstring.o inet.o io.o \
- io_mask.o ioqueue.o lock.o mapdist.o minmax.o numstr.o onearg.o \
+ io_mask.o ioqueue.o mapdist.o minmax.o numstr.o onearg.o \
parse.o plur.o queue.o round.o scthash.o \
strdup.o
NTOBJS = atoip.obj chance.obj copy.obj disassoc.obj dtable.obj \
emp_config.obj getstarg.obj getstring.obj \
- inet.obj io.obj io_mask.obj ioqueue.obj lock.obj mapdist.obj minmax.obj \
+ inet.obj io.obj io_mask.obj ioqueue.obj mapdist.obj minmax.obj \
numstr.obj onearg.obj parse.obj plur.obj queue.obj round.obj \
scthash.obj strdup.obj
+++ /dev/null
-/*
- * Empire - A multi-player, client/server Internet based war game.
- * Copyright (C) 1986-2000, 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 the "LEGAL", "LICENSE", "CREDITS" and "README" files for all the
- * related information and legal notices. It is expected that any future
- * projects/authors will amend these files as needed.
- *
- * ---
- *
- * lock.c: Lock a file
- *
- * Known contributors to this file:
- * Doug Hay, 1998
- */
-
-#ifdef aix
-#define L_SET 0
-#endif /* aix */
-
-#include "misc.h"
-#include "gen.h"
-#include "common.h"
-#include <fcntl.h>
-
-#ifdef sys5
-#include <unistd.h>
-#endif
-#if !defined(L_SET) && !defined(_WIN32)
-#include <sys/file.h>
-#endif
-
-#ifdef aix
-#define L_SET 0
-#endif /* aix */
-
-#if defined(_WIN32)
-#include <sys/locking.h>
-
-int
-file_lock(int fd)
-{
- if (_locking(fd, _LK_LOCK, 0) < 0) {
- logerror("file lock (fd %d) failed", fd);
- return 0;
- }
- return 1;
-}
-
-int
-file_unlock(int fd)
-{
- if (_locking(fd, _LK_UNLCK, 0) < 0) {
- logerror("file lock (fd %d) failed", fd);
- return 0;
- }
- return 1;
-}
-
-#else
-
-#ifndef NOFLOCK
-
-int flock();
-
-int
-file_lock(int fd)
-{
- if (flock(fd, LOCK_EX) < 0) {
- logerror("file lock (fd %d) failed", fd);
- return 0;
- }
- return 1;
-}
-
-int
-file_unlock(int fd)
-{
- if (flock(fd, LOCK_UN) < 0) {
- logerror("file unlock (fd %d) failed", fd);
- return 0;
- }
- return 1;
-}
-
-#else
-
-int
-file_lock(int fd)
-{
- struct flock lock;
-
- lock.l_type = F_WRLCK;
- lock.l_whence = L_SET;
- lock.l_start = 0;
- lock.l_len = 0;
- lock.l_pid = 0;
- if (fcntl(fd, F_SETLKW, &lock) < 0) {
- logerror("file lock (fd %d) failed", fd);
- return 0;
- }
- return 1;
-}
-
-int
-file_unlock(int fd)
-{
- struct flock lock;
-
- lock.l_type = F_UNLCK;
- lock.l_whence = L_SET;
- lock.l_start = 0;
- lock.l_len = 0;
- lock.l_pid = 0;
- if (fcntl(fd, F_SETLKW, &lock) < 0) {
- logerror("file unlock (fd %d) failed", fd);
- return 0;
- }
- return 1;
-}
-#endif
-
-#endif /* _WIN32 */
return 0;
}
-int
-commlock(void)
-{
- return file_lock(commf);
-}
-
-int
-communlock(void)
-{
- return file_unlock(commf);
-}
-
/*
* returns amount of commodity, and price to the user
*/
return 0;
(void)time(&now);
if (now > tp->trt_exp) {
- if (!ef_lock(EF_TREATY)) {
- pr("Can't lock treaty file; get help!\n");
- return 0;
- }
tp->trt_status = TS_FREE;
if (!puttre(n, tp)) {
pr("Couldn't save treaty; get help!\n");
- (void)ef_unlock(EF_TREATY);
return 0;
}
- (void)ef_unlock(EF_TREATY);
pr("Treaty #%d expired %s", n, ctime(&tp->trt_exp));
return 0;
}