DIRECTORY
Basics,
Commander USING [CommandProc,  Register],
IO,
IOClasses,
PFS,
PFSNames,
Process USING [CheckForAbort],
Rope,
SharedErrors;

TCCopyImpl: CEDAR MONITOR
IMPORTS Commander, IO, IOClasses, PFS, PFSNames, Process, Rope, SharedErrors
= BEGIN

ROPE: TYPE = Rope.ROPE;
PATH: TYPE = PFSNames.PATH;
STREAM: TYPE = IO.STREAM;

QuotedStringError: ERROR = CODE;

CmdTokenBreak: PROC [char: CHAR] RETURNS [IO.CharClass] = {
IF char = '" THEN RETURN [break];
IF char = '  OR char = '\t OR char = ', OR char = '\l OR char = '\r THEN RETURN [sepr];
RETURN [other];
};

Token: TYPE = RECORD [value, literal: ROPE];
GetCmdToken: PROC [stream: IO.STREAM] RETURNS [token: Token м [NIL, NIL]] = {
token.value м token.literal м IO.GetTokenRope[stream, CmdTokenBreak ! IO.EndOfStream => CONTINUE].token;
IF Rope.Equal[token.literal, "\""] THEN {
ref: REF;
IO.Backup[self: stream, char: '"];
ref м IO.GetRefAny[stream ! IO.Error, IO.EndOfStream => ERROR QuotedStringError];
WITH ref SELECT FROM
rope: ROPE => token.value м rope;
ENDCASE => ERROR QuotedStringError;
};
};
DoTCCopy: Commander.CommandProc = {
destinationDirectory: PATH м NIL;
leftArrowExists: BOOL м FALSE;
compsBeforeStar: INT м 0;
forceCopy: BOOL м TRUE;
retainStructure: BOOL м FALSE;
updateOnly: BOOL м FALSE;
exactLevelMatch: BOOL м FALSE;
componentsRequired: INT м 0;

HandleAFile: PROC [to, from: PATH] = {
sourceID: PFS.UniqueID м PFS.FileInfo[from].uniqueID;
toName: ROPE ~ PFS.RopeFromPath[to];
fromName: ROPE ~ PFS.RopeFromPath[from];
Process.CheckForAbort[];
cmd.out.PutF["  %g _ %g", [rope[toName]], [rope[fromName]]];
{ENABLE
PFS.Error =>
IF error.group # bug THEN {msg м PFSErrorMsg1[error]; GO TO skipIt};
IF updateOnly THEN {
destID: PFS.UniqueID м PFS.nullUniqueID;
destID м PFS.FileInfo[to ! PFS.Error => IF error.group # bug THEN CONTINUE].uniqueID;
IF sourceID = destID AND sourceID # PFS.nullUniqueID THEN {
cmd.out.PutRope["\n  -- not copied, create dates match"];
GO TO skipIt;
};
};
BEGIN
outputStream: IO.STREAM ~ PFS.StreamOpen[fileName: to, accessOptions: create, wantedUniqueID: sourceID
! PFS.Error => IF error.group = user THEN {
msg м IO.PutFR["Cannot create %s: %s\n", [rope[toName]], [rope[error.explanation]]];
GO TO sigh;
}];

pipeBufferLength: INT ~ 2048;
toPipe, fromPipe: IO.STREAM;
Fetcher: PROC ~ {
pfsRemoteStreamProc: PFS.RetrieveConfirmProc ~ {
RETURN [toPipe];
};

PFS.Retrieve[name: from, proc: pfsRemoteStreamProc];
IO.Close[toPipe];
};
Storer: PROC ~ TRUSTED {
buffer: PACKED ARRAY [0..pipeBufferLength) OF CHAR;
block: Basics.UnsafeBlock м [base: LOOPHOLE[LONG[@buffer]], startIndex: 0, count: pipeBufferLength];
count: INT;
DO
count м IO.UnsafeGetBlock[fromPipe, block];
IF count < pipeBufferLength THEN {
block.count м count;
IO.UnsafePutBlock[outputStream, block];
IO.Close[outputStream];
RETURN;
}
ELSE
IO.UnsafePutBlock[outputStream, block];
ENDLOOP;
};
[toPipe, fromPipe] м IOClasses.CreatePipe[pipeBufferLength];
TRUSTED {
SharedErrors.Fork[LIST[Storer, Fetcher]
! PFS.Error => IF error.group = user THEN {
msg м IO.PutFR["Cannot read %s: %s\n", [rope[fromName]], [rope[error.explanation]]];
GO TO sigh;
}];
};

EXITS
sigh => {};
END;
EXITS
skipIt => {};
};
cmd.out.PutRope["\n"];
};

argStream: IO.STREAM ~ IO.RIS[cmd.commandLine];
head: LIST OF ROPE ~ LIST[NIL];
last: LIST OF ROPE м head;
nArgs: NAT м 0;
args: LIST OF ROPE м NIL;
sources: LIST OF ROPE м NIL;
DO
arg: Token ~ GetCmdToken[argStream];
length: INT ~ Rope.Length[arg.value];
SELECT TRUE FROM
(arg.value = NIL) => EXIT;
(length = 0) => NULL;
(Rope.Fetch[arg.literal, 0] = '-) => {
sense: BOOL м TRUE;
FOR j: INT IN [1..length) DO
SELECT arg.literal.Fetch[j] FROM
'~ => {sense м NOT sense; LOOP };
'r, 'R => retainStructure м sense;
'u, 'U => updateOnly м sense;
'x, 'X => exactLevelMatch м sense;
ENDCASE => {
msg м Rope.Cat["Unknown switch: ", arg.literal.Substr[0, j], " ", arg.literal.Substr[j]];
GOTO Die;
};
sense м TRUE;
ENDLOOP;
};
(nArgs = 1 AND (Rope.Equal[arg.literal, "_"] OR Rope.Equal[arg.literal, "м"])) => {
leftArrowExists м TRUE;
};
ENDCASE => { nArgs м nArgs + 1; last м last.rest м LIST[arg.value] };
ENDLOOP;
args м head.rest;
IF leftArrowExists
THEN {
target: PATH м PFS.PathFromRope[args.first];
sources м args.rest;
IF target.IsADirectory[]
THEN destinationDirectory м target
ELSE {
IF nArgs # 2 OR Rope.Find[args.first, "*"] >= 0 OR Rope.Find[args.rest.first, "*"] >= 0
THEN RETURN[$Failure, "Bad syntax for copying a file"];
HandleAFile[from: PFS.PathFromRope[args.rest.first], to: target];
RETURN[IF msg # NIL THEN $Failure ELSE NIL, msg];
};
}
ELSE {
destinationDirectory м PFS.GetWDir[];
sources м args;
};

FOR tail: LIST OF ROPE м sources, tail.rest UNTIL tail = NIL DO
source: PATH м PFS.PathFromRope[tail.first];
IF source.IsADirectory[] THEN {
msg м Rope.Concat["Cannot copy a directory: ", tail.first];
GO TO Die;
};
IF Rope.Find[tail.first, "*"] >= 0
THEN {
pattern: PATH м source;
handleIt: PFS.NameProc = {
to: PATH;
short: ROPE м NIL;
continue м TRUE;
IF exactLevelMatch AND componentsRequired # name.ComponentCount[] THEN RETURN [TRUE];
IF retainStructure
THEN to м name.SubName[compsBeforeStar]
ELSE to м name.SubName[start~name.ComponentCount[]-1, count~1];
to м to.StripVersionNumber[];
to м PFSNames.Cat[destinationDirectory, to];
HandleAFile[from: name, to: to];
RETURN[msg = NIL];
};
IF pattern.ShortName[].version = [none] THEN pattern м pattern.SetVersionNumber[[highest]];
pattern м PFS.AbsoluteName[pattern];
IF exactLevelMatch THEN componentsRequired м PFSNames.ComponentCount[pattern];
IF retainStructure THEN {
goOn: BOOL м TRUE;
findStar: PFSNames.ComponentProc ~ {
IF goOn AND Rope.Find[comp.ComponentRope[], "*"] >= 0 THEN goOn м FALSE ELSE compsBeforeStar  м compsBeforeStar+1;
};
dummySeparatorProc: PFSNames.SeparatorProc ~ {};
PFSNames.Map[pattern, findStar, dummySeparatorProc, NIL];
};
PFS.EnumerateForNames[pattern, handleIt
! PFS.Error => IF error.group # $bug THEN {msg м PFSErrorMsg[error]; GO TO Die}];
}
ELSE {
from: PATH м source;
to: PATH м PFSNames.StripVersionNumber[from.SubName[from.ComponentCount[]-1]];
to м PFSNames.Cat[destinationDirectory, to];
HandleAFile[from: from, to: to];
IF msg # NIL THEN GO TO Die;
};
Process.CheckForAbort[];
ENDLOOP;
EXITS
Die =>  result м $Failure;
};

TCFileInfo: PROC[name: PATH] RETURNS[uid: PFS.UniqueID м PFS.nullUniqueID] ~ {
Enum: PFS.InfoProc ~ {
uid м uniqueID;
RETURN[FALSE];
};
comp: PFSNames.Component м PFSNames.ShortName[name];
IF comp.version.versionKind = none THEN
name м PFSNames.SetVersionNumber[name, [highest, 0 ]];
PFS.EnumerateForInfo[name, Enum];
};

PFSErrorMsg: PROC [error: PFS.ErrorDesc] RETURNS [ROPE] = {
IF error.code = $unknownFile
THEN RETURN ["  -- not found!\n"]
ELSE RETURN[Rope.Cat[" -- PFS.Error: ", error.explanation, "\n"]];
};

PFSErrorMsg1: PROC [error: PFS.ErrorDesc] RETURNS [ROPE] = {
IF error.code = $unknownFile
THEN RETURN ["  -- not found!"]
ELSE RETURN[Rope.Concat["\n  -- PFS.Error: ", error.explanation]];
};

copyDoc: ROPE = "newFile _ oldFile  |  directory _ {pattern}*
Copies a file or files.
  -c	force copy
  -r	retain structure
  -u	update only
  -x	exact level match";


Init: PROC = {
Commander.Register["TCCopy", DoTCCopy, copyDoc, $Copy];
};

Init[];

END.
   ■  
TCCopyImpl.mesa
Copyright ╙ 1991, 1992 by Xerox Corporation.  All rights reserved.
taken from PFSCommandsImpl
Willie-s, February 19, 1991 11:53 am PST

Copying using Retrieve and Store
This file does not need a copy, since it has the same ID as the destination file.  We have been instructed to trust the ID.
If we get here, then for each of the filenames and patterns, copy the file to the destination directory.
[name: PATH] RETURNS [continue: BOOL]
don't have FileInfo in TC interface
Initialization
Э╩/  Ц(cedarcode) styleХNewlineDelimiter
Щ codeЪЬЩKЪЬ
╧eЬ7ЩBKЩKЩ(KЩ Ъ╧k	Ш	KШKЪЬ
ЮЬШ)KЪЮЬШKШ
KЪЮЬШKЪЬ	Ш	KЪЬЮЬШKЪЬШKЪЬШЧЧKШ Ъ╨ln
ЬЮЬЮШKЪЮЬЮЬЮЬ'ШLKЪЬЮШKШ KЪЮЬЮЬЮЬШKЪЮЬЮЬЮЬШЪЮЬЮЬЮЬЮЬШKШ ЧЪ╧nЬЮЬЮЬШ KШ ЧЪ
аЬЮЬЮЬЮЬЮЬШ;KЪЮЬЮЬЮЬ	Ш!KЪЮЬЮЬЮЬЮЬЮЬЮЬЮЬШWKЪЮЬ	ШKШKШ ЧKЪЬЮЬЮЬЮЬШ,ЪаЬЮЬ
ЮЬЮЬЮЬЮЬЮЬШMKЪЬЮЬ&ЮЬЮЬШhХStartOfExpansion6[pattern: ROPE, object: ROPE, case: BOOL _ TRUE]ЪЮЬ!ЮЬШ)KЪЬЮЬШ	KЦ[self: STREAM, char: CHAR]ЪЮЬ Ш"KЪ	ЬЮЬЮЬЮЬЮЬШQЪЮЬЮЬЮШKЪЬЮЬШ!KЪЮЬЮЬШ#ЧKЪЬШЧKШЧЧheadЩ ЪаЬШ#KЪЬЮЬЮЬШ!KЪЬЮЬЮЬШKЪЬЮЬШKЪЬЮЬЮЬШKЪЬЮЬЮЬШKЪЬЮЬЮЬШKЪЬЮЬЮЬШKЪЬЮЬШKШ ЪаЬЮЬЮЬШ&KЪЬ
ЮЬЮЬШ5KЪЬЮЬЮЬШ$KЪЬ
ЮЬЮЬШ(KЪЬШKЪЬ<Ш<ЪЬЮШЪЮЬ	ШKЪЮЬЮЬЮЬЮЬ	ШDЧЪЮЬЮЬШKЪЬЮЬЮЬШ(KЪЬ	ЮЬЮЬ
ЮЬЮЬЮЬШUЪЮЬЮЬЮЬЮЬШ;KЪЬ{Щ{KЪЬ9Ш9KЪЮЬЮЬШKШЧKШЧЪЮШЦ╩[fileName: ROPE, accessOptions: FS.AccessOptions _ read, streamOptions: FS.StreamOptions _ (3)[TRUE, TRUE, TRUE], keep: CARDINAL _ 1B (1), createByteCount: FS.ByteCount _ 2560, streamBufferParms: FS.StreamBufferParms _ [vmPagesPerBuffer: 8, nBuffers: 2], extendFileProc: FS.ExtendFileProc, wantedCreatedTime: GMT _ nullGMT, remoteCheck: BOOL _ TRUE, wDir: ROPE _ NIL, checkFileType: BOOL _ FALSE, fileType: FS.FileType _ [0B (0)]]ЪЬЮЬЮЬЮЬIШfЪЬЮЬ
ЮЬЮЬШ+KЪЬЮЬLШTKЪЮЬЮЬШKШЧЧKШ KЪЬЮЬШKЪЬЮЬЮЬШЪаЬЮЬШЪ╧bЬЮЬШ0KЪЮЬ
ШKШЧKШ KЪЮЬ1Ш4KЪЮЬШKШЧЪаЬЮЬЮЬШKЪ	ЬЮЬЮЬЮЬЮЬШ3KЪЬ#ЮЬЮЬ4ШdKЪЬЮЬШЪЮШKЪЬЮЬ!Ш+ЪЮЬЮЬШ"KШKЪЮЬ%Ш'KЪЮЬШKЪЮЬШKЪЬШЧЪЮШKЪЮЬ%Ш'ЧKЪЮЬШKШЧЧKШ<ЪЮЬШ	ЪЬЮЬШ'ЪЬЮЬ
ЮЬЮЬШ+KЪЬЮЬLШTKЪЮЬЮЬШKШЧЧKЪЬШЧKШ ЪЮШKЪЬШЧKЪЮЬШЪЮШKШЧЧKШЧKЪЬШKШЧKШ KЪ	ЬЮЬЮЬЮЬЮЬШ/KЪЬЮЬЮЬЮЬЮЬЮЬШKЪЬЮЬЮЬЮЬШKЪЬЮЬШKЪ	ЬЮЬЮЬЮЬЮЬШKЪ	Ь	ЮЬЮЬЮЬЮЬШЪЮШKЪЬ$Ш$KЪЬЮЬШ%ЪЮЬЮЬЮШKЪЬЮЬЮЬШKЪЬЮЬШЪЬ&Ш&KЪЬЮЬЮЬШЪЮЬЮЬЮЬЮШЪЮЬЮШ KЪЬЮЬЮЬШ!KШ"KШKШ"ЪЮЬШKШYKЪЮЬШ	KШЧЧKЪЬЮЬШKЪЮЬШЧKЪЬШЧЪЬЮЬЮЬ$ШSKЪЬЮЬШKЪЬШЧKЪЮЬ,ЮЬШEЧKЪЮЬШЧKШЪЮЬШЪЮЬШKЪЬЮЬЮЬШ,KШЪЮЬШKЪЮЬШ"ЪЮЬШЪЮЬЮЬ!ЮЬ%ШWKЪЮЬЮЬ,Ш7ЧKЪЬЮЬ,ШAKЪЮЬЮЬЮЬЮЬ
ЮЬЮЬШ1KШЧЧKШЧЪЮЬШKЪЬЮЬШ%KШKЪЬШЧЧKШ KЩhЪЮЬЮЬЮЬЮЬЮЬЮЬЮШ?KЪЬЮЬЮЬШ,ЪЮЬЮЬШKШ;KЪЮЬЮЬШ
KШЧЪЮЬ Ш"ЪЮЬШKЪЬ	ЮЬ
ШЪЬ
ЮЬШKЪЬЮЬЮЬЮЬЩ%KЪЬЮЬШ	KЪЬЮЬЮЬШKЪЬЮЬШKЪ
ЮЬЮЬ,ЮЬЮЬЮЬШUЪЮЬШKЪЮЬ#Ш'KЪЮЬ;Ш?ЧKШKШ,KЪЬ Ш KЪЮЬЮЬШKШЧKЪЮЬ&ЮЬ/Ш[KШ$KЪЮЬЮЬ7ШNЪЮЬЮЬШKЪЬЮЬЮЬШЪЬ$Ш$KЪ
ЮЬЮЬ+ЮЬЮЬЮЬ&ШrKЪЬШЧKЪЬ0Ш0KЪЬ4ЮЬШ9KШЧЪЮЬ$Ш'KЪЬЮЬ
ЮЬЮЬЮЬЮЬШQЧKЪЬШЧЪЮЬШKЪЬЮЬ
ШKЪЬЮЬFШNKШ,KЪЬ Ш KЪ
ЮЬЮЬЮЬЮЬЮЬШKШЧЧKЪЬШKЪЮЬШЧЪЮШKШЧKШKШ ЧЪа
ЬЮЬЮЬЮЬЮЬЮЬШNKЩ#ЪаЬЮЬШKШKЪЮЬЮЬШKШЧKШ4KЪЮЬ!ЮЬ7Ш^KЪЮЬШ!KШKШ ЧЪ
аЬЮЬ	ЮЬЮЬЮЬШ;ЪЮЬШKЪЮЬЮЬШ!KЪЮЬЮЬ7ШBЧKЪЬШKШ ЧЪ
аЬЮЬ	ЮЬЮЬЮЬШ<ЪЮЬШKЪЮЬЮЬШKЪЮЬЮЬ7ШBЧKЪЬШЧЧЩШ ЪЬ	ЮЬШШеKШ ЧKШ ЪаЬЮЬШKЪЬ7Ш7KШKШ ЧKШЧKШ ЧKЪЮЬШЧ ЕЧ    $  +Q  