axis-java-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sam...@apache.org
Subject svn commit: r356130 - in /webservices/axis2/trunk/c/modules/core/engine/src: Makefile.am soap_body_disp.c
Date Mon, 12 Dec 2005 03:32:48 GMT
Author: samisa
Date: Sun Dec 11 19:32:39 2005
New Revision: 356130

URL: http://svn.apache.org/viewcvs?rev=356130&view=rev
Log:
Initial SOAP body based dispatcher. 
There are commented blocks to be incommented when SOAP module is complete.

Added:
    webservices/axis2/trunk/c/modules/core/engine/src/soap_body_disp.c
Modified:
    webservices/axis2/trunk/c/modules/core/engine/src/Makefile.am

Modified: webservices/axis2/trunk/c/modules/core/engine/src/Makefile.am
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/c/modules/core/engine/src/Makefile.am?rev=356130&r1=356129&r2=356130&view=diff
==============================================================================
--- webservices/axis2/trunk/c/modules/core/engine/src/Makefile.am (original)
+++ webservices/axis2/trunk/c/modules/core/engine/src/Makefile.am Sun Dec 11 19:32:39 2005
@@ -1,7 +1,7 @@
 lib_LTLIBRARIES = libaxis2_engine.la
 AM_CPPFLAGS = $(CPPFLAGS)
 libaxis2_engine_la_SOURCES = handler.c msg_recv.c engine_config.c phase.c disp_checker.c
event.c \
-                             addr_disp.c req_uri_disp.c soap_action_disp.c
+                             addr_disp.c req_uri_disp.c soap_action_disp.c soap_body_disp.c
 
 libaxis2_engine_la_LIBADD = $(LDFLAGS)
 INCLUDES = -I${CUTEST_HOME}/include \

Added: webservices/axis2/trunk/c/modules/core/engine/src/soap_body_disp.c
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/c/modules/core/engine/src/soap_body_disp.c?rev=356130&view=auto
==============================================================================
--- webservices/axis2/trunk/c/modules/core/engine/src/soap_body_disp.c (added)
+++ webservices/axis2/trunk/c/modules/core/engine/src/soap_body_disp.c Sun Dec 11 19:32:39
2005
@@ -0,0 +1,152 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <axis2_disp.h>
+#include <axis2_handler_desc.h>
+#include <axis2_qname.h>
+#include <axis2_relates_to.h>
+#include <axis2_svc.h>
+#include <axis2.h>
+#include <axis2_conf_ctx.h>
+#include <axis2_addr.h>
+#include <axis2_utils.h>
+
+axis2_status_t AXIS2_CALL axis2_soap_body_disp_invoke (struct axis2_handler * handler, 
+                                                axis2_env_t **env,
+                                                struct axis2_msg_ctx *msg_ctx);
+axis2_svc_t* AXIS2_CALL axis2_soap_body_disp_find_svc(axis2_msg_ctx_t *msg_ctx,
+                    axis2_env_t **env);
+axis2_operation_t* AXIS2_CALL axis2_soap_body_disp_find_operation(axis2_msg_ctx_t *msg_ctx,

+                                axis2_env_t **env,
+                                axis2_svc_t *svc);
+
+
+axis2_disp_t* AXIS2_CALL axis2_soap_body_disp_create(axis2_env_t **env) 
+{
+    axis2_disp_t *disp = NULL;
+    axis2_handler_t *handler = NULL;
+    axis2_qname_t *qname = NULL;
+    
+    AXIS2_ENV_CHECK(env, NULL);
+
+    qname = axis2_qname_create(env, "soap_message_body_based_dispatcher", 
+                                                "http://axis.ws.apache.org",
+                                                NULL);
+    
+    disp = axis2_disp_create(env, qname);
+    if (!disp)
+    { 
+        AXIS2_ERROR_SET((*env)->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
+        return NULL;        
+    }
+    
+    handler = AXIS2_DISP_GET_BASE(disp, env);
+    if (!handler)
+    {
+        AXIS2_ERROR_SET((*env)->error, AXIS2_ERROR_INVALID_HANDLER_STATE, AXIS2_FAILURE);
+        return NULL;        
+    }
+
+    handler->ops->invoke = axis2_soap_body_disp_invoke;
+    
+    AXIS2_QNAME_FREE(qname, env);
+    
+    return disp;
+}
+
+    
+/** The struct that inherits from this struct
+    should implement the find_service and find_operation methods and assing the 
+    respective function pointers in the base struct.
+    Here we have only the dummy implementation to gauard against erros due to 
+    the failure to provide an impl version by mistake.
+ */
+    
+/**
+ * finds the service
+ *
+ * @param messageContext
+ * @return
+ */
+axis2_svc_t* AXIS2_CALL axis2_soap_body_disp_find_svc(axis2_msg_ctx_t *msg_ctx, 
+                    axis2_env_t **env) 
+{    
+    AXIS2_FUNC_PARAM_CHECK(msg_ctx, env, NULL);    
+/*
+    OMElement bodyFirstChild = messageContext.getEnvelope().getBody().getFirstElement();
+
+        if (bodyFirstChild != null) {
+            OMNamespace ns = bodyFirstChild.getNamespace();
+            if (ns != null) {
+                String filePart = ns.getName();
+                log.debug("Checking for Service using SOAP message body's first child's namespace
: " + filePart);
+
+                String[] values = Utils.parseRequestURLForServiceAndOperation(
+                        filePart);
+                if (values[1] != null) {
+                    operationName = new QName(values[1]);
+                }
+                if (values[0] != null) {
+                    serviceName = values[0];
+                    AxisConfiguration registry =
+                            messageContext.getConfigurationContext().getAxisConfiguration();
+                    return registry.getService(serviceName);
+                }
+            }
+        }
+*/        
+    return NULL;
+}
+
+/**
+ * finds the operation
+ *
+ * @param service
+ * @param msg_ctx
+ * @return
+ */
+axis2_operation_t* AXIS2_CALL axis2_soap_body_disp_find_operation(axis2_msg_ctx_t *msg_ctx,

+                                axis2_env_t **env,
+                                axis2_svc_t *svc)
+{
+        
+    AXIS2_FUNC_PARAM_CHECK(msg_ctx, env, NULL);    
+/*
+    OMElement bodyFirstChild = messageContext.getEnvelope().getBody()
+                .getFirstElement();
+        if (bodyFirstChild == null) {
+            return null;
+        } else {
+            log.debug("Checking for Operation using SOAP message body's first child's local
name : " + bodyFirstChild.getLocalName());
+            operationName = new QName(bodyFirstChild.getLocalName());
+        }
+
+        return service.getOperation(operationName);
+*/    
+    return NULL;
+}
+            
+axis2_status_t AXIS2_CALL axis2_soap_body_disp_invoke(struct axis2_handler * handler, 
+                                                axis2_env_t **env,
+                                                struct axis2_msg_ctx *msg_ctx)
+{
+    AXIS2_FUNC_PARAM_CHECK(msg_ctx, env, AXIS2_FAILURE);    
+    
+    msg_ctx->ops->find_svc = axis2_soap_body_disp_find_svc;
+    msg_ctx->ops->find_operation = axis2_soap_body_disp_find_operation;
+    
+    return axis2_disp_invoke(handler, env, msg_ctx);
+}



Mime
View raw message