/***************************************************************************/
/***************************************************************************/
/* */
/* (c) 1995-1999. 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 */
/* XDIR 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 XDIR 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 <Xm/Xm.h>
#include "xdir.h"
#include "xfer.h"
#include "str.h"
int cb_expand_snk_forest();
int cb_examine_snk_forest();
int cb_xfer_files();
extern XtAppContext app;
extern int overwrite_dirs;
extern Display *display;
extern struct xfer_ctrl_block xc;
extern char *xfer_question;
extern char *recursion_disabled_msg;
/*
* cb_examine_src_forest - Build forest of directories and files to transfer.
*/
cb_examine_src_forest()
{
char *rel_path;
char *full_path;
char *rel_path_parent;
int retval;
int i;
int src_host;
int snk_host;
struct forest_node *ptr;
struct forest_node *head;
struct sl_struct *list;
char *q;
char msg[MAXPATHLEN+50];
/* Determine types of current directory's entries */
if (xc.state == 0) {
while (xc.s0ptr) {
if (stop()) {
xfer_abort(False);
return True;
}
if (xc.s0ptr->type == TYPE_UNKNOWN) {
if (xc.src_host_system == SYS_VMS)
fatal_error("Bug in cb_examine_src_forest()");
if (xc.s0ptr->parent)
src_paths_of_xfer_node(xc.s0ptr->parent,
&rel_path_parent, NULL);
else
rel_path_parent = XtNewString(xc.src_dirname);
set_xfermon_name(rel_path_parent);
XtFree(rel_path_parent);
XSync(display, 0);
src_paths_of_xfer_node(xc.s0ptr, NULL, &full_path);
retval = test_for_dir(xc.src_dirwin->host, full_path);
XtFree(full_path);
switch (retval) {
case -6:
xfer_abort(False);
return True;
case -3:
xfer_done(True, False);
return True;
case 0:
if ((xc.operation == COPY) && !xc.asked_user) {
beep();
if (question_dialog(xfer_question,
xc.snk_dirwin->w_shell))
xc.operation = RCOPY;
xc.asked_user = True;
}
if (xc.operation == RCOPY) {
xc.s0ptr->type = TYPE_DIR;
xc.s0ptr = xc.s0ptr->next;
} else { /* Remove entry */
src_paths_of_xfer_node(xc.s0ptr, &rel_path, NULL);
sprintf(msg, recursion_disabled_msg, rel_path);
XtFree(rel_path);
record_warning(msg);
if (*xc.s0head == xc.s0ptr) {
*xc.s0head = xc.s0ptr->next;
XtFree(xc.s0ptr->entry);
XtFree((char *)xc.s0ptr);
xc.s0ptr = *xc.s0head;
xc.node[xc.level] = *xc.s0head;
} else {
ptr = *xc.s0head;
while (ptr->next != xc.s0ptr)
ptr = ptr->next;
ptr->next = xc.s0ptr->next;
XtFree(xc.s0ptr->entry);
XtFree((char *)xc.s0ptr);
xc.s0ptr = ptr->next;
}
}
break;
case -1:
xc.s0ptr->type = TYPE_FILE;
xc.s0ptr = xc.s0ptr->next;
}
} else
xc.s0ptr = xc.s0ptr->next;
}
xc.state = 1;
}
/* Build forest */
while (1) {
if (stop()) {
xfer_abort(False);
return True;
}
if (xc.node[xc.level] == NULL) {
xc.level--;
if (xc.level < 0) {
xc.node[0] = xc.forest;
xc.level = 0;
xc.file_count = 0;
xc.file_total = nfiles_in_xfer_forest();
set_xfermon_file_count(0, xc.file_total);
if (dir_in_xfer_forest()) {
if (overwrite_dirs) {
set_xfermon_status(STATUS_PASS3);
XtAppAddWorkProc(app, (XtWorkProc)cb_expand_snk_forest,
NULL);
} else {
set_xfermon_status(STATUS_PASS2);
XtAppAddWorkProc(app, (XtWorkProc)cb_examine_snk_forest,
NULL);
}
} else {
src_host = xc.src_dirwin->host;
if ((src_host != LOCAL) &&
((retval = ftp_type(src_host, xc.mode)) < 0)) {
switch (retval) {
case -1:
record_and_alert("Unable to set transfer mode.",
xc.src_dirwin->w_shell);
return True;
case -3:
xfer_done(True, False);
return True;
case -6:
xfer_abort(False);
return True;
}
}
snk_host = xc.snk_dirwin->host;
if ((snk_host != LOCAL) &&
((retval = ftp_type(snk_host, xc.mode)) < 0)) {
switch (retval) {
case -1:
record_and_alert("Unable to set transfer mode.",
xc.snk_dirwin->w_shell);
return True;
case -3:
xfer_done(False, True);
return True;
case -6:
xfer_abort(False);
return True;
}
}
xc.state = 0;
if (xc.mode == ASCII)
set_xfermon_status(STATUS_XFER_ASCII);
else
set_xfermon_status(STATUS_XFER_BINARY);
set_xfermon_name_label("File Name:");
XSync(display, 0);
XtAppAddWorkProc(app, (XtWorkProc)cb_xfer_files, NULL);
}
return True;
}
xc.node[xc.level] = xc.node[xc.level]->next;
} else if (xc.node[xc.level]->type == TYPE_DIR) {
if (xc.level == MAXLEVELS-1) {
record_and_alert(
"File transfer recurses too deeply - aborted.",
xc.snk_dirwin->w_shell);
xfer_done(False, False);
return True;
}
if (xc.node[xc.level]->position != ABOVE_START_NODE) {
/* Get directory list */
src_paths_of_xfer_node(xc.node[xc.level], &rel_path,
&full_path);
set_xfermon_name(rel_path);
XSync(display, 0);
retval = get_dirlist(xc.src_dirwin->host, full_path, TABULAR,
True, False, False, &list);
XtFree(rel_path);
XtFree(full_path);
switch (retval) {
case -6:
xfer_abort(False);
return True;
case -3:
xfer_done(True, False);
return True;
case -1:
src_paths_of_xfer_node(xc.node[xc.level], &rel_path, NULL);
sprintf(msg, "Unable to get list of source directory %s",
rel_path);
record_and_alert(msg, xc.snk_dirwin->w_shell);
XtFree(rel_path);
xfer_done(False, False);
return True;
}
/* Add source directory list to new level */
head = NULL;
for (i=list->nentries-1; i>=0; i--) {
ptr = XtNew(struct forest_node);
ptr->parent = xc.node[xc.level];
ptr->first_child = NULL;
ptr->status = NOT_PROCESSED;
ptr->position = BELOW_START_NODE;
ptr->entry = XtNewString(list->entries[i]);
if (xc.src_host_system == SYS_VMS) {
if ((q = strstr(ptr->entry, ".dir"))) {
*q = '\0'; /* Shave off ".dir;n" */
ptr->type = TYPE_DIR;
} else
ptr->type = TYPE_FILE;
} else
ptr->type = TYPE_UNKNOWN;
ptr->next = head;
head = ptr;
}
release_array_list(list);
xc.node[xc.level]->first_child = head;
}
xc.level++;
xc.node[xc.level] = xc.node[xc.level-1]->first_child;
xc.s0ptr = xc.node[xc.level-1]->first_child;
xc.s0head = &xc.node[xc.level-1]->first_child;
xc.state = 0;
return False;
} else
xc.node[xc.level] = xc.node[xc.level]->next;
}
}
/*
* dir_in_xfer_forest - Scans the completed source forest and returns True
* if it contains a directory that is at or below a
* "start node".
*/
dir_in_xfer_forest()
{
struct forest_node *node[MAXLEVELS];
int level = 0;
node[0] = xc.forest;
while (1) {
if (node[level] == NULL) {
level--;
if (level < 0)
return False;
node[level] = node[level]->next;
} else if (node[level]->type == TYPE_DIR) {
if (node[level]->position == ABOVE_START_NODE) {
node[level+1] = node[level]->first_child;
level++;
} else
return True;
} else {
node[level] = node[level]->next;
}
}
}
syntax highlighted by Code2HTML, v. 0.9.1