zoo_service_loader.c @ 60

Last change on this file since 60 was 60, checked in by djay, 13 years ago
Small fixs in freeElements and runRequest.
File size: 48.6 KB

Rev	Line
[1]	1	/**
	2	* Author : Gérald FENOY
	3	*
	4	* Copyright 2008-2009 GeoLabs SARL. All rights reserved.
	5	*
	6	* Permission is hereby granted, free of charge, to any person obtaining a copy
	7	* of this software and associated documentation files (the "Software"), to deal
	8	* in the Software without restriction, including without limitation the rights
	9	* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
	10	* copies of the Software, and to permit persons to whom the Software is
	11	* furnished to do so, subject to the following conditions:
	12	*
	13	* The above copyright notice and this permission notice shall be included in
	14	* all copies or substantial portions of the Software.
	15	*
	16	* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
	17	* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
	18	* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
	19	* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
	20	* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
	21	* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
	22	* THE SOFTWARE.
	23	*/
	24
	25	#define length(x) (sizeof(x) / sizeof(x[0]))
	26
	27	extern "C" int yylex();
	28	extern "C" int crlex();
[9]	29
	30
[1]	31	extern "C" {
	32	#include <libxml/tree.h>
	33	#include <libxml/xmlmemory.h>
	34	#include <libxml/parser.h>
	35	#include <libxml/xpath.h>
	36	#include <libxml/xpathInternals.h>
	37	}
	38
	39	#include "cgic.h"
	40	#include "ulinet.h"
	41
[34]	42	#include <libintl.h>
	43	#include <locale.h>
[1]	44	#include <string.h>
	45
	46	#include "service.h"
[34]	47
[1]	48	#include "service_internal.h"
[33]	49
	50	#ifdef USE_PYTHON
[1]	51	#include "service_internal_python.h"
[33]	52	#endif
[1]	53
	54	#ifdef USE_JAVA
	55	#include "service_internal_java.h"
	56	#endif
	57
	58	#ifdef USE_PHP
	59	#include "service_internal_php.h"
	60	#endif
	61
	62	#ifdef USE_JS
	63	#include "service_internal_js.h"
	64	#endif
	65
[25]	66	#ifdef USE_PERL
	67	#include "service_internal_perl.h"
	68	#endif
[1]	69
[25]	70
	71
[1]	72	#include <dirent.h>
	73	#include <signal.h>
	74	#include <unistd.h>
	75	#ifndef WIN32
	76	#include <dlfcn.h>
	77	#include <libgen.h>
	78	#else
	79	#include <windows.h>
	80	#include <direct.h>
	81	#endif
	82	#include <fcntl.h>
	83	#include <time.h>
	84	#include <stdarg.h>
	85
[34]	86	#define _(String) dgettext ("zoo-kernel",String)
	87
	88
	89	void translateChar(char str,char toReplace,char toReplaceBy){
	90	int i=0,len=strlen(str);
	91	for(i=0;i<len;i++){
	92	if(str[i]==toReplace)
	93	str[i]=toReplaceBy;
	94	}
	95	}
	96
[9]	97	xmlXPathObjectPtr extractFromDoc(xmlDocPtr doc,char* search){
[1]	98	xmlXPathContextPtr xpathCtx;
	99	xmlXPathObjectPtr xpathObj;
	100	xpathCtx = xmlXPathNewContext(doc);
	101	xpathObj = xmlXPathEvalExpression(BAD_CAST search,xpathCtx);
[9]	102	xmlXPathFreeContext(xpathCtx);
	103	return xpathObj;
[1]	104	}
	105
[9]	106	void sig_handler(int sig){
	107	char tmp[100];
	108	char *ssig;
	109	switch(sig){
	110	case SIGSEGV:
	111	ssig="SIGSEGV";
	112	break;
	113	case SIGTERM:
	114	ssig="SIGTERM";
	115	break;
	116	case SIGINT:
	117	ssig="SIGINT";
	118	break;
	119	case SIGILL:
	120	ssig="SIGILL";
	121	break;
	122	case SIGFPE:
	123	ssig="SIGFPE";
	124	break;
	125	case SIGABRT:
	126	ssig="SIGABRT";
	127	break;
	128	default:
	129	ssig="UNKNOWN";
	130	break;
	131	}
[34]	132	sprintf(tmp,_("ZOO Kernel failed to process your request receiving signal %d = %s"),sig,ssig);
[9]	133	errorException(NULL, tmp, "InternalError");
[10]	134	#ifdef DEBUG
[1]	135	fprintf(stderr,"Not this time!\n");
[10]	136	#endif
[9]	137	exit(0);
[1]	138	}
	139
[34]	140	void loadServiceAndRun(maps myMap,service s1,map* request_inputs,maps inputs,maps ioutputs,int* eres){
	141	char tmps1[1024];
	142	char ntmp[1024];
	143	maps m=myMap;
	144	maps request_output_real_format=ioutputs;
	145	maps request_input_real_format=inputs;
	146	/**
	147	* Extract serviceType to know what kind of service should be loaded
	148	*/
	149	map* r_inputs=NULL;
	150	#ifndef WIN32
	151	getcwd(ntmp,1024);
	152	#else
	153	_getcwd(ntmp,1024);
	154	#endif
	155	r_inputs=getMap(s1->content,"serviceType");
	156	#ifdef DEBUG
	157	fprintf(stderr,"LOAD A %s SERVICE PROVIDER \n",r_inputs->value);
	158	fflush(stderr);
	159	#endif
	160	if(strncasecmp(r_inputs->value,"C",1)==0){
	161	r_inputs=getMap(request_inputs,"metapath");
	162	if(r_inputs!=NULL)
	163	sprintf(tmps1,"%s/%s",ntmp,r_inputs->value);
	164	else
	165	sprintf(tmps1,"%s/",ntmp);
	166	char *altPath=strdup(tmps1);
	167	r_inputs=getMap(s1->content,"ServiceProvider");
	168	sprintf(tmps1,"%s/%s",altPath,r_inputs->value);
	169	free(altPath);
	170	#ifdef DEBUG
	171	fprintf(stderr,"Trying to load %s\n",tmps1);
	172	#endif
	173	#ifdef WIN32
	174	HINSTANCE so = LoadLibraryEx(tmps1,NULL,LOAD_WITH_ALTERED_SEARCH_PATH);
	175	#else
	176	void* so = dlopen(tmps1, RTLD_LAZY);
	177	#endif
	178	#ifdef DEBUG
[57]	179	#ifdef WIN32
[34]	180	DWORD errstr;
	181	errstr = GetLastError();
	182	fprintf(stderr,"%s loaded (%d) \n",tmps1,errstr);
	183	#else
	184	char *errstr;
	185	errstr = dlerror();
	186	#endif
	187	#endif
	188
	189	if( so != NULL ) {
	190	#ifdef DEBUG
	191	fprintf(stderr,"Library loaded %s \n",errstr);
	192	fprintf(stderr,"Service Shared Object = %s\n",r_inputs->value);
	193	#endif
	194	r_inputs=getMap(s1->content,"serviceType");
	195	#ifdef DEBUG
	196	dumpMap(r_inputs);
	197	fprintf(stderr,"%s\n",r_inputs->value);
	198	fflush(stderr);
	199	#endif
	200	if(strncasecmp(r_inputs->value,"C-FORTRAN",9)==0){
	201	#ifdef WIN32
	202	//Strange return value needed here !
	203	return 1;
	204	#endif
	205	r_inputs=getMap(request_inputs,"Identifier");
	206	char fname[1024];
	207	sprintf(fname,"%s_",r_inputs->value);
	208	#ifdef DEBUG
	209	fprintf(stderr,"Try to load function %s\n",fname);
	210	#endif
	211	#ifdef WIN32
	212	typedef int (CALLBACK* execute_t)(char*,char,char**);
	213	execute_t execute=(execute_t)GetProcAddress(so,fname);
	214	#else
	215	typedef int (execute_t)(char,char,char**);
	216	execute_t execute=(execute_t)dlsym(so,fname);
	217	#endif
	218	#ifdef DEBUG
	219	#ifdef WIN32
	220	errstr = GetLastError();
	221	#else
	222	errstr = dlerror();
	223	#endif
	224	fprintf(stderr,"Function loaded %s\n",errstr);
	225	#endif
	226
	227	char main_conf[10][30][1024];
	228	char inputs[10][30][1024];
	229	char outputs[10][30][1024];
	230	for(int i=0;i<10;i++){
	231	for(int j=0;j<30;j++){
	232	memset(main_conf[i][j],0,1024);
	233	memset(inputs[i][j],0,1024);
	234	memset(outputs[i][j],0,1024);
	235	}
	236	}
	237	mapsToCharXXX(m,(char***)main_conf);
	238	mapsToCharXXX(request_input_real_format,(char***)inputs);
	239	mapsToCharXXX(request_output_real_format,(char***)outputs);
	240	eres=execute((char)&main_conf[0],(char)&inputs[0],(char**)&outputs[0]);
	241	#ifdef DEBUG
	242	fprintf(stderr,"Function run successfully \n");
	243	#endif
	244	charxxxToMaps((char***)&outputs[0],&request_output_real_format);
	245	}else{
	246	#ifdef DEBUG
	247	#ifdef WIN32
	248	errstr = GetLastError();
	249	fprintf(stderr,"Function %s failed to load because of %d\n",r_inputs->value,errstr);
	250	#endif
	251	#endif
	252	r_inputs=getMap(request_inputs,"Identifier");
	253	#ifdef DEBUG
	254	fprintf(stderr,"Try to load function %s\n",r_inputs->value);
	255	#endif
	256	typedef int (execute_t)(maps,maps,maps*);
	257	#ifdef WIN32
	258	execute_t execute=(execute_t)GetProcAddress(so,r_inputs->value);
	259	#else
	260	execute_t execute=(execute_t)dlsym(so,r_inputs->value);
	261	#endif
	262
	263	#ifdef DEBUG
	264	#ifdef WIN32
	265	errstr = GetLastError();
	266	#else
	267	errstr = dlerror();
	268	#endif
	269	fprintf(stderr,"Function loaded %s\n",errstr);
	270	#endif
	271
	272	#ifdef DEBUG
	273	fprintf(stderr,"Now run the function \n");
	274	fflush(stderr);
	275	#endif
	276	*eres=execute(&m,&request_input_real_format,&request_output_real_format);
	277	#ifdef DEBUG
	278	fprintf(stderr,"Function loaded and returned %d\n",eres);
	279	fflush(stderr);
	280	#endif
	281	}
	282	dlclose(so);
	283	} else {
	284	/**
	285	* Unable to load the specified shared library
	286	*/
	287	char tmps[1024];
	288	#ifdef WIN32
	289	DWORD errstr = GetLastError();
	290	#else
	291	char* errstr = dlerror();
	292	#endif
	293	sprintf(tmps,_("C Library can't be loaded %s \n"),errstr);
	294	map* tmps1=createMap("text",tmps);
	295	printExceptionReportResponse(m,tmps1);
	296	*eres=-1;
	297	}
	298	}
	299	else
	300	#ifdef USE_PYTHON
	301	if(strncasecmp(r_inputs->value,"PYTHON",6)==0){
	302	*eres=zoo_python_support(&m,request_inputs,s1,&request_input_real_format,&request_output_real_format);
	303	}
	304	else
	305	#endif
	306
	307	#ifdef USE_JAVA
	308	if(strncasecmp(r_inputs->value,"JAVA",4)==0){
	309	*eres=zoo_java_support(&m,request_inputs,s1,&request_input_real_format,&request_output_real_format);
	310	}
	311	else
	312	#endif
	313
	314	#ifdef USE_PHP
	315	if(strncasecmp(r_inputs->value,"PHP",3)==0){
	316	*eres=zoo_php_support(&m,request_inputs,s1,&request_input_real_format,&request_output_real_format);
	317	}
	318	else
	319	#endif
	320
	321
	322	#ifdef USE_PERL
	323	if(strncasecmp(r_inputs->value,"PERL",4)==0){
	324	*eres=zoo_perl_support(&m,request_inputs,s1,&request_input_real_format,&request_output_real_format);
	325	}
	326	else
	327	#endif
	328
	329	#ifdef USE_JS
	330	if(strncasecmp(r_inputs->value,"JS",2)==0){
	331	*eres=zoo_js_support(&m,request_inputs,s1,&request_input_real_format,&request_output_real_format);
	332	}
	333	else
	334	#endif
	335	{
	336	char tmpv[1024];
	337	sprintf(tmpv,_("Programming Language (%s) set in ZCFG file is not currently supported by ZOO Kernel.\n"),r_inputs->value);
	338	map* tmps=createMap("text",tmpv);
	339	printExceptionReportResponse(m,tmps);
	340	*eres=-1;
	341	}
[57]	342	*myMap=m;
[34]	343	*ioutputs=request_output_real_format;
	344	}
	345
[1]	346	int runRequest(map* request_inputs)
	347	{
	348
[53]	349	#ifndef USE_GDB
[9]	350	(void) signal(SIGSEGV,sig_handler);
	351	(void) signal(SIGTERM,sig_handler);
	352	(void) signal(SIGINT,sig_handler);
	353	(void) signal(SIGILL,sig_handler);
	354	(void) signal(SIGFPE,sig_handler);
	355	(void) signal(SIGABRT,sig_handler);
[53]	356	#endif
[9]	357
[1]	358	map* r_inputs=NULL,*tmps=NULL;
	359	maps* m=NULL;
	360	int argc=count(request_inputs);
	361
	362	char* REQUEST=NULL;
	363	/**
	364	* Parsing service specfic configuration file
	365	*/
[9]	366	m=(maps*)calloc(1,MAPS_SIZE);
	367	if(m == NULL){
[34]	368	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	369	}
[1]	370	char ntmp[1024];
	371	#ifndef WIN32
	372	getcwd(ntmp,1024);
	373	#else
	374	_getcwd(ntmp,1024);
	375	#endif
[9]	376	r_inputs=getMap(request_inputs,"metapath");
	377	if(r_inputs==NULL){
	378	if(request_inputs==NULL)
	379	request_inputs=createMap("metapath","");
	380	else
	381	addToMap(request_inputs,"metapath","");
	382	#ifdef DEBUG
	383	fprintf(stderr,"ADD METAPATH\n");
	384	dumpMap(request_inputs);
	385	#endif
	386	r_inputs=getMap(request_inputs,"metapath");
	387	}
	388	char conf_file[10240];
	389	snprintf(conf_file,10240,"%s/%s/main.cfg",ntmp,r_inputs->value);
[1]	390	conf_read(conf_file,m);
[9]	391	#ifdef DEBUG
	392	fprintf(stderr, "***** BEGIN MAPS\n");
	393	dumpMaps(m);
	394	fprintf(stderr, "***** END MAPS\n");
	395	#endif
	396
[34]	397	bindtextdomain ("zoo-kernel","/usr/share/locale/");
	398	bindtextdomain ("zoo-services","/usr/share/locale/");
	399
	400	if((r_inputs=getMap(request_inputs,"language"))!=NULL){
	401	char *tmp=strdup(r_inputs->value);
	402	translateChar(tmp,'-','_');
	403	setlocale (LC_ALL, tmp);
	404	free(tmp);
	405	setMapInMaps(m,"main","language",r_inputs->value);
	406	}
	407	else{
	408	setlocale (LC_ALL, "en_US");
	409	setMapInMaps(m,"main","language","en-US");
	410	}
	411	setlocale (LC_NUMERIC, "en_US");
	412	bind_textdomain_codeset("zoo-kernel","UTF-8");
	413	textdomain("zoo-kernel");
	414	bind_textdomain_codeset("zoo-services","UTF-8");
	415	textdomain("zoo-services");
	416
	417
[1]	418	/**
	419	* Check for minimum inputs
	420	*/
	421	r_inputs=getMap(request_inputs,"Request");
[9]	422	if(request_inputs==NULL \|\| r_inputs==NULL){
[34]	423	errorException(m, _("Parameter <request> was not specified"),"MissingParameterValue");
[9]	424	freeMaps(&m);
	425	free(m);
[60]	426	freeMap(&request_inputs);
	427	free(request_inputs);
	428	free(REQUEST);
[1]	429	return 1;
	430	}
[9]	431	else{
[1]	432	REQUEST=strdup(r_inputs->value);
[9]	433	if(strncasecmp(r_inputs->value,"GetCapabilities",15)!=0
	434	&& strncasecmp(r_inputs->value,"DescribeProcess",15)!=0
	435	&& strncasecmp(r_inputs->value,"Execute",7)!=0){
[34]	436	errorException(m, _("Unenderstood <request> value. Please check that it was set to GetCapabilities, DescribeProcess or Execute."), "InvalidParameterValue");
[9]	437	freeMaps(&m);
	438	free(m);
	439	free(REQUEST);
	440	return 1;
	441	}
	442	}
[1]	443	r_inputs=NULL;
	444	r_inputs=getMap(request_inputs,"Service");
[9]	445	if(r_inputs==NULLMAP){
[34]	446	errorException(m, _("Parameter <service> was not specified"),"MissingParameterValue");
[9]	447	freeMaps(&m);
	448	free(m);
	449	free(REQUEST);
[1]	450	return 1;
	451	}
[9]	452	if(strncasecmp(REQUEST,"GetCapabilities",15)!=0){
[1]	453	r_inputs=getMap(request_inputs,"Version");
	454	if(r_inputs==NULL){
[34]	455	errorException(m, _("Parameter <version> was not specified"),"MissingParameterValue");
[9]	456	freeMaps(&m);
	457	free(m);
	458	free(REQUEST);
[1]	459	return 1;
	460	}
	461	}
	462
[9]	463	r_inputs=getMap(request_inputs,"serviceprovider");
	464	if(r_inputs==NULL){
	465	addToMap(request_inputs,"serviceprovider","");
[1]	466	}
	467
	468	map* outputs=NULL;
	469	maps* request_output_real_format=NULL;
	470	map* tmpm=getMapFromMaps(m,"main","serverAddress");
	471	if(tmpm!=NULL)
	472	SERVICE_URL=strdup(tmpm->value);
	473	else
	474	SERVICE_URL=DEFAULT_SERVICE_URL;
	475
	476	service* s[100];
	477	service* s1;
	478	int scount=0;
	479
	480	#ifdef DEBUG
	481	dumpMap(r_inputs);
	482	#endif
	483	char conf_dir[1024];
	484	int t;
	485	char tmps1[1024];
	486
[9]	487	r_inputs=NULL;
	488	r_inputs=getMap(request_inputs,"metapath");
	489	if(r_inputs!=NULL)
	490	snprintf(conf_dir,1024,"%s/%s",ntmp,r_inputs->value);
	491	else
	492	snprintf(conf_dir,1024,"%s",ntmp);
	493
	494	if(strncasecmp(REQUEST,"GetCapabilities",15)==0){
[1]	495	int i=0;
	496	struct dirent *dp;
	497	#ifdef DEBUG
	498	dumpMap(r_inputs);
	499	#endif
[9]	500	DIR *dirp = opendir(conf_dir);
[1]	501	if(dirp==NULL){
[34]	502	return errorException(m, _("The specified path doesn't exist."),"InvalidParameterValue");
[1]	503	}
	504	xmlDocPtr doc = xmlNewDoc(BAD_CAST "1.0");
	505	r_inputs=NULL;
	506	r_inputs=getMap(request_inputs,"ServiceProvider");
[9]	507	xmlNodePtr n;
	508	//dumpMap(request_inputs);
	509	if(r_inputs!=NULL)
	510	n = printGetCapabilitiesHeader(doc,r_inputs->value,m);
	511	else
	512	n = printGetCapabilitiesHeader(doc,"",m);
[1]	513	/**
	514	* Strange, here we need to close stdout to ensure that no uneeded
	515	* char will be printed (parser issue ?)
	516	*/
	517	int saved_stdout = dup(fileno(stdout));
	518	dup2(fileno(stderr),fileno(stdout));
	519	while ((dp = readdir(dirp)) != NULL)
	520	if(strstr(dp->d_name,".zcfg")!=0){
[9]	521	memset(tmps1,0,1024);
	522	snprintf(tmps1,1024,"%s/%s",conf_dir,dp->d_name);
	523	s1=(service*)calloc(1,SERVICE_SIZE);
	524	if(s1 == NULL){
[34]	525	return errorException(m, _("Unable to allocate memory."),"InternalError");
[9]	526	}
[1]	527	#ifdef DEBUG
	528	fprintf(stderr,"#################\n%s\n#################\n",tmps1);
	529	#endif
	530	t=getServiceFromFile(tmps1,&s1);
	531	#ifdef DEBUG
	532	dumpService(s1);
	533	fflush(stdout);
	534	fflush(stderr);
	535	#endif
	536	printGetCapabilitiesForProcess(m,n,s1);
[9]	537	freeService(&s1);
	538	free(s1);
[1]	539	scount++;
	540	}
	541	(void)closedir(dirp);
	542	fflush(stdout);
	543	dup2(saved_stdout,fileno(stdout));
[9]	544	printDocument(m,doc,getpid());
	545	freeMaps(&m);
	546	free(m);
	547	free(REQUEST);
	548	free(SERVICE_URL);
[1]	549	fflush(stdout);
	550	return 0;
	551	}
	552	else{
	553	r_inputs=getMap(request_inputs,"Identifier");
	554	if(r_inputs==NULL
	555	\|\| strlen(r_inputs->name)==0 \|\| strlen(r_inputs->value)==0){
[34]	556	errorException(m, _("Mandatory <identifier> was not specified"),"MissingParameterValue");
[9]	557	freeMaps(&m);
	558	free(m);
	559	free(REQUEST);
	560	free(SERVICE_URL);
	561	return 0;
[1]	562	}
	563
	564	struct dirent *dp;
	565	DIR *dirp = opendir(conf_dir);
	566	if(dirp==NULL){
[34]	567	errorException(m, _("The specified path path doesn't exist."),"InvalidParameterValue");
[9]	568	freeMaps(&m);
	569	free(m);
	570	free(REQUEST);
	571	free(SERVICE_URL);
	572	return 0;
[1]	573	}
[9]	574	if(strncasecmp(REQUEST,"DescribeProcess",15)==0){
[1]	575	/**
	576	* Loop over Identifier list
	577	*/
	578	xmlDocPtr doc = xmlNewDoc(BAD_CAST "1.0");
	579	r_inputs=NULL;
	580	r_inputs=getMap(request_inputs,"ServiceProvider");
[9]	581
[1]	582	xmlNodePtr n;
	583	if(r_inputs!=NULL)
	584	n = printDescribeProcessHeader(doc,r_inputs->value,m);
[9]	585	else
	586	n = printDescribeProcessHeader(doc,"",m);
[1]	587
	588	r_inputs=getMap(request_inputs,"Identifier");
	589	char *tmps=strtok(r_inputs->value,",");
	590
	591	char buff[256];
	592	char buff1[1024];
	593	int i=0;
	594	int j=0;
	595	int end=-1;
	596	int saved_stdout = dup(fileno(stdout));
	597	dup2(fileno(stderr),fileno(stdout));
	598	while(tmps){
	599	memset(buff,0,256);
[9]	600	snprintf(buff,256,"%s.zcfg",tmps);
[1]	601	memset(buff1,0,1024);
	602	#ifdef DEBUG
	603	fprintf(stderr,"\n#######%s\n########\n",buff1);
	604	#endif
	605	while ((dp = readdir(dirp)) != NULL)
	606	if(strcmp(dp->d_name,buff)==0){
	607	memset(buff1,0,1024);
[9]	608	snprintf(buff1,1024,"%s/%s",conf_dir,dp->d_name);
	609	//s1=(service)malloc(sizeof(service));
	610	s1=(service*)calloc(1,SERVICE_SIZE);
	611	if(s1 == NULL){
[34]	612	return errorException(m, _("Unable to allocate memory."),"InternalError");
[9]	613	}
[1]	614	#ifdef DEBUG
[9]	615	fprintf(stderr,"#################\n%s\n#################\n",buff1);
[1]	616	#endif
	617	t=getServiceFromFile(buff1,&s1);
[9]	618	#ifdef DEBUG
	619	dumpService(s1);
	620	#endif
	621	printDescribeProcessForProcess(m,n,s1,1);
	622	freeService(&s1);
	623	free(s1);
[1]	624	scount++;
	625	}
	626	rewinddir(dirp);
	627	tmps=strtok(NULL,",");
	628	}
[9]	629	closedir(dirp);
[1]	630	fflush(stdout);
	631	dup2(saved_stdout,fileno(stdout));
[9]	632	printDocument(m,doc,getpid());
	633	freeMaps(&m);
	634	free(m);
	635	free(REQUEST);
	636	free(SERVICE_URL);
[1]	637	fflush(stdout);
	638	//xmlFree(n);
	639	#ifndef LINUX_FREE_ISSUE
[9]	640	if(s1)
	641	free(s1);
[1]	642	#endif
	643	return 0;
	644	}
	645	else
[9]	646	if(strncasecmp(REQUEST,"Execute",strlen(REQUEST))!=0){
[34]	647	errorException(m, _("Unenderstood <request> value. Please check that it was set to GetCapabilities, DescribeProcess or Execute."), "InvalidParameterValue");
[1]	648	#ifdef DEBUG
	649	fprintf(stderr,"No request found %s",REQUEST);
	650	#endif
[9]	651	closedir(dirp);
[1]	652	free(s);
	653	return 0;
	654	}
[9]	655	closedir(dirp);
[1]	656	}
	657
	658	s1=NULL;
[9]	659	s1=(service*)calloc(1,SERVICE_SIZE);
	660	if(s1 == NULL){
[32]	661	freeMaps(&m);
	662	free(m);
	663	free(REQUEST);
	664	free(SERVICE_URL);
[34]	665	return errorException(m, _("Unable to allocate memory."),"InternalError");
[9]	666	}
[1]	667	r_inputs=getMap(request_inputs,"MetaPath");
[9]	668	if(r_inputs!=NULL)
	669	snprintf(tmps1,1024,"%s/%s",ntmp,r_inputs->value);
	670	else
	671	snprintf(tmps1,1024,"%s/",ntmp);
[1]	672	r_inputs=getMap(request_inputs,"Identifier");
[9]	673	char *ttmp=strdup(tmps1);
	674	snprintf(tmps1,1024,"%s/%s.zcfg",ttmp,r_inputs->value);
	675	free(ttmp);
[1]	676	#ifdef DEBUG
	677	fprintf(stderr,"Trying to load %s\n", tmps1);
	678	#endif
	679	int saved_stdout = dup(fileno(stdout));
	680	dup2(fileno(stderr),fileno(stdout));
	681	t=getServiceFromFile(tmps1,&s1);
	682	fflush(stdout);
	683	dup2(saved_stdout,fileno(stdout));
[32]	684	if(t<0){
	685	char tmpMsg[2048+strlen(r_inputs->value)];
[34]	686	sprintf(tmpMsg,_("The value for <indetifier> seems to be wrong (%s). Please, ensure that the process exist using the GetCapabilities request."),r_inputs->value);
[32]	687	errorException(m, tmpMsg, "InvalidParameterValue");
	688	freeService(&s1);
	689	free(s1);
	690	freeMaps(&m);
	691	free(m);
	692	free(REQUEST);
	693	free(SERVICE_URL);
	694	return 0;
[1]	695	}
[32]	696	close(saved_stdout);
[1]	697
	698	#ifdef DEBUG
	699	dumpService(s1);
	700	#endif
	701	map* inputs=NULL;
	702	elements* c_inputs=s1->inputs;
	703	int j;
	704
	705	/**
	706	* Create the input maps data structure
	707	*/
	708	int i=0;
	709	HINTERNET hInternet;
	710	HINTERNET res;
	711	hInternet=InternetOpen(
	712	#ifndef WIN32
	713	(LPCTSTR)
	714	#endif
	715	"ZooWPSClient\0",
	716	INTERNET_OPEN_TYPE_PRECONFIG,
	717	NULL,NULL, 0);
	718
	719	#ifndef WIN32
	720	if(!CHECK_INET_HANDLE(hInternet))
	721	fprintf(stderr,"WARNING : hInternet handle failed to initialize");
	722	#endif
	723	maps* request_input_real_format=NULL;
	724	maps* tmpmaps = request_input_real_format;
	725	map* postRequest=NULL;
	726	postRequest=getMap(request_inputs,"xrequest");
	727	if(postRequest==NULLMAP){
	728	/**
	729	* Parsing outputs provided as KVP
	730	*/
	731	r_inputs=NULL;
	732	#ifdef DEBUG
	733	fprintf(stderr,"OUTPUT Parsing ... \n");
	734	#endif
	735	r_inputs=getMap(request_inputs,"ResponseDocument");
[9]	736	if(r_inputs==NULL) r_inputs=getMap(request_inputs,"RawDataOutput");
	737
[32]	738	#ifdef DEBUG
[1]	739	fprintf(stderr,"OUTPUT Parsing ... \n");
[32]	740	#endif
[9]	741	if(r_inputs!=NULL){
[32]	742	#ifdef DEBUG
[1]	743	fprintf(stderr,"OUTPUT Parsing start now ... \n");
[32]	744	#endif
[1]	745	char current_output_as_string[10240];
	746	char cursor_output[10240];
[9]	747	char *cotmp=strdup(r_inputs->value);
	748	snprintf(cursor_output,10240,"%s",cotmp);
	749	free(cotmp);
[1]	750	j=0;
	751	map* request_kvp_outputs=NULL;
	752
	753	/**
	754	* Put each Output into the outputs_as_text array
	755	*/
	756	char * pToken;
	757	maps* tmp_output=NULL;
	758	#ifdef DEBUG
	759	fprintf(stderr,"OUTPUT [%s]\n",cursor_output);
	760	#endif
	761	pToken=strtok(cursor_output,";");
[9]	762	char outputs_as_text=(char)calloc(128,sizeof(char*));
	763	if(outputs_as_text == NULL) {
[34]	764	return errorException(m, _("Unable to allocate memory"), "InternalError");
[9]	765	}
[1]	766	i=0;
	767	while(pToken!=NULL){
	768	#ifdef DEBUG
	769	fprintf(stderr,"*%s*\n",pToken);
	770	fflush(stderr);
	771	fprintf(stderr,"*%s*\n",pToken);
	772	#endif
[9]	773	outputs_as_text[i]=(char*)calloc(strlen(pToken)+1,sizeof(char));
	774	if(outputs_as_text[i] == NULL) {
[34]	775	return errorException(m, _("Unable to allocate memory"), "InternalError");
[9]	776	}
	777	snprintf(outputs_as_text[i],strlen(pToken)+1,"%s",pToken);
[1]	778	pToken = strtok(NULL,";");
	779	i++;
	780	}
	781	for(j=0;j<i;j++){
	782	char *tmp=strdup(outputs_as_text[j]);
[9]	783	free(outputs_as_text[j]);
[1]	784	char *tmpc;
	785	tmpc=strtok(tmp,"@");
	786	int k=0;
	787	while(tmpc!=NULL){
	788	if(k==0){
	789	if(tmp_output==NULL){
[9]	790	tmp_output=(maps*)calloc(1,MAPS_SIZE);
	791	if(tmp_output == NULL){
[34]	792	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	793	}
[1]	794	tmp_output->name=strdup(tmpc);
	795	tmp_output->content=NULL;
	796	tmp_output->next=NULL;
	797	}
	798	}
	799	else{
	800	char *tmpv=strstr(tmpc,"=");
	801	char tmpn[256];
	802	memset(tmpn,0,256);
	803	strncpy(tmpn,tmpc,(strlen(tmpc)-strlen(tmpv))*sizeof(char));
	804	tmpn[strlen(tmpc)-strlen(tmpv)]=0;
	805	#ifdef DEBUG
	806	fprintf(stderr,"OUTPUT DEF [%s]=[%s]\n",tmpn,tmpv+1);
	807	#endif
	808	if(tmp_output->content==NULL){
	809	tmp_output->content=createMap(tmpn,tmpv+1);
	810	tmp_output->content->next=NULL;
	811	}
	812	else
	813	addToMap(tmp_output->content,tmpn,tmpv+1);
	814	}
	815	k++;
	816	#ifdef DEBUG
	817	fprintf(stderr,"*%s*\n",tmpc);
	818	#endif
	819	tmpc=strtok(NULL,"@");
	820	}
	821	if(request_output_real_format==NULL)
[9]	822	request_output_real_format=dupMaps(&tmp_output);
[1]	823	else
	824	addMapsToMaps(&request_output_real_format,tmp_output);
[9]	825	freeMaps(&tmp_output);
	826	free(tmp_output);
	827	tmp_output=NULL;
[1]	828	#ifdef DEBUG
	829	dumpMaps(tmp_output);
	830	fflush(stderr);
	831	#endif
[9]	832	//tmp_output=tmp_output->next;
	833	free(tmp);
[1]	834	}
[9]	835	free(outputs_as_text);
[1]	836	}
	837
	838
	839	/**
	840	* Parsing inputs provided as KVP
	841	*/
	842	r_inputs=getMap(request_inputs,"DataInputs");
	843	#ifdef DEBUG
	844	fprintf(stderr,"DATA INPUTS [%s]\n",r_inputs->value);
	845	#endif
	846	char current_input_as_string[40960];
	847	char cursor_input[40960];
[9]	848	if(r_inputs!=NULL)
	849	snprintf(cursor_input,40960,"%s",r_inputs->value);
	850	else{
[34]	851	errorException(m, _("Parameter <DataInputs> was not specified"),"MissingParameterValue");
[9]	852	freeMaps(&m);
	853	free(m);
	854	free(REQUEST);
	855	free(SERVICE_URL);
[57]	856	InternetCloseHandle(hInternet);
	857	freeService(&s1);
	858	free(s1);
[9]	859	return 0;
	860	}
[1]	861	j=0;
	862	map* request_kvp_inputs=NULL;
	863
	864	/**
	865	* Put each DataInputs into the inputs_as_text array
	866	*/
	867	char * pToken;
	868	pToken=strtok(cursor_input,";");
[9]	869	char inputs_as_text=(char)calloc(100,sizeof(char*));
	870	if(inputs_as_text == NULL){
[34]	871	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	872	}
[1]	873	i=0;
	874	while(pToken!=NULL){
	875	#ifdef DEBUG
	876	fprintf(stderr,"*%s*\n",pToken);
	877	#endif
	878	fflush(stderr);
	879	#ifdef DEBUG
	880	fprintf(stderr,"*%s*\n",pToken);
	881	#endif
[9]	882	inputs_as_text[i]=(char*)calloc(strlen(pToken)+1,sizeof(char));
	883	snprintf(inputs_as_text[i],strlen(pToken)+1,"%s",pToken);
	884	if(inputs_as_text[i] == NULL){
[34]	885	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	886	}
[1]	887	pToken = strtok(NULL,";");
	888	i++;
	889	}
	890
	891	for(j=0;j<i;j++){
	892	char *tmp=strdup(inputs_as_text[j]);
[9]	893	free(inputs_as_text[j]);
[1]	894	char *tmpc;
	895	tmpc=strtok(tmp,"@");
	896	while(tmpc!=NULL){
	897	#ifdef DEBUG
	898	fprintf(stderr,"*\n%s**\n",tmpc);
	899	#endif
	900	char *tmpv=strstr(tmpc,"=");
	901	char tmpn[256];
	902	memset(tmpn,0,256);
	903	strncpy(tmpn,tmpc,(strlen(tmpc)-strlen(tmpv))*sizeof(char));
	904	tmpn[strlen(tmpc)-strlen(tmpv)]=0;
	905	int cnt=0;
	906	#ifdef DEBUG
	907	fprintf(stderr,"*\n* %s = %s ***\n",tmpn,tmpv+1);
	908	#endif
	909	if(tmpmaps==NULL){
[9]	910	tmpmaps=(maps*)calloc(1,MAPS_SIZE);
	911	if(tmpmaps == NULL){
[34]	912	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	913	}
[1]	914	tmpmaps->name=strdup(tmpn);
	915	tmpmaps->content=createMap("value",tmpv+1);
	916	tmpmaps->next=NULL;
	917	}
	918	tmpc=strtok(NULL,"@");
	919	while(tmpc!=NULL){
	920	#ifdef DEBUG
	921	fprintf(stderr,"* KVP NON URL-ENCODED \n%s**\n",tmpc);
	922	#endif
	923	char *tmpv1=strstr(tmpc,"=");
	924	#ifdef DEBUG
	925	fprintf(stderr,"* VALUE NON URL-ENCODED \n%s**\n",tmpv1+1);
	926	#endif
	927	char tmpn1[1024];
	928	memset(tmpn1,0,1024);
	929	strncpy(tmpn1,tmpc,strlen(tmpc)-strlen(tmpv1));
	930	tmpn1[strlen(tmpc)-strlen(tmpv1)]=0;
	931	#ifdef DEBUG
	932	fprintf(stderr,"* NAME NON URL-ENCODED \n%s**\n",tmpn1);
	933	fprintf(stderr,"* VALUE NON URL-ENCODED \n%s**\n",tmpv1+1);
	934	#endif
	935	if(strcmp(tmpn1,"xlink:href")!=0)
	936	addToMap(tmpmaps->content,tmpn1,tmpv1+1);
	937	else{
	938	#ifdef DEBUG
	939	fprintf(stderr,"REQUIRE TO DOWNLOAD A FILE FROM A SERVER : url(%s)\n",tmpv1+1);
	940	#endif
	941	#ifndef WIN32
[9]	942	if(CHECK_INET_HANDLE(hInternet))
[1]	943	#endif
[9]	944	{
	945	res=InternetOpenUrl(hInternet,tmpv1+1,NULL,0,
	946	INTERNET_FLAG_NO_CACHE_WRITE,0);
[1]	947	#ifdef DEBUG
[9]	948	fprintf(stderr,"(%s) content-length : %d,,res.nDataAlloc %d \n",
	949	tmpv1+1,res.nDataAlloc,res.nDataLen);
[1]	950	#endif
[9]	951	char* tmpContent=(char*)calloc((res.nDataLen+1),sizeof(char));
	952	if(tmpContent == NULL){
[34]	953	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	954	}
	955	size_t dwRead;
	956	InternetReadFile(res, (LPVOID)tmpContent,res.nDataLen, &dwRead);
	957	map* tmpMap=getMap(tmpmaps->content,"value");
[58]	958	if(tmpMap!=NULL){
[59]	959	free(tmpMap->value);
[58]	960	tmpMap->value=(char)malloc((res.nDataLen+1)sizeof(char));
	961	memmove(tmpMap->value,tmpContent,(res.nDataLen)*sizeof(char));
	962	tmpMap->value[res.nDataLen]=0;
[59]	963	if(strlen(tmpContent)!=res.nDataLen){
[58]	964	char tmp[256];
[59]	965	sprintf(tmp,"%d",res.nDataLen*sizeof(char));
[58]	966	addToMap(tmpmaps->content,"size",tmp);
	967	}
	968	}
[9]	969	free(tmpContent);
	970	}
[1]	971	addToMap(tmpmaps->content,tmpn1,tmpv1+1);
	972	}
	973	tmpc=strtok(NULL,"@");
	974	}
	975	#ifdef DEBUG
	976	dumpMaps(tmpmaps);
	977	fflush(stderr);
	978	#endif
[9]	979	if(request_input_real_format==NULL)
	980	request_input_real_format=dupMaps(&tmpmaps);
	981	else
	982	addMapsToMaps(&request_input_real_format,tmpmaps);
	983	freeMaps(&tmpmaps);
	984	free(tmpmaps);
	985	tmpmaps=NULL;
	986	free(tmp);
[1]	987	}
	988	}
[9]	989	free(inputs_as_text);
	990	}
[1]	991	else {
[9]	992	/**
	993	* Parse XML request
	994	*/
[1]	995	xmlInitParser();
	996	#ifdef DEBUG
	997	fflush(stderr);
	998	fprintf(stderr,"BEFORE %s\n",postRequest->value);
	999	fflush(stderr);
	1000	#endif
	1001	xmlDocPtr doc =
[5]	1002	xmlParseMemory(postRequest->value,cgiContentLength);
[1]	1003	#ifdef DEBUG
	1004	fprintf(stderr,"AFTER\n");
	1005	fflush(stderr);
	1006	#endif
	1007	xmlNodePtr cur = xmlDocGetRootElement(doc);
	1008	/**
	1009	* Parse every Input in DataInputs node.
	1010	*/
	1011	maps* tempMaps=NULL;
[9]	1012	xmlXPathObjectPtr tmpsptr=extractFromDoc(doc,"///*[local-name()='Input']");
	1013	xmlNodeSet* tmps=tmpsptr->nodesetval;
[1]	1014	#ifdef DEBUG
	1015	fprintf(stderr,"***%d***\n",tmps->nodeNr);
	1016	#endif
	1017	for(int k=0;k<tmps->nodeNr;k++){
	1018	maps *tmpmaps=NULL;
	1019	xmlNodePtr cur=tmps->nodeTab[k];
	1020	if(tmps->nodeTab[k]->type == XML_ELEMENT_NODE) {
	1021	/**
	1022	* A specific Input node.
	1023	*/
	1024	#ifdef DEBUG
	1025	fprintf(stderr, "= element 0 node \"%s\"\n", cur->name);
	1026	#endif
[9]	1027	xmlNodePtr cur2=cur->children;
[32]	1028	while(cur2!=NULL){
	1029	while(cur2!=NULL && cur2->type!=XML_ELEMENT_NODE)
[9]	1030	cur2=cur2->next;
[32]	1031	if(cur2==NULL)
	1032	break;
[9]	1033	/**
	1034	* Indentifier
	1035	*/
	1036	if(xmlStrncasecmp(cur2->name,BAD_CAST "Identifier",xmlStrlen(cur2->name))==0){
	1037	xmlChar *val= xmlNodeListGetString(doc,cur2->xmlChildrenNode,1);
	1038	if(tmpmaps==NULL){
	1039	tmpmaps=(maps*)calloc(1,MAPS_SIZE);
	1040	if(tmpmaps == NULL){
[34]	1041	return errorException(m, _("Unable to allocate memory."), "InternalError");
[1]	1042	}
[9]	1043	tmpmaps->name=strdup((char*)val);
	1044	tmpmaps->content=NULL;
	1045	tmpmaps->next=NULL;
[1]	1046	}
[9]	1047	xmlFree(val);
	1048	}
	1049	/**
	1050	* Title, Asbtract
	1051	*/
	1052	if(xmlStrncasecmp(cur2->name,BAD_CAST "Title",xmlStrlen(cur2->name))==0 \|\|
	1053	xmlStrncasecmp(cur2->name,BAD_CAST "Abstract",xmlStrlen(cur2->name))==0){
	1054	xmlChar *val=
	1055	xmlNodeListGetString(doc,cur2->xmlChildrenNode,1);
	1056	if(tmpmaps==NULL){
	1057	tmpmaps=(maps*)calloc(1,MAPS_SIZE);
	1058	if(tmpmaps == NULL){
[34]	1059	return errorException(m, _("Unable to allocate memory."), "InternalError");
[1]	1060	}
[9]	1061	tmpmaps->name="missingIndetifier";
	1062	tmpmaps->content=createMap((char)cur2->name,(char)val);
	1063	tmpmaps->next=NULL;
	1064	}
	1065	else{
	1066	if(tmpmaps->content!=NULL)
	1067	addToMap(tmpmaps->content,
	1068	(char)cur2->name,(char)val);
	1069	else
	1070	tmpmaps->content=
	1071	createMap((char)cur2->name,(char)val);
	1072	}
[1]	1073	#ifdef DEBUG
[9]	1074	dumpMaps(tmpmaps);
[1]	1075	#endif
[9]	1076	xmlFree(val);
	1077	}
	1078	/**
	1079	* InputDataFormChoice (Reference or Data ?)
	1080	*/
	1081	if(xmlStrcasecmp(cur2->name,BAD_CAST "Reference")==0){
[1]	1082	/**
[9]	1083	* Get every attribute from a Reference node
	1084	* mimeType, encoding, schema, href, method
	1085	* Header and Body gesture should be added here
[1]	1086	*/
	1087	#ifdef DEBUG
[9]	1088	fprintf(stderr,"REFERENCE\n");
[1]	1089	#endif
[9]	1090	map* referenceMap=NULL;
	1091	char *refs[5];
	1092	refs[0]="mimeType";
	1093	refs[1]="encoding";
	1094	refs[2]="schema";
	1095	refs[3]="method";
	1096	refs[4]="href";
	1097	char*url;
	1098	for(int l=0;l<5;l++){
[1]	1099	#ifdef DEBUG
[9]	1100	fprintf(stderr,"* %s *",refs[l]);
[1]	1101	#endif
[9]	1102	xmlChar *val=xmlGetProp(cur2,BAD_CAST refs[l]);
	1103	if(val!=NULL && xmlStrlen(val)>0){
	1104	if(tmpmaps->content!=NULL)
	1105	addToMap(tmpmaps->content,refs[l],(char*)val);
	1106	else
	1107	tmpmaps->content=createMap(refs[l],(char*)val);
	1108	map* ltmp=getMap(tmpmaps->content,"method");
	1109	if(l==4){
	1110	if(!(ltmp!=NULL && strcmp(ltmp->value,"POST")==0)
	1111	&& CHECK_INET_HANDLE(hInternet)){
	1112	res=InternetOpenUrl(hInternet,(char*)val,NULL,0,
	1113	INTERNET_FLAG_NO_CACHE_WRITE,0);
	1114	char* tmpContent=
	1115	(char*)calloc((res.nDataLen+1),sizeof(char));
	1116	if(tmpContent == NULL){
[34]	1117	return errorException(m, _("Unable to allocate memory."), "InternalError");
[1]	1118	}
[9]	1119	size_t dwRead;
	1120	InternetReadFile(res, (LPVOID)tmpContent,
	1121	res.nDataLen, &dwRead);
	1122	tmpContent[res.nDataLen]=0;
	1123	addToMap(tmpmaps->content,"value",tmpContent);
[1]	1124	}
	1125	}
[9]	1126	}
[1]	1127	#ifdef DEBUG
[9]	1128	fprintf(stderr,"%s\n",val);
[1]	1129	#endif
[9]	1130	xmlFree(val);
	1131	}
[1]	1132	#ifdef POST_DEBUG
[9]	1133	fprintf(stderr,"Parse Header and Body from Reference \n");
[1]	1134	#endif
[9]	1135	xmlNodePtr cur3=cur2->children;
	1136	hInternet.header=NULL;
	1137	while(cur3){
	1138	if(xmlStrcasecmp(cur3->name,BAD_CAST "Header")==0 ){
	1139	xmlNodePtr cur4=cur3;
	1140	char *tmp=new char[cgiContentLength];
	1141	char *ha[2];
	1142	ha[0]="key";
	1143	ha[1]="value";
	1144	int hai;
	1145	char *has;
	1146	char *key;
	1147	for(hai=0;hai<2;hai++){
	1148	xmlChar *val=xmlGetProp(cur3,BAD_CAST ha[hai]);
[1]	1149	#ifdef POST_DEBUG
[9]	1150	fprintf(stderr,"%s = %s\n",ha[hai],(char*)val);
[1]	1151	#endif
[9]	1152	if(hai==0){
	1153	key=(char)calloc((1+strlen((char)val)),sizeof(char));
	1154	snprintf(key,1+strlen((char)val),"%s",(char)val);
	1155	}else{
	1156	has=(char)calloc((3+strlen((char)val)+strlen(key)),sizeof(char));
	1157	if(has == NULL){
[34]	1158	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	1159	}
	1160	snprintf(has,(3+strlen((char)val)+strlen(key)),"%s: %s",key,(char)val);
[1]	1161	#ifdef POST_DEBUG
[9]	1162	fprintf(stderr,"%s\n",has);
[1]	1163	#endif
	1164	}
	1165	}
[9]	1166	hInternet.header=curl_slist_append(hInternet.header, has);
	1167	//free(has);
	1168	}
	1169	else{
[1]	1170	#ifdef POST_DEBUG
[9]	1171	fprintf(stderr,"Try to fetch the body part of the request ...\n");
[1]	1172	#endif
[9]	1173	if(xmlStrcasecmp(cur3->name,BAD_CAST "Body")==0 ){
[1]	1174	#ifdef POST_DEBUG
[9]	1175	fprintf(stderr,"Body part found !!!\n",(char*)cur3->content);
[1]	1176	#endif
[9]	1177	char *tmp=new char[cgiContentLength];
	1178	memset(tmp,0,cgiContentLength);
	1179	xmlNodePtr cur4=cur3->children;
	1180	while(cur4!=NULL){
	1181	xmlDocPtr bdoc = xmlNewDoc(BAD_CAST "1.0");
	1182	bdoc->encoding = xmlCharStrdup ("UTF-8");
	1183	xmlDocSetRootElement(bdoc,cur4);
	1184	xmlChar* btmps;
	1185	int bsize;
	1186	xmlDocDumpMemory(bdoc,&btmps,&bsize);
[1]	1187	#ifdef POST_DEBUG
[9]	1188	fprintf(stderr,"Body part found !!! %s %s\n",tmp,(char*)btmps);
[1]	1189	#endif
[9]	1190	if(btmps!=NULL)
	1191	sprintf(tmp,"%s",(char*)btmps);
	1192	xmlFreeDoc(bdoc);
	1193	cur4=cur4->next;
	1194	}
	1195	map *btmp=getMap(tmpmaps->content,"href");
	1196	if(btmp!=NULL){
	1197	#ifdef POST_DEBUG
	1198	fprintf(stderr,"%s %s\n",btmp->value,tmp);
	1199	curl_easy_setopt(hInternet.handle, CURLOPT_VERBOSE, 1);
	1200	#endif
	1201	res=InternetOpenUrl(hInternet,btmp->value,tmp,strlen(tmp),
	1202	INTERNET_FLAG_NO_CACHE_WRITE,0);
	1203	char* tmpContent = (char*)calloc((res.nDataLen+1),sizeof(char));
	1204	if(tmpContent == NULL){
[34]	1205	return errorException(m, _("Unable to allocate memory."), "InternalError");
[1]	1206	}
[9]	1207	size_t dwRead;
	1208	InternetReadFile(res, (LPVOID)tmpContent,
	1209	res.nDataLen, &dwRead);
	1210	tmpContent[res.nDataLen]=0;
	1211	if(hInternet.header!=NULL)
	1212	curl_slist_free_all(hInternet.header);
	1213	addToMap(tmpmaps->content,"value",tmpContent);
	1214	#ifdef POST_DEBUG
	1215	fprintf(stderr,"DL CONTENT : (%s)\n",tmpContent);
	1216	#endif
	1217	}
	1218	}
	1219	else
	1220	if(xmlStrcasecmp(cur3->name,BAD_CAST "BodyReference")==0 ){
	1221	xmlChar *val=xmlGetProp(cur3,BAD_CAST "href");
	1222	HINTERNET bInternet,res1;
	1223	bInternet=InternetOpen(
	1224	#ifndef WIN32
	1225	(LPCTSTR)
	1226	#endif
	1227	"ZooWPSClient\0",
	1228	INTERNET_OPEN_TYPE_PRECONFIG,
	1229	NULL,NULL, 0);
	1230	if(!CHECK_INET_HANDLE(bInternet))
	1231	fprintf(stderr,"WARNING : hInternet handle failed to initialize");
	1232	#ifdef POST_DEBUG
	1233	curl_easy_setopt(bInternet.handle, CURLOPT_VERBOSE, 1);
	1234	#endif
	1235	res1=InternetOpenUrl(bInternet,(char*)val,NULL,0,
	1236	INTERNET_FLAG_NO_CACHE_WRITE,0);
	1237	char* tmp=
	1238	(char*)calloc((res1.nDataLen+1),sizeof(char));
	1239	if(tmp == NULL){
[34]	1240	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	1241	}
	1242	size_t bRead;
	1243	InternetReadFile(res1, (LPVOID)tmp,
	1244	res1.nDataLen, &bRead);
	1245	tmp[res1.nDataLen]=0;
	1246	InternetCloseHandle(bInternet);
[1]	1247	map *btmp=getMap(tmpmaps->content,"href");
	1248	if(btmp!=NULL){
	1249	#ifdef POST_DEBUG
	1250	fprintf(stderr,"%s %s\n",btmp->value,tmp);
	1251	curl_easy_setopt(hInternet.handle, CURLOPT_VERBOSE, 1);
	1252	#endif
[9]	1253	res=InternetOpenUrl(hInternet,btmp->value,tmp,
	1254	strlen(tmp),
[1]	1255	INTERNET_FLAG_NO_CACHE_WRITE,0);
[9]	1256	char* tmpContent = (char*)calloc((res.nDataLen+1),sizeof(char));
	1257	if(tmpContent == NULL){
[34]	1258	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	1259	}
[1]	1260	size_t dwRead;
	1261	InternetReadFile(res, (LPVOID)tmpContent,
	1262	res.nDataLen, &dwRead);
	1263	tmpContent[res.nDataLen]=0;
	1264	if(hInternet.header!=NULL)
	1265	curl_slist_free_all(hInternet.header);
	1266	addToMap(tmpmaps->content,"value",tmpContent);
	1267	#ifdef POST_DEBUG
	1268	fprintf(stderr,"DL CONTENT : (%s)\n",tmpContent);
	1269	#endif
	1270	}
	1271	}
	1272	}
[9]	1273	cur3=cur3->next;
	1274	}
[1]	1275	#ifdef POST_DEBUG
[9]	1276	fprintf(stderr,"Header and Body was parsed from Reference \n");
[1]	1277	#endif
	1278	#ifdef DEBUG
[9]	1279	dumpMap(tmpmaps->content);
	1280	fprintf(stderr, "= element 2 node \"%s\" = (%s)\n",
	1281	cur2->name,cur2->content);
[1]	1282	#endif
[9]	1283	}
	1284	else if(xmlStrcasecmp(cur2->name,BAD_CAST "Data")==0){
[1]	1285	#ifdef DEBUG
[9]	1286	fprintf(stderr,"DATA\n");
[1]	1287	#endif
[9]	1288	xmlNodePtr cur4=cur2->children;
[32]	1289	while(cur4!=NULL){
	1290	while(cur4!=NULL &&cur4->type!=XML_ELEMENT_NODE)
[9]	1291	cur4=cur4->next;
[32]	1292	if(cur4==NULL)
	1293	break;
[9]	1294	if(xmlStrcasecmp(cur4->name, BAD_CAST "LiteralData")==0){
	1295	/**
	1296	* Get every attribute from a LiteralData node
	1297	* dataType , uom
	1298	*/
	1299	char *lits[2];
	1300	lits[0]="dataType";
	1301	lits[1]="uom";
	1302	for(int l=0;l<2;l++){
[1]	1303	#ifdef DEBUG
[9]	1304	fprintf(stderr,"* LiteralData %s *",lits[l]);
[1]	1305	#endif
[9]	1306	xmlChar *val=xmlGetProp(cur4,BAD_CAST lits[l]);
	1307	if(val!=NULL && strlen((char*)val)>0){
	1308	if(tmpmaps->content!=NULL)
	1309	addToMap(tmpmaps->content,lits[l],(char*)val);
	1310	else
	1311	tmpmaps->content=createMap(lits[l],(char*)val);
	1312	}
[1]	1313	#ifdef DEBUG
[9]	1314	fprintf(stderr,"%s\n",val);
[1]	1315	#endif
[9]	1316	xmlFree(val);
[1]	1317	}
[9]	1318	}
	1319	else if(xmlStrcasecmp(cur4->name, BAD_CAST "ComplexData")==0){
	1320	/**
	1321	* Get every attribute from a Reference node
	1322	* mimeType, encoding, schema
	1323	*/
	1324	char *coms[3];
	1325	coms[0]="mimeType";
	1326	coms[1]="encoding";
	1327	coms[2]="schema";
	1328	for(int l=0;l<3;l++){
[1]	1329	#ifdef DEBUG
[9]	1330	fprintf(stderr,"* ComplexData %s *",coms[l]);
[1]	1331	#endif
[9]	1332	xmlChar *val=xmlGetProp(cur4,BAD_CAST coms[l]);
	1333	if(val!=NULL && strlen((char*)val)>0){
	1334	if(tmpmaps->content!=NULL)
	1335	addToMap(tmpmaps->content,coms[l],(char*)val);
	1336	else
	1337	tmpmaps->content=createMap(coms[l],(char*)val);
	1338	}
[1]	1339	#ifdef DEBUG
[9]	1340	fprintf(stderr,"%s\n",val);
[1]	1341	#endif
[9]	1342	xmlFree(val);
[1]	1343	}
	1344	}
[9]	1345	xmlChar* mv=xmlNodeListGetString(doc,cur4->xmlChildrenNode,1);
	1346	addToMap(tmpmaps->content,"value",(char*)mv);
	1347	xmlFree(mv);
	1348	cur4=cur4->next;
[1]	1349	}
[9]	1350	}
[1]	1351	#ifdef DEBUG
[9]	1352	fprintf(stderr,"cur2 next \n");
	1353	fflush(stderr);
[1]	1354	#endif
[9]	1355	cur2=cur2->next;
	1356	}
[1]	1357	#ifdef DEBUG
[9]	1358	fprintf(stderr,"ADD MAPS TO REQUEST MAPS !\n");
	1359	fflush(stderr);
[1]	1360	#endif
[9]	1361	addMapsToMaps(&request_input_real_format,tmpmaps);
	1362
[1]	1363	#ifdef DEBUG
[9]	1364	fprintf(stderr,"****TMPMAPS***\n");
[1]	1365	dumpMaps(tmpmaps);
[9]	1366	fprintf(stderr,"****REQUESTMAPS***\n");
	1367	dumpMaps(request_input_real_format);
[1]	1368	#endif
[32]	1369	freeMaps(&tmpmaps);
	1370	free(tmpmaps);
	1371	tmpmaps=NULL;
[1]	1372	}
[25]	1373	#ifdef DEBUG
	1374	dumpMaps(tmpmaps);
	1375	#endif
[1]	1376	}
	1377	#ifdef DEBUG
[9]	1378	fprintf(stderr,"Search for response document node\n");
	1379	#endif
	1380	xmlXPathFreeObject(tmpsptr);
	1381	//xmlFree(tmps);
	1382	tmpsptr=extractFromDoc(doc,"///*[local-name()='ResponseDocument']");
	1383	tmps=tmpsptr->nodesetval;
	1384	#ifdef DEBUG
[1]	1385	fprintf(stderr,"***%d***\n",tmps->nodeNr);
	1386	#endif
	1387	for(int k=0;k<tmps->nodeNr;k++){
	1388	addToMap(request_inputs,"ResponseDocument","");
	1389	request_output_real_format;
	1390	maps *tmpmaps=NULL;
	1391	xmlNodePtr cur=tmps->nodeTab[k];
	1392	if(cur->type == XML_ELEMENT_NODE) {
	1393	/**
	1394	* A specific responseDocument node.
	1395	*/
	1396	if(tmpmaps==NULL){
[9]	1397	tmpmaps=(maps*)calloc(1,MAPS_SIZE);
	1398	if(tmpmaps == NULL){
[34]	1399	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	1400	}
[1]	1401	tmpmaps->name="unknownIdentifier";
	1402	tmpmaps->next=NULL;
	1403	}
	1404	/**
	1405	* Get every attribute from a LiteralData node
	1406	* storeExecuteResponse, lineage, status
	1407	*/
	1408	char *ress[3];
	1409	ress[0]="storeExecuteResponse";
	1410	ress[1]="lineage";
	1411	ress[2]="status";
	1412	xmlChar *val;
	1413	for(int l=0;l<3;l++){
	1414	#ifdef DEBUG
	1415	fprintf(stderr,"* %s *\t",ress[l]);
	1416	#endif
	1417	val=xmlGetProp(cur,BAD_CAST ress[l]);
	1418	if(val!=NULL && strlen((char*)val)>0){
	1419	if(tmpmaps->content!=NULL)
	1420	addToMap(tmpmaps->content,ress[l],(char*)val);
	1421	else
	1422	tmpmaps->content=createMap(ress[l],(char*)val);
	1423	addToMap(request_inputs,ress[l],(char*)val);
	1424	}
	1425	#ifdef DEBUG
	1426	fprintf(stderr,"%s\n",val);
	1427	#endif
	1428	xmlFree(val);
	1429	}
	1430	xmlNodePtr cur1=cur->children;
	1431	while(cur1){
[9]	1432	if(xmlStrncasecmp(cur1->name,BAD_CAST "Output",xmlStrlen(cur1->name))==0){
[1]	1433	/**
	1434	* Get every attribute from a Output node
	1435	* mimeType, encoding, schema, uom, asReference
	1436	*/
	1437	char *outs[5];
	1438	outs[0]="mimeType";
	1439	outs[1]="encoding";
	1440	outs[2]="schema";
	1441	outs[3]="uom";
	1442	outs[4]="asReference";
	1443	for(int l=0;l<5;l++){
	1444	#ifdef DEBUG
	1445	fprintf(stderr,"* %s *\t",outs[l]);
	1446	#endif
	1447	val=xmlGetProp(cur1,BAD_CAST outs[l]);
	1448	if(val!=NULL && strlen((char*)val)>0){
	1449	if(tmpmaps->content!=NULL)
	1450	addToMap(tmpmaps->content,outs[l],(char*)val);
	1451	else
	1452	tmpmaps->content=createMap(outs[l],(char*)val);
	1453	}
	1454	#ifdef DEBUG
	1455	fprintf(stderr,"%s\n",val);
	1456	#endif
	1457	xmlFree(val);
	1458	}
	1459
	1460	xmlNodePtr cur2=cur1->children;
	1461	while(cur2){
	1462	/**
	1463	* Indentifier
	1464	*/
[9]	1465	if(xmlStrncasecmp(cur2->name,BAD_CAST "Identifier",xmlStrlen(cur2->name))==0){
[1]	1466	xmlChar *val=
	1467	xmlNodeListGetString(doc,cur2->xmlChildrenNode,1);
	1468	if(tmpmaps==NULL){
[9]	1469	tmpmaps=(maps*)calloc(1,MAPS_SIZE);
	1470	if(tmpmaps == NULL){
[34]	1471	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	1472	}
[1]	1473	tmpmaps->name=strdup((char*)val);
	1474	tmpmaps->content=NULL;
	1475	tmpmaps->next=NULL;
	1476	}
	1477	else
	1478	tmpmaps->name=strdup((char*)val);;
	1479	xmlFree(val);
	1480	}
	1481	/**
	1482	* Title, Asbtract
	1483	*/
[9]	1484	if(xmlStrncasecmp(cur2->name,BAD_CAST "Title",xmlStrlen(cur2->name))==0 \|\|
	1485	xmlStrncasecmp(cur2->name,BAD_CAST "Abstract",xmlStrlen(cur2->name))==0){
[1]	1486	xmlChar *val=
	1487	xmlNodeListGetString(doc,cur2->xmlChildrenNode,1);
	1488	if(tmpmaps==NULL){
[9]	1489	tmpmaps=(maps*)calloc(1,MAPS_SIZE);
	1490	if(tmpmaps == NULL){
[34]	1491	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	1492	}
[1]	1493	tmpmaps->name="missingIndetifier";
	1494	tmpmaps->content=createMap((char)cur2->name,(char)val);
	1495	tmpmaps->next=NULL;
	1496	}
	1497	else{
	1498	if(tmpmaps->content!=NULL)
	1499	addToMap(tmpmaps->content,
	1500	(char)cur2->name,(char)val);
	1501	else
	1502	tmpmaps->content=
	1503	createMap((char)cur2->name,(char)val);
	1504	}
	1505	xmlFree(val);
	1506	}
	1507	cur2=cur2->next;
	1508	}
	1509	}
	1510	cur1=cur1->next;
	1511	}
	1512	}
	1513	//xmlFree(cur);
	1514	if(request_output_real_format==NULL)
	1515	request_output_real_format=tmpmaps;
	1516	else
	1517	addMapsToMaps(&request_output_real_format,tmpmaps);
	1518	#ifdef DEBUG
	1519	dumpMaps(tmpmaps);
	1520	#endif
	1521	}
[9]	1522	xmlXPathFreeObject(tmpsptr);
	1523	//xmlFree(tmps);
	1524	tmpsptr=extractFromDoc(doc,"///*[local-name()='RawDataOutput']");
	1525	tmps=tmpsptr->nodesetval;
[1]	1526	#ifdef DEBUG
	1527	fprintf(stderr,"***%d***\n",tmps->nodeNr);
	1528	#endif
	1529	for(int k=0;k<tmps->nodeNr;k++){
	1530	addToMap(request_inputs,"RawDataOutput","");
	1531	xmlNodePtr cur1=tmps->nodeTab[k];
	1532	xmlChar *val;
	1533	/**
	1534	* Get every attribute from a Output node
	1535	* mimeType, encoding, schema, uom, asReference
	1536	*/
	1537	char *outs[4];
	1538	outs[0]="mimeType";
	1539	outs[1]="encoding";
	1540	outs[2]="schema";
	1541	outs[3]="uom";
	1542	for(int l=0;l<4;l++){
	1543	#ifdef DEBUG
	1544	fprintf(stderr,"* %s *\t",outs[l]);
	1545	#endif
	1546	val=xmlGetProp(cur1,BAD_CAST outs[l]);
	1547	if(val!=NULL && strlen((char*)val)>0){
	1548	if(tmpmaps==NULL){
[9]	1549	tmpmaps=(maps*)calloc(1,MAPS_SIZE);
	1550	if(tmpmaps == NULL){
[34]	1551	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	1552	}
[1]	1553	tmpmaps->name="unknownIdentifier";
	1554	tmpmaps->content=createMap(outs[l],(char*)val);
	1555	tmpmaps->next=NULL;
	1556	}
	1557	else
	1558	addToMap(tmpmaps->content,outs[l],(char*)val);
	1559	}
	1560	#ifdef DEBUG
	1561	fprintf(stderr,"%s\n",val);
	1562	#endif
	1563	xmlFree(val);
	1564	}
	1565
	1566	xmlNodePtr cur2=cur1->children;
	1567	while(cur2){
	1568	/**
	1569	* Indentifier
	1570	*/
[9]	1571	if(xmlStrncasecmp(cur2->name,BAD_CAST "Identifier",xmlStrlen(cur2->name))==0){
[1]	1572	val=
	1573	xmlNodeListGetString(doc,cur2->xmlChildrenNode,1);
	1574	if(tmpmaps==NULL){
[9]	1575	tmpmaps=(maps*)calloc(1,MAPS_SIZE);
	1576	if(tmpmaps == NULL){
[34]	1577	return errorException(m, _("Unable to allocate memory."), "InternalError");
[9]	1578	}
[1]	1579	tmpmaps->name=strdup((char*)val);
	1580	tmpmaps->content=NULL;
	1581	tmpmaps->next=NULL;
	1582	}
	1583	else
	1584	tmpmaps->name=strdup((char*)val);;
	1585	xmlFree(val);
	1586	}
	1587	cur2=cur2->next;
	1588	}
	1589	if(request_output_real_format==NULL)
	1590	request_output_real_format=tmpmaps;
	1591	else
	1592	addMapsToMaps(&request_output_real_format,tmpmaps);
	1593	#ifdef DEBUG
	1594	dumpMaps(tmpmaps);
	1595	#endif
	1596	}
[9]	1597	xmlXPathFreeObject(tmpsptr);
	1598	//xmlFree(tmps);
[1]	1599	xmlCleanupParser();
	1600	}
	1601
[9]	1602	//if(CHECK_INET_HANDLE(hInternet))
	1603	InternetCloseHandle(hInternet);
[1]	1604
	1605	#ifdef DEBUG
	1606	fprintf(stderr,"\n%i\n",i);
	1607	dumpMaps(request_input_real_format);
	1608	dumpMaps(request_output_real_format);
[9]	1609	dumpMap(request_inputs);
[1]	1610	#endif
	1611
	1612	/**
	1613	* Ensure that each requested arguments are present in the request
	1614	* DataInputs and ResponseDocument / RawDataOutput
[9]	1615	*/
	1616	char *dfv=addDefaultValues(&request_input_real_format,s1->inputs,m,"inputs");
	1617	if(strcmp(dfv,"")!=0){
	1618	char tmps[1024];
[34]	1619	snprintf(tmps,1024,_("The <%s> argument was not specified in DataInputs but defined as requested in ZOO ServicesProvider configuration file, please correct your query or the ZOO Configuration file."),dfv);
[9]	1620	map* tmpe=createMap("text",tmps);
	1621	addToMap(tmpe,"code","MissingParameterValue");
	1622	printExceptionReportResponse(m,tmpe);
	1623	freeMap(&tmpe);
	1624	free(tmpe);
	1625	freeMaps(&m);
	1626	free(m);
	1627	free(REQUEST);
	1628	freeMaps(&request_input_real_format);
	1629	free(request_input_real_format);
	1630	freeMaps(&request_output_real_format);
	1631	free(request_output_real_format);
	1632	freeMaps(&tmpmaps);
	1633	free(tmpmaps);
	1634	return 1;
	1635	}
[1]	1636	addDefaultValues(&request_output_real_format,s1->outputs,m,"outputs");
	1637
[9]	1638	#ifdef DEBUG
	1639	fprintf(stderr,"REQUEST_INPUTS\n");
	1640	dumpMaps(request_input_real_format);
	1641	fprintf(stderr,"REQUEST_OUTPUTS\n");
	1642	dumpMaps(request_output_real_format);
	1643	#endif
[1]	1644
	1645	maps* curs=getMaps(m,"env");
	1646	if(curs!=NULL){
	1647	map* mapcs=curs->content;
	1648	while(mapcs!=NULLMAP){
	1649	#ifndef WIN32
	1650	setenv(mapcs->name,mapcs->value,1);
	1651	#else
	1652	#ifdef DEBUG
	1653	fprintf(stderr,"[ZOO: setenv (%s=%s)]\n",mapcs->name,mapcs->value);
	1654	#endif
	1655	if(mapcs->value[strlen(mapcs->value)-2]=='\r'){
	1656	#ifdef DEBUG
	1657	fprintf(stderr,"[ZOO: Env var finish with \r]\n");
	1658	#endif
	1659	mapcs->value[strlen(mapcs->value)-1]=0;
	1660	}
	1661	#ifdef DEBUG
	1662	fflush(stderr);
	1663	fprintf(stderr,"setting variable... %s\n",
	1664	#endif
	1665	SetEnvironmentVariable(mapcs->name,mapcs->value)
	1666	#ifdef DEBUG
	1667	? "OK" : "FAILED");
	1668	#else
	1669	;
	1670	#endif
	1671	#ifdef DEBUG
	1672	fflush(stderr);
	1673	#endif
	1674	#endif
	1675	#ifdef DEBUG
	1676	fprintf(stderr,"[ZOO: setenv (%s=%s)]\n",mapcs->name,mapcs->value);
	1677	fflush(stderr);
	1678	#endif
	1679	mapcs=mapcs->next;
	1680	}
	1681	}
	1682
	1683	#ifdef DEBUG
	1684	dumpMap(request_inputs);
	1685	#endif
	1686
	1687	/**
	1688	* Need to check if we need to fork to load a status enabled
	1689	*/
	1690	r_inputs=NULL;
	1691	r_inputs=getMap(request_inputs,"storeExecuteResponse");
	1692	int eres=SERVICE_STARTED;
	1693	int cpid=getpid();
[32]	1694
	1695	maps _tmpMaps=(maps)malloc(MAPS_SIZE);
	1696	_tmpMaps->name=strdup("lenv");
	1697	char tmpBuff[100];
	1698	sprintf(tmpBuff,"%i",cpid);
	1699	_tmpMaps->content=createMap("sid",tmpBuff);
	1700	_tmpMaps->next=NULL;
	1701	addToMap(_tmpMaps->content,"status","0");
	1702	addMapsToMaps(&m,_tmpMaps);
	1703	freeMaps(&_tmpMaps);
	1704	free(_tmpMaps);
	1705
[1]	1706	#ifdef DEBUG
	1707	dumpMap(request_inputs);
	1708	#endif
	1709
[9]	1710	if(r_inputs!=NULL)
	1711	if(strcasecmp(r_inputs->value,"false")==0)
	1712	r_inputs=NULL;
[1]	1713	if(r_inputs==NULLMAP){
[34]	1714	loadServiceAndRun(&m,s1,request_inputs,&request_input_real_format,&request_output_real_format,&eres);
	1715	}
[1]	1716	else{
	1717	pid_t pid;
	1718	#ifdef DEBUG
	1719	fprintf(stderr,"\nPID : %d\n",cpid);
	1720	#endif
[9]	1721
[1]	1722	#ifndef WIN32
[9]	1723	pid = fork ();
[1]	1724	#else
[9]	1725	pid = 0;
[1]	1726	#endif
	1727	if (pid > 0) {
	1728	/**
	1729	* dady :
	1730	* set status to SERVICE_ACCEPTED
	1731	*/
	1732	#ifdef DEBUG
	1733	fprintf(stderr,"father pid continue (origin %d) %d ...\n",cpid,getpid());
	1734	#endif
	1735	eres=SERVICE_ACCEPTED;
	1736	}else if (pid == 0) {
	1737	/**
	1738	* son : have to close the stdout, stdin and stderr to let the parent
	1739	* process answer to http client.
	1740	*/
	1741	r_inputs=getMapFromMaps(m,"main","tmpPath");
[9]	1742	map* r_inputs1=getMap(s1->content,"ServiceProvider");
[32]	1743	char* fbkp=(char)malloc((strlen(r_inputs->value)+strlen(r_inputs1->value)+100)sizeof(char));
[9]	1744	sprintf(fbkp,"%s/%s_%d.xml",r_inputs->value,r_inputs1->value,cpid);
[32]	1745	char* flog=(char)malloc((strlen(r_inputs->value)+strlen(r_inputs1->value)+100)sizeof(char));
[9]	1746	sprintf(flog,"%s/%s_%d_error.log",r_inputs->value,r_inputs1->value,cpid);
[1]	1747	#ifdef DEBUG
	1748	fprintf(stderr,"RUN IN BACKGROUND MODE \n");
	1749	fprintf(stderr,"son pid continue (origin %d) %d ...\n",cpid,getpid());
[9]	1750	fprintf(stderr,"\nFILE TO STORE DATA %s\n",r_inputs->value);
[1]	1751	#endif
[9]	1752	freopen(fbkp , "w+", stdout);
[1]	1753	fclose(stdin);
[9]	1754	freopen(flog,"w+",stderr);
	1755	free(fbkp);
	1756	free(flog);
[1]	1757	/**
	1758	* set status to SERVICE_STARTED and flush stdout to ensure full
	1759	* content was outputed (the file used to store the ResponseDocument).
	1760	* The rewind stdout to restart writing from the bgining of the file,
	1761	* this way the data will be updated at the end of the process run.
	1762	*/
[32]	1763	updateStatus(m);
[9]	1764	printProcessResponse(m,request_inputs,cpid,
[32]	1765	s1,r_inputs1->value,SERVICE_STARTED,
[1]	1766	request_input_real_format,
	1767	request_output_real_format);
	1768	fflush(stdout);
	1769	rewind(stdout);
	1770
[34]	1771	loadServiceAndRun(&m,s1,request_inputs,&request_input_real_format,&request_output_real_format,&eres);
[9]	1772
[1]	1773	} else {
	1774	/**
	1775	* error server don't accept the process need to output a valid
	1776	* error response here !!!
	1777	*/
[34]	1778	eres=-1;
	1779	errorException(m, _("Unable to run the child process properly"), "InternalError");
[1]	1780	}
	1781
	1782	}
	1783
	1784	#ifdef DEBUG
	1785	dumpMaps(request_output_real_format);
[9]	1786	fprintf(stderr,"Function loaded and returned %d\n",eres);
	1787	fflush(stderr);
[1]	1788	#endif
[9]	1789	if(eres!=-1)
	1790	outputResponse(s1,request_input_real_format,
	1791	request_output_real_format,request_inputs,
	1792	cpid,m,eres);
[1]	1793
[32]	1794	if(((int)getpid())!=cpid){
	1795	fclose(stdout);
	1796	fclose(stderr);
	1797	unhandleStatus(m);
	1798	}
	1799
[9]	1800	freeService(&s1);
	1801	free(s1);
[59]	1802	freeMaps(&m);
[9]	1803	free(m);
	1804
	1805	freeMaps(&request_input_real_format);
	1806	free(request_input_real_format);
[25]	1807
[59]	1808	freeMaps(&request_output_real_format);
	1809	free(request_output_real_format);
[9]	1810
	1811	free(REQUEST);
	1812	free(SERVICE_URL);
[1]	1813	#ifdef DEBUG
	1814	fprintf(stderr,"Processed response \n");
	1815	fflush(stdout);
	1816	fflush(stderr);
	1817	#endif
	1818
	1819	return 0;
	1820	}

Note: See TracBrowser for help on using the repository browser.

Open WPS platform

source: trunk/zoo-kernel/zoo_service_loader.c @ 60

Download in other formats:

Download now !

Support ZOO-Project

Search

Context Navigation

Main Navigation

ZOO Sponsors

Knowledge partners

Related links