From c24e5b5135d745098ea6e5c4664a88ada6b99225 Mon Sep 17 00:00:00 2001
From: snowdrop
Date: Tue, 10 Jan 2006 11:21:55 +0000
Subject: indent with 'indent -nut -bli0 -fca' command
---
libcsoap/soap-server.c | 589 ++++++++++++++++++++++++++-----------------------
1 file changed, 318 insertions(+), 271 deletions(-)
(limited to 'libcsoap/soap-server.c')
diff --git a/libcsoap/soap-server.c b/libcsoap/soap-server.c
index 591ecc0..9daf639 100644
--- a/libcsoap/soap-server.c
+++ b/libcsoap/soap-server.c
@@ -1,5 +1,5 @@
/******************************************************************
-* $Id: soap-server.c,v 1.12 2005/12/19 14:06:16 snowdrop Exp $
+* $Id: soap-server.c,v 1.13 2006/01/10 11:21:55 snowdrop Exp $
*
* CSOAP Project: A SOAP client/server library in C
* Copyright (C) 2003 Ferhat Ayaz
@@ -28,362 +28,409 @@
typedef struct _SoapRouterNode
{
- char *context;
- SoapRouter *router;
- struct _SoapRouterNode *next;
+ char *context;
+ SoapRouter *router;
+ struct _SoapRouterNode *next;
-}SoapRouterNode;
+} SoapRouterNode;
SoapRouterNode *head = NULL;
SoapRouterNode *tail = NULL;
static
-SoapRouterNode *router_node_new(SoapRouter *router,
- const char *context,
- SoapRouterNode *next);
+ SoapRouterNode *router_node_new (SoapRouter * router,
+ const char *context,
+ SoapRouterNode * next);
-static
-SoapRouter *router_find(const char *context);
+static SoapRouter *router_find (const char *context);
-static
-void _soap_server_send_ctx(httpd_conn_t* conn, SoapCtx *ctxres);
+static void _soap_server_send_ctx (httpd_conn_t * conn, SoapCtx * ctxres);
/*---------------------------------*/
-void soap_server_entry(httpd_conn_t *conn, hrequest_t *req);
+void soap_server_entry (httpd_conn_t * conn, hrequest_t * req);
+static void _soap_server_send_env (http_output_stream_t * out, SoapEnv * env);
static
-void _soap_server_send_env(http_output_stream_t *out, SoapEnv* env);
-static
-void _soap_server_send_fault(httpd_conn_t *conn, hpair_t *header,
- const char* errmsg);
+ void _soap_server_send_fault (httpd_conn_t * conn, hpair_t * header,
+ const char *errmsg);
/*---------------------------------*/
-herror_t 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);
}
-int soap_server_register_router(SoapRouter *router, const char* context)
+int
+soap_server_register_router (SoapRouter * router, const char *context)
{
- if (!httpd_register(context, soap_server_entry)) {
- return 0;
- }
-
- if (tail == NULL) {
- head = tail = router_node_new(router, context, NULL);
- } else {
- tail->next = router_node_new(router, context, NULL);
- tail = tail->next;
- }
-
- return 1;
+ if (!httpd_register (context, soap_server_entry))
+ {
+ return 0;
+ }
+
+ if (tail == NULL)
+ {
+ head = tail = router_node_new (router, context, NULL);
+ }
+ else
+ {
+ tail->next = router_node_new (router, context, NULL);
+ tail = tail->next;
+ }
+
+ return 1;
}
-herror_t soap_server_run()
+herror_t
+soap_server_run ()
{
- return httpd_run();
+ return httpd_run ();
}
-void soap_server_destroy()
+void
+soap_server_destroy ()
{
- SoapRouterNode *node = head;
- SoapRouterNode *tmp;
-
- while (node != NULL) {
- tmp = node->next;
- log_verbose2("soap_router_free(%p)", node->router);
- soap_router_free(node->router);
- free(node->context);
- free(node);
- node = tmp;
- }
- httpd_destroy();
+ SoapRouterNode *node = head;
+ SoapRouterNode *tmp;
+
+ while (node != NULL)
+ {
+ tmp = node->next;
+ log_verbose2 ("soap_router_free(%p)", node->router);
+ soap_router_free (node->router);
+ free (node->context);
+ free (node);
+ node = tmp;
+ }
+ httpd_destroy ();
}
-void soap_server_entry(httpd_conn_t *conn, hrequest_t *req)
+void
+soap_server_entry (httpd_conn_t * conn, hrequest_t * req)
{
- hpair_t *header = NULL;
- char buffer[1054];
- char urn[150];
- char method[150];
- SoapCtx *ctx, *ctxres;
- SoapRouter *router;
- SoapService *service;
- SoapEnv *env;
- herror_t err;
-
- if (req->method != HTTP_REQUEST_POST) {
-
- httpd_send_header(conn, 200, "OK");
- http_output_stream_write_string(conn->out, "");
- http_output_stream_write_string(conn->out, "Sorry!
");
- http_output_stream_write_string(conn->out, "I only speak with 'POST' method");
- http_output_stream_write_string(conn->out, "");
- return;
- }
-
-
- 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) {
-
- _soap_server_send_fault(conn, header,"Can not receive POST data!");
-
- } else {
-
- ctx = soap_ctx_new(env);
- soap_ctx_add_files(ctx, req->attachments);
+ hpair_t *header = NULL;
+ char buffer[1054];
+ char urn[150];
+ char method[150];
+ SoapCtx *ctx, *ctxres;
+ SoapRouter *router;
+ SoapService *service;
+ SoapEnv *env;
+ herror_t err;
- if (ctx->env == NULL) {
+ if (req->method != HTTP_REQUEST_POST)
+ {
- _soap_server_send_fault(conn, header,"Can not parse POST data!");
+ httpd_send_header (conn, 200, "OK");
+ http_output_stream_write_string (conn->out, "");
+ http_output_stream_write_string (conn->out, "Sorry!
");
+ http_output_stream_write_string (conn->out,
+ "I only speak with 'POST' method");
+ http_output_stream_write_string (conn->out, "");
+ return;
+ }
- } else {
- /*soap_xml_doc_print(env->root->doc);*/
+ header = hpairnode_new (HEADER_CONTENT_TYPE, "text/xml", NULL);
- router = router_find(req->path);
+ 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 ( router == NULL) {
- _soap_server_send_fault(conn, header, "Can not find router!");
+ if (env == NULL)
+ {
- } else {
+ _soap_server_send_fault (conn, header, "Can not receive POST data!");
- if (!soap_env_find_urn(ctx->env, urn)) {
+ }
+ else
+ {
- _soap_server_send_fault(conn, header, "No URN found!");
- soap_ctx_free(ctx);
- return;
- } else {
- log_verbose2("urn: '%s'", urn);
- }
+ ctx = soap_ctx_new (env);
+ soap_ctx_add_files (ctx, req->attachments);
- if (!soap_env_find_methodname(ctx->env, method)) {
+ if (ctx->env == NULL)
+ {
- _soap_server_send_fault(conn, header, "No method found!");
- soap_ctx_free(ctx);
- return;
- }else {
- log_verbose2("method: '%s'", method);
- }
+ _soap_server_send_fault (conn, header, "Can not parse POST data!");
- service = soap_router_find_service(router, urn, method);
+ }
+ else
+ {
- if (service == NULL) {
+ /* soap_xml_doc_print(env->root->doc); */
- sprintf(buffer, "URN '%s' not found", urn);
- _soap_server_send_fault(conn, header, buffer);
- soap_ctx_free(ctx);
- return;
- } else {
+ router = router_find (req->path);
- log_verbose2("func: %p", service->func);
- ctxres = soap_ctx_new(NULL);
- /* ===================================== */
- /* CALL SERVICE FUNCTION */
- /* ===================================== */
- 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 (router == NULL)
+ {
- if (ctxres->env == NULL) {
+ _soap_server_send_fault (conn, header, "Can not find router!");
- sprintf(buffer, "Service '%s' returned no envelope", urn);
- _soap_server_send_fault(conn, header, buffer);
- soap_ctx_free(ctx);
- return;
-
- } else {
+ }
+ else
+ {
+
+ if (!soap_env_find_urn (ctx->env, urn))
+ {
+
+ _soap_server_send_fault (conn, header, "No URN found!");
+ soap_ctx_free (ctx);
+ return;
+ }
+ else
+ {
+ log_verbose2 ("urn: '%s'", urn);
+ }
+
+ if (!soap_env_find_methodname (ctx->env, method))
+ {
+
+ _soap_server_send_fault (conn, header, "No method found!");
+ soap_ctx_free (ctx);
+ return;
+ }
+ else
+ {
+ log_verbose2 ("method: '%s'", method);
+ }
+
+ service = soap_router_find_service (router, urn, method);
+
+ if (service == NULL)
+ {
+
+ sprintf (buffer, "URN '%s' not found", urn);
+ _soap_server_send_fault (conn, header, buffer);
+ soap_ctx_free (ctx);
+ return;
+ }
+ else
+ {
+
+ log_verbose2 ("func: %p", service->func);
+ ctxres = soap_ctx_new (NULL);
+ /* ===================================== */
+ /* CALL SERVICE FUNCTION */
+ /* ===================================== */
+ 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);
+ soap_ctx_free (ctx);
+ return;
+
+ }
+ else
+ {
/* httpd_send_header(conn, 200, "OK");
_soap_server_send_env(conn->out, ctxres->env);
*/
- _soap_server_send_ctx(conn, ctxres);
- /* free envctx */
- soap_ctx_free(ctxres);
- }
+ _soap_server_send_ctx (conn, ctxres);
+ /* free envctx */
+ soap_ctx_free (ctxres);
+ }
- }
+ }
- }
- }
- soap_ctx_free(ctx);
- }
+ }
+ }
+ soap_ctx_free (ctx);
+ }
}
-static
-void _soap_server_send_ctx(httpd_conn_t* conn, SoapCtx *ctx)
+static void
+_soap_server_send_ctx (httpd_conn_t * conn, SoapCtx * ctx)
{
- xmlBufferPtr buffer;
- static int counter = 1;
- char strbuffer[150];
- part_t *part;
+ xmlBufferPtr buffer;
+ static int counter = 1;
+ char strbuffer[150];
+ part_t *part;
- if (ctx->env == NULL || ctx->env->root == NULL) return;
+ if (ctx->env == NULL || ctx->env->root == NULL)
+ return;
- buffer = xmlBufferCreate();
+ buffer = xmlBufferCreate ();
/* xmlIndentTreeOutput = 1;*/
- xmlThrDefIndentTreeOutput(1);
+ xmlThrDefIndentTreeOutput (1);
/* xmlKeepBlanksDefault(0);*/
- xmlNodeDump(buffer, ctx->env->root->doc, ctx->env->root, 1 ,1);
-
- if (ctx->attachments)
- {
- sprintf(strbuffer, "000128590350940924234%d", counter++);
- httpd_mime_send_header(conn, strbuffer, "", "text/xml", 200, "OK");
- httpd_mime_next(conn, strbuffer, "text/xml", "binary");
- http_output_stream_write_string(conn->out, (const char*)xmlBufferContent(buffer));
- part = ctx->attachments->parts;
- while (part)
- {
- httpd_mime_send_file(conn, part->id, part->content_type, part->transfer_encoding, part->filename);
- part = part->next;
- }
- httpd_mime_end(conn);
- }
- else
- {
- char buflen[100];
- xmlXPathContextPtr xpathCtx;
- xmlXPathObjectPtr xpathObj;
- xpathCtx = xmlXPathNewContext(ctx->env->root->doc);
- xpathObj = xmlXPathEvalExpression("//Fault", xpathCtx);
+ xmlNodeDump (buffer, ctx->env->root->doc, ctx->env->root, 1, 1);
+
+ if (ctx->attachments)
+ {
+ sprintf (strbuffer, "000128590350940924234%d", counter++);
+ httpd_mime_send_header (conn, strbuffer, "", "text/xml", 200, "OK");
+ httpd_mime_next (conn, strbuffer, "text/xml", "binary");
+ http_output_stream_write_string (conn->out,
+ (const char *)
+ xmlBufferContent (buffer));
+ part = ctx->attachments->parts;
+ while (part)
+ {
+ httpd_mime_send_file (conn, part->id, part->content_type,
+ part->transfer_encoding, part->filename);
+ part = part->next;
+ }
+ httpd_mime_end (conn);
+ }
+ else
+ {
+ char buflen[100];
+ xmlXPathContextPtr xpathCtx;
+ xmlXPathObjectPtr xpathObj;
+ xpathCtx = xmlXPathNewContext (ctx->env->root->doc);
+ xpathObj = xmlXPathEvalExpression ("//Fault", xpathCtx);
#ifdef WIN32
#define snprintf(buffer, num, s1, s2) sprintf(buffer, s1,s2)
#endif
- snprintf(buflen,100,"%d", strlen((const char*)xmlBufferContent (buffer)));
- httpd_set_header (conn, HEADER_CONTENT_LENGTH, buflen);
- if((xpathObj->nodesetval) ? xpathObj->nodesetval->nodeNr : 0){
- httpd_send_header(conn, 500, "FAILED");
- } else {
- httpd_send_header(conn, 200, "OK");
- }
-
- http_output_stream_write_string(conn->out, (const char*)xmlBufferContent(buffer));
- xmlXPathFreeObject(xpathObj);
- xmlXPathFreeContext(xpathCtx);
-
- }
- xmlBufferFree(buffer);
+ snprintf (buflen, 100, "%d",
+ strlen ((const char *) xmlBufferContent (buffer)));
+ httpd_set_header (conn, HEADER_CONTENT_LENGTH, buflen);
+ if ((xpathObj->nodesetval) ? xpathObj->nodesetval->nodeNr : 0)
+ {
+ httpd_send_header (conn, 500, "FAILED");
+ }
+ else
+ {
+ httpd_send_header (conn, 200, "OK");
+ }
+
+ http_output_stream_write_string (conn->out,
+ (const char *)
+ xmlBufferContent (buffer));
+ xmlXPathFreeObject (xpathObj);
+ xmlXPathFreeContext (xpathCtx);
+
+ }
+ xmlBufferFree (buffer);
}
-static
-void _soap_server_send_env(http_output_stream_t *out, SoapEnv* env)
+static void
+_soap_server_send_env (http_output_stream_t * out, SoapEnv * env)
{
- xmlBufferPtr buffer;
- if (env == NULL || env->root == NULL) return;
+ xmlBufferPtr buffer;
+ if (env == NULL || env->root == NULL)
+ return;
- buffer = xmlBufferCreate();
- xmlNodeDump(buffer, env->root->doc, env->root, 1 ,1);
- http_output_stream_write_string(out, (const char*)xmlBufferContent(buffer));
- xmlBufferFree(buffer);
+ buffer = xmlBufferCreate ();
+ xmlNodeDump (buffer, env->root->doc, env->root, 1, 1);
+ http_output_stream_write_string (out,
+ (const char *) xmlBufferContent (buffer));
+ xmlBufferFree (buffer);
}
-static
-void _soap_server_send_fault(httpd_conn_t *conn, hpair_t *header,
- const char* errmsg)
+static void
+_soap_server_send_fault (httpd_conn_t * conn, hpair_t * header,
+ const char *errmsg)
{
- SoapEnv *envres;
- herror_t err;
- char buffer[45];
- httpd_set_headers(conn, header);
- 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, &envres);
- if (err != H_OK) {
- log_error1(herror_message(err));
- http_output_stream_write_string(conn->out, "");
- http_output_stream_write_string(conn->out, "Error
");
- http_output_stream_write_string(conn->out, "Error while sending fault object:
Message: ");
- http_output_stream_write_string(conn->out, herror_message(err));
- http_output_stream_write_string(conn->out, "
Function: ");
- http_output_stream_write_string(conn->out, herror_func(err));
- http_output_stream_write_string(conn->out, "
Error code: ");
- sprintf(buffer, "%d", herror_code(err));
- http_output_stream_write_string(conn->out, buffer);
- http_output_stream_write_string(conn->out, "");
- return;
-
- herror_release(err);
- } else {
- _soap_server_send_env(conn->out, envres);
- }
+ SoapEnv *envres;
+ herror_t err;
+ char buffer[45];
+ httpd_set_headers (conn, header);
+ 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, &envres);
+ if (err != H_OK)
+ {
+ log_error1 (herror_message (err));
+ http_output_stream_write_string (conn->out, "");
+ http_output_stream_write_string (conn->out, "Error
");
+ http_output_stream_write_string (conn->out,
+ "Error while sending fault object:
Message: ");
+ http_output_stream_write_string (conn->out, herror_message (err));
+ http_output_stream_write_string (conn->out, "
Function: ");
+ http_output_stream_write_string (conn->out, herror_func (err));
+ http_output_stream_write_string (conn->out, "
Error code: ");
+ sprintf (buffer, "%d", herror_code (err));
+ http_output_stream_write_string (conn->out, buffer);
+ http_output_stream_write_string (conn->out, "");
+ return;
+
+ herror_release (err);
+ }
+ else
+ {
+ _soap_server_send_env (conn->out, envres);
+ }
}
-static
-SoapRouterNode *router_node_new(SoapRouter *router,
- const char *context,
- SoapRouterNode *next)
+static SoapRouterNode *
+router_node_new (SoapRouter * router,
+ const char *context, SoapRouterNode * next)
{
- SoapRouterNode *node;
- const char *noname = "/lost_found";
-
- node = (SoapRouterNode*)malloc(sizeof(SoapRouterNode));
- if (context) {
- node->context = (char*)malloc(strlen(context)+1);
- strcpy(node->context, context);
- } else {
- log_warn2("context is null. Using '%s'", noname);
- node->context = (char*)malloc(strlen(noname)+1);
- strcpy(node->context, noname);
- }
-
- node->router = router;
- node->next = next;
-
- return node;
+ SoapRouterNode *node;
+ const char *noname = "/lost_found";
+
+ node = (SoapRouterNode *) malloc (sizeof (SoapRouterNode));
+ if (context)
+ {
+ node->context = (char *) malloc (strlen (context) + 1);
+ strcpy (node->context, context);
+ }
+ else
+ {
+ log_warn2 ("context is null. Using '%s'", noname);
+ node->context = (char *) malloc (strlen (noname) + 1);
+ strcpy (node->context, noname);
+ }
+
+ node->router = router;
+ node->next = next;
+
+ return node;
}
-static
-SoapRouter *router_find(const char* context)
+static SoapRouter *
+router_find (const char *context)
{
- SoapRouterNode *node = head;
+ SoapRouterNode *node = head;
- while (node != NULL) {
- if (!strcmp(node->context, context))
- return node->router;
- node = node->next;
- }
+ while (node != NULL)
+ {
+ if (!strcmp (node->context, context))
+ return node->router;
+ node = node->next;
+ }
- return NULL;
+ return NULL;
}
-
-
-
-
-
--
cgit v1.1-32-gdbae