Adding upstream version 115.7.0esr.upstream/115.7.0esr

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 157 insertions, 0 deletions

diff --git a/nsprpub/pr/tests/abstract.c b/nsprpub/pr/tests/abstract.c
new file mode 100644
index 0000000000..3d255c1c2b
--- /dev/null
+++ b/nsprpub/pr/tests/abstract.c
@@ -0,0 +1,157 @@
+/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
+/* This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
+
+#include <stdio.h>
+
+#if defined(LINUX)
+
+#include <string.h>
+#include "nspr.h"
+
+static const char abstractSocketName[] = "\0testsocket";
+
+static void
+ClientThread(void* aArg)
+{
+    PRFileDesc* socket;
+    PRNetAddr addr;
+    PRUint8 buf[1024];
+    PRInt32 len;
+    PRInt32 total;
+
+    addr.local.family = PR_AF_LOCAL;
+    memcpy(addr.local.path, abstractSocketName, sizeof(abstractSocketName));
+
+    socket = PR_OpenTCPSocket(addr.raw.family);
+    if (!socket) {
+        fprintf(stderr, "PR_OpenTCPSokcet failed\n");
+        exit(1);
+    }
+
+    if (PR_Connect(socket, &addr, PR_INTERVAL_NO_TIMEOUT) == PR_FAILURE) {
+        fprintf(stderr, "PR_Connect failed\n");
+        exit(1);
+    }
+
+    total = 0;
+    while (total < sizeof(buf)) {
+        len = PR_Recv(socket, buf + total, sizeof(buf) - total, 0,
+                      PR_INTERVAL_NO_TIMEOUT);
+        if (len < 1) {
+            fprintf(stderr, "PR_Recv failed\n");
+            exit(1);
+        }
+        total += len;
+    }
+
+    total = 0;
+    while (total < sizeof(buf)) {
+        len = PR_Send(socket, buf + total, sizeof(buf) - total, 0,
+                      PR_INTERVAL_NO_TIMEOUT);
+        if (len < 1) {
+            fprintf(stderr, "PR_Send failed\n");
+            exit(1);
+        }
+        total += len;
+    }
+
+    if (PR_Close(socket) == PR_FAILURE) {
+        fprintf(stderr, "PR_Close failed\n");
+        exit(1);
+    }
+}
+
+int
+main()
+{
+    PRFileDesc* socket;
+    PRFileDesc* acceptSocket;
+    PRThread* thread;
+    PRNetAddr addr;
+    PRUint8 buf[1024];
+    PRInt32 len;
+    PRInt32 total;
+
+    addr.local.family = PR_AF_LOCAL;
+    memcpy(addr.local.path, abstractSocketName, sizeof(abstractSocketName));
+
+    socket = PR_OpenTCPSocket(addr.raw.family);
+    if (!socket) {
+        fprintf(stderr, "PR_OpenTCPSocket failed\n");
+        exit(1);
+    }
+    if (PR_Bind(socket, &addr) == PR_FAILURE) {
+        fprintf(stderr, "PR_Bind failed\n");
+        exit(1);
+    }
+
+    if (PR_Listen(socket, 5) == PR_FAILURE) {
+        fprintf(stderr, "PR_Listen failed\n");
+        exit(1);
+    }
+
+    thread = PR_CreateThread(PR_USER_THREAD, ClientThread, 0, PR_PRIORITY_NORMAL,
+                             PR_GLOBAL_THREAD, PR_JOINABLE_THREAD, 0);
+    if (!thread) {
+        fprintf(stderr, "PR_CreateThread failed");
+        exit(1);
+    }
+
+    acceptSocket  = PR_Accept(socket, NULL, PR_INTERVAL_NO_TIMEOUT);
+    if (!acceptSocket) {
+        fprintf(stderr, "PR_Accept failed\n");
+        exit(1);
+    }
+
+    memset(buf, 'A', sizeof(buf));
+
+    total = 0;
+    while (total < sizeof(buf)) {
+        len = PR_Send(acceptSocket, buf + total, sizeof(buf) - total, 0,
+                      PR_INTERVAL_NO_TIMEOUT);
+        if (len < 1) {
+            fprintf(stderr, "PR_Send failed\n");
+            exit(1);
+        }
+        total += len;
+    }
+
+    total = 0;
+    while (total < sizeof(buf)) {
+        len = PR_Recv(acceptSocket, buf + total, sizeof(buf) - total, 0,
+                      PR_INTERVAL_NO_TIMEOUT);
+        if (len < 1) {
+            fprintf(stderr, "PR_Recv failed\n");
+            exit(1);
+        }
+        total += len;
+    }
+
+    if (PR_Close(acceptSocket) == PR_FAILURE) {
+        fprintf(stderr, "PR_Close failed\n");
+        exit(1);
+    }
+
+    if (PR_JoinThread(thread) == PR_FAILURE) {
+        fprintf(stderr, "PR_JoinThread failed\n");
+        exit(1);
+    }
+
+    if (PR_Close(socket) == PR_FAILURE) {
+        fprintf(stderr, "PR_Close failed\n");
+        exit(1);
+    }
+    printf("PASS\n");
+    return 0;
+}
+
+#else
+int
+main()
+{
+    printf("PASS\n");
+    return 0;
+}
+#endif