1998-03-28 02:44:41 +00:00
|
|
|
/* -*- Mode: C; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*-
|
|
|
|
*
|
|
|
|
* The contents of this file are subject to the Netscape Public License
|
|
|
|
* Version 1.0 (the "NPL"); you may not use this file except in
|
|
|
|
* compliance with the NPL. You may obtain a copy of the NPL at
|
|
|
|
* http://www.mozilla.org/NPL/
|
|
|
|
*
|
|
|
|
* Software distributed under the NPL is distributed on an "AS IS" basis,
|
|
|
|
* WITHOUT WARRANTY OF ANY KIND, either express or implied. See the NPL
|
|
|
|
* for the specific language governing rights and limitations under the
|
|
|
|
* NPL.
|
|
|
|
*
|
|
|
|
* The Initial Developer of this code under the NPL is Netscape
|
|
|
|
* Communications Corporation. Portions created by Netscape are
|
|
|
|
* Copyright (C) 1998 Netscape Communications Corporation. All Rights
|
|
|
|
* Reserved.
|
|
|
|
*/
|
|
|
|
/*
|
|
|
|
movemail.c --- move mail between folders with file locking
|
|
|
|
Created: Spencer Murray <spence@netscape.com>, 15-Sep-95.
|
|
|
|
|
|
|
|
The GNU movemail source used to ship with Netscape binaries.
|
|
|
|
To avoid GPL license issues, the movemail source will be
|
|
|
|
shipped separately from the Mozilla source. -mcafee
|
|
|
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
#include <stdio.h>
|
|
|
|
*/
|
|
|
|
#include <sys/types.h>
|
|
|
|
#include <sys/stat.h>
|
|
|
|
#include <fcntl.h>
|
|
|
|
#include <unistd.h>
|
|
|
|
#include <errno.h>
|
|
|
|
#include <sys/wait.h>
|
|
|
|
|
|
|
|
#include "mozilla.h"
|
|
|
|
#include "xfe.h"
|
|
|
|
|
|
|
|
#include <sys/errno.h>
|
1998-08-25 19:44:12 +00:00
|
|
|
#if !defined(HAVE_SYSERRLIST)
|
1998-03-28 02:44:41 +00:00
|
|
|
extern char *sys_errlist[];
|
|
|
|
extern int sys_nerr;
|
|
|
|
#endif
|
|
|
|
|
|
|
|
/* for XP_GetString() */
|
|
|
|
#include <xpgetstr.h>
|
|
|
|
extern int XFE_CANT_MOVE_MAIL;
|
|
|
|
extern int XFE_CANT_GET_NEW_MAIL_LOCK_FILE_EXISTS;
|
|
|
|
extern int XFE_CANT_GET_NEW_MAIL_UNABLE_TO_CREATE_LOCK_FILE;
|
|
|
|
extern int XFE_CANT_GET_NEW_MAIL_SYSTEM_ERROR;
|
|
|
|
extern int XFE_CANT_MOVE_MAIL_UNABLE_TO_OPEN;
|
|
|
|
extern int XFE_CANT_MOVE_MAIL_UNABLE_TO_READ;
|
|
|
|
extern int XFE_CANT_MOVE_MAIL_UNABLE_TO_WRITE;
|
|
|
|
extern int XFE_THERE_WERE_PROBLEMS_MOVING_MAIL;
|
|
|
|
extern int XFE_THERE_WERE_PROBLEMS_MOVING_MAIL_EXIT_STATUS;
|
|
|
|
extern int XFE_THERE_WERE_PROBLEMS_CLEANING_UP;
|
|
|
|
extern int XFE_MOVEMAIL_FAILURE_SUFFIX;
|
|
|
|
extern int XFE_UNKNOWN_ERROR_CODE;
|
|
|
|
extern int XFE_MOVEMAIL_NO_MESSAGES;
|
|
|
|
extern int XFE_MOVEMAIL_CANT_DELETE_LOCK;
|
|
|
|
|
|
|
|
#define TMP_SUFFIX ".nslock"
|
|
|
|
#define LOCK_SUFFIX ".lock"
|
|
|
|
|
|
|
|
#define NAME_LEN 1024
|
|
|
|
|
|
|
|
#ifndef BUFSIZ
|
|
|
|
#define BUFSIZ 1024
|
|
|
|
#endif /* BUFSIZ */
|
|
|
|
|
|
|
|
static void
|
|
|
|
fe_movemail_perror(MWContext *context, const char *message)
|
|
|
|
{
|
|
|
|
int e = errno;
|
|
|
|
char *es = 0;
|
|
|
|
char *buf1 = 0;
|
|
|
|
char buf2[512];
|
|
|
|
char *suffix;
|
|
|
|
int L;
|
|
|
|
|
|
|
|
XP_ASSERT(context);
|
|
|
|
if (!context) return;
|
|
|
|
|
|
|
|
if ((unsigned)e < (unsigned)sys_nerr)
|
|
|
|
{
|
|
|
|
es = sys_errlist [e];
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
PR_snprintf (buf2, sizeof (buf2), XP_GetString( XFE_UNKNOWN_ERROR_CODE ),
|
|
|
|
errno);
|
|
|
|
es = buf2;
|
|
|
|
}
|
|
|
|
|
|
|
|
suffix = XP_GetString(XFE_MOVEMAIL_FAILURE_SUFFIX);
|
|
|
|
if(!suffix) suffix = "";
|
|
|
|
if(!message) message = "";
|
|
|
|
L = XP_STRLEN(message) + XP_STRLEN(es) + XP_STRLEN(suffix) + 40;
|
|
|
|
buf1 = (char *) XP_ALLOC(L);
|
|
|
|
if(!buf1) return;
|
|
|
|
PR_snprintf (buf1, L-1, "%s\n%s\n\n%s", message, es, suffix);
|
|
|
|
FE_Alert (context, buf1);
|
|
|
|
XP_FREE(buf1);
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
int
|
|
|
|
fe_MoveMail (MWContext *context, char *from, char *to)
|
|
|
|
{
|
|
|
|
XP_Bool succeeded = FALSE;
|
|
|
|
char tmp_file[NAME_LEN];
|
|
|
|
char lock_file[NAME_LEN];
|
|
|
|
char spool_dir[NAME_LEN];
|
|
|
|
char *bp, buf[BUFSIZ];
|
|
|
|
char msgbuf[1024];
|
|
|
|
int from_fd = -1;
|
|
|
|
int to_fd = -1;
|
|
|
|
int tmp_fd = -1;
|
|
|
|
int nread, nwritten, nbytes, ntodo;
|
|
|
|
struct stat st;
|
|
|
|
|
|
|
|
*lock_file = 0;
|
|
|
|
|
|
|
|
if (!from || !to)
|
|
|
|
return FALSE;
|
|
|
|
|
|
|
|
if (strlen(from) > NAME_LEN - 1) return FALSE;
|
|
|
|
|
|
|
|
/* Make spool_dir be "/var/spool/mail" from "/var/spool/mail/$USER". */
|
|
|
|
strcpy(spool_dir, from);
|
|
|
|
while ((bp = strrchr(spool_dir, '/')) && bp[1] == '\0')
|
|
|
|
*bp = '\0';
|
|
|
|
if (!bp) return FALSE;
|
|
|
|
*bp = 0;
|
|
|
|
|
|
|
|
/* If we can't write into the directory itself, we can't create files,
|
|
|
|
so we lose. */
|
|
|
|
if (access(spool_dir, R_OK|W_OK) < 0)
|
|
|
|
{
|
|
|
|
PR_snprintf(msgbuf, sizeof (msgbuf),
|
|
|
|
XP_GetString(XFE_CANT_MOVE_MAIL_UNABLE_TO_WRITE),
|
|
|
|
from);
|
|
|
|
fe_movemail_perror(context, msgbuf);
|
|
|
|
goto FAIL;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* If the mail-spool file doesn't exist, or is 0-length, bug out.
|
|
|
|
*/
|
|
|
|
if (stat(from, &st) < 0 ||
|
|
|
|
st.st_size == 0)
|
|
|
|
{
|
|
|
|
FE_Alert (context, XP_GetString(XFE_MOVEMAIL_NO_MESSAGES));
|
|
|
|
goto FAIL;
|
|
|
|
}
|
|
|
|
|
|
|
|
PR_snprintf(tmp_file, sizeof (tmp_file), "%s%s", from, TMP_SUFFIX);
|
|
|
|
|
|
|
|
if (access(tmp_file, 0) == 0) {
|
|
|
|
/* The tmp file exists; try to get rid of it */
|
|
|
|
|
|
|
|
if (unlink(tmp_file) < 0) {
|
|
|
|
PR_snprintf(msgbuf, sizeof (msgbuf),
|
|
|
|
XP_GetString( XFE_CANT_GET_NEW_MAIL_LOCK_FILE_EXISTS ),
|
|
|
|
tmp_file);
|
|
|
|
fe_movemail_perror(context, msgbuf);
|
|
|
|
goto FAIL;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
PR_snprintf(lock_file, sizeof (lock_file), "%s%s", from, LOCK_SUFFIX);
|
|
|
|
|
|
|
|
while (1) {
|
|
|
|
int ret;
|
|
|
|
|
|
|
|
/* First create a real file, $USER.nslock
|
|
|
|
*/
|
|
|
|
tmp_fd = open(tmp_file, O_WRONLY|O_CREAT|O_EXCL, 0666);
|
|
|
|
|
|
|
|
if (tmp_fd < 0) {
|
|
|
|
PR_snprintf(msgbuf, sizeof (msgbuf),
|
|
|
|
XP_GetString( XFE_CANT_GET_NEW_MAIL_UNABLE_TO_CREATE_LOCK_FILE ),
|
|
|
|
tmp_file);
|
|
|
|
fe_movemail_perror(context, msgbuf);
|
|
|
|
goto FAIL;
|
|
|
|
}
|
|
|
|
close(tmp_fd);
|
|
|
|
tmp_fd = -1;
|
|
|
|
|
|
|
|
/* Then make a hard link from $USER.lock to $USER.nslock -- this is the
|
|
|
|
trick to make NFS behave synchronously.
|
|
|
|
*/
|
|
|
|
ret = link(tmp_file, lock_file);
|
|
|
|
|
|
|
|
/* Now we've (attempted to) make the link. `ret' says whether it was
|
|
|
|
successful. It would have failed if the lock was already being held.
|
|
|
|
|
|
|
|
Regardless of whether it succeeded, we can now delete $USER.nslock
|
|
|
|
(the thing to which the hard-link points.)
|
|
|
|
*/
|
|
|
|
if (unlink(tmp_file) < 0) {
|
|
|
|
PR_snprintf(msgbuf, sizeof (msgbuf),
|
|
|
|
/* This error message isn't quite right; what it really
|
|
|
|
means is "can't delete $MAIL.nslock", but I guess that
|
|
|
|
could only happen if some other user was the owner of
|
|
|
|
it? Or if it was already gone? Weird... */
|
|
|
|
XP_GetString(XFE_MOVEMAIL_CANT_DELETE_LOCK), tmp_file);
|
|
|
|
fe_movemail_perror(context, msgbuf);
|
|
|
|
goto FAIL;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* If we didn't obtain the lock (== make the hard-link), above, then
|
|
|
|
retry getting it until the file is 60 seconds old... Then get
|
|
|
|
Guido to go over and bust its kneecaps.
|
|
|
|
*/
|
|
|
|
if (ret < 0) {
|
|
|
|
sleep (1);
|
|
|
|
if (stat(lock_file, &st) >= 0) {
|
|
|
|
int current = time(NULL);
|
|
|
|
if (st.st_ctime < current - 60)
|
|
|
|
unlink (lock_file);
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
/* Got the lock - done waiting. */
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/* All of this junk used to happen in a forked process, but that's not
|
|
|
|
necessary any more (actually, hasn't been for a long time) since we
|
|
|
|
no longer play any setuid/setgid games -- there is no gain to doing
|
|
|
|
this in another fork and waiting for it to complete.
|
|
|
|
*/
|
|
|
|
|
|
|
|
/* Open the mail spool file for input...
|
|
|
|
*/
|
|
|
|
from_fd = open(from, O_RDWR, 0666);
|
|
|
|
if (from_fd < 0)
|
|
|
|
{
|
|
|
|
int err;
|
|
|
|
if (access(from, W_OK) < 0) /* look again, for right error message */
|
|
|
|
err = XFE_CANT_MOVE_MAIL_UNABLE_TO_WRITE;
|
|
|
|
else if (access(from, 0) == 0)
|
|
|
|
err = XFE_CANT_MOVE_MAIL_UNABLE_TO_READ;
|
|
|
|
else
|
|
|
|
err = XFE_CANT_MOVE_MAIL_UNABLE_TO_OPEN;
|
|
|
|
PR_snprintf(msgbuf, sizeof (msgbuf), XP_GetString(err), from);
|
|
|
|
fe_movemail_perror(context, msgbuf);
|
|
|
|
goto FAIL;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Open the destination file for output...
|
|
|
|
*/
|
|
|
|
to_fd = open(to, O_WRONLY|O_CREAT|O_EXCL, 0666);
|
|
|
|
if (to_fd < 0) {
|
|
|
|
PR_snprintf(msgbuf, sizeof (msgbuf),
|
|
|
|
XP_GetString( XFE_CANT_MOVE_MAIL_UNABLE_TO_OPEN ),
|
|
|
|
to);
|
|
|
|
fe_movemail_perror(context, msgbuf);
|
|
|
|
goto FAIL;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* copy the file */
|
|
|
|
|
|
|
|
nbytes = BUFSIZ;
|
|
|
|
|
|
|
|
while (1) {
|
|
|
|
nread = read(from_fd, buf, nbytes);
|
|
|
|
|
|
|
|
if (nread < 0) {
|
|
|
|
/* we're busted */
|
|
|
|
PR_snprintf(msgbuf, sizeof (msgbuf),
|
|
|
|
XP_GetString( XFE_CANT_MOVE_MAIL_UNABLE_TO_READ ), from);
|
|
|
|
fe_movemail_perror(context, msgbuf);
|
|
|
|
goto FAIL;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!nread) {
|
|
|
|
/* we're done */
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
for (ntodo = nread, bp = buf;
|
|
|
|
ntodo > 0;
|
|
|
|
ntodo -= nwritten, bp += nwritten) {
|
|
|
|
nwritten = write(to_fd, bp, ntodo);
|
|
|
|
|
|
|
|
if (nwritten < 0) {
|
|
|
|
PR_snprintf(msgbuf, sizeof (msgbuf),
|
|
|
|
XP_GetString( XFE_CANT_MOVE_MAIL_UNABLE_TO_WRITE ), to);
|
|
|
|
fe_movemail_perror(context, msgbuf);
|
|
|
|
goto FAIL;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/* if we made it this far, we're done copying the file contents.
|
|
|
|
First, close and sync the output file.
|
|
|
|
*/
|
|
|
|
|
|
|
|
if (fsync(to_fd) < 0 ||
|
|
|
|
close(to_fd) < 0)
|
|
|
|
{
|
|
|
|
PR_snprintf(msgbuf, sizeof (msgbuf),
|
|
|
|
XP_GetString( XFE_CANT_MOVE_MAIL_UNABLE_TO_WRITE ), to);
|
|
|
|
fe_movemail_perror(context, msgbuf);
|
|
|
|
goto FAIL;
|
|
|
|
}
|
|
|
|
to_fd = -1;
|
|
|
|
|
|
|
|
/* Now the output file is closed and sync'ed, so we can truncate the
|
|
|
|
spool file.
|
|
|
|
*/
|
|
|
|
if (ftruncate(from_fd, (off_t)0) < 0)
|
|
|
|
{
|
|
|
|
PR_snprintf(msgbuf, sizeof (msgbuf),
|
|
|
|
XP_GetString( XFE_THERE_WERE_PROBLEMS_CLEANING_UP ),
|
|
|
|
from);
|
|
|
|
fe_movemail_perror(context, msgbuf);
|
|
|
|
goto FAIL;
|
|
|
|
}
|
|
|
|
|
|
|
|
succeeded = TRUE;
|
|
|
|
|
|
|
|
FAIL:
|
|
|
|
|
|
|
|
if (to_fd >= 0) close(to_fd);
|
|
|
|
if (from_fd >= 0) close(from_fd);
|
|
|
|
if (tmp_fd >= 0) close(tmp_fd);
|
|
|
|
|
|
|
|
/* Unlink the lock file.
|
|
|
|
If this fails, but we were otherwise successful, then whine about it.
|
|
|
|
Otherwise, we've already presented an error dialog about something else.
|
|
|
|
*/
|
|
|
|
if (*lock_file && unlink(lock_file) < 0 && succeeded)
|
|
|
|
{
|
|
|
|
PR_snprintf(msgbuf, sizeof (msgbuf),
|
|
|
|
XP_GetString( XFE_THERE_WERE_PROBLEMS_CLEANING_UP ),
|
|
|
|
lock_file);
|
|
|
|
fe_movemail_perror(context, msgbuf);
|
|
|
|
succeeded = FALSE;
|
|
|
|
}
|
|
|
|
|
|
|
|
return succeeded;
|
|
|
|
}
|