(DEFINE-FILE-INFO READTABLE "INTERLISP" PACKAGE "INTERLISP") (FILECREATED "22-Jul-88 14:16:28" |{MCS:MCS:STANFORD}IPTALK.;1| 12755 ) (PRETTYCOMPRINT IPTALKCOMS) (RPAQQ IPTALKCOMS ((* TALK (Interim) IP Interface) (LOCALVARS . T) (FNS TALK.IP.SERVER) (FNS TALK.IP.USERNAME TALK.IP.CONNECT TALK.IP.EVENT TALK.START.IP.SERVER) (INITVARS (TALK.UDP.PORT 517)) (GLOBALVARS TALK.UDP.PORT TALK.IP.CONSTANTS) (DECLARE%: DONTCOPY (RECORDS TALK.IP.PACKET) (CONSTANTS * TALK.IP.CONSTANTS)) (* etc) (FILES TALK TCP TCPUDP) (APPENDVARS (TALK.PROTOCOLTYPES (IP DODIP.HOSTP TALK.IP.USERNAME TALK.IP.CONNECT TALK.IP.EVENT TALK.START.IP.SERVER))) (DECLARE%: DONTCOPY DONTEVAL@LOAD EVAL@COMPILE (FILES ETHERRECORDS TCPEXPORTS) ) (P (TALK.START.IP.SERVER)))) (* TALK (Interim) IP Interface) (DECLARE%: DOEVAL@COMPILE DONTCOPY (LOCALVARS . T) ) (DEFINEQ (TALK.IP.SERVER [LAMBDA NIL (* ; "Edited 17-Jun-88 13:45 by cdl") (DECLARE (GLOBALVARS \IP.READY)) (LET (SOCKET) (DECLARE (SPECVARS SOCKET)) (RESETLST [RESETSAVE NIL `(UDP.CLOSE.SOCKET ,(SETQ SOCKET (UDP.OPEN.SOCKET TALK.UDP.PORT] [bind PACKET RESPONSE SERVICE GAP.SERVICETYPE TALK.SERVICETYPE INPUTSTREAM OUTPUTSTREAM PORT USER while \IP.READY do (SETQ PACKET (UDP.GET SOCKET T)) (UDP.SETUP (SETQ RESPONSE (\ALLOCATE.ETHERPACKET)) (with IP PACKET IPSOURCEADDRESS) (with UDP PACKET UDPSOURCEPORT) 0 SOCKET 'FREE) (UDP.APPEND.BYTE RESPONSE (with TALK.IP.PACKET PACKET TALK.SERVICE.BYTE)) (if [OR [NULL (if (SETQ GAP.SERVICETYPE (ASSOC (with TALK.IP.PACKET PACKET TALK.SERVICE.BYTE ) GAP.SERVICETYPES)) then (SETQ SERVICE (with GAP.SERVICETYPE GAP.SERVICETYPE GAP.SERVICENAME] (NULL (SETQ TALK.SERVICETYPE (ASSOC SERVICE TALK.SERVICETYPES] then (UDP.APPEND.BYTE RESPONSE \IPTALK.NOSERVICE) (UDP.SEND SOCKET RESPONSE) elseif [OR TALK.GAG (NOT (TALK.ANSWER (SETQ USER (with TALK.IP.PACKET PACKET TALK.IP.USERNAME) ) SERVICE 'IP (with IP PACKET IPSOURCEADDRESS] then (UDP.APPEND.BYTE RESPONSE \IPTALK.NOANSWER) (UDP.SEND SOCKET RESPONSE) else (UDP.APPEND.BYTE RESPONSE \IPTALK.SUCCESS) (UDP.APPEND.WORD RESPONSE (SETQ PORT (\TCP.SELECT.PORT))) (UDP.SEND SOCKET RESPONSE) (if (SETQ INPUTSTREAM (TCP.OPEN (with IP PACKET IPSOURCEADDRESS ) NIL PORT 'PASSIVE 'INPUT)) then (TALK.PROCESS INPUTSTREAM (TCP.OTHER.STREAM INPUTSTREAM) TALK.SERVICETYPE 'IP 'SERVER USER T])]) ) (DEFINEQ (TALK.IP.USERNAME [LAMBDA (INPUTSTREAM OUTPUTSTREAM SERVICETYPE MODE USER) (* ; "Edited 8-Jun-88 15:45 by cdl") (SELECTQ (with TALK.SERVICETYPE SERVICETYPE TALK.SERVICENAME) ((TTY Sketch) (* For (backward) compatibility) USER) (LET ((NAME (USERNAME))) (PRINTOUT OUTPUTSTREAM (if (NOT (STREQUAL NAME (CONSTANT null))) then NAME) T) (FORCEOUTPUT OUTPUTSTREAM) (SETQ NAME (RATOM INPUTSTREAM TALK.READTABLE)) (* Eat EOL) (BIN INPUTSTREAM) (OR NAME USER]) (TALK.IP.CONNECT [LAMBDA (HOST SERVICETYPES) (* ; "Edited 13-Jun-88 17:54 by cdl") (DECLARE (SPECVARS HOST SERVICETYPES)) (LET (SOCKET) (DECLARE (SPECVARS SOCKET)) (RESETLST [RESETSAVE NIL `(UDP.CLOSE.SOCKET ,(SETQ SOCKET (UDP.OPEN.SOCKET] [PROG (NAME REQUEST RESPONSE INPUTSTREAM RESULT) (while (STREQUAL (SETQ NAME (USERNAME)) (CONSTANT null)) do (LOGIN)) (if [LITATOM (SETQ RESULT (for SERVICETYPE in SERVICETYPES thereis (PROGN (UDP.SETUP (SETQ REQUEST (\ALLOCATE.ETHERPACKET)) HOST TALK.UDP.PORT 0 SOCKET 'FREE) (UDP.APPEND.BYTE REQUEST (with GAP.SERVICETYPE [for GAP.SERVICETYPE in GAP.SERVICETYPES thereis (with GAP.SERVICETYPE GAP.SERVICETYPE (with TALK.SERVICETYPE SERVICETYPE (EQ GAP.SERVICENAME TALK.SERVICENAME] GAP.UNSPECIFIED)) (UDP.APPEND.BYTE REQUEST 0) (UDP.APPEND.WORD REQUEST 0) (UDP.APPEND.WORD REQUEST (NCHARS NAME)) (UDP.APPEND.STRING REQUEST NAME) (if [SETQ RESPONSE (UDP.EXCHANGE SOCKET REQUEST (TIMES TALK.ANSWER.WAIT (CONSTANT (PROGN (* Convert to milliseconds and  double in case they are idle) (TIMES 2 1000] then (SELECT (with TALK.IP.PACKET RESPONSE TALK.STATUS) (\IPTALK.SUCCESS T) (\IPTALK.NOSERVICE NIL) (\IPTALK.NOANSWER (RETURN 'ANSWER)) (RETURN 'CONNECT)) else (* Can't connect) (RETURN 'CONNECT] then (RETURN RESULT) else (if (STREAMP (SETQ INPUTSTREAM (TCP.OPEN HOST (with TALK.IP.PACKET RESPONSE TALK.TEDIT.PORT) NIL 'ACTIVE 'INPUT T))) then [RETURN (CONS RESULT (CONS INPUTSTREAM (TCP.OTHER.STREAM INPUTSTREAM] else (RETURN 'CONNECT])]) (TALK.IP.EVENT [LAMBDA (INPUTSTREAM OUTPUTSTREAM) (* cdl "18-May-87 16:29") (while (AND (OPENP INPUTSTREAM) (OPENP OUTPUTSTREAM) (NOT (READP INPUTSTREAM))) do (if (EOFP INPUTSTREAM) then (CLOSEF? INPUTSTREAM)) (BLOCK]) (TALK.START.IP.SERVER [LAMBDA (RESTART) (* ; "Edited 17-Jun-88 12:20 by cdl") [LET [(DEVICE (\GETDEVICEFROMNAME 'TCP 'NOERROR 'DONTCREATE] (if DEVICE then (* (Temporary) patch to make TCP  streams handle NS character codes) (with FDEV DEVICE (if (NULL READCHARCODE) then (SETQ READCHARCODE (FUNCTION \GENERIC.READCCODE ] (bind PROCESS while (AND (SETQ PROCESS (FIND.PROCESS 'TALK.IP.SERVER)) RESTART) do (DEL.PROCESS PROCESS) (BLOCK) yield (if PROCESS then PROCESS elseif \IP.READY then (ADD.PROCESS '(TALK.IP.SERVER) 'RESTARTABLE 'SYSTEM]) ) (RPAQ? TALK.UDP.PORT 517) (DECLARE%: DOEVAL@COMPILE DONTCOPY (GLOBALVARS TALK.UDP.PORT TALK.IP.CONSTANTS) ) (DECLARE%: DONTCOPY (DECLARE%: EVAL@COMPILE (ACCESSFNS TALK.IP.PACKET [(TALK.PACKET.BASE (with UDP DATUM UDPCONTENTS)) (TALK.IP.USERNAME (\GETBASESTRING (with UDP DATUM UDPCONTENTS) 6 (with TALK.IP.PACKET DATUM TALK.USERNAME.LENGTH] (BLOCKRECORD TALK.PACKET.BASE ((TALK.SERVICE.BYTE BYTE) (TALK.STATUS BYTE) (TALK.TEDIT.PORT WORD) (TALK.USERNAME.LENGTH WORD)))) ) (RPAQQ TALK.IP.CONSTANTS ((\IPTALK.SUCCESS 0) (\IPTALK.NOSERVICE 1) (\IPTALK.NOANSWER 2))) (DECLARE%: EVAL@COMPILE (RPAQQ \IPTALK.SUCCESS 0) (RPAQQ \IPTALK.NOSERVICE 1) (RPAQQ \IPTALK.NOANSWER 2) (CONSTANTS (\IPTALK.SUCCESS 0) (\IPTALK.NOSERVICE 1) (\IPTALK.NOANSWER 2)) ) ) (* etc) (FILESLOAD TALK TCP TCPUDP) (APPENDTOVAR TALK.PROTOCOLTYPES (IP DODIP.HOSTP TALK.IP.USERNAME TALK.IP.CONNECT TALK.IP.EVENT TALK.START.IP.SERVER)) (DECLARE%: DONTCOPY DONTEVAL@LOAD EVAL@COMPILE (FILESLOAD ETHERRECORDS TCPEXPORTS) ) (TALK.START.IP.SERVER) (DECLARE%: DONTCOPY (FILEMAP (NIL (1313 4720 (TALK.IP.SERVER 1323 . 4718)) (4721 11119 (TALK.IP.USERNAME 4731 . 5475) ( TALK.IP.CONNECT 5477 . 9538) (TALK.IP.EVENT 9540 . 9963) (TALK.START.IP.SERVER 9965 . 11117))))) STOP