You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by ja...@apache.org on 2005/03/18 10:42:33 UTC
cvs commit: ws-axis/c/tests/auto_build/testcases/client/cpp General_TTestClient.cpp
jamejose 2005/03/18 01:42:33
Added: c/tests/auto_build/testcases/client/cpp
General_TTestClient.cpp
Log:
General thread test.
Revision Changes Path
1.1 ws-axis/c/tests/auto_build/testcases/client/cpp/General_TTestClient.cpp
Index: General_TTestClient.cpp
===================================================================
/* This program will create 10 Threads and each thread will invoke different operations of Calculator Service
@Author James
*/
#include "Calculator.hpp"
#include <axis/AxisException.hpp>
//#include <exception>
#include <ctype.h>
#include <iostream>
#include <stdlib.h>
#include <string.h>
#include <axis/Axis.hpp>
/* Defining platform specific constants */
#ifdef WIN32
#include <windows.h>
#define RETTYPE DWORD WINAPI
#define ARGTYPE LPVOID
#else
#include <pthread.h>
#include <unistd.h>
#define RETTYPE void*
#define ARGTYPE void*
#endif
/* Defining a structure to pass arguments to entry point function */
struct ARG_LIST{
char url[200];
char op[4];
};
//#define MACRO_NUM_THREADS 10
//int NUM_THREADS = MACRO_NUM_THREADS;
#define NUM_THREADS 10
/* 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 * */
ARG_LIST *p=(ARG_LIST *)Param;
char endpoint[256];
const char* url="http://puppet.in.ibm.com:9060/Calculator/services/Calculator";
char *op;
if(p!=NULL){
url=p->url;
op=p->op;
}
try
{
sprintf(endpoint, "%s", url);
Calculator ws(endpoint);
if(strcmp(op,"add")==0){
if(ws.add(3,2)==5)
cout << "successful" << endl;
}else if(strcmp(op,"mul")==0){
if(ws.mul(3,2)==6)
cout << "successful" << endl;
}else if(strcmp(op,"sub")==0){
if(ws.sub(3,2)==1)
cout << "successful" << endl;
}else if(strcmp(op,"div")==0){
if(ws.div(4,2)==2)
cout << "successful" << endl;
}
}catch(AxisException& e)
{
cout << "Exception : " << e.what() << endl;
}
catch(exception& e)
{
cout << "Unknown exception has occured" << endl;
}
catch(...)
{
cout << "Unknown exception has occured" << endl;
}
#ifndef WIN32
pthread_exit(0);
#endif
return 0;
}
int main(int argc, char *argv[])
{
Axis::initialize(false);
try{
int i;
ARG_LIST a;
/* Copying url to argument list */
strcpy(a.url,argv[1]);
char actions[4][4]={"add","sub","div","mul"};
#ifdef WIN32
/*Windows specific code comes here */
HANDLE hThread[NUM_THREADS];
for(i=0;i<NUM_THREADS;i++){
/* Copying operation name to argument list */
strcpy(a.op,actions[i%4]);
DWORD dwThreadId;
//LPVOID dwThrdParam = LPVOID(argv[1]);
hThread[i] = CreateThread(
NULL, // no security attributes
0, // use default stack size
ThreadFunc, // thread function
LPVOID(&a), //LPVOID(argv[1]), // argument to thread function
0,
&dwThreadId); // returns the thread identifier
if (hThread[i] == NULL)
{
cout<<"Thread creation Failed";
}
Sleep(500);
}
/* 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, status = 0;
// Initialize and set thread detached attribute
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);
for (t = 0; t < NUM_THREADS; t++)
{
/* Copying operation name to argument list */
strcpy(a.op,actions[t%4]);
/*Creating threads */
rc = pthread_create(&thread[t], &attr, ThreadFunc,(void *)(&a));
if (rc)
{
cout<<"Thread Creation Failed";
}
sleep(1);
}
//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], (void **)&status);
if (rc)
{
cout<<"ERROR from pthread_join()"<<endl;
}
}
#endif
}catch(exception &e){
cout<< e.what();
}
cout<<endl <<"----------------------------------TEST COMPLETE--------------------------------"<<endl;
}