Changeset 217 for branches/branch-1.2/zoo-kernel/zoo_service_loader.c

Timestamp:

May 31, 2011, 3:30:49 AM (13 years ago)

Author:

djay

Message:

Merge trunk r111:r216 into branch-1.2

Location:

branches/branch-1.2

Files:

• . (modified) (1 prop)
• zoo-kernel/zoo_service_loader.c (modified) (54 diffs)

branches/branch-1.2/zoo-kernel/zoo_service_loader.c

@@ -94 +94 @@
 }
 
-xmlXPathObjectPtr extractFromDoc(xmlDocPtr doc,char* search){
+xmlXPathObjectPtr extractFromDoc(xmlDocPtr doc,const char* search){
   xmlXPathContextPtr xpathCtx;
   xmlXPathObjectPtr xpathObj;
@@ -110 +110 @@
 void sig_handler(int sig){
   char tmp[100];
-  char *ssig;
+  const char *ssig;
   switch(sig){
   case SIGSEGV:
@@ -153 +153 @@
   map* r_inputs=NULL;
 #ifndef WIN32
-  getcwd(ntmp,1024);
+  char* pntmp=getcwd(ntmp,1024);
 #else
   _getcwd(ntmp,1024);
@@ -203 +203 @@
 #endif
       if(strncasecmp(r_inputs->value,"C-FORTRAN",9)==0){
-#ifdef WIN32
-        //Strange return value needed here !
-        return 1;
-#endif
         r_inputs=getMap(request_inputs,"Identifier");
         char fname[1024];
@@ -284 +280 @@
 #endif
       }
+#ifdef WIN32
+      *ioutputs=dupMaps(&request_output_real_format);
+      FreeLibrary(so);
+#else
       dlclose(so);
+#endif
     } else {
       /**
@@ -345 +346 @@
               }
   *myMap=m;
+#ifndef WIN32
   *ioutputs=request_output_real_format;
+#endif
 }
+
+#ifdef WIN32
+/**
+ * createProcess function: create a new process after setting some env variables
+ */
+void createProcess(maps* m,map* request_inputs,service* s1,char* opts,int cpid, maps* inputs,maps* outputs){
+  STARTUPINFO si;
+  PROCESS_INFORMATION pi;
+  ZeroMemory( &si, sizeof(si) );
+  si.cb = sizeof(si);
+  ZeroMemory( &pi, sizeof(pi) );
+  char *tmp=(char *)malloc((1024+cgiContentLength)*sizeof(char));
+  char *tmpq=(char *)malloc((1024+cgiContentLength)*sizeof(char));
+  map *req=getMap(request_inputs,"request");
+  map *id=getMap(request_inputs,"identifier");
+  map *di=getMap(request_inputs,"DataInputs");
+
+  char *dataInputsKVP=getMapsAsKVP(inputs,cgiContentLength,0);
+  char *dataOutputsKVP=getMapsAsKVP(outputs,cgiContentLength,1);
+  fprintf(stderr,"DATAINPUTSKVP %s\n",dataInputsKVP);
+  fprintf(stderr,"DATAOUTPUTSKVP %s\n",dataOutputsKVP);
+  map *sid=getMapFromMaps(m,"lenv","sid");
+  map* r_inputs=getMapFromMaps(m,"main","tmpPath");
+  map* r_inputs1=getMap(s1->content,"ServiceProvider");
+  map* r_inputs2=getMap(s1->content,"ResponseDocument");
+  if(r_inputs2==NULL)
+    r_inputs2=getMap(s1->content,"RawDataOutput");
+  map *tmpPath=getMapFromMaps(m,"lenv","cwd");
+
+  if(r_inputs2!=NULL){
+    sprintf(tmp,"\"request=%s&service=WPS&version=1.0.0&Identifier=%s&DataInputs=%s&%s=%s&cgiSid=%s\"",req->value,id->value,dataInputsKVP,r_inputs2->name,r_inputs2->value,sid->value);
+        sprintf(tmpq,"request=%s&service=WPS&version=1.0.0&Identifier=%s&DataInputs=%s&%s=%s",req->value,id->value,dataInputsKVP,r_inputs2->name,dataOutputsKVP);
+  }
+  else{
+    sprintf(tmp,"\"request=%s&service=WPS&version=1.0.0&Identifier=%s&DataInputs=%s&cgiSid=%s\"",req->value,id->value,dataInputsKVP,sid->value);
+    sprintf(tmpq,"request=%s&service=WPS&version=1.0.0&Identifier=%s&DataInputs=%s",req->value,id->value,dataInputsKVP,sid->value);
+  }
+
+  char *tmp1=strdup(tmp);
+  sprintf(tmp,"zoo_loader.cgi %s \"%s\"",tmp1,sid->value);
+
+  free(dataInputsKVP);
+  free(dataOutputsKVP);
+  fprintf(stderr,"REQUEST IS : %s \n",tmp);
+  SetEnvironmentVariable("CGISID",TEXT(sid->value));
+  SetEnvironmentVariable("QUERY_STRING",TEXT(tmpq));
+  char clen[1000];
+  sprintf(clen,"%d",strlen(tmpq));
+  SetEnvironmentVariable("CONTENT_LENGTH",TEXT(clen));
+
+  if( !CreateProcess( NULL,             // No module name (use command line)
+                      TEXT(tmp),        // Command line
+                      NULL,             // Process handle not inheritable
+                      NULL,             // Thread handle not inheritable
+                      FALSE,            // Set handle inheritance to FALSE
+                      CREATE_NO_WINDOW, // Apache won't wait until the end
+                      NULL,             // Use parent's environment block
+                      NULL,             // Use parent's starting directory 
+                      &si,              // Pointer to STARTUPINFO struct
+                      &pi )             // Pointer to PROCESS_INFORMATION struct
+      ) 
+    { 
+      fprintf( stderr, "CreateProcess failed (%d).\n", GetLastError() );
+      return ;
+    }else{
+    fprintf( stderr, "CreateProcess successfull (%d).\n\n\n\n", GetLastError() );
+  }
+  CloseHandle( pi.hProcess );
+  CloseHandle( pi.hThread );
+  fprintf(stderr,"CreateProcess finished !\n");
+}
+#endif
 
 int runRequest(map* request_inputs)
@@ -360 +435 @@
 #endif
 
-  map* r_inputs=NULL,*tmps=NULL;
+  map* r_inputs=NULL;
   maps* m=NULL;
-  int argc=count(request_inputs);
 
   char* REQUEST=NULL;
@@ -374 +448 @@
   char ntmp[1024];
 #ifndef WIN32
-  getcwd(ntmp,1024);
+  char *pntmp=getcwd(ntmp,1024);
 #else
   _getcwd(ntmp,1024);
@@ -470 +544 @@
   }
 
-  map* outputs=NULL;
   maps* request_output_real_format=NULL;
   map* tmpm=getMapFromMaps(m,"main","serverAddress");
@@ -478 +551 @@
     SERVICE_URL=strdup(DEFAULT_SERVICE_URL);
 
-  service* s[100];
   service* s1;
   int scount=0;
@@ -497 +569 @@
 
   if(strncasecmp(REQUEST,"GetCapabilities",15)==0){
-    int i=0;
     struct dirent *dp;
 #ifdef DEBUG
@@ -510 +581 @@
     r_inputs=getMap(request_inputs,"ServiceProvider");
     xmlNodePtr n;
-    //dumpMap(request_inputs);
     if(r_inputs!=NULL)
       n = printGetCapabilitiesHeader(doc,r_inputs->value,m);
@@ -516 +586 @@
       n = printGetCapabilitiesHeader(doc,"",m);
     /**
-     * Strange, here we need to close stdout to ensure that no uneeded 
-     * char will be printed (parser issue ?)
+     * Here we need to close stdout to ensure that not supported chars 
+     * has been found in the zcfg and then printed on stdout
      */
     int saved_stdout = dup(fileno(stdout));
@@ -595 +665 @@
       char buff[256];
       char buff1[1024];
-      int i=0;
-      int j=0;
-      int end=-1;
       int saved_stdout = dup(fileno(stdout));
       dup2(fileno(stderr),fileno(stdout));
@@ -611 +678 @@
             memset(buff1,0,1024);
             snprintf(buff1,1024,"%s/%s",conf_dir,dp->d_name);
-            //s1=(service*)malloc(sizeof(service*));
             s1=(service*)calloc(1,SERVICE_SIZE);
             if(s1 == NULL){
@@ -640 +706 @@
       free(SERVICE_URL);
       fflush(stdout);
-      //xmlFree(n);
 #ifndef LINUX_FREE_ISSUE
       if(s1)
@@ -654 +719 @@
 #endif  
         closedir(dirp);
-        free(s);
         return 0;
       }
@@ -682 +746 @@
 #endif
   int saved_stdout = dup(fileno(stdout));
-  dup2(fileno(stderr),fileno(stdout));
+    dup2(fileno(stderr),fileno(stdout));
   t=getServiceFromFile(tmps1,&s1);
   fflush(stdout);
   dup2(saved_stdout,fileno(stdout));
   if(t<0){
-    char tmpMsg[2048+strlen(r_inputs->value)];
+    char *tmpMsg=(char*)malloc(2048+strlen(r_inputs->value));
+    
     sprintf(tmpMsg,_("The value for <indetifier> seems to be wrong (%s). Please, ensure that the process exist using the GetCapabilities request."),r_inputs->value);
     errorException(m, tmpMsg, "InvalidParameterValue");
+    free(tmpMsg);
     freeService(&s1);
     free(s1);
@@ -698 +764 @@
     return 0;
   }
-  close(saved_stdout);
+  //close(saved_stdout);
 
 #ifdef DEBUG
   dumpService(s1);
 #endif
-  map* inputs=NULL;
-  elements* c_inputs=s1->inputs;
   int j;
   
@@ -747 +811 @@
       fprintf(stderr,"OUTPUT Parsing start now ... \n");
 #endif
-      char current_output_as_string[10240];
       char cursor_output[10240];
       char *cotmp=strdup(r_inputs->value);
@@ -753 +816 @@
       free(cotmp);
       j=0;
-      map* request_kvp_outputs=NULL;
         
       /**
@@ -834 +896 @@
         fflush(stderr);
 #endif
-        //tmp_output=tmp_output->next;
         free(tmp);
       }
@@ -848 +909 @@
     fprintf(stderr,"DATA INPUTS [%s]\n",r_inputs->value);
 #endif
-    char current_input_as_string[40960];
     char cursor_input[40960];
     if(r_inputs!=NULL)
@@ -864 +924 @@
     }
     j=0;
-    map* request_kvp_inputs=NULL;
   
     /**
@@ -905 +964 @@
         char tmpn[256];
         memset(tmpn,0,256);
-        strncpy(tmpn,tmpc,(strlen(tmpc)-strlen(tmpv))*sizeof(char));
-        tmpn[strlen(tmpc)-strlen(tmpv)]=0;
-        int cnt=0;
+        if(tmpv!=NULL){
+          strncpy(tmpn,tmpc,(strlen(tmpc)-strlen(tmpv))*sizeof(char));
+          tmpn[strlen(tmpc)-strlen(tmpv)]=0;
+        }
+        else{
+          strncpy(tmpn,tmpc,strlen(tmpc)*sizeof(char));
+          tmpn[strlen(tmpc)]=0;
+        }
 #ifdef DEBUG
         fprintf(stderr,"***\n*** %s = %s ***\n",tmpn,tmpv+1);
@@ -917 +981 @@
           }
           tmpmaps->name=strdup(tmpn);
-          tmpmaps->content=createMap("value",tmpv+1);
+          if(tmpv!=NULL)
+            tmpmaps->content=createMap("value",tmpv+1);
+          else
+            tmpmaps->content=createMap("value","Reference");
           tmpmaps->next=NULL;
         }
@@ -931 +998 @@
           char tmpn1[1024];
           memset(tmpn1,0,1024);
-          strncpy(tmpn1,tmpc,strlen(tmpc)-strlen(tmpv1));
-          tmpn1[strlen(tmpc)-strlen(tmpv1)]=0;
+          if(tmpv1!=NULL){
+            strncpy(tmpn1,tmpc,strlen(tmpc)-strlen(tmpv1));
+            tmpn1[strlen(tmpc)-strlen(tmpv1)]=0;
+            addToMap(tmpmaps->content,tmpn1,tmpv1+1);
+          }
+          else{
+            strncpy(tmpn1,tmpc,strlen(tmpc));
+            tmpn1[strlen(tmpc)]=0;
+            map* lmap=getLastMap(tmpmaps->content);
+            char *tmpValue=(char*)calloc((strlen(lmap->value)+strlen(tmpc)+1),sizeof(char));
+            sprintf(tmpValue,"%s@%s",lmap->value,tmpc);
+            free(lmap->value);
+            lmap->value=strdup(tmpValue);
+            free(tmpValue);
+            dumpMap(tmpmaps->content);
+            tmpc=strtok(NULL,"@");
+            continue;
+          }
 #ifdef DEBUG
           fprintf(stderr,"*** NAME NON URL-ENCODED \n***%s***\n",tmpn1);
@@ -939 +1022 @@
           if(strcmp(tmpn1,"xlink:href")!=0)
             addToMap(tmpmaps->content,tmpn1,tmpv1+1);
-          else{
-#ifdef DEBUG
-            fprintf(stderr,"REQUIRE TO DOWNLOAD A FILE FROM A SERVER : url(%s)\n",tmpv1+1);
+          else
+            if(tmpv1!=NULL){
+              if(strncasecmp(tmpv1+1,"http://",7)!=0 &&
+                 strncasecmp(tmpv1+1,"ftp://",6)!=0){
+                char emsg[1024];
+                sprintf(emsg,_("Unable to find a valid protocol to download the remote file %s"),tmpv1+1);
+                errorException(m,emsg,"InternalError");
+                freeMaps(&m);
+                free(m);
+                free(REQUEST);
+                free(SERVICE_URL);
+                InternetCloseHandle(hInternet);
+                freeService(&s1);
+                free(s1);
+                return 0;
+              }
+#ifdef DEBUG
+              fprintf(stderr,"REQUIRE TO DOWNLOAD A FILE FROM A SERVER : url(%s)\n",tmpv1+1);
 #endif
 #ifndef WIN32
-            if(CHECK_INET_HANDLE(hInternet))
-#endif
-              {
-                res=InternetOpenUrl(hInternet,tmpv1+1,NULL,0,
-                                    INTERNET_FLAG_NO_CACHE_WRITE,0);
-#ifdef DEBUG
-                fprintf(stderr,"(%s) content-length : %d,,res.nDataAlloc %d \n",
-                        tmpv1+1,res.nDataAlloc,res.nDataLen);
-#endif
-                char* tmpContent=(char*)calloc((res.nDataLen+1),sizeof(char));
-                if(tmpContent == NULL){
-                  return errorException(m, _("Unable to allocate memory."), "InternalError");
+              if(CHECK_INET_HANDLE(hInternet))
+#endif
+                {
+                  res=InternetOpenUrl(hInternet,tmpv1+1,NULL,0,
+                                      INTERNET_FLAG_NO_CACHE_WRITE,0);
+#ifdef DEBUG
+                  fprintf(stderr,"(%s) content-length : %d,,res.nDataAlloc %d \n",
+                          tmpv1+1,res.nDataAlloc,res.nDataLen);
+#endif
+                  char* tmpContent=(char*)calloc((res.nDataLen+1),sizeof(char));
+                  if(tmpContent == NULL){
+                    return errorException(m, _("Unable to allocate memory."), "InternalError");
+                  }
+                  size_t dwRead;
+                  InternetReadFile(res, (LPVOID)tmpContent,res.nDataLen, &dwRead);
+                  map* tmpMap=getMap(tmpmaps->content,"value");
+                  if(tmpMap!=NULL){
+                    free(tmpMap->value);
+                    tmpMap->value=(char*)malloc((res.nDataLen+1)*sizeof(char));
+                    memmove(tmpMap->value,tmpContent,(res.nDataLen)*sizeof(char));
+                    tmpMap->value[res.nDataLen]=0;
+                    if(strlen(tmpContent)!=res.nDataLen){
+                      char tmp[256];
+                      sprintf(tmp,"%d",res.nDataLen*sizeof(char));
+                      addToMap(tmpmaps->content,"size",tmp);
+                    }
+                  }
+                  free(tmpContent);
                 }
-                size_t dwRead;
-                InternetReadFile(res, (LPVOID)tmpContent,res.nDataLen, &dwRead);
-                map* tmpMap=getMap(tmpmaps->content,"value");
-                if(tmpMap!=NULL){
-                  free(tmpMap->value);
-                  tmpMap->value=(char*)malloc((res.nDataLen+1)*sizeof(char));
-                  memmove(tmpMap->value,tmpContent,(res.nDataLen)*sizeof(char));
-                  tmpMap->value[res.nDataLen]=0;
-                  if(strlen(tmpContent)!=res.nDataLen){
-                    char tmp[256];
-                    sprintf(tmp,"%d",res.nDataLen*sizeof(char));
-                    addToMap(tmpmaps->content,"size",tmp);
-                  }
-                }
-                free(tmpContent);
-              }
-            addToMap(tmpmaps->content,tmpn1,tmpv1+1);
-            addToMap(tmpmaps->content,"Reference",tmpv1+1);
-          }
+              char *tmpx=url_encode(tmpv1+1);
+              addToMap(tmpmaps->content,tmpn1,tmpx);
+              free(tmpx);
+              addToMap(tmpmaps->content,"Reference",tmpv1+1);
+              dumpMap(tmpmaps->content);
+            }
           tmpc=strtok(NULL,"@");
         }
@@ -1010 +1111 @@
     fflush(stderr);
 #endif
-    xmlNodePtr cur = xmlDocGetRootElement(doc);
     /**
      * Parse every Input in DataInputs node.
      */
-    maps* tempMaps=NULL;
     xmlXPathObjectPtr tmpsptr=extractFromDoc(doc,"/*/*/*[local-name()='Input']");
     xmlNodeSet* tmps=tmpsptr->nodesetval;
@@ -1064 +1163 @@
                 return errorException(m, _("Unable to allocate memory."), "InternalError");
               }
-              tmpmaps->name="missingIndetifier";
+              tmpmaps->name=strdup("missingIndetifier");
               tmpmaps->content=createMap((char*)cur2->name,(char*)val);
               tmpmaps->next=NULL;
@@ -1093 +1192 @@
             fprintf(stderr,"REFERENCE\n");
 #endif
-            map* referenceMap=NULL;
-            char *refs[5];
+            const char *refs[5];
             refs[0]="mimeType";
             refs[1]="encoding";
@@ -1100 +1198 @@
             refs[3]="method";
             refs[4]="href";
-            char*url;
             for(int l=0;l<5;l++){
 #ifdef DEBUG
@@ -1141 +1238 @@
             hInternet.header=NULL;
             while(cur3){
+              while(cur3!=NULL && cur3->type!=XML_ELEMENT_NODE)
+                cur2=cur3->next;
               if(xmlStrcasecmp(cur3->name,BAD_CAST "Header")==0 ){
-                xmlNodePtr cur4=cur3;
-                char *tmp=new char[cgiContentLength];
-                char *ha[2];
+                const char *ha[2];
                 ha[0]="key";
                 ha[1]="value";
@@ -1170 +1267 @@
                 }
                 hInternet.header=curl_slist_append(hInternet.header, has);
-                //free(has);
+                free(has);
               }
               else{
@@ -1184 +1281 @@
                   xmlNodePtr cur4=cur3->children;
                   while(cur4!=NULL){
+                    while(cur4->type!=XML_ELEMENT_NODE)
+                      cur4=cur4->next;
                     xmlDocPtr bdoc = xmlNewDoc(BAD_CAST "1.0");
                     bdoc->encoding = xmlCharStrdup ("UTF-8");
@@ -1302 +1401 @@
                  * dataType , uom
                  */
-                char *lits[2];
-                lits[0]="dataType";
-                lits[1]="uom";
+                char *list[2];
+                list[0]=strdup("dataType");
+                list[1]=strdup("uom");
                 for(int l=0;l<2;l++){
 #ifdef DEBUG
-                  fprintf(stderr,"*** LiteralData %s ***",lits[l]);
-#endif
-                  xmlChar *val=xmlGetProp(cur4,BAD_CAST lits[l]);
+                  fprintf(stderr,"*** LiteralData %s ***",list[l]);
+#endif
+                  xmlChar *val=xmlGetProp(cur4,BAD_CAST list[l]);
                   if(val!=NULL && strlen((char*)val)>0){
                     if(tmpmaps->content!=NULL)
-                      addToMap(tmpmaps->content,lits[l],(char*)val);
+                      addToMap(tmpmaps->content,list[l],(char*)val);
                     else
-                      tmpmaps->content=createMap(lits[l],(char*)val);
+                      tmpmaps->content=createMap(list[l],(char*)val);
                   }
 #ifdef DEBUG
@@ -1320 +1419 @@
 #endif
                   xmlFree(val);
+                  free(list[l]);
                 }
               }
@@ -1327 +1427 @@
                  * mimeType, encoding, schema
                  */
-                char *coms[3];
+                const char *coms[3];
                 coms[0]="mimeType";
                 coms[1]="encoding";
@@ -1368 +1468 @@
                 char *res=NULL;
                 char *curs=tmpv->value;
-                int i=0;
                 for(int i=0;i<=strlen(tmpv->value)/64;i++) {
                   if(res==NULL)
@@ -1421 +1520 @@
 #endif
     xmlXPathFreeObject(tmpsptr);
-    //xmlFree(tmps);
     
     tmpsptr=extractFromDoc(doc,"/*/*/*[local-name()='ResponseDocument']");
@@ -1439 +1537 @@
       else
         addToMap(request_inputs,"ResponseDocument","");
-      request_output_real_format;
       maps *tmpmaps=NULL;
       xmlNodePtr cur=tmps->nodeTab[k];
@@ -1451 +1548 @@
             return errorException(m, _("Unable to allocate memory."), "InternalError");
           }
-          tmpmaps->name="unknownIdentifier";
+          tmpmaps->name=strdup("unknownIdentifier");
           tmpmaps->next=NULL;
         }
@@ -1458 +1555 @@
          * storeExecuteResponse, lineage, status
          */
-        char *ress[3];
+        const char *ress[3];
         ress[0]="storeExecuteResponse";
         ress[1]="lineage";
@@ -1487 +1584 @@
              * mimeType, encoding, schema, uom, asReference
              */
-            char *outs[5];
+            const char *outs[5];
             outs[0]="mimeType";
             outs[1]="encoding";
@@ -1543 +1640 @@
                     return errorException(m, _("Unable to allocate memory."), "InternalError");
                   }
-                  tmpmaps->name="missingIndetifier";
+                  tmpmaps->name=strdup("missingIndetifier");
                   tmpmaps->content=createMap((char*)cur2->name,(char*)val);
                   tmpmaps->next=NULL;
@@ -1563 +1660 @@
         }
       }
-      //xmlFree(cur);
       if(request_output_real_format==NULL)
         request_output_real_format=dupMaps(&tmpmaps);
@@ -1576 +1672 @@
 
     xmlXPathFreeObject(tmpsptr);
-    //xmlFree(tmps);
     xmlCleanupParser();
   }
@@ -1710 +1805 @@
   _tmpMaps->next=NULL;
   addToMap(_tmpMaps->content,"status","0");
+  addToMap(_tmpMaps->content,"cwd",ntmp);
   if(cgiCookie!=NULL && strlen(cgiCookie)>0){
     addToMap(_tmpMaps->content,"sessid",strstr(cgiCookie,"=")+1);
@@ -1735 +1831 @@
   dumpMap(request_inputs);
 #endif
-
+#ifdef WIN32
+  char *cgiSidL=NULL;
+  if(getenv("CGISID")!=NULL)
+        addToMap(request_inputs,"cgiSid",getenv("CGISID"));
+  map* test1=getMap(request_inputs,"cgiSid");
+  if(test1!=NULL){
+    cgiSid=test1->value;
+  }
+  if(cgiSid!=NULL){
+    addToMap(request_inputs,"storeExecuteResponse","true");
+    addToMap(request_inputs,"status","true");
+    status=getMap(request_inputs,"status");
+    dumpMap(request_inputs);
+    fprintf(stderr,"cgiSID : %s",cgiSid);
+  }
+#endif
   if(status!=NULL)
     if(strcasecmp(status->value,"false")==0)
@@ -1751 +1862 @@
     pid = fork ();
 #else
-    pid = 0;
+    if(cgiSid==NULL){
+      addToMap(request_inputs,"cgSid",cgiSid);
+      createProcess(m,request_inputs,s1,NULL,cpid,request_input_real_format,request_output_real_format);
+      pid = cpid;
+    }else{
+      pid=0;
+      cpid=atoi(cgiSid);
+    }
+    fflush(stderr);
 #endif
     if (pid > 0) {
@@ -1778 +1897 @@
       fprintf(stderr,"\nFILE TO STORE DATA %s\n",r_inputs->value);
 #endif
+      freopen(flog,"w+",stderr);
       freopen(fbkp , "w+", stdout);
       fclose(stdin);
-      freopen(flog,"w+",stderr);
       free(fbkp);
       free(flog);
@@ -1791 +1910 @@
       updateStatus(m);
       printProcessResponse(m,request_inputs,cpid,
-                            s1,r_inputs1->value,SERVICE_STARTED,
-                            request_input_real_format,
-                            request_output_real_format);
+                           s1,r_inputs1->value,SERVICE_STARTED,
+                           request_input_real_format,
+                           request_output_real_format);
+#ifndef WIN32
       fflush(stdout);
       rewind(stdout);
+#endif
 
       loadServiceAndRun(&m,s1,request_inputs,&request_input_real_format,&request_output_real_format,&eres);
@@ -1811 +1932 @@
 #ifdef DEBUG
   dumpMaps(request_output_real_format);
-  fprintf(stderr,"Function loaded and returned %d\n",eres);
+  fprintf(stderr,"Function loaded and returned %d\n",*eres);
   fflush(stderr);
 #endif
@@ -1818 +1939 @@
                    request_output_real_format,request_inputs,
                    cpid,m,eres);
+  fflush(stdout);
   /**
    * Ensure that if error occurs when freeing memory, no signal will return