blob: b8c26e3ce9f9a2b4add38efcfe96549be39b0b72 [file] [log] [blame]
/*
* 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_phases_info.h>
/**
* @brief Phases Info struct impl
* Axis2 Phases Info impl
*/
typedef struct axis2_phases_info_impl
{
axis2_phases_info_t phases_info;
axis2_array_list_t *in_phases;
axis2_array_list_t *out_phases;
axis2_array_list_t *in_faultphases;
axis2_array_list_t *out_faultphases;
}
axis2_phases_info_impl_t;
#define AXIS2_INTF_TO_IMPL(phases_info) \
((axis2_phases_info_impl_t *)(phases_info))
/***************************** Function headers *******************************/
axis2_status_t AXIS2_CALL
axis2_phases_info_free(
axis2_phases_info_t *phases_info,
const axis2_env_t *env);
axis2_status_t AXIS2_CALL
axis2_phases_info_set_in_phases(
axis2_phases_info_t *phases_info,
const axis2_env_t *env,
axis2_array_list_t *in_phases);
axis2_status_t AXIS2_CALL
axis2_phases_info_set_out_phases(
axis2_phases_info_t *phases_info,
const axis2_env_t *env,
axis2_array_list_t *out_phases);
axis2_status_t AXIS2_CALL
axis2_phases_info_set_in_faultphases(
axis2_phases_info_t *phases_info,
const axis2_env_t *env,
axis2_array_list_t *in_faultphases);
axis2_status_t AXIS2_CALL
axis2_phases_info_set_out_faultphases(
axis2_phases_info_t *phases_info,
const axis2_env_t *env,
axis2_array_list_t *out_faultphases);
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_in_phases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env);
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_out_phases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env);
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_in_faultphases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env);
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_out_faultphases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env);
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_op_in_phases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env);
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_op_out_phases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env);
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_op_in_faultphases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env);
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_op_out_faultphases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env);
axis2_status_t AXIS2_CALL
axis2_phases_info_set_op_phases(
axis2_phases_info_t *phases_info,
const axis2_env_t *env,
struct axis2_op *op_desc);
/***************************** End of function headers ************************/
axis2_phases_info_t *AXIS2_CALL
axis2_phases_info_create(
const axis2_env_t *env)
{
axis2_phases_info_impl_t *phases_info_impl = NULL;
AXIS2_ENV_CHECK(env, NULL);
phases_info_impl = (axis2_phases_info_impl_t *) AXIS2_MALLOC(env->allocator,
sizeof(axis2_phases_info_impl_t));
if (NULL == phases_info_impl)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return NULL;
}
phases_info_impl->in_phases = NULL;
phases_info_impl->out_phases = NULL;
phases_info_impl->in_faultphases = NULL;
phases_info_impl->out_faultphases = NULL;
phases_info_impl->phases_info.ops = (axis2_phases_info_ops_t *)
AXIS2_MALLOC(env->allocator, sizeof(axis2_phases_info_ops_t));
if (NULL == phases_info_impl->phases_info.ops)
{
AXIS2_FREE(env->allocator, phases_info_impl);
phases_info_impl = NULL;
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return NULL;
}
phases_info_impl->phases_info.ops->free = axis2_phases_info_free;
phases_info_impl->phases_info.ops->set_in_phases =
axis2_phases_info_set_in_phases;
phases_info_impl->phases_info.ops->set_out_phases =
axis2_phases_info_set_out_phases;
phases_info_impl->phases_info.ops->set_in_faultphases =
axis2_phases_info_set_in_faultphases;
phases_info_impl->phases_info.ops->set_out_faultphases =
axis2_phases_info_set_out_faultphases;
phases_info_impl->phases_info.ops->get_in_phases =
axis2_phases_info_get_in_phases;
phases_info_impl->phases_info.ops->get_out_phases =
axis2_phases_info_get_out_phases;
phases_info_impl->phases_info.ops->get_in_faultphases =
axis2_phases_info_get_in_faultphases;
phases_info_impl->phases_info.ops->get_out_faultphases =
axis2_phases_info_get_out_faultphases;
phases_info_impl->phases_info.ops->get_op_in_phases =
axis2_phases_info_get_op_in_phases;
phases_info_impl->phases_info.ops->get_op_out_phases =
axis2_phases_info_get_op_out_phases;
phases_info_impl->phases_info.ops->get_op_in_faultphases =
axis2_phases_info_get_op_in_faultphases;
phases_info_impl->phases_info.ops->get_op_out_faultphases =
axis2_phases_info_get_op_out_faultphases;
phases_info_impl->phases_info.ops->set_op_phases =
axis2_phases_info_set_op_phases;
return &(phases_info_impl->phases_info);
}
/******************************************************************************/
axis2_status_t AXIS2_CALL
axis2_phases_info_free(
axis2_phases_info_t *phases_info,
const axis2_env_t *env)
{
axis2_phases_info_impl_t *phases_info_impl = NULL;
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
phases_info_impl = AXIS2_INTF_TO_IMPL(phases_info);
if (phases_info_impl->in_phases)
{
AXIS2_ARRAY_LIST_FREE(phases_info_impl->in_phases, env);
phases_info_impl->in_phases = NULL;
}
if (phases_info_impl->out_phases)
{
AXIS2_ARRAY_LIST_FREE(phases_info_impl->out_phases, env);
phases_info_impl->out_phases = NULL;
}
if (phases_info_impl->in_faultphases)
{
AXIS2_ARRAY_LIST_FREE(phases_info_impl->in_faultphases, env);
phases_info_impl->in_faultphases = NULL;
}
if (phases_info_impl->out_faultphases)
{
AXIS2_ARRAY_LIST_FREE(phases_info_impl->out_faultphases, env);
phases_info_impl->out_faultphases = NULL;
}
if (phases_info->ops)
{
AXIS2_FREE(env->allocator, phases_info->ops);
phases_info->ops = NULL;
}
if (phases_info_impl)
{
AXIS2_FREE(env->allocator, phases_info_impl);
phases_info_impl = NULL;
}
return AXIS2_SUCCESS;
}
axis2_status_t AXIS2_CALL
axis2_phases_info_set_in_phases(
axis2_phases_info_t *phases_info,
const axis2_env_t *env,
axis2_array_list_t *in_phases)
{
axis2_phases_info_impl_t *phases_info_impl = NULL;
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
AXIS2_PARAM_CHECK(env->error, in_phases, AXIS2_FAILURE);
phases_info_impl = AXIS2_INTF_TO_IMPL(phases_info);
if (phases_info_impl->in_phases)
{
AXIS2_ARRAY_LIST_FREE(phases_info_impl->in_phases, env);
phases_info_impl->in_phases = NULL;
}
phases_info_impl->in_phases = in_phases;
return AXIS2_SUCCESS;
}
axis2_status_t AXIS2_CALL
axis2_phases_info_set_out_phases(
axis2_phases_info_t *phases_info,
const axis2_env_t *env,
axis2_array_list_t *out_phases)
{
axis2_phases_info_impl_t *phases_info_impl = NULL;
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
AXIS2_PARAM_CHECK(env->error, out_phases, AXIS2_FAILURE);
phases_info_impl = AXIS2_INTF_TO_IMPL(phases_info);
if (phases_info_impl->out_phases)
{
AXIS2_ARRAY_LIST_FREE(phases_info_impl->out_phases, env);
phases_info_impl->out_phases = NULL;
}
phases_info_impl->out_phases = out_phases;
return AXIS2_SUCCESS;
}
axis2_status_t AXIS2_CALL
axis2_phases_info_set_in_faultphases(
axis2_phases_info_t *phases_info,
const axis2_env_t *env,
axis2_array_list_t *in_faultphases)
{
axis2_phases_info_impl_t *phases_info_impl = NULL;
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
AXIS2_PARAM_CHECK(env->error, in_faultphases, AXIS2_FAILURE);
phases_info_impl = AXIS2_INTF_TO_IMPL(phases_info);
if (phases_info_impl->in_faultphases)
{
AXIS2_ARRAY_LIST_FREE(phases_info_impl->in_faultphases, env);
phases_info_impl->in_faultphases = NULL;
}
phases_info_impl->in_faultphases = in_faultphases;
return AXIS2_SUCCESS;
}
axis2_status_t AXIS2_CALL
axis2_phases_info_set_out_faultphases(
axis2_phases_info_t *phases_info,
const axis2_env_t *env,
axis2_array_list_t *out_faultphases)
{
axis2_phases_info_impl_t *phases_info_impl = NULL;
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
AXIS2_PARAM_CHECK(env->error, out_faultphases, AXIS2_FAILURE);
phases_info_impl = AXIS2_INTF_TO_IMPL(phases_info);
if (phases_info_impl->out_faultphases)
{
AXIS2_ARRAY_LIST_FREE(phases_info_impl->out_faultphases, env);
phases_info_impl->out_faultphases = NULL;
}
phases_info_impl->out_faultphases = out_faultphases;
return AXIS2_SUCCESS;
}
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_in_phases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env)
{
AXIS2_ENV_CHECK(env, NULL);
return AXIS2_INTF_TO_IMPL(phases_info)->in_phases;
}
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_out_phases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env)
{
AXIS2_ENV_CHECK(env, NULL);
return AXIS2_INTF_TO_IMPL(phases_info)->out_phases;
}
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_in_faultphases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env)
{
AXIS2_ENV_CHECK(env, NULL);
return AXIS2_INTF_TO_IMPL(phases_info)->in_faultphases;
}
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_out_faultphases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env)
{
AXIS2_ENV_CHECK(env, NULL);
return AXIS2_INTF_TO_IMPL(phases_info)->out_faultphases;
}
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_op_in_phases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env)
{
axis2_phases_info_impl_t *phases_info_impl = NULL;
struct axis2_phase *phase = NULL;
int i = 0;
int size = 0;
axis2_char_t *phase_name = NULL;
axis2_array_list_t *op_in_phases = NULL;
axis2_status_t status = AXIS2_FAILURE;
AXIS2_ENV_CHECK(env, NULL);
phases_info_impl = AXIS2_INTF_TO_IMPL(phases_info);
op_in_phases = axis2_array_list_create(env, 0);
if (!op_in_phases)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return NULL;
}
phase = axis2_phase_create(env, AXIS2_PHASE_POLICY_DETERMINATION);
status = AXIS2_ARRAY_LIST_ADD(op_in_phases, env, phase);
if (AXIS2_SUCCESS != status)
{
AXIS2_PHASE_FREE(phase, env);
phase = NULL;
AXIS2_ARRAY_LIST_FREE(op_in_phases, env);
op_in_phases = NULL;
return NULL;
}
if (!phases_info_impl->in_phases)
{
return op_in_phases;
}
size = AXIS2_ARRAY_LIST_SIZE(phases_info_impl->in_phases, env);
for (i = 0; i < size; i++)
{
phase_name = (axis2_char_t *) AXIS2_ARRAY_LIST_GET(
phases_info_impl->in_phases, env, i);
if (0 == AXIS2_STRCMP(AXIS2_PHASE_TRANSPORTIN, phase_name) ||
0 == AXIS2_STRCMP(AXIS2_PHASE_PRE_DISPATCH, phase_name) ||
0 == AXIS2_STRCMP(AXIS2_PHASE_DISPATCH, phase_name) ||
0 == AXIS2_STRCMP(AXIS2_PHASE_POST_DISPATCH, phase_name))
{
/* Do nothing */
}
else
{
phase = axis2_phase_create(env, phase_name);
if (phase)
{
status = AXIS2_ARRAY_LIST_ADD(op_in_phases, env, phase);
}
if (AXIS2_SUCCESS != status)
{
int i = 0;
int size = 0;
AXIS2_PHASE_FREE(phase, env);
phase = NULL;
size = AXIS2_ARRAY_LIST_SIZE(op_in_phases, env);
for (i = 0; i < size; i++)
{
phase = AXIS2_ARRAY_LIST_GET(op_in_phases, env, i);
AXIS2_PHASE_FREE(phase, env);
phase = NULL;
}
AXIS2_ARRAY_LIST_FREE(op_in_phases, env);
op_in_phases = NULL;
return NULL;
}
}
}
return op_in_phases;
}
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_op_out_phases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env)
{
axis2_phases_info_impl_t *phases_info_impl = NULL;
struct axis2_phase *phase = NULL;
int i = 0;
int size = 0;
axis2_char_t *phase_name = NULL;
axis2_array_list_t *op_out_phases = NULL;
axis2_status_t status = AXIS2_FAILURE;
AXIS2_ENV_CHECK(env, NULL);
phases_info_impl = AXIS2_INTF_TO_IMPL(phases_info);
if (phases_info_impl->out_phases)
size = AXIS2_ARRAY_LIST_SIZE(phases_info_impl->out_phases, env);
op_out_phases = axis2_array_list_create(env, 0);
if (!op_out_phases)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return NULL;
}
for (i = 0; i < size; i++)
{
phase_name = (axis2_char_t *) AXIS2_ARRAY_LIST_GET(phases_info_impl->
out_phases, env, i);
if (0 == AXIS2_STRCMP(AXIS2_PHASE_TRANSPORT_OUT, phase_name))
{
/* Do Nothing */
}
else
{
phase = axis2_phase_create(env, phase_name);
if (phase)
status = AXIS2_ARRAY_LIST_ADD(op_out_phases, env, phase);
if (AXIS2_SUCCESS != status)
{
int i = 0;
int size = 0;
AXIS2_PHASE_FREE(phase, env);
phase = NULL;
size = AXIS2_ARRAY_LIST_SIZE(op_out_phases, env);
for (i = 0; i < size; i++)
{
phase = AXIS2_ARRAY_LIST_GET(op_out_phases, env, i);
AXIS2_PHASE_FREE(phase, env);
phase = NULL;
}
AXIS2_ARRAY_LIST_FREE(op_out_phases, env);
op_out_phases = NULL;
return NULL;
}
}
}
phase = axis2_phase_create(env, AXIS2_PHASE_POLICY_DETERMINATION);
if (phase)
status = AXIS2_ARRAY_LIST_ADD(op_out_phases, env, phase);
if (AXIS2_SUCCESS != status)
{
int i = 0;
int size = 0;
AXIS2_PHASE_FREE(phase, env);
phase = NULL;
size = AXIS2_ARRAY_LIST_SIZE(op_out_phases, env);
for (i = 0; i < size; i++)
{
phase = AXIS2_ARRAY_LIST_GET(op_out_phases, env, i);
AXIS2_PHASE_FREE(phase, env);
phase = NULL;
}
AXIS2_ARRAY_LIST_FREE(op_out_phases, env);
op_out_phases = NULL;
return NULL;
}
phase = axis2_phase_create(env, AXIS2_PHASE_MESSAGE_OUT);
if (phase)
status = AXIS2_ARRAY_LIST_ADD(op_out_phases, env, phase);
if (AXIS2_SUCCESS != status)
{
int i = 0;
int size = 0;
AXIS2_PHASE_FREE(phase, env);
phase = NULL;
size = AXIS2_ARRAY_LIST_SIZE(op_out_phases, env);
for (i = 0; i < size; i++)
{
phase = AXIS2_ARRAY_LIST_GET(op_out_phases, env, i);
AXIS2_PHASE_FREE(phase, env);
phase = NULL;
}
AXIS2_ARRAY_LIST_FREE(op_out_phases, env);
op_out_phases = NULL;
return NULL;
}
return op_out_phases;
}
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_op_in_faultphases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env)
{
axis2_phases_info_impl_t *phases_info_impl = NULL;
int i = 0;
int size = 0;
axis2_status_t status = AXIS2_FAILURE;
axis2_char_t *phase_name = NULL;
axis2_array_list_t *op_in_faultphases = NULL;
struct axis2_phase *phase = NULL;
AXIS2_ENV_CHECK(env, NULL);
phases_info_impl = AXIS2_INTF_TO_IMPL(phases_info);
if (!phases_info_impl->in_faultphases)
{
return NULL;
}
size = AXIS2_ARRAY_LIST_SIZE(phases_info_impl->in_faultphases, env);
if (0 == size)
{
return NULL;
}
op_in_faultphases = axis2_array_list_create(env, 0);
if (!op_in_faultphases)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return NULL;
}
for (i = 0; i < size; i++)
{
phase_name = (axis2_char_t *) AXIS2_ARRAY_LIST_GET(phases_info_impl->
in_faultphases, env, i);
phase = axis2_phase_create(env, phase_name);
if (phase)
status = AXIS2_ARRAY_LIST_ADD(op_in_faultphases, env, phase);
if (AXIS2_SUCCESS != status)
{
int i = 0;
int size = 0;
AXIS2_PHASE_FREE(phase, env);
phase = NULL;
size = AXIS2_ARRAY_LIST_SIZE(op_in_faultphases, env);
for (i = 0; i < size; i++)
{
phase = AXIS2_ARRAY_LIST_GET(op_in_faultphases, env, i);
AXIS2_PHASE_FREE(phase, env);
phase = NULL;
}
AXIS2_ARRAY_LIST_FREE(op_in_faultphases, env);
op_in_faultphases = NULL;
return NULL;
}
}
return op_in_faultphases;
}
axis2_array_list_t *AXIS2_CALL
axis2_phases_info_get_op_out_faultphases(
const axis2_phases_info_t *phases_info,
const axis2_env_t *env)
{
axis2_phases_info_impl_t *phases_info_impl = NULL;
int i = 0;
int size = 0;
axis2_status_t status = AXIS2_FAILURE;
axis2_char_t *phase_name = NULL;
axis2_array_list_t *op_out_faultphases = NULL;
struct axis2_phase *phase = NULL;
AXIS2_ENV_CHECK(env, NULL);
phases_info_impl = AXIS2_INTF_TO_IMPL(phases_info);
if (!phases_info_impl->out_faultphases)
{
return NULL;
}
size = AXIS2_ARRAY_LIST_SIZE(phases_info_impl->out_faultphases, env);
if (0 == size)
return NULL;
op_out_faultphases = axis2_array_list_create(env, 0);
if (!op_out_faultphases)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return NULL;
}
for (i = 0; i < size; i++)
{
phase_name = (axis2_char_t *) AXIS2_ARRAY_LIST_GET(phases_info_impl->
out_faultphases, env, i);
phase = axis2_phase_create(env, phase_name);
if (phase)
status = AXIS2_ARRAY_LIST_ADD(op_out_faultphases, env, phase);
if (AXIS2_SUCCESS != status)
{
int i = 0;
int size = 0;
AXIS2_PHASE_FREE(phase, env);
phase = NULL;
size = AXIS2_ARRAY_LIST_SIZE(op_out_faultphases, env);
for (i = 0; i < size; i++)
{
phase = AXIS2_ARRAY_LIST_GET(op_out_faultphases, env, i);
AXIS2_PHASE_FREE(phase, env);
phase = NULL;
}
AXIS2_ARRAY_LIST_FREE(op_out_faultphases, env);
op_out_faultphases = NULL;
return NULL;
}
}
return op_out_faultphases;
}
axis2_status_t AXIS2_CALL
axis2_phases_info_set_op_phases(
axis2_phases_info_t *phases_info,
const axis2_env_t *env,
axis2_op_t *op_desc)
{
axis2_status_t status = AXIS2_FAILURE;
axis2_array_list_t *op_in_phases = NULL;
axis2_array_list_t *op_out_phases = NULL;
axis2_array_list_t *op_in_faultphases = NULL;
axis2_array_list_t *op_out_faultphases = NULL;
axis2_phases_info_impl_t *phases_info_impl = NULL;
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
AXIS2_PARAM_CHECK(env->error, op_desc, AXIS2_FAILURE);
phases_info_impl = AXIS2_INTF_TO_IMPL(phases_info);
op_in_phases = axis2_phases_info_get_op_in_phases(phases_info, env);
if (NULL == op_in_phases)
{
status = AXIS2_ERROR_GET_STATUS_CODE(env->error);
/* op_in_phases cannot be NULL */
return status;
}
op_out_phases = axis2_phases_info_get_op_out_phases(phases_info, env);
if (NULL == op_out_phases)
{
status = AXIS2_ERROR_GET_STATUS_CODE(env->error);
/* op_out_phases cannot be NULL */
return status;
}
op_in_faultphases = axis2_phases_info_get_op_in_faultphases(phases_info, env);
op_out_faultphases = axis2_phases_info_get_op_out_faultphases(phases_info,
env);
status = AXIS2_OP_SET_IN_FLOW(op_desc, env, op_in_phases);
status = AXIS2_OP_SET_OUT_FLOW(op_desc, env, op_out_phases);
if (op_in_faultphases)
{
status = AXIS2_OP_SET_FAULT_IN_FLOW(op_desc, env,
op_in_faultphases);
}
else
{
status = AXIS2_ERROR_GET_STATUS_CODE(env->error);
if (AXIS2_SUCCESS != status)
{
return status;
}
}
if (op_out_faultphases)
{
status = AXIS2_OP_SET_FAULT_OUT_FLOW(op_desc, env,
op_out_faultphases);
}
else
{
status = AXIS2_ERROR_GET_STATUS_CODE(env->error);
if (AXIS2_SUCCESS != status)
{
return status;
}
}
return status;
}