DIRECTORY IO USING [STREAM], IPDefs USING [DByte, Address, nullAddress]; TCP: CEDAR DEFINITIONS = BEGIN TCPInfo: TYPE ~ RECORD [ -- describes the kind of connection we want. matchLocalPort: BOOL _ FALSE, -- true to use LocalPort field, false to assign an unused local port localPort: IPDefs.DByte _ 0, -- TCP port matchForeignAddr: BOOL _ TRUE, -- true to match ForeignAddress foreignAddress: IPDefs.Address _ IPDefs.nullAddress, -- address of remote TCP matchForeignPort: BOOL _ TRUE, -- true to match ForeignPort foreignPort: IPDefs.DByte _ 0, -- TCP port at remote TCP active: BOOL _ TRUE, -- true to initiate connection, false to wait as listener. If true, matchForeignAddr and matchForeignPort must also be true. timeout: INT _ neverTimeout]; -- raise Timeout if data not delivered in this time (in msec) maxTimeout: INT ~ LAST[INT] / 1000; -- don't make it bigger than this neverTimeout: INT ~ -1; -- use this to never timeout STREAM: TYPE = IO.STREAM; CreateTCPStream: PROC [tcpInfo: TCPInfo] RETURNS [s: STREAM]; AbortTCPStream: PROC [s: STREAM]; WaitForListenerOpen: PROC [s: STREAM, timeout: INT _ neverTimeout]; GetRemoteAddress: PROC [s: STREAM] RETURNS [IPDefs.Address]; SetUrgent: PROC [s: STREAM]; WaitForUrgentData: PROC [s: STREAM] RETURNS [urgentIndex: INT]; Error: ERROR [reason: Reason]; Reason: TYPE ~ { localConflict, unspecifiedRemoteEnd, neverOpen, localClose, localAbort, remoteClose, remoteAbort, transmissionTimeout, protocolViolation }; ErrorFromStream: PROC [s: STREAM] RETURNS [reason: Reason]; Timeout: SIGNAL; END. ºCopyright (C) 1983, 1985 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. TCP.mesa David Nichols, September 1, 1983 4:20 pm Taft, January 4, 1984 11:06 am HGM, March 21, 1984 0:49:04 am PST Hal Murray May 16, 1985 3:11:54 am PDT John Larson, April 14, 1986 11:17:31 pm PST Types TCP Interface Use CreateTCPStream to get an ordinary IO.STREAM. You can read and write on it to receive and send TCP data. Doing a Flush causes a TCP push operation to take place. If you are interested in urgent data, the WaitForUrgentData call will return as soon as TCP knows about some urgent data in the stream, giving the caller the index of the urgent data. Make a new bidirectional stream. May raise Error. Instead of clean close. Wait until the listening connection on this socket is open or the timeout expires. No signals. The urgent pointer is set to the current index in the output stream. Wait asynchronously for urgent data indication. May raise Error. Signals Procedures defined in this interface may raise Error if something goes wrong. On the other hand, if something goes wrong during a generic operation on a TCP stream (e.g., GetChar), IO.Error[$Failure, self] is raised. In that case, if the client is interested in the Reason for the failure, it must call ErrorFromStream[self]. Warning: TCP.Error and IO.Error are sometimes raised with monitor locks held. Do not perform any other operations on the stream until you have unwound the ERROR. Returns the Reason for the most recent error reported by IO.Error (not TCP.Error). Raised during data transfer operation if no data arrives within the interval specified when the stream was created (even although the other end is responding to our probes). This signal may be resumed to try again. Timeout can be raised during any stream operation, seemingly in violation of the rule that all generic stream operations raise IO.Error exclusively. However, this is an INFORMATIONAL SIGNAL, meaning that if it is not caught it is automatically resumed. Consequently, no harm results if it is not caught. (In any event, Timeout can be raised only if the client supplied a non-default TCPInfo.Timeout, which presumably only a knowledgable client will do.) It WAS an INFORMATIONAL SIGNAL, but you can't UNWIND them. Ê«– "cedar" style˜Icode2šœ¯™¯head™Icode™(J™J™"J™&M™+šÏk ˜ Kšœœœ˜Kšœœ˜+——šÏbœœœ˜Kš˜—™šœ œœÏc,˜EKšœœœŸD˜bKšœŸ˜)KšœœœŸ ˜?Kšœ5Ÿ˜NKšœœœŸ˜