You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by da...@apache.org on 2006/07/11 11:02:42 UTC
svn commit: r420769 - in /webservices/sandesha/trunk/c: ./ include/
include/sandesha2/ src/ src/storage/ src/storage/inmemory/ src/util/
Author: damitha
Date: Tue Jul 11 02:02:41 2006
New Revision: 420769
URL: http://svn.apache.org/viewvc?rev=420769&view=rev
Log:
Work on storage mangager and client
Added:
webservices/sandesha/trunk/c/include/sandesha2_in_memory_create_seq_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_in_memory_invoker_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_in_memory_next_msg_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_in_memory_sender_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_in_memory_seq_property_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_in_memory_transaction.h
webservices/sandesha/trunk/c/include/sandesha2_sequence_report.h
Removed:
webservices/sandesha/trunk/c/include/sandesha2/sandesha2_create_seq_bean_manager.h
webservices/sandesha/trunk/c/include/sandesha2/sandesha2_invoker_bean_manager.h
webservices/sandesha/trunk/c/include/sandesha2/sandesha2_next_msg_bean_manager.h
webservices/sandesha/trunk/c/include/sandesha2/sandesha2_sender_bean_manager.h
Modified:
webservices/sandesha/trunk/c/build.sh
webservices/sandesha/trunk/c/configure.ac
webservices/sandesha/trunk/c/include/sandesha2/sandesha2_constants.h
webservices/sandesha/trunk/c/include/sandesha2/sandesha2_error.h
webservices/sandesha/trunk/c/include/sandesha2/sandesha2_invoker_bean.h
webservices/sandesha/trunk/c/include/sandesha2/sandesha2_sender_bean.h
webservices/sandesha/trunk/c/include/sandesha2/sandesha2_utils.h
webservices/sandesha/trunk/c/src/Makefile.am
webservices/sandesha/trunk/c/src/storage/Makefile.am
webservices/sandesha/trunk/c/src/storage/inmemory/in_memory_storage_manager.c
webservices/sandesha/trunk/c/src/util/utils.c
Modified: webservices/sandesha/trunk/c/build.sh
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/build.sh?rev=420769&r1=420768&r2=420769&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/build.sh (original)
+++ webservices/sandesha/trunk/c/build.sh Tue Jul 11 02:02:41 2006
@@ -1,5 +1,6 @@
#!/bin/bash
./autogen.sh
-./configure --prefix=${AXIS2C_HOME} --enable-static=no --with-axis2=${AXIS2C_HOME}/include
+./configure --prefix=${AXIS2C_HOME} --enable-static=no --with-axis2=${AXIS2C_HOME}/include --with-axis2_util=${AXIS2C_HOME}/include
+make
make
make install
Modified: webservices/sandesha/trunk/c/configure.ac
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/configure.ac?rev=420769&r1=420768&r2=420769&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/configure.ac (original)
+++ webservices/sandesha/trunk/c/configure.ac Tue Jul 11 02:02:41 2006
@@ -20,7 +20,7 @@
dnl Checks for libraries.
AC_CHECK_LIB(dl, dlopen)
-CFLAGS="$CFLAGS -D_LARGEFILE64_SOURCE"
+CFLAGS="$CFLAGS -D_LARGEFILE64_SOURCE -Werror"
if test "$GCC" = "yes"; then
CFLAGS="$CFLAGS -ansi -Wall -Wno-implicit-function-declaration"
fi
@@ -61,12 +61,38 @@
AC_MSG_RESULT(no)
)
+AC_MSG_CHECKING(To Use Axis2 C Util. This is a compulsory module to build Axis2 C)
+AC_ARG_WITH(axis2_util,
+[ --with-axis2_util[=PATH] use axis2_util.],
+[ case "$withval" in
+ no)
+ AC_MSG_RESULT(no)
+ ;;
+ *)
+ AC_MSG_RESULT(yes)
+ dnl Find axis2_util include dir in the path
+ if test -d $withval; then
+ axis2_utilinc="-I$withval"
+ dnl else find the axis2_util include dir in $(AXIS2C_HOME)/include
+ elif test -d '$(AXIS2C_HOME)/include'; then
+ axis2_utilinc="-I$(AXIS2C_HOME)/include"
+ else
+ AC_MSG_ERROR(could not find axis2_util. stop)
+ fi
+ ;;
+ esac ],
+ AC_MSG_RESULT(no)
+)
+
AXIS2INC=$axis2inc
+UTILINC=$axis2_utilinc
AC_SUBST(AXIS2INC)
+AC_SUBST(UTILINC)
AC_CONFIG_FILES([Makefile
src/Makefile \
+ src/util/Makefile \
src/wsrm/Makefile\
src/transport/Makefile\
src/workers/Makefile\
@@ -74,6 +100,8 @@
src/util/Makefile\
src/storage/Makefile\
src/storage/beans/Makefile\
+ src/storage/inmemory/Makefile\
+ src/client/Makefile
])
AC_OUTPUT
Modified: webservices/sandesha/trunk/c/include/sandesha2/sandesha2_constants.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2/sandesha2_constants.h?rev=420769&r1=420768&r2=420769&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2/sandesha2_constants.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2/sandesha2_constants.h Tue Jul 11 02:02:41 2006
@@ -300,7 +300,7 @@
#define SANDESHA2_BEAN_MAP_STORAGE_MAP "StorageMapBeanMap"
- #define SANDESHA2_BEAN_MAP_ NEXT_MESSAGE "NextMsgBeanMap"
+ #define SANDESHA2_BEAN_MAP_NEXT_MESSAGE "NextMsgBeanMap"
/**
* SOAP Faults
Modified: webservices/sandesha/trunk/c/include/sandesha2/sandesha2_error.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2/sandesha2_error.h?rev=420769&r1=420768&r2=420769&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2/sandesha2_error.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2/sandesha2_error.h Tue Jul 11 02:02:41 2006
@@ -17,6 +17,8 @@
#ifndef SANDESHA2_ERROR_H
#define SANDESHA2_ERROR_H
+#include <axis2_error.h>
+
#ifdef __cplusplus
extern "C"
{
@@ -57,6 +59,14 @@
SANDESHA2_ERROR_TO_OM_INVALID_NUMBER,
/* Ack Final now allowed in the spec */
SANDESHA2_ERROR_ACK_FINAL_NOT_ALLOWED,
+ /* 'To' address is not set */
+ SANDESHA2_ERROR_TO_ADDRESS_IS_NOT_SET,
+ /* Service Context is NULL */
+ SANDESHA2_ERROR_SVC_CTX_IS_NULL,
+ /* Result is not unique */
+ SANDESHA2_ERROR_NON_UNIQUE_RESULT,
+ /* Key is NULL. Cannot insert */
+ SANDESHA2_ERROR_KEY_IS_NULL,
/* Ack None now allowed in the spec */
SANDESHA2_ERROR_ACK_NONE_NOT_ALLOWED,
/* unknown storage manager */
@@ -81,6 +91,12 @@
SANDESHA2_ERROR_NULL_TO,
/* NULL sequnce given for processing */
SANDESHA2_ERROR_NULL_SEQUENCE
+ /** The following has to be the last error value all the time.
+ All other error codes should appear above this.
+ SANDESHA_ERROR_LAST is used to track the number of error codes present
+ for the purpose of sizing the error message array.
+ */
+ SANDESHA2_ERROR_LAST
};
/** @} */
Modified: webservices/sandesha/trunk/c/include/sandesha2/sandesha2_invoker_bean.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2/sandesha2_invoker_bean.h?rev=420769&r1=420768&r2=420769&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2/sandesha2_invoker_bean.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2/sandesha2_invoker_bean.h Tue Jul 11 02:02:41 2006
@@ -95,10 +95,10 @@
#define SANDESHA2_INVOKER_BEAN_FREE(invoker_bean, env) \
((invoker_bean)->ops->free(invoker_bean, env))
-#define SANDESHA2_INVOKER_BEAN_GET_MSG_CONTEXT_REF_ID(invoker_bean, env) \
+#define SANDESHA2_INVOKER_BEAN_GET_MSG_CONTEXT_REF_KEY(invoker_bean, env) \
((invoker_bean)->ops->get_msg_context_ref_key(invoker_bean, env))
-#define SANDESHA2_INVOKER_BEAN_SET_MSG_CONTEXT_REF_ID(invoker_bean, env, ref_id) \
+#define SANDESHA2_INVOKER_BEAN_SET_MSG_CONTEXT_REF_KEY(invoker_bean, env, ref_id) \
((invoker_bean)->ops->set_msg_context_ref_key(invoker_bean, env, ref_id))
#define SANDESHA2_INVOKER_BEAN_GET_MSG_NO(invoker_bean, env) \
Modified: webservices/sandesha/trunk/c/include/sandesha2/sandesha2_sender_bean.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2/sandesha2_sender_bean.h?rev=420769&r1=420768&r2=420769&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2/sandesha2_sender_bean.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2/sandesha2_sender_bean.h Tue Jul 11 02:02:41 2006
@@ -146,67 +146,70 @@
#define SANDESHA2_SENDER_BEAN_FREE(sender_bean, env) \
- ((sender_bean)->ops->free(sender_bean, env)
+ ((sender_bean)->ops->free(sender_bean, env))
-#define SANDESHA2_SENDER_BEAN_GET_MSG_CONTEXT_REF_KEY(sender_bean, env) \
- ((sender_bean)->ops->get_msg_context_ref_key(sender_bean, env)
+#define SANDESHA2_SENDER_BEAN_GET_MSG_CONTEXT_REF_KEY(sender, env) \
+ (((sandesha2_sender_bean_t *) sender)->ops->\
+ get_msg_context_ref_key (sender, env))
#define SANDESHA2_SENDER_BEAN_SET_MSG_CONTEXT_REF_KEY(sender_bean, env, ref_key) \
- ((sender_bean)->ops->set_msg_context_ref_key(sender_bean, env, ref_key)
+ ((sender_bean)->ops->set_msg_context_ref_key(sender_bean, env, ref_key))
-#define SANDESHA2_SENDER_BEAN_GET_MSG_ID(sender_bean, env) \
- ((sender_bean)->ops->get_msg_id(sender_bean, env)
+#define SANDESHA2_SENDER_BEAN_GET_MSG_ID(sender, env) \
+ (((sandesha2_sender_bean_t *)sender)->ops->\
+ get_msg_id(sender, env))
#define SANDESHA2_SENDER_BEAN_SET_MSG_ID(sender_bean, env, msg_id) \
- ((sender_bean)->ops->set_msg_id(sender_bean, env, msg_id)
+ ((sender_bean)->ops->set_msg_id(sender_bean, env, msg_id))
#define SANDESHA2_SENDER_BEAN_IS_SEND(sender_bean, env) \
- ((sender_bean)->ops->is_send(sender_bean, env)
+ ((sender_bean)->ops->is_send(sender_bean, env))
#define SANDESHA2_SENDER_BEAN_SET_SEND(sender_bean, env, send) \
- ((sender_bean)->ops->set_send(sender_bean, env, send)
+ ((sender_bean)->ops->set_send(sender_bean, env, send))
-#define SANDESHA2_SENDER_BEAN_GET_INTERNAL_SEQ_ID(sender_bean, env) \
- ((sender_bean)->ops->get_internal_seq_id(sender_bean, env)
+#define SANDESHA2_SENDER_BEAN_GET_INTERNAL_SEQ_ID(sender, env) \
+ (((sandesha2_sender_bean_t *) sender)->ops->\
+ get_internal_seq_id (sender, env))
#define SANDESHA2_SENDER_BEAN_SET_INTERNAL_SEQ_ID(sender_bean, env, int_seq_id) \
- ((sender_bean)->ops->set_internal_seq_id(sender_bean, env, int_seq_id)
+ ((sender_bean)->ops->set_internal_seq_id(sender_bean, env, int_seq_id))
#define SANDESHA2_SENDER_BEAN_GET_SENT_COUNT(sender_bean, env) \
- ((sender_bean)->ops->get_sent_count(sender_bean, env)
+ ((sender_bean)->ops->get_sent_count(sender_bean, env))
#define SANDESHA2_SENDER_BEAN_SET_SENT_COUNT(sender_bean, env, sent_count) \
- ((sender_bean)->ops->set_sent_count(sender_bean, env, sent_count)
+ ((sender_bean)->ops->set_sent_count(sender_bean, env, sent_count))
#define SANDESHA2_SENDER_BEAN_GET_MSG_NO(sender_bean, env) \
- ((sender_bean)->ops->get_msg_no(sender_bean, env)
+ ((sender_bean)->ops->get_msg_no(sender_bean, env))
#define SANDESHA2_SENDER_BEAN_SET_MSG_NO(sender_bean, env, msg_no) \
- ((sender_bean)->ops->set_msg_no(sender_bean, env, msg_no)
+ ((sender_bean)->ops->set_msg_no(sender_bean, env, msg_no))
#define SANDESHA2_SENDER_BEAN_IS_RESEND(sender_bean, env) \
- ((sender_bean)->ops->is_resend(sender_bean, env)
+ ((sender_bean)->ops->is_resend(sender_bean, env))
#define SANDESHA2_SENDER_BEAN_SET_RESEND(sender_bean, env, resend) \
- ((sender_bean)->ops->set_resend(sender_bean, env, resend)
+ ((sender_bean)->ops->set_resend(sender_bean, env, resend))
#define SANDESHA2_SENDER_BEAN_GET_TIME_TO_SEND(sender_bean, env) \
- ((sender_bean)->ops->get_time_to_send(sender_bean, env)
+ ((sender_bean)->ops->get_time_to_send(sender_bean, env))
#define SANDESHA2_SENDER_BEAN_SET_TIME_TO_SEND(sender_bean, env, time_to_send) \
- ((sender_bean)->ops->set_time_to_send(sender_bean, env, time_to_send)
+ ((sender_bean)->ops->set_time_to_send(sender_bean, env, time_to_send))
#define SANDESHA2_SENDER_BEAN_GET_MSG_TYPE(sender_bean, env) \
- ((sender_bean)->ops->get_msg_type(sender_bean, env)
-
+ ((sender_bean)->ops->get_msg_type(sender_bean, env))
+
#define SANDESHA2_SENDER_BEAN_SET_MSG_TYPE(sender_bean, env, msg_type) \
- ((sender_bean)->ops->set_msg_type(sender_bean, env, msg_type)
+ ((sender_bean)->ops->set_msg_type(sender_bean, env, msg_type))
#define SANDESHA2_SENDER_BEAN_GET_SEQUENCE_ID(sender_bean, env) \
- ((sender_bean)->ops->get_sequence_id(sender_bean, env)
+ ((sender_bean)->ops->get_sequence_id(sender_bean, env))
#define SANDESHA2_SENDER_BEAN_SET_SEQUENCE_ID(sender_bean, env, seq_id) \
- ((sender_bean)->ops->set_sequence_id(sender_bean, env, seq_id)
+ ((sender_bean)->ops->set_sequence_id(sender_bean, env, seq_id))
#ifdef __cplusplus
Modified: webservices/sandesha/trunk/c/include/sandesha2/sandesha2_utils.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2/sandesha2_utils.h?rev=420769&r1=420768&r2=420769&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2/sandesha2_utils.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2/sandesha2_utils.h Tue Jul 11 02:02:41 2006
@@ -17,6 +17,8 @@
#ifndef SANDESHA2_UTILS_H
#define SANDESHA2_UTILS_H
+#include <axiom_soap_envelope.h>
+
/**
* @file sandesha2_utils.h
* @brief
@@ -40,6 +42,13 @@
* @{
*/
AXIS2_EXTERN axis2_status_t AXIS2_CALL
+
+AXIS2_EXTERN long AXIS2_CALL
+sandesha2_util_get_current_time_in_millis(
+ const axis2_env_t *env);
+
+#define sandesha2_util_get_current_time_in_millis SANDESHA2_UTIL_GET_CURRENT_TIME_IN_MILLIS
+
sandesha2_utils_remove_soap_body_part(const axis2_env_t *env,
axiom_soap_envelope_t *envelope, axis2_qname_t *qname);
Added: webservices/sandesha/trunk/c/include/sandesha2_in_memory_create_seq_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_in_memory_create_seq_mgr.h?rev=420769&view=auto
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_in_memory_create_seq_mgr.h (added)
+++ webservices/sandesha/trunk/c/include/sandesha2_in_memory_create_seq_mgr.h Tue Jul 11 02:02:41 2006
@@ -0,0 +1,139 @@
+/*
+ * 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.
+ */
+
+#ifndef SANDESHA2_IN_MEMORY_CREATE_SEQ_MGR_H
+#define SANDESHA2_IN_MEMORY_CREATE_SEQ_MGR_H
+
+/**
+ * @file sandesha2_in_memory_create_seq_mgr.h
+ * @brief Sandesha In Memory Create Sequence Manager Interface
+ */
+
+#include <axis2_allocator.h>
+#include <axis2_env.h>
+#include <axis2_error.h>
+#include <axis2_string.h>
+#include <axis2_utils.h>
+#include <axis2_ctx.h>
+#include <axis2_array_list.h>
+#include <sandesha2_create_seq_bean.h>
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+typedef struct sandesha2_in_memory_create_seq_mgr sandesha2_in_memory_create_seq_mgr_t;
+typedef struct sandesha2_in_memory_create_seq_mgr_ops sandesha2_in_memory_create_seq_mgr_ops_t;
+
+/** @defgroup sandesha2_in_memory_create_seq_mgr In Memory Create Sequence Manager
+ * @ingroup sandesha2
+ * @{
+ */
+
+struct sandesha2_in_memory_create_seq_mgr_ops
+{
+ /**
+ * Deallocate memory
+ * @return status code
+ */
+ axis2_status_t (AXIS2_CALL *
+ free) (
+ void *seq_mgr,
+ const axis2_env_t *env);
+
+ axis2_bool_t (AXIS2_CALL *
+ insert) (
+ sandesha2_in_memory_create_seq_mgr_t *seq_mgr,
+ const axis2_env_t *env,
+ sandesha2_create_seq_bean_t *bean);
+
+ axis2_bool_t (AXIS2_CALL *
+ remove) (
+ sandesha2_in_memory_create_seq_mgr_t *seq_mgr,
+ const axis2_env_t *env,
+ axis2_char_t *msg_id);
+
+ sandesha2_create_seq_bean_t *(AXIS2_CALL *
+ retrieve) (
+ sandesha2_in_memory_create_seq_mgr_t *seq_mgr,
+ const axis2_env_t *env,
+ axis2_char_t *msg_id);
+
+ axis2_bool_t (AXIS2_CALL *
+ update) (
+ sandesha2_in_memory_create_seq_mgr_t *seq_mgr,
+ const axis2_env_t *env,
+ sandesha2_create_seq_bean_t *bean);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ find) (
+ sandesha2_in_memory_create_seq_mgr_t *seq_mgr,
+ const axis2_env_t *env,
+ sandesha2_create_seq_bean_t *bean);
+
+ sandesha2_create_seq_bean_t *(AXIS2_CALL *
+ find_unique) (
+ sandesha2_in_memory_create_seq_mgr_t *seq_mgr,
+ const axis2_env_t *env,
+ sandesha2_create_seq_bean_t *bean);
+
+
+};
+
+struct sandesha2_in_memory_create_seq_mgr
+{
+ sandesha2_in_memory_create_seq_mgr_ops_t *ops;
+};
+
+AXIS2_EXTERN sandesha2_in_memory_create_seq_mgr_t * AXIS2_CALL
+sandesha2_in_memory_create_seq_mgr_create(
+ const axis2_env_t *env,
+ axis2_ctx_t *ctx);
+
+#define SANDESHA2_IN_MEMORY_CREATE_SEQ_MGR_FREE(seq_mgr, env) \
+ (((sandesha2_in_memory_create_seq_mgr_t *) seq_mgr)->ops->free (seq_mgr, env))
+
+#define SANDESHA2_IN_MEMORY_CREATE_SEQ_MGR_INSERT(seq_mgr, env, bean) \
+ (((sandesha2_in_memory_create_seq_mgr_t *) seq_mgr)->ops->\
+ insert (seq_mgr, env, bean))
+
+#define SANDESHA2_IN_MEMORY_CREATE_SEQ_MGR_REMOVE(seq_mgr, env, msg_id) \
+ (((sandesha2_in_memory_create_seq_mgr_t *) seq_mgr)->ops->\
+ remove (seq_mgr, env, msg_id))
+
+#define SANDESHA2_IN_MEMORY_CREATE_SEQ_MGR_RETRIEVE(seq_mgr, env, msg_id) \
+ (((sandesha2_in_memory_create_seq_mgr_t *) seq_mgr)->ops->\
+ retrieve (seq_mgr, env, msg_id))
+
+#define SANDESHA2_IN_MEMORY_CREATE_SEQ_MGR_UPDATE(seq_mgr, env, bean) \
+ (((sandesha2_in_memory_create_seq_mgr_t *) seq_mgr)->ops->\
+ update (seq_mgr, env, bean))
+
+#define SANDESHA2_IN_MEMORY_CREATE_SEQ_MGR_FIND(seq_mgr, env, bean) \
+ (((sandesha2_in_memory_create_seq_mgr_t *) seq_mgr)->ops->\
+ find (seq_mgr, env, bean))
+
+#define SANDESHA2_IN_MEMORY_CREATE_SEQ_MGR_FIND_UNIQUE(seq_mgr, env, bean) \
+ (((sandesha2_in_memory_create_seq_mgr_t *) seq_mgr)->ops->\
+ find_unique (seq_mgr, env, bean))
+
+
+/** @} */
+#ifdef __cplusplus
+}
+#endif
+#endif /* SANDESHA2_IN_MEMORY_CREATE_SEQ_MGR_H */
Added: webservices/sandesha/trunk/c/include/sandesha2_in_memory_invoker_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_in_memory_invoker_mgr.h?rev=420769&view=auto
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_in_memory_invoker_mgr.h (added)
+++ webservices/sandesha/trunk/c/include/sandesha2_in_memory_invoker_mgr.h Tue Jul 11 02:02:41 2006
@@ -0,0 +1,139 @@
+/*
+ * 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.
+ */
+
+#ifndef SANDESHA2_IN_MEMORY_INVOKER_MGR_H
+#define SANDESHA2_IN_MEMORY_INVOKER_MGR_H
+
+/**
+ * @file sandesha2_in_memory_invoker_mgr.h
+ * @brief Sandesha In Memory Invoker Manager Interface
+ */
+
+#include <axis2_allocator.h>
+#include <axis2_env.h>
+#include <axis2_error.h>
+#include <axis2_string.h>
+#include <axis2_utils.h>
+#include <axis2_ctx.h>
+#include <axis2_array_list.h>
+#include <sandesha2_invoker_bean.h>
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+typedef struct sandesha2_in_memory_invoker_mgr sandesha2_in_memory_invoker_mgr_t;
+typedef struct sandesha2_in_memory_invoker_mgr_ops sandesha2_in_memory_invoker_mgr_ops_t;
+
+/** @defgroup sandesha2_in_memory_invoker_mgr In Memory Invoker Manager
+ * @ingroup sandesha2
+ * @{
+ */
+
+struct sandesha2_in_memory_invoker_mgr_ops
+{
+ /**
+ * Deallocate memory
+ * @return status code
+ */
+ axis2_status_t (AXIS2_CALL *
+ free) (
+ void *invoker,
+ const axis2_env_t *env);
+
+ axis2_bool_t (AXIS2_CALL *
+ insert) (
+ sandesha2_in_memory_invoker_mgr_t *invoker,
+ const axis2_env_t *env,
+ sandesha2_invoker_bean_t *bean);
+
+ axis2_bool_t (AXIS2_CALL *
+ remove) (
+ sandesha2_in_memory_invoker_mgr_t *invoker,
+ const axis2_env_t *env,
+ axis2_char_t *ref_key);
+
+ sandesha2_invoker_bean_t *(AXIS2_CALL *
+ retrieve) (
+ sandesha2_in_memory_invoker_mgr_t *invoker,
+ const axis2_env_t *env,
+ axis2_char_t *ref_key);
+
+ axis2_bool_t (AXIS2_CALL *
+ update) (
+ sandesha2_in_memory_invoker_mgr_t *invoker,
+ const axis2_env_t *env,
+ sandesha2_invoker_bean_t *bean);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ find) (
+ sandesha2_in_memory_invoker_mgr_t *invoker,
+ const axis2_env_t *env,
+ sandesha2_invoker_bean_t *bean);
+
+ sandesha2_invoker_bean_t *(AXIS2_CALL *
+ find_unique) (
+ sandesha2_in_memory_invoker_mgr_t *invoker,
+ const axis2_env_t *env,
+ sandesha2_invoker_bean_t *bean);
+
+
+};
+
+struct sandesha2_in_memory_invoker_mgr
+{
+ sandesha2_in_memory_invoker_mgr_ops_t *ops;
+};
+
+AXIS2_EXTERN sandesha2_in_memory_invoker_mgr_t * AXIS2_CALL
+sandesha2_in_memory_invoker_mgr_create(
+ const axis2_env_t *env,
+ axis2_ctx_t *ctx);
+
+#define SANDESHA2_IN_MEMORY_INVOKER_MGR_FREE(invoker, env) \
+ (((sandesha2_in_memory_invoker_mgr_t *) invoker)->ops->free (invoker, env))
+
+#define SANDESHA2_IN_MEMORY_INVOKER_MGR_INSERT(invoker, env, bean) \
+ (((sandesha2_in_memory_invoker_mgr_t *) invoker)->ops->\
+ insert (invoker, env, bean))
+
+#define SANDESHA2_IN_MEMORY_INVOKER_MGR_REMOVE(invoker, env, ref_key) \
+ (((sandesha2_in_memory_invoker_mgr_t *) invoker)->ops->\
+ remove (invoker, env, ref_key))
+
+#define SANDESHA2_IN_MEMORY_INVOKER_MGR_RETRIEVE(invoker, env, ref_key) \
+ (((sandesha2_in_memory_invoker_mgr_t *) invoker)->ops->\
+ retrieve (invoker, env, ref_key))
+
+#define SANDESHA2_IN_MEMORY_INVOKER_MGR_UPDATE(invoker, env, bean) \
+ (((sandesha2_in_memory_invoker_mgr_t *) invoker)->ops->\
+ update (invoker, env, bean))
+
+#define SANDESHA2_IN_MEMORY_INVOKER_MGR_FIND(invoker, env, bean) \
+ (((sandesha2_in_memory_invoker_mgr_t *) invoker)->ops->\
+ find (invoker, env, bean))
+
+#define SANDESHA2_IN_MEMORY_INVOKER_MGR_FIND_UNIQUE(invoker, env, bean) \
+ (((sandesha2_in_memory_invoker_mgr_t *) invoker)->ops->\
+ find_unique (invoker, env, bean))
+
+
+/** @} */
+#ifdef __cplusplus
+}
+#endif
+#endif /* SANDESHA2_IN_MEMORY_INVOKER_MGR_H */
Added: webservices/sandesha/trunk/c/include/sandesha2_in_memory_next_msg_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_in_memory_next_msg_mgr.h?rev=420769&view=auto
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_in_memory_next_msg_mgr.h (added)
+++ webservices/sandesha/trunk/c/include/sandesha2_in_memory_next_msg_mgr.h Tue Jul 11 02:02:41 2006
@@ -0,0 +1,147 @@
+/*
+ * 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.
+ */
+
+#ifndef SANDESHA2_IN_MEMORY_NEXT_MSG_MGR_H
+#define SANDESHA2_IN_MEMORY_NEXT_MSG_MGR_H
+
+/**
+ * @file sandesha2_in_memory_next_msg_mgr.h
+ * @brief Sandesha In Memory Next Message Manager Interface
+ */
+
+#include <axis2_allocator.h>
+#include <axis2_env.h>
+#include <axis2_error.h>
+#include <axis2_string.h>
+#include <axis2_utils.h>
+#include <axis2_ctx.h>
+#include <axis2_array_list.h>
+#include <sandesha2_next_msg_bean.h>
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+typedef struct sandesha2_in_memory_next_msg_mgr sandesha2_in_memory_next_msg_mgr_t;
+typedef struct sandesha2_in_memory_next_msg_mgr_ops sandesha2_in_memory_next_msg_mgr_ops_t;
+
+/** @defgroup sandesha2_in_memory_next_msg_mgr In Memory Next Message Manager
+ * @ingroup sandesha2
+ * @{
+ */
+
+struct sandesha2_in_memory_next_msg_mgr_ops
+{
+ /**
+ * Deallocate memory
+ * @return status code
+ */
+ axis2_status_t (AXIS2_CALL *
+ free) (
+ void *next_msg,
+ const axis2_env_t *env);
+
+ axis2_bool_t (AXIS2_CALL *
+ insert) (
+ sandesha2_in_memory_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env,
+ sandesha2_next_msg_bean_t *bean);
+
+ axis2_bool_t (AXIS2_CALL *
+ remove) (
+ sandesha2_in_memory_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env,
+ axis2_char_t *msg_id);
+
+ sandesha2_next_msg_bean_t *(AXIS2_CALL *
+ retrieve) (
+ sandesha2_in_memory_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env,
+ axis2_char_t *msg_id);
+
+ axis2_bool_t (AXIS2_CALL *
+ update) (
+ sandesha2_in_memory_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env,
+ sandesha2_next_msg_bean_t *bean);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ find) (
+ sandesha2_in_memory_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env,
+ sandesha2_next_msg_bean_t *bean);
+
+ sandesha2_next_msg_bean_t *(AXIS2_CALL *
+ find_unique) (
+ sandesha2_in_memory_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env,
+ sandesha2_next_msg_bean_t *bean);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ retrieve_all) (
+ sandesha2_in_memory_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env);
+};
+
+struct sandesha2_in_memory_next_msg_mgr
+{
+ sandesha2_in_memory_next_msg_mgr_ops_t *ops;
+};
+
+AXIS2_EXTERN sandesha2_in_memory_next_msg_mgr_t * AXIS2_CALL
+sandesha2_in_memory_next_msg_mgr_create(
+ const axis2_env_t *env,
+ axis2_ctx_t *ctx);
+
+#define SANDESHA2_IN_MEMORY_NEXT_MSG_MGR_FREE(next_msg, env) \
+ (((sandesha2_in_memory_next_msg_mgr_t *) next_msg)->ops->free (next_msg, env))
+
+#define SANDESHA2_IN_MEMORY_NEXT_MSG_INSERT(next_msg, env, bean) \
+ (((sandesha2_in_memory_next_msg_mgr_t *) next_msg)->ops->\
+ insert (next_msg, env, bean))
+
+#define SANDESHA2_IN_MEMORY_NEXT_MSG_REMOVE(next_msg, env, msg_id) \
+ (((sandesha2_in_memory_next_msg_mgr_t *) next_msg)->ops->\
+ remove (next_msg, env, msg_id))
+
+#define SANDESHA2_IN_MEMORY_NEXT_MSG_RETRIEVE(next_msg, env, msg_id) \
+ (((sandesha2_in_memory_next_msg_mgr_t *) next_msg)->ops->\
+ retrieve (next_msg, env, msg_id))
+
+#define SANDESHA2_IN_MEMORY_NEXT_MSG_UPDATE(next_msg, env, bean) \
+ (((sandesha2_in_memory_next_msg_mgr_t *) next_msg)->ops->\
+ update (next_msg, env, bean))
+
+#define SANDESHA2_IN_MEMORY_NEXT_MSG_FIND(next_msg, env, bean) \
+ (((sandesha2_in_memory_next_msg_mgr_t *) next_msg)->ops->\
+ find_by_next_msg_bean (next_msg, env, bean))
+
+#define SANDESHA2_IN_MEMORY_NEXT_MSG_FIND_UNIQUE(next_msg, env, bean) \
+ (((sandesha2_in_memory_next_msg_mgr_t *) next_msg)->ops->\
+ find_unique (next_msg, env, bean))
+
+#define SANDESHA2_IN_MEMORY_NEXT_MSG_RETRIEVE_ALL(next_msg, env) \
+ (((sandesha2_in_memory_next_msg_mgr_t *) next_msg)->ops->\
+ retrieve_all (next_msg, env))
+
+
+
+/** @} */
+#ifdef __cplusplus
+}
+#endif
+#endif /* SANDESHA2_IN_MEMORY_NEXT_MSG_MGR_H */
Added: webservices/sandesha/trunk/c/include/sandesha2_in_memory_sender_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_in_memory_sender_mgr.h?rev=420769&view=auto
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_in_memory_sender_mgr.h (added)
+++ webservices/sandesha/trunk/c/include/sandesha2_in_memory_sender_mgr.h Tue Jul 11 02:02:41 2006
@@ -0,0 +1,167 @@
+/*
+ * 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.
+ */
+
+#ifndef SANDESHA2_IN_MEMORY_SENDER_MGR_H
+#define SANDESHA2_IN_MEMORY_SENDER_MGR_H
+
+/**
+ * @file sandesha2_in_memory_sender_mgr.h
+ * @brief Sandesha In Memory Sender Manager Interface
+ */
+
+#include <axis2_allocator.h>
+#include <axis2_env.h>
+#include <axis2_error.h>
+#include <axis2_string.h>
+#include <axis2_utils.h>
+#include <axis2_ctx.h>
+#include <axis2_array_list.h>
+#include <sandesha2_sender_bean.h>
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+typedef struct sandesha2_in_memory_sender_mgr sandesha2_in_memory_sender_mgr_t;
+typedef struct sandesha2_in_memory_sender_mgr_ops sandesha2_in_memory_sender_mgr_ops_t;
+
+/** @defgroup sandesha2_in_memory_sender_mgr In Memory Sender Manager
+ * @ingroup sandesha2
+ * @{
+ */
+
+struct sandesha2_in_memory_sender_mgr_ops
+{
+ /**
+ * Deallocate memory
+ * @return status code
+ */
+ axis2_status_t (AXIS2_CALL *
+ free) (
+ void *sender,
+ const axis2_env_t *env);
+
+ axis2_bool_t (AXIS2_CALL *
+ insert) (
+ sandesha2_in_memory_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ sandesha2_sender_bean_t *bean);
+
+ axis2_bool_t (AXIS2_CALL *
+ remove) (
+ sandesha2_in_memory_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ axis2_char_t *msg_id);
+
+ sandesha2_sender_bean_t *(AXIS2_CALL *
+ retrieve) (
+ sandesha2_in_memory_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ axis2_char_t *msg_id);
+
+ axis2_bool_t (AXIS2_CALL *
+ update) (
+ sandesha2_in_memory_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ sandesha2_sender_bean_t *bean);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ find_by_internal_seq_id) (
+ sandesha2_in_memory_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ axis2_char_t *internal_seq_id);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ find_by_sender_bean) (
+ sandesha2_in_memory_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ sandesha2_sender_bean_t *bean);
+
+ sandesha2_sender_bean_t *(AXIS2_CALL *
+ find_unique) (
+ sandesha2_in_memory_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ sandesha2_sender_bean_t *bean);
+
+ sandesha2_sender_bean_t *(AXIS2_CALL *
+ get_next_msg_to_send) (
+ sandesha2_in_memory_sender_mgr_t *sender,
+ const axis2_env_t *env);
+
+ sandesha2_sender_bean_t *(AXIS2_CALL *
+ retrieve_from_msg_ref_key) (
+ sandesha2_in_memory_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ axis2_char_t *msg_ctx_ref_key);
+};
+
+struct sandesha2_in_memory_sender_mgr
+{
+ sandesha2_in_memory_sender_mgr_ops_t *ops;
+};
+
+AXIS2_EXTERN sandesha2_in_memory_sender_mgr_t * AXIS2_CALL
+sandesha2_in_memory_sender_mgr_create(
+ const axis2_env_t *env,
+ axis2_ctx_t *ctx);
+
+#define SANDESHA2_IN_MEMORY_SENDER_MGR_FREE(sender, env) \
+ (((sandesha2_in_memory_sender_mgr_t *) sender)->ops->free (sender, env))
+
+#define SANDESHA2_IN_MEMORY_SENDER_INSERT(sender, env, bean) \
+ (((sandesha2_in_memory_sender_mgr_t *) sender)->ops->\
+ insert (sender, env, bean))
+
+#define SANDESHA2_IN_MEMORY_SENDER_REMOVE(sender, env, msg_id) \
+ (((sandesha2_in_memory_sender_mgr_t *) sender)->ops->\
+ remove (sender, env, msg_id))
+
+#define SANDESHA2_IN_MEMORY_SENDER_RETRIEVE(sender, env, msg_id) \
+ (((sandesha2_in_memory_sender_mgr_t *) sender)->ops->\
+ retrieve (sender, env, msg_id))
+
+#define SANDESHA2_IN_MEMORY_SENDER_UPDATE(sender, env, bean) \
+ (((sandesha2_in_memory_sender_mgr_t *) sender)->ops->\
+ update (sender, env, bean))
+
+#define SANDESHA2_IN_MEMORY_SENDER_FIND_BY_INTERNAL_SEQ_ID(sender, env, internal_seq_id) \
+ (((sandesha2_in_memory_sender_mgr_t *) sender)->ops->\
+ find_by_internal_seq_id (sender, env, internal_seq_id))
+
+#define SANDESHA2_IN_MEMORY_SENDER_FIND_BY_SENDER_BEAN(sender, env, bean) \
+ (((sandesha2_in_memory_sender_mgr_t *) sender)->ops->\
+ find_by_sender_bean (sender, env, bean))
+
+#define SANDESHA2_IN_MEMORY_SENDER_FIND_UNIQUE(sender, env, bean) \
+ (((sandesha2_in_memory_sender_mgr_t *) sender)->ops->\
+ find_unique (sender, env, bean))
+
+#define SANDESHA2_IN_MEMORY_SENDER_GET_NEXT_MSG_TO_SEND(sender, env) \
+ (((sandesha2_in_memory_sender_mgr_t *) sender)->ops->\
+ get_next_msg_to_send (sender, env))
+
+#define SANDESHA2_IN_MEMORY_SENDER_RETRIEVE_FROM_MSG_REF_KEY(sender, env, ref_key) \
+ (((sandesha2_in_memory_sender_mgr_t *) sender)->ops->\
+ retrieve_from_msg_ref_key (sender, env, ref_key))
+
+
+
+/** @} */
+#ifdef __cplusplus
+}
+#endif
+#endif /* SANDESHA2_IN_MEMORY_SENDER_MGR_H */
Added: webservices/sandesha/trunk/c/include/sandesha2_in_memory_seq_property_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_in_memory_seq_property_mgr.h?rev=420769&view=auto
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_in_memory_seq_property_mgr.h (added)
+++ webservices/sandesha/trunk/c/include/sandesha2_in_memory_seq_property_mgr.h Tue Jul 11 02:02:41 2006
@@ -0,0 +1,159 @@
+/*
+ * 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.
+ */
+
+#ifndef SANDESHA2_IN_MEMORY_SEQ_PROPERTY_MGR_H
+#define SANDESHA2_IN_MEMORY_SEQ_PROPERTY_MGR_H
+
+/**
+ * @file sandesha2_in_memory_seq_property_mgr.h
+ * @brief Sandesha In Memory Sequence Property Manager Interface
+ */
+
+#include <axis2_allocator.h>
+#include <axis2_env.h>
+#include <axis2_error.h>
+#include <axis2_string.h>
+#include <axis2_utils.h>
+#include <axis2_ctx.h>
+#include <axis2_array_list.h>
+#include <sandesha2_sequence_property_bean.h>
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+typedef struct sandesha2_in_memory_seq_property_mgr sandesha2_in_memory_seq_property_mgr_t;
+typedef struct sandesha2_in_memory_seq_property_mgr_ops sandesha2_in_memory_seq_property_mgr_ops_t;
+
+/** @defgroup sandesha2_in_memory_seq_property_mgr In Memory Sequence Property Manager
+ * @ingroup sandesha2
+ * @{
+ */
+
+struct sandesha2_in_memory_seq_property_mgr_ops
+{
+ /**
+ * Deallocate memory
+ * @return status code
+ */
+ axis2_status_t (AXIS2_CALL *
+ free) (
+ void *seq_property,
+ const axis2_env_t *env);
+
+ axis2_bool_t (AXIS2_CALL *
+ insert) (
+ sandesha2_in_memory_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ sandesha2_sequence_property_bean_t *bean);
+
+ axis2_bool_t (AXIS2_CALL *
+ remove) (
+ sandesha2_in_memory_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ axis2_char_t *seq_id,
+ axis2_char_t *name);
+
+ sandesha2_sequence_property_bean_t *(AXIS2_CALL *
+ retrieve) (
+ sandesha2_in_memory_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ axis2_char_t *seq_id,
+ axis2_char_t *name);
+
+ axis2_bool_t (AXIS2_CALL *
+ update) (
+ sandesha2_in_memory_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ sandesha2_sequence_property_bean_t *bean);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ find) (
+ sandesha2_in_memory_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ sandesha2_sequence_property_bean_t *bean);
+
+ sandesha2_sequence_property_bean_t *(AXIS2_CALL *
+ find_unique) (
+ sandesha2_in_memory_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ sandesha2_sequence_property_bean_t *bean);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ retrieve_all) (
+ sandesha2_in_memory_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env);
+
+ axis2_bool_t (AXIS2_CALL *
+ update_or_insert) (
+ sandesha2_in_memory_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ sandesha2_sequence_property_bean_t *bean);
+};
+
+struct sandesha2_in_memory_seq_property_mgr
+{
+ sandesha2_in_memory_seq_property_mgr_ops_t *ops;
+};
+
+AXIS2_EXTERN sandesha2_in_memory_seq_property_mgr_t * AXIS2_CALL
+sandesha2_in_memory_seq_property_mgr_create(
+ const axis2_env_t *env,
+ axis2_ctx_t *ctx);
+
+#define SANDESHA2_IN_MEMORY_SEQ_PROPERTY_MGR_FREE(seq_property, env) \
+ (((sandesha2_in_memory_seq_property_mgr_t *) seq_property)->ops->free (seq_property, env))
+
+#define SANDESHA2_IN_MEMORY_SEQ_PROPERTY_INSERT(seq_property, env, bean) \
+ (((sandesha2_in_memory_seq_property_mgr_t *) seq_property)->ops->\
+ insert (seq_property, env, bean))
+
+#define SANDESHA2_IN_MEMORY_SEQ_PROPERTY_REMOVE(seq_property, env, seq_id, name) \
+ (((sandesha2_in_memory_seq_property_mgr_t *) seq_property)->ops->\
+ remove (seq_property, env, seq_id, name))
+
+#define SANDESHA2_IN_MEMORY_SEQ_PROPERTY_RETRIEVE(seq_property, env, seq_id, name) \
+ (((sandesha2_in_memory_seq_property_mgr_t *) seq_property)->ops->\
+ retrieve (seq_property, env, seq_id, name))
+
+#define SANDESHA2_IN_MEMORY_SEQ_PROPERTY_UPDATE(seq_property, env, bean) \
+ (((sandesha2_in_memory_seq_property_mgr_t *) seq_property)->ops->\
+ update (seq_property, env, bean))
+
+#define SANDESHA2_IN_MEMORY_SEQ_PROPERTY_FIND(seq_property, env, bean) \
+ (((sandesha2_in_memory_seq_property_mgr_t *) seq_property)->ops->\
+ find (seq_property, env, bean))
+
+#define SANDESHA2_IN_MEMORY_SEQ_PROPERTY_FIND_UNIQUE(seq_property, env, bean) \
+ (((sandesha2_in_memory_seq_property_mgr_t *) seq_property)->ops->\
+ find_unique (seq_property, env, bean))
+
+#define SANDESHA2_IN_MEMORY_SEQ_PROPERTY_UPDATE_OR_INSERT(seq_property, env, bean) \
+ (((sandesha2_in_memory_seq_property_mgr_t *) seq_property)->ops->\
+ update_or_insert (seq_property, env, bean))
+
+#define SANDESHA2_IN_MEMORY_SEQ_PROPERTY_RETRIEVE_ALL(seq_property, env) \
+ (((sandesha2_in_memory_seq_property_mgr_t *) seq_property)->ops->\
+ retrieve_all (seq_property, env))
+
+
+
+/** @} */
+#ifdef __cplusplus
+}
+#endif
+#endif /* SANDESHA2_IN_MEMORY_SEQ_PROPERTY_MGR_H */
Added: webservices/sandesha/trunk/c/include/sandesha2_in_memory_transaction.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_in_memory_transaction.h?rev=420769&view=auto
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_in_memory_transaction.h (added)
+++ webservices/sandesha/trunk/c/include/sandesha2_in_memory_transaction.h Tue Jul 11 02:02:41 2006
@@ -0,0 +1,90 @@
+/*
+ * 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.
+ */
+
+#ifndef SANDESHA2_IN_MEMORY_TRANSACTION_H
+#define SANDESHA2_IN_MEMORY_TRANSACTION_H
+
+/**
+ * @file sandesha2_in_memory_transaction.h
+ * @brief Sandesha In Memory Transaction Interface
+ */
+
+#include <axis2_allocator.h>
+#include <axis2_env.h>
+#include <axis2_error.h>
+#include <axis2_string.h>
+#include <axis2_utils.h>
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+typedef struct sandesha2_in_memory_transaction sandesha2_in_memory_transaction_t;
+typedef struct sandesha2_in_memory_transaction_ops sandesha2_in_memory_transaction_ops_t;
+
+/** @defgroup sandesha2_in_memory_transaction In Memory Transaction
+ * @ingroup sandesha2
+ * @{
+ */
+
+struct sandesha2_in_memory_transaction_ops
+{
+ /**
+ * Deallocate memory
+ * @return status code
+ */
+ axis2_status_t (AXIS2_CALL *
+ free) (
+ void *seq_mgr,
+ const axis2_env_t *env);
+
+ axis2_status_t (AXIS2_CALL *
+ commit) (
+ sandesha2_in_memory_transaction_t *seq_mgr,
+ const axis2_env_t *env);
+
+ axis2_status_t (AXIS2_CALL *
+ rollback) (
+ sandesha2_in_memory_transaction_t *seq_mgr,
+ const axis2_env_t *env);
+};
+
+struct sandesha2_in_memory_transaction
+{
+ sandesha2_in_memory_transaction_ops_t *ops;
+};
+
+AXIS2_EXTERN sandesha2_in_memory_transaction_t * AXIS2_CALL
+sandesha2_in_memory_transaction_create(
+ const axis2_env_t *env);
+
+#define SANDESHA2_IN_MEMORY_TRANSACTION_FREE(seq_mgr, env) \
+ (((sandesha2_in_memory_transaction_t *) seq_mgr)->ops->free (seq_mgr, env))
+
+#define SANDESHA2_IN_MEMORY_TRANSACTION_COMMIT(seq_mgr, env) \
+ (((sandesha2_in_memory_transaction_t *) seq_mgr)->ops->\
+ commit (seq_mgr, env))
+
+#define SANDESHA2_IN_MEMORY_TRANSACTION_ROLLBACK(seq_mgr, env) \
+ (((sandesha2_in_memory_transaction_t *) seq_mgr)->ops->\
+ rollback (seq_mgr, env))
+
+/** @} */
+#ifdef __cplusplus
+}
+#endif
+#endif /* SANDESHA2_IN_MEMORY_TRANSACTION_H */
Added: webservices/sandesha/trunk/c/include/sandesha2_sequence_report.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_sequence_report.h?rev=420769&view=auto
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_sequence_report.h (added)
+++ webservices/sandesha/trunk/c/include/sandesha2_sequence_report.h Tue Jul 11 02:02:41 2006
@@ -0,0 +1,198 @@
+/*
+ * 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.
+ */
+
+#ifndef SANDESHA2_SEQUENCE_REPORT_H
+#define SANDESHA2_SEQUENCE_REPORT_H
+
+/**
+ * @file sandesha2_sequence_report.h
+ * @brief Sandesha Sequence Report Interface
+ */
+
+#include <axis2_allocator.h>
+#include <axis2_env.h>
+#include <axis2_error.h>
+#include <axis2_string.h>
+#include <axis2_utils.h>
+#include <axis2_hash.h>
+#include <axis2_uri.h>
+#include <axis2_array_list.h>
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+typedef struct sandesha2_sequence_report sandesha2_sequence_report_t;
+typedef struct sandesha2_sequence_report_ops sandesha2_sequence_report_ops_t;
+
+#define SEQUENCE_STATUS_UNKNOWN 0
+#define SEQUENCE_STATUS_INITIAL 1
+#define SEQUENCE_STATUS_ESTABLISHED 2
+#define SEQUENCE_STATUS_TERMINATED 3
+#define SEQUENCE_STATUS_TIMED_OUT 4
+#define MAX_SEQUENCE_STATUS 4
+
+#define SEQUENCE_DIRECTION_UNKNOWN 0
+#define SEQUENCE_DIRECTION_IN 1
+#define SEQUENCE_DIRECTION_OUT 2
+#define MAX_SEQUENCE_DIRECTION 2
+
+
+/** @defgroup sandesha2_sequence_report Sequence Report
+ * @ingroup sandesha2
+ * @{
+ */
+
+struct sandesha2_sequence_report_ops
+{
+ /**
+ * Deallocate memory
+ * @return status code
+ */
+ axis2_status_t (AXIS2_CALL *
+ free) (
+ void *seq_report,
+ const axis2_env_t *env);
+
+ axis2_status_t (AXIS2_CALL *
+ set_sequence_status) (
+ sandesha2_sequence_report_t *report,
+ const axis2_env_t *env,
+ axis2_char_t sequence_status);
+
+ axis2_status_t (AXIS2_CALL *
+ set_sequence_direction) (
+ sandesha2_sequence_report_t *report,
+ const axis2_env_t *env,
+ axis2_char_t sequence_direction);
+
+ axis2_char_t (AXIS2_CALL *
+ get_sequence_status) (
+ sandesha2_sequence_report_t *report,
+ const axis2_env_t *env);
+
+ axis2_char_t (AXIS2_CALL *
+ get_sequence_direction) (
+ sandesha2_sequence_report_t *report,
+ const axis2_env_t *env);
+
+ axis2_char_t *(AXIS2_CALL *
+ get_sequence_id) (
+ sandesha2_sequence_report_t *report,
+ const axis2_env_t *env);
+
+ axis2_status_t (AXIS2_CALL *
+ set_sequence_id) (
+ sandesha2_sequence_report_t *report,
+ const axis2_env_t *env,
+ axis2_char_t *sequence_id);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ get_completed_msgs) (
+ sandesha2_sequence_report_t *report,
+ const axis2_env_t *env);
+
+ axis2_status_t (AXIS2_CALL *
+ add_completed_msg) (
+ sandesha2_sequence_report_t *report,
+ const axis2_env_t *env,
+ long *msg_no);
+
+ axis2_status_t (AXIS2_CALL *
+ set_completed_msgs) (
+ sandesha2_sequence_report_t *report,
+ const axis2_env_t *env,
+ axis2_array_list_t *completed_msgs);
+
+ axis2_char_t *(AXIS2_CALL *
+ get_internal_sequence_id) (
+ sandesha2_sequence_report_t *report,
+ const axis2_env_t *env,
+ long *msg_no);
+
+ axis2_status_t (AXIS2_CALL *
+ set_internal_sequence_id) (
+ sandesha2_sequence_report_t *report,
+ const axis2_env_t *env,
+ axis2_char_t *internal_sequence_id);
+
+};
+
+struct sandesha2_sequence_report
+{
+ sandesha2_sequence_report_ops_t *ops;
+};
+
+AXIS2_EXTERN sandesha2_sequence_report_t * AXIS2_CALL
+sandesha2_sequence_report_create(const axis2_env_t *env);
+
+#define SANDESHA2_SEQUENCE_REPORT_FREE(seq_report, env) \
+ (((sandesha2_sequence_report_t *) seq_report)->ops->free (seq_report, env))
+
+#define SANDESHA2_SEQUENCE_REPORT_SET_SEQUENCE_STATUS(seq_report, env, \
+ sequence_status) \
+ (((sandesha2_sequence_report_t *) seq_report)->ops->\
+ set_sequence_status (seq_report, env, sequence_status))
+
+#define SANDESHA2_SEQUENCE_REPORT_SET_SEQUENCE_DIRECTION(seq_report, env, \
+ sequence_direction) \
+ (((sandesha2_sequence_report_t *) seq_report)->ops->\
+ set_sequence_direction (seq_report, env, sequence_direction))
+
+#define SANDESHA2_SEQUENCE_REPORT_GET_SEQUENCE_STATUS(seq_report, env) \
+ (((sandesha2_sequence_report_t *) seq_report)->ops->\
+ get_sequence_status (seq_report, env))
+
+#define SANDESHA2_SEQUENCE_REPORT_GET_SEQUENCE_DIRECTION(seq_report, env) \
+ (((sandesha2_sequence_report_t *) seq_report)->ops->\
+ get_sequence_direction (seq_report, env))
+
+#define SANDESHA2_SEQUENCE_REPORT_GET_SEQUENCE_ID(seq_report, env) \
+ (((sandesha2_sequence_report_t *) seq_report)->ops->\
+ get_sequence_id (seq_report, env))
+
+#define SANDESHA2_SEQUENCE_REPORT_SET_SEQUENCE_ID(seq_report, env, sequence_id) \
+ (((sandesha2_sequence_report_t *) seq_report)->ops->\
+ set_sequence_id (seq_report, env, sequence_id))
+
+#define SANDESHA2_SEQUENCE_REPORT_GET_COMPLETED_MSGS(seq_report, env) \
+ (((sandesha2_sequence_report_t *) seq_report)->ops->\
+ get_completed_msgs (seq_report, env))
+
+#define SANDESHA2_SEQUENCE_REPORT_ADD_COMPLETED_MSG(seq_report, env, msg_no) \
+ (((sandesha2_sequence_report_t *) seq_report)->ops->\
+ add_completed_msg (seq_report, env, msg_no))
+
+#define SANDESHA2_SEQUENCE_REPORT_SET_COMPLETED_MSGS(seq_report, env, completed_msgs) \
+ (((sandesha2_sequence_report_t *) seq_report)->ops->\
+ set_completed_msgs (seq_report, env, completed_msgs))
+
+#define SANDESHA2_SEQUENCE_REPORT_GET_INTERNAL_SEQUENCE_ID(seq_report, env) \
+ (((sandesha2_sequence_report_t *) seq_report)->ops->\
+ get_internal_sequence_id (seq_report, env))
+
+#define SANDESHA2_SEQUENCE_REPORT_SET_INTERNAL_SEQUENCE_ID(seq_report, env, \
+ sequence_id) \
+ (((sandesha2_sequence_report_t *) seq_report)->ops->\
+ set_internal_sequence_id (seq_report, env, sequence_id))
+
+
+/** @} */
+#ifdef __cplusplus
+}
+#endif
+#endif /* SANDESHA2_SEQUENCE_REPORT_H */
Modified: webservices/sandesha/trunk/c/src/Makefile.am
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/Makefile.am?rev=420769&r1=420768&r2=420769&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/src/Makefile.am (original)
+++ webservices/sandesha/trunk/c/src/Makefile.am Tue Jul 11 02:02:41 2006
@@ -1,4 +1,4 @@
-SUBDIRS = wsrm storage util transport workers
+SUBDIRS = wsrm storage util client transport workers
noinst_LTLIBRARIES = libsandesha2.la
libsandesha2_la_SOURCES = msg_ctx.c
Modified: webservices/sandesha/trunk/c/src/storage/Makefile.am
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/storage/Makefile.am?rev=420769&r1=420768&r2=420769&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/src/storage/Makefile.am (original)
+++ webservices/sandesha/trunk/c/src/storage/Makefile.am Tue Jul 11 02:02:41 2006
@@ -1,4 +1,4 @@
-SUBDIRS = beans
+SUBDIRS = beans inmemory
lib_LTLIBRARIES = libsandesha2_storage.la
libsandesha2_storage_la_SOURCES =
Modified: webservices/sandesha/trunk/c/src/storage/inmemory/in_memory_storage_manager.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/storage/inmemory/in_memory_storage_manager.c?rev=420769&r1=420768&r2=420769&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/src/storage/inmemory/in_memory_storage_manager.c (original)
+++ webservices/sandesha/trunk/c/src/storage/inmemory/in_memory_storage_manager.c Tue Jul 11 02:02:41 2006
@@ -311,13 +311,61 @@
return storage_impl->instance;
}
- public MessageContext retrieveMessageContext(String key,ConfigurationContext context) {
- HashMap storageMap = (HashMap) getContext().getProperty(MESSAGE_MAP_KEY);
- if (storageMap==null)
- return null;
+axis2_msg_ctx_t *AXIS2_CALL
+sandesha2_in_memory_storage_mgr_retrieve_msg_ctx(
+ sandesha2_in_memory_storage_mgr_t *storage,
+ const axis2_env_t *env,
+ axis2_char_t *key,
+ axis2_conf_ctx_t *conf_ctx)
+{
+ sandesha2_in_memory_storage_mgr_impl_t *storage_impl = NULL;
+ axis2_hash_t *storage_map = NULL;
+ axis2_property_t *property = NULL;
+ axis2_conf_ctx_t *conf_ctx = NULL;
+ axis2_ctx_t *ctx = NULL;
+
+ AXIS2_ENV_CHECK(env, AXIS2_FALSE);
+ storage_impl = SANDESHA2_INTF_TO_IMPL(storage);
+
+ conf_ctx = sandesha2_in_memory_storage_mgr_get_ctx(storage, env);
+ ctx = AXIS2_CONF_CTX_GET_BASE(conf_ctx, env);
+ property = AXIS2_CTX_GET_PROPERTY(ctx, env, SANDESHA2_MSG_MAP_KEY);
+ storage_map = (axis2_hash_t *) AXIS2_PROPERTY_GET_VALUE(property, env);
+ if(!storage_map)
+ return NULL;
+
+ return (axis2_msg_ctx_t *) axis2_hash_get(storage_map, key, AXIS2_HASH_KEY_STRING);
+}
- return (MessageContext) storageMap.get(key);
- }
+axis2_status_t AXIS2_CALL
+sandesha2_in_memory_storage_mgr_store_msg_ctx(
+ sandesha2_in_memory_storage_mgr_t *storage,
+ const axis2_env_t *env,
+ axis2_char_t *key,
+ axis2_msg_ctx_t *msg_ctx)
+{
+ sandesha2_in_memory_storage_mgr_impl_t *storage_impl = NULL;
+ axis2_hash_t *storage_map = NULL;
+ axis2_property_t *property = NULL;
+ axis2_conf_ctx_t *conf_ctx = NULL;
+ axis2_ctx_t *ctx = NULL;
+
+ AXIS2_ENV_CHECK(env, AXIS2_FALSE);
+ storage_impl = SANDESHA2_INTF_TO_IMPL(storage);
+
+ conf_ctx = sandesha2_in_memory_storage_mgr_get_ctx(storage, env);
+ ctx = AXIS2_CONF_CTX_GET_BASE(conf_ctx, env);
+ property = AXIS2_CTX_GET_PROPERTY(ctx, env, SANDESHA2_MSG_MAP_KEY);
+ storage_map = (axis2_hash_t *) AXIS2_PROPERTY_GET_VALUE(property, env);
+ if(!storage_map)
+ {
+ storage_map = axis2_hash_make(env);
+
+ }
+
+ return (axis2_msg_ctx_t *) axis2_hash_get(storage_map, key, AXIS2_HASH_KEY_STRING);
+}
+
public void storeMessageContext(String key,MessageContext msgContext) {
HashMap storageMap = (HashMap) getContext().getProperty(MESSAGE_MAP_KEY);
Modified: webservices/sandesha/trunk/c/src/util/utils.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/util/utils.c?rev=420769&r1=420768&r2=420769&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/src/util/utils.c (original)
+++ webservices/sandesha/trunk/c/src/util/utils.c Tue Jul 11 02:02:41 2006
@@ -15,6 +15,7 @@
*/
#include <sandesha2/sandesha2_utils.h>
+#include <sys/timeb.h>
#include <axis2_param.h>
#include <sandesha2/sandesha2_constants.h>
#include <sandesha2/sandesha2_in_order_invoker.h>
@@ -64,6 +65,20 @@
return AXIS2_SUCCESS;
}
+AXIS2_EXTERN long AXIS2_CALL
+sandesha2_util_get_current_time_in_millis(
+ const axis2_env_t *env)
+{
+ struct timeb *tp = AXIS2_MALLOC(env->allocator, sizeof(struct timeb));
+ ftime(tp);
+ long seconds = tp->time;
+ seconds = seconds * 1000;
+ long millis = tp->millitm;
+ millis = millis + seconds;
+
+ return millis;
+}
+
AXIS2_EXTERN axis2_char_t* AXIS2_CALL
sandesha2_utils_get_rm_version(const axis2_env_t *env,
axis2_char_t *key,
@@ -328,3 +343,4 @@
/*TODO implement when the persistent storage is avalable */
return NULL;
}
+>>>>>>> .r420768
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org