+++ /dev/null
-#include <TTestSuite.h>
-
-
-/*
- * Create a new s_TestSuite an returns a pointer to self.
- */
-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->successCount = 0;
- testSuite->failureCount = 0;
-
- return testSuite;
-}
-
-/*
- * Initialize the s_TestSuite structure.
- */
-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();
- }
- }
-}
-
-/*
- * Launch the test suite.
- */
-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);
- }
-}
-/*
- * 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;
-
-}
-
-/*
- * Set the timeout of the test case context of the
- * test suite.
- */
-void TestSuite_setTimeout(TestSuite_t testSuite)
-{
-
- int timeout = atoi(testSuite->stream->line + 2 + strlen("set timeout "));
- TestCaseContext_setTimeout(testSuite->test_case_context,timeout);
-}
-
-/*
- * Enable output checking for the current test case context.
- */
-void TestSuite_enableOutputChecking(TestSuite_t testSuite)
-{
- 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 "));
-}
-
-/*
- * Disable output checking for the current test case context.
- */
-void TestSuite_disableOutputChecking(TestSuite_t testSuite)
-{
- TestCaseContext_disableOutputChecking(testSuite->test_case_context);
-}
-
-/*
- * Enable post output checking for the current test case context.
- */
-void TestSuite_enablePostOutputChecking(TestSuite_t testSuite)
-{
- TestCaseContext_enable_post_output_checking(testSuite->test_case_context);
-}
-
-void TestSuite_createConsole(TestSuite_t testSuite)
-{
- TestCaseContext_createConsole(testSuite->test_case_context);
-}
-
-void TestSuite_createNoConsole(TestSuite_t testSuite)
-{
- TestCaseContext_createNoConsole(testSuite->test_case_context);
-}
-
-/*
- * Disable post output checking for the current test case context.
- */
-void TestSuite_disablePostOutputChecking(TestSuite_t testSuite)
-{
- TestCaseContext_disablePostOutputChecking(testSuite->test_case_context);
-}
-
-/*
- * Set the expected exit code of the current test case context of the test suite.
- */
-void TestSuite_setExpectedExitCode(TestSuite_t testSuite)
-{
- 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);
-}
-
-void TestSuite_disableExitCodeChecking(TestSuite_t testSuite)
-{
- TestCaseContext_disableExitCodeChecking(testSuite->test_case_context);
-}
-
-
-/*
- * Export a variable in the environment of the current test_runner.exe process.
- */
-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;
-}
-
-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;
-}
-
-/*
- * Expected child output processing.
- */
-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;
-}
-
-/*
- * Child input processing.
- */
-errno_t TestSuite_processChildInput(TestSuite_t testSuite)
-{
- /* TODO : trim */
- TestCaseContext_appendChildInput(testSuite->test_case_context,testSuite->stream->line + 2);
-
- return E_SUCCESS;
-}
-
-/*
- * Free the s_TestSuite pointed to by ptr.
- */
-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;
- }
-
- 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);
- }
-
- if(NULL != testSuite->test_case_context)
- TestCaseContext_free(testSuite->test_case_context);
-
- if(NULL != testSuite->stream)
- Stream_free(testSuite->stream);
-
- free(testSuite);
-}
-
-/*
- * Check the child output.
- */
-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;
-}
-
-/*
- * 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();
- }
-
- return E_SUCCESS;
-}
-
-/*
- * Terminate the test suite.
- */
-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);
-
-
-}
-
-
-/*
- * Print message
- */
-void TestSuite_print(const char* str)
-{
- char* t = (char*)calloc(1,20);
-
- __time(t);
-
- EnterCriticalSection(&cs);
- printf("%s %s",t,str);
- LeaveCriticalSection(&cs);
-
- free(t);
-
-}
-
-unsigned long WINAPI TestSuite_asyncReadChildOutput(void* param)
-{
- char str[1024] = {0};
- char __buffer[1024] = {0};
-
- DWORD nBytesRead;
- DWORD nCharsWritten;
- 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);
-
-
- Buffer_append(context->outputBuffer,str);
- }
-
- memset(str,0,1024);
- memset(__buffer,0,1024);
- }
-
- }
- 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();
-}
-
-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();
- }
-
- 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 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;
-
- if(!CloseHandle(context->hChildStderr)){
- setErrno(E_CANNOT_CLOSE_CHILD_STDERR_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();
- }
-
-
- 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(!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;
- 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();
- }
-
- 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;
- 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;
- }
-
- return false;
-}
-
-bool TestSuite_iSExitCodeCheckingEnabled(TestCaseContext_t context)
-{
- 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;
- }
-
- Stream_printLine(testSuite->stream,change_directory_line_type);
-
- return E_SUCCESS;
-}
-
