From 0425aadc78680e53000fd0108b540d6eca048516 Mon Sep 17 00:00:00 2001 From: gmcdonald Date: Sat, 13 Feb 2010 01:32:03 +0000 Subject: Moving axis svn, part of TLP move INFRA-2441 git-svn-id: http://svn.apache.org/repos/asf/axis/axis2/c/core/trunk@909681 13f79535-47bb-0310-9956-ffa450edef68 --- src/core/phaseresolver/phase_holder.c | 243 ++++++++++++++++++++++++++++++++++ 1 file changed, 243 insertions(+) create mode 100644 src/core/phaseresolver/phase_holder.c (limited to 'src/core/phaseresolver/phase_holder.c') diff --git a/src/core/phaseresolver/phase_holder.c b/src/core/phaseresolver/phase_holder.c new file mode 100644 index 0000000..f371dd4 --- /dev/null +++ b/src/core/phaseresolver/phase_holder.c @@ -0,0 +1,243 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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 + +struct axis2_phase_holder +{ + axutil_array_list_t *phase_list; +}; + +AXIS2_EXTERN axis2_phase_holder_t *AXIS2_CALL +axis2_phase_holder_create( + const axutil_env_t * env) +{ + axis2_phase_holder_t *phase_holder = NULL; + + AXIS2_ENV_CHECK(env, NULL); + + phase_holder = (axis2_phase_holder_t *)AXIS2_MALLOC(env-> allocator, + sizeof(axis2_phase_holder_t)); + + if(!phase_holder) + { + AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE); + return NULL; + } + + phase_holder->phase_list = NULL; + + return phase_holder; +} + +AXIS2_EXTERN axis2_phase_holder_t *AXIS2_CALL +axis2_phase_holder_create_with_phases( + const axutil_env_t * env, + axutil_array_list_t * phases) +{ + axis2_phase_holder_t *phase_holder = NULL; + + AXIS2_ENV_CHECK(env, NULL); + + if(!phases) + { + return NULL; + } + + phase_holder = (axis2_phase_holder_t *)axis2_phase_holder_create(env); + phase_holder->phase_list = phases; + + return phase_holder; +} + +AXIS2_EXTERN void AXIS2_CALL +axis2_phase_holder_free( + axis2_phase_holder_t * phase_holder, + const axutil_env_t * env) +{ + AXIS2_ENV_CHECK(env, void); + + if(phase_holder) + { + AXIS2_FREE(env->allocator, phase_holder); + } + + return; +} + +AXIS2_EXTERN axis2_bool_t AXIS2_CALL +axis2_phase_holder_is_phase_exist( + axis2_phase_holder_t * phase_holder, + const axutil_env_t * env, + const axis2_char_t * phase_name) +{ + int size = 0; + int i = 0; + axis2_phase_t *phase = NULL; + + AXIS2_ENV_CHECK(env, AXIS2_FALSE); + AXIS2_PARAM_CHECK(env->error, phase_name, AXIS2_FALSE); + + size = axutil_array_list_size(phase_holder->phase_list, env); + + for(i = 0; i < size; i++) + { + const axis2_char_t *phase_name_l = NULL; + + phase = (axis2_phase_t *)axutil_array_list_get(phase_holder-> phase_list, env, i); + phase_name_l = axis2_phase_get_name(phase, env); + if(0 == axutil_strcmp(phase_name_l, phase_name)) + { + return AXIS2_TRUE; + } + } + return AXIS2_FALSE; +} + +AXIS2_EXTERN axis2_status_t AXIS2_CALL +axis2_phase_holder_add_handler( + axis2_phase_holder_t * phase_holder, + const axutil_env_t * env, + axis2_handler_desc_t * handler) +{ + const axis2_char_t *phase_name = NULL; + axis2_status_t status = AXIS2_FAILURE; + + AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI, "axis2_phase_holder_add_handler start"); + AXIS2_ENV_CHECK(env, AXIS2_FAILURE); + AXIS2_PARAM_CHECK(env->error, handler, AXIS2_FAILURE); + + phase_name = axis2_phase_rule_get_name(axis2_handler_desc_get_rules(handler, env), env); + if(AXIS2_TRUE == axis2_phase_holder_is_phase_exist(phase_holder, env, phase_name)) + { + axis2_phase_t *phase = NULL; + + phase = axis2_phase_holder_get_phase(phase_holder, env, phase_name); + status = axis2_phase_add_handler_desc(phase, env, handler); + AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, "Add handler %s to phase %s", + axutil_string_get_buffer(axis2_handler_desc_get_name(handler, env), env), phase_name); + } + else + { + AXIS2_ERROR_SET(env->error, AXIS2_ERROR_INVALID_PHASE, AXIS2_FAILURE); + status = AXIS2_FAILURE; + } + AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI, "axis2_phase_holder_add_handler end status = %s", + status ? "SUCCESS" : "FAILURE"); + return status; +} + +AXIS2_EXTERN axis2_status_t AXIS2_CALL +axis2_phase_holder_remove_handler( + axis2_phase_holder_t * phase_holder, + const axutil_env_t * env, + axis2_handler_desc_t * handler) +{ + const axis2_char_t *phase_name = NULL; + axis2_status_t status = AXIS2_FAILURE; + + AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI, "axis2_phase_holder_remove_handler start"); + AXIS2_ENV_CHECK(env, AXIS2_FAILURE); + AXIS2_PARAM_CHECK(env->error, handler, AXIS2_FAILURE); + + phase_name = axis2_phase_rule_get_name(axis2_handler_desc_get_rules(handler, env), env); + if(AXIS2_TRUE == axis2_phase_holder_is_phase_exist(phase_holder, env, phase_name)) + { + axis2_phase_t *phase = NULL; + + phase = axis2_phase_holder_get_phase(phase_holder, env, phase_name); + status = axis2_phase_remove_handler_desc(phase, env, handler); + AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, "Remove handler %s from phase %s", + axutil_string_get_buffer(axis2_handler_desc_get_name(handler, env), env), phase_name); + } + else + { + AXIS2_ERROR_SET(env->error, AXIS2_ERROR_INVALID_PHASE, AXIS2_FAILURE); + status = AXIS2_FAILURE; + } + AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI, "axis2_phase_holder_remove_handler end status = %s", + status ? "SUCCESS" : "FAILURE"); + return status; +} + +AXIS2_EXTERN axis2_phase_t *AXIS2_CALL +axis2_phase_holder_get_phase( + const axis2_phase_holder_t * phase_holder, + const axutil_env_t * env, + const axis2_char_t * phase_name) +{ + int size = 0; + int i = 0; + axis2_phase_t *phase = NULL; + + AXIS2_PARAM_CHECK(env->error, phase_name, NULL); + + size = axutil_array_list_size(phase_holder->phase_list, env); + + for(i = 0; i < size; i++) + { + const axis2_char_t *phase_name_l = NULL; + phase = (axis2_phase_t *)axutil_array_list_get(phase_holder-> phase_list, env, i); + phase_name_l = axis2_phase_get_name(phase, env); + if(0 == axutil_strcmp(phase_name_l, phase_name)) + { + return phase; + } + } + + return NULL; +} + +/* This function is deprecated */ +AXIS2_EXTERN axis2_status_t AXIS2_CALL +axis2_phase_holder_build_transport_handler_chain( + axis2_phase_holder_t * phase_holder, + const axutil_env_t * env, + axis2_phase_t * phase, + axutil_array_list_t * handlers) +{ + axis2_handler_t *handler = NULL; + int size = 0; + int status = AXIS2_FAILURE; + int i = 0; + axis2_handler_desc_t *handler_desc = NULL; + + AXIS2_ENV_CHECK(env, AXIS2_FAILURE); + AXIS2_PARAM_CHECK(env->error, phase, AXIS2_FAILURE); + AXIS2_PARAM_CHECK(env->error, handlers, AXIS2_FAILURE); + + size = axutil_array_list_size(handlers, env); + + for(i = 0; i < size; i++) + { + handler_desc = (axis2_handler_desc_t *)axutil_array_list_get(handlers, env, i); + status = axis2_handler_init(handler, env, handler_desc); + if(AXIS2_FAILURE == status) + { + return status; + } + + status = axis2_handler_desc_set_handler(handler_desc, env, handler); + if(AXIS2_FAILURE == status) + { + return status; + } + + status = axis2_phase_add_handler(phase, env, handler); + } + return status; +} -- cgit v1.1-32-gdbae