*/
TestSuite_t TestSuite_new(void)
{
- TestSuite_t testSuite = calloc(1,sizeof(s_TestSuite_t));
-
- if(NULL == testSuite){
- setErrno(E_TEST_SUITE_ALLOCATION_FAILED);
- TestSuite_free(testSuite);
- return NULL;
- }
-
- testSuite->stream = Stream_new();
-
- if(NULL == testSuite->stream){
- TestSuite_free(testSuite);
- return NULL;
- }
-
- testSuite->test_case_context = TestCaseContext_new();
-
- if(NULL == testSuite->test_case_context){
- TestSuite_free(testSuite);
- return NULL;
- }
-
- testSuite->test_case_context->hConsole = GetStdHandle(STD_OUTPUT_HANDLE);
-
- testSuite->threads = ThreadDynarray_new(15);
-
- if(NULL == testSuite->threads){
- TestSuite_free(testSuite);
- return NULL;
- }
+ TestSuite_t testSuite = calloc(1, sizeof(s_TestSuite_t));
+
+ if (NULL == testSuite) {
+ setErrno(E_TEST_SUITE_ALLOCATION_FAILED);
+ TestSuite_free(testSuite);
+ return NULL;
+ }
+
+ testSuite->stream = Stream_new();
+
+ if (NULL == testSuite->stream) {
+ TestSuite_free(testSuite);
+ return NULL;
+ }
+
+ testSuite->test_case_context = TestCaseContext_new();
+
+ if (NULL == testSuite->test_case_context) {
+ TestSuite_free(testSuite);
+ return NULL;
+ }
- testSuite->successCount = 0;
- testSuite->failureCount = 0;
-
- return testSuite;
+ testSuite->test_case_context->hConsole = GetStdHandle(STD_OUTPUT_HANDLE);
+
+ testSuite->threads = ThreadDynarray_new(15);
+
+ if (NULL == testSuite->threads) {
+ TestSuite_free(testSuite);
+ return NULL;
+ }
+
+ testSuite->successCount = 0;
+ testSuite->failureCount = 0;
+
+ return testSuite;
}
/*
* Initialize the s_TestSuite structure.
*/
-errno_t TestSuite_initialize(TestSuite_t ptr,int argc,char *argv[])
+errno_t TestSuite_initialize(TestSuite_t ptr, int argc, char *argv[])
{
- switch(argc)
- {
- case 1:
- TestSuite_print("Run the test case from the console.\n");
-
- ptr->stream->file = stdin;
- return E_SUCCESS;
-
- case 2:
-
- if(E_SUCCESS != Stream_isValidFile(argv[1]))
- return getErrno();
-
- printf("\n\n Test runner : %s\n\n",argv[1]);
-
- if(E_SUCCESS != Stream_openFile(ptr->stream,argv[1]))
- return getErrno();
-
- return E_SUCCESS;
-
- default:
- {
- setErrno(E_BAD_USAGE);
- return getErrno();
- }
- }
+ switch (argc) {
+ case 1:
+ TestSuite_print("Run the test case from the console.\n");
+
+ ptr->stream->file = stdin;
+ return E_SUCCESS;
+
+ case 2:
+
+ if (E_SUCCESS != Stream_isValidFile(argv[1]))
+ return getErrno();
+
+ printf("\n\n Test runner : %s\n\n", argv[1]);
+
+ if (E_SUCCESS != Stream_openFile(ptr->stream, argv[1]))
+ return getErrno();
+
+ return E_SUCCESS;
+
+ default:
+ {
+ setErrno(E_BAD_USAGE);
+ return getErrno();
+ }
+ }
}
/*
*/
void TestSuite_run(TestSuite_t testSuite)
{
- Stream_t stream = testSuite->stream;
-
- /* Handle all lines in the testsuite file (or from stdin) */
- while((Stream_getLine(stream) != -1) && (E_SUCCESS == getErrno()))
- {
- /* Don't process blank lines. */
- if (Stream_lineIsBlank(stream))
- continue;
-
- /* Check if the current text line contains a invalid token. */
- if(Stream_lineContainsInvalidToken(stream))
- return;
-
- /* Check if the text line contains a meta command. */
- if(Stream_lineIsMetaCommand(stream)){
- /* Check if the current text line contains a unknown meta command. */
- if(Stream_lineIsUnknwnMetaCommand(stream))
- return;
-
- /* Check the meta command validity.*/
- if(Stream_lineIsInvalidMetaCommand(stream))
- return;
-
- /* We have a valid meta command, process it */
- if(E_SUCCESS != TestSuite_processMetaCommand(testSuite))
- return;
-
- continue;
- }
-
- /* Handle the comment. */
- if(Stream_lineIsComment(stream)){
- Stream_printLine(testSuite->stream,comment_line_type);
- continue;
- }
-
- /* Handle expected child output. */
- if(Stream_lineIsExpectedChildOutput(stream)){
- if(E_SUCCESS != TestSuite_processExpectedChildOutput(testSuite))
- return;
-
- continue;
- }
-
- /* Handle expected child input. */
- if(Stream_lineIsChildInput(stream)){
- if(E_SUCCESS != TestSuite_processChildInput(testSuite))
- return;
-
- continue;
- }
-
- if(Stream_lineIsChangeDir(stream)){
- if(E_SUCCESS != TestSuite_changeDir(testSuite))
- return;
-
- continue;
- }
-
- /* Handle synchrone synchrone test case. */
- if(Stream_lineIsSyncTestCase(stream)){
- TestCaseContext_setName(testSuite->test_case_context,stream->line + 2);
-
- TestSuite_runSyncTestCase(testSuite->test_case_context);
-
-
- if(TestSuite_iSPostOutputCheckingEnabled(testSuite->test_case_context)){
- TestSuite_checkChildOutput(testSuite->test_case_context);
- }
-
- if(TestSuite_iSExitCodeCheckingEnabled(testSuite->test_case_context)){
- if(E_SUCCESS != TestSuite_checkChildExitCode(testSuite->test_case_context))
- return;
- }
-
-
- if(E_SUCCESS != getErrno())
- return;
- }
- /* Handle asynchrone synchrone test case. */
- else if(Stream_lineIsAsyncTestCase(stream))
- {
- TestCaseContext_setName(testSuite->test_case_context,stream->line + 2);
-
- if(E_SUCCESS != TestSuite_runAsyncTestCase(testSuite))
- return;
- }
- else
- {
- ASSERT(false);
- }
-
- /* Clear the child input stream. */
- Buffer_clear(testSuite->test_case_context->inputBuffer);
- /* Clear the command line buffer. */
- Buffer_clear(testSuite->test_case_context->commandLineBuffer);
- }
+ Stream_t stream = testSuite->stream;
+
+ /* Handle all lines in the testsuite file (or from stdin) */
+ while ((Stream_getLine(stream) != -1) && (E_SUCCESS == getErrno())) {
+ /* Don't process blank lines. */
+ if (Stream_lineIsBlank(stream))
+ continue;
+
+ /* Check if the current text line contains a invalid token. */
+ if (Stream_lineContainsInvalidToken(stream))
+ return;
+
+ /* Check if the text line contains a meta command. */
+ if (Stream_lineIsMetaCommand(stream)) {
+ /* Check if the current text line contains a unknown meta command. */
+ if (Stream_lineIsUnknwnMetaCommand(stream))
+ return;
+
+ /* Check the meta command validity. */
+ if (Stream_lineIsInvalidMetaCommand(stream))
+ return;
+
+ /* We have a valid meta command, process it */
+ if (E_SUCCESS != TestSuite_processMetaCommand(testSuite))
+ return;
+
+ continue;
+ }
+
+ /* Handle the comment. */
+ if (Stream_lineIsComment(stream)) {
+ Stream_printLine(testSuite->stream, comment_line_type);
+ continue;
+ }
+
+ /* Handle expected child output. */
+ if (Stream_lineIsExpectedChildOutput(stream)) {
+ if (E_SUCCESS != TestSuite_processExpectedChildOutput(testSuite))
+ return;
+
+ continue;
+ }
+
+ /* Handle expected child input. */
+ if (Stream_lineIsChildInput(stream)) {
+ if (E_SUCCESS != TestSuite_processChildInput(testSuite))
+ return;
+
+ continue;
+ }
+
+ if (Stream_lineIsChangeDir(stream)) {
+ if (E_SUCCESS != TestSuite_changeDir(testSuite))
+ return;
+
+ continue;
+ }
+
+ /* Handle synchrone synchrone test case. */
+ if (Stream_lineIsSyncTestCase(stream)) {
+ TestCaseContext_setName(testSuite->test_case_context,
+ stream->line + 2);
+
+ TestSuite_runSyncTestCase(testSuite->test_case_context);
+
+
+ if (TestSuite_iSPostOutputCheckingEnabled
+ (testSuite->test_case_context)) {
+ TestSuite_checkChildOutput(testSuite->test_case_context);
+ }
+
+ if (TestSuite_iSExitCodeCheckingEnabled
+ (testSuite->test_case_context)) {
+ if (E_SUCCESS !=
+ TestSuite_checkChildExitCode(testSuite->test_case_context))
+ return;
+ }
+
+
+ if (E_SUCCESS != getErrno())
+ return;
+ }
+ /* Handle asynchrone synchrone test case. */
+ else if (Stream_lineIsAsyncTestCase(stream)) {
+ TestCaseContext_setName(testSuite->test_case_context,
+ stream->line + 2);
+
+ if (E_SUCCESS != TestSuite_runAsyncTestCase(testSuite))
+ return;
+ } else {
+ ASSERT(false);
+ }
+
+ /* Clear the child input stream. */
+ Buffer_clear(testSuite->test_case_context->inputBuffer);
+ /* Clear the command line buffer. */
+ Buffer_clear(testSuite->test_case_context->commandLineBuffer);
+ }
}
+
/*
* Meta command processing.
*/
errno_t TestSuite_processMetaCommand(TestSuite_t testSuite)
{
- Stream_t stream = testSuite->stream;
-
- if(!strncmp("set timeout ",stream->line + 2,strlen("set timeout ")))
- {
- TestSuite_setTimeout(testSuite);
- }
- else if(!strncmp("command line ",stream->line + 2,strlen("command line")))
- {
- TestSuite_setCommandLine(testSuite);
- }
- else if(!strncmp("enable output checking",stream->line + 2,strlen("enable output checking")))
- {
- TestSuite_enableOutputChecking(testSuite);
- }
- else if(!strncmp("disable output checking",stream->line + 2,strlen("disable output checking")))
- {
- TestSuite_disableOutputChecking(testSuite);
- }
- else if(!strncmp("enable post output checking",stream->line + 2,strlen("enable post output checking")))
- {
- TestSuite_enablePostOutputChecking(testSuite);
- }
- else if(!strncmp("disable post output checking",stream->line + 2,strlen("disable post output checking")))
- {
- TestSuite_disablePostOutputChecking(testSuite);
- }
- else if(!strncmp("expect exit code ",stream->line + 2,strlen("expect exit code ")))
- {
- TestSuite_setExpectedExitCode(testSuite);
- }
- else if(!strncmp("export ",stream->line + 2,strlen("export ")))
- {
- TestSuite_export(testSuite);
- }
- else if(!strncmp("unset ",stream->line + 2,strlen("unset ")))
- {
- TestSuite_unset(testSuite);
- }
- else if(!strncmp("create console",stream->line + 2,strlen("create console")))
- {
- TestSuite_createConsole(testSuite);
- }
- else if(!strncmp("create no console",stream->line + 2,strlen("create no console")))
- {
- TestSuite_createNoConsole(testSuite);
- }
- else if(!strncmp("enable exit code checking",stream->line + 2,strlen("enable exit code checking")))
- {
- TestSuite_enableExitCodeChecking(testSuite);
- }
- else if(!strncmp("disable exit code checking",stream->line + 2,strlen("disable exit code checking")))
- {
- TestSuite_disableExitCodeChecking(testSuite);
- }
- else
- {
- /* TODO */
- ASSERT(false);
- }
-
- return E_SUCCESS;
-
+ Stream_t stream = testSuite->stream;
+
+ if (!strncmp("set timeout ", stream->line + 2, strlen("set timeout "))) {
+ TestSuite_setTimeout(testSuite);
+ } else
+ if (!strncmp
+ ("command line ", stream->line + 2, strlen("command line"))) {
+ TestSuite_setCommandLine(testSuite);
+ } else
+ if (!strncmp
+ ("enable output checking", stream->line + 2,
+ strlen("enable output checking"))) {
+ TestSuite_enableOutputChecking(testSuite);
+ } else
+ if (!strncmp
+ ("disable output checking", stream->line + 2,
+ strlen("disable output checking"))) {
+ TestSuite_disableOutputChecking(testSuite);
+ } else
+ if (!strncmp
+ ("enable post output checking", stream->line + 2,
+ strlen("enable post output checking"))) {
+ TestSuite_enablePostOutputChecking(testSuite);
+ } else
+ if (!strncmp
+ ("disable post output checking", stream->line + 2,
+ strlen("disable post output checking"))) {
+ TestSuite_disablePostOutputChecking(testSuite);
+ } else
+ if (!strncmp
+ ("expect exit code ", stream->line + 2,
+ strlen("expect exit code "))) {
+ TestSuite_setExpectedExitCode(testSuite);
+ } else if (!strncmp("export ", stream->line + 2, strlen("export "))) {
+ TestSuite_export(testSuite);
+ } else if (!strncmp("unset ", stream->line + 2, strlen("unset "))) {
+ TestSuite_unset(testSuite);
+ } else
+ if (!strncmp
+ ("create console", stream->line + 2, strlen("create console"))) {
+ TestSuite_createConsole(testSuite);
+ } else
+ if (!strncmp
+ ("create no console", stream->line + 2,
+ strlen("create no console"))) {
+ TestSuite_createNoConsole(testSuite);
+ } else
+ if (!strncmp
+ ("enable exit code checking", stream->line + 2,
+ strlen("enable exit code checking"))) {
+ TestSuite_enableExitCodeChecking(testSuite);
+ } else
+ if (!strncmp
+ ("disable exit code checking", stream->line + 2,
+ strlen("disable exit code checking"))) {
+ TestSuite_disableExitCodeChecking(testSuite);
+ } else {
+ /* TODO */
+ ASSERT(false);
+ }
+
+ return E_SUCCESS;
+
}
/*
*/
void TestSuite_setTimeout(TestSuite_t testSuite)
{
-
- int timeout = atoi(testSuite->stream->line + 2 + strlen("set timeout "));
- TestCaseContext_setTimeout(testSuite->test_case_context,timeout);
+
+ int timeout = atoi(testSuite->stream->line + 2 + strlen("set timeout "));
+ TestCaseContext_setTimeout(testSuite->test_case_context, timeout);
}
/*
*/
void TestSuite_enableOutputChecking(TestSuite_t testSuite)
{
- TestCaseContext_enableOutputChecking(testSuite->test_case_context);
+ TestCaseContext_enableOutputChecking(testSuite->test_case_context);
}
void TestSuite_setCommandLine(TestSuite_t testSuite)
{
- TestCaseContext_setCommandLine(testSuite->test_case_context,testSuite->stream->line + 2 + strlen("command line "));
+ TestCaseContext_setCommandLine(testSuite->test_case_context,
+ testSuite->stream->line + 2 +
+ strlen("command line "));
}
/*
*/
void TestSuite_disableOutputChecking(TestSuite_t testSuite)
{
- TestCaseContext_disableOutputChecking(testSuite->test_case_context);
+ TestCaseContext_disableOutputChecking(testSuite->test_case_context);
}
/*
*/
void TestSuite_enablePostOutputChecking(TestSuite_t testSuite)
{
- TestCaseContext_enable_post_output_checking(testSuite->test_case_context);
+ TestCaseContext_enable_post_output_checking(testSuite->
+ test_case_context);
}
void TestSuite_createConsole(TestSuite_t testSuite)
{
- TestCaseContext_createConsole(testSuite->test_case_context);
+ TestCaseContext_createConsole(testSuite->test_case_context);
}
void TestSuite_createNoConsole(TestSuite_t testSuite)
{
- TestCaseContext_createNoConsole(testSuite->test_case_context);
+ TestCaseContext_createNoConsole(testSuite->test_case_context);
}
/*
*/
void TestSuite_disablePostOutputChecking(TestSuite_t testSuite)
{
- TestCaseContext_disablePostOutputChecking(testSuite->test_case_context);
+ TestCaseContext_disablePostOutputChecking(testSuite->test_case_context);
}
/*
*/
void TestSuite_setExpectedExitCode(TestSuite_t testSuite)
{
- int expectedExitCode = atoi(testSuite->stream->line + 2 + strlen("expect exit code "));
- TestCaseContext_setExpectedExitCode(testSuite->test_case_context,expectedExitCode);
+ int expectedExitCode =
+ atoi(testSuite->stream->line + 2 + strlen("expect exit code "));
+ TestCaseContext_setExpectedExitCode(testSuite->test_case_context,
+ expectedExitCode);
}
void TestSuite_enableExitCodeChecking(TestSuite_t testSuite)
{
- TestCaseContext_enableExitCodeChecking(testSuite->test_case_context);
+ TestCaseContext_enableExitCodeChecking(testSuite->test_case_context);
}
void TestSuite_disableExitCodeChecking(TestSuite_t testSuite)
{
- TestCaseContext_disableExitCodeChecking(testSuite->test_case_context);
+ TestCaseContext_disableExitCodeChecking(testSuite->test_case_context);
}
*/
errno_t TestSuite_export(TestSuite_t testSuite)
{
- /* TODO trim */
- const char* ptr;
- const char* pos;
- char __buffer[50] = {0};
- char* line = testSuite->stream->line + strlen("export ");
-
- line[strlen(line) -1] = '\0';
-
- ptr = strchr(line,' ');
- pos= ++ptr;
- ptr = strchr(line,'=');
- strncpy(__buffer,pos,ptr - pos);
- if(!SetEnvironmentVariable(__buffer,++ptr))
- {
- setErrno(E_EXPORT_FAILED);
- Stream_printLine(testSuite->stream,export_failed_line_type);
- return getErrno();
-
- }
-
- return E_SUCCESS;
+ /* TODO trim */
+ const char *ptr;
+ const char *pos;
+ char __buffer[50] = { 0 };
+ char *line = testSuite->stream->line + strlen("export ");
+
+ line[strlen(line) - 1] = '\0';
+
+ ptr = strchr(line, ' ');
+ pos = ++ptr;
+ ptr = strchr(line, '=');
+ strncpy(__buffer, pos, ptr - pos);
+ if (!SetEnvironmentVariable(__buffer, ++ptr)) {
+ setErrno(E_EXPORT_FAILED);
+ Stream_printLine(testSuite->stream, export_failed_line_type);
+ return getErrno();
+
+ }
+
+ return E_SUCCESS;
}
errno_t TestSuite_unset(TestSuite_t testSuite)
{
- char line[128] = {0};
- const char* ptr;
- strcpy(line,testSuite->stream->line +2);
- ptr = strchr(line,' ');
- line[strlen(line) -1] = '\0';
-
- if(!SetEnvironmentVariable(++ptr,NULL))
- {
-
- setErrno(E_UNSET_FAILED);
- Stream_printLine(testSuite->stream,unset_failed_line_type);
- return getErrno();
- }
-
- return E_SUCCESS;
+ char line[128] = { 0 };
+ const char *ptr;
+ strcpy(line, testSuite->stream->line + 2);
+ ptr = strchr(line, ' ');
+ line[strlen(line) - 1] = '\0';
+
+ if (!SetEnvironmentVariable(++ptr, NULL)) {
+
+ setErrno(E_UNSET_FAILED);
+ Stream_printLine(testSuite->stream, unset_failed_line_type);
+ return getErrno();
+ }
+
+ return E_SUCCESS;
}
/*
*/
errno_t TestSuite_processExpectedChildOutput(TestSuite_t testSuite)
{
- /* TODO : logic error*/
- if(!TestCaseContext_isOutputCheckingEnabled(testSuite->test_case_context))
- return E_SUCCESS;
-
- /* TODO : trim */
- TestCaseContext_appendExpectedOutput(testSuite->test_case_context,testSuite->stream->line + 2);
-
- return E_SUCCESS;
+ /* TODO : logic error */
+ if (!TestCaseContext_isOutputCheckingEnabled
+ (testSuite->test_case_context))
+ return E_SUCCESS;
+
+ /* TODO : trim */
+ TestCaseContext_appendExpectedOutput(testSuite->test_case_context,
+ testSuite->stream->line + 2);
+
+ return E_SUCCESS;
}
/*
*/
errno_t TestSuite_processChildInput(TestSuite_t testSuite)
{
- /* TODO : trim */
- TestCaseContext_appendChildInput(testSuite->test_case_context,testSuite->stream->line + 2);
+ /* TODO : trim */
+ TestCaseContext_appendChildInput(testSuite->test_case_context,
+ testSuite->stream->line + 2);
- return E_SUCCESS;
+ return E_SUCCESS;
}
/*
*/
void TestSuite_free(TestSuite_t testSuite)
{
- ThreadEntry_t entry;
- unsigned long count;
- unsigned long i;
- DWORD dwWaitResult;
- bool steel_running;
- bool last_async_process_error = false;
- DWORD ExitCode = 0;
- errno_t e = getErrno();
-
- if(NULL == testSuite)
- return;
-
- count = ThreadDynarray_getCount(testSuite->threads);
-
- /* Wait for all asynchrone process */
- if(NULL != testSuite->threads && count)
- {
- while(true)
- {
- steel_running = false;
-
- for(i = 0;i < count ; i++)
- {
- entry = ThreadDynarray_at(testSuite->threads,i);
-
- GetExitCodeThread(entry->hThread,&ExitCode);
-
- if(STILL_ACTIVE == ExitCode)
- {
- Sleep(0);
- steel_running = true;
- }
- }
-
- if(!steel_running)
- break;
+ ThreadEntry_t entry;
+ unsigned long count;
+ unsigned long i;
+ DWORD dwWaitResult;
+ bool steel_running;
+ bool last_async_process_error = false;
+ DWORD ExitCode = 0;
+ errno_t e = getErrno();
+
+ if (NULL == testSuite)
+ return;
+
+ count = ThreadDynarray_getCount(testSuite->threads);
+
+ /* Wait for all asynchrone process */
+ if (NULL != testSuite->threads && count) {
+ while (true) {
+ steel_running = false;
+
+ for (i = 0; i < count; i++) {
+ entry = ThreadDynarray_at(testSuite->threads, i);
+
+ GetExitCodeThread(entry->hThread, &ExitCode);
+
+ if (STILL_ACTIVE == ExitCode) {
+ Sleep(0);
+ steel_running = true;
}
+ }
+
+ if (!steel_running)
+ break;
+ }
- for(i = 0;i <count;i++)
- {
- entry = ThreadDynarray_at(testSuite->threads,i);
-
- if(entry->context->pi.hProcess)
- {
- dwWaitResult=WaitForSingleObject(entry->hThread,INFINITE);
-
- if((WAIT_FAILED == dwWaitResult))
- TerminateThread(entry->hThread,0);
- else
- CloseHandle(entry->hThread);
- }
-
- /*if(((E_SUCCESS == e) || (E_EXIT_CODE_DONT_MATCH == e) || (E_OUTPUT_DONT_MATCH == e)) && !last_async_process_error)
- {*/
- /* Child output and exit code checking */
- if(TestSuite_iSPostOutputCheckingEnabled(entry->context))
- {
- if(E_SUCCESS != TestSuite_checkChildOutput(entry->context))
- last_async_process_error = true;
- }
-
- if(TestSuite_iSExitCodeCheckingEnabled(entry->context))
- {
- if(E_SUCCESS != TestSuite_checkChildExitCode(entry->context))
- last_async_process_error = true;
- }
- }
-
- TestCaseContext_free(entry->context);
- /*}*/
-
- ThreadDynarray_destroy(testSuite->threads);
+ for (i = 0; i < count; i++) {
+ entry = ThreadDynarray_at(testSuite->threads, i);
+
+ if (entry->context->pi.hProcess) {
+ dwWaitResult = WaitForSingleObject(entry->hThread, INFINITE);
+
+ if ((WAIT_FAILED == dwWaitResult))
+ TerminateThread(entry->hThread, 0);
+ else
+ CloseHandle(entry->hThread);
+ }
+
+ /*if(((E_SUCCESS == e) || (E_EXIT_CODE_DONT_MATCH == e) || (E_OUTPUT_DONT_MATCH == e)) && !last_async_process_error)
+ { */
+ /* Child output and exit code checking */
+ if (TestSuite_iSPostOutputCheckingEnabled(entry->context)) {
+ if (E_SUCCESS != TestSuite_checkChildOutput(entry->context))
+ last_async_process_error = true;
+ }
+
+ if (TestSuite_iSExitCodeCheckingEnabled(entry->context)) {
+ if (E_SUCCESS != TestSuite_checkChildExitCode(entry->context))
+ last_async_process_error = true;
+ }
}
- if(NULL != testSuite->test_case_context)
- TestCaseContext_free(testSuite->test_case_context);
-
- if(NULL != testSuite->stream)
- Stream_free(testSuite->stream);
-
- free(testSuite);
+ TestCaseContext_free(entry->context);
+ /*} */
+
+ ThreadDynarray_destroy(testSuite->threads);
+ }
+
+ if (NULL != testSuite->test_case_context)
+ TestCaseContext_free(testSuite->test_case_context);
+
+ if (NULL != testSuite->stream)
+ Stream_free(testSuite->stream);
+
+ free(testSuite);
}
/*
*/
errno_t TestSuite_checkChildOutput(TestCaseContext_t context)
{
- bool are_equals = false;
- char str[256] = {0};
-
-
- if (context->expectedOutputBuffer->size==0 && context->outputBuffer->size==0)
- return E_SUCCESS;
-
- Buffer_chomp(context->outputBuffer);
- Buffer_chomp(context->expectedOutputBuffer);
-
-
- if (context->outputBuffer->size != context->expectedOutputBuffer->size || strcmp(context->outputBuffer->data, context->expectedOutputBuffer->data))
- {
- strcpy(str,"<OUTPUT NOT MATCH > \n");
- TestSuite_print(str);
-
- }
- else
- {
- are_equals = true;
- strcpy(str,"<OUTPUT MATCH > \n");
- TestSuite_print(str);
-
-
- }
-
- memset(str,0,256);
-
- if(context->expectedOutputBuffer->size)
- {
- sprintf(str,"<EXPECTED > SIZE (%4d) DATA (%s)\n",context->expectedOutputBuffer->size,context->expectedOutputBuffer->data);
- TestSuite_print(str);
- }
- else
- {
- scanf(str,"<EXPECTED > SIZE (%4d) DATA (%s)\n",context->expectedOutputBuffer->size,"empty");
- TestSuite_print(str);
- }
-
- memset(str,0,256);
-
- if(context->outputBuffer->size)
- {
- sprintf(str,"<RECEIVED > SIZE (%4d) DATA (%s)\n",context->outputBuffer->size,context->outputBuffer->data);
- TestSuite_print(str);
- }
- else
- {
- sprintf(str,"<RECEIVED > SIZE (%4d) DATA (%s)\n",context->outputBuffer->size,"empty");
- TestSuite_print(str);
- }
-
- Buffer_clear(context->expectedOutputBuffer);
- Buffer_clear(context->outputBuffer);
-
- if(!are_equals)
- {
- setErrno(E_OUTPUT_DONT_MATCH);
- return getErrno();
- }
-
- return E_SUCCESS;
+ bool are_equals = false;
+ char str[256] = { 0 };
+
+
+ if (context->expectedOutputBuffer->size == 0
+ && context->outputBuffer->size == 0)
+ return E_SUCCESS;
+
+ Buffer_chomp(context->outputBuffer);
+ Buffer_chomp(context->expectedOutputBuffer);
+
+
+ if (context->outputBuffer->size != context->expectedOutputBuffer->size
+ || strcmp(context->outputBuffer->data,
+ context->expectedOutputBuffer->data)) {
+ strcpy(str, "<OUTPUT NOT MATCH > \n");
+ TestSuite_print(str);
+
+ } else {
+ are_equals = true;
+ strcpy(str, "<OUTPUT MATCH > \n");
+ TestSuite_print(str);
+
+
+ }
+
+ memset(str, 0, 256);
+
+ if (context->expectedOutputBuffer->size) {
+ sprintf(str,
+ "<EXPECTED > SIZE (%4d) DATA (%s)\n",
+ context->expectedOutputBuffer->size,
+ context->expectedOutputBuffer->data);
+ TestSuite_print(str);
+ } else {
+ scanf(str,
+ "<EXPECTED > SIZE (%4d) DATA (%s)\n",
+ context->expectedOutputBuffer->size, "empty");
+ TestSuite_print(str);
+ }
+
+ memset(str, 0, 256);
+
+ if (context->outputBuffer->size) {
+ sprintf(str,
+ "<RECEIVED > SIZE (%4d) DATA (%s)\n",
+ context->outputBuffer->size, context->outputBuffer->data);
+ TestSuite_print(str);
+ } else {
+ sprintf(str,
+ "<RECEIVED > SIZE (%4d) DATA (%s)\n",
+ context->outputBuffer->size, "empty");
+ TestSuite_print(str);
+ }
+
+ Buffer_clear(context->expectedOutputBuffer);
+ Buffer_clear(context->outputBuffer);
+
+ if (!are_equals) {
+ setErrno(E_OUTPUT_DONT_MATCH);
+ return getErrno();
+ }
+
+ return E_SUCCESS;
}
/*
* Check the child process exit code.
- */
+ */
errno_t TestSuite_checkChildExitCode(TestCaseContext_t context)
{
- bool __success = false;
- char str[256] = {0};
-
- sprintf(str,"<TEST CASE TERMINATED > %s %3ld\n",context->name,context->exitCode);
- TestSuite_print(str);
-
- memset(str,0,256);
-
- /* if a expected exit code was signaled, compare it with the real. */
- if(context->expectedExitCode != INVALID_EXIT_CODE)
- {
- if(context->expectedExitCode != context->exitCode )
- {
-
- TestSuite_print("<EXIT CODE DON'T MATCH >\n");
- }
- else
- {
- __success = true;
- TestSuite_print("<EXIT CODE MATCH >\n");
- }
- sprintf(str,"<EXIT CODE EXPECTED > (%3d)\n",context->expectedExitCode);
- TestSuite_print(str);
-
- memset(str,0,256);
-
- sprintf(str,"<EXIT CODE RETURNED > (%3d)\n",context->exitCode);
- TestSuite_print(str);
-
- context->expectedExitCode = INVALID_EXIT_CODE;
- }
-
- if(!__success)
- {
- setErrno(E_EXIT_CODE_DONT_MATCH);
- return getErrno();
- }
+ bool __success = false;
+ char str[256] = { 0 };
+
+ sprintf(str, "<TEST CASE TERMINATED > %s %3ld\n",
+ context->name, context->exitCode);
+ TestSuite_print(str);
+
+ memset(str, 0, 256);
- return E_SUCCESS;
+ /* if a expected exit code was signaled, compare it with the real. */
+ if (context->expectedExitCode != INVALID_EXIT_CODE) {
+ if (context->expectedExitCode != context->exitCode) {
+
+ TestSuite_print("<EXIT CODE DON'T MATCH >\n");
+ } else {
+ __success = true;
+ TestSuite_print("<EXIT CODE MATCH >\n");
+ }
+ sprintf(str, "<EXIT CODE EXPECTED > (%3d)\n",
+ context->expectedExitCode);
+ TestSuite_print(str);
+
+ memset(str, 0, 256);
+
+ sprintf(str, "<EXIT CODE RETURNED > (%3d)\n",
+ context->exitCode);
+ TestSuite_print(str);
+
+ context->expectedExitCode = INVALID_EXIT_CODE;
+ }
+
+ if (!__success) {
+ setErrno(E_EXIT_CODE_DONT_MATCH);
+ return getErrno();
+ }
+
+ return E_SUCCESS;
}
/*
*/
void TestSuite_terminate(TestSuite_t testSuite)
{
- TestCaseContext_t context = testSuite->test_case_context;
-
- /* cleanup the child_input_stream/output buffers. */
- if(NULL != context->inputBuffer)
- Buffer_free(context->inputBuffer);
-
- if(NULL != context->outputBuffer)
- Buffer_free(context->outputBuffer);
-
- if(NULL != context->expectedOutputBuffer)
- Buffer_free(context->expectedOutputBuffer);
-
- /* close the file stream. */
- if(NULL != testSuite->stream)
- Stream_free(testSuite->stream);
-
-
+ TestCaseContext_t context = testSuite->test_case_context;
+
+ /* cleanup the child_input_stream/output buffers. */
+ if (NULL != context->inputBuffer)
+ Buffer_free(context->inputBuffer);
+
+ if (NULL != context->outputBuffer)
+ Buffer_free(context->outputBuffer);
+
+ if (NULL != context->expectedOutputBuffer)
+ Buffer_free(context->expectedOutputBuffer);
+
+ /* close the file stream. */
+ if (NULL != testSuite->stream)
+ Stream_free(testSuite->stream);
+
+
}
/*
* Print message
*/
-void TestSuite_print(const char* str)
+void TestSuite_print(const char *str)
{
- char* t = (char*)calloc(1,20);
-
- __time(t);
+ char *t = (char *) calloc(1, 20);
- EnterCriticalSection(&cs);
- printf("%s %s",t,str);
- LeaveCriticalSection(&cs);
+ __time(t);
- free(t);
+ EnterCriticalSection(&cs);
+ printf("%s %s", t, str);
+ LeaveCriticalSection(&cs);
+
+ free(t);
}
-unsigned long WINAPI TestSuite_asyncReadChildOutput(void* param)
+unsigned long WINAPI TestSuite_asyncReadChildOutput(void *param)
{
- char str[1024] = {0};
- char __buffer[1024] = {0};
-
+ char str[1024] = { 0 };
+ char __buffer[1024] = { 0 };
+
DWORD nBytesRead;
DWORD nCharsWritten;
- TestCaseContext_t context = (TestCaseContext_t)param;
+ TestCaseContext_t context = (TestCaseContext_t) param;
HANDLE hPipeRead = context->hOutputRead;
-
- while (context->runThread)
- {
- if (!ReadFile(hPipeRead,str,sizeof(str),&nBytesRead,NULL) || !nBytesRead){
- if (GetLastError() == ERROR_BROKEN_PIPE){
- break;
- }
- else{
- /* TODO */
- context->threadExitCode = 1;
- exit(1);
- }
- }
-
- if(nBytesRead){
- if(context->isOutputCheckingEnabled){
- if(!Buffer_empty(context->outputBuffer))
- Buffer_clear(context->outputBuffer);
- TestSuite_print(str);
+ while (context->runThread) {
+ if (!ReadFile(hPipeRead, str, sizeof(str), &nBytesRead, NULL)
+ || !nBytesRead) {
+ if (GetLastError() == ERROR_BROKEN_PIPE) {
+ break;
+ } else {
+ /* TODO */
+ context->threadExitCode = 1;
+ exit(1);
+ }
+ }
+
+ if (nBytesRead) {
+ if (context->isOutputCheckingEnabled) {
+ if (!Buffer_empty(context->outputBuffer))
+ Buffer_clear(context->outputBuffer);
+
+ TestSuite_print(str);
+
+ Buffer_append(context->outputBuffer, str);
+ }
- Buffer_append(context->outputBuffer,str);
- }
-
- memset(str,0,1024);
- memset(__buffer,0,1024);
+ memset(str, 0, 1024);
+ memset(__buffer, 0, 1024);
}
-
+
}
- context->threadExitCode = 0;
- return 0;
+ context->threadExitCode = 0;
+ return 0;
}
errno_t TestSuite_runAsyncTestCase(TestSuite_t testSuite)
{
- DWORD ThreadId;
- s_ThreadEntry_t entry;
- /* = (ThreadEntry_t)calloc(1,sizeof(s_ThreadEntry_t));*/
-
- TestCaseContext_t context = testSuite->test_case_context;
- memset(&entry,0,sizeof(s_ThreadEntry_t));
- entry.context = TestCaseContext_new();
-
- Buffer_append(entry.context->inputBuffer,context->inputBuffer->data);
- Buffer_append(entry.context->outputBuffer,context->outputBuffer->data);
- Buffer_append(entry.context->expectedOutputBuffer,context->expectedOutputBuffer->data);
- Buffer_append(entry.context->commandLineBuffer,context->commandLineBuffer->data);
- entry.context->name = strdup(context->name);
- entry.context->timeoutValue = context->timeoutValue;
- entry.context->isOutputCheckingEnabled = context->isOutputCheckingEnabled;
- entry.context->isPostOutputCheckingEnabled = context->isPostOutputCheckingEnabled;
- entry.context->expectedExitCode = context->expectedExitCode;
- entry.context->createConsole = context->createConsole;
- entry.context->exitCodeCheckingEnabled = context->exitCodeCheckingEnabled;
- entry.context->hConsole = context->hConsole;
- Buffer_clear(context->inputBuffer);
- Buffer_clear(context->outputBuffer);
- Buffer_clear(context->expectedOutputBuffer);
- memset(&(entry.context->pi),0,sizeof(PROCESS_INFORMATION));
- entry.context->runThread = true;
-
- entry.hThread = CreateThread(NULL,0,TestSuite_runSyncTestCase,(LPVOID)entry.context,CREATE_SUSPENDED,&ThreadId);
- entry.threadId = ThreadId;
- ThreadDynarray_pushBack(testSuite->threads,&entry);
- ResumeThread(entry.hThread);
- Sleep(0);
- setErrno(E_SUCCESS);
-
- return getErrno();
+ DWORD ThreadId;
+ s_ThreadEntry_t entry;
+ /* = (ThreadEntry_t)calloc(1,sizeof(s_ThreadEntry_t)); */
+
+ TestCaseContext_t context = testSuite->test_case_context;
+ memset(&entry, 0, sizeof(s_ThreadEntry_t));
+ entry.context = TestCaseContext_new();
+
+ Buffer_append(entry.context->inputBuffer, context->inputBuffer->data);
+ Buffer_append(entry.context->outputBuffer, context->outputBuffer->data);
+ Buffer_append(entry.context->expectedOutputBuffer,
+ context->expectedOutputBuffer->data);
+ Buffer_append(entry.context->commandLineBuffer,
+ context->commandLineBuffer->data);
+ entry.context->name = strdup(context->name);
+ entry.context->timeoutValue = context->timeoutValue;
+ entry.context->isOutputCheckingEnabled =
+ context->isOutputCheckingEnabled;
+ entry.context->isPostOutputCheckingEnabled =
+ context->isPostOutputCheckingEnabled;
+ entry.context->expectedExitCode = context->expectedExitCode;
+ entry.context->createConsole = context->createConsole;
+ entry.context->exitCodeCheckingEnabled =
+ context->exitCodeCheckingEnabled;
+ entry.context->hConsole = context->hConsole;
+ Buffer_clear(context->inputBuffer);
+ Buffer_clear(context->outputBuffer);
+ Buffer_clear(context->expectedOutputBuffer);
+ memset(&(entry.context->pi), 0, sizeof(PROCESS_INFORMATION));
+ entry.context->runThread = true;
+
+ entry.hThread =
+ CreateThread(NULL, 0, TestSuite_runSyncTestCase,
+ (LPVOID) entry.context, CREATE_SUSPENDED, &ThreadId);
+ entry.threadId = ThreadId;
+ ThreadDynarray_pushBack(testSuite->threads, &entry);
+ ResumeThread(entry.hThread);
+ Sleep(0);
+ setErrno(E_SUCCESS);
+
+ return getErrno();
}
-unsigned long WINAPI TestSuite_runSyncTestCase( void* param)
+unsigned long WINAPI TestSuite_runSyncTestCase(void *param)
{
- STARTUPINFO si = {0};
- SECURITY_ATTRIBUTES sa = {0};
- DWORD dwWaitResult = 0;
- DWORD dwExitCode = 0;
- DWORD ThreadId;
- DWORD nBytes = 0;
- DWORD dwCreationMode = CREATE_NO_WINDOW;
- char cmdLine[4098] = {0};
-
- TestCaseContext_t context = (TestCaseContext_t)param;
- context->started = true;
-
-
- sa.nLength = sizeof(SECURITY_ATTRIBUTES);
- sa.lpSecurityDescriptor = NULL;
- /* The pipe handes can be inherited by the child. */
- sa.bInheritHandle = TRUE;
-
- /* Create a write pipe handle for the child std output */
- if(!CreatePipe(&(context->hChildStdoutReadTmp),&(context->hChildStdOutWrite),&sa,0))
- {
- setErrno(E_CANNOT_CREATE_CHILD_STDOUT_READ_HANDLE);
- return getErrno();
- }
-
- /*
- * Create a duplicate of the output write handle for the std error
- * write handle. This is necessary in case the child application closes
- * one of its std output handles.
- */
- if(!DuplicateHandle(GetCurrentProcess(),(context->hChildStdOutWrite),GetCurrentProcess(),&(context->hChildStderr),0,TRUE,DUPLICATE_SAME_ACCESS))
- {
- setErrno(E_CANNOT_CREATE_CHILD_STDERR_READ_HANDLE);
- return getErrno();
- }
-
- /* Create a read pipe handle for the child std input */
- if(!CreatePipe(&(context->hChildStdInRead),&(context->hChildStdinWriteTmp),&sa,0))
- {
- setErrno(E_CANNOT_CREATE_CHILD_STDIN_WRITE_HANDLE);
- return getErrno();
- }
-
-
- /* Create new output read handle and the input write handle use by
- * the parent process to communicate with his child. Set the Properties
- * to FALSE. Otherwise, the child inherits the properties and, as a
- * result, non-closeable handles to the pipes are created.
- */
-
- /* Read handle for read operations on the child std output. */
- if(!DuplicateHandle(GetCurrentProcess(),(context->hChildStdoutReadTmp),GetCurrentProcess(),&(context->hOutputRead),0,FALSE, DUPLICATE_SAME_ACCESS))
- {
- setErrno(E_CANNOT_CREATE_STDOUT_READ_HANDLE);
- return getErrno();
- }
-
-
- /* Write handle for write operations on the child std input. */
- if(!DuplicateHandle(GetCurrentProcess(),(context->hChildStdinWriteTmp),GetCurrentProcess(),&(context->hInputWrite), 0,FALSE,DUPLICATE_SAME_ACCESS))
- {
- setErrno(E_CANNOT_CREATE_STDIN_WRITE_HANDLE);
- return getErrno();
- }
-
-
- /* Close inheritable copies of the handles you do not want to be inherited. */
- if(!CloseHandle((context->hChildStdoutReadTmp)))
- {
- setErrno(E_CANNOT_CLOSE_CHILD_STDIN_TEMPORY_HANDLE);
- return getErrno();
- }
+ STARTUPINFO si = { 0 };
+ SECURITY_ATTRIBUTES sa = { 0 };
+ DWORD dwWaitResult = 0;
+ DWORD dwExitCode = 0;
+ DWORD ThreadId;
+ DWORD nBytes = 0;
+ DWORD dwCreationMode = CREATE_NO_WINDOW;
+ char cmdLine[4098] = { 0 };
+
+ TestCaseContext_t context = (TestCaseContext_t) param;
+ context->started = true;
+
+
+ sa.nLength = sizeof(SECURITY_ATTRIBUTES);
+ sa.lpSecurityDescriptor = NULL;
+ /* The pipe handes can be inherited by the child. */
+ sa.bInheritHandle = TRUE;
+
+ /* Create a write pipe handle for the child std output */
+ if (!CreatePipe
+ (&(context->hChildStdoutReadTmp), &(context->hChildStdOutWrite), &sa,
+ 0)) {
+ setErrno(E_CANNOT_CREATE_CHILD_STDOUT_READ_HANDLE);
+ return getErrno();
+ }
- context->hChildStdoutReadTmp = NULL;
-
- if(!CloseHandle((context->hChildStdinWriteTmp)))
- {
- setErrno(E_CANNOT_CLOSE_CHILD_STDOUT_TEMPORY_HANDLE);
- return getErrno();
- }
-
-
- context->hChildStdinWriteTmp = NULL;
-
- si.cb = sizeof(STARTUPINFO);
- /* Set the child std handles. */
- si.dwFlags = STARTF_USESTDHANDLES;
- si.hStdOutput = context->hChildStdOutWrite;
- si.hStdInput = context->hChildStdInRead;
- si.hStdError = context->hChildStderr;
-
- if(context->createConsole)
- dwCreationMode = CREATE_NEW_CONSOLE;
-
- if(!Buffer_empty(context->commandLineBuffer)){
- Buffer_chomp(context->commandLineBuffer);
- sprintf(cmdLine,"%s %s",context->name,context->commandLineBuffer->data);
- }
- else
- strcpy(cmdLine,context->name);
+ /*
+ * Create a duplicate of the output write handle for the std error
+ * write handle. This is necessary in case the child application closes
+ * one of its std output handles.
+ */
+ if (!DuplicateHandle
+ (GetCurrentProcess(), (context->hChildStdOutWrite),
+ GetCurrentProcess(), &(context->hChildStderr), 0, TRUE,
+ DUPLICATE_SAME_ACCESS)) {
+ setErrno(E_CANNOT_CREATE_CHILD_STDERR_READ_HANDLE);
+ return getErrno();
+ }
+ /* Create a read pipe handle for the child std input */
+ if (!CreatePipe
+ (&(context->hChildStdInRead), &(context->hChildStdinWriteTmp), &sa,
+ 0)) {
+ setErrno(E_CANNOT_CREATE_CHILD_STDIN_WRITE_HANDLE);
+ return getErrno();
+ }
- /* Create the child process. */
- if(!CreateProcess(NULL,cmdLine,NULL,NULL,TRUE,dwCreationMode,NULL,NULL,&si,&(context->pi))){
- setErrno(E_CANNOT_CREATE_CHILD_PROCESS);
- return getErrno();
- }
-
- if(!CloseHandle(context->pi.hThread)){
- setErrno(E_CANNOT_CLOSE_PROCESS_THREAD_HANDLE);
- return getErrno();
- }
-
-
- context->pi.hThread = NULL;
-
- /* close unnessary pipe handles. */
- if(!CloseHandle(context->hChildStdOutWrite)){
- setErrno(E_CANNOT_CLOSE_CHILD_STDOUT_HANDLE);
- return getErrno();
- }
-
- context->hChildStdOutWrite = NULL;
-
- if(!CloseHandle(context->hChildStdInRead)){
- setErrno(E_CANNOT_CLOSE_CHILD_STDIN_HANDLE);
- return getErrno();
- }
- context->hChildStdInRead = NULL;
+ /* Create new output read handle and the input write handle use by
+ * the parent process to communicate with his child. Set the Properties
+ * to FALSE. Otherwise, the child inherits the properties and, as a
+ * result, non-closeable handles to the pipes are created.
+ */
- if(!CloseHandle(context->hChildStderr)){
- setErrno(E_CANNOT_CLOSE_CHILD_STDERR_HANDLE);
- return getErrno();
- }
+ /* Read handle for read operations on the child std output. */
+ if (!DuplicateHandle
+ (GetCurrentProcess(), (context->hChildStdoutReadTmp),
+ GetCurrentProcess(), &(context->hOutputRead), 0, FALSE,
+ DUPLICATE_SAME_ACCESS)) {
+ setErrno(E_CANNOT_CREATE_STDOUT_READ_HANDLE);
+ return getErrno();
+ }
- context->hChildStderr = NULL;
- if(!Buffer_empty(context->inputBuffer)){
- if(!WriteFile(context->hInputWrite,context->inputBuffer->data,context->inputBuffer->size,&nBytes,NULL)){
- setErrno(E_CANNOT_WRITE_ON_CHILD_STDIN);
- return getErrno();
- }
- }
-
- context->hThread = CreateThread(&sa,0,TestSuite_asyncReadChildOutput,(LPVOID)context,0,&ThreadId);
- Sleep(0);
-
- if(NULL == context->hThread){
- setErrno(E_CANNOT_CREATE_READ_CHILD_OUTPUT_THREAD);
- return getErrno();
- }
-
+ /* Write handle for write operations on the child std input. */
+ if (!DuplicateHandle
+ (GetCurrentProcess(), (context->hChildStdinWriteTmp),
+ GetCurrentProcess(), &(context->hInputWrite), 0, FALSE,
+ DUPLICATE_SAME_ACCESS)) {
+ setErrno(E_CANNOT_CREATE_STDIN_WRITE_HANDLE);
+ return getErrno();
+ }
- dwWaitResult = WaitForSingleObject(context->pi.hProcess,context->timeoutValue);
- if(WAIT_FAILED == dwWaitResult)
- {
- TerminateProcess(context->pi.hProcess,0);
- context->pi.hProcess = NULL;
- context->runThread = false;
+ /* Close inheritable copies of the handles you do not want to be inherited. */
+ if (!CloseHandle(context->hChildStdoutReadTmp)) {
+ setErrno(E_CANNOT_CLOSE_CHILD_STDIN_TEMPORY_HANDLE);
+ return getErrno();
+ }
- if(WAIT_FAILED == WaitForSingleObject(context->hThread,INFINITE)){
- setErrno(E_WAIT_THREAD_FAILED);
- return getErrno();
- }
+ context->hChildStdoutReadTmp = NULL;
- if(!CloseHandle(context->hThread)){
- setErrno(E_CANNOT_CLOSE_THREAD_HANDLE);
- return getErrno();
- }
+ if (!CloseHandle(context->hChildStdinWriteTmp)) {
+ setErrno(E_CANNOT_CLOSE_CHILD_STDOUT_TEMPORY_HANDLE);
+ return getErrno();
+ }
- context->hThread = NULL;
- if(!CloseHandle(context->hOutputRead)){
- setErrno(E_CANNOT_CLOSE_READ_HANDLE);
- return getErrno();
- }
+ context->hChildStdinWriteTmp = NULL;
- context->hOutputRead = NULL;
+ si.cb = sizeof(STARTUPINFO);
+ /* Set the child std handles. */
+ si.dwFlags = STARTF_USESTDHANDLES;
+ si.hStdOutput = context->hChildStdOutWrite;
+ si.hStdInput = context->hChildStdInRead;
+ si.hStdError = context->hChildStderr;
- if(!CloseHandle(context->hInputWrite)){
- setErrno(E_CANNOT_CLOSE_WRITE_HANDLE);
- return getErrno();
- }
+ if (context->createConsole)
+ dwCreationMode = CREATE_NEW_CONSOLE;
- context->hInputWrite = NULL;
- setErrno(E_WAIT_FAILURE);
- return getErrno();
- }
+ if (!Buffer_empty(context->commandLineBuffer)) {
+ Buffer_chomp(context->commandLineBuffer);
+ sprintf(cmdLine, "%s %s", context->name,
+ context->commandLineBuffer->data);
+ } else
+ strcpy(cmdLine, context->name);
- if(WAIT_TIMEOUT == dwWaitResult)
- {
- TerminateProcess(context->pi.hProcess,0);
- context->pi.hProcess = NULL;
- context->runThread = false;
- if(WAIT_FAILED == WaitForSingleObject(context->hThread,INFINITE)){
- setErrno(E_WAIT_THREAD_FAILED);
- return getErrno();
- }
+ /* Create the child process. */
+ if (!CreateProcess
+ (NULL, cmdLine, NULL, NULL, TRUE, dwCreationMode, NULL, NULL, &si,
+ &(context->pi))) {
+ setErrno(E_CANNOT_CREATE_CHILD_PROCESS);
+ return getErrno();
+ }
+
+ if (!CloseHandle(context->pi.hThread)) {
+ setErrno(E_CANNOT_CLOSE_PROCESS_THREAD_HANDLE);
+ return getErrno();
+ }
+
- if(!CloseHandle(context->hThread)){
- setErrno(E_CANNOT_CLOSE_THREAD_HANDLE);
- return getErrno();
- }
+ context->pi.hThread = NULL;
+
+ /* close unnessary pipe handles. */
+ if (!CloseHandle(context->hChildStdOutWrite)) {
+ setErrno(E_CANNOT_CLOSE_CHILD_STDOUT_HANDLE);
+ return getErrno();
+ }
- context->hThread = NULL;
+ context->hChildStdOutWrite = NULL;
- if(!CloseHandle(context->hOutputRead)){
- setErrno(E_CANNOT_CLOSE_READ_HANDLE);
- return getErrno();
- }
+ if (!CloseHandle(context->hChildStdInRead)) {
+ setErrno(E_CANNOT_CLOSE_CHILD_STDIN_HANDLE);
+ return getErrno();
+ }
+ context->hChildStdInRead = NULL;
- context->hOutputRead = NULL;
+ if (!CloseHandle(context->hChildStderr)) {
+ setErrno(E_CANNOT_CLOSE_CHILD_STDERR_HANDLE);
+ return getErrno();
+ }
- if(!CloseHandle(context->hInputWrite)){
- setErrno(E_CANNOT_CLOSE_WRITE_HANDLE);
- return getErrno();
- }
+ context->hChildStderr = NULL;
- context->hInputWrite = NULL;
- setErrno(E_WAIT_TIMEOUT);
- return getErrno();
+ if (!Buffer_empty(context->inputBuffer)) {
+ if (!WriteFile
+ (context->hInputWrite, context->inputBuffer->data,
+ context->inputBuffer->size, &nBytes, NULL)) {
+ setErrno(E_CANNOT_WRITE_ON_CHILD_STDIN);
+ return getErrno();
}
+ }
+
+ context->hThread =
+ CreateThread(&sa, 0, TestSuite_asyncReadChildOutput,
+ (LPVOID) context, 0, &ThreadId);
+ Sleep(0);
+
+ if (NULL == context->hThread) {
+ setErrno(E_CANNOT_CREATE_READ_CHILD_OUTPUT_THREAD);
+ return getErrno();
+ }
+
- /* all is ok . */
+ dwWaitResult =
+ WaitForSingleObject(context->pi.hProcess, context->timeoutValue);
+ if (WAIT_FAILED == dwWaitResult) {
+ TerminateProcess(context->pi.hProcess, 0);
+ context->pi.hProcess = NULL;
context->runThread = false;
- if(WAIT_FAILED == WaitForSingleObject(context->hThread,INFINITE)){
- setErrno(E_WAIT_THREAD_FAILED);
- return getErrno();
+ if (WAIT_FAILED == WaitForSingleObject(context->hThread, INFINITE)) {
+ setErrno(E_WAIT_THREAD_FAILED);
+ return getErrno();
}
- if(!CloseHandle(context->hThread)){
- setErrno(E_CANNOT_CLOSE_THREAD_HANDLE);
- return getErrno();
+ if (!CloseHandle(context->hThread)) {
+ setErrno(E_CANNOT_CLOSE_THREAD_HANDLE);
+ return getErrno();
}
context->hThread = NULL;
- if(!CloseHandle(context->hOutputRead)){
- setErrno(E_CANNOT_CLOSE_READ_HANDLE);
- return getErrno();
+ if (!CloseHandle(context->hOutputRead)) {
+ setErrno(E_CANNOT_CLOSE_READ_HANDLE);
+ return getErrno();
}
context->hOutputRead = NULL;
- if(!CloseHandle(context->hInputWrite)){
- setErrno(E_CANNOT_CLOSE_WRITE_HANDLE);
- return getErrno();
+ if (!CloseHandle(context->hInputWrite)) {
+ setErrno(E_CANNOT_CLOSE_WRITE_HANDLE);
+ return getErrno();
}
context->hInputWrite = NULL;
-
-
- /* Get the child exit code before close it. */
- GetExitCodeProcess(context->pi.hProcess,&dwExitCode);
-
- context->exitCode = (int)dwExitCode;
-
- if(!CloseHandle(context->pi.hProcess)){
- setErrno(E_CANNOT_CLOSE_PROCESS_HANDLE);
- return getErrno();
+ setErrno(E_WAIT_FAILURE);
+ return getErrno();
+ }
+
+ if (WAIT_TIMEOUT == dwWaitResult) {
+ TerminateProcess(context->pi.hProcess, 0);
+ context->pi.hProcess = NULL;
+ context->runThread = false;
+
+ if (WAIT_FAILED == WaitForSingleObject(context->hThread, INFINITE)) {
+ setErrno(E_WAIT_THREAD_FAILED);
+ return getErrno();
}
- context->runThread = true;
+ if (!CloseHandle(context->hThread)) {
+ setErrno(E_CANNOT_CLOSE_THREAD_HANDLE);
+ return getErrno();
+ }
- if(TestSuite_iSPostOutputCheckingEnabled(context)){
- if (context->expectedOutputBuffer->size !=0 || context->outputBuffer->size !=0){
- Buffer_chomp(context->outputBuffer);
- Buffer_chomp(context->expectedOutputBuffer);
+ context->hThread = NULL;
- if (context->outputBuffer->size != context->expectedOutputBuffer->size || strcmp(context->outputBuffer->data, context->expectedOutputBuffer->data)){
- setErrno(E_OUTPUT_DONT_MATCH);
- }
- }
- }
+ if (!CloseHandle(context->hOutputRead)) {
+ setErrno(E_CANNOT_CLOSE_READ_HANDLE);
+ return getErrno();
+ }
- if(TestSuite_iSExitCodeCheckingEnabled(context)){
- if(context->expectedExitCode != INVALID_EXIT_CODE){
- if(context->expectedExitCode != context->exitCode ){
- setErrno(E_EXIT_CODE_DONT_MATCH);
- }
- }
- }
-
- context->pi.hProcess = NULL;
- return getErrno();
+
+ context->hOutputRead = NULL;
+
+ if (!CloseHandle(context->hInputWrite)) {
+ setErrno(E_CANNOT_CLOSE_WRITE_HANDLE);
+ return getErrno();
+ }
+
+ context->hInputWrite = NULL;
+ setErrno(E_WAIT_TIMEOUT);
+ return getErrno();
+ }
+
+ /* all is ok . */
+
+ context->runThread = false;
+
+ if (WAIT_FAILED == WaitForSingleObject(context->hThread, INFINITE)) {
+ setErrno(E_WAIT_THREAD_FAILED);
+ return getErrno();
+ }
+
+ if (!CloseHandle(context->hThread)) {
+ setErrno(E_CANNOT_CLOSE_THREAD_HANDLE);
+ return getErrno();
+ }
+
+ context->hThread = NULL;
+
+ if (!CloseHandle(context->hOutputRead)) {
+ setErrno(E_CANNOT_CLOSE_READ_HANDLE);
+ return getErrno();
+ }
+
+ context->hOutputRead = NULL;
+
+ if (!CloseHandle(context->hInputWrite)) {
+ setErrno(E_CANNOT_CLOSE_WRITE_HANDLE);
+ return getErrno();
+ }
+
+ context->hInputWrite = NULL;
+
+
+ /* Get the child exit code before close it. */
+ GetExitCodeProcess(context->pi.hProcess, &dwExitCode);
+
+ context->exitCode = (int) dwExitCode;
+
+ if (!CloseHandle(context->pi.hProcess)) {
+ setErrno(E_CANNOT_CLOSE_PROCESS_HANDLE);
+ return getErrno();
+ }
+
+ context->runThread = true;
+
+ if (TestSuite_iSPostOutputCheckingEnabled(context)) {
+ if (context->expectedOutputBuffer->size != 0
+ || context->outputBuffer->size != 0) {
+ Buffer_chomp(context->outputBuffer);
+ Buffer_chomp(context->expectedOutputBuffer);
+
+ if (context->outputBuffer->size !=
+ context->expectedOutputBuffer->size
+ || strcmp(context->outputBuffer->data,
+ context->expectedOutputBuffer->data)) {
+ setErrno(E_OUTPUT_DONT_MATCH);
+ }
+ }
+ }
+
+ if (TestSuite_iSExitCodeCheckingEnabled(context)) {
+ if (context->expectedExitCode != INVALID_EXIT_CODE) {
+ if (context->expectedExitCode != context->exitCode) {
+ setErrno(E_EXIT_CODE_DONT_MATCH);
+ }
+ }
+ }
+
+ context->pi.hProcess = NULL;
+ return getErrno();
}
bool TestSuite_iSPostOutputCheckingEnabled(TestCaseContext_t context)
{
- if(!context->isPostOutputCheckingEnabled && context->isOutputCheckingEnabled){
- return true;
- }
+ if (!context->isPostOutputCheckingEnabled
+ && context->isOutputCheckingEnabled) {
+ return true;
+ }
- return false;
+ return false;
}
bool TestSuite_iSExitCodeCheckingEnabled(TestCaseContext_t context)
{
- return context->exitCodeCheckingEnabled;
+ return context->exitCodeCheckingEnabled;
}
errno_t TestSuite_changeDir(TestSuite_t testSuite)
{
- char* line = testSuite->stream->line + 5;
- size_t size = strlen(line);
-
- while ((line[size-1] == '\n') || (line[size-1] == '\r')){
- line[size-1] = '\0';
-
- if(size)
- (size)--;
- }
-
- if(!SetCurrentDirectory(line)){
- setErrno(E_CHANGE_DIRECTORY_FAILED);
- return E_CHANGE_DIRECTORY_FAILED;
- }
+ char *line = testSuite->stream->line + 5;
+ size_t size = strlen(line);
- Stream_printLine(testSuite->stream,change_directory_line_type);
+ while ((line[size - 1] == '\n') || (line[size - 1] == '\r')) {
+ line[size - 1] = '\0';
- return E_SUCCESS;
-}
+ if (size)
+ (size)--;
+ }
+ if (!SetCurrentDirectory(line)) {
+ setErrno(E_CHANGE_DIRECTORY_FAILED);
+ return E_CHANGE_DIRECTORY_FAILED;
+ }
+
+ Stream_printLine(testSuite->stream, change_directory_line_type);
+
+ return E_SUCCESS;
+}
