29 files changed, 986 insertions, 742 deletions
diff --git a/examples/csoap/echoattachments-client.c b/examples/csoap/echoattachments-client.c
index 352a73c..1550c93 100755
--- a/examples/csoap/echoattachments-client.c
+++ b/examples/csoap/echoattachments-client.c
@@ -1,142 +1,157 @@
-/******************************************************************
- * $Id: echoattachments-client.c,v 1.3 2004/10/15 15:10:14 snowdrop Exp $
- *
- * CSOAP Project:  CSOAP examples project 
- * Copyright (C) 2003-2004  Ferhat Ayaz
- *
- * This program is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program; if not, write to the Free Software
- * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA02111-1307USA
- *
- * Email: ferhatayaz@yahoo.com
- ******************************************************************/
-
-#include <libcsoap/soap-client.h>
-
-
-/*
-static const char *url = "http://csoap.sourceforge.net/cgi-bin/csoapserver";
-*/
-static const char *url = "http://localhost:10000/echoattachment";
-static const char *urn = "";
-static const char *method = "echo";
-
-
-void compareFiles(const char* received, const char *sent)
-{
-  FILE *f1, *f2;
-  char c1, c2;
-  long s1,s2;
-
-  printf("Opening received file to compare: '%s'\n", received);
-  f1 = fopen(received, "r");
-  if (!f1) {
-    fprintf(stderr, "Can not open '%s'\n", received);
-    return;
-  }
-
-  printf("Opening sent file to compare: '%s'\n", sent);
-  f2 = fopen(sent, "r");
-  if (!f2) {
-    fprintf(stderr, "Can not open '%s'\n", sent);
-    fclose(f1);
-    return;
-  }
-
-  fseek(f1, 0, SEEK_END);
-  fseek(f2, 0, SEEK_END);
-
-  s1 = ftell(f1);
-  s2 = ftell(f2);
-
-  fseek(f1, 0, SEEK_SET);
-  fseek(f2, 0, SEEK_SET);
-
-  if (s1 > s2) {
-
-      printf("ERROR: files are not equal! Received file is bigger\n");
-      fclose(f1); fclose(f2);
-      return;
-
-  } else if (s2 > s1) {
-
-      printf("ERROR: files are not equal! Sent file is bigger\n");
-      fclose(f1); fclose(f2);
-      return;
-  }
-
-  while (feof(f1)) {
-    
-    c1= fgetc(f1);
-    c2= fgetc(f2);
-    if (c1 != c2){
-      printf("ERROR: files are not equal! Byte compare failed\n");
-      fclose(f1); fclose(f2);
-      break;
-    }
-  }
-  
-  printf("OK: files are equal!\n");
-  fclose(f1); fclose(f2);
-  
-}
-
-int main(int argc, char *argv[])
-{
-  SoapCtx *ctx, *ctx2;
-  char href[MAX_HREF_SIZE];
-  xmlNodePtr fault;
-
-  if (argc < 2) {
-    fprintf(stderr, "usage: %s <filename> [url]\n", argv[0]);
-    exit(1);
-  }
-
-  log_set_level(HLOG_VERBOSE);
-  if (!soap_client_init_args(argc, argv)) {
-	  return 1;
-  }
-
-  ctx = soap_client_ctx_new(urn, method);
-  if (soap_ctx_add_file(ctx, argv[1], "application/octet-stream", href) != H_OK) {
-    fprintf(stderr, "Error while adding '%s'\n", argv[1]);
-    soap_ctx_free(ctx);
-    exit(1);
-  }
-  soap_env_add_attachment(ctx->env,"source", href);
-
-  printf("sending request ...\n");  
-  if (argc > 2)
-    ctx2 = soap_client_invoke(ctx, argv[2], "");
-  else
-    ctx2 = soap_client_invoke(ctx, url, "");
-
-  fault = soap_env_get_fault(ctx2->env);
-  if (fault) {
-    soap_xml_doc_print(ctx2->env->root->doc);
-  } else if (ctx2->attachments) {
-    compareFiles(ctx2->attachments->parts->filename, argv[1]);
-  } else {
-    printf("No attachments!");
-    soap_xml_doc_print(ctx2->env->root->doc);
-  }
-
-  soap_ctx_free(ctx2);
-  soap_ctx_free(ctx);
-
-  return 0;
-}
-
-
-
-
+/******************************************************************
+ * $Id: echoattachments-client.c,v 1.4 2004/10/28 10:30:41 snowdrop Exp $
+ *
+ * CSOAP Project:  CSOAP examples project 
+ * Copyright (C) 2003-2004  Ferhat Ayaz
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA02111-1307USA
+ *
+ * Email: ferhatayaz@yahoo.com
+ ******************************************************************/
+
+#include <libcsoap/soap-client.h>
+
+
+
+
+static const char *urn = "urn:examples";
+static const char *url = "http://localhost:10000/echoattachment";
+static const char *method = "echo";
+
+
+void compareFiles(const char* received, const char *sent)
+{
+  FILE *f1, *f2;
+  char c1, c2;
+  long s1,s2;
+
+  printf("Opening received file to compare: '%s'\n", received);
+  f1 = fopen(received, "r");
+  if (!f1) {
+    fprintf(stderr, "Can not open '%s'\n", received);
+    return;
+  }
+
+  printf("Opening sent file to compare: '%s'\n", sent);
+  f2 = fopen(sent, "r");
+  if (!f2) {
+    fprintf(stderr, "Can not open '%s'\n", sent);
+    fclose(f1);
+    return;
+  }
+
+  fseek(f1, 0, SEEK_END);
+  fseek(f2, 0, SEEK_END);
+
+  s1 = ftell(f1);
+  s2 = ftell(f2);
+
+  fseek(f1, 0, SEEK_SET);
+  fseek(f2, 0, SEEK_SET);
+
+  if (s1 > s2) {
+
+      printf("ERROR: files are not equal! Received file is bigger\n");
+      fclose(f1); fclose(f2);
+      return;
+
+  } else if (s2 > s1) {
+
+      printf("ERROR: files are not equal! Sent file is bigger\n");
+      fclose(f1); fclose(f2);
+      return;
+  }
+
+  while (feof(f1)) {
+    
+    c1= fgetc(f1);
+    c2= fgetc(f2);
+    if (c1 != c2){
+      printf("ERROR: files are not equal! Byte compare failed\n");
+      fclose(f1); fclose(f2);
+      break;
+    }
+  }
+  
+  printf("OK: files are equal!\n");
+  fclose(f1); fclose(f2);
+  
+}
+
+int main(int argc, char *argv[])
+{
+  SoapCtx *ctx, *ctx2;
+  char href[MAX_HREF_SIZE];
+  xmlNodePtr fault;
+  herror_t err;
+
+  if (argc < 2) {
+    fprintf(stderr, "usage: %s <filename> [url]\n", argv[0]);
+    exit(1);
+  }
+
+  log_set_level(HLOG_VERBOSE);
+  err = soap_client_init_args(argc, argv);
+  if (err != H_OK) {
+	log_error4("[%d] %s():%s ", herror_code(err), herror_func(err), herror_message(err));
+	herror_release(err);
+	return 1;
+  }
+
+  err = soap_client_ctx_new(urn, method, &ctx);
+  if (err != H_OK) {
+	log_error4("[%d] %s():%s ", herror_code(err), herror_func(err), herror_message(err));
+	herror_release(err);
+	return 1;
+  }
+   if (soap_ctx_add_file(ctx, argv[1], "application/octet-stream", href) != H_OK) {
+    fprintf(stderr, "Error while adding '%s'\n", argv[1]);
+    soap_ctx_free(ctx);
+    exit(1);
+  }
+  soap_env_add_attachment(ctx->env,"source", href);
+
+  printf("sending request ...\n");  
+  if (argc > 2)
+    err = soap_client_invoke(ctx, &ctx2, argv[2], "");
+  else
+    err = soap_client_invoke(ctx, &ctx2, url, "");
+
+  if (err != H_OK) {
+	log_error4("%s():%s [%d]", herror_func(err), herror_message(err), herror_code(err));
+	herror_release(err);
+	return 1;
+  }
+
+  fault = soap_env_get_fault(ctx2->env);
+  if (fault) {
+    soap_xml_doc_print(ctx2->env->root->doc);
+  } else if (ctx2->attachments) {
+    compareFiles(ctx2->attachments->parts->filename, argv[1]);
+  } else {
+    printf("No attachments!");
+    soap_xml_doc_print(ctx2->env->root->doc);
+  }
+
+  soap_ctx_free(ctx2);
+  soap_ctx_free(ctx);
+
+  return 0;
+}
+
+
+
+
+
diff --git a/examples/csoap/echoattachments-server.c b/examples/csoap/echoattachments-server.c
index 701d6a6..5aeeb76 100755
--- a/examples/csoap/echoattachments-server.c
+++ b/examples/csoap/echoattachments-server.c
@@ -1,5 +1,5 @@
 /******************************************************************
- * $Id: echoattachments-server.c,v 1.2 2004/10/15 15:10:15 snowdrop Exp $
+ * $Id: echoattachments-server.c,v 1.3 2004/10/28 10:30:42 snowdrop Exp $
  *
  * CSOAP Project:  CSOAP examples project 
  * Copyright (C) 2003-2004  Ferhat Ayaz
@@ -24,21 +24,26 @@
 #include <libcsoap/soap-server.h>
 
 
-static const char *url = "/echoattachment";
-static const char *urn = "";
+static const char *url = "/echoattachments";
+static const char *urn = "urn:examples";
 static const char *method = "echo";
 
 
-
+/*
 SoapCtx* echo_attachments(SoapCtx *req)
 {
-
+  herror_t err;
   SoapEnv *env;
   SoapCtx*  ctx;
   part_t *part;
   char href[MAX_HREF_SIZE];
 
-  env = soap_env_new_with_response(req->env);
+  err = soap_env_new_with_response(req->env, &env);
+  if (err != H_OK) {
+	  herror_release(err);
+	  return NULL;
+  }
+
   ctx = soap_ctx_new(env);
 
   if (req->attachments) {
@@ -54,16 +59,45 @@ SoapCtx* echo_attachments(SoapCtx *req)
   return ctx;
 }
 
+*/
 
-int main(int argc, char *argv[])
+herror_t echo_attachments(SoapCtx *req, SoapCtx* res)
 {
+  herror_t err;
+
+  part_t *part;
+  char href[MAX_HREF_SIZE];
+
+  err = soap_env_new_with_response(req->env, &res->env);
+  if (err != H_OK) {
+	  return err;
+  }
 
+  if (req->attachments) 
+  {
+	for (part = req->attachments->parts; part != NULL; part = part->next) 
+	{
+      soap_ctx_add_file(res, part->filename, part->content_type, href);
+      soap_env_add_attachment(res->env, "echoFile", href);
+    }
+  }
+    
+  return H_OK;
+}
+
+
+int main(int argc, char *argv[])
+{
+	herror_t err;
   SoapRouter *router;
   
   log_set_level(HLOG_VERBOSE);
 
-  if (!soap_server_init_args(argc, argv)) {
-    return 1;
+  err = soap_server_init_args(argc, argv);
+  if (err != H_OK) {
+	log_error4("%s():%s [%d]", herror_func(err), herror_message(err), herror_code(err));
+	herror_release(err);
+	return 1;
   }
   
   router = soap_router_new();
diff --git a/examples/csoap/simpleclient.c b/examples/csoap/simpleclient.c
index 3ac1588..7b80193 100644
--- a/examples/csoap/simpleclient.c
+++ b/examples/csoap/simpleclient.c
@@ -1,8 +1,8 @@
 /******************************************************************
- * $Id: simpleclient.c,v 1.5 2004/10/15 13:42:57 snowdrop Exp $
+ * $Id: simpleclient.c,v 1.6 2004/10/28 10:30:42 snowdrop Exp $
  *
  * CSOAP Project:  CSOAP examples project 
- * Copyright (C) 2003  Ferhat Ayaz
+ * Copyright (C) 2003-2004  Ferhat Ayaz
  *
  * This program is free software; you can redistribute it and/or modify
  * it under the terms of the GNU General Public License as published by
@@ -18,67 +18,54 @@
  * along with this program; if not, write to the Free Software
  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA02111-1307USA
  *
- * Email: ayaz@jprogrammer.net
+ * Email: ferhatayaz@yahoo.com
  ******************************************************************/
 
 #include <libcsoap/soap-client.h>
 
 
-/*
-static const char *url = "http://csoap.sourceforge.net/cgi-bin/csoapserver";
-*/
-static const char *url = "http://localhost:3031/csoapserver";
+static const char *url = "http://localhost:10000/csoapserver";
 static const char *urn = "urn:examples";
 static const char *method = "sayHello";
 
 
 int main(int argc, char *argv[])
 {
-  SoapCtx *ctx, *ctx2;
+  SoapCtx *ctx, *ctx2;
+  herror_t err;
+ 
+  /*log_set_level(HLOG_VERBOSE);*/
+  err = soap_client_init_args(argc, argv);
+  if (err != H_OK) {
+	log_error4("%s():%s [%d]", herror_func(err), herror_message(err), herror_code(err));
+	herror_release(err);
+	return 1;
+  }
+
+  err = soap_client_ctx_new(urn, method, &ctx);
+  if (err != H_OK) {
+	log_error4("%s():%s [%d]", herror_func(err), herror_message(err), herror_code(err));
+	herror_release(err);
+	return 1;
+  }
 
-  log_set_level(HLOG_VERBOSE);
-  if (!soap_client_init_args(argc, argv)) {
-	  return 1;
-  }
-
-  ctx = soap_client_ctx_new(urn, method);
   soap_env_add_item(ctx->env, "xsd:string", "name", "Jonny B. Good");
   
   if (argc > 1)
-    ctx2 = soap_client_invoke(ctx, argv[1], "");
+    err = soap_client_invoke(ctx, &ctx2, argv[1], "");
   else
-    ctx2 = soap_client_invoke(ctx, url, "");
+    err = soap_client_invoke(ctx, &ctx2, url, "");
+
+  if (err != H_OK) {
+	log_error4("[%d] %s(): %s ", herror_code(err), herror_func(err), herror_message(err));
+	herror_release(err);
+	  soap_ctx_free(ctx);
+	  return 1;
+  }
 
   soap_xml_doc_print(ctx2->env->root->doc);
   soap_ctx_free(ctx2);
-  soap_ctx_free(ctx);
-}
-
-/*
-int main2(int argc, char *argv[])
-{
-  SoapEnv *env, *res;
-
-  log_set_level(HLOG_VERBOSE);
-  if (!soap_client_init_args(argc, argv)) {
-	  return 1;
-  }
-
-  env = soap_env_new_with_method(urn, method);
-  soap_env_add_item(env, "xsd:string", "name", "Jonny B. Good");
-
-  if (argc > 1)
-    res = soap_client_invoke(env, argv[1], "");
-  else
-    res = soap_client_invoke(env, url, "");
-  soap_xml_doc_print(res->root->doc);
-  soap_env_free(res);
-  soap_env_free(env);
-
+  soap_ctx_free(ctx);
+
   return 0;
 }
-
-*/
-
-
-
diff --git a/examples/csoap/simpleserver.c b/examples/csoap/simpleserver.c
index 3ccd61e..a165cfc 100644
--- a/examples/csoap/simpleserver.c
+++ b/examples/csoap/simpleserver.c
@@ -1,8 +1,8 @@
 /******************************************************************
- * $Id: simpleserver.c,v 1.10 2004/10/15 13:42:57 snowdrop Exp $
+ * $Id: simpleserver.c,v 1.11 2004/10/28 10:30:42 snowdrop Exp $
  *
  * CSOAP Project:  CSOAP examples project 
- * Copyright (C) 2003  Ferhat Ayaz
+ * Copyright (C) 2003-2004  Ferhat Ayaz
  *
  * This program is free software; you can redistribute it and/or modify
  * it under the terms of the GNU General Public License as published by
@@ -18,7 +18,7 @@
  * along with this program; if not, write to the Free Software
  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA02111-1307USA
  *
- * Email: ayaz@jprogrammer.net
+ * Email: ferhatayaz@yahoo.com
  ******************************************************************/
 
 #include <libcsoap/soap-server.h>
@@ -29,54 +29,45 @@ static const char *urn = "urn:examples";
 static const char *method = "sayHello";
 
 
-void add_name(xmlNodePtr node, SoapEnv *env)
+herror_t say_hello(SoapCtx *req, SoapCtx* res)
 {
-  char *name;
-  name = (char*)xmlNodeListGetString(node->doc, 
-				     node->xmlChildrenNode, 1);
-
-
-  if (!name) return;
 
-  soap_env_add_itemf(env,"xsd:string", "echo", 
-		     "Hello '%s'", name);
-
-  /*xmlFree(BAD_CAST name);*/
-
-}
-
-
-SoapCtx* say_hello(SoapCtx *request)
-{
+  herror_t err;
+  char *name;
 
-  SoapEnv *env;
-  SoapCtx*  ctx;
   xmlNodePtr method, node;
 
-  env = soap_env_new_with_response(request->env);
+  err = soap_env_new_with_response(req->env, &res->env);
+  if (err != H_OK) {
+	return err;
+  }
 
-  method = soap_env_get_method(request->env);
+  method = soap_env_get_method(req->env);
   node = soap_xml_get_children(method);
 
   while (node) {
-    add_name(node, env);
+	name = (char*)xmlNodeListGetString(node->doc, node->xmlChildrenNode, 1);
+	soap_env_add_itemf(req->env,"xsd:string", "echo", "Hello '%s'", name);
     node = soap_xml_get_next(node);
   }
 
-  ctx = soap_ctx_new(env);
-  return ctx;
+  return H_OK;
 }
 
 
 int main(int argc, char *argv[])
 {
 
+  herror_t err;
   SoapRouter *router;
   
   log_set_level(HLOG_VERBOSE);
 
-  if (!soap_server_init_args(argc, argv)) {
-    return 1;
+  err = soap_server_init_args(argc, argv);
+  if (err != H_OK) {
+	log_error4("%s():%s [%d]", herror_func(err), herror_message(err), herror_code(err));
+	herror_release(err);
+	return 1;
   }
   
   router = soap_router_new();
diff --git a/libcsoap/soap-client.c b/libcsoap/soap-client.c
index 5562399..2a56e11 100644
--- a/libcsoap/soap-client.c
+++ b/libcsoap/soap-client.c
@@ -1,5 +1,5 @@
 /******************************************************************
-*  $Id: soap-client.c,v 1.9 2004/10/20 14:17:36 snowdrop Exp $
+*  $Id: soap-client.c,v 1.10 2004/10/28 10:30:46 snowdrop Exp $
 *
 * CSOAP Project:  A SOAP client/server library in C
 * Copyright (C) 2003  Ferhat Ayaz
@@ -27,7 +27,7 @@
 
 /*--------------------------------- */
 static int _block_socket = 0;
-static SoapEnv *_soap_client_build_result(hresponse_t *res);
+static herror_t _soap_client_build_result(hresponse_t *res, SoapEnv **out);
 /*--------------------------------- */
 
 void soap_client_block_socket(int block)
@@ -42,11 +42,11 @@ int soap_client_get_blockmode()
 
 
 
-int soap_client_init_args(int argc, char *argv[])
+herror_t soap_client_init_args(int argc, char *argv[])
 
 {
 
-	return !httpc_init(argc, argv);
+	return httpc_init(argc, argv);
 
 }
 
@@ -65,17 +65,15 @@ long _file_get_size(const char* filename)
   return size;
 }
 
-SoapCtx*
-soap_client_invoke(SoapCtx *call, const char *url, const char *soap_action)
+
+herror_t
+soap_client_invoke(SoapCtx *call, SoapCtx** response, const char *url, const char *soap_action)
 {
   /* Status */
-  hstatus_t status;
+  herror_t status;
 
 	/* Result document */
-	SoapEnv* doc;
-
-	/* Result Context */
-	SoapCtx *ctx;
+	SoapEnv* res_env;
 
 	/* Buffer variables*/
 	xmlBufferPtr buffer;
@@ -118,48 +116,27 @@ soap_client_invoke(SoapCtx *call, const char *url, const char *soap_action)
   
     if (status != H_OK) {
       httpc_free(conn);
-    	xmlBufferFree(buffer);
-  		return soap_ctx_new(
-  		        soap_env_new_with_fault(Fault_Client, 
-          			"Can not begin post envelope","",""));
+    	xmlBufferFree(buffer);
+		return status;
     }
   
     status = http_output_stream_write_string(conn->out, content);
     if (status != H_OK) {
       httpc_free(conn);
     	xmlBufferFree(buffer);
-  		return soap_ctx_new(
-  		        soap_env_new_with_fault(Fault_Client,   
-  		         	"Can not post envelope","",""));
+		return status;
     }
   
-  /*	res = httpc_post(conn, url, (int)strlen(content), content);*/
-    res = httpc_post_end(conn);
-    if (res == NULL) {
+    status = httpc_post_end(conn, &res);
+    if (status != H_OK) {
       httpc_free(conn);
     	xmlBufferFree(buffer);
-  		return soap_ctx_new(
-  		         soap_env_new_with_fault(Fault_Client, 
-           			conn->errmsg,"",""));
+		return status;
     }
 	} 
 	else
 	{
 	
-	  /* Use content-length transport */
-    /*for (part=call->attachments->parts; part; part=part->next) {
-      file_size = _file_get_size(part->filename);
-      if (file_size == -1) [
-        httpc_free(conn);
-      	xmlBufferFree(buffer);
-    		return soap_ctx_new(
-    		        soap_env_new_with_fault(Fault_Client,   
-    		         	"Can not open file!","",""));
-      }
-      
-      total_size += file_size + BOUDARY_LENGTH;
-    }*/
-
     /* Use chunked transport */
     httpc_set_header(conn, HEADER_TRANSFER_ENCODING, TRANSFER_ENCODING_CHUNKED);
     
@@ -168,27 +145,21 @@ soap_client_invoke(SoapCtx *call, const char *url, const char *soap_action)
     if (status != H_OK) {
       httpc_free(conn);
     	xmlBufferFree(buffer);
-  		return soap_ctx_new(
-  		        soap_env_new_with_fault(Fault_Client,   
-  		         	"Can not begin MIME transport","",""));
+		return status;
     }
   
     status = httpc_mime_next(conn, start_id, "text/xml", "binary");
     if (status != H_OK) {
       httpc_free(conn);
     	xmlBufferFree(buffer);
-  		return soap_ctx_new(
-  		        soap_env_new_with_fault(Fault_Client,   
-  		         	"MIME transport error","",""));
+		return status;
     }
 
     status = http_output_stream_write(conn->out, content, strlen(content));
     if (status != H_OK) {
       httpc_free(conn);
     	xmlBufferFree(buffer);
-  		return soap_ctx_new(
-  		        soap_env_new_with_fault(Fault_Client,   
-  		         	"MIME transport error","",""));
+		return status;
     }
 
     
@@ -200,20 +171,16 @@ soap_client_invoke(SoapCtx *call, const char *url, const char *soap_action)
           log_error2("Send file failed. Status:%d", status);
           httpc_free(conn);
         	xmlBufferFree(buffer);
-      		return soap_ctx_new(
-      		        soap_env_new_with_fault(Fault_Client,   
-      		         	"MIME transport error while sending file","",""));
+			return status;
         }
     }
 
-    res = httpc_mime_end(conn);
-    if (!res)
+    status = httpc_mime_end(conn, &res);
+    if (status != H_OK)
     {
       httpc_free(conn);
     	xmlBufferFree(buffer);
-  		return soap_ctx_new(
-  		        soap_env_new_with_fault(Fault_Client,   
-  		         	"MIME transport error","",""));
+		return status;
     }
 	}
 
@@ -221,59 +188,54 @@ soap_client_invoke(SoapCtx *call, const char *url, const char *soap_action)
 	xmlBufferFree(buffer);
 
 	/* Build result */
-	/* TODO: If res == NULL, find out where and why it is NULL! */
-	doc = _soap_client_build_result(res); 
+	status = _soap_client_build_result(res, &res_env); 
+	if (status != H_OK)
+		return status;
 
 	/* Create Context */
-	ctx = soap_ctx_new(doc);
-	soap_ctx_add_files(ctx, res->attachments);
+	*response = soap_ctx_new(res_env);
+	soap_ctx_add_files(*response, res->attachments);
 
-	return ctx;
+	return H_OK;
 }
 
 
-static 
-SoapEnv* _soap_client_build_result(hresponse_t *res)
-{
-	SoapEnv *env;
+static 
+herror_t
+ _soap_client_build_result(hresponse_t *res, SoapEnv** env)
+{
+	herror_t err;
 
 	log_verbose2("Building result (%p)", res);
 
 	if (res == NULL)
-		return soap_env_new_with_fault(Fault_Client, 
-		"Response is NULL","","");
+		return herror_new("_soap_client_build_result", 
+			GENERAL_INVALID_PARAM, "hresponse_t is NULL");
 
 
 	if (res->in == NULL)
-		return soap_env_new_with_fault(Fault_Client, 
-		"Empty response from server!","","");
-
+		return herror_new("_soap_client_build_result", 
+			GENERAL_INVALID_PARAM, "Empty response from server");
 
-/*
-	doc = xmlParseDoc(BAD_CAST res->body);
-	if (doc == NULL) {
-		return soap_env_new_with_fault(Fault_Client, 
-			"Response is not in XML format!","","");
-	}
 
-	env = soap_env_new_from_doc(doc);
-*/
-  env = soap_env_new_from_stream(res->in);
+    err = soap_env_new_from_stream(res->in, env);
 
-	if (env == NULL) {
-/*		xmlFreeDoc(doc);*/
-		return soap_env_new_with_fault(Fault_Client, 
-			"Can not create envelope","","");
+	if (err != H_OK) {
+		return err;
 	}
 
-	return env;
+	return H_OK;
 }
 
 
-SoapCtx *soap_client_ctx_new(const char *urn, const char *method)
-{
-  SoapCtx *ctx = soap_ctx_new(soap_env_new_with_method(urn, method));
+herror_t soap_client_ctx_new(const char *urn, const char *method, SoapCtx **out)
+{
+	SoapEnv *env;
+	herror_t err;
+	err = soap_env_new_with_method(urn, method, &env);
+	if (err != H_OK) return err;
+    *out = soap_ctx_new(env);
 
-  return ctx;
+  return H_OK;
 }
 
diff --git a/libcsoap/soap-client.h b/libcsoap/soap-client.h
index 6820c14..22e41bb 100644
--- a/libcsoap/soap-client.h
+++ b/libcsoap/soap-client.h
@@ -1,5 +1,5 @@
 /******************************************************************
- *  $Id: soap-client.h,v 1.5 2004/10/20 14:17:36 snowdrop Exp $
+ *  $Id: soap-client.h,v 1.6 2004/10/28 10:30:46 snowdrop Exp $
  *
  * CSOAP Project:  A SOAP client/server library in C
  * Copyright (C) 2003  Ferhat Ayaz
@@ -30,7 +30,7 @@
 /**
 	Initializes the client side soap engine
 */
-int soap_client_init_args(int argc, char *argv[]);
+herror_t soap_client_init_args(int argc, char *argv[]);
 
 
 /**
@@ -38,19 +38,22 @@ int soap_client_init_args(int argc, char *argv[]);
    the given envelope. 
 
    @param env envelope to send
+   @param response  the result envelope
    @param url url to the soap server
    @soap_action value for "SoapAction:" in the 
     HTTP request header.
 
-    @returns the result envelope. In case of failure,
-     this function return an envelope with a fault object.
+    @returns H_OK if success 
  */
-SoapCtx* soap_client_invoke(SoapCtx *ctx, 
+herror_t soap_client_invoke(SoapCtx *ctx, SoapCtx** response, 
 			    const char *url,
 			    const char *soap_action);
 
 
-SoapCtx *soap_client_ctx_new(const char *urn, const char *method);
+/**
+	Creates a new soap context object.
+*/
+herror_t soap_client_ctx_new(const char *urn, const char *method, SoapCtx **out);
 
 /**
 	Sets the underlaying socket to use while connecting
diff --git a/libcsoap/soap-ctx.c b/libcsoap/soap-ctx.c
index a77bbdd..944abf0 100755
--- a/libcsoap/soap-ctx.c
+++ b/libcsoap/soap-ctx.c
@@ -1,5 +1,5 @@
 /******************************************************************
- *  $Id: soap-ctx.c,v 1.1 2004/10/15 13:33:48 snowdrop Exp $
+ *  $Id: soap-ctx.c,v 1.2 2004/10/28 10:30:46 snowdrop Exp $
  *
  * CSOAP Project:  A SOAP client/server library in C
  * Copyright (C) 2003-2004  Ferhat Ayaz
@@ -49,14 +49,16 @@ void soap_ctx_add_files(SoapCtx* ctx, attachments_t *attachments)
 }
 
 
-hstatus_t soap_ctx_add_file(SoapCtx* ctx, const char* filename, const char* content_type, char *dest_href)
+herror_t soap_ctx_add_file(SoapCtx* ctx, const char* filename, const char* content_type, char *dest_href)
 {
   char cid[250];
   char id[250];
   part_t *part;
   static int counter = 1;
   FILE *test = fopen(filename, "r");
-  if (!test) return FILE_ERROR_OPEN;
+  if (!test) 
+	  return herror_new("soap_ctx_add_file", FILE_ERROR_OPEN, 
+	  "Can not open file '%s'", filename);
   
   fclose(test);
   
diff --git a/libcsoap/soap-ctx.h b/libcsoap/soap-ctx.h
index c32f372..2ea107b 100755
--- a/libcsoap/soap-ctx.h
+++ b/libcsoap/soap-ctx.h
@@ -1,5 +1,5 @@
 /******************************************************************
- *  $Id: soap-ctx.h,v 1.1 2004/10/15 13:33:48 snowdrop Exp $
+ *  $Id: soap-ctx.h,v 1.2 2004/10/28 10:30:46 snowdrop Exp $
  *
  * CSOAP Project:  A SOAP client/server library in C
  * Copyright (C) 2003-2004  Ferhat Ayaz
@@ -40,7 +40,7 @@ typedef struct _SoapCtx
 SoapCtx* soap_ctx_new(SoapEnv *env); /* should only be used internally */
 
 /* Size of destination dest_href should be MAX_HREF_SIZE */
-hstatus_t soap_ctx_add_file(SoapCtx* ctx, const char* filename, const char* content_type, char *dest_href);
+herror_t soap_ctx_add_file(SoapCtx* ctx, const char* filename, const char* content_type, char *dest_href);
 void soap_ctx_add_files(SoapCtx* ctx, attachments_t *attachments);
 void soap_ctx_free(SoapCtx* ctx);
 
diff --git a/libcsoap/soap-env.c b/libcsoap/soap-env.c
index 7d7811b..6527028 100644
--- a/libcsoap/soap-env.c
+++ b/libcsoap/soap-env.c
@@ -1,5 +1,5 @@
 /******************************************************************
-*  $Id: soap-env.c,v 1.8 2004/10/15 14:33:07 snowdrop Exp $
+*  $Id: soap-env.c,v 1.9 2004/10/28 10:30:46 snowdrop Exp $
 *
 * CSOAP Project:  A SOAP client/server library in C
 * Copyright (C) 2003  Ferhat Ayaz
@@ -102,21 +102,96 @@ static
 
 /* ---------------------------------------------------------------------------- */
 
-SoapEnv *
+
+
+herror_t
+soap_env_new_from_doc (xmlDocPtr doc, SoapEnv **out)
+{
+  xmlNodePtr node;
+  SoapEnv *env;
+
+  if (doc == NULL)
+  {
+    log_error1 ("Can not create xml document!");
+    return herror_new("soap_env_new_from_doc", 
+		GENERAL_INVALID_PARAM, "XML Document (xmlDocPtr) is NULL");
+  }
+
+  node = xmlDocGetRootElement (doc);
+  if (node == NULL)
+  {
+    log_error1 ("xml document is empty!");
+    return herror_new("soap_env_new_from_doc", 
+		XML_ERROR_EMPTY_DOCUMENT, "XML Document is empty!");
+  }
+
+  env = (SoapEnv *) malloc (sizeof (SoapEnv));
+
+  /* set root */
+  env->root = node;
+
+  /* set method root
+     set call->cur (current node) to <method>.
+     xpath: //Envelope/Body/
+   */
+  node = soap_xml_get_children (env->root);/* Check for NULL ! */
+  env->cur = soap_xml_get_children (node); /* Check for NULL ! */
+
+  *out = env;
+  return H_OK;
+}
+
+
+
+
+herror_t
+soap_env_new_from_buffer (const char *buffer, SoapEnv **out)
+{
+  xmlDocPtr doc;
+  herror_t err;
+
+  if (buffer == NULL)
+     return herror_new("soap_env_new_from_buffer", 
+		GENERAL_INVALID_PARAM, "buffer (first param) is NULL");
+
+  doc = xmlParseDoc (BAD_CAST buffer);
+  if (doc == NULL)
+     return herror_new("soap_env_new_from_buffer", 
+		XML_ERROR_PARSE, "Can not parse xml");
+
+  err = soap_env_new_from_doc (doc, out);
+  if (err != H_OK)  {
+    xmlFreeDoc (doc);
+  }
+
+  return err;
+}
+
+
+herror_t
 soap_env_new_with_fault (fault_code_t faultcode,
 			 const char *faultstring,
-			 const char *faultactor, const char *detail)
+			 const char *faultactor, const char *detail, SoapEnv **out)
 {
   xmlDocPtr doc;
+  herror_t err;
+	
   doc = soap_fault_build (faultcode, faultstring, faultactor, detail);
   if (doc == NULL)
-    return NULL;
-  return soap_env_new_from_doc (doc);
+    return herror_new("soap_env_new_with_fault", 
+		XML_ERROR_PARSE, "Can not parse fault xml");
+
+  err = soap_env_new_from_doc (doc, out);
+  if (err != H_OK)  {
+    xmlFreeDoc (doc);
+  }
+
+  return err;
 }
 
 
-SoapEnv *
-soap_env_new_with_response (SoapEnv * request)
+herror_t
+soap_env_new_with_response (SoapEnv * request, SoapEnv **out)
 {
   char urn[100];
   char methodname[150];
@@ -124,19 +199,20 @@ soap_env_new_with_response (SoapEnv * request)
 
   if (request == NULL)
   {
-    log_error1 ("request object is NULL");
-    return NULL;
+     return herror_new("soap_env_new_with_response", 
+		GENERAL_INVALID_PARAM, "request (first param) is NULL");
   }
 
   if (request->root == NULL)
   {
-    log_error1 ("request has no xml");
-    return NULL;
-  }
+     return herror_new("soap_env_new_with_response", 
+		GENERAL_INVALID_PARAM, "request (first param) has no xml structure");
+   }
 
   if (!soap_env_find_methodname (request, methodname))
   {
-    return NULL;
+     return herror_new("soap_env_new_with_response", 
+		GENERAL_INVALID_PARAM, "Method name '%s' not found in request", SAVE_STR(methodname));
   }
 
   if (!soap_env_find_urn (request, urn))
@@ -148,15 +224,14 @@ soap_env_new_with_response (SoapEnv * request)
   }
 
   sprintf (methodname2, "%sResponse", methodname);
-  return soap_env_new_with_method (urn, methodname2);
+  return soap_env_new_with_method (urn, methodname2, out);
 }
 
 
-SoapEnv *
-soap_env_new_with_method (const char *urn, const char *method)
+herror_t
+soap_env_new_with_method (const char *urn, const char *method, SoapEnv **out)
 {
   xmlDocPtr env;
-  SoapEnv *call;
   xmlChar buffer[1054];
 
 
@@ -188,19 +263,30 @@ soap_env_new_with_method (const char *urn, const char *method)
 #endif
 
   }
-  env = xmlParseDoc (buffer);
-  call = soap_env_new_from_doc (env);
+  
+  env = xmlParseDoc (buffer);
+  if (!env)
+    return herror_new("soap_env_new_with_method", 
+		XML_ERROR_PARSE, "Can not parse xml");
+
+  return soap_env_new_from_doc (env, out);
 
-  return call;
 }
+
+
 
 static 
 int _soap_env_xml_io_read(void* ctx, char *buffer, int len)
-{
-  http_input_stream_t *in = (http_input_stream_t *)ctx;
-  if(!http_input_stream_is_ready(in))
-    return 0;
-  return http_input_stream_read(in, buffer, len);
+{
+	int readed;
+	http_input_stream_t *in = (http_input_stream_t*)ctx;
+	if(!http_input_stream_is_ready(in))
+		return 0;
+  
+	readed = http_input_stream_read(in, buffer, len);
+	if (readed == -1)
+		return 0;
+	return readed;
 }
 
 static
@@ -210,15 +296,21 @@ int _soap_env_xml_io_close(void *ctx)
   return 0;
 }
 
-SoapEnv *
-soap_env_new_from_stream(http_input_stream_t *in)
+
+herror_t
+soap_env_new_from_stream(http_input_stream_t *in, SoapEnv **out)
 {
-  xmlDocPtr doc;
-  
+  xmlDocPtr doc;
+  herror_t err;
+ 
   doc = xmlReadIO(_soap_env_xml_io_read,
     _soap_env_xml_io_close,  in, "", NULL, 0);
-
-  return soap_env_new_from_doc (doc);
+
+  if (in->err != H_OK) return in->err;
+  if (doc == NULL) return herror_new("soap_env_new_from_stream", 
+	  XML_ERROR_PARSE, "Trying to parse not valid xml");
+  err = soap_env_new_from_doc (doc, out);
+  return err;
 }
 
 
@@ -346,67 +438,6 @@ soap_env_free (SoapEnv * env)
 }
 
 
-SoapEnv *
-soap_env_new_from_doc (xmlDocPtr doc)
-{
-  SoapEnv *env;
-  xmlNodePtr node;
-
-  if (doc == NULL)
-  {
-    log_error1 ("Can not create xml document!");
-    return NULL;
-  }
-
-  node = xmlDocGetRootElement (doc);
-  if (node == NULL)
-  {
-    log_error1 ("xml document is empty!");
-    return NULL;
-  }
-
-  env = (SoapEnv *) malloc (sizeof (SoapEnv));
-
-  /* set root */
-  env->root = node;
-
-  /* set method root
-     set call->cur (current node) to <method>.
-     xpath: //Envelope/Body/
-   */
-  node = soap_xml_get_children (env->root);
-  env->cur = soap_xml_get_children (node);
-
-  return env;
-}
-
-
-
-
-SoapEnv *
-soap_env_new_from_buffer (const char *buffer)
-{
-  xmlDocPtr doc;
-  SoapEnv *env;
-
-  if (buffer == NULL)
-    return NULL;
-
-  doc = xmlParseDoc (BAD_CAST buffer);
-  if (doc == NULL)
-    return NULL;
-
-  env = soap_env_new_from_doc (doc);
-  if (env == NULL)
-  {
-    xmlFreeDoc (doc);
-    return NULL;
-  }
-
-  return env;
-}
-
-
 xmlNodePtr
 soap_env_get_body (SoapEnv * env)
 {
diff --git a/libcsoap/soap-env.h b/libcsoap/soap-env.h
index 5b3bd7f..58af136 100644
--- a/libcsoap/soap-env.h
+++ b/libcsoap/soap-env.h
@@ -1,5 +1,5 @@
 /******************************************************************
- *  $Id: soap-env.h,v 1.7 2004/10/15 13:33:13 snowdrop Exp $
+ *  $Id: soap-env.h,v 1.8 2004/10/28 10:30:46 snowdrop Exp $
  *
  * CSOAP Project:  A SOAP client/server library in C
  * Copyright (C) 2003  Ferhat Ayaz
@@ -50,8 +50,8 @@ typedef struct _SoapEnv
    @param faultstring A fault message
    @param faultactor The fault actor (This can be NULL)
    @param detail The detail of the error (This can be NULL)
-
-   @returns A Soap envelope object like follows 
+   @param out the result envelope out parameter like follows
+   @returns H_OK if success
 
    <pre>
    <SOAP-ENV:Envelope xmlns:SOAP-ENV="..." SOAP-ENV:encoding="..."
@@ -71,11 +71,12 @@ typedef struct _SoapEnv
    
    </pre>
 
- */
-SoapEnv *soap_env_new_with_fault(fault_code_t faultcode, 
+ */
+herror_t
+soap_env_new_with_fault(fault_code_t faultcode, 
 				 const char *faultstring,
 				 const char *faultactor,
-				 const char *detail);
+				 const char *detail, SoapEnv **out);
 
 /**
    Creates an envelope with a method to invoke a soap service.
@@ -84,7 +85,8 @@ SoapEnv *soap_env_new_with_fault(fault_code_t faultcode,
    @param urn The urn of the soap service to invoke
    @param method The method name of the soap service
 
-   @returns A Soap envelope object like follows 
+   @param out the result envelope out parameter like follows
+   @returns H_OK if success
 
    <pre>
    <SOAP-ENV:Envelope xmlns:SOAP-ENV="..." SOAP-ENV:encoding="..."
@@ -101,7 +103,8 @@ SoapEnv *soap_env_new_with_fault(fault_code_t faultcode,
    </pre>
 
  */
-SoapEnv *soap_env_new_with_method(const char *urn, const char *method);
+herror_t
+soap_env_new_with_method(const char *urn, const char *method, SoapEnv **out);
 
 
 /**
@@ -115,7 +118,8 @@ SoapEnv *soap_env_new_with_method(const char *urn, const char *method);
    @param req The request object. A response object will be created
     to this request.
 
-   @returns A Soap envelope object like follows 
+   @param out the result envelope out paramter like follows
+   @returns H_OK if success
 
    <pre>
    <SOAP-ENV:Envelope xmlns:SOAP-ENV="..." SOAP-ENV:encoding="..."
@@ -133,18 +137,19 @@ SoapEnv *soap_env_new_with_method(const char *urn, const char *method);
 
 
  */
-SoapEnv *soap_env_new_with_response(SoapEnv *req);
+herror_t soap_env_new_with_response(SoapEnv *req,SoapEnv **out);
 
 
 /**
    Creates an envelope from a given libxml2 xmlDoc 
    pointer.
 
-   @param doc the xml document pointer
-   @returns A Soap envelop object if success, 
-    NULL otherwise.
+   @param doc the xml document pointer
+   @param out the output envelope object
+   @returns H_OK if success
+    
  */
-SoapEnv *soap_env_new_from_doc(xmlDocPtr doc);
+herror_t soap_env_new_from_doc(xmlDocPtr doc, SoapEnv **out);
 
 
 /**
@@ -152,17 +157,20 @@ SoapEnv *soap_env_new_from_doc(xmlDocPtr doc);
    The string must be in xml format.
 
    @param buffer The string to parse into a envelope.
-   @returns A soap envelope object if success or
-    NULL if the string can not be parsed or the string
-    does not represent an soap envelope in xml format.
+   @param out the output envelope object
+   @returns H_OK if success
  */
-SoapEnv *soap_env_new_from_buffer(const char* buffer);
+herror_t soap_env_new_from_buffer(const char* buffer,SoapEnv **out);
 
 
 /**
-  Create an envelope from input stream
+  Create an envelope from input stream
+
+   @param in the input stream object to read from 
+   @param out the output envelope object
+   @returns H_OK if success
 */
-SoapEnv *soap_env_new_from_stream(http_input_stream_t *in);
+herror_t soap_env_new_from_stream(http_input_stream_t *in, SoapEnv **out);
 
 /* --------------------------------------------------- */
 /*      XML Serializer functions  and typedefs         */
diff --git a/libcsoap/soap-server.c b/libcsoap/soap-server.c
index 690fa6b..65bef3f 100644
--- a/libcsoap/soap-server.c
+++ b/libcsoap/soap-server.c
@@ -1,5 +1,5 @@
 /******************************************************************
-*  $Id: soap-server.c,v 1.6 2004/10/20 14:17:36 snowdrop Exp $
+*  $Id: soap-server.c,v 1.7 2004/10/28 10:30:46 snowdrop Exp $
 *
 * CSOAP Project:  A SOAP client/server library in C
 * Copyright (C) 2003  Ferhat Ayaz
@@ -58,9 +58,9 @@ void _soap_server_send_fault(httpd_conn_t *conn, hpair_t *header,
 /*---------------------------------*/
 
 
-int soap_server_init_args(int argc, char *argv[])
+herror_t soap_server_init_args(int argc, char *argv[])
 {
-	return !httpd_init(argc, argv);
+	return httpd_init(argc, argv);
 }
 
 
@@ -82,7 +82,7 @@ int soap_server_register_router(SoapRouter *router, const char* context)
 }
 
 
-int soap_server_run()
+herror_t soap_server_run()
 {
 	return httpd_run();
 }
@@ -113,7 +113,8 @@ void soap_server_entry(httpd_conn_t *conn, hrequest_t *req)
 	SoapCtx *ctx, *ctxres;
 	SoapRouter *router;
 	SoapService *service;
-	SoapEnv *env;
+	SoapEnv *env;
+	herror_t err;
 
 	if (req->method != HTTP_REQUEST_POST) {
 
@@ -125,10 +126,17 @@ void soap_server_entry(httpd_conn_t *conn, hrequest_t *req)
 		return;
 	}
 
-/*	postdata = httpd_get_postdata(conn, req, &received, -1);*/
-  env = soap_env_new_from_stream(req->in);
 
-	header = hpairnode_new(HEADER_CONTENT_TYPE, "text/xml", NULL);
+	header = hpairnode_new(HEADER_CONTENT_TYPE, "text/xml", NULL);
+
+	err = soap_env_new_from_stream(req->in, &env);
+	if (err != H_OK) 
+	{
+  		_soap_server_send_fault(conn, header, herror_message(err));
+		herror_release(err);
+		return;
+	}
+
 
 	if (env == NULL) {
 
@@ -183,13 +191,22 @@ void soap_server_entry(httpd_conn_t *conn, hrequest_t *req)
 					return;
 				} else {
 
-					log_verbose2("func: %p", service->func);
+					log_verbose2("func: %p", service->func);
+					ctxres = soap_ctx_new(NULL);
 					/* ===================================== */
           /*       CALL SERVICE FUNCTION           */
 					/* ===================================== */
-					ctxres = service->func(ctx);
-					log_verbose2("func returned: (%p)", ctxres);
-					if (ctxres == NULL) {
+					err = service->func(ctx, ctxres);
+					if (err != H_OK) {
+						sprintf(buffer, "Service returned following error message: '%s'",
+							herror_message(err));
+						herror_release(err);
+						_soap_server_send_fault(conn, header, buffer);
+						soap_ctx_free(ctx);
+						return;
+					}
+
+					if (ctxres->env == NULL) {
 
 						sprintf(buffer, "Service '%s' returned no envelope", urn);
 						_soap_server_send_fault(conn, header, buffer);
@@ -271,13 +288,38 @@ static
 void _soap_server_send_fault(httpd_conn_t *conn, hpair_t *header, 
 							 const char* errmsg)
 {
-	SoapEnv *envres;
+	SoapEnv *envres;
+	herror_t err;
+	char buffer[45];
 	httpd_set_headers(conn, header);
-	httpd_send_header(conn, 500, "FAILED");
-	envres = soap_env_new_with_fault(Fault_Server,
+	err = httpd_send_header(conn, 500, "FAILED");
+	if (err != H_OK) {
+		 /* WARNING: unhandled exception !*/
+		log_error4("%s():%s [%d]", herror_func(err), herror_message(err), herror_code(err));
+		return;
+	}
+
+	err = soap_env_new_with_fault(Fault_Server,
 		errmsg?errmsg:"General error",
-		"cSOAP_Server", NULL);
-	_soap_server_send_env(conn->out, envres);
+		"cSOAP_Server", NULL, &envres);
+	 if (err != H_OK) {
+		 log_error1(herror_message(err));
+		http_output_stream_write_string(conn->out, "<html><head></head><body>");
+		http_output_stream_write_string(conn->out, "<h1>Error</h1><hr>");
+		http_output_stream_write_string(conn->out, "Error while sending fault object:<br>Message: ");
+		http_output_stream_write_string(conn->out, herror_message(err));
+		http_output_stream_write_string(conn->out, "<br>Function: ");
+		http_output_stream_write_string(conn->out, herror_func(err));
+		http_output_stream_write_string(conn->out, "<br>Error code: ");
+		sprintf(buffer, "%d", herror_code(err));
+		http_output_stream_write_string(conn->out, buffer);
+		http_output_stream_write_string(conn->out, "</body></html>");
+		return;
+
+		 herror_release(err);
+	 } else {
+	_soap_server_send_env(conn->out, envres);
+	 }
 
 }
 
diff --git a/libcsoap/soap-server.h b/libcsoap/soap-server.h
index 13abd92..62d136c 100644
--- a/libcsoap/soap-server.h
+++ b/libcsoap/soap-server.h
@@ -1,5 +1,5 @@
 /******************************************************************
- *  $Id: soap-server.h,v 1.3 2004/10/15 13:33:13 snowdrop Exp $
+ *  $Id: soap-server.h,v 1.4 2004/10/28 10:30:46 snowdrop Exp $
  *
  * CSOAP Project:  A SOAP client/server library in C
  * Copyright (C) 2003  Ferhat Ayaz
@@ -19,7 +19,7 @@
  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  * Boston, MA  02111-1307, USA.
  * 
- * Email: ayaz@jprogrammer.net
+ * Email: ferhatayaz@yahoo.com
  ******************************************************************/
 #ifndef cSOAP_SERVER_H
 #define cSOAP_SERVER_H
@@ -34,7 +34,9 @@
 
    <TABLE border=1>
    <TR><TH>Argument</TH><TH>Description</TH></TR>
-   <TR><TD>-NHTTPport [port]</TD><TD>Port to listen (default: 10000)</TD></TR>
+   <TR><TD>-NHTTPport [port]</TD><TD>Port to listen (default: 10000)</TD></TR>
+   <TR><TD>-NHTTPmaxconn [num]</TD><TD>Maximum thread connections</TD></TR>
+   <TR><TD>-NHTTPlog [logfilename]</TD><TD>logfile</TD></TR>
    </TABLE>
 
    @param argc commandline arg count
@@ -42,7 +44,7 @@
 
    @returns 1 if success, 0 otherwise
  */
-int soap_server_init_args(int argc, char *argv[]);
+herror_t soap_server_init_args(int argc, char *argv[]);
 
 
 /**
@@ -66,7 +68,7 @@ int soap_server_register_router(SoapRouter *router, const char* context);
    Enters the server loop and starts to listen to 
    http requests.
  */
-int soap_server_run();
+herror_t soap_server_run();
 
 
 /**
diff --git a/libcsoap/soap-service.h b/libcsoap/soap-service.h
index 7c2855e..c03d7df 100644
--- a/libcsoap/soap-service.h
+++ b/libcsoap/soap-service.h
@@ -1,5 +1,5 @@
 /******************************************************************
- *  $Id: soap-service.h,v 1.2 2004/10/15 13:34:02 snowdrop Exp $
+ *  $Id: soap-service.h,v 1.3 2004/10/28 10:30:46 snowdrop Exp $
  *
  * CSOAP Project:  A SOAP client/server library in C
  * Copyright (C) 2003  Ferhat Ayaz
@@ -28,7 +28,7 @@
 #include <libcsoap/soap-env.h>
 #include <libcsoap/soap-ctx.h>
 
-typedef SoapCtx* (*SoapServiceFunc)(SoapCtx*);
+typedef herror_t (*SoapServiceFunc)(SoapCtx*, SoapCtx*);
 
 
 typedef struct _SoapService
diff --git a/nanohttp/nanohttp-client.c b/nanohttp/nanohttp-client.c
index de55427..c393573 100644
--- a/nanohttp/nanohttp-client.c
+++ b/nanohttp/nanohttp-client.c
@@ -1,5 +1,5 @@
 /******************************************************************
-*  $Id: nanohttp-client.c,v 1.22 2004/10/20 14:17:41 snowdrop Exp $
+*  $Id: nanohttp-client.c,v 1.23 2004/10/28 10:30:46 snowdrop Exp $
 *
 * CSOAP Project:  A http client/server library in C
 * Copyright (C) 2003  Ferhat Ayaz
@@ -48,7 +48,7 @@ FUNCTION: httpc_init
 DESC: Initialize http client connection
 NOTE: This will be called from soap_client_init_args()
 ----------------------------------------------------*/
-int 
+herror_t 
 httpc_init(int argc, char *argv[])
 {
 	int i;
@@ -63,7 +63,7 @@ httpc_init(int argc, char *argv[])
        log_set_file(argv[i+1]);
     }
   }
-	return 0;
+  return H_OK;
 }
 
 /*--------------------------------------------------
@@ -198,11 +198,11 @@ FUNCTION: httpc_send_header
 DESC: Sends the current header information stored
 in conn through conn->sock.
 ----------------------------------------------------*/
-int 
+herror_t 
 httpc_send_header(httpc_conn_t * conn)
 {
 	hpair_t        *p;
-	int             status;
+	herror_t        status;
 	char            buffer[1024];
 
 	p = conn->header;
@@ -266,17 +266,20 @@ If success, this function will return 0.
 >0 otherwise.
 ----------------------------------------------------*/
 static
-int 
+herror_t 
 httpc_talk_to_server(hreq_method_t method, httpc_conn_t * conn,
 		     const char *urlstr)
-{
+{
+
 	hurl_t          url;
 	char            buffer[4096];
-	int             status;
+	herror_t             status;
 
 	if (conn == NULL) {
-		log_error1("Connection object is NULL");
-		return 1;
+		return herror_new(
+				"httpc_talk_to_server", 
+				GENERAL_INVALID_PARAM, 
+				"httpc_conn_t param is NULL");
 	}
 	/* Build request header */
 	httpc_header_add_date(conn);
@@ -295,9 +298,7 @@ httpc_talk_to_server(hreq_method_t method, httpc_conn_t * conn,
 	/* Open connection */
 	status = hsocket_open(&conn->sock, url.host, url.port);
 	if (status != H_OK) {
-		log_error3("Can not open connection to '%s' (status:%d)",
-			   SAVE_STR(url.host), status);
-		return 3;
+		return status;
 	}
 	status = hsocket_block(conn->sock, conn->block);
 	if (status != H_OK) {
@@ -321,23 +322,27 @@ httpc_talk_to_server(hreq_method_t method, httpc_conn_t * conn,
 	} else {
 
 		log_error1("Unknown method type!");
-		return 15;
+		return herror_new(
+				"httpc_talk_to_server", 
+				GENERAL_INVALID_PARAM, 
+				"hreq_method_t must be  HTTP_REQUEST_GET or HTTP_REQUEST_POST");
 	}
 
 	status = hsocket_send(conn->sock, buffer);
 	if (status != H_OK) {
 		log_error2("Can not send request (status:%d)", status);
 		hsocket_close(conn->sock);
-		return 4;
+		return status;
 	}
 	/* Send Header */
 	status = httpc_send_header(conn);
 	if (status != H_OK) {
 		log_error2("Can not send header (status:%d)", status);
 		hsocket_close(conn->sock);
-		return 5;
-	}
-	return status;
+		return status;
+	}
+
+	return H_OK;
 
 }
 
@@ -345,28 +350,26 @@ httpc_talk_to_server(hreq_method_t method, httpc_conn_t * conn,
 FUNCTION: httpc_get
 DESC:
 ----------------------------------------------------*/
-hresponse_t    *
-httpc_get(httpc_conn_t *conn, const char *urlstr)
+herror_t
+httpc_get(httpc_conn_t *conn, hresponse_t** out, const char *urlstr)
 {
-	int             status;
-	hresponse_t    *res;
+	herror_t             status;
 
 	status = httpc_talk_to_server(HTTP_REQUEST_GET, conn, urlstr);
 
 	if (status != H_OK)
 	{
-  	_httpc_set_error(conn, status, "Can not comunicate: %s", urlstr);
-  	return NULL;
+  	return status;
 	}
 
-	res = hresponse_new_from_socket(conn->sock);
-	if (res == NULL)
+	status = hresponse_new_from_socket(conn->sock, out);
+	if (status != H_OK)
 	{
-  	_httpc_set_error(conn, -1, "Can not get response from '%s'", urlstr);
-  	return NULL;
+  	return status;
 	}
-		
-	return res;
+		
+
+	return H_OK;
 }
 
 
@@ -374,10 +377,10 @@ httpc_get(httpc_conn_t *conn, const char *urlstr)
 FUNCTION: httpc_post_begin
 DESC: Returns H_OK if success
 ----------------------------------------------------*/
-int httpc_post_begin(httpc_conn_t *conn, const char *url)
+herror_t httpc_post_begin(httpc_conn_t *conn, const char *url)
 {
   
-	int             status;
+	herror_t             status;
 
 	status = httpc_talk_to_server(HTTP_REQUEST_POST, conn, url);
 	if (status != H_OK)
@@ -394,27 +397,24 @@ FUNCTION: httpc_post_begin
 DESC: End a "POST" method and receive the response.
   You MUST call httpc_post_end() before!
 ----------------------------------------------------*/
-hresponse_t *httpc_post_end(httpc_conn_t *conn)
+herror_t httpc_post_end(httpc_conn_t *conn, hresponse_t** out)
 {
-  int status;
-  hresponse_t *res;
+  herror_t status;
 
   status = http_output_stream_flush(conn->out);
 
   if (status != H_OK)
   {
-    _httpc_set_error(conn, status, "Can not flush output stream");
-    return NULL;
+    return status;
   }
 
-	res = hresponse_new_from_socket(conn->sock);
-	if (res == NULL)
-	{
-  	_httpc_set_error(conn, -1, "Can not get response ");
-  	return NULL;
+	status = hresponse_new_from_socket(conn->sock, out);
+	if (status != H_OK)
+	{
+    	return status;
 	}
-		
-	return res;
+
+	return H_OK;
 }
 
 
@@ -422,6 +422,7 @@ hresponse_t *httpc_post_end(httpc_conn_t *conn)
 /* ---------------------------------------------------
   DIME support functions httpc_dime_* function set
 -----------------------------------------------------*/
+/*
 int httpc_dime_begin(httpc_conn_t *conn, const char *url)
 {
   int status;
@@ -545,7 +546,7 @@ hresponse_t* httpc_dime_end(httpc_conn_t *conn)
 	int             status;
 	hresponse_t    *res;
 
-  /* Flush put stream */
+   Flush put stream 
   status = http_output_stream_flush(conn->out);
 
   if (status != H_OK)
@@ -564,7 +565,7 @@ hresponse_t* httpc_dime_end(httpc_conn_t *conn)
 	return res;
 }
 
-
+*/
 /* ---------------------------------------------------
   MIME support functions httpc_mime_* function set
 -----------------------------------------------------*/
@@ -576,12 +577,12 @@ void _httpc_mime_get_boundary(httpc_conn_t *conn, char *dest)
   log_verbose2("boundary= \"%s\"", dest);
 }
 
-int httpc_mime_begin(httpc_conn_t *conn, const char *url,
+herror_t httpc_mime_begin(httpc_conn_t *conn, const char *url,
   const char* related_start, 
   const char* related_start_info, 
   const char* related_type)
 {
-	int             status;
+	herror_t             status;
 	char            buffer[300];
 	char            temp[75];
 	char            boundary[75];
@@ -626,12 +627,12 @@ int httpc_mime_begin(httpc_conn_t *conn, const char *url,
 }
 
 
-int httpc_mime_next(httpc_conn_t *conn, 
+herror_t httpc_mime_next(httpc_conn_t *conn, 
   const char* content_id,
   const char* content_type, 
   const char* transfer_encoding)
 {
-  int            status;
+  herror_t            status;
   char           buffer[512];
   char           boundary[75];
 
@@ -659,10 +660,9 @@ int httpc_mime_next(httpc_conn_t *conn,
 }
 
 
-hresponse_t *httpc_mime_end(httpc_conn_t *conn)
+herror_t httpc_mime_end(httpc_conn_t *conn, hresponse_t** out)
 {
-  hresponse_t   *res;
-  int            status;
+  herror_t            status;
   char           buffer[512];
   char           boundary[75];
 
@@ -675,25 +675,23 @@ hresponse_t *httpc_mime_end(httpc_conn_t *conn)
     (const byte_t*)buffer, strlen(buffer));
 
   if (status != H_OK)
-    return NULL;
+    return status;
 
   /* Flush put stream */
   status = http_output_stream_flush(conn->out);
 
   if (status != H_OK)
   {
-    _httpc_set_error(conn, status, "Can not flush output stream");
-    return NULL;
+    return status;
   }
 
-	res = hresponse_new_from_socket(conn->sock);
-	if (res == NULL)
+	status = hresponse_new_from_socket(conn->sock, out);
+	if (status != H_OK)
 	{
-  	_httpc_set_error(conn, -1, "Can not get response ");
-  	return NULL;
+  	return status;
 	}
-		
-	return res;
+		
+	return H_OK;
 
 }
 
@@ -702,19 +700,20 @@ hresponse_t *httpc_mime_end(httpc_conn_t *conn)
   Send boundary and part header and continue 
   with next part
 */
-int
+herror_t
 httpc_mime_send_file (httpc_conn_t * conn,
                       const char *content_id,
                       const char *content_type,
                       const char *transfer_encoding, const char *filename)
 {
-  int status;
+  herror_t status;
   FILE *fd = fopen (filename, "rb");
   byte_t buffer[MAX_FILE_BUFFER_SIZE];
   size_t size;
 
   if (fd == NULL)
-    return FILE_ERROR_OPEN;
+    return herror_new("httpc_mime_send_file", FILE_ERROR_OPEN, 
+	"Can not open file '%s'", filename);
 
   status =
     httpc_mime_next(conn, content_id, content_type, transfer_encoding);
@@ -730,17 +729,23 @@ httpc_mime_send_file (httpc_conn_t * conn,
     if (size == -1)
     {
       fclose (fd);
-      return FILE_ERROR_READ;
-    }
-
-    status = http_output_stream_write (conn->out, buffer, size);
-    if (status != H_OK) {
-      fclose (fd);
-      return status;
+      return herror_new("httpc_mime_send_file", FILE_ERROR_READ, 
+			"Can not read from file '%s'", filename);
     }
+
+	if (size>0)
+	{
+		/*DEBUG: fwrite(buffer, 1, size, stdout);*/
+		status = http_output_stream_write (conn->out, buffer, size);
+		if (status != H_OK) {
+		fclose (fd);
+		return status;
+		}
+	}
   }
 
-  fclose (fd);
+  fclose (fd);
+  log_verbose1("file sent!");
   return H_OK;
 }
 
diff --git a/nanohttp/nanohttp-client.h b/nanohttp/nanohttp-client.h
index 6b54a03..b03c0a0 100644
--- a/nanohttp/nanohttp-client.h
+++ b/nanohttp/nanohttp-client.h
@@ -1,5 +1,5 @@
 /******************************************************************
- *  $Id: nanohttp-client.h,v 1.11 2004/10/20 14:17:41 snowdrop Exp $
+ *  $Id: nanohttp-client.h,v 1.12 2004/10/28 10:30:46 snowdrop Exp $
  *
  * CSOAP Project:  A http client/server library in C
  * Copyright (C) 2003  Ferhat Ayaz
@@ -58,7 +58,7 @@ typedef struct httpc_conn
 /**
   initialize the httpc_* module
 */
-hstatus_t httpc_init(int argc, char *argv[]);
+herror_t httpc_init(int argc, char *argv[]);
  
 /**
   Creates a new connection
@@ -78,19 +78,20 @@ int httpc_set_header(httpc_conn_t *conn, const char* key, const char* value);
 /**
   Invoke a "GET" method request and receive the response
 */
-hresponse_t *httpc_get(httpc_conn_t *conn, const char *url);
+herror_t
+httpc_get(httpc_conn_t *conn, hresponse_t** out, const char *urlstr);
 
 /**
   Start a "POST" method request
   Returns: HSOCKET_OK  or error flag
 */
-int httpc_post_begin(httpc_conn_t *conn, const char *url);
+herror_t httpc_post_begin(httpc_conn_t *conn, const char *url);
 
 /**
   End a "POST" method and receive the response.
   You MUST call httpc_post_end() before!
 */
-hresponse_t *httpc_post_end(httpc_conn_t *conn);
+herror_t httpc_post_end(httpc_conn_t *conn, hresponse_t **out);
 
 
 /* --------------------------------------------------------------
@@ -100,12 +101,13 @@ hresponse_t *httpc_post_end(httpc_conn_t *conn);
 /*
   DIME support httpc_dime_* function set
 */
+/*
 int httpc_dime_begin(httpc_conn_t *conn, const char *url);
 int httpc_dime_next(httpc_conn_t* conn, long content_length, 
                     const char *content_type, const char *id,
                     const char *dime_options, int last);
 hresponse_t* httpc_dime_end(httpc_conn_t *conn);
-
+*/
 
 /* --------------------------------------------------------------
  MIME RELATED FUNCTIONS
@@ -118,7 +120,7 @@ hresponse_t* httpc_dime_end(httpc_conn_t *conn);
   Begin MIME multipart/related POST request
   Returns: HSOCKET_OK  or error flag
 */
-int httpc_mime_begin(httpc_conn_t *conn, const char *url,
+herror_t httpc_mime_begin(httpc_conn_t *conn, const char *url,
   const char* related_start, 
   const char* related_start_info, 
   const char* related_type);
@@ -127,7 +129,7 @@ int httpc_mime_begin(httpc_conn_t *conn, const char *url,
   Send boundary and part header and continue 
   with next part
 */
-int httpc_mime_next(httpc_conn_t *conn, 
+herror_t httpc_mime_next(httpc_conn_t *conn, 
   const char* content_id,
   const char* content_type, 
   const char* transfer_encoding);
@@ -135,14 +137,14 @@ int httpc_mime_next(httpc_conn_t *conn,
 /**
   Finish MIME request and get the response
 */
-hresponse_t *httpc_mime_end(httpc_conn_t *conn);
+herror_t httpc_mime_end(httpc_conn_t *conn, hresponse_t** out);
 
 /**
   Send boundary and part header and continue 
   with next part
 */
 
-int httpc_mime_send_file (httpc_conn_t * conn,
+herror_t httpc_mime_send_file (httpc_conn_t * conn,
                       const char *content_id,
                       const char *content_type,
                       const char *transfer_encoding, 
diff --git a/nanohttp/nanohttp-common.c b/nanohttp/nanohttp-common.c
index df968c3..819c98b 100644
--- a/nanohttp/nanohttp-common.c
+++ b/nanohttp/nanohttp-common.c
@@ -1,5 +1,5 @@
 /******************************************************************
-*  $Id: nanohttp-common.c,v 1.14 2004/10/20 14:17:41 snowdrop Exp $
+*  $Id: nanohttp-common.c,v 1.15 2004/10/28 10:30:46 snowdrop Exp $
 *
 * CSOAP Project:  A http client/server library in C
 * Copyright (C) 2003  Ferhat Ayaz
@@ -33,6 +33,61 @@
 #ifdef MEM_DEBUG
 #include <utils/alloc.h>
 #endif
+
+
+
+typedef struct _herror_impl_t
+{
+	int errcode;
+	char message[250];
+	char func[100];
+}herror_impl_t;
+
+
+herror_t herror_new(const char* func, int errcode, const char* format, ...)
+{
+	va_list         ap;
+
+	herror_impl_t *impl = (herror_impl_t*)malloc(sizeof(herror_impl_t));
+	impl->errcode = errcode;
+	strcpy(impl->func, func);
+	va_start(ap, format);
+	vsprintf(impl->message, format, ap);
+	va_end(ap);
+
+	return (herror_t)impl;
+
+}
+
+int herror_code(herror_t err)
+{
+	herror_impl_t* impl = (herror_impl_t*)err;
+	if (!err) return H_OK;
+	return impl->errcode;
+}
+
+char* herror_func(herror_t err)
+{
+	herror_impl_t* impl = (herror_impl_t*)err;
+	if (!err) return "";
+	return impl->func;
+}
+
+char* herror_message(herror_t err)
+{
+	herror_impl_t* impl = (herror_impl_t*)err;
+	if (!err) return "";
+	return impl->message;
+}
+
+void herror_release(herror_t err)
+{
+	herror_impl_t* impl = (herror_impl_t*)err;
+	if (!err) return;
+	free(impl);
+}
+
+
 
 static log_level_t loglevel = HLOG_DEBUG;
 static char logfile[75] = {'\0'};
@@ -372,7 +427,7 @@ hurl_dump(const hurl_t * url)
 }
 
 
-int hurl_parse(hurl_t* url, const char *urlstr)
+herror_t hurl_parse(hurl_t* url, const char *urlstr)
 {
 	int             iprotocol;
 	int             ihost;
@@ -392,17 +447,17 @@ int hurl_parse(hurl_t* url, const char *urlstr)
 
 	if (iprotocol == 0) {
 		log_error1("no protocol");
-		return URL_ERROR_NO_PROTOCOL;
+		return herror_new("hurl_parse", URL_ERROR_NO_PROTOCOL, "No protocol");
 	}
 	if (iprotocol + 3 >= len) {
 		log_error1("no host");
-		return URL_ERROR_NO_HOST;
+		return herror_new("hurl_parse", URL_ERROR_NO_HOST, "No host");
 	}
 	if (urlstr[iprotocol] != ':'
 	    && urlstr[iprotocol + 1] != '/'
 	    && urlstr[iprotocol + 2] != '/') {
 		log_error1("no protocol");
-		return URL_ERROR_NO_PROTOCOL;
+		return herror_new("hurl_parse", URL_ERROR_NO_PROTOCOL, "No protocol");
 	}
 	/* find host */
 	ihost = iprotocol + 3;
@@ -414,7 +469,7 @@ int hurl_parse(hurl_t* url, const char *urlstr)
 
 	if (ihost == iprotocol + 1) {
 		log_error1("no host");
-		return URL_ERROR_NO_HOST;
+		return herror_new("hurl_parse", URL_ERROR_NO_HOST, "No host");
 	}
 	/* find port */
 	iport = ihost;
@@ -435,7 +490,8 @@ int hurl_parse(hurl_t* url, const char *urlstr)
 	  url->protocol = PROTOCOL_HTTPS;
 	else if (strcmpigcase(protocol, "ftp"))
 	  url->protocol = PROTOCOL_FTP;
-	else return URL_ERROR_UNKNOWN_PROTOCOL;
+	else 	return herror_new("hurl_parse", 
+		URL_ERROR_UNKNOWN_PROTOCOL, "Unknown protocol '%s'", protocol);
 
 	/* TODO (#1#): add max of size and URL_MAX_HOST_SIZE */
 	size = ihost - iprotocol - 3; 
diff --git a/nanohttp/nanohttp-common.h b/nanohttp/nanohttp-common.h
index f7b6c10..79ca625 100644
--- a/nanohttp/nanohttp-common.h
+++ b/nanohttp/nanohttp-common.h
@@ -1,5 +1,5 @@
 /******************************************************************
- *  $Id: nanohttp-common.h,v 1.13 2004/10/20 14:17:41 snowdrop Exp $
+ *  $Id: nanohttp-common.h,v 1.14 2004/10/28 10:30:46 snowdrop Exp $
  * 
  * CSOAP Project:  A http client/server library in C
  * Copyright (C) 2003-2004  Ferhat Ayaz
@@ -118,8 +118,18 @@
 #define MIME_ERROR_NO_ROOT_PART        1304 
 #define MIME_ERROR_NOT_MIME_MESSAGE    1305
 
+
+/* General errors */
+#define GENERAL_INVALID_PARAM	1400
+#define GENERAL_HEADER_PARSE_ERROR	1401
 
-
+/* Thread errors */
+#define THREAD_BEGIN_ERROR 1500
+
+/* XML Errors */
+#define XML_ERROR_EMPTY_DOCUMENT 1600
+#define XML_ERROR_PARSE 1601
+
 /*
 Set Sleep function platform depended
 */
@@ -136,7 +146,7 @@ struct tm *localtime_r(const time_t *const timep, struct tm *p_tm);
 #endif
 
 typedef unsigned char byte_t;
-typedef int hstatus_t;
+typedef void* herror_t;
 
 
 
@@ -159,7 +169,14 @@ typedef enum _hreq_method
   HTTP_REQUEST_GET
 }hreq_method_t ;
 
-
+
+herror_t herror_new(const char* func, 
+					int errcode, const char* format, ...);
+int herror_code(herror_t err);
+char* herror_func(herror_t err);
+char* herror_message(herror_t err);
+void herror_release(herror_t err);
+
 
 /*
   string function to compare strings ignoring case
@@ -350,7 +367,7 @@ typedef struct _hurl
     URL_ERROR_NO_PROTOCOL 
     URL_ERROR_NO_HOST 
 */
-hstatus_t hurl_parse(hurl_t *obj, const char* url);
+herror_t hurl_parse(hurl_t *obj, const char* url);
 
 /*
   Object representation of the content-type field 
diff --git a/nanohttp/nanohttp-mime.c b/nanohttp/nanohttp-mime.c
index 952cc22..2b6794d 100755
--- a/nanohttp/nanohttp-mime.c
+++ b/nanohttp/nanohttp-mime.c
@@ -3,7 +3,7 @@
 * | \/ | | | | \/ | | _/
 * |_''_| |_| |_''_| |_'/  PARSER
 *
-*  $Id: nanohttp-mime.c,v 1.2 2004/10/20 14:17:41 snowdrop Exp $
+*  $Id: nanohttp-mime.c,v 1.3 2004/10/28 10:30:46 snowdrop Exp $
 *
 * CSOAP Project:  A http client/server library in C
 * Copyright (C) 2003-2004  Ferhat Ayaz
@@ -509,13 +509,21 @@ MIME_read_status mime_streamreader_function(void* userdata,
   if (!http_input_stream_is_ready(in))
     return MIME_READ_EOF;
 
-  readed = http_input_stream_read(in, dest, *size);
+  readed = http_input_stream_read(in, dest, *size);
+  /*
+  log_info1("http_input_stream_read() returned 0");
+  */
+  if (readed == -1) {
+	log_error4("[%d] %s():%s ", herror_code(in->err), herror_func(in->err), herror_message(in->err));
+  }
+
   *size = readed;
-  if (*size!=-1) {
-    _log_str("reader.log", dest, *size);
+  if (*size!=-1) {
+	  /*
+    _log_str("reader.log", dest, *size);
+	*/
       return MIME_READ_OK;
-  }
-
+  } 
   return MIME_READ_ERROR;
 }
 
@@ -654,7 +662,7 @@ static
 void _mime_received_bytes(void *data, const unsigned char* bytes, int size)
 {
   int i=0;
-  char *id;
+  char *id, *type;
   mime_callback_data_t *cbdata = (mime_callback_data_t*)data;
 
   if (!cbdata ) {
@@ -720,13 +728,18 @@ void _mime_received_bytes(void *data, const unsigned char* bytes, int size)
           cbdata->current_part->header = _mime_process_header(cbdata->header);
           hpairnode_dump_deep(cbdata->current_part->header);
           /* set id */
-          id = hpairnode_get(cbdata->current_part->header, HEADER_CONTENT_ID);
-          if (id != NULL)
-          {
-            strcpy(cbdata->current_part->id, id);
-            if (!strcmp(id, cbdata->root_id))
-              cbdata->message->root_part = cbdata->current_part;
-          }
+          id = hpairnode_get(cbdata->current_part->header, HEADER_CONTENT_ID);
+          if (id != NULL)
+          {
+            strcpy(cbdata->current_part->id, id);
+            if (!strcmp(id, cbdata->root_id))
+              cbdata->message->root_part = cbdata->current_part;
+          }
+          type = hpairnode_get(cbdata->current_part->header, HEADER_CONTENT_TYPE);
+          if (type != NULL)
+          {
+            strcpy(cbdata->current_part->content_type, type);
+          }
           i++;
           break;
         }
@@ -854,7 +867,7 @@ mime_message_parse_from_file(FILE *in, const char* root_id,
 
 
 
-hstatus_t mime_get_attachments(content_type_t *ctype, http_input_stream_t *in, attachments_t **dest)
+herror_t mime_get_attachments(content_type_t *ctype, http_input_stream_t *in, attachments_t **dest)
 {
   /* MIME variables */
   attachments_t  *mimeMessage;
@@ -864,7 +877,8 @@ hstatus_t mime_get_attachments(content_type_t *ctype, http_input_stream_t *in, a
   /* Check for MIME message */
   if (!(ctype && 
       !strcmp(ctype->type, "multipart/related")))
-      return MIME_ERROR_NOT_MIME_MESSAGE;
+      return herror_new("mime_get_attachments", MIME_ERROR_NOT_MIME_MESSAGE,
+	    "Not a MIME message '%s'", ctype->type);
 
   boundary = hpairnode_get(ctype->params, "boundary");
   root_id  = hpairnode_get(ctype->params, "start");
@@ -872,14 +886,16 @@ hstatus_t mime_get_attachments(content_type_t *ctype, http_input_stream_t *in, a
   {
       /* TODO (#1#): Handle Error in http form */
     log_error1("'boundary' not set for multipart/related");
-    return MIME_ERROR_NO_BOUNDARY_PARAM;
+    return herror_new("mime_get_attachments", MIME_ERROR_NO_BOUNDARY_PARAM,
+		"'boundary' not set for multipart/related");
   }
 
   if (root_id == NULL)
   {
       /* TODO (#1#): Handle Error in http form */
     log_error1("'start' not set for multipart/related");
-    return MIME_ERROR_NO_START_PARAM;
+    return herror_new("mime_get_attachments", MIME_ERROR_NO_START_PARAM,
+		"'start' not set for multipart/related");
   }
 
   /* TODO (#1#): Set this not to working directory
@@ -890,14 +906,16 @@ hstatus_t mime_get_attachments(content_type_t *ctype, http_input_stream_t *in, a
   {
       /* TODO (#1#): Handle Error in http form */
     log_error1("MIME Parse Error");
-    return MIME_ERROR_PARSE_ERROR;
+    return herror_new("mime_get_attachments", MIME_ERROR_PARSE_ERROR,
+		"MIME Parse Error");
   }
 
   /* Find root */
   if (!mimeMessage->root_part)
   {
     attachments_free(mimeMessage);
-    return MIME_ERROR_NO_ROOT_PART;
+    return herror_new("mime_get_attachments", MIME_ERROR_NO_ROOT_PART,
+		"No root part found!");
   }
 
   /* delete root_part from list */
diff --git a/nanohttp/nanohttp-mime.h b/nanohttp/nanohttp-mime.h
index f78efa1..b51e44d 100755
--- a/nanohttp/nanohttp-mime.h
+++ b/nanohttp/nanohttp-mime.h
@@ -3,7 +3,7 @@
 * | \/ | | | | \/ | | _/
 * |_''_| |_| |_''_| |_'/  PARSER
 *
-*  $Id: nanohttp-mime.h,v 1.2 2004/10/20 14:17:41 snowdrop Exp $
+*  $Id: nanohttp-mime.h,v 1.3 2004/10/28 10:30:46 snowdrop Exp $
 *
 * CSOAP Project:  A http client/server library in C
 * Copyright (C) 2003-2004  Ferhat Ayaz
@@ -40,7 +40,7 @@
 
 
 
-hstatus_t mime_get_attachments(content_type_t *ctype, 
+herror_t mime_get_attachments(content_type_t *ctype, 
   http_input_stream_t *in, attachments_t **dest);
 
 
diff --git a/nanohttp/nanohttp-request.c b/nanohttp/nanohttp-request.c
index 0eb5a22..7661592 100755
--- a/nanohttp/nanohttp-request.c
+++ b/nanohttp/nanohttp-request.c
@@ -1,5 +1,5 @@
 /******************************************************************
-*  $Id: nanohttp-request.c,v 1.2 2004/10/20 14:17:41 snowdrop Exp $
+*  $Id: nanohttp-request.c,v 1.3 2004/10/28 10:30:46 snowdrop Exp $
 *
 * CSOAP Project:  A http client/server library in C
 * Copyright (C) 2003  Ferhat Ayaz
@@ -217,10 +217,11 @@ hrequest_free(hrequest_t * req)
 }
 
 
-hrequest_t *
-hrequest_new_from_socket(hsocket_t sock)
+herror_t
+hrequest_new_from_socket(hsocket_t sock, hrequest_t **out)
 {
-  int              i=0, status;
+  int              i=0, readed;
+  herror_t			status;
   hrequest_t      *req;
   char             buffer[MAX_HEADER_SIZE+1];
   attachments_t  *mimeMessage;
@@ -228,11 +229,11 @@ hrequest_new_from_socket(hsocket_t sock)
   /* Read header */
   while (i<MAX_HEADER_SIZE)
   {
-    status = hsocket_read(sock, &(buffer[i]), 1, 1);
-    if (status == -1)
+    status = hsocket_read(sock, &(buffer[i]), 1, 1, &readed);
+    if (status != H_OK)
     {
         log_error1("Socket read error");
-        return NULL;
+        return status;
     }
 
     buffer[i+1] = '\0'; /* for strmp */
@@ -248,11 +249,7 @@ hrequest_new_from_socket(hsocket_t sock)
 
   /* Create response */
   req = _hrequest_parse_header(buffer);
-  if (req == NULL)
-  {
-    log_error1("Header parse error");
-    return NULL;
-  }
+
 
   /* Create input stream */
   req->in = http_input_stream_new(sock, req->header);
@@ -266,7 +263,7 @@ hrequest_new_from_socket(hsocket_t sock)
     {
       /* TODO (#1#): Handle error */
       hrequest_free(req);
-      return NULL;            
+      return status;            
     }
     else
     {
@@ -275,8 +272,8 @@ hrequest_new_from_socket(hsocket_t sock)
     }
   }
      
-
-  return req;
+  *out = req;
+  return H_OK;
 }
 
 
diff --git a/nanohttp/nanohttp-request.h b/nanohttp/nanohttp-request.h
index c445596..8989247 100755
--- a/nanohttp/nanohttp-request.h
+++ b/nanohttp/nanohttp-request.h
@@ -1,5 +1,5 @@
 /******************************************************************
- *  $Id: nanohttp-request.h,v 1.1 2004/10/15 13:30:42 snowdrop Exp $
+ *  $Id: nanohttp-request.h,v 1.2 2004/10/28 10:30:46 snowdrop Exp $
  *
  * CSOAP Project:  A http client/server library in C
  * Copyright (C) 2003-2004  Ferhat Ayaz
@@ -45,7 +45,7 @@ typedef struct hrequest
   char root_part_id[150];
 }hrequest_t;
 
-hrequest_t *hrequest_new_from_socket(hsocket_t sock);
+herror_t hrequest_new_from_socket(hsocket_t sock, hrequest_t **out);
 void hrequest_free(hrequest_t *req);
 
 #endif
diff --git a/nanohttp/nanohttp-response.c b/nanohttp/nanohttp-response.c
index 8f55856..f2e13c5 100755
--- a/nanohttp/nanohttp-response.c
+++ b/nanohttp/nanohttp-response.c
@@ -1,5 +1,5 @@
 /******************************************************************
-*  $Id: nanohttp-response.c,v 1.1 2004/10/15 13:30:42 snowdrop Exp $
+*  $Id: nanohttp-response.c,v 1.2 2004/10/28 10:30:46 snowdrop Exp $
 *
 * CSOAP Project:  A http client/server library in C
 * Copyright (C) 2003-2004  Ferhat Ayaz
@@ -121,10 +121,12 @@ _hresponse_parse_header(const char *buffer)
 	return res;
 }
 
-hresponse_t *
-hresponse_new_from_socket(hsocket_t sock)
+
+herror_t
+hresponse_new_from_socket(hsocket_t sock, hresponse_t **out)
 {
-  int              i=0, status;
+  int              i=0, readed;
+  herror_t		status;
   hresponse_t     *res;
   attachments_t  *mimeMessage;
   char             buffer[MAX_HEADER_SIZE+1];
@@ -133,11 +135,11 @@ read_header: /* for errorcode: 100 (continue) */
   /* Read header */
   while (i<MAX_HEADER_SIZE)
   {
-    status = hsocket_read(sock, &(buffer[i]), 1, 1);
-    if (status == -1)
+    status = hsocket_read(sock, &(buffer[i]), 1, 1, &readed);
+    if (status != H_OK)
     {
         log_error1("Socket read error");
-        return NULL;
+        return status;
     }
 
     buffer[i+1] = '\0'; /* for strmp */
@@ -156,7 +158,8 @@ read_header: /* for errorcode: 100 (continue) */
   if (res == NULL)
   {
     log_error1("Header parse error");
-    return NULL;
+    return herror_new("hresponse_new_from_socket", 
+		GENERAL_HEADER_PARSE_ERROR, "Can not parse response header");
   }
 
   /* Chec for Errorcode: 100 (continue) */
@@ -179,7 +182,7 @@ read_header: /* for errorcode: 100 (continue) */
     {
       /* TODO (#1#): Handle error */
       hresponse_free(res);
-      return NULL;            
+      return status;            
     }
     else
     {
@@ -187,8 +190,8 @@ read_header: /* for errorcode: 100 (continue) */
       res->in = http_input_stream_new_from_file(mimeMessage->root_part->filename);
     }
   }
-     
-  return res;
+   *out = res;
+  return H_OK;
 }
 
 
diff --git a/nanohttp/nanohttp-response.h b/nanohttp/nanohttp-response.h
index 7607eb7..63dd463 100755
--- a/nanohttp/nanohttp-response.h
+++ b/nanohttp/nanohttp-response.h
@@ -1,5 +1,5 @@
 /******************************************************************
- *  $Id: nanohttp-response.h,v 1.1 2004/10/15 13:30:42 snowdrop Exp $
+ *  $Id: nanohttp-response.h,v 1.2 2004/10/28 10:30:46 snowdrop Exp $
  *
  * CSOAP Project:  A http client/server library in C
  * Copyright (C) 2003-2004  Ferhat Ayaz
@@ -43,7 +43,7 @@ typedef struct hresponse
   char root_part_id[150];
 }hresponse_t;
 
-hresponse_t *hresponse_new_from_socket(hsocket_t sock);
+herror_t hresponse_new_from_socket(hsocket_t sock, hresponse_t **out);
 void hresponse_free(hresponse_t *res); 
 
 
diff --git a/nanohttp/nanohttp-server.c b/nanohttp/nanohttp-server.c
index 2ee15c7..71dbba7 100644
--- a/nanohttp/nanohttp-server.c
+++ b/nanohttp/nanohttp-server.c
@@ -1,5 +1,5 @@
 /******************************************************************
-*  $Id: nanohttp-server.c,v 1.27 2004/10/20 14:17:41 snowdrop Exp $
+*  $Id: nanohttp-server.c,v 1.28 2004/10/28 10:30:46 snowdrop Exp $
 *
 * CSOAP Project:  A http client/server library in C
 * Copyright (C) 2003  Ferhat Ayaz
@@ -94,12 +94,13 @@ static void WSAReaper(void *x);
  * NOTE: This will be called from soap_server_init_args()
  * -----------------------------------------------------
  */
-int
+herror_t
 httpd_init (int argc, char *argv[])
 {
-  int i, status;
+  int i;
+  herror_t status;
   status = hsocket_module_init ();
-  if (status != 0)
+  if (status != H_OK)
     return status;
 
   /* write argument information */
@@ -136,12 +137,15 @@ httpd_init (int argc, char *argv[])
     memset ((char *) &_httpd_connection[i], 0, sizeof (_httpd_connection[i]));
   }
 
-#ifdef WIN32
+#ifdef WIN32
+  /*
   if (_beginthread (WSAReaper, 0, NULL) == -1)
   {
     log_error1 ("Winsock reaper thread failed to start");
-    return (-1);
-  }
+    return herror_new("httpd_init", THREAD_BEGIN_ERROR, 
+		"_beginthread() failed while starting WSAReaper");
+  }
+  */
 #endif
 
   /* create socket */
@@ -244,7 +248,7 @@ httpd_response_set_content_type (httpd_conn_t * res, const char *content_type)
  * FUNCTION: httpd_response_send_header
  * -----------------------------------------------------
  */
-int
+herror_t
 httpd_send_header (httpd_conn_t * res, int code, const char *text)
 {
   struct tm stm;
@@ -252,7 +256,7 @@ httpd_send_header (httpd_conn_t * res, int code, const char *text)
   char buffer[255];
   char header[1024];
   hpair_t *cur;
-  int status;
+  herror_t status;
 
   /* set status code */
   sprintf (header, "HTTP/1.1 %d %s\r\n", code, text);
@@ -291,9 +295,11 @@ httpd_send_header (httpd_conn_t * res, int code, const char *text)
 
   /* send header */
   status = hsocket_nsend (res->sock, header, strlen (header));
+	if (status != H_OK)
+		return status;
 
   res->out = http_output_stream_new (res->sock, res->header);
-  return status;
+  return H_OK;
 }
 
 
@@ -381,10 +387,12 @@ httpd_session_main (void *data)
   hrequest_t *req = NULL;       /* only for test */
   httpd_conn_t *rconn;
   hservice_t *service = NULL;
-  long content_length = 0;
+  long content_length = 0;
+  herror_t status;
 
   header[0] = '\0';
-  len = 0;
+  len = 0;
+
 
 
   log_verbose1 ("starting httpd_session_main()");
@@ -393,10 +401,11 @@ httpd_session_main (void *data)
 /*  req = hrequest_new_from_buffer (header);*/
   rconn = httpd_new(conn->sock);
 
-  req = hrequest_new_from_socket (conn->sock);
-  if (req == NULL)
+  status = hrequest_new_from_socket (conn->sock, &req);
+  if (status != H_OK)
   {
-    httpd_send_internal_error (rconn, "Request parse error!");
+    httpd_send_internal_error (rconn, herror_message(status)/*"Request parse error!"*/);
+	herror_release(status);
   }
   else
   {
@@ -597,10 +606,10 @@ _httpd_start_thread (conndata_t * conn)
  * -----------------------------------------------------
  */
 
-int
+herror_t
 httpd_run ()
 {
-  int err;
+  herror_t err;
   conndata_t *conn;
   fd_set fds;
   struct timeval timeout;
@@ -614,7 +623,7 @@ httpd_run ()
   err = hsocket_listen (_httpd_socket);
   if (err != H_OK)
   {
-    log_error2 ("httpd_run(): '%d'", err);
+    log_error2 ("httpd_run(): '%d'", herror_message(err));
     return err;
   }
   log_verbose2 ("listening to port '%d'", _httpd_port);
@@ -626,7 +635,7 @@ httpd_run ()
   err = hsocket_block (_httpd_socket, 0);
   if (err != H_OK)
   {
-    log_error2 ("httpd_run(): '%d'", err);
+    log_error2 ("httpd_run(): '%s'", herror_message(err));
     return err;
   }
 
@@ -673,8 +682,8 @@ httpd_run ()
     err = hsocket_accept (_httpd_socket, &(conn->sock));
     if (err != H_OK)
     {
-      log_error2 ("Can not accept socket: %d", err);
-      return -1;                /* this is hard core! */
+      log_error2 ("Can not accept socket: %s", herror_message(err));
+      return err;                /* this is hard core! */
     }
 
     /* Now start a thread */
@@ -805,7 +814,7 @@ _httpd_mime_get_boundary (httpd_conn_t * conn, char *dest)
   Begin MIME multipart/related POST 
   Returns: H_OK  or error flag
 */
-int
+herror_t
 httpd_mime_send_header (httpd_conn_t * conn,
                         const char *related_start,
                         const char *related_start_info,
@@ -861,12 +870,12 @@ httpd_mime_send_header (httpd_conn_t * conn,
   Send boundary and part header and continue 
   with next part
 */
-int
+herror_t
 httpd_mime_next (httpd_conn_t * conn,
                  const char *content_id,
                  const char *content_type, const char *transfer_encoding)
 {
-  int status;
+  herror_t status;
   char buffer[512];
   char boundary[75];
 
@@ -901,19 +910,20 @@ httpd_mime_next (httpd_conn_t * conn,
   Send boundary and part header and continue 
   with next part
 */
-int
+herror_t
 httpd_mime_send_file (httpd_conn_t * conn,
                       const char *content_id,
                       const char *content_type,
                       const char *transfer_encoding, const char *filename)
 {
-  int status;
+  herror_t status;
   FILE *fd = fopen (filename, "rb");
   byte_t buffer[MAX_FILE_BUFFER_SIZE];
   size_t size;
 
   if (fd == NULL)
-    return FILE_ERROR_OPEN;
+    return herror_new("httpd_mime_send_file", FILE_ERROR_OPEN,
+	 "Can not open file '%d'", filename);
 
   status =
     httpd_mime_next (conn, content_id, content_type, transfer_encoding);
@@ -929,7 +939,8 @@ httpd_mime_send_file (httpd_conn_t * conn,
     if (size == -1)
     {
       fclose (fd);
-      return FILE_ERROR_READ;
+          return herror_new("httpd_mime_send_file", FILE_ERROR_READ,
+		  "Can not read from file '%d'", filename);
     }
 
     status = http_output_stream_write (conn->out, buffer, size);
@@ -947,10 +958,10 @@ httpd_mime_send_file (httpd_conn_t * conn,
   Finish MIME request 
   Returns: H_OK  or error flag
 */
-int
+herror_t
 httpd_mime_end (httpd_conn_t * conn)
 {
-  int status;
+  herror_t status;
   char buffer[512];
   char boundary[75];
 
diff --git a/nanohttp/nanohttp-server.h b/nanohttp/nanohttp-server.h
index 513f4de..e344eba 100644
--- a/nanohttp/nanohttp-server.h
+++ b/nanohttp/nanohttp-server.h
@@ -1,5 +1,5 @@
 /******************************************************************
- *  $Id: nanohttp-server.h,v 1.7 2004/10/20 14:17:41 snowdrop Exp $
+ *  $Id: nanohttp-server.h,v 1.8 2004/10/28 10:30:46 snowdrop Exp $
  *
  * CSOAP Project:  A http client/server library in C
  * Copyright (C) 2003  Ferhat Ayaz
@@ -62,22 +62,23 @@ typedef struct tag_hservice
 /*
   Begin  httpd_* function set
  */
-int httpd_init(int argc, char *argv[]);
+herror_t httpd_init(int argc, char *argv[]);
 int httpd_register(const char* ctx,  httpd_service service);
-int httpd_run();
+herror_t httpd_run();
 void httpd_destroy();
 
 hservice_t *httpd_services();
 
-int httpd_send_header(httpd_conn_t *res, 
+herror_t httpd_send_header(httpd_conn_t *res, 
 		      int code, const char* text);
 
 int httpd_set_header(httpd_conn_t *conn, const char *key, const char* value);
 void httpd_set_headers(httpd_conn_t *conn, hpair_t *header);
-
+
+/*
 unsigned char *httpd_get_postdata(httpd_conn_t *conn, 
 			 hrequest_t *req, long *received, long max);
-
+*/
 /* --------------------------------------------------------------
  MIME RELATED FUNCTIONS
  ---------------------------------------------------------------*/
@@ -89,7 +90,7 @@ unsigned char *httpd_get_postdata(httpd_conn_t *conn,
   Begin MIME multipart/related POST 
   Returns: HSOCKET_OK  or error flag
 */
-int httpd_mime_send_header(httpd_conn_t *conn,
+herror_t httpd_mime_send_header(httpd_conn_t *conn,
   const char* related_start, 
   const char* related_start_info, 
   const char* related_type, int code, const char* text);
@@ -98,7 +99,7 @@ int httpd_mime_send_header(httpd_conn_t *conn,
   Send boundary and part header and continue 
   with next part
 */
-int httpd_mime_next(httpd_conn_t *conn, 
+herror_t httpd_mime_next(httpd_conn_t *conn, 
   const char* content_id,
   const char* content_type, 
   const char* transfer_encoding);
@@ -107,7 +108,7 @@ int httpd_mime_next(httpd_conn_t *conn,
   Send boundary and part header and continue 
   with next part
 */
-int httpd_mime_send_file(httpd_conn_t *conn, 
+herror_t httpd_mime_send_file(httpd_conn_t *conn, 
   const char* content_id,
   const char* content_type, 
   const char* transfer_encoding,
@@ -117,7 +118,7 @@ int httpd_mime_send_file(httpd_conn_t *conn,
   Finish MIME request 
   Returns: HSOCKET_OK  or error flag
 */
-int httpd_mime_end(httpd_conn_t *conn);
+herror_t httpd_mime_end(httpd_conn_t *conn);
 
 
 #endif
diff --git a/nanohttp/nanohttp-socket.c b/nanohttp/nanohttp-socket.c
index d7a1d59..7b378fc 100644
--- a/nanohttp/nanohttp-socket.c
+++ b/nanohttp/nanohttp-socket.c
@@ -1,5 +1,5 @@
 /******************************************************************
-*  $Id: nanohttp-socket.c,v 1.29 2004/10/20 14:17:41 snowdrop Exp $
+*  $Id: nanohttp-socket.c,v 1.30 2004/10/28 10:30:46 snowdrop Exp $
 *
 * CSOAP Project:  A http client/server library in C
 * Copyright (C) 2003  Ferhat Ayaz
@@ -73,7 +73,7 @@ FUNCTION: hsocket_module_init
 NOTE: This will be called from httpd_init()
 	for server and from httpc_init() for client
 ----------------------------------------------------*/
-hstatus_t
+herror_t
 hsocket_module_init ()
 {
 #ifdef WIN32
@@ -103,7 +103,7 @@ hsocket_module_destroy ()
 /*--------------------------------------------------
 FUNCTION: hsocket_init
 ----------------------------------------------------*/
-hstatus_t
+herror_t
 hsocket_init (hsocket_t * sock)
 {
   /* just set the descriptor to -1 */
@@ -123,7 +123,7 @@ hsocket_free (hsocket_t sock)
 /*--------------------------------------------------
 FUNCTION: hsocket_open
 ----------------------------------------------------*/
-hstatus_t
+herror_t
 hsocket_open (hsocket_t * dsock, const char *hostname, int port)
 {
   hsocket_t sock;
@@ -133,12 +133,12 @@ hsocket_open (hsocket_t * dsock, const char *hostname, int port)
 
   sock = socket (AF_INET, SOCK_STREAM, 0);
   if (sock <= 0)
-    return HSOCKET_ERROR_CREATE;
+    return herror_new("hsocket_open", HSOCKET_ERROR_CREATE, strerror (errno));
 
   /* Get host data */
   host = gethostbyname (hostname);
   if (host == NULL)
-    return HSOCKET_ERROR_GET_HOSTNAME;
+    return herror_new("hsocket_open", HSOCKET_ERROR_GET_HOSTNAME, strerror (errno));
 
   ip = inet_ntoa (*(struct in_addr *) *host->h_addr_list);
   address.sin_addr.s_addr = inet_addr (ip);
@@ -149,7 +149,7 @@ hsocket_open (hsocket_t * dsock, const char *hostname, int port)
 
   /* connect to the server */
   if (connect (sock, (struct sockaddr *) &address, sizeof (address)) != 0)
-    return HSOCKET_ERROR_CONNECT;
+    return herror_new("hsocket_open", HSOCKET_ERROR_CONNECT, "Connect to '%s:%d' failed", hostname, port);
 
   *dsock = sock;
   return H_OK;
@@ -158,7 +158,7 @@ hsocket_open (hsocket_t * dsock, const char *hostname, int port)
 /*--------------------------------------------------
 FUNCTION: hsocket_bind
 ----------------------------------------------------*/
-hstatus_t
+herror_t
 hsocket_bind (hsocket_t * dsock, int port)
 {
   hsocket_t sock;
@@ -169,7 +169,7 @@ hsocket_bind (hsocket_t * dsock, int port)
   if (sock == -1)
   {
     log_error2 ("Can not create socket: '%s'", strerror (errno));
-    return HSOCKET_ERROR_CREATE;
+    return herror_new("hsocket_bind", HSOCKET_ERROR_CREATE, strerror (errno));
   }
   /* bind socket */
   addr.sin_family = AF_INET;
@@ -181,7 +181,7 @@ hsocket_bind (hsocket_t * dsock, int port)
   if (bind (sock, (struct sockaddr *) &addr, sizeof (struct sockaddr)) == -1)
   {
     log_error2 ("Can not bind: '%s'", strerror (errno));
-    return HSOCKET_ERROR_BIND;
+    return herror_new("hsocket_bind", HSOCKET_ERROR_BIND, strerror (errno));
   }
   *dsock = sock;
   return H_OK;
@@ -190,7 +190,7 @@ hsocket_bind (hsocket_t * dsock, int port)
 /*----------------------------------------------------------
 FUNCTION: hsocket_accept
 ----------------------------------------------------------*/
-hstatus_t
+herror_t
 hsocket_accept (hsocket_t sock, hsocket_t * dest)
 {
   socklen_t asize;
@@ -198,7 +198,8 @@ hsocket_accept (hsocket_t sock, hsocket_t * dest)
   struct sockaddr_in addr;
 
   if (sock <= 0)
-    return  HSOCKET_ERROR_NOT_INITIALIZED;
+	return herror_new("hsocket_accept", HSOCKET_ERROR_NOT_INITIALIZED, 
+	 "Called hsocket_listen() before initializing!");
 
   asize = sizeof (struct sockaddr_in);
 #ifdef WIN32
@@ -207,7 +208,7 @@ hsocket_accept (hsocket_t sock, hsocket_t * dest)
     sockfd = accept (sock, (struct sockaddr *) &addr, &asize);
     if (sockfd == INVALID_SOCKET)   {
       if (WSAGetLastError () != WSAEWOULDBLOCK)
-        return HSOCKET_ERROR_ACCEPT;
+		return herror_new("hsocket_accept", HSOCKET_ERROR_ACCEPT, strerror (errno));
     } else  {
       break;
     }
@@ -216,7 +217,7 @@ hsocket_accept (hsocket_t sock, hsocket_t * dest)
 /* TODO (#1#): why not a loop like in win32? */
   sockfd = accept (sock, (struct sockaddr *) &addr, &asize);
   if (sockfd == -1) {
-    return HSOCKET_ERROR_ACCEPT;
+		return herror_new("hsocket_accept", HSOCKET_ERROR_ACCEPT, strerror (errno));
   }
 #endif 
 /* TODO (#1#): Write to access.log file */
@@ -231,16 +232,17 @@ hsocket_accept (hsocket_t sock, hsocket_t * dest)
 /*--------------------------------------------------
 FUNCTION: hsocket_listen
 ----------------------------------------------------*/
-hstatus_t
+herror_t
 hsocket_listen (hsocket_t sock)
 {
   if (sock <= 0)
-    return  HSOCKET_ERROR_NOT_INITIALIZED;
+	return herror_new("hsocket_listen", HSOCKET_ERROR_NOT_INITIALIZED, 
+	 "Called hsocket_listen() before initializing!");
 
   if (listen (sock, 15) == -1)
   {
     log_error2 ("Can not listen: '%s'", strerror (errno));
-    return HSOCKET_ERROR_LISTEN;
+	return herror_new("hsocket_listen", HSOCKET_ERROR_LISTEN, strerror (errno));
   }
 
   return H_OK;
@@ -315,34 +317,49 @@ hsocket_close (hsocket_t sock)
 #endif
   log_verbose1 ("closed");
 }
+
+
+static int _test_send_to_file(const char* filename, const byte_t* bytes,int n)
+{
+	int size;
+	FILE *f = fopen(filename, "ab");
+	if (!f) f = fopen(filename, "wb");
+	size= fwrite(bytes, 1, n, f);
+	fclose(f);
+	return size;
+}
 
 /*--------------------------------------------------
 FUNCTION: hsocket_send
 ----------------------------------------------------*/
-hstatus_t
+herror_t
 hsocket_nsend (hsocket_t sock, const byte_t *bytes, int n)
 {
   int size;
-
+  int total=0;
   if (sock <= 0)
-    return  HSOCKET_ERROR_NOT_INITIALIZED;
+	return herror_new("hsocket_nsend", HSOCKET_ERROR_NOT_INITIALIZED, 
+	 "Called hsocket_listen() before initializing!");
+
 
   /* TODO (#1#): check return value and send again until n bytes sent */
   
   while (1)
   {
-    size = send((int) sock, bytes, n, 0);
+    size = send((int) sock, bytes + total, n, 0);
+	 /* size = _test_send_to_file(filename, bytes, n);*/
 #ifdef WIN32
     if (size == INVALID_SOCKET)
         if (WSAGetLastError () == WSAEWOULDBLOCK)
           continue;
         else       
-          return HSOCKET_ERROR_SEND;
+		return herror_new("hsocket_nsend", HSOCKET_ERROR_SEND, strerror (errno));
 #else
     if (size == -1)
-        return HSOCKET_ERROR_SEND;
+		return herror_new("hsocket_nsend", HSOCKET_ERROR_SEND, strerror (errno));
 #endif
-    n -= size;
+    n -= size;
+	total += size;
     if (n<=0) break;
   }
   return H_OK;
@@ -351,7 +368,7 @@ hsocket_nsend (hsocket_t sock, const byte_t *bytes, int n)
 /*--------------------------------------------------
 FUNCTION: hsocket_send
 ----------------------------------------------------*/
-hstatus_t
+herror_t
 hsocket_send (hsocket_t sock, const char *str)
 {
   return hsocket_nsend (sock, str, strlen (str));
@@ -360,14 +377,16 @@ hsocket_send (hsocket_t sock, const char *str)
 /*
   return: -1 is error. read bytes otherwise
 */
-int
-hsocket_read (hsocket_t sock, byte_t *buffer, int total, int force)
+herror_t
+hsocket_read (hsocket_t sock, byte_t *buffer, int total, int force, int *received)
 {
   int status;
   int totalRead;
   int wsa_error;
   totalRead = 0;
-
+/*
+  log_verbose3("Entering hsocket_read(total=%d,force=%d)", total, force);
+*/
   do
   {
     status = recv(sock, &buffer[totalRead], total - totalRead, 0);
@@ -379,12 +398,12 @@ hsocket_read (hsocket_t sock, byte_t *buffer, int total, int force)
         switch (wsa_error)
         {
           case WSAEWOULDBLOCK: 
-          case WSAEALREADY:
-          case WSAEINPROGRESS:        
+         /* case WSAEALREADY:
+          case WSAEINPROGRESS:        */
              continue;
           default:
              log_error2("WSAGetLastError()=%d", wsa_error);
-             return -1;
+			return herror_new("hsocket_read", HSOCKET_ERROR_RECEIVE, strerror (errno));
         }
     }
 
@@ -398,24 +417,32 @@ hsocket_read (hsocket_t sock, byte_t *buffer, int total, int force)
    }
 */
     if (status == -1)
-        return -1;
+		return herror_new("hsocket_read", HSOCKET_ERROR_RECEIVE, strerror (errno));
 #endif
     
-    if (!force) {
-        return status;
+    if (!force) {
+		*received = status;
+		/*
+		log_verbose3("Leaving !force (received=%d)(status=%d)", *received, status);
+		*/
+        return H_OK;
     }
     
     totalRead += status;
 
     if (totalRead == total) {
-      return totalRead;
+		*received = totalRead;
+		/*
+		log_verbose4("Leaving totalRead == total (received=%d)(status=%d)(totalRead=%d)", *received, status, totalRead);
+		*/
+        return H_OK;
     }
   }
   while (1);
 }
 
 
-hstatus_t
+herror_t
 hsocket_block(hsocket_t sock, int block)
 {
 #ifdef WIN32
@@ -423,7 +450,8 @@ hsocket_block(hsocket_t sock, int block)
 #endif
 
   if (sock <= 0)
-    return  HSOCKET_ERROR_NOT_INITIALIZED;
+	return herror_new("hsocket_block", HSOCKET_ERROR_NOT_INITIALIZED, 
+	 "Called hsocket_listen() before initializing!");
 
 #ifdef WIN32
 /*#define HSOCKET_BLOCKMODE 0
@@ -434,7 +462,7 @@ hsocket_block(hsocket_t sock, int block)
   if (ioctlsocket (sock, FIONBIO, (u_long FAR *) & iMode) == INVALID_SOCKET)
   {
     log_error1 ("ioctlsocket error");
-    return HSOCKET_ERROR_IOCTL;
+		return herror_new("hsocket_block", HSOCKET_ERROR_IOCTL, strerror (errno));
   }
 #else /* fcntl(sock, F_SETFL, O_NONBLOCK); */
 /* TODO (#1#): check for *nix the non blocking sockets */
diff --git a/nanohttp/nanohttp-socket.h b/nanohttp/nanohttp-socket.h
index 8deb273..83d8f72 100644
--- a/nanohttp/nanohttp-socket.h
+++ b/nanohttp/nanohttp-socket.h
@@ -1,5 +1,5 @@
 /******************************************************************
- *  $Id: nanohttp-socket.h,v 1.13 2004/10/15 13:29:37 snowdrop Exp $
+ *  $Id: nanohttp-socket.h,v 1.14 2004/10/28 10:30:47 snowdrop Exp $
  *
  * CSOAP Project:  A http client/server library in C
  * Copyright (C) 2003  Ferhat Ayaz
@@ -48,7 +48,7 @@
 
   @returns This function should always return H_OK. 
  */
-hstatus_t hsocket_module_init();
+herror_t hsocket_module_init();
 
 
 /**
@@ -66,7 +66,7 @@ void hsocket_module_destroy();
 
   @returns This function should always return H_OK. 
  */
-hstatus_t hsocket_init(hsocket_t *sock);
+herror_t hsocket_init(hsocket_t *sock);
 
 
 /**
@@ -90,7 +90,7 @@ void hsocket_free(hsocket_t sock);
     <BR>HSOCKET_ERROR_GET_HOSTNAME 
     <BR>HSOCKET_ERROR_CONNECT
  */
-hstatus_t hsocket_open(hsocket_t *sock, const char* host, int port);
+herror_t hsocket_open(hsocket_t *sock, const char* host, int port);
 
 
 /**
@@ -114,7 +114,7 @@ void hsocket_close(hsocket_t sock);
 
   @see hsocket_listen
  */
-hstatus_t hsocket_bind(hsocket_t *sock, int port);
+herror_t hsocket_bind(hsocket_t *sock, int port);
 
 
 /**
@@ -128,7 +128,7 @@ hstatus_t hsocket_bind(hsocket_t *sock, int port);
     <BR>HSOCKET_ERROR_NOT_INITIALIZED
     <BR>HSOCKET_ERROR_LISTEN
 */
-hstatus_t hsocket_listen(hsocket_t sock);
+herror_t hsocket_listen(hsocket_t sock);
 
 
 /**
@@ -142,7 +142,7 @@ hstatus_t hsocket_listen(hsocket_t sock);
     <BR>HSOCKET_ERROR_NOT_INITIALIZED
     <BR>HSOCKET_ERROR_ACCEPT
 */
-hstatus_t hsocket_accept(hsocket_t sock, hsocket_t *dest);
+herror_t hsocket_accept(hsocket_t sock, hsocket_t *dest);
 
 
 /**
@@ -156,7 +156,7 @@ hstatus_t hsocket_accept(hsocket_t sock, hsocket_t *dest);
     <BR>HSOCKET_ERROR_NOT_INITIALIZED
     <BR>HSOCKET_ERROR_SEND
 */
-hstatus_t hsocket_nsend(hsocket_t sock, const byte_t* bytes, int size); 
+herror_t hsocket_nsend(hsocket_t sock, const byte_t* bytes, int size); 
 
 
 /**
@@ -169,7 +169,7 @@ hstatus_t hsocket_nsend(hsocket_t sock, const byte_t* bytes, int size);
     <BR>HSOCKET_ERROR_NOT_INITIALIZED
     <BR>HSOCKET_ERROR_SEND
 */
-hstatus_t hsocket_send(hsocket_t sock, const char* str); 
+herror_t hsocket_send(hsocket_t sock, const char* str); 
 
 
 /**
@@ -188,7 +188,7 @@ hstatus_t hsocket_send(hsocket_t sock, const char* str);
      the socket.
   
 */
-int hsocket_read(hsocket_t sock, byte_t* buffer, int size, int force);
+herror_t hsocket_read(hsocket_t sock, byte_t* buffer, int size, int force, int *readed);
 
 /**
   Sets the goven socket to non-blocking socket mode.
@@ -199,7 +199,7 @@ int hsocket_read(hsocket_t sock, byte_t* buffer, int size, int force);
     <BR>HSOCKET_ERROR_NOT_INITIALIZED
     <BR>HSOCKET_ERROR_IOCTL
 */
-hstatus_t hsocket_block(hsocket_t sock, int block);
+herror_t hsocket_block(hsocket_t sock, int block);
 
 
 #endif
diff --git a/nanohttp/nanohttp-stream.c b/nanohttp/nanohttp-stream.c
index 039eadc..991d2ab 100755
--- a/nanohttp/nanohttp-stream.c
+++ b/nanohttp/nanohttp-stream.c
@@ -1,5 +1,5 @@
 /******************************************************************
-*  $Id: nanohttp-stream.c,v 1.3 2004/10/20 14:17:41 snowdrop Exp $
+*  $Id: nanohttp-stream.c,v 1.4 2004/10/28 10:30:47 snowdrop Exp $
 *
 * CSOAP Project:  A http client/server library in C
 * Copyright (C) 2003-2004  Ferhat Ayaz
@@ -180,21 +180,22 @@ static
 int _http_input_stream_content_length_read(
   http_input_stream_t *stream, byte_t *dest, int size)
 {
-  int status;
+  herror_t status;
+  int read;
 
   /* check limit */
   if (stream->content_length - stream->received < size)
     size = stream->content_length - stream->received;
 
   /* read from socket */
-  status = hsocket_read(stream->sock, dest, size, 1);
-  if (status == -1) {
-    stream->err = HSOCKET_ERROR_RECEIVE;
+  status = hsocket_read(stream->sock, dest, size, 1, &read);
+  if (status != H_OK) {
+    stream->err = status;
     return -1;
   }
 
-  stream->received += status;
-  return status;
+  stream->received += read;
+  return read;
 }
 
 static 
@@ -203,14 +204,22 @@ int _http_input_stream_chunked_read_chunk_size(
 {
   char  chunk[25];
   int status, i = 0;
-  int chunk_size;
+  int chunk_size;
+  herror_t err;
   
   while (1)
   {
-    status = hsocket_read(stream->sock, &(chunk[i]), 1, 1);
-
-    if (status == -1) {
-      stream->err = HSOCKET_ERROR_RECEIVE;
+    err = hsocket_read(stream->sock, &(chunk[i]), 1, 1, &status);
+	if (status != 1) {
+      stream->err = herror_new("_http_input_stream_chunked_read_chunk_size",
+		  GENERAL_INVALID_PARAM, "This should never happens!");
+      return -1;
+	}
+
+    if (err != H_OK) {
+	log_error4("[%d] %s(): %s ", herror_code(err), herror_func(err), herror_message(err));
+		
+      stream->err = err;
       return -1;
     }
 
@@ -221,13 +230,17 @@ int _http_input_stream_chunked_read_chunk_size(
     else if (chunk[i] == '\n')
     {
         chunk[i] = '\0'; /* double check*/
-  			chunk_size = strtol(chunk, (char **) NULL, 16);	/* hex to dec */
-/*  			log_verbose3("chunk_size: '%s' as dec: '%d'", chunk, chunk_size);*/
+  			chunk_size = strtol(chunk, (char **) NULL, 16);	/* hex to dec */
+			/*
+  			log_verbose3("chunk_size: '%s' as dec: '%d'", chunk, chunk_size);
+			*/
   			return chunk_size;
     }
     
     if (i == 24) {
-        stream->err = STREAM_ERROR_NO_CHUNK_SIZE;
+        stream->err = herror_new(
+			"_http_input_stream_chunked_read_chunk_size", STREAM_ERROR_NO_CHUNK_SIZE,
+			"reached max line == %d", i);
         return -1;
     }
     else
@@ -235,8 +248,10 @@ int _http_input_stream_chunked_read_chunk_size(
   }
 
   /* this should never happens */
-  stream->err = STREAM_ERROR_NO_CHUNK_SIZE;
-  return -1;
+    stream->err = herror_new(
+		"_http_input_stream_chunked_read_chunk_size", STREAM_ERROR_NO_CHUNK_SIZE,
+		"reached max line == %d", i);
+    return -1;
 }
 
 static 
@@ -245,7 +260,8 @@ int _http_input_stream_chunked_read(
 {
   int status, counter;
   int remain, read=0;
-  char ch;
+  char ch;
+  herror_t err;
 
   while (size > 0)
   {
@@ -258,10 +274,10 @@ int _http_input_stream_chunked_read(
         counter = 100; /* maximum for stop infinity */
         while (1)
         {
-          status = hsocket_read(stream->sock, &ch, 1, 1);
+          err = hsocket_read(stream->sock, &ch, 1, 1, &status );
       
-          if (status == -1) {
-            stream->err = HSOCKET_ERROR_RECEIVE;
+          if (err != H_OK) {
+            stream->err = err;
             return -1;
           }
       
@@ -270,7 +286,8 @@ int _http_input_stream_chunked_read(
               break;
           }
           if (counter-- == 0) {
-            stream->err = STREAM_ERROR_WRONG_CHUNK_SIZE;
+            stream->err = herror_new("_http_input_stream_chunked_read", 
+				STREAM_ERROR_WRONG_CHUNK_SIZE,"Wrong chunk-size");
             return -1;
           }
         }
@@ -298,20 +315,29 @@ int _http_input_stream_chunked_read(
     /* show remaining chunk size in socket */
     if (remain < size)
     {
-      /* read from socket */
-      status = hsocket_read(stream->sock, &(dest[read]), remain, 1);
-      if (status == -1) {
-        stream->err = HSOCKET_ERROR_RECEIVE;
-        return -1;
-      }
-
+      /* read from socket */
+      err = hsocket_read(stream->sock, &(dest[read]), remain, 1, &status);
+      if (err != H_OK) {
+        stream->err = err;
+        return -1;
+      }
+		if (status != remain) {
+		  stream->err = herror_new("_http_input_stream_chunked_read",
+			  GENERAL_INVALID_PARAM, "This should never happens(remain=%d)(status=%d)!", remain, status);
+		  return -1;
+		}
     }
     else
     {
       /* read from socket */
-      status = hsocket_read(stream->sock, &(dest[read]), size, 1);
-      if (status == -1) {
-        stream->err = HSOCKET_ERROR_RECEIVE;
+      err = hsocket_read(stream->sock, &(dest[read]), size, 1, &status);
+		if (status != size) {
+		  stream->err = herror_new("_http_input_stream_chunked_read",
+			  GENERAL_INVALID_PARAM, "This should never happens(size=%d)(status=%d)!", size, status);
+		  return -1;
+		}
+      if (err != H_OK) {
+        stream->err = err;
         return -1;
       }
     }
@@ -330,11 +356,12 @@ int _http_input_stream_connection_closed_read(
   http_input_stream_t *stream, byte_t *dest, int size)
 {
   int status;
+  herror_t err;
 
   /* read from socket */
-  status = hsocket_read(stream->sock, dest, size, 0);
-  if (status == -1) {
-    stream->err = HSOCKET_ERROR_RECEIVE;
+  err = hsocket_read(stream->sock, dest, size, 0, &status );
+  if (err != H_OK) {
+    stream->err = err;
     return -1;
   }
 
@@ -354,7 +381,8 @@ int _http_input_stream_file_read(
   
   readed = fread(dest, 1, size, stream->fd);
   if (readed == -1) {
-    stream->err = HSOCKET_ERROR_RECEIVE;
+    stream->err = herror_new("_http_input_stream_file_read", 
+			HSOCKET_ERROR_RECEIVE, "fread() returned -1");
     return -1;
   }
 
@@ -420,7 +448,8 @@ int http_input_stream_read(http_input_stream_t *stream,
         readed=_http_input_stream_file_read(stream, dest, size);
         break;
     default:
-        stream->err = STREAM_ERROR_INVALID_TYPE;
+        stream->err = herror_new("http_input_stream_read", 
+			STREAM_ERROR_INVALID_TYPE, "%d is invalid stream type", stream->type);
         return -1;
   }
 
@@ -493,10 +522,10 @@ void http_output_stream_free(http_output_stream_t *stream)
   Writes 'size' bytes of 'bytes' into stream.
   Returns socket error flags or H_OK.
 */
-hstatus_t http_output_stream_write(http_output_stream_t *stream, 
+herror_t http_output_stream_write(http_output_stream_t *stream, 
                            const byte_t *bytes, int size)
 {
-  int status;
+  herror_t status;
   char chunked[15];
 
   if (stream->type == HTTP_TRANSFER_CHUNKED)
@@ -529,16 +558,16 @@ hstatus_t http_output_stream_write(http_output_stream_t *stream,
   Writes 'strlen()' bytes of 'str' into stream.
   Returns socket error flags or H_OK.
 */
-int http_output_stream_write_string(http_output_stream_t *stream, 
+herror_t http_output_stream_write_string(http_output_stream_t *stream, 
                            const char *str)
 {
   return  http_output_stream_write(stream, str, strlen(str));
 }
 
 
-int http_output_stream_flush(http_output_stream_t *stream)
+herror_t http_output_stream_flush(http_output_stream_t *stream)
 {
-  int status;
+  herror_t status;
 
   if (stream->type == HTTP_TRANSFER_CHUNKED)
   {
diff --git a/nanohttp/nanohttp-stream.h b/nanohttp/nanohttp-stream.h
index fb44284..7b0f0f8 100755
--- a/nanohttp/nanohttp-stream.h
+++ b/nanohttp/nanohttp-stream.h
@@ -1,5 +1,5 @@
 /******************************************************************
- *  $Id: nanohttp-stream.h,v 1.2 2004/10/15 14:26:15 snowdrop Exp $
+ *  $Id: nanohttp-stream.h,v 1.3 2004/10/28 10:30:47 snowdrop Exp $
  *
  * CSOAP Project:  A http client/server library in C
  * Copyright (C) 2003-2004  Ferhat Ayaz
@@ -88,7 +88,7 @@ typedef enum http_transfer_type
 typedef struct http_input_stream
 {
   hsocket_t sock; 
-  hstatus_t err;
+  herror_t err;
   http_transfer_type_t type; 
   int received;
   int content_length;
@@ -236,7 +236,7 @@ void http_output_stream_free(http_output_stream_t *stream);
     <BR>HSOCKET_ERROR_NOT_INITIALIZED
     <BR>HSOCKET_ERROR_SEND
 */
-hstatus_t http_output_stream_write(http_output_stream_t *stream, 
+herror_t http_output_stream_write(http_output_stream_t *stream, 
                            const byte_t *bytes, int size);
 
 /**
@@ -249,7 +249,7 @@ hstatus_t http_output_stream_write(http_output_stream_t *stream,
     <BR>HSOCKET_ERROR_NOT_INITIALIZED
     <BR>HSOCKET_ERROR_SEND
 */
-hstatus_t http_output_stream_write_string(http_output_stream_t *stream, 
+herror_t http_output_stream_write_string(http_output_stream_t *stream, 
                            const char *str);
 
 
@@ -263,7 +263,7 @@ hstatus_t http_output_stream_write_string(http_output_stream_t *stream,
     <BR>HSOCKET_ERROR_NOT_INITIALIZED
     <BR>HSOCKET_ERROR_SEND
 */
-hstatus_t http_output_stream_flush(http_output_stream_t *stream);
+herror_t http_output_stream_flush(http_output_stream_t *stream);
 
 #endif