vi/common/recover.c

124 rcv_tmp(SCR *sp, EXF *ep, char *name)
133 	 * ep MAY NOT BE THE SAME AS sp->ep, DON'T USE THE LATTER.
135 	if (opts_empty(sp, O_RECDIR, 0))
137 	dp = O_STR(sp, O_RECDIR);
141 			msgq(sp, M_SYSERR, "%s", dp);
150 			msgq(sp, M_ERR,
156 	if ((fd = rcv_mktemp(sp, path, dp, S_IRWXU)) == -1)
161 		msgq(sp, M_SYSERR, NULL);
163 err:		msgq(sp, M_ERR,
180 rcv_init(SCR *sp)
185 	ep = sp->ep;
200 		if (rcv_mailfile(sp, 0, NULL))
204 		if (db_last(sp, &lno))
208 		sp->gp->scr_busy(sp,
211 			msgq_str(sp, M_SYSERR, ep->rcv_path,
213 			sp->gp->scr_busy(sp, NULL, BUSY_OFF);
216 		sp->gp->scr_busy(sp, NULL, BUSY_OFF);
226 err:	msgq(sp, M_ERR,
242 rcv_sync(SCR *sp, u_int flags)
249 	ep = sp->ep;
259 			msgq_str(sp, M_SYSERR,
270 			rcv_email(sp, ep->rcv_fd);
285 		if (opts_empty(sp, O_RECDIR, 0))
287 		dp = O_STR(sp, O_RECDIR);
289 		if ((fd = rcv_mktemp(sp, buf, dp, S_IRUSR | S_IWUSR)) == -1)
291 		sp->gp->scr_busy(sp,
293 		if (rcv_copy(sp, fd, ep->rcv_path) ||
294 		    close(fd) || rcv_mailfile(sp, 1, buf)) {
299 		sp->gp->scr_busy(sp, NULL, BUSY_OFF);
307 		F_SET(sp, SC_EXIT_FORCE);
317 rcv_mailfile(SCR *sp, int issync, char *cp_path)
330 	gp = sp->gp;
332 		msgq(sp, M_ERR,
337 	if (opts_empty(sp, O_RECDIR, 0))
339 	dp = O_STR(sp, O_RECDIR);
341 	if ((fd = rcv_mktemp(sp, mpath, dp, S_IRUSR | S_IWUSR)) == -1)
351 	ep = sp->ep;
352 	if (file_lock(sp, NULL, NULL, fd, 1) != LOCK_SUCCESS)
353 		msgq(sp, M_SYSERR, "Unable to lock recovery file");
358 			msgq(sp, M_SYSERR, NULL);
371 	t = sp->frp->name;
402 lerr:		msgq(sp, M_ERR, "Recovery file buffer overrun");
441 		rcv_email(sp, fd);
443 werr:			msgq(sp, M_SYSERR, "Recovery file");
463 rcv_openat(SCR *sp, int dfd, const char *name, int *locked)
486 	switch ((*locked = file_lock(sp, NULL, NULL, fd, 0))) {
520 rcv_list(SCR *sp)
531 	if (opts_empty(sp, O_RECDIR, 0))
533 	p = O_STR(sp, O_RECDIR);
535 		msgq_str(sp, M_SYSERR, p, "recdir: %s");
544 		if ((fd = rcv_openat(sp, dirfd(dirp), dp->d_name, NULL)) == -1)
558 			msgq_str(sp, M_ERR, dp->d_name,
601 rcv_read(SCR *sp, FREF *frp)
612 	if (opts_empty(sp, O_RECDIR, 0))
614 	rp = O_STR(sp, O_RECDIR);
616 		msgq_str(sp, M_SYSERR, rp, "%s");
631 		if ((fd = rcv_openat(sp, dirfd(dirp), dp->d_name, &lck)) == -1)
641 			msgq_str(sp, M_ERR, recpath,
678 				msgq(sp, M_SYSERR, NULL);
683 				msgq(sp, M_SYSERR, NULL);
703 		msgq_str(sp, M_INFO, name,
709 			msgq(sp, M_INFO,
712 			msgq(sp, M_INFO,
722 	if (file_init(sp, frp, pathp + sizeof(VI_PHEADER) - 1, 0)) {
734 	ep = sp->ep;
750 rcv_copy(SCR *sp, int wfd, char *fname)
764 err:	msgq_str(sp, M_SYSERR, fname, "%s");
792 rcv_mktemp(SCR *sp, char *path, char *dname, int perms)
806 		msgq_str(sp, M_SYSERR, dname, "%s");
821 rcv_email(SCR *sp, int fd)
832 	if (O_ISSET(sp, O_SECURE))
836 		msgq_str(sp, M_SYSERR,
848 			msgq(sp, M_SYSERR, "fork");
852 				msgq(sp, M_SYSERR, "lseek");
857 					msgq(sp, M_SYSERR, "dup2");
863 			msgq(sp, M_SYSERR, _PATH_SENDMAIL);