diff options
Diffstat (limited to 'pr/tests/abstract.c')
| -rw-r--r--[-rwxr-xr-x] | pr/tests/abstract.c | 244 |
1 files changed, 122 insertions, 122 deletions
diff --git a/pr/tests/abstract.c b/pr/tests/abstract.c index 47c4637a..3d255c1c 100755..100644 --- a/pr/tests/abstract.c +++ b/pr/tests/abstract.c @@ -15,143 +15,143 @@ 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); + 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); } - 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); + + 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 += len; - } - if (PR_Close(socket) == PR_FAILURE) { - fprintf(stderr, "PR_Close failed\n"); - exit(1); - } + 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); + 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); } - 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); + + 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); } - 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; + printf("PASS\n"); + return 0; } #else int main() { - printf("PASS\n"); - return 0; + printf("PASS\n"); + return 0; } #endif |