
DIRECTORY 
Basics, XCommunications, UnixSocket, UnixSysCalls, UXStrings, IO, Rope;

XCommunicationsTCPPCedarNoYP: CEDAR PROGRAM 
IMPORTS Basics, IO, Rope, UnixSysCalls, XCommunications
~ BEGIN 

STREAM: TYPE = IO.STREAM; 
 

--C-- PortNumber: TYPE = MACHINE DEPENDENT RECORD [val: Basics.HWORD];
--C-- InAddr: TYPE = PACKED ARRAY [0..4) OF BYTE; --internet address

--C-- SockAddrIn: TYPE = WORD16 MACHINE DEPENDENT RECORD [ 
--see chapter 8.7, page 203  ...<netinet/in.h>
sinFamily: UnixSocket.ProtocolFamily, 
sinPort: PortNumber,
sinAddr: InAddr,
sinZero: PACKED ARRAY [0..8) OF BYTE
];

--C-- SockAddr: TYPE = WORD16 MACHINE DEPENDENT RECORD [
SELECT OVERLAID * FROM
standard => [standard: UnixSocket.SockAddr],
in => [in: SockAddrIn],
ENDCASE
];


myStreamProcs: REF IO.StreamProcs м IO.CreateStreamProcs[
variety: inputOutput, 
class: $MyTCP,
getChar: MyGetChar,
endOf: MyEndOf,
unsafeGetBlock: MyUnsafeGetBlock,
putChar: MyPutChar,
unsafePutBlock: MyUnsafePutBlock,
flush: SendNow,
close: MyClose
];

bufferSize: INT = 1024;

MyDataRec: TYPE = MONITORED RECORD [
socket1: UnixSysCalls.FD, --writer...
socket2: UnixSysCalls.FD, --reader...
closed: BOOL м FALSE,
bufCnt: INT м 0,
server: SockAddrIn,
outBuffer: PACKED ARRAY [0..bufferSize) OF CHAR
];

MyEndOf: PROC [self: STREAM] RETURNS [BOOL] = {
RETURN [FALSE];
};

MyPutChar: PROC [self: STREAM, char: CHAR] = {
d: REF MyDataRec = NARROW[self.streamData];
IF d.closed THEN ERROR IO.Error[StreamClosed, self];
IF d.bufCnt>=bufferSize THEN MyFlush[d];
d.outBuffer[d.bufCnt] м char;
d.bufCnt м d.bufCnt+1;
IF d.bufCnt>=bufferSize THEN MyFlush[d];
};

MyUnsafePutBlock: PROC [self: STREAM, block: Basics.UnsafeBlock] = TRUSTED {
d: REF MyDataRec = NARROW[self.streamData];
IF d.closed THEN ERROR IO.Error[StreamClosed, self];
IF d.bufCnt>=bufferSize THEN MyFlush[d];
DO
bCnt: INT м d.bufCnt; 
cnt: INT м MIN[bufferSize-bCnt, block.count];
MoveBytes[@d.outBuffer+bCnt, block.base+block.startIndex, cnt];
d.bufCnt м d.bufCnt + cnt;
block.startIndex м block.startIndex + cnt;
block.count м block.count - cnt;
IF block.count>0 THEN MyFlush[d] ELSE EXIT
ENDLOOP;
IF d.bufCnt>=bufferSize THEN MyFlush[d];
};

MoveBytes: UNSAFE PROC [dest: POINTER, src: POINTER, len: CARDINAL] ~ UNCHECKED MACHINE CODE{
"XR_MoveBytesDisjoint"
};

MyGetChar: PROC [self: STREAM] RETURNS [ch: CHAR] = TRUSTED {
d: REF MyDataRec = NARROW[self.streamData];
n: INT;
buff: PACKED ARRAY [0..BYTES[WORD]) OF CHAR;
IF d.closed THEN ERROR IO.Error[StreamClosed, self];
n м UnixSysCalls.Read[d.socket2, LOOPHOLE[@buff], 1];
IF n = 0 THEN ERROR IO.EndOfStream[self];
IF n < 0 THEN ERROR;
RETURN [buff[0]];
};

MyUnsafeGetBlock: UNSAFE PROC [self: STREAM, block: Basics.UnsafeBlock] RETURNS [nBytesRead: INT м 0] = {
d: REF MyDataRec = NARROW[self.streamData];
IF d.closed THEN ERROR IO.Error[StreamClosed, self];
WHILE block.count>0 DO
n: INT;
TRUSTED {
n м UnixSysCalls.Read[d.socket2, LOOPHOLE[block.base+block.startIndex+nBytesRead], block.count];
};
IF n<=0 THEN {
IF n=0 THEN RETURN;
ERROR;
};
block.count м block.count-n;
nBytesRead м nBytesRead+n;
ENDLOOP
};

MyClose: PROC [self: STREAM, abort: BOOL] = {
d: REF MyDataRec = NARROW[self.streamData];
IF d.closed THEN RETURN;
IF ~abort THEN SendNow[self];
d.closed м TRUE;
[] м UnixSysCalls.Close[d.socket1];
[] м UnixSysCalls.Close[d.socket2];
};

MyFlush: PROC [d: REF MyDataRec] = TRUSTED {
addr: POINTER м @d.outBuffer;
cnt: INT м d.bufCnt; d.bufCnt м 0;
WHILE cnt>0 DO
n: INT м UnixSysCalls.Write[d.socket1, LOOPHOLE[addr], cnt];
IF n<=0 THEN ERROR;
cnt м cnt-n; addr м addr+n;
ENDLOOP
};

SendNow: PROC [self: STREAM] = {
d: REF MyDataRec = NARROW[self.streamData];
IF d.bufCnt>0 THEN MyFlush[d];
};

Create: PROC [base: Rope.ROPE, port: REF ANY] RETURNS [sd: XCommunications.StreamData] = TRUSTED {
portNo: INT;
d: REF MyDataRec м NEW[MyDataRec];
WITH port SELECT FROM
ri: REF INT => portNo м riн;
ENDCASE => {sd.errorMsg м "bad port type"; GOTO Oops};
d.socket1 м UnixSysCalls.Socket[inet, stream, unspec];
IF LOOPHOLE[d.socket1, INT]<0 THEN {sd.errorMsg м "socket not created"; GOTO Oops};
d.server.sinFamily м inet;


SELECT TRUE FROM
Rope.Match["*clarissa*", base, FALSE]  => d.server.sinAddr м [13, 1, 100, 140]; 
Rope.Match["*presto*", base, FALSE]  => d.server.sinAddr м [13, 1, 100, 151]; 
Rope.Match["*lyrane*", base, FALSE] => d.server.sinAddr м [13, 1, 100, 213]; 
Rope.Match["*kimball*", base, FALSE]  => d.server.sinAddr м [13, 1, 100, 206]; 
Rope.Match["*illona*", base, FALSE]  => d.server.sinAddr м [13, 1, 101, 48]; 
ENDCASE => d.server.sinAddr м [13, 1, 100, 140]; --clarissa

d.server.sinPort м [Basics.HFromInt16[portNo]]; 
IF UnixSysCalls.Connect[d.socket1, LOOPHOLE[@d.server], BYTES[SockAddrIn]] # success THEN {
sd.errorMsg м "not connected"; GOTO Oops
};
d.socket2 м UnixSysCalls.Dup[d.socket1];
IF LOOPHOLE[d.socket2, CARD32]=0 THEN {
[] м UnixSysCalls.Close[d.socket1];
sd.errorMsg м "not connected: duplication of socket failed"; GOTO Oops
};
sd.in м sd.out  м IO.CreateStream[streamProcs: myStreamProcs, streamData: d];
sd.success м TRUE;
sd.errorFromStream м ErrorFromStream;
EXITS Oops => {}
};

ErrorFromStream: PROC [s: IO.STREAM] RETURNS [reason: Rope.ROPE] = {
reason м "failure"; 
};

XCommunications.RegisterCommunication[[create: Create, protocol: $TCP]];
END.

  ╚  
XCommunicationsTCPPCedarNoYP.mesa
Copyright ╙ 1988, 1991 by Xerox Corporation.  All rights reserved.
Created by Christian Jacobi, July 11, 1988 2:41:31 pm PDT
Christian Jacobi, December 5, 1988 2:52:57 pm PST
From Sun manual: 
Network Programming
Revision A, of 9 May 1988
Chapter 8.8, Figure 8.9, page 206 
Initiating an Internet Domain Stream Connection
--C-- HostEnt: TYPE = MACHINE DEPENDENT RECORD [ 	
--see chapter 9.2, page 233
hName: UXStrings.UnixString,	--official name of host
hAliases: POINTER TO PACKED ARRAY [0..0) OF UXStrings.UnixString,	--alias list
hAddrtype: AFTypes,		--host address type (e.g. AF_INET)
hLength: INT32,		--length af address in bytes
hAddrList: POINTER TO PACKED ARRAY [0..0) OF POINTER TO Basics.RawBytes --list of addresses, list null terminated; each address is hLength bytes long
];
GetHostByRope: PROC [name: Rope.ROPE] RETURNS [p: POINTER TO HostEnt] = {
GetHostByName: PROC [UXStrings.UnixString] RETURNS [POINTER TO HostEnt] = TRUSTED MACHINE CODE {
"gethostbyname"
};
p _ GetHostByName[UXStrings.Create[name].string]
};

hp: POINTER TO HostEnt,
--copy that even competing processes will not cause MoveBytes to write outside buffer 
--create socket
--bind socket to name
d.hp _ GetHostByRope[base];
IF d.hp=NIL THEN {err _ "socket not bound"; GOTO Oops};
d.server.sinAddr _ LOOPHOLE[d.hp.hAddrList[0], POINTER TO InAddr]^; 
BCopy[hp.hAddr^, @server+BYTES[WORD], hp.hLength];
--connect socket with remote socket


--create stream
 Э╩е  Ц(cedarcode) styleХNewlineDelimiter
Щ codeЪЬ!Щ!KЪЬ
╧eЬ7ЩBKЪЬ9Щ9KЪЬ1Щ1ЧKШ Ъ╧k	ЬШ
KЪЬ>ЮЬШGKШ ЧЪ╧nЬЮЬЮЬШ,KЪЮЬ	ЮЬ%Ш7ЧЪЬЮШKШ KЪЮЬЮЬЮЬЮЬШЩKЩKЩKЩ"KЩ/ЧKШ Ъ
╧cЬ
ЮЬЮЬЮ	ЬЮЬЩ2KЪаЩKЪЬаЩ4KЪЬ
ЮЬЮЬЮЬЮЬЮЬаЩNKЪЬа"Щ7KЪЬ	ЮЬаЩ-KЪЬЮЬЮЬЮЬЮЬЮЬЮЬЮЬаMЩХKЩЧKШ KЪаЬЮЬЮЬЮ	ЬЮЬЮЬШFKЪаЬ	ЮЬЮЬЮЬЮЬЮЬаШDKШ Ъ
аЬЮЬЮЬЮ	ЬЮЬШ;KЪа.Ш.KЪЬ&Ш&KЪЬШKЪЬЮШKЪЬ	ЮЬЮЬЮЬЮШ$KШЧKШ Ъ
аЬЮЬЮЬЮ	ЬЮЬШ8ЪЮЬЮЬЮШKЪЬ,Ш,KЪЬШKЪЮШЧKШЧKШ KШ ЪЯЬЮЬЮЬЮЬЮЬЮЬЩIЪЯЬЮЬЮЬЮЬЮЬЮЬЮЬЮЬЩ`KЪЬЩKЩЧKЪЬ0Щ0KЪЬЩKЩ ЧЦ"cedar" styleЪЬЮЬЮЬЮЬШ9KЦ"cedar" styleЪЬШKЦ"cedar" styleЪЬШKЦ"cedar" styleЪЬШKЦ"cedar" styleЪЬШKЦ"cedar" styleЪЬ!Ш!KЦ"cedar" styleЪЬШKЦ"cedar" styleЪЬ!Ш!KЦ"cedar" styleЪЬШKЦ"cedar" styleЪЬШKЦ"cedar" styleЪЬШЧKЦ"cedar" styleШ KЪЬЮЬШKШ ЪЬЮЬЮ	ЬЮЬШ$KЪЬЮЬаШ%KЪЬЮЬаШ%KЪЬЮЬЮЬШKЪЬЮЬШKЪЬШKЪЬЮЬЮЬ	ЩKЪЬЮЬЮЬЮЬЮШ/KЪЬШЧKШ Ъ
ЯЬЮЬЮЬЮЬЮЬШ/KЪЮЬЮЬШKЪЬШЧKШ ЪЯ	ЬЮЬЮЬЮЬШ.KЪЬЮЬЮЬШ+KЦ"cedar" styleЪЮЬ
ЮЬЮЬЮЬШ4KЪЮЬЮЬШ(KЪЬШKЪЬШKЪЮЬЮЬШ(KЪЬШЧKЦ"cedar" styleШ Ц"cedar" styleЪЯЬЮЬЮЬЮЬШLKЪЬЮЬЮЬШ+KЦ"cedar" styleЪЮЬ
ЮЬЮЬЮЬШ4KЪЮЬЮЬШ(ЪЮШЦ"cedar" styleЪЬЮЬШKЦ"cedar" styleЪаVЩVЧKЪЬЮЬЮЬШ-KЪЬ?Ш?KЪЬШKЪЬ*Ш*KЪЬ Ш KЪЮЬЮЬЮЬЮШ*KЪЮЬШЧKЪЮЬЮЬШ(KЦ"cedar" styleЪЬШKЦ"cedar" styleШ ЧЪЯ	ЬЮЬЮЬЮЬЮЬЮЬЮ	ЬЮЬЮЬШ]KЪЬШKШKШ ЧЦ"cedar" styleЪЯ	ЬЮЬЮЬЮЬЮЬЮЬШ=KЪЬЮЬЮЬШ+Icode2ЪЬЮЬШLЪЬЮЬЮЬЮЬЮЬЮЬЮЬШ,KЦ"cedar" styleЪЮЬ
ЮЬЮЬЮЬШ4LЪЬ!ЮЬШ5LЪЮЬЮЬЮЬЮЬШ)LЪЮЬЮЬЮЬШLЪЮЬ
ШKЦ"cedar" styleШЧKЦ"cedar" styleШ Ц"cedar" styleЪЯЬЮЬЮЬЮЬЮЬЮЬ	ШiKЪЬЮЬЮЬШ+KЦ"cedar" styleЪЮЬ
ЮЬЮЬЮЬШ4ЪЮЬЮШLЪЬЮШЪЮЬШ	LЪЬ!ЮЬ7Ш`LШЧЪЮЬЮЬЮШLЪЮЬЮЬЮЬШLЪЮЬШLШЧLЪЬШLЪЬШLЪЮШЧKЦ"cedar" styleШЧKЦ"cedar" styleШ Ц"cedar" styleЪЯЬЮЬЮЬ	ЮЬШ-KЪЬЮЬЮЬШ+KЦ"cedar" styleЪЮЬ
ЮЬЮЬШKЦ"cedar" styleЪЮЬЮЬШKЪЬЮЬШKЪЬ#Ш#KЪЬ#Ш#KЦ"cedar" styleЪЬШЧKШ ЪЯЬЮЬЮЬЮЬШ,KЪЬЮЬШKЪЬЮЬШ"ЪЮЬЮШKЪЬЮЬ!ЮЬШ<KЪЮЬЮЬЮЬШKЪЬШKЪЮШЧKШЧKШ ЪЯЬЮЬЮЬШ KЪЬЮЬЮЬШ+KЪЮЬЮЬШKЪЬШЧKШ ЪЯЬЮЬЮЬЮЬЮЬЮЬ$ЮЬШbKЪЬЮЬШKЪЬЮЬЮЬШ"ЪЮЬЮЬЮШKЪЬЮЬЮЬШKЪЮЬ$ЮЬШ6ЧKЪаЩKЪЬ6Ш6KЪ
ЮЬЮЬЮЬЮЬ&ЮЬШSKЪаЩKЪЬШKШ KЪЬЩKЪЮЬЮЬЮЬЮЬЩ7ЪЬЮЬЮЬЮЬЩDKЪЬЮЬЮЬЩ2ЧKШ ЪЮЬЮЬЮШKЪЬЮЬ,ШPKЪЬЮЬ,ШNKЪЬЮЬ+ШMKЪЬЮЬ,ШOKЪЬЮЬ+ШMKЪЮЬ*а
Ш;ЧKШ KЪЬ0Ш0KЪа#Щ#ЪЮЬ!ЮЬЮЬЮЬШ[KЪЬЮЬШ(KЪЬШЧKЩ KЪЬ(Ш(ЪЮЬЮЬЮЬЮЬШ'KЪЬ#Ш#KЪЬ=ЮЬШFKШЧKЩ KЪаЩKЪЬЮЬ9ШMKЪЬЮЬШKЪЬ%Ш%KЪЮЬШKШЧKШ ЪЯЬЮЬЮЬЮЬЮЬЮЬШDKЪЬШKЪЬШЧKШ ЧKЪЬHШHKЪЮЬШKШ Ч ЕЧ    ж  &  