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 [Detach, 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;  -- 256*32checkData: BOOLEAN _ TRUE;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[];TRUSTED{Process.Detach[server]};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;FOR i: INT IN [0..blocksize) DObyte: BYTE _ i MOD 256;TRUSTED{block[i] _ LOOPHOLE[byte];}ENDLOOP;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};};IF NOT checkData THEN {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, block[count]];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, block[count]];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[];TRUSTED{Process.Detach[server]};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byteExpected: CHAR _ 0C;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[];IF checkData AND char#byteExpected THEN ERROR;charsSincePause _ charsSincePause + 1;IF charsSincePause > charsBetweenPauses THEN {IF msToPause#0 THEN Process.PauseMsec[msToPause];charsSincePause _ 0;};byteExpected _ IF byteExpected=377C THEN 0C ELSE byteExpected + 1;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, March 22, 1988 3:26:02 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]Note: if checkData=TRUE then blocksize should be a multiple of 256 to be safe.Initialize block of dataCreate TCP connectionSend data[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."]; ‌ت
7  –"cedar" styleک head™Icode2ڑœ¯™¯J™2Jڑœ3دk™6Jڑœ‌œ‌™4Icodeڑœ)™)Mڑœ#‌™&Mڑœ(‌™+J™ ڑ‌	ک	Lڑœ‌œکLڑœ‌œکLڑœ
‌œک(Lڑ‌œ‌œu‌œک…Mڑœ‌œ#ک0Lڑœ‌œ‌œک/Lڑœ‌œکLڑœ‌œoک|——ڑدnœ‌œ‌کLڑ‌œ‌œ+کLLڑ‌کLڑœ‌œکMڑœ‌œکMک Mڑœ*ک*Mڑœ)ک)Mڑœ(ک(Mک Mڑœ!ک!Mک M™3Mڑœ‌œ
کMڑœ‌œ
دc	ک!Lڑœ‌œ‌œک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ڑœںک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–	[PROCESS]ڑ‌œک 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ڑœN™NMڑœ‌œکMڑœ‌œ‌œکMڑœ‌œک!Mڑœ‌œکM™Mڑ	œ‌œ‌œ‌œ‌œک'Mڑœکڑ‌œ‌œ‌œ‌کMڑœ‌œ‌œکMڑ‌œ‌œک#Mڑ‌œک—M™Mڑœb‌œکyMڑœ	‌œ‌œ	ک)Mڑœ	‌œ‌œ'کGMڑœںک!ڑ‌œکLڑœ>‌œ
کLLڑœ:‌œ
کHLڑ‌œ‌œ‌œ	ک=Lک—ڑ‌œ‌œ‌œکMڑ‌œکMڑ‌œک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–	[PROCESS]ڑ‌œک Lک!MکMک —Mڑœ•™•Mڑœ‌œکMڑœ$ک$Mک ڑ‍
œ‌œکLڑ‌œ‌œک!Lڑœ‌œ‌œکLڑœ‌œکڑ‌œں
کLڑœ‌œکLڑ	œ6‌œ+‌œ‌œ
‌œک•ڑ‌کڑ‌œ‌کLڑ‌œ
‌œکLڑ‌œ‌œکLڑœ‌œکLڑœ‌œکLڑ‌œک—Lڑœ‌œک"Lڑ‌œ‌œ‌œ‌œک.Lڑœ&ک&ڑ‌œ&‌œک.Lڑ‌œ‌œک1LڑœکLک—Lڑœ‌œ‌œ‌œکBLڑ‌œک—Lڑœ‌œ
‌œک*Mڑ‌œک—MکMک —J™RJک;JکbJڑœPکPJڑœNکNJڑœ_ک_Lڑ‌œک—— …—    ¤  *  