~
BEGIN
STREAM: TYPE = IO.STREAM;
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
];
--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
];
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]
};
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,
hp: POINTER TO HostEnt,
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;
--copy that even competing processes will not cause MoveBytes to write outside buffer
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};
--create socket
d.socket1 ¬ UnixSysCalls.Socket[inet, stream, unspec];
IF LOOPHOLE[d.socket1, INT]<0 THEN {sd.errorMsg ¬ "socket not created"; GOTO Oops};
--bind socket to name
d.server.sinFamily ¬ inet;
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];
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]];
--connect socket with remote socket
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
};
--create stream
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";
};