DIRECTORYArpa USING [Address],ArpaExtras USING [MyAddress],Commander USING [CommandProc, Register],IO USING [Close, EndOf, EndOfStream, Error, Flush, GetChar, GetLineRope, int, PutBlock, PutChar, PutF, PutFR, PutRope, rope, STREAM],Process USING [Milliseconds, PauseMsec],Rope USING [Cat, Find, FromChar, Length, ROPE],UserCredentials USING [Get],ArpaTCP USING [AbortTCPStream, CreateTCPStream, Error, ErrorFromStream, neverTimeout, Reason, Timeout, WaitForListenerOpen];ArpaTCPTest: CEDAR PROGRAMIMPORTS ArpaExtras, Commander, IO, Process, Rope, UserCredentials, ArpaTCP =BEGINfingerSocket: INT = 79;sinkSocket: INT = 531;me: Arpa.Address _ ArpaExtras.MyAddress[];cslSun: Arpa.Address _ [13, 1, 100, 206];parcvax: Arpa.Address _  [13, 2, 16, 8];remoteAddress: Arpa.Address _ me;totalsize: INT _ 100000;blocksize: INT _ 8192;running: BOOL _ TRUE;server: PROCESS;Finger: Commander.CommandProc = {out: IO.STREAM _ cmd.out;fingerStream: IO.STREAM;c: CHAR;cr: ArpaTCP.Reason _ neverOpen;{ENABLE {ArpaTCP.Timeout => {out.PutRope["[No response.]\n"];GO TO GiveUp;};ArpaTCP.Error => {cr _ reason;GO TO GiveUp;};IO.Error => {cr _ ArpaTCP.ErrorFromStream[fingerStream];GOTO GiveUp;};};fingerStream _ ArpaTCP.CreateTCPStream[[matchLocalPort~FALSE, localPort~0, matchForeignAddr~TRUE, foreignAddress~remoteAddress, matchForeignPort~TRUE, foreignPort~fingerSocket, active~TRUE, timeout~120000]];ArpaTCP.WaitForListenerOpen[fingerStream, ArpaTCP.neverTimeout];fingerStream.PutRope[cmd.commandLine];fingerStream.PutChar['\l];	-- send the LF as wellfingerStream.Flush[];WHILE NOT fingerStream.EndOf[] DOc _ fingerStream.GetChar[ ! IO.EndOfStream => EXIT];IF c # '\l THEN out.PutChar[c];ENDLOOP;fingerStream.Close[];EXITSGiveUp =>SELECT cr FROMremoteAbort => out.PutRope["[Remote host refused to point the finger at its users.]\n"];ENDCASE => ArpaTCP.AbortTCPStream[fingerStream];};};StartFingerServer: Commander.CommandProc = {running _ TRUE;server _ FORK FingerServer[];msg _ "TCP finger server started.";};FingerServer: PROC = {ENABLE ArpaTCP.Timeout => RESUME;fingerStream: IO.STREAM;WHILE running DOENABLE BEGINIO.Error => RETRY;ArpaTCP.Timeout => RETRY;ArpaTCP.Error => RETRY;END;char: CHAR;rope: Rope.ROPE _ NIL;fingerStream _ ArpaTCP.CreateTCPStream[[matchLocalPort: TRUE, localPort: fingerSocket, matchForeignAddr: FALSE, matchForeignPort: FALSE, active: FALSE]];DOchar _ fingerStream.GetChar[];IF char = '\l THEN EXIT;rope _ Rope.Cat[rope, Rope.FromChar[char]];ENDLOOP;fingerStream.PutF["User %g logged in on a Dorado.\n\l", IO.rope[UserCredentials.Get[].name]];IF Rope.Find[rope, "Verbose"] # -1 THENTHROUGH [0..20) DOfingerStream.PutF[" 123456789 123456789 123456789 123456789 123456789\n\l"];ENDLOOP;IF Rope.Find[rope, "Super"] # -1 THENTHROUGH [0..200) DOfingerStream.PutF[" 123456789 123456789 123456789 123456789 123456789\n\l"];ENDLOOP;fingerStream.Flush[];fingerStream.Close[];ENDLOOP;};CharTest: Commander.CommandProc = {IO.PutF[cmd.out, "Starting to send data in character mode.\n"];msg _ SendData[blockmode: FALSE];};BlockTest: Commander.CommandProc = {IO.PutF[cmd.out, "Starting to send data in block mode.\n"];msg _ SendData[blockmode: TRUE];};SendData: PROC[blockmode: BOOLEAN _ TRUE, waitForResult: BOOLEAN _ FALSE] RETURNS [result: Rope.ROPE _ NIL] = {stillToDo: INT;tcpStream: IO.STREAM;headerForm: Rope.ROPE = "t%09g ";header: Rope.ROPE;block: REF TEXT _ NEW[TEXT[blocksize]];block.length _ blocksize;tcpStream _ ArpaTCP.CreateTCPStream[[foreignAddress~remoteAddress, foreignPort~sinkSocket, active~TRUE, timeout~200000]];header _ IO.PutFR[headerForm, IO.int[0]];header _ IO.PutFR[headerForm, IO.int[totalsize + Rope.Length[header]]];{ -- nested block to catch errorsENABLE {ArpaTCP.Timeout => {result _ "ArpaTCP.Timeout on TCP stream"; GOTO GiveUp}; ArpaTCP.Error => {result _ "ArpaTCP.Error on TCP stream"; GOTO GiveUp}; IO.Error => {result _ "IO.Error on TCP stream"; GOTO GiveUp};};IO.PutF[tcpStream, header];IO.Flush[tcpStream];stillToDo _ totalsize;FOR left: INT _ totalsize-blocksize, left - blocksize UNTIL left < 0 DOIF blockmodeTHEN IO.PutBlock[tcpStream, block, 0, blocksize]ELSE FOR count: INT IN [0..blocksize) DOIO.PutChar[tcpStream, 'w];ENDLOOP;IO.Flush[tcpStream];stillToDo _ left;ENDLOOP;IF blockmodeTHEN IO.PutBlock[tcpStream, block, 0, stillToDo]ELSE FOR count: INT IN [0..stillToDo) DOIO.PutChar[tcpStream, 'w];ENDLOOP;IO.Flush[tcpStream];IF waitForResult THENresult _ IO.GetLineRope[tcpStream ! ArpaTCP.Timeout => CONTINUE];IO.Close[tcpStream];EXITSGiveUp => ArpaTCP.AbortTCPStream[tcpStream];};};Sink: Commander.CommandProc = {server _ FORK SinkServer[];msg _ "TCP sink server started.";};charsBetweenPauses: INT _ 500;msToPause: Process.Milliseconds _ 0;SinkServer: PROC = {ENABLE ArpaTCP.Timeout => RESUME;sinkStream: IO.STREAM;charsSincePause: INT _ 0;DO -- foreversinkStream _ ArpaTCP.CreateTCPStream[[matchLocalPort: TRUE, localPort: sinkSocket, matchForeignAddr: FALSE, matchForeignPort: FALSE, active: FALSE]];DOENABLE BEGINIO.Error => EXIT;IO.EndOfStream => EXIT;ArpaTCP.Timeout => EXIT;ArpaTCP.Error => EXIT;END;char: CHAR _ sinkStream.GetChar[];charsSincePause _ charsSincePause + 1;IF charsSincePause > charsBetweenPauses THEN {IF msToPause#0 THEN Process.PauseMsec[msToPause];charsSincePause _ 0;};ENDLOOP;sinkStream.Close[ ! IO.Error => CONTINUE];ENDLOOP;};Commander.Register["TCPFinger", Finger, "Who is on host."];Commander.Register["TCPFingerServer", StartFingerServer, "Start TCP finger server on this host."];Commander.Register["TCPBlockSend", BlockTest, "Tests the 'ArpaTCP' interface."];Commander.Register["TCPCharSend", CharTest, "Tests the 'ArpaTCP' interface."];Commander.Register["TCPSink", Sink, "Start TCP server that eats whatever data is sent to it."];END.      ArpaTCPTest.mesaCopyright (C) 1983, 1984 by Xerox Corporation. All rights reserved. The following program was created in 1983 but has not been published within the meaning of the copyright law, is furnished under license, and may not be used, copied and/or disclosed except in accordance with the terms of said license.Last Edited by: Nichols, September 1, 1983 4:43 pmLast Edited by: Taft, January 22, 1984 11:28:59 am PSTLast Edited by: HGM, October 6, 1984 10:51:08 pm PDTDoug Terry, November 20, 1987 12:50:18 pm PSTHal Murray May 16, 1985 3:16:56 am PDTJohn Larson, April 14, 1986 11:34:42 pm PSTused for tests involving blocks of data being sent:SetAddress: Commander.CommandProc = {out: IO.STREAM _ cmd.out;argv: CommandTool.ArgumentVector = CommandTool.Parse[cmd !CommandTool.Failed => {out.PutRope[errorMsg]; GO TO GiveUp}];remoteAddresses: LIST OF Arpa.Address _ IPName.NameToAddress[argv[1]];IF remoteAddresses=NIL THEN {out.PutRope["Name not found"]; GOTO GiveUp};remoteAddress _ remoteAddresses.first;out.PutF["[%g.%g.%g.%g]\n", IO.int[remoteAddress[0]], IO.int[remoteAddress[1]], IO.int[remoteAddress[2]], IO.int[remoteAddress[3]]];EXITSGiveUp => NULL;};[cmd: Commander.Handle] RETURNS [result: REF ANY _ NIL, msg: ROPE _ NIL]Hack for resting reassembly via echoing to GOONHILLY-ECHO. Send big packets.Adapted from Mark Weiser:[cmd: Commander.Handle] RETURNS [result: REF ANY _ NIL, msg: ROPE _ NIL][cmd: Commander.Handle] RETURNS [result: REF ANY _ NIL, msg: ROPE _ NIL][cmd: Commander.Handle] RETURNS [result: REF ANY _ NIL, msg: ROPE _ NIL]the following can be adjusted to slow down the sink, perhaps to simulate a slow receiver or to test what happens when the senders window goes to zeroCommander.Register["SetTCPAddress", SetAddress, "Tell which remote host to use."]; ‌ت	k  –"cedar" styleک head™Icode2ڑœ¯™¯J™2Jڑœ3دk™6Jڑœ‌œ‌™4Icodeڑœ-™-Mڑœ#‌™&Mڑœ(‌™+J™ ڑ‌	ک	Lڑœ‌œکLڑœ‌œکLڑœ
‌œک(Lڑ‌œ‌œu‌œک…Mڑœ‌œک(Lڑœ‌œ‌œک/Lڑœ‌œکLڑœ‌œoک|——ڑدnœ‌œ‌کLڑ‌œ‌œ+کLLڑ‌کLڑœ‌œکMڑœ‌œکMک Mڑœ*ک*Mڑœ)ک)Mڑœ(ک(Mک Mڑœ!ک!Mک M™3Mڑœ‌œ
کMڑœ‌œکLڑœ	‌œ‌œکLڑœ‌œکڑ‍
œ™%Lڑœ‌œ‌œ™™:Lڑœدrœ‌œ‌œ
™=—Lڑœ‌œ‌œ.™FLڑ‌œ‌œ‌œ!‌œ	™ILڑœ&™&Lڑ	œ‌œ‌œ‌œ‌œ™„ڑ‌™Lڑœ
‌œ™—L™—ڑ‍œک!Lڑœ‌œ‌œںœکLڑœ‌œ‌œکLڑœ‌œکLڑœکLک کڑ‌œکڑœکLڑœ ک Lڑ‌œ‌œکLک—ڑœکLکLڑ‌œ‌œکLک—ڑ‌œکLڑœ+ک+Lڑ‌œکLک—Lک—Lڑ	œ7‌œ ‌œ1‌œ#‌œکدLڑœ@ک@Lڑœ&ک&Lڑœدcک1Lکڑ‌œ‌œ‌ک!Lڑœ‌œ‌œک4Lڑ‌œ	‌œکLڑ‌œک—Lکڑ‌کڑœ	ک	ڑ‌œ‌کLکXLڑ‌œ)ک0———Lک—Lک—•StartOfExpansionL -- [cmd: Commander.Handle] RETURNS [result: REF ANY _ NIL, msg: ROPE _ NIL]ڑ‍œک,LڑذckH™HLڑœ
‌œکLڑœ	‌œکLک#Lک—ڑ‍œ‌œکLڑ‌œ‌œک!Lڑœ‌œ‌œکLک ڑ‌œ	‌کڑ‌œ‌کLڑ‌œ
‌œکLڑœ‌œکLڑœ‌œکLڑ‌œک—Lڑœ‌œکLڑœ‌œ‌œکLڑ	œ8‌œ-‌œ‌œ
‌œک™ڑ‌کLڑœکLڑ‌œ‌œ‌œکLڑœ+ک+Lڑ‌œک—Lڑœ8‌œ#ک]ڑ‌œ!‌ک'Lڑœ+‌	œ‌œ™Lڑ‌œ	‌کLکLLڑ‌œک——ڑ‌œ‌ک%ڑ‌œ
‌کLکLLڑ‌œک——LکLکLڑ‌œک—Lک—M–L -- [cmd: Commander.Handle] RETURNS [result: REF ANY _ NIL, msg: ROPE _ NIL]ک Mڑœ™ڑ‍œک#Mڑœ‌œ
‌œ‌œ‌œ‌œ‌œ™HMڑ‌œ=ک?Mڑœ‌œک!MکMک —ڑ‍	œک$Mڑœ‌œ
‌œ‌œ‌œ‌œ‌œ™HMڑ‌œ9ک;Mڑœ‌œک MکMک —ڑ‍œ‌œ‌œ‌œ‌œ‌œ‌œ‌œ‌œکoMڑœ‌œکMڑœ‌œ‌œکMڑœ‌œک!Mڑœ‌œکMڑ	œ‌œ‌œ‌œ‌œک'MڑœکMڑœb‌œکyMڑœ	‌œ‌œ	ک)Mڑœ	‌œ‌œ'کGMڑœ ک!ڑ‌œکLڑœ>‌œ
کLLڑœ:‌œ
کHLڑ‌œ‌œ‌œ	ک=Lک—Mڑ‌œکMڑ‌œکMڑœکڑ‌œ‌œ)‌œ
‌کGڑ‌œ
کMڑ‌œ‌œ)ک0ڑ	‌œ‌œ‌œ‌œ‌ک(Mڑ‌œکMڑ‌œک——Mڑ‌œکMکMڑ‌œک—ڑ‌œ
کMڑ‌œ‌œ)ک0ڑ	‌œ‌œ‌œ‌œ‌ک(Mڑ‌œکMڑ‌œک——Mڑ‌œکڑ‌œ‌کMڑœ	‌œ,‌œکA—Mڑ‌œکڑ‌کLڑœ	‌œ"ک,—MکMکMک —ڑ‍œکMڑœ‌œ
‌œ‌œ‌œ‌œ‌œ™HLڑœ	‌œکLک!MکMک —Mڑœ•™•Mڑœ‌œکMڑœ$ک$Mک ڑ‍
œ‌œکLڑ‌œ‌œک!Lڑœ‌œ‌œکLڑœ‌œکڑ‌œ 
کLڑ	œ6‌œ+‌œ‌œ
‌œک•ڑ‌کڑ‌œ‌کLڑ‌œ
‌œکLڑ‌œ‌œکLڑœ‌œکLڑœ‌œکLڑ‌œک—Lڑœ‌œک"Lڑœ&ک&ڑ‌œ&‌œک.Lڑ‌œ‌œک1LڑœکLک—Lڑ‌œک—Lڑœ‌œ
‌œک*Mڑ‌œک—MکMک —J™RJک;JکbJڑœPکPJڑœNکNJڑœ_ک_Lڑ‌œک—— …—      '،  