DIRECTORY IO, Process, Protocols, PupDefs, PupStream, PupTypes, Rope, UserCredentials;PupTelnet: CEDAR MONITORLOCKS pc USING pc: PupConversationIMPORTS IO, Process, Protocols, PupDefs, PupStream, Rope, UserCredentials = {OPEN Protocols;pupTelnet: Protocol _ NEW [ProtocolRep _ [name: "PupTelnet",Connect: Connect,Disconnect: Disconnect]];PupConversation: TYPE = REF PupConversationRep;PupConversationRep: TYPE = MONITORED RECORD [serverName: ROPE,fromClient, toClient, serverStream: IO.STREAM _ NIL,charsSentSinceFlush: NAT _ 0,procs: ARRAY Who OF PROCESS,procing: ARRAY Who OF BOOL _ ALL[TRUE],looping: ARRAY Who OF BOOL _ ALL[FALSE],open: BOOL _ TRUE];Who: TYPE = {uToS, sToU};whoBar: ARRAY Who OF Who _ [uToS: sToU, sToU: uToS];MarkByte: TYPE = [0..256);setLineWidth: MarkByte = 2;setPageLength: MarkByte = 3;timingMark: MarkByte = 5;timingMarkReply: MarkByte = 6;doSetLineWidth: BOOL _ TRUE;Connect: PROC[serverName: ROPE,fromClient, toClient: IO.STREAM,noteDisconnect: PROC [clientData: REF ANY] _ NIL,clientData: REF ANY _ NIL,login: BOOL _ FALSE]RETURNS [c: Conversation] ={pc: PupConversation _ NEW [PupConversationRep _ [serverName: serverName,fromClient: fromClient,toClient: toClient]];addr: PupDefs.PupAddress;c _ NIL;PupDefs.PupPackageMake[];toClient.PutF["Opening connection to %g ... ", IO.rope[serverName]];addr _ PupStream.GetPupAddress[PupTypes.telnetSoc, serverName! PupStream.PupNameTrouble =>{toClient.PutRope["PUP name error"];FinishStringWithErrorMsg[toClient, e];GOTO Return;}];pc.serverStream _ PupStream.PupByteStreamCreate[addr, PupStream.SecondsToTocks[1]! PupStream.StreamClosing =>{toClient.PutRope["Can't connect"];FinishStringWithErrorMsg[toClient, text];GOTO Return;}];toClient.PutF["open.\015\012"];c _ NEW [ConversationRep _ [protocol: pupTelnet,noteDisconnect: noteDisconnect, clientData: clientData,data: pc]];IF doSetLineWidth THEN {PupStream.SendMark[pc.serverStream, setLineWidth]; pc.serverStream.PutChar[0C];pc.serverStream.Flush[];};IF login THEN {name, password: Rope.ROPE;[name: name, password: password] _ UserCredentials.Get[];pc.serverStream.PutRope["Login "];pc.serverStream.PutRope[name];IF Rope.Find[s1: name, s2: "."] = -1 THEN pc.serverStream.PutRope[".PA"];pc.serverStream.PutRope[" "];pc.serverStream.PutRope[password];pc.serverStream.PutRope[" \n"];pc.serverStream.Flush[];};TRUSTED {Process.Detach[pc.procs[uToS] _ FORK UserToServer[c, pc]];Process.Detach[pc.procs[sToU] _ FORK ServerToUser[c, pc]];};EXITSReturn => NULL;};Disconnect: PROC [c: Conversation] = {pc: PupConversation _ NARROW[c.data];IF pc.open THEN CloseConnection[pc, TRUE]};flushPeriod: NAT _ 50;UserToServer: PROC [c: Conversation, pc: PupConversation] = {char: CHAR;report: BOOL _ TRUE;{ENABLE UNWIND => Exit[c, pc, uToS];SetLooping[pc, uToS, TRUE];WHILE pc.open DOENABLE {PupStream.StreamClosing => {IF pc.open THEN {pc.toClient.PutF["\015\012Connection being closed by %s", IO.rope[pc.serverName]];FinishStringWithErrorMsg[pc.toClient, text, " ... "];report _ FALSE;};EXIT;};IO.EndOfStream, IO.Error, ABORTED => EXIT;};char _ pc.fromClient.GetChar[];IF NOT pc.open THEN {pc.fromClient.Backup[char];EXIT;};pc.serverStream.PutChar[char];IF pc.charsSentSinceFlush >= flushPeriod OR pc.fromClient.CharsAvail[] = 0 THEN {pc.serverStream.Flush[];pc.charsSentSinceFlush _ 0;}ELSE pc.charsSentSinceFlush _ pc.charsSentSinceFlush + 1;ENDLOOP;SetLooping[pc, uToS, FALSE];IF pc.open THEN CloseConnection[pc, report];};Exit[c, pc, uToS];};ServerToUser: PROC [c: Conversation, pc: PupConversation] = {char: CHAR;report: BOOL _ TRUE;{ENABLE UNWIND => Exit[c, pc, sToU];SetLooping[pc, sToU, TRUE];WHILE pc.open DOENABLE {PupStream.StreamClosing => {IF pc.open THEN {pc.toClient.PutF["\015\012Connection being closed by %s", IO.rope[pc.serverName]];FinishStringWithErrorMsg[pc.toClient, text, " ... "];report _ FALSE;};EXIT;};IO.EndOfStream, IO.Error, ABORTED => EXIT;};IF pc.serverStream.EndOf[] THEN {mySST: MarkByte;mySST _ PupStream.ConsumeMark[pc.serverStream];IF mySST = timingMark THEN PupStream.SendMark[pc.serverStream, timingMarkReply];};char _ pc.serverStream.GetChar[!PupStream.TimeOut => RESUME;IO.EndOfStream => LOOP;];IF NOT pc.open THEN EXIT;pc.toClient.PutChar[char];ENDLOOP;SetLooping[pc, sToU, FALSE];IF pc.open THEN CloseConnection[pc, report];};Exit[c, pc, sToU];};SetLooping: ENTRY PROC [pc: PupConversation, who: Who, ing: BOOL] ={pc.looping[who] _ ing};Exit: PROC [c: Conversation, pc: PupConversation, who: Who] = {whoElse: Who _ whoBar[who];LastOneOut: ENTRY PROC [pc: PupConversation] RETURNS [last: BOOL] = {pc.procing[who] _ FALSE;pc.looping[who] _ FALSE;last _ NOT pc.procing[whoElse];};IF whoElse = who THEN ERROR;IF NOT LastOneOut[pc] THEN RETURN;pc.toClient.PutRope[" ... closed\015\012" !IO.Error => CONTINUE];IF c.noteDisconnect # NIL THEN c.noteDisconnect[c.clientData];pc.serverStream.Close[!IO.Error => CONTINUE];pc.serverStream _ NIL;	-- could cause pointer faults!PupDefs.PupPackageDestroy[];};FinishStringWithErrorMsg: PROC [toClient: IO.STREAM, errorMsg: ROPE, ending: ROPE _ ".\015\012"] = {IF errorMsg # NIL THEN toClient.PutF[":\t%s", IO.rope[errorMsg]];toClient.PutRope[ending];};CloseConnection: PROC [pc: PupConversation, report: BOOL] = {rawSelf: UNSAFE PROCESS;self: PROCESS;AbortEm: ENTRY PROC [pc: PupConversation] = TRUSTED {IF pc.procs[uToS] # self AND pc.looping[uToS]THEN Process.Abort[pc.procs[uToS] !Process.InvalidProcess => CONTINUE];IF pc.procs[sToU] # self AND pc.looping[sToU]THEN Process.Abort[pc.procs[sToU] !Process.InvalidProcess => CONTINUE];};TRUSTED {rawSelf _ Process.GetCurrent[];self _ LOOPHOLE[rawSelf]};IF report THEN pc.toClient.PutF["\015\012Closing connection to %s ...", IO.rope[pc.serverName] ! IO.Error => CONTINUE];pc.open _ FALSE;pc.serverStream.Close[TRUE !IO.Error => CONTINUE];AbortEm[pc];};Protocols.RegProtocol[pupTelnet];}.    P  PupTelnet.MesaLast Edited by: Spreitzer, March 20, 1985 11:42:17 am PST Э╩"  Ц"cedar" styleШ IcodeЩKЩ9KШ KЪ╧k	ЬЭЬJШVKШ Ъ╨bx	ЬЭЬЭШKЪЭЬЭЬШ"KЪЭЬЭЬ?ШIKШ KЪЬЭЬШKШ ЪЬЭЬШ*KШKЪЬШKЪЬШKШЧKШ KЪЬЭЬЭЬШ/ЪЬЭЬЭ	ЬЭЬШ-KЪЬЭЬШKЪЬ$ЭЬЭЬЭЬШ4KЪЬЭЬШKЪЬЭЬЭЬЭЬШKЪЬ	ЭЬЭЬЭЬЭЬЭЬШ'KЪЬ	ЭЬЭЬЭЬЭЬЭЬШ(KЪЬЭЬЭЬШЧKШ KЪЬЭЬШKЪЬЭЬЭЬ Ш4KШ KЪЬ
ЭЬШKШKШKШKШKШ KЪЬЭЬЭЬШKШ Ъ╧nЬЭШЪЬШKЪЬЭЬШKЪЬЭЬЭЬШ KЪ	ЬЭЬЭЬЭЬЭЬШ1KЪЬЭЬЭЬЭЬШKЪЬЭЬЭЬШЧKЪЭЬШKЪЬШЪЬЭЬШ1KЪЬШKЪЬШKЪЬШЧKШKЪЬЭЬШKШKЪЬ/ЭЬШDШ=ШШKЪЬ#Ш#KЪЬ&Ш&KЪЭЬШЧKШЧKШЧШQШШKЪЬ"Ш"KЪЬ)Ш)KЪЭЬШЧKШЧKШЧKЪЬШЪЬЭЬШKЪЬШKЪЬ7Ш7KЪЬШЧЪЭЬЭЬШKЪЬ3Ш3KЪЬШKЪЬШKШЧЪЭЬЭЬШKЪЬЭЬШJШ9JЪЬ"Ш"JЪЬШJЪЭЬ#ЭЬ ШIJЪЬШJЪЬ"Ш"JЪЬШJЪЬШJШЧЪЭЬШ	KЪЬ ЭЬШ:KЪЬ ЭЬШ:KЪЬШЧЪЭШKЪЬ
ЭЬШЧKШЧKШ ЪЯ
ЬЭЬШ&KЪЬЭЬ	Ш%KЪЭЬ	ЭЬЭЬШ+ЧKШ KЪЬЭЬШKШ ЪЯЬЭЬ+Ш=KЪЬЭЬШЪЬЭЬЭЬШKЪЬЭЬЭЬШ$KЪЬЭЬШЪЭЬ	ЭШЪЭЬШЪЬШЪЭЬ	ЭЬШKЪЬ:ЭЬШRKШ5KЪЬ	ЭЬШKШЧKЪЭЬШKШЧKЪЭЬЭЬЭЬЭЬШ*KШЧKШЪЭЬЭЬ	ЭЬШKЪЬШKЪЭЬШKШЧKШЪЭЬ'ЭЬ ЭЬШQJШJЪЬШJШЧJЪЭЬ5Ш9KЪЭЬШЧKЪЬЭЬШKЪЭЬ	ЭЬШ,KШЧKШKШЧKШ ЪЯЬЭЬ+Ш=KЪЬЭЬШЪЬЭЬЭЬШKЪЬЭЬЭЬШ$KЪЬЭЬШЪЭЬ	ЭШЪЭЬШШЪЭЬ	ЭЬШKЪЬ:ЭЬШRKШ5KЪЬ	ЭЬШKШЧKЪЭЬШJШЧKЪЭЬЭЬЭЬЭЬШ*JШЧЪЭЬЭЬШ!KШKШ/KЪЭЬЭЬ6ШPKШЧШ JЪЬЭЬШJЪЭЬЭЬШJЪЬШЧJЪЭЬЭЬ	ЭЬЭЬШJШJЪЭЬШЧKЪЬЭЬШKЪЭЬ	ЭЬШ,KШЧKШKШЧKШ ЪЯ
ЬЭЬЭЬ&ЭЬШCKШЧKШ ЪЯЬЭЬ5Ш?KШЪ
Я
ЬЭЬЭЬЭЬЭЬШEKЪЬЭЬШKЪЬЭЬШKЪЬЭЬШKШЧJЪЭЬЭЬЭЬШJЪЭЬЭЬЭЬЭЬШ"JЪЬ+ЭЬ
ЭЬШAJЪЭЬЭЬЭЬ Ш>KЪЬЭЬ
ЭЬШ-JЪЬЭЬ╧cШ5JШKШЧKШ ЪЯЬЭЬЭЬЭЬЭЬ
ЭЬШdKЪЭЬЭЬЭЬЭЬШAKЪЬШKШЧKШ ЪЯЬЭЬЭЬШ=KЪЬ	ЭЬЭЬШKЪЬЭЬШЪЯЬЭЬЭЬЭЬШ5ЪЭЬЭЬШ-KЪЭЬ9ЭЬШGЧЪЭЬЭЬШ-KЪЭЬ9ЭЬШGЧKШ KШЧЪЭЬШ	KЪЬШKЪЬЭЬШЧKЪ
ЭЬЭЬ:ЭЬЭЬ
ЭЬШwKЪЬ
ЭЬШKЪЬЭЬЭЬ
ЭЬШ2KЪЬШKШЧKШ KШ!KШ KШЧЧ ЕЧ    Ю     