
DIRECTORY
Arpa,
ArpaUDP,
Basics,
Convert,
DatagramSocket,
IO,
Process,
RefText,
Rope,
UXIO
;

DatagramSocketTest: CEDAR PROGRAM
IMPORTS DatagramSocket, UXIO, IO, Convert, Rope, Basics, Process, RefText
~ {
SH: TYPE ~ DatagramSocket.Handle;
Address: TYPE ~ Arpa.Address;
Port: TYPE ~ ArpaUDP.Port;

Err: ERROR [code: ATOM] м DatagramSocket.Error;

sh1: SH м NIL;
a1: Address м Arpa.nullAddress;
p1: Port м ArpaUDP.nullPort;

sh2: SH м NIL;
a2: Address м Arpa.nullAddress;
p2: Port м ArpaUDP.nullPort;

maxDatagramSize: CARD м 0;
maxPrintLength: CARD м 30;

sendData: Rope.ROPE м "Hello.  What hath God wrought?\nThe explorer was frozen in his big kayak just after making some queer discoveries.\nThe quick brown fox jumps over the lazy dog.\n";

stdout: IO.STREAM м UXIO.CreateStandardStream[output];

PutErr: PROC [code: ATOM] ~ {
IO.PutF1[stdout, "Err[%g] - aborting\n", [atom[code]]];
};

Create: PROC ~ {
ENABLE Err => { PutErr[code]; CONTINUE };
sh1 м DatagramSocket.Create[];
IO.PutRope[stdout, "First create succeeds ... "];
[a1, p1] м DatagramSocket.GetLocal[sh1];
IO.PutF[stdout, "address: %g, port: %g\n", [rope[Convert.RopeFromArpaAddress[a1]]], [cardinal[Basics.Card16FromH[p1]]] ];
sh2 м DatagramSocket.Create[];
IO.PutRope[stdout, "Second create succeeds ... "];
[a2, p2] м DatagramSocket.GetLocal[sh2];
IO.PutF[stdout, "address: %g, port: %g\n", [rope[Convert.RopeFromArpaAddress[a2]]], [cardinal[Basics.Card16FromH[p2]]] ];
maxDatagramSize м DatagramSocket.GetMaxDatagramSize[sh2];
IO.PutF1[stdout, "max datagram size: %g\n", [cardinal[maxDatagramSize]] ];
IF maxDatagramSize > 2048 THEN {
IO.PutRope[stdout, "(setting maxDatagramSize _ 2048)\n"];
maxDatagramSize м 2048;
};
};

ForkCreate: PROC ~ TRUSTED { Process.Detach[ FORK Create[] ] };

Destroy: PROC ~ {
ENABLE Err => { PutErr[code]; CONTINUE };
IF sh1 # NIL THEN { DatagramSocket.Destroy[sh1]; sh1 м NIL };
IF sh2 # NIL THEN { DatagramSocket.Destroy[sh2]; sh2 м NIL };
IO.PutRope[stdout, "destroyed\n"];
};

ForkDestroy: PROC ~ TRUSTED { Process.Detach[ FORK Destroy[] ] };

Recv: PROC [timeoutMsec: CARD, unsafe: BOOL м FALSE] ~ {
ENABLE Err => { PutErr[code]; CONTINUE };
recvBuf: REF TEXT м RefText.New[maxDatagramSize];
fromA: Address;
fromP: Port;
nBytesRead: NAT;
IF unsafe
THEN TRUSTED {
[nBytesRead, fromA, fromP] м DatagramSocket.UnsafeRecv[h~sh2, b~[LOOPHOLE[recvBuf, POINTER TO Basics.RawBytes]+UNITS[TEXT[0]], 0, recvBuf.maxLength], timeoutMsec~timeoutMsec];
recvBuf.length м nBytesRead;
}
ELSE {
[nBytesRead, fromA, fromP] м DatagramSocket.Recv[h~sh2, b~recvBuf, timeoutMsec~timeoutMsec];
};
IO.PutF[stdout, "Received %g bytes from %g : %g\n", [cardinal[nBytesRead]], [rope[Convert.RopeFromArpaAddress[fromA]]], [cardinal[Basics.Card16FromH[fromP]]] ];
IF recvBuf.length <= maxPrintLength THEN {
IO.PutF1[stdout, "data: %g\n", [rope[Rope.FromRefText[recvBuf]]] ];
};
};

ForkRecv: PROC ~ TRUSTED { Process.Detach[ FORK Recv[1000, FALSE] ] };

ForkRecvLongTimeout: PROC ~ TRUSTED { Process.Detach[ FORK Recv[10000, FALSE] ] };

ForkUnsafeRecv: PROC ~ TRUSTED { Process.Detach[ FORK Recv[1000, TRUE] ] };

ForkUnsafeRecvLongTimeout: PROC ~ TRUSTED { Process.Detach[ FORK Recv[10000, TRUE] ] };

Send: PROC [nBytes: NAT, unsafe: BOOL м FALSE] ~ {
ENABLE Err => { PutErr[code]; CONTINUE };
sendBuf: REF TEXT м Rope.ToRefText[sendData];
IF unsafe
THEN TRUSTED {
nBytes м MIN[sendBuf.length, nBytes];
DatagramSocket.UnsafeSend[sh1, a2, p2,
[ LOOPHOLE[sendBuf, LONG POINTER TO Basics.RawBytes]+UNITS[TEXT[0]], 0, nBytes ]
];
}
ELSE {
nBytes м MIN[nBytes, sendBuf.maxLength];
DatagramSocket.Send[sh1, a2, p2, sendBuf, 0, nBytes];
};
IO.PutF1[stdout, "Sent %g bytes\n", [cardinal[nBytes]] ];
};

ForkSend: PROC ~ TRUSTED { Process.Detach[ FORK Send[maxPrintLength, FALSE] ] };

ForkUnsafeSend: PROC ~ TRUSTED { Process.Detach[ FORK Send[maxPrintLength, TRUE] ] };

ForkSendLong: PROC ~ TRUSTED { Process.Detach[ FORK Send[maxDatagramSize, FALSE] ] };

ForkUnsafeSendLong: PROC ~ TRUSTED { Process.Detach[ FORK Send[maxDatagramSize, TRUE] ] };

}.
    
DatagramSocketTest.mesa
Copyright ╙ 1991 by Xerox Corporation.  All rights reserved.
Demers, November 22, 1988 12:12:47 pm PST
Carl Hauser, November 22, 1988 3:10:00 pm PST
Willie-s, August 13, 1991 4:24 pm PDT
Michael Plass, November 22, 1991 4:51 pm PST
 Э╩∙  ХNewlineDelimiter
Ц(cedarcode) styleЩ codeЪЬЩKЪЬ
╧eЬ1Щ<KЩ)KЩ-KЩ%KЩ,KШ ЧЪ╧k	Ш	KШKШKШKШKШKЪЮЬШKШKШKШKЪЮШKШKШ ЧЪ╧nЬЮЬЮШ!KЪЮЬBШIKШKЪЮЬЮЬШ!KЪЬ	ЮЬШKЪЬЮЬШKШ KЪЯЬЮЬЮЬШ/KШ KЪЬЮЬЮЬШKШKШKШ KЪЬЮЬЮЬШKШKШKШ KЪЬЮЬШKЪЬЮЬШKШ KЪЬЮЬиШ╗KШ KЪЬЮЬЮЬЮЬШ6KШ ЪЯЬЮЬЮЬШKЪЮЬ5Ш7KШKШ ЧЪЯЬЮЬШKЪЮЬЮЬШ)KЪЬШKШ1KЪЬ(Ш(KЪЮЬwШyKЪЬШKШ2KЪЬ(Ш(KЪЮЬwШyKЪЬ9Ш9KЪЮЬHШJЪЮЬЮЬШ KЪЮЬ7Ш9KЪЬШKШЧKШKШ ЧЪЯ
ЬЮЬЮЬЮЬШ?KШ ЧЪЯЬЮЬШKЪЮЬЮЬШ)KЪЮЬЮЬЮЬ&ЮЬШ=KЪЮЬЮЬЮЬ&ЮЬШ=KЪЮЬ Ш"KШKШ ЧЪЯЬЮЬЮЬЮЬШAKШ ЧЪ
ЯЬЮЬЮЬ
ЮЬЮЬШ8KЪЮЬЮЬШ)KЪЬ	ЮЬЮЬ Ш1KШKШKЪЬЮЬШЪЮЬШ	ЪЮЬЮЬШKЪЬAЮЬ
ЮЬЮЬЮЬЮЬ6ШпKЪЬШKШЧЪЮЬШKЪЬ\Ш\KШЧЧKЪЮЬЮШаЪЮЬ"ЮЬШ*KЪЮЬAШCKШЧKШKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШFKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШRKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШKKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШWKШ ЧЪ
ЯЬЮЬ
ЮЬ
ЮЬЮЬШ2KЪЮЬЮЬШ)KЪЬ	ЮЬЮЬШ-ЪЮЬШ	ЪЮЬЮЬШKЪЬ	ЮЬШ%ЪЬ&Ш&KЪЬЮЬ
ЮЬЮЬЮЬЮЬЮЬШPKЪЬШЧKШЧЪЮЬШKЪЬ	ЮЬШ(KЪЬ5Ш5KШЧЧKЪЮЬ7Ш9KШKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШPKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШUKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШUKШ ЧKЪ
ЯЬЮЬЮЬЮЬЮЬШZKШ KШЧЧ ЕЧ    ║  ╗  