DIRECTORY
BasicTime,
BridgeComm,
BridgeFTPOps,
Convert,
IO,
NetworkStream,
Process,
Rope
;

BridgeFTPOpsImpl: CEDAR PROGRAM
IMPORTS BasicTime, BridgeComm, Convert, IO, NetworkStream, Process, Rope
EXPORTS BridgeFTPOps
~ {

ROPE: TYPE ~ Rope.ROPE;
STREAM: TYPE ~ IO.STREAM;
NetworkStreamPair: TYPE ~ BridgeComm.NetworkStreamPair;

ActionProc: TYPE ~ BridgeFTPOps.ActionProc;

RetrieveStream: PUBLIC PROC [nsp: NetworkStreamPair, remoteName: ROPE, action: ActionProc, clientData: REF м NIL, msgStream: STREAM м NIL] RETURNS [excuse: ROPE м NIL]
~ {
ENABLE {
ABORTED => {
excuse м "aborted";
CONTINUE };
BridgeComm.Error => {
PutMsg[msgStream, "Communication error: %g\n", msg];
excuse м "Bridge communication error";
CONTINUE };
IO.Error, NetworkStream.Error => {
PutMsg[msgStream, "I/O error\n"];
excuse м "I/O error";
CONTINUE };
};
ansMsg: CHAR;
ansArg: ROPE;
ansArgNumeric: CARD;
actionProcQuit: BOOL;
PutMsg[msgStream, "Retrieving from %g ... ", remoteName];
[ansMsg, ansArg] м BridgeComm.PutMsgWithReply[nsp, 'I, remoteName]; -- Open for input.
SELECT ansMsg FROM
'Y => NULL; -- ansArg is really aaa.bbb where aaa is the iNode and bbb is the mtime
'N => { PutMsg[msgStream, "%g\n", ansArg]; RETURN [ansArg] }; -- ansArg = error like not found
ENDCASE => { PutMsg[msgStream, "Protocol error\n"]; RETURN ["Protocol error"] };
[ansMsg, ansArg] м BridgeComm.PutMsgWithReply[nsp, 'R]; -- Read current file
SELECT ansMsg FROM
'D => NULL; -- ansArg is the number of bytes in the file as reported by stat
'N => { PutMsg[msgStream, "%g\n", ansArg]; RETURN [ansArg] }; -- stat error
ENDCASE => { PutMsg[msgStream, "Protocol error\n"]; RETURN ["Protocol error"] };
ansArgNumeric м Convert.CardFromRope[ansArg -- really bytes in the file
! Convert.Error => ansArgNumeric м CARD.LAST];
IF ansArgNumeric = 0
THEN {
Process.PauseMsec[500] -- Kludge -- ; actionProcQuit м FALSE;
}
ELSE {
actionProcQuit м action[nsp, ansArgNumeric, NIL]; -- send the bits.  Should only get ansArgNumeric (byte count)
IF actionProcQuit THEN IO.Reset[nsp.in];
};
WHILE NetworkStream.GetStreamState[nsp.in, TRUE].streamState # open DO NULL ENDLOOP;
[] м BridgeComm.PutMsgWithReply[nsp, 'i]; -- close the file
PutMsg[msgStream, IF actionProcQuit THEN "aborted\n" ELSE "ok\n"];
};


MkTempName: PROC [name: ROPE] RETURNS [tempName: ROPE] ~ {
tempName м IO.PutFR["%g.%g", [rope[name]], [cardinal[BasicTime.ToNSTime[BasicTime.Now[]]]] ];
};

StoreStream: PUBLIC PROC [nsp: NetworkStreamPair, remoteName: ROPE, overwrite: BOOL, action: ActionProc, clientData: REF м NIL, msgStream: STREAM м NIL] RETURNS [excuse: ROPE м NIL]
~ {
ENABLE {
ABORTED => {
excuse м "aborted";
CONTINUE };
BridgeComm.Error => {
PutMsg[msgStream, "Communication error: %g\n", msg];
excuse м "Bridge communication error";
CONTINUE };
IO.Error, NetworkStream.Error => {
PutMsg[msgStream, "I/O error\n"];
excuse м "I/O error";
CONTINUE };
};
ansMsg: CHAR;
ansArg: ROPE;
tempName: ROPE;
actionProcQuit: BOOL;

IF overwrite
THEN {
PutMsg[msgStream, "Writing %g ... ", remoteName];
[ansMsg, ansArg] м BridgeComm.PutMsgWithReply[nsp, 'O, remoteName];
SELECT ansMsg FROM
'Y => NULL;
'N => { PutMsg[msgStream, "%g\n", ansArg]; RETURN [ansArg] };
ENDCASE => { PutMsg[msgStream, "Protocol error\n"]; RETURN ["Protocol error"] };
BridgeComm.PutMsg[nsp, 'W];
actionProcQuit м action[nsp, -1, NIL];
NetworkStream.SendEndOfMessage[nsp.out];
[ansMsg, ansArg] м BridgeComm.GetMsg[nsp];
SELECT ansMsg FROM
'Y => NULL;
'N => { PutMsg[msgStream, "%g\n", ansArg]; RETURN [ansArg] };
ENDCASE => { PutMsg[msgStream, "Protocol error\n"]; RETURN ["Protocol error"] };
[] м BridgeComm.PutMsgWithReply[nsp, 'o];
PutMsg[msgStream, IF actionProcQuit THEN "aborted\n" ELSE "ok\n"];
}
ELSE {
PutMsg[msgStream, "Storing to temporary ... "];
tempName м MkTempName[remoteName];
[ansMsg, ansArg] м BridgeComm.PutMsgWithReply[nsp, 'N, tempName];
SELECT ansMsg FROM
'Y => NULL;
'N => { PutMsg[msgStream, "%g\n", ansArg]; RETURN [ansArg] };
ENDCASE => { PutMsg[msgStream, "Protocol error\n"]; RETURN ["Protocol error"] };
BridgeComm.PutMsg[nsp, 'W];
actionProcQuit м action[nsp, -1, NIL];
NetworkStream.SendEndOfMessage[nsp.out];
[ansMsg, ansArg] м BridgeComm.GetMsg[nsp];
SELECT ansMsg FROM
'Y => NULL;
'N => { PutMsg[msgStream, "%g\n", ansArg]; RETURN [ansArg] };
ENDCASE => { PutMsg[msgStream, "Protocol error\n"]; RETURN ["Protocol error"] };
[ansMsg, ansArg] м BridgeComm.PutMsgWithReply[nsp, 'o];
SELECT ansMsg FROM
'Y => NULL;
'N => { PutMsg[msgStream, "%g\n", ansArg]; RETURN [ansArg] };
ENDCASE => { PutMsg[msgStream, "Protocol error\n"]; RETURN ["Protocol error"] };
IF actionProcQuit
THEN {
PutMsg[msgStream, "aborted\n"];
}
ELSE {
PutMsg[msgStream, "renaming temporary to %g ... ", remoteName];
[ansMsg, ansArg] м BridgeComm.PutMsgWithReply[nsp, 'M,
Rope.Cat[tempName, " ", remoteName]];
SELECT ansMsg FROM
'Y => NULL;
'N => { PutMsg[msgStream, "%g\n", ansArg]; RETURN [ansArg] };
ENDCASE => { PutMsg[msgStream, "Protocol error\n"]; RETURN ["Protocol error"] };
PutMsg[msgStream, "ok\n"];
};
};
};


PutMsg: PROC [s: STREAM, fmt: ROPE, msg: ROPE м NIL] ~ {
ENABLE IO.Error => CONTINUE;
IF (s # NIL) THEN IO.PutF1[s, fmt, IF msg # NIL THEN [rope[msg]] ELSE [null[]]];
};

}...

  Т  
BridgeFTPOpsImpl.mesa
Copyright ╙ 1987, 1988, 1989, 1992 by Xerox Corporation.  All rights reserved.
Demers, October 12, 1990 12:22 pm PDT
Tim Diebert: September 11, 1989 9:49:57 am PDT
Willie-s, January 29, 1992 6:21 pm PST

The following tries to work around host failure to send back-to-back EOM's reliably ...
TODO: IF actionProcQuit then delete the file!  (someday we'll have file delete?)
Э╩K  Ц(cedarcode) styleХNewlineDelimiter
Щ codeЪЬЩKЪЬ
╧eЬCЩNKЩ%KЩ.KЩ&KЩ ЧЪ╧k	Ш	KШ
KЪЬШKЪЬШKЪЬШKЪЮЬШKШKЪЬШKЪЬШKШKШ ЧЪ╧nЬЮЬЮШKЪЮЬ!ЮЬШHKЪЮЬШKШKШ KЪЮЬЮЬЮЬШKЪЮЬЮЬЮЬЮЬШKЪЬЮЬ Ш7KШ KЪЬЮЬШ+KШ Ъ╨bnЬЮЬЮЬ&ЮЬ"ЮЬЮЬЮЬЮЬЮЬ
ЮЬЮЬШзKШЪЮЬШЪЮЬШKШKЪЮЬШЧЪЬШKЪЬ4Ш4KШ&KЪЮЬШЧЪЮЬ Ш"KЪЬ!Ш!KШKЪЮЬШЧKШЧKЪЬЮЬШKЪЬЮЬШKЪЬЮЬШKЪЬЮЬШKЪЬ9Ш9KЪЬD╧cШVЪЮЬЮШKЪЬЮЬбGШSKЪЬ+ЮЬб Ш^KЪЮЬ-ЮЬШPЧKЪЬ8бШLЪЮЬЮШKЪЬЮЬб@ШLKЪЬ+ЮЬбШKKЪЮЬ-ЮЬШPЧKЩWЪЬ,бШGKЪЬ#ЮЬЮЬШ.ЧЪЮЬШЪЮЬШKЪЬбЬЮЬШ=KЪЬШЧЪЮЬШKЪЬ,ЮЬб=ШoKЪЮЬЮЬЮЬШ(KШЧЧKЪ
ЮЬ&ЮЬЮЬЮЬЮЬШTKЪЬ*бШ;KЪЬЮЬЮЬЮЬ	ШBKШKШ KШ ЧЪ
Я
ЬЮЬЮЬЮЬЮЬШ:KЪЬЮЬPШ]KШKШ ЧЪаЬЮЬЮЬ&ЮЬЮЬ"ЮЬЮЬЮЬЮЬЮЬ
ЮЬЮЬШ╡KШЪЮЬШЪЮЬШKШKЪЮЬШЧЪЬШKЪЬ4Ш4KШ&KЪЮЬШЧЪЮЬ Ш"KЪЬ!Ш!KШKЪЮЬШЧKШЧKЪЬЮЬШKЪЬЮЬШKЪЬ
ЮЬШKЪЬЮЬШKШ ЪЮЬ
ШЪЮЬШKЪЬ1Ш1KШCЪЮЬЮШKЪЬЮЬШKЪЬ+ЮЬШ=KЪЮЬ-ЮЬШPЧKЪЬШKЪЬ!ЮЬШ&KЪЬ(Ш(KШ*ЪЮЬЮШKЪЬЮЬШKЪЬ+ЮЬШ=KЪЮЬ-ЮЬШPЧKШ)KЪЮЬЮЬHЩPKЪЬЮЬЮЬЮЬ	ШBKШЧЪЮЬШKЪЬ/Ш/KШ"KШAЪЮЬЮШKЪЬЮЬШKЪЬ+ЮЬШ=KЪЮЬ-ЮЬШPЧKЪЬШKЪЬ!ЮЬШ&KЪЬ(Ш(KШ*ЪЮЬЮШKЪЬЮЬШKЪЬ+ЮЬШ=KЪЮЬ-ЮЬШPЧKШ7ЪЮЬЮШKЪЬЮЬШKЪЬ+ЮЬШ=KЪЮЬ-ЮЬШPЧЪЮЬШЪЮЬШKЪЬШKШЧЪЮЬШKЪЬ?Ш?KШ\ЪЮЬЮШKЪЬЮЬШKЪЬ+ЮЬШ=KЪЮЬ-ЮЬШPЧKЪЬШKШЧЧKШЧЧKШKШ KШ ЧЪЯЬЮЬЮЬЮЬЮЬЮЬШ8KЪЮЬЮЬ
ЮЬШKЪЮЬЮЬЮЬЮЬЮЬЮЬЮЬЮЬШPKШKШ ЧKШЧKШ Ч ЕЧ    F  #  