/***************************************************************************/
/***************************************************************************/
/*                                                                         */
/*   (c) 1993-1994.  The Regents of the University of California.  All     */
/*   rights reserved.                                                      */
/*                                                                         */
/*   This work was produced at the University of California, Lawrence      */
/*   Livermore National Laboratory (UC LLNL) under contract no.            */
/*   W-7405-ENG-48 (Contract 48) between the U.S. Department of Energy     */
/*   (DOE) and The Regents of the University of California (University)    */
/*   for the operation of UC LLNL.  Copyright is reserved to the           */
/*   University for purposes of controlled dissemination,                  */
/*   commercialization through formal licensing, or other disposition      */
/*   under terms of Contract 48; DOE policies, regulations and orders;     */
/*   and U.S. statutes.  The rights of the Federal Government are          */
/*   reserved under Contract 48 subject to the restrictions agreed upon    */
/*   by the DOE and University.                                            */
/*                                                                         */
/*                                                                         */
/*                              DISCLAIMER                                 */
/*                                                                         */
/*   This software was prepared as an account of work sponsored by an      */
/*   agency of the United States Government.  Neither the United States    */
/*   Government nor the University of California nor any of their          */
/*   employees, makes any warranty, express or implied, or assumes any     */
/*   liability or responsibility for the accuracy, completeness, or        */
/*   usefulness of any information, apparatus, product, or process         */
/*   disclosed, or represents that its specific commercial products,       */
/*   process, or service by trade name, trademark, manufacturer, or        */
/*   otherwise, does not necessarily constitute or imply its               */
/*   endorsement, recommendation, or favoring by the United States         */
/*   Government or the University of California. The views and opinions    */
/*   of the authors expressed herein do not necessarily state or reflect   */
/*   those of the United States Government or the University of            */
/*   California, and shall not be used for advertising or product          */
/*   endorsement purposes.                                                 */
/*                                                                         */
/*   Permission to use, copy, modify and distribute this software and its  */
/*   documentation for any non-commercial purpose, without fee, is         */
/*   hereby granted, provided that the above copyright notice and this     */
/*   permission notice appear in all copies of the software and            */
/*   supporting documentation, and that all UC LLNL identification in      */
/*   the user interface remain unchanged.  The title to copyright LLNL     */
/*   XFTP shall at all times remain with The Regents of the University     */
/*   of California and users agree to preserve same. Users seeking the     */
/*   right to make derivative works with LLNL XFTP for commercial          */
/*   purposes may obtain a license from the Lawrence Livermore National    */
/*   Laboratory's Technology Transfer Office, P.O. Box 808, L-795,         */
/*   Livermore, CA 94550.                                                  */
/*                                                                         */
/***************************************************************************/
/***************************************************************************/

#include <sys/types.h>
#include <sys/stat.h>
#include <errno.h>
#include <fcntl.h>
#include "xftp.h"
#include "xfer.h"

#define MAXFILEBUF 2048

extern struct xfer_ctrl_block xfer_ctrl;
extern int store_unique;

char *create_unique_name();


/*
 * init_local_copy - Initialize transfer of file from local host to local
 *                   host.  "xfer_ctrl" is used for input and output.
 *                   Returns 0 if successful, else -1.
 */
init_local_copy()
{
	int src_file_fd;
	int snk_file_fd;
	int src_host = xfer_ctrl.src_host;
	int snk_host = xfer_ctrl.snk_host;
	char *src_file = xfer_ctrl.src_path;
	char *snk_file = xfer_ctrl.snk_path;
	long file_len;
	struct stat status;
	char msg[MAXPATHLEN+30];
	char *dir;
	int retval;

    /* Get unique file name if requested */
    if (store_unique) {
        if ((snk_file = create_unique_name(snk_file)) == NULL)
            return -1;
    }

    /* Create temporary directory for view file */
    if (xfer_ctrl.operation == VIEW) {
        parse_path(SYS_UNIX, xfer_ctrl.snk_path, &dir, NULL);
        retval = local_mkdir(snk_host, dir, 0700);
        XtFree(dir);
        if (retval)
            return -1;
    }

    /* Verify that a writable sink file can be created */
    if (!can_create_sinkfile(snk_host, snk_file))
        return -1;

    /* Open source file */
    if ((src_file_fd = iopen2(src_file, O_RDONLY)) < 0) {
        report_perror(src_host, src_file);
        return -1;
    }

    /* Verify that source file is a "real" file */
    if (fstat(src_file_fd, &status) < 0 || !S_ISREG(status.st_mode)) {
		sprintf(msg, "%s is not a \"real\" file", src_file);
		warning_error(msg);
        close(src_file_fd);
        return -1;
    }

    /* Get length of file */
    file_len = status.st_size;

	/* Create sink file */
	if (unlink(snk_file) == -1)
		if (errno != ENOENT) {
			report_perror(snk_host, snk_file);
			close(src_file_fd);
			return -1;
		}
	if ((snk_file_fd = iopen3(snk_file, O_CREAT|O_WRONLY, 0644)) < 0) {
		report_perror(snk_host, snk_file);
		close(src_file_fd);
		return -1;
	}

	xfer_ctrl.src_file_fd = src_file_fd;
	xfer_ctrl.snk_file_fd = snk_file_fd;
	xfer_ctrl.file_len = file_len;
    xfer_ctrl.file_index = 0;

    return 0;
}


/*
 * do_local_copy - Transfer next part of file from local host to local
 *                 host.  "xfer_ctrl" is used for input and output.
 *                 Returns 0 if file transfer complete, 1 if file
 *                 transfer not complete, and -1 for error.
 */
do_local_copy()
{
	int src_host = xfer_ctrl.src_host;
	int snk_host = xfer_ctrl.snk_host;
	int src_file_fd = xfer_ctrl.src_file_fd;
	int snk_file_fd = xfer_ctrl.snk_file_fd;
	long file_index = xfer_ctrl.file_index;
	long file_len = xfer_ctrl.file_len;
	int nbytes;
	char filebuf[MAXFILEBUF];
	char *src_file = xfer_ctrl.src_path;
	char *snk_file = xfer_ctrl.snk_path;

	if (file_index < file_len) {
		nbytes = MIN(file_len-file_index, MAXFILEBUF);
		if (iread(src_file_fd, filebuf, nbytes) != nbytes) {
			report_perror(src_host, src_file);
			close(src_file_fd);
			close(snk_file_fd);
			return -1;
		}
		if (iwrite(snk_file_fd, filebuf, nbytes) != nbytes) {
			report_perror(snk_host, snk_file);
			close(src_file_fd);
			close(snk_file_fd);
			return -1;
		}
		file_index += nbytes;
	}

    /* Have all the bytes been transferred? */
    xfer_ctrl.file_index = file_index;
    if (file_index < file_len)
        return 1;

    /* Close files */
    close(src_file_fd);
	close(snk_file_fd);

	return 0;
}


/*
 * abort_local_copy - Abort transfer of file from local host to local
 *                    host.  "xfer_ctrl" is used for input and output.
 *                    Returns -1.
 */
abort_local_copy()
{
	close(xfer_ctrl.src_file_fd);
	close(xfer_ctrl.snk_file_fd);
	return -1;
}