tests/auto_build/testcases/client/cpp/AxisBench_TTestClient.cpp - axis-axis1-c - Git at Google

 // Copyright 2003-2004 The Apache Software Foundation.
 // (c) Copyright IBM Corp. 2004, 2005 All Rights Reserved
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
 // You may obtain a copy of the License at
 //
 //        http://www.apache.org/licenses/LICENSE-2.0
 //
 // Unless required by applicable law or agreed to in writing, software
 // distributed under the License is distributed on an "AS IS" BASIS,
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.


 /* This program will create 10 Threads and each thread will invoke AxisBench Service @Author James */

 #include "AxisBench.hpp"
 #include <axis/AxisException.hpp>
 //#include <exception>
 #include <ctype.h>
 #include <iostream>
 #include <stdlib.h>
 #include <axis/Axis.hpp>
 /* Defining platform specific constants  */
 #include <time.h>
 #include "CommonClientTestCode.hpp"

 #ifdef WIN32
 #include <windows.h>
 #include "sys/timeb.h"
 #define RETTYPE DWORD WINAPI
 #define ARGTYPE LPVOID
 #else
 #include <pthread.h>
 #include <unistd.h>
 #include "sys/time.h"
 #define RETTYPE void*
 #define ARGTYPE void*
 #endif


 //#define MACRO_NUM_THREADS 10
 //int NUM_THREADS = MACRO_NUM_THREADS;
 #define NUM_THREADS 5


 /* In windows the entry point function return type is DWORD WINAPI In linux it is void *
  */
 RETTYPE ThreadFunc(ARGTYPE Param)
 {
     /*Type casting the url to char * */
     char *p=(char *)Param;
     char endpoint[256];
     const char* url="http://puppet.in.ibm.com:9060/Calculator/services/Calculator";
     AxisBench *ws;
     BenchDataType *input = NULL;
     BenchDataType *output = NULL;
     xsd__unsignedByte* buffer = NULL;
     if (p!=NULL)
         url=p;

     int iResult;
     bool bSuccess = false;
     int     iRetryIterationCount = 1;

     do
     {
         try
         {
             sprintf(endpoint, "%s", url);
             ws = new AxisBench(endpoint, APTHTTP1_1);
             int request = 1;

             input = new BenchDataType();
             input->count = 1;

             BenchBasicDataType_Array arrayIn;
             //              cout <<" About to create BenchBasicDataType"<<endl;
             BenchBasicDataType **   ppBBDT = new BenchBasicDataType *[input->count];

 #ifdef WIN32
             __int64 ll = 10000;
 #else
             long long ll = 10000;
 #endif

             // input->infos.m_Array = ppBBDT;

             // input->infos.m_Size = input->count;

             time_t tim;
             tim = 1100246323;
             struct tm *temp = gmtime(&tim);
             struct tm lt;
             memcpy(&lt, temp, sizeof(struct tm));

             char *letterA_String = stringToAscii("A");
             buffer = (xsd__unsignedByte*)calloc (1, input->count + 2);

             strcpy ( (char *)buffer, letterA_String);

             //                cout <<" input->count = "<<input->count<<endl;
             for ( int i = 0; i < input->count ; i++ )
             {
                 BenchBasicDataType *type = new BenchBasicDataType();
                 type->StringType = "StringType";
                 type->IntegerType = 10*(i+1);
                 type->DoubleType = 11.111 * (i+1);
                 type->BooleanType = true_;
                 type->DateTimeType = lt ;
                 type->TimeType = lt ;
                 type->DateType = lt ;
                 type->IntType = (i+1);
                 type->ByteType = '1';
                 type->DecimalType = 10*(i+1);
                 type->FloatType = (float)((float)(11*(i+1))/(float)2.0);
                 type->LongType = ll;
                 type->QNameType = "toto";
                 type->ShortType = (i+1);
                 type->Base64BinaryType.set(buffer, i);
                 type->HexBinary.set(buffer, i);

                 ppBBDT[i] = type;

                 if( ll == 0)
                     ll = 1;
                 else
                     ll += 10000;

                 strcat ( (char *)buffer, letterA_String);
             }

             arrayIn.set(ppBBDT,input->count);
             input->setinfos(&arrayIn);
             //                cout << "About to delete the output prior to calling the service"<<endl;
             for ( int ii = 0; ii < request ; ii++ )
             {
                 if (output)
                 {
                     int outputSize =0;
                     BenchBasicDataType ** outArray =output->infos->get(outputSize);
                     for (int i = 0; i < outputSize; i++)
                         delete outArray[i];
                     delete output;
                     output = NULL;
                 }
                 //                    cout << "About to do bench request"<<endl;
                 output = ws->doBenchRequest(input);
                 //                    cout << "Done bench request"<<endl;
             }

             free(buffer);

             if ( ws->getStatus() == AXIS_FAIL )
                 cout << "Failed" << endl;
             else
             {
                 bSuccess = true;
                 char dateTime[50];
                 int i = 0;
                 int outputSize = 0;
                 BenchBasicDataType ** outArray =output->infos->get(outputSize);
                 for ( ; i < output->count ; i++ )
                 {
                     if ( outArray[i] != (BenchBasicDataType *) 0xcdcdcdcd)
                         cout << " StringType " << outArray[i]->StringType << endl;
                 }

                 // returnValue=0;
             }
         }
         catch(AxisException& e)
         {
             bool bSilent = false;

             if( e.getExceptionCode() == CLIENT_TRANSPORT_OPEN_CONNECTION_FAILED)
             {
                 if( iRetryIterationCount > 0)
                     bSilent = true;
             }
             else
                 iRetryIterationCount = 0;

             if( !bSilent)
                 cout << "Exception : " << e.what() << endl;
         }
         catch(exception& e)
         {
             cout << "Unknown exception has occured" << endl;
         }
         catch(...)
         {
             cout << "Unknown exception has occured" << endl;
         }

         try
         {
             delete ws;
             delete input;
             if (output)
                 delete output;
         }
         catch(exception& exception)
         {
             cout << "Exception on clean up: " << exception.what()<<endl;
         }
         catch(...)
         {
             cout << "Unknown exception on clean up: " << endl;
         }

         iRetryIterationCount--;
     }
     while( iRetryIterationCount > 1 && !bSuccess);

 #ifndef WIN32
     pthread_exit(0);
 #endif

     return 0;
 }


 int main(int argc, char *argv[])
 {
     Axis::initialize(false);
     try
     {
         int i;
 #ifdef WIN32
         /*Windows specific code comes here */
         HANDLE hThread[NUM_THREADS];
         for(i=0;i<NUM_THREADS;i++){
             DWORD dwThreadId;
             //LPVOID dwThrdParam = LPVOID(argv[1]);
             hThread[i] = CreateThread(
                                       NULL,                        // no security attributes
                                       0,                           // use default stack size
                                       ThreadFunc,                  // thread function
                                       LPVOID(argv[1]),             // argument to thread function
                                       0,
                                       &dwThreadId);              // returns the thread identifier

             if (hThread[i] == NULL)
                 cout<<"Thread creation Failed";
         }
         /* Waiting for threads to terminate */
         WaitForMultipleObjects(NUM_THREADS,hThread,true, INFINITE);
         for(i=0;i<NUM_THREADS;i++)
             CloseHandle( hThread[i] );

 #else
         pthread_t thread[NUM_THREADS];
         pthread_attr_t attr;
         int rc, t;
         void *status;
         //   Initialize and set thread detached attribute
         pthread_attr_init(&attr);
         pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);
         for (t = 0; t < NUM_THREADS; t++)
         {
             /*Creating threads */
             rc = pthread_create(&thread[t], &attr, ThreadFunc,(void *)argv[1]);
             if (rc)
                 cout<<"Thread Creation Failed";
         }
         //Free attribute and wait for the other threads
         pthread_attr_destroy(&attr);
         /* Wait for the threads to terminate  */
         for(t=0;t<NUM_THREADS;t++)
         {
             rc = pthread_join(thread[t], &status);
             if (rc)
                 cout<<"ERROR from pthread_join()"<<endl;
         }
 #endif
     }catch(exception &e){
         cout<< e.what();
     }
     cout<<endl <<"----------------------------------TEST COMPLETE--------------------------------"<<endl;
 }
	// Copyright 2003-2004 The Apache Software Foundation.
	// (c) Copyright IBM Corp. 2004, 2005 All Rights Reserved
	//
	// Licensed under the Apache License, Version 2.0 (the "License");
	// you may not use this file except in compliance with the License.
	// You may obtain a copy of the License at
	//
	// http://www.apache.org/licenses/LICENSE-2.0
	//
	// Unless required by applicable law or agreed to in writing, software
	// distributed under the License is distributed on an "AS IS" BASIS,
	// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	// See the License for the specific language governing permissions and
	// limitations under the License.


	/* This program will create 10 Threads and each thread will invoke AxisBench Service @Author James */

	#include "AxisBench.hpp"
	#include <axis/AxisException.hpp>
	//#include <exception>
	#include <ctype.h>
	#include <iostream>
	#include <stdlib.h>
	#include <axis/Axis.hpp>
	/* Defining platform specific constants */
	#include <time.h>
	#include "CommonClientTestCode.hpp"

	#ifdef WIN32
	#include <windows.h>
	#include "sys/timeb.h"
	#define RETTYPE DWORD WINAPI
	#define ARGTYPE LPVOID
	#else
	#include <pthread.h>
	#include <unistd.h>
	#include "sys/time.h"
	#define RETTYPE void*
	#define ARGTYPE void*
	#endif


	//#define MACRO_NUM_THREADS 10
	//int NUM_THREADS = MACRO_NUM_THREADS;
	#define NUM_THREADS 5


	/* In windows the entry point function return type is DWORD WINAPI In linux it is void *
	*/
	RETTYPE ThreadFunc(ARGTYPE Param)
	{
	/Type casting the url to char */
	char p=(char )Param;
	char endpoint[256];
	const char* url="http://puppet.in.ibm.com:9060/Calculator/services/Calculator";
	AxisBench *ws;
	BenchDataType *input = NULL;
	BenchDataType *output = NULL;
	xsd__unsignedByte* buffer = NULL;
	if (p!=NULL)
	url=p;

	int iResult;
	bool bSuccess = false;
	int iRetryIterationCount = 1;

	do
	{
	try
	{
	sprintf(endpoint, "%s", url);
	ws = new AxisBench(endpoint, APTHTTP1_1);
	int request = 1;

	input = new BenchDataType();
	input->count = 1;

	BenchBasicDataType_Array arrayIn;
	// cout <<" About to create BenchBasicDataType"<<endl;
	BenchBasicDataType ** ppBBDT = new BenchBasicDataType *[input->count];

	#ifdef WIN32
	__int64 ll = 10000;
	#else
	long long ll = 10000;
	#endif

	// input->infos.m_Array = ppBBDT;

	// input->infos.m_Size = input->count;

	time_t tim;
	tim = 1100246323;
	struct tm *temp = gmtime(&tim);
	struct tm lt;
	memcpy(&lt, temp, sizeof(struct tm));

	char *letterA_String = stringToAscii("A");
	buffer = (xsd__unsignedByte*)calloc (1, input->count + 2);

	strcpy ( (char *)buffer, letterA_String);

	// cout <<" input->count = "<<input->count<<endl;
	for ( int i = 0; i < input->count ; i++ )
	{
	BenchBasicDataType *type = new BenchBasicDataType();
	type->StringType = "StringType";
	type->IntegerType = 10*(i+1);
	type->DoubleType = 11.111 * (i+1);
	type->BooleanType = true_;
	type->DateTimeType = lt ;
	type->TimeType = lt ;
	type->DateType = lt ;
	type->IntType = (i+1);
	type->ByteType = '1';
	type->DecimalType = 10*(i+1);
	type->FloatType = (float)((float)(11*(i+1))/(float)2.0);
	type->LongType = ll;
	type->QNameType = "toto";
	type->ShortType = (i+1);
	type->Base64BinaryType.set(buffer, i);
	type->HexBinary.set(buffer, i);

	ppBBDT[i] = type;

	if( ll == 0)
	ll = 1;
	else
	ll += 10000;

	strcat ( (char *)buffer, letterA_String);
	}

	arrayIn.set(ppBBDT,input->count);
	input->setinfos(&arrayIn);
	// cout << "About to delete the output prior to calling the service"<<endl;
	for ( int ii = 0; ii < request ; ii++ )
	{
	if (output)
	{
	int outputSize =0;
	BenchBasicDataType ** outArray =output->infos->get(outputSize);
	for (int i = 0; i < outputSize; i++)
	delete outArray[i];
	delete output;
	output = NULL;
	}
	// cout << "About to do bench request"<<endl;
	output = ws->doBenchRequest(input);
	// cout << "Done bench request"<<endl;
	}

	free(buffer);

	if ( ws->getStatus() == AXIS_FAIL )
	cout << "Failed" << endl;
	else
	{
	bSuccess = true;
	char dateTime[50];
	int i = 0;
	int outputSize = 0;
	BenchBasicDataType ** outArray =output->infos->get(outputSize);
	for ( ; i < output->count ; i++ )
	{
	if ( outArray[i] != (BenchBasicDataType *) 0xcdcdcdcd)
	cout << " StringType " << outArray[i]->StringType << endl;
	}

	// returnValue=0;
	}
	}
	catch(AxisException& e)
	{
	bool bSilent = false;

	if( e.getExceptionCode() == CLIENT_TRANSPORT_OPEN_CONNECTION_FAILED)
	{
	if( iRetryIterationCount > 0)
	bSilent = true;
	}
	else
	iRetryIterationCount = 0;

	if( !bSilent)
	cout << "Exception : " << e.what() << endl;
	}
	catch(exception& e)
	{
	cout << "Unknown exception has occured" << endl;
	}
	catch(...)
	{
	cout << "Unknown exception has occured" << endl;
	}

	try
	{
	delete ws;
	delete input;
	if (output)
	delete output;
	}
	catch(exception& exception)
	{
	cout << "Exception on clean up: " << exception.what()<<endl;
	}
	catch(...)
	{
	cout << "Unknown exception on clean up: " << endl;
	}

	iRetryIterationCount--;
	}
	while( iRetryIterationCount > 1 && !bSuccess);

	#ifndef WIN32
	pthread_exit(0);
	#endif

	return 0;
	}




	int main(int argc, char *argv[])
	{
	Axis::initialize(false);
	try
	{
	int i;
	#ifdef WIN32
	/Windows specific code comes here /
	HANDLE hThread[NUM_THREADS];
	for(i=0;i<NUM_THREADS;i++){
	DWORD dwThreadId;
	//LPVOID dwThrdParam = LPVOID(argv[1]);
	hThread[i] = CreateThread(
	NULL, // no security attributes
	0, // use default stack size
	ThreadFunc, // thread function
	LPVOID(argv[1]), // argument to thread function
	0,
	&dwThreadId); // returns the thread identifier

	if (hThread[i] == NULL)
	cout<<"Thread creation Failed";
	}
	/* Waiting for threads to terminate */
	WaitForMultipleObjects(NUM_THREADS,hThread,true, INFINITE);
	for(i=0;i<NUM_THREADS;i++)
	CloseHandle( hThread[i] );

	#else
	pthread_t thread[NUM_THREADS];
	pthread_attr_t attr;
	int rc, t;
	void *status;
	// Initialize and set thread detached attribute
	pthread_attr_init(&attr);
	pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);
	for (t = 0; t < NUM_THREADS; t++)
	{
	/Creating threads /
	rc = pthread_create(&thread[t], &attr, ThreadFunc,(void *)argv[1]);
	if (rc)
	cout<<"Thread Creation Failed";
	}
	//Free attribute and wait for the other threads
	pthread_attr_destroy(&attr);
	/* Wait for the threads to terminate */
	for(t=0;t<NUM_THREADS;t++)
	{
	rc = pthread_join(thread[t], &status);
	if (rc)
	cout<<"ERROR from pthread_join()"<<endl;
	}
	#endif
	}catch(exception &e){
	cout<< e.what();
	}
	cout<<endl <<"----------------------------------TEST COMPLETE--------------------------------"<<endl;
	}