Changeset 96864 in vbox for trunk

Timestamp:

Sep 26, 2022 2:38:59 PM (2 years ago)

Author:

vboxsync

svn:sync-xref-src-repo-rev:

153771

Message:

Runtime: Implement RTUdpCreateServerSocket(), bugref:9822

Location:

trunk

Files:

• include/iprt/mangling.h (modified) (1 diff)
• include/iprt/udp.h (modified) (1 diff)
• src/VBox/Runtime/r3/udp.cpp (modified) (1 diff)

trunk/include/iprt/mangling.h

@@ -2758 +2758 @@
 # define RTTraceSetDefaultBuf                           RT_MANGLER(RTTraceSetDefaultBuf)
 # define RTUdpCreateClientSocket                        RT_MANGLER(RTUdpCreateClientSocket)
+# define RTUdpCreateServerSocket                        RT_MANGLER(RTUdpCreateServerSocket)
 # define RTUdpRead                                      RT_MANGLER(RTUdpRead)
 # define RTUdpServerCreate                              RT_MANGLER(RTUdpServerCreate)

trunk/include/iprt/udp.h

@@ -175 +175 @@
 RTR3DECL(int) RTUdpCreateClientSocket(const char *pszAddress, uint32_t uPort, PRTNETADDR pLocalAddr, PRTSOCKET pSock);
 
+/**
+ * Create a data socket acting as a server.
+ *
+ * @returns iprt status code.
+ * @param   pszAddress          The address to connect to.
+ * @param   uPort               The port to connect to.
+ * @param   pSock               Where to store the handle to the established connection.
+ */
+RTR3DECL(int) RTUdpCreateServerSocket(const char *pszAddress, uint32_t uPort, PRTSOCKET pSock);
+
 /** @} */
 RT_C_DECLS_END

trunk/src/VBox/Runtime/r3/udp.cpp

@@ -736 +736 @@
 }
 
+
+RTR3DECL(int) RTUdpCreateServerSocket(const char *pszAddress, uint32_t uPort, PRTSOCKET pSock)
+{
+    /*
+     * Validate input.
+     */
+    AssertReturn(uPort > 0, VERR_INVALID_PARAMETER);
+    AssertPtrReturn(pszAddress, VERR_INVALID_POINTER);
+    AssertPtrReturn(pSock, VERR_INVALID_POINTER);
+
+    /*
+     * Resolve the address.
+     */
+    RTNETADDR LocalAddr;
+    int rc = RTSocketParseInetAddress(pszAddress, uPort, &LocalAddr);
+    if (RT_FAILURE(rc))
+        return rc;
+
+    /*
+     * Setting up socket.
+     */
+    RTSOCKET Sock;
+    rc = rtSocketCreate(&Sock, AF_INET, SOCK_DGRAM, IPPROTO_UDP, false /*fInheritable*/);
+    if (RT_SUCCESS(rc))
+    {
+        /*
+         * Set socket options.
+         */
+        int fFlag = 1;
+        if (!rtSocketSetOpt(Sock, SOL_SOCKET, SO_REUSEADDR, &fFlag, sizeof(fFlag)))
+        {
+            /*
+             * Bind a name to the socket.
+             */
+            rc = rtSocketBind(Sock, &LocalAddr);
+            if (RT_SUCCESS(rc))
+            {
+                *pSock = Sock;
+                return VINF_SUCCESS;
+            }
+        }
+        RTSocketClose(Sock);
+    }
+    return rc;
+}