vipak/sockets.Mod

MODULE sockets; (*noch 23.2.2017 / 14.4.2017*)
IMPORT types, SYS := SYSTEM;

TYPE 
     Int16* = types.Int16; (* INTEGER on 32 bit platform *)
     Int32* = types.Int32;
     Int64* = types.Int64;

CONST 
   SockStream* = 1;
   SockDgram*  = 2;
   SockRaw*    = 3;
   SockRdm*    = 4;
   SockSeqpacket* = 5;
   SockDccp*   = 6;
   SockPacket* = 10;

   AfUnspec* = 0;      (* Unspecified.  *)
   AfLocal*  = 1;      (* Local to host (pipes and file-domain).  *)
   AfUnix*   = 1;      (* POSIX name for PF_LOCAL.  *)
   AfFile*   = 1;      (* Another non-standard name for PF_LOCAL.  *)
   AfInet*   = 2;      (* IP protocol family.  *)
   AfAx25*   = 3;      (* Amateur Radio AX.25.  *)
   AfIpx*    = 4;      (* Novell Internet Protocol.  *)
   AfAppletalk* = 5;   (* Appletalk DDP.  *)
   AfNetrom* = 6;      (* Amateur radio NetROM.  *)
   AfBridge* = 7;      (* Multiprotocol bridge.  *)
   AfAtmpvc* = 8;      (* ATM PVCs.  *)
   AfX25*    = 9;      (* Reserved for X.25 project.  *)
   AfInet6*  = 10;     (* IP version 6.  *)
   AfRose*   = 11;     (* Amateur Radio X.25 PLP.  *)
   AfDecnet* = 12;     (* Reserved for DECnet project.  *)
   AfNetbeui*= 13;     (* Reserved for 802.2LLC project.  *)
   AfSecurity*=14;     (* Security callback pseudo AF.  *)
   AfKey*    = 15;     (* PF_KEY key management API.  *)
   AfNetlink*= 16;
   AfRoute*  = 16;     (* Alias to emulate 4.4BSD.  *)
   AfPacket  = 17;     (* Packet family.  *)
   AfAsh     = 18;     (* Ash.  *)
   AfEconet* = 19;     (* Acorn Econet.  *)
   AfAtmsvc* = 20;     (* ATM SVCs.  *)
   AfRds*    = 21;     (* RDS sockets.  *)
   AfSna     = 22;     (* Linux SNA Project *)
   AfIrda*   = 23;     (* IRDA sockets.  *)
   AfPppox   = 24;     (* PPPoX sockets.  *)
   AfWanpipe*= 25;     (* Wanpipe API sockets.  *)
   AfLlc*    = 26;     (* Linux LLC.  *)
   AfCan*    = 29;     (* Controller Area Network.  *)
   AfTipc*   = 30;     (* TIPC sockets.  *)
   AfBluetooth* = 31;  (* Bluetooth sockets.  *)
   AfIucv*   = 32;     (* IUCV sockets.  *)
   AfRxrpc*  = 33;     (* RxRPC sockets.  *)
   AfIsdn*   = 34;     (* mISDN sockets.  *)
   AfPhonet* = 35;     (* Phonet sockets.  *)
   AfIeee802154* = 36; (* IEEE 802.15.4 sockets.  *)
   AfCaif*   = 37;     (* CAIF sockets.  *)
   AfAlg*    = 38;     (* Algorithm sockets.  *)
   AfNfc*    = 39;     (* NFC sockets.  *)
   AfVsock*  = 40;     (* vSockets.  *)
   AfMax*    = 41;     (* For now..  *)

   InAddrAny* = 0;

TYPE
(*
   (* /usr/include/netinet/in.h *)
   InAddr* = RECORD
    SAddr* : Int32;
   END;

   SockAddrIn* = RECORD
    SinFamily* : Int16;
    SinPort*   : Int16;
    SinAddr*   : InAddr;
    SinZero*   : ARRAY 8 OF CHAR;
   END;
*)
   (* /usr/include/sys/socket.h *)
  
   SockAddr* = RECORD
    SaFamily* : Int16;
    SaData*   : ARRAY 14 OF CHAR
   END;
(*
   PROCEDURE -includeSockets
      "#include <sys/socket.h>";
*)
   PROCEDURE -socket(domain, type, protocol: Int32): Int32
      "(int)socket(domain, type, protocol)";

   PROCEDURE Socket*(domain, type, protocol: Int32): Int32;
   BEGIN
      RETURN socket(domain, type, protocol)
   END Socket;

   PROCEDURE -bind(sockfd: Int32; VAR addr: SockAddr; addrlen: Int32): Int32
      "(int)bind(sockfd, addr, addrlen)";

   PROCEDURE Bind*(sockfd: Int32; VAR addr: SockAddr; addrlen: Int32): Int32;
   BEGIN
      RETURN bind(sockfd, addr, addrlen)
   END Bind;

   PROCEDURE -listen(sockfd, backlog: Int32): Int32
      "(int)listen(sockfd, backlog)";

   PROCEDURE Listen*(sockfd, backlog: Int32): Int32;
   BEGIN
      RETURN listen(sockfd, backlog)
   END Listen;

   PROCEDURE -accept(sockfd: Int32; VAR addr: SockAddr; VAR addrlen: Int32): Int32
      "(int)accept(sockfd, addr, addrlen)";

   PROCEDURE Accept*(sockfd: Int32; VAR addr: SockAddr; VAR addrlen: Int32): Int32;
   BEGIN
      RETURN accept(sockfd, addr, addrlen)
   END Accept;
    (* int connect(int sockfd, const struct sockaddr *addr,
	                   socklen_t addrlen); *)
   PROCEDURE -connect(sockfd: Int32; addr: SYS.ADDRESS; addrlen: Int32): Int32
     "(INTEGER)(connect(sockfd, addr, addrlen))";

   
   PROCEDURE Connect*(sockfd: Int32; sockaddr: SYS.ADDRESS; addrlen: Int32): Int32;
   BEGIN
     RETURN connect(sockfd, sockaddr, addrlen)
   END Connect;

  (* ssize_t recv(int sockfd, void *buf, size_t len, int flags); *)

  PROCEDURE -recv(sockfd: Int32; buf: SYS.ADDRESS; len: Int64; flags: Int32):Int64
    "(HUGEINT)recv(sockfd, buf, len, flags)";

(*
 PROCEDURE -SizeofSockaddr(): INTEGER
    "sizeof(sockaddr)";

  PROCEDURE -Error(msg: ARRAY OF CHAR; len: INTEGER)
    "write(1/*stdout*/, msg, len); char ch = 0xa; write(1, &ch, 1)";

  PROCEDURE sockaddrCheck; (* check for inconsistent usage of sigjmp_buf; better avoid Unix_JmpBuf *)
    VAR x, y: LONGINT;
  BEGIN
    x := SizeofSockaddr();
    y := SIZE(SockAddr);
    IF x # y THEN
      Error("sockets.sockaddrCheck: inconsistent usage of sockaddr", 52);
      HALT(1);
    END
END sockaddrCheck;
*)
BEGIN


END sockets.