
DIRECTORY
BridgeComm,
BridgeExec,
IO,
NetworkStream,
Process,
Rope
;

BridgeCommImpl: CEDAR PROGRAM
IMPORTS IO, NetworkStream, Process, Rope
EXPORTS BridgeComm
~ {

ROPE: TYPE ~ Rope.ROPE;
NetworkStreamPair: TYPE ~ BridgeExec.NetworkStreamPair;

Error: PUBLIC ERROR [msg: ROPE] ~ CODE;

GetRopeToEOM: PUBLIC PROC [nsp: NetworkStreamPair] RETURNS [rope: ROPE м NIL] ~ {
rope м IO.GetRope[nsp.in];
DO {
state: NetworkStream.StreamState;
[streamState~state] м NetworkStream.GetStreamState[nsp.in, TRUE];
IF state = open OR state = remoteClosed THEN EXIT;
} ENDLOOP;
};

GetMsg: PUBLIC PROC [nsp: NetworkStreamPair] RETURNS [msg: CHAR, arg: ROPE] ~ {
ENABLE {
NetworkStream.Error -- [..., msg] -- => ERROR Error[msg];
IO.Error -- [..., stream] -- => ERROR Error[ Rope.Concat["I/O error", NetworkStream.GetIOErrorDetails[stream].msg ]];
IO.EndOfStream => ERROR Error["end of stream"];
};
msg м IO.GetChar[nsp.in];
arg м GetRopeToEOM[nsp];
};
PutMsg: PUBLIC PROC [nsp: NetworkStreamPair, msg: CHAR, arg: ROPE м NIL] ~ {
ENABLE {
NetworkStream.Error -- [..., msg] -- => ERROR Error[msg];
NetworkStream.Timeout -- [..., msg] -- => ERROR Error["timeout"];
IO.Error -- [..., stream] -- => ERROR Error[ Rope.Concat["I/O error", NetworkStream.GetIOErrorDetails[stream].msg ]];
};
IO.PutChar[nsp.out, msg];
IO.PutRope[nsp.out, arg];
NetworkStream.SendEndOfMessage[nsp.out];
};

PutMsgWithReply: PUBLIC PROC [nsp: NetworkStreamPair, msg: CHAR, arg: ROPE м NIL]
RETURNS [ansMsg: CHAR, ansArg: ROPE] ~ {
PutMsg[nsp, msg, arg];
NetworkStream.SendSoon[nsp.out, 0];
[ansMsg, ansArg] м GetMsg[nsp];
};

PutMsgWithAck: PUBLIC PROC [nsp: NetworkStreamPair, msg: CHAR, arg: ROPE м NIL] ~ {
ansMsg: CHAR;
ansArg: ROPE;
PutMsg[nsp, msg, arg];
NetworkStream.SendSoon[nsp.out, 0];
[ansMsg, ansArg] м GetMsg[nsp];
IF ansMsg # 'Y THEN ERROR Error[ IF ansMsg = 'N THEN ansArg ELSE NIL ];
};

closeRequestSST: NetworkStream.SubStreamType м 254;
closeReplySST: NetworkStream.SubStreamType м 255;

CloseConnectionWorker: PROC [nsp: NetworkStreamPair, action: BridgeComm.CloseHandshakeAction] ~ {
SELECT action FROM
initiate => IF nsp.out # NIL THEN {
ENABLE IO.Error, NetworkStream.Error, NetworkStream.Timeout => CONTINUE;
NetworkStream.SetTimeout[nsp.out, 2000];
NetworkStream.SetSubStreamType[nsp.out, closeRequestSST];
NetworkStream.SendSoon[nsp.out, 0];
};
ENDCASE;
SELECT action FROM
initiate => IF nsp.in # NIL THEN {
ENABLE IO.Error, IO.EndOfStream, NetworkStream.Error, NetworkStream.Timeout => CONTINUE;
reply: NetworkStream.SubStreamType;
state: NetworkStream.StreamState;
NetworkStream.SetTimeout[nsp.in, 2000];
DO
IO.Reset[nsp.in];
[streamState~state, subStreamType~reply] м NetworkStream.GetStreamState[nsp.in, TRUE];
IF state = remoteClosed THEN EXIT;
IF reply = closeReplySST THEN EXIT;
ENDLOOP;
};
ENDCASE;
IF nsp.in # NIL THEN {
ENABLE IO.Error, IO.EndOfStream, NetworkStream.Error, NetworkStream.Timeout => CONTINUE;
IO.Close[nsp.in, TRUE];
};
SELECT action FROM
initiate, reply => IF nsp.out # NIL THEN {
ENABLE IO.Error, NetworkStream.Error, NetworkStream.Timeout => CONTINUE;
NetworkStream.SetTimeout[nsp.out, 2000];
NetworkStream.SetSubStreamType[nsp.out, closeReplySST];
NetworkStream.SendSoon[nsp.out, 0];
NetworkStream.WaitAck[nsp.out, 2000];
};
ENDCASE => NULL;
IF nsp.out # NIL THEN {
ENABLE IO.Error, NetworkStream.Error, NetworkStream.Timeout => CONTINUE;
IO.Close[nsp.out, TRUE];
};
};

CloseConnection: PUBLIC PROC [nsp: NetworkStreamPair, action: BridgeComm.CloseHandshakeAction] ~ {
TRUSTED {
Process.Detach[ FORK CloseConnectionWorker[nsp, action] ];
};
};

}...

   T  
BridgeCommImpl.mesa
Copyright ╙ 1992 by Xerox Corporation.  All rights reserved.
Demers, February 13, 1991 12:39 pm PST
Peter B. Kessler February 25, 1988 12:04:29 pm PST
Tim Diebert: August 30, 1989 5:57:32 am PDT
Chauser, April 14, 1993 10:22 am PDT
Read to EOM and return chars read as a rope.  Clear the EndOfStream condition.

 Э╩у  Ц(cedarcode) styleХNewlineDelimiter
Щ codeЩKЪЬ
╧eЬ1Щ<KЩ&KЩ2KЩ+KЩ$KШ ЧЪ╧k	Ш	KЪЬШKШKЪЮЬШKШKШKЪЬШKШKШ ЧЪ╧nЬЮЬЮШKЪЮЬЮЬШ(KЪЮЬШKЪЬШKШ KЪЮЬЮЬЮЬШKЪЬЮЬ Ш7KШ KЪЯЬЮЬЮЬЮЬШ'KШ Ъ
ЯЬЮЬЮЬЮЬЮЬШQKЩNKЪЬЮЬШЪЮЬШKЪЬ!Ш!KЪЬ;ЮЬШAKЪЮЬЮЬЮЬЮЬШ2KЪЬЮЬШ
ЧKШЧKШ Ъ
ЯЬЮЬЮЬЮЬЮЬШOЪЮЬШKЪЬ╧cЬЮЬШ9KЪЮЬаЬЮЬPШuKЪЮЬЮЬШ/KШЧKЪЬЮЬШKШKШKЩ ЧЪЯЬЮЬЮЬЮЬЮЬЮЬШLЪЮЬШKЪЬаЬЮЬШ9KЪЬаЬЮЬШAKЪЮЬаЬЮЬPШuKШЧKЪЮЬШKЪЮЬШKЪЬ(Ш(KШKШ ЧЪЯЬЮЬЮЬЮЬЮЬЮЬЮЬ
ЮЬ
ЮЬШzKЪЬШKШ#KШKШKШ ЧЪЯЬЮЬЮЬЮЬЮЬЮЬШSKЪЬЮЬШKЪЬЮЬШKЪЬШKШ#KШKЪЮЬЮЬЮЬЮЬЮЬЮЬЮЬШGKШKШ ЧKШ3KШ1KШ ЪЯЬЮЬFШaЪЮЬЮШЪЬЮЬЮЬЮЬШ#KЪЮЬЮЬ6ЮЬШHKЪЬ(Ш(KШ9KШ#KШЧKЪЮЬШЧЪЮЬЮШЪЬЮЬ
ЮЬЮЬШ"KЪЮЬЮЬЮЬ<ЮЬШXKЪЬ#Ш#KЪЬ!Ш!KЪЬ'Ш'ЪЮШKЪЮЬШKЪЬPЮЬШVKЪЮЬЮЬЮЬШ"KЪЮЬЮЬЮЬШ#KЪЮЬШЧKШЧKЪЮЬШЧЪЮЬ
ЮЬЮЬШKЪЮЬЮЬЮЬ<ЮЬШXKЪЮЬЮЬШKШЧЪЮЬЮШЪЬЮЬЮЬЮЬШ*KЪЮЬЮЬ6ЮЬШHKЪЬ(Ш(KШ7KШ#KШ%KШЧKЪЮЬЮЬШЧЪЮЬЮЬЮЬШKЪЮЬЮЬ6ЮЬШHKЪЮЬЮЬШKШЧKШKШ ЧЪЯЬЮЬЮЬFШbЪЮЬШ	ЪЬЮЬ&Ш:KШЧЧKШЧKШ KШЧKШ Ч ЕЧ    Ё  '  