zoo_service_loader.c @ 11

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

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

Open WPS platform

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

Download in other formats:

Download now !

Support ZOO-Project

Search

Context Navigation

Main Navigation

ZOO Sponsors

Knowledge partners

Related links