now test server can listen on any ipv4 address.

This commit is contained in:
Norayr Chilingarian 2025-02-21 04:52:54 +04:00
parent e36e862c8c
commit 2178fa7b18
2 changed files with 68 additions and 62 deletions

View file

@ -4,7 +4,7 @@ IMPORT sockets, types, Out := Console, SYSTEM, Platform, Strings;
PROCEDURE DoSmth(sock: Platform.FileHandle);
VAR
VAR
str, aff: ARRAY 256 OF CHAR;
n: LONGINT;
BEGIN
@ -15,7 +15,7 @@ BEGIN
ELSE
str[n] := 0X; (* Make sure that received message is zero terminated *)
Out.String("received message is "); Out.String(str); Out.Ln;
IF Platform.Write(sock, SYSTEM.ADR(aff), Strings.Length(aff)) # 0 THEN
Out.String("error writing to socket"); Out.Ln
END;
@ -29,16 +29,17 @@ PROCEDURE -fork(): LONGINT "(LONGINT)fork()";
PROCEDURE serve;
CONST
CONST
Port = 2055;
MaxQueue = 5;
VAR
VAR
sockfd: LONGINT;
newsockfd: LONGINT;
ServAddr: sockets.SockAddrIn;
pid: LONGINT;
res: Platform.ErrorCode;
sockaddrlen: LONGINT;
ipAddr: LONGINT; ip: ARRAY 16 OF CHAR;
BEGIN
sockfd := sockets.Socket(sockets.AfInet, sockets.SockStream, 0);
IF sockfd < 0 THEN
@ -47,15 +48,17 @@ BEGIN
Out.String("socket created.")
END;
Out.Ln;
COPY("127.0.0.1", ip);
ipAddr := sockets.inetaddr(ip);
sockets.SetSockAddrIn(sockets.AfInet, Port, 0, ServAddr);
sockets.SetSockAddrIn(sockets.AfInet, Port, ipAddr, ServAddr);
IF sockets.Bind(sockfd, SYSTEM.VAL(sockets.SockAddr, ServAddr), SIZE(sockets.SockAddr)) < 0 THEN
Out.String("error on binding")
ELSE
Out.String("binding completed.")
END;
Out.Ln;
IF sockets.Listen(sockfd, MaxQueue) # 0 THEN
Out.String("listen() failed");
ELSE

View file

@ -2,60 +2,60 @@ MODULE sockets;
IMPORT SYSTEM, oocC;
CONST
SockStream* = 1;
SockDgram* = 2;
SockRaw* = 3;
SockRdm* = 4;
SockSeqpacket* = 5;
SockDccp* = 6;
SockPacket* = 10;
AfUnscec* = 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;
CONST
SockStream* = 1;
SockDgram* = 2;
SockRaw* = 3;
SockRdm* = 4;
SockSeqpacket* = 5;
SockDccp* = 6;
SockPacket* = 10;
AfUnscec* = 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 *)
@ -70,13 +70,16 @@ TYPE
SinZero*: ARRAY 8 OF CHAR;
END;
(* /usr/include/sys/socket.h *)
SockAddr* = RECORD
SaFamily*: oocC.shortint;
SaData*: ARRAY 14 OF CHAR
END;
PROCEDURE -includesocket "#include <sys/socket.h>";
PROCEDURE -includeInet "#include <arpa/inet.h>";
PROCEDURE -inetaddr*(s: ARRAY OF CHAR): LONGINT "(LONGINT)inet_addr((char*)s)";
PROCEDURE -SetCShort(i: INTEGER; VAR si: oocC.shortint)
"*(short*)si = i";
@ -84,7 +87,7 @@ TYPE
PROCEDURE -SetCShortSwapped(i: INTEGER; VAR si: oocC.shortint)
"*(short*)si = ((i >> 8) & 0x00ff) | ((i << 8) & 0xff00)";
PROCEDURE SetSockAddrIn*(family, port, inaddr: INTEGER; VAR sai: SockAddrIn);
PROCEDURE SetSockAddrIn*(family, port: INTEGER; inaddr: LONGINT; VAR sai: SockAddrIn);
VAR i: INTEGER;
BEGIN
SetCShort(family, sai.SinFamily);