/* -*- 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/. */ /* * File: pipeping.c * * Description: * This test runs in conjunction with the pipepong test. * This test creates two pipes and redirects the stdin and * stdout of the pipepong test to the pipes. Then this * test writes "ping" to the pipepong test and the pipepong * test writes "pong" back. To run this pair of tests, * just invoke pipeping. * * Tested areas: process creation, pipes, file descriptor * inheritance, standard I/O redirection. */ #include "prerror.h" #include "prio.h" #include "prproces.h" #include #include #include #ifdef XP_OS2 static char *child_argv[] = { "pipepong.exe", NULL }; #else static char *child_argv[] = { "pipepong", NULL }; #endif #define NUM_ITERATIONS 10 int main(int argc, char **argv) { PRFileDesc *in_pipe[2]; PRFileDesc *out_pipe[2]; PRStatus status; PRProcess *process; PRProcessAttr *attr; char buf[1024]; PRInt32 nBytes; PRInt32 exitCode; int idx; status = PR_CreatePipe(&in_pipe[0], &in_pipe[1]); if (status == PR_FAILURE) { fprintf(stderr, "PR_CreatePipe failed\n"); exit(1); } status = PR_CreatePipe(&out_pipe[0], &out_pipe[1]); if (status == PR_FAILURE) { fprintf(stderr, "PR_CreatePipe failed\n"); exit(1); } status = PR_SetFDInheritable(in_pipe[0], PR_FALSE); if (status == PR_FAILURE) { fprintf(stderr, "PR_SetFDInheritable failed\n"); exit(1); } status = PR_SetFDInheritable(in_pipe[1], PR_TRUE); if (status == PR_FAILURE) { fprintf(stderr, "PR_SetFDInheritable failed\n"); exit(1); } status = PR_SetFDInheritable(out_pipe[0], PR_TRUE); if (status == PR_FAILURE) { fprintf(stderr, "PR_SetFDInheritable failed\n"); exit(1); } status = PR_SetFDInheritable(out_pipe[1], PR_FALSE); if (status == PR_FAILURE) { fprintf(stderr, "PR_SetFDInheritable failed\n"); exit(1); } attr = PR_NewProcessAttr(); if (attr == NULL) { fprintf(stderr, "PR_NewProcessAttr failed\n"); exit(1); } PR_ProcessAttrSetStdioRedirect(attr, PR_StandardInput, out_pipe[0]); PR_ProcessAttrSetStdioRedirect(attr, PR_StandardOutput, in_pipe[1]); process = PR_CreateProcess(child_argv[0], child_argv, NULL, attr); if (process == NULL) { fprintf(stderr, "PR_CreateProcess failed\n"); exit(1); } PR_DestroyProcessAttr(attr); status = PR_Close(out_pipe[0]); if (status == PR_FAILURE) { fprintf(stderr, "PR_Close failed\n"); exit(1); } status = PR_Close(in_pipe[1]); if (status == PR_FAILURE) { fprintf(stderr, "PR_Close failed\n"); exit(1); } for (idx = 0; idx < NUM_ITERATIONS; idx++) { strcpy(buf, "ping"); printf("ping process: sending \"%s\"\n", buf); nBytes = PR_Write(out_pipe[1], buf, 5); if (nBytes == -1) { fprintf(stderr, "PR_Write failed: (%d, %d)\n", PR_GetError(), PR_GetOSError()); exit(1); } memset(buf, 0, sizeof(buf)); nBytes = PR_Read(in_pipe[0], buf, sizeof(buf)); if (nBytes == -1) { fprintf(stderr, "PR_Read failed: (%d, %d)\n", PR_GetError(), PR_GetOSError()); exit(1); } printf("ping process: received \"%s\"\n", buf); if (nBytes != 5) { fprintf(stderr, "ping process: expected 5 bytes but got %d bytes\n", nBytes); exit(1); } if (strcmp(buf, "pong") != 0) { fprintf(stderr, "ping process: expected \"pong\" but got \"%s\"\n", buf); exit(1); } } status = PR_Close(in_pipe[0]); if (status == PR_FAILURE) { fprintf(stderr, "PR_Close failed\n"); exit(1); } status = PR_Close(out_pipe[1]); if (status == PR_FAILURE) { fprintf(stderr, "PR_Close failed\n"); exit(1); } status = PR_WaitProcess(process, &exitCode); if (status == PR_FAILURE) { fprintf(stderr, "PR_WaitProcess failed\n"); exit(1); } if (exitCode == 0) { printf("PASS\n"); return 0; } else { printf("FAIL\n"); return 1; } }