zoo_service_loader.c @ 128

Last change on this file since 128 was 127, checked in by djay, 14 years ago
Small fix for accessing Body node.
File size: 49.5 KB

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

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

Open WPS platform

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

Download in other formats:

Download now !

Support ZOO-Project

Search

Context Navigation

Main Navigation

ZOO Sponsors

Knowledge partners

Related links