#include <sys_defs.h>
#include <unistd.h>
#include <msg.h>
#include <mymalloc.h>
#include <stringops.h>
#include <dict.h>
#include <dict_dbm.h>
#include <myflock.h>
#include "mkmap.h"
#ifdef HAS_DBM
#ifdef PATH_NDBM_H
#include PATH_NDBM_H
#else
#include <ndbm.h>
#endif
typedef struct MKMAP_DBM {
MKMAP mkmap;
char *lock_file;
int lock_fd;
} MKMAP_DBM;
static void mkmap_dbm_after_close(MKMAP *mp)
{
MKMAP_DBM *mkmap = (MKMAP_DBM *) mp;
if (mkmap->lock_fd >= 0 && close(mkmap->lock_fd) < 0)
msg_warn("close %s: %m", mkmap->lock_file);
myfree(mkmap->lock_file);
}
MKMAP *mkmap_dbm_open(const char *path)
{
MKMAP_DBM *mkmap = (MKMAP_DBM *) mymalloc(sizeof(*mkmap));
char *pag_file;
int pag_fd;
mkmap->lock_file = concatenate(path, ".dir", (char *) 0);
mkmap->mkmap.open = dict_dbm_open;
mkmap->mkmap.after_open = 0;
mkmap->mkmap.after_close = mkmap_dbm_after_close;
if ((mkmap->lock_fd = open(mkmap->lock_file, O_CREAT | O_RDWR, 0644)) < 0)
msg_fatal("open %s: %m", mkmap->lock_file);
pag_file = concatenate(path, ".pag", (char *) 0);
if ((pag_fd = open(pag_file, O_CREAT | O_RDWR, 0644)) < 0)
msg_fatal("open %s: %m", pag_file);
if (close(pag_fd))
msg_warn("close %s: %m", pag_file);
myfree(pag_file);
if (myflock(mkmap->lock_fd, INTERNAL_LOCK, MYFLOCK_OP_EXCLUSIVE) < 0)
msg_fatal("lock %s: %m", mkmap->lock_file);
return (&mkmap->mkmap);
}
#endif