DIRECTORYPupBuffer USING [Buffer],DESFace USING [Block, IV, Key],PupWKS USING [rpc],RPC USING [Conversation, InterfaceName, Principal, SecurityLevel, VersionRange],RPCLupine USING [DataLength, Dispatcher, RPCPkt],RPCPkt USING [CallCount, ConnectionID, ConversationID, DispatcherDetails, DispatcherID, ExportHandle, Header, PktConversationID, PktID, Machine];RPCInternal: DEFINITIONS =BEGINStartRPCBinding: PROC [RPCPkt.Machine];StartRPCSecurity: PROC [RPCPkt.Machine];StartRPCPktStreams: PROC [RPCPkt.Machine];RollbackRPCBinding: PROC;RollbackRPCSecurity: PROC;RollbackRPCPktStreams: PROC;ExportInstance: TYPE = RECORD[id: RPCPkt.DispatcherID,dispatcher: RPCLupine.Dispatcher,name: RPC.InterfaceName,stubProtocol: RPC.VersionRange ];ExportTable: TYPE = RECORD[used: CARDINAL,entries: SEQUENCE length: RPCPkt.ExportHandle OF ExportInstance];exportTable: REF ExportTable;ImportInstance: TYPE = RECORD[host: RPCPkt.Machine,dispatcher: RPCPkt.DispatcherDetails ];ConversationObject: TYPE = RECORD[next: REF ConversationObject,id: RPCPkt.ConversationID,level: RPC.SecurityLevel,key: DESFace.Key, -- conversation key --iv: DESFace.IV,originator: RPC.Principal,responder: RPC.Principal,authenticator: Authenticator,maxTransmissions: CARDINAL _ 0,timeoutEnable: TimeoutEnable _ dontCare];TimeoutEnable: TYPE = { dontCare, always, never };Authenticator: TYPE = REF AuthenticatorObject;AuthenticatorObject: TYPE = RECORD[SEQUENCE nBlks: CARDINAL OF DESFace.Block ];firstConversation: RPCPkt.PktConversationID; -- for unencrypted conversations --EncryptPkt:	PROC[pkt: RPCLupine.RPCPkt, l: RPCLupine.DataLength]RETURNS[CARDINAL];DecryptPkt:	PROC[header: LONG POINTER TO RPCPkt.Header,convHandle: RPC.Conversation]RETURNS[ok: BOOLEAN, l: RPCLupine.DataLength];GetConnectionState: PROC[ decrypted: BOOLEAN, callPkt: RPCLupine.RPCPkt]RETURNS[ ok: BOOLEAN,id: RPCPkt.ConnectionID,call: RPCPkt.CallCount,conv: RPC.Conversation,l: RPCLupine.DataLength ];ReplyToRFA: PROC [b: PupBuffer.Buffer,-- incoming packet --callHeader: LONG POINTER TO RPCPkt.Header, -- encrypted --callPktID: RPCPkt.PktID-- clear --,convHandle: RPC.Conversation]RETURNS[BOOLEAN];DoSignal: PROC [b: PupBuffer.Buffer, pktLength: RPCLupine.DataLength,signalHandler: RPCLupine.Dispatcher,convHandle: RPC.Conversation]RETURNS[resumePkt: RPCLupine.RPCPkt,resumeLength: RPCLupine.DataLength,myLocalFrame: POINTER];ServerMain: PROCEDURE;CopyPrincipal: PROC [from: RPC.Principal, to: LONG POINTER];EntryGenerate: PROC [ level: RPC.SecurityLevel, iv: DESFace.IV, originator, responder: RPC.Principal, convKey: DESFace.Key, auth: RPCInternal.Authenticator]RETURNS [ conversation: REF RPCInternal.ConversationObject ];AddToExportTable: PROC [interface: RPC.InterfaceName, dispatcher: RPCLupine.Dispatcher, stubProtocol: RPC.VersionRange] RETURNS [ instance: RPCPkt.ExportHandle ];AllocBuffer: PROC RETURNS [b: PupBuffer.Buffer];GiveBackBuffer: PROC [b: PupBuffer.Buffer];SendBuffer: PROC [b: PupBuffer.Buffer];pktLengthOverhead: RPCLupine.DataLength = SIZE[RPCPkt.Header] + 1--checksum--;SetupResponse: PROC [header: LONG POINTER TO RPCPkt.Header] = INLINEBEGINheader.destHost _ header.srceHost;header.destSoc _ PupWKS.rpc;header.destPSB _ header.srcePSB;header.outcome _ result;END;PktExchangeState: TYPE = { receiving, sending, call, endCall, authReq };PktExchange: PROC[inPkt: RPCLupine.RPCPkt, length: RPCLupine.DataLength,maxlength: RPCLupine.DataLength,state: PktExchangeState,signalHandler: RPCLupine.Dispatcher _ NIL]RETURNS[newPkt: BOOLEAN, newLength: RPCLupine.DataLength];IdleReceive: PROC[pkt: RPCLupine.RPCPkt, maxlength: CARDINAL];EnqueueAgain: PROC [b: PupBuffer.Buffer];END.  
®  RPCInternal.mesaCopyright c 1985, 1986 by Xerox Corporation.  All rights reserved.RPC: Internal interfaceAndrew Birrell   September 7, 1983 4:12 pmBob Hagmann February 8, 1985 3:33:38 pm PSTHal Murray, May 12, 1986 11:56:13 am PDTSwinehart, November 24, 1986 7:44:54 am PST******** Start-up sequence.  Main control is RPCPktIO **************** Binding:  exported by RPCBinding ********Exporter's record of exported interfaceImporter's record of successful binding******** Authentication/Security: exported by RPCSecurity ********Can be set through RPCTimeouts.SetMaxTransmissions[] to override the standard maximum number of unacknowledged packet retransmissions before timing out.  Some calls must complete quickly or are best abandoned.  If 0, the standard value is used.Can be set through RPCTimeouts.SetMaxTransmissions[] to override the determination of whether unacknowledged packet retransmissions are ever timed out.  When distributed systems are being developed, sometimes they are unresponsive for long periods of time.  always means that timeouts will raise an error signal.  never means that RPC will try forever to complete the call.  If dontCare, the standard value is used.Allocated storage for an authenticator.  For A talking to B using key CK, contains: {KY}KB, spare, { {CK}KB, spare, time, A }KY . The keys are single cipher blocks. The rest is encrypted with CBC-check using a zero IVEncrypts packet using pkt.convHandle; "l" is data length of pkt; returns Pup length of packet.Decrypts packet using pkt.convHandle; ok iff checksum matches; returns data length of packetOn entry, packet is decrypted iff "decrypted".  On exit, packet is decrypted if "ok".  If "ok" and not "decrypted", returns pkt data length in "l".  Sends RFA and accepts response; results valid iff "ok"Generates RFA response packet if request matches thisPktID******** Packet stream functions: exported by RPCPktStream ********Called from inside PktExchange to handle signal-back packetsFORK'ed when needed by RPCPktIO, to maintain an adequate stock of them******** For some Voice kludgery that I don't understand /HGM, Jan 86 **************** For new Communication package /HGM, Jan 86 **************** Moved from RPCPkt /HGM, Apr 86 ********Difference between RPCLupine.DataLength and transmitted Pup length for unencrypted packetsReliable transmission of given packet, and receipt of next packet; "newLength" is data length of incoming packet, if any.Returns when new packet arrives; "maxlength" is number of words in the pkt buffer starting from pkt.header (total, including all overheads)Dispatches packet to appropriate process;  used by idler processes to requeue pkt that had incorrect destPSB. Ê  ˜ headšœ™Icodešœ
Ïmœ7™B—šœ™Jšœ*™*L™+L™(L™+—J˜ šÏk	˜	Jšœ
žœ	˜Jšœžœžœ˜Jšœžœ˜JšœžœF˜PJšœ
žœ!˜1Jšœžœ„˜‘J˜ —Jšœžœ˜J˜ Jšž˜J˜ Jšœ>™>˜ JšÏnœžœ˜'JšŸœžœ˜(JšŸœžœ˜*J˜ JšŸœžœ˜JšŸœžœ˜JšŸœžœ˜J˜ J˜ J˜ —Jšœ2™2˜ šœžœžœ˜Jšœ'™'J˜J˜!J˜J˜!—J˜ šœžœžœ˜Jšœžœ˜Jšœ	žœžœ˜A—J˜ Jšœžœ˜J˜ šœžœžœ˜Jšœ'™'J˜J˜'—J˜ J˜ J˜ —JšœB™B˜ šœžœžœ˜"Jšœžœ˜J˜J˜JšœÏc˜(Jšœžœ˜J˜J˜Jšœ˜J™ôJšœžœ˜J™ŸJ˜'Jšœ˜—Jšœžœ˜2J˜ Jšœžœžœ˜.J˜ šœžœžœ˜#Jšœ-žœžœžœžœžœžœžœžœžœAžœž™ÙJšžœžœžœ˜,—J˜ Jšœ- #˜PJ˜ šŸ
œžœ0˜@Jšžœžœ˜Jšœ@ ™^—J˜ š
Ÿ
œžœ	žœžœžœ˜7J˜Jšžœžœ˜.Jšœ> ™\—J˜ šŸœžœžœ˜Hšžœžœ˜J˜J˜J˜J˜—Jšœ“ 8™Ë—J˜ šŸ
œžœ ˜;Jšœžœžœžœ ˜:Jšœ œ˜#J˜Jšžœžœ˜Jšœ:™:—J˜ J˜ J˜ —JšœC™C˜ šŸœžœ6˜EJ˜$J˜šžœ˜$J˜#Jšœžœ˜—Jšœ<™<—J˜ šŸ
œž	œ˜JšœF™F—J˜ J˜ —šœN™NJ™ Jš
Ÿœžœžœžœžœ˜<J˜ š
Ÿœžœ
žœžœžœB˜œJšžœžœ"˜=J˜ —Lš
Ÿœžœžœ@žœžœ#˜¢—J™ šœ<™<J™ LšŸœžœžœ˜0LšŸœžœ˜+LšŸ
œžœ˜'L˜ J˜ —šœ0™0J™ šœ*žœ œ˜NJšœB ™Z—J˜ šŸœžœ	žœžœžœž˜DJšž˜J˜"J˜J˜ J˜Jšžœ˜J˜ —Jšœžœ2˜HJ˜ šŸœžœ7˜HJ˜ J˜Jšœ&žœ˜*Jšžœ	žœ#˜:JšœB 7™y—J˜ šŸœžœ#žœ˜>JšœF E™‹—J˜ šŸœžœ˜)Jšœm™m—L˜ J˜ —Jšžœ˜J˜ — …—    ¸  å  