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 --- test/core/Makefile.am | 3 + test/core/addr/Makefile.am | 21 ++ test/core/addr/test_addr.c | 182 +++++++++++ test/core/clientapi/Makefile.am | 49 +++ test/core/clientapi/addr_echo.xml | 23 ++ test/core/clientapi/echo.xml | 1 + test/core/clientapi/test_client.c | 182 +++++++++++ test/core/clientapi/test_clientapi.c | 119 +++++++ .../core/clientapi/test_svc_client_handler_count.c | 22 ++ test/core/context/Makefile.am | 21 ++ test/core/context/test_context.c | 124 +++++++ test/core/deployment/Makefile.am | 25 ++ test/core/deployment/axis2.xml | 126 ++++++++ test/core/deployment/test_deployment.c | 360 +++++++++++++++++++++ test/core/description/Makefile.am | 26 ++ test/core/description/test_description.c | 215 ++++++++++++ test/core/engine/Makefile.am | 25 ++ test/core/engine/test_engine.c | 123 +++++++ test/core/transport/Makefile.am | 1 + test/core/transport/http/Makefile.am | 21 ++ test/core/transport/http/test_http_transport.c | 274 ++++++++++++++++ 21 files changed, 1943 insertions(+) create mode 100644 test/core/Makefile.am create mode 100644 test/core/addr/Makefile.am create mode 100644 test/core/addr/test_addr.c create mode 100644 test/core/clientapi/Makefile.am create mode 100644 test/core/clientapi/addr_echo.xml create mode 100644 test/core/clientapi/echo.xml create mode 100644 test/core/clientapi/test_client.c create mode 100644 test/core/clientapi/test_clientapi.c create mode 100644 test/core/clientapi/test_svc_client_handler_count.c create mode 100644 test/core/context/Makefile.am create mode 100644 test/core/context/test_context.c create mode 100644 test/core/deployment/Makefile.am create mode 100644 test/core/deployment/axis2.xml create mode 100644 test/core/deployment/test_deployment.c create mode 100644 test/core/description/Makefile.am create mode 100644 test/core/description/test_description.c create mode 100644 test/core/engine/Makefile.am create mode 100644 test/core/engine/test_engine.c create mode 100644 test/core/transport/Makefile.am create mode 100644 test/core/transport/http/Makefile.am create mode 100644 test/core/transport/http/test_http_transport.c (limited to 'test/core') diff --git a/test/core/Makefile.am b/test/core/Makefile.am new file mode 100644 index 0000000..3fa8f58 --- /dev/null +++ b/test/core/Makefile.am @@ -0,0 +1,3 @@ +TESTS = +SUBDIRS = description context engine deployment addr transport clientapi + diff --git a/test/core/addr/Makefile.am b/test/core/addr/Makefile.am new file mode 100644 index 0000000..9d42172 --- /dev/null +++ b/test/core/addr/Makefile.am @@ -0,0 +1,21 @@ +TESTS = test_addr +check_PROGRAMS = test_addr +noinst_PROGRAMS = test_addr +SUBDIRS = +AM_CFLAGS = -g -pthread +test_addr_SOURCES = test_addr.c + +test_addr_LDADD = \ + ../../../util/src/libaxutil.la \ + ../../../axiom/src/om/libaxis2_axiom.la \ + ../../../axiom/src/parser/$(WRAPPER_DIR)/libaxis2_parser.la \ + $(top_builddir)/neethi/src/libneethi.la \ + $(top_builddir)/src/core/engine/libaxis2_engine.la \ + $(top_builddir)/src/core/transport/http/common/libaxis2_http_common.la + +INCLUDES = -I${CUTEST_HOME}/include \ + -I$(top_builddir)/src/xml/guththila \ + -I$(top_builddir)/include \ + -I ../../../util/include \ + -I ../../../axiom/include + diff --git a/test/core/addr/test_addr.c b/test/core/addr/test_addr.c new file mode 100644 index 0000000..c013a57 --- /dev/null +++ b/test/core/addr/test_addr.c @@ -0,0 +1,182 @@ + +/* + * 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 +#include +#include +#include +#include + +int +axis2_test_msg_info_headers( + ) +{ + axis2_endpoint_ref_t *to = NULL; + axis2_endpoint_ref_t *from = NULL; + axis2_endpoint_ref_t *reply_to = NULL; + axis2_endpoint_ref_t *fault_to = NULL; + axis2_endpoint_ref_t *axis2_endpoint_ref = NULL; + axis2_status_t status = AXIS2_FAILURE; + axis2_msg_info_headers_t *axis2_msg_info_headers = NULL; + axutil_allocator_t *allocator = axutil_allocator_init(NULL); + const axutil_env_t *env = axutil_env_create(allocator); + const axis2_char_t *action = "test action"; + const axis2_char_t *get_action = NULL; + to = axis2_endpoint_ref_create(env, "to"); + from = axis2_endpoint_ref_create(env, "from"); + reply_to = axis2_endpoint_ref_create(env, "reply to"); + fault_to = axis2_endpoint_ref_create(env, "fault to"); + + axis2_msg_info_headers = axis2_msg_info_headers_create(env, NULL, action); + if (axis2_msg_info_headers) + printf("SUCCESS axis2_msg_info_headers_create\n"); + else + { + printf("ERROR AXIS2_MSG_INFO_HEADERS_CREATE\n"); + return -1; + } + + status = axis2_msg_info_headers_set_to(axis2_msg_info_headers, env, to); + + if (status == AXIS2_SUCCESS) + printf("SUCCESS axis2_msg_info_headers_set_to\n"); + else + { + printf("ERROR axis2_msg_info_headers_set_to"); + return -1; + } + + axis2_endpoint_ref = + axis2_msg_info_headers_get_to(axis2_msg_info_headers, env); + + if (axis2_endpoint_ref) + printf("SUCCESS axis2_msg_info_headers_get_to\n"); + else + { + printf("ERROR axis2_msg_info_headers_get_to\n"); + return -1; + } + + status = AXIS2_FAILURE; + status = axis2_msg_info_headers_set_from(axis2_msg_info_headers, env, from); + + if (status) + printf("SUCCESS axis2_msg_info_headers_set_from\n"); + else + { + printf("ERROR axis2_msg_info_headers_set_from\n"); + return -1; + } + + axis2_endpoint_ref = NULL; + axis2_endpoint_ref = + axis2_msg_info_headers_get_from(axis2_msg_info_headers, env); + + if (axis2_endpoint_ref) + printf("SUCCESS axis2_msg_info_headers_get_from\n"); + else + { + printf("ERROR axis2_msg_info_headers_get_from\n"); + return -1; + } + + axis2_endpoint_ref = NULL; + axis2_endpoint_ref = + axis2_msg_info_headers_get_reply_to(axis2_msg_info_headers, env); + + if (status) + printf("SUCCESS axis2_msg_info_headers_get_reply_to\n"); + else + { + printf("ERROR axis2_msg_info_headers_get_reply_to\n"); + return -1; + } + + status = AXIS2_FAILURE; + status = + axis2_msg_info_headers_set_reply_to(axis2_msg_info_headers, env, + reply_to); + + if (status) + printf("SUCCESS axis2_msg_info_headers_set_reply_to\n"); + else + { + printf("ERROR axis2_msg_info_headers_set_reply_to\n"); + return -1; + } + + status = AXIS2_FAILURE; + status = + axis2_msg_info_headers_set_fault_to(axis2_msg_info_headers, env, + fault_to); + if (status) + printf("SUCCESS axis2_msg_info_headers_set_fault_to\n"); + else + { + printf("ERROR axis2_msg_info_headers_set_fault_to\n"); + return -1; + } + + axis2_endpoint_ref = NULL; + axis2_endpoint_ref = + axis2_msg_info_headers_get_fault_to(axis2_msg_info_headers, env); + if (axis2_endpoint_ref) + printf("SUCCESS axis2_msg_info_headers_get_fault_to\n"); + else + { + printf("ERROR axis2_msg_info_headers_get_fault_to\n"); + return -1; + } + + get_action = axis2_msg_info_headers_get_action(axis2_msg_info_headers, env); + if (get_action) + printf("SUCCESS axis2_msg_info_headers_get_action\n"); + else + { + printf("ERROR axis2_msg_info_headers_get_action\n"); + return -1; + } + + status = AXIS2_FAILURE; + status = + axis2_msg_info_headers_set_action(axis2_msg_info_headers, env, action); + if (status) + printf("SUCCESS axis2_msg_info_headers_set_action\n"); + else + { + printf("ERROR axis2_msg_info_headers_set_action\n"); + } + + status = AXIS2_FAILURE; + /* status = axis2_msg_info_headers_free(axis2_msg_info_headers, env); */ + if (status) + printf("SUCCESS axis2_msg_info_headers_free\n"); + else + { + printf("ERROR axis2_msg_info_headers_free\n"); + } + return 0; +} + +int +main( + ) +{ + axis2_test_msg_info_headers(); + return 0; +} diff --git a/test/core/clientapi/Makefile.am b/test/core/clientapi/Makefile.am new file mode 100644 index 0000000..e88c350 --- /dev/null +++ b/test/core/clientapi/Makefile.am @@ -0,0 +1,49 @@ +TESTS = test_client test_clientapi test_svc_client_handler_count +noinst_PROGRAMS = test_client test_clientapi test_svc_client_handler_count +check_PROGRAMS = test_client test_clientapi test_svc_client_handler_count +SUBDIRS = +AM_CFLAGS = -g -pthread +test_client_SOURCES = test_client.c +test_clientapi_SOURCES = test_clientapi.c +test_svc_client_handler_count_SOURCES = test_svc_client_handler_count.c + +test_clientapi_LDADD = \ + ../../../util/src/libaxutil.la \ + ../../../axiom/src/om/libaxis2_axiom.la \ + ../../../axiom/src/parser/$(WRAPPER_DIR)/libaxis2_parser.la \ + $(top_builddir)/neethi/src/libneethi.la \ + -lpthread \ + $(top_builddir)/src/core/engine/libaxis2_engine.la \ + $(top_builddir)/src/core/transport/http/sender/libaxis2_http_sender.la + +test_client_LDADD = \ + ../../../util/src/libaxutil.la \ + ../../../axiom/src/om/libaxis2_axiom.la \ + ../../../axiom/src/parser/$(WRAPPER_DIR)/libaxis2_parser.la \ + $(top_builddir)/neethi/src/libneethi.la \ + -lpthread \ + $(top_builddir)/src/core/engine/libaxis2_engine.la \ + $(top_builddir)/src/core/transport/http/sender/libaxis2_http_sender.la + +test_svc_client_handler_count_LDADD = \ + ../../../util/src/libaxutil.la \ + ../../../axiom/src/om/libaxis2_axiom.la \ + ../../../axiom/src/parser/$(WRAPPER_DIR)/libaxis2_parser.la \ + $(top_builddir)/neethi/src/libneethi.la \ + -lpthread \ + $(top_builddir)/src/core/engine/libaxis2_engine.la \ + $(top_builddir)/src/core/transport/http/sender/libaxis2_http_sender.la + + +INCLUDES = -I${CUTEST_HOME}/include \ + -I$(top_builddir)/include \ + -I$(top_builddir)/src/core/description \ + -I$(top_builddir)/src/core/context \ + -I$(top_builddir)/src/core/phaseresolver \ + -I$(top_builddir)/src/core/deployment \ + -I$(top_builddir)/src/core/engine \ + -I$(top_builddir)/src/core/clientapi \ + -I ../../../util/include \ + -I ../../../neethi/include \ + -I ../../../axiom/include + diff --git a/test/core/clientapi/addr_echo.xml b/test/core/clientapi/addr_echo.xml new file mode 100644 index 0000000..85284bf --- /dev/null +++ b/test/core/clientapi/addr_echo.xml @@ -0,0 +1,23 @@ + + + + + uuid:967F11455D2EC0EC9411374901147634 + 1 + + + http://127.0.0.1:9090/axis2/services/echo + http://127.0.0.1:9090/axis2/services/echo/__OPERATION_OUT_IN__ + + http://192.168.1.217:9090/axis2/services/__ANONYMOUS_SERVICE__/__OPERATION_OUT_IN__ + + 38DDECF77196B604F511374901138822 + + + + + echo5 + + + \ No newline at end of file diff --git a/test/core/clientapi/echo.xml b/test/core/clientapi/echo.xml new file mode 100644 index 0000000..fad1895 --- /dev/null +++ b/test/core/clientapi/echo.xml @@ -0,0 +1 @@ +echo5 diff --git a/test/core/clientapi/test_client.c b/test/core/clientapi/test_client.c new file mode 100644 index 0000000..83a417e --- /dev/null +++ b/test/core/clientapi/test_client.c @@ -0,0 +1,182 @@ + +/* + * 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 +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +/* Function prototypes */ +int write_to_socket( + const char *address, + const char *port, + const char *filename, + const char *endpoint); + +/* End of function prototypes */ + +void +error( + const char *msg) +{ + perror(msg); + exit(0); +} + +int +main( + int argc, + char *argv[]) +{ + const axis2_char_t *hostname = "localhost"; + const axis2_char_t *port = "9090"; + const axis2_char_t *filename = "echo.xml"; + const axis2_char_t *endpoint = "/axis2/services/echo/echo"; + int c; + extern char *optarg; + + while ((c = getopt(argc, argv, ":h:p:f:e:")) != -1) + { + switch (c) + { + case 'h': + hostname = optarg; + break; + case 'p': + port = optarg; + break; + case 'f': + filename = optarg; + break; + case 'e': + endpoint = optarg; + break; + } + } + + write_to_socket(hostname, port, filename, endpoint); + return 0; +} + +int +write_to_socket( + const char *address, + const char *port, + const char *filename, + const char *endpoint) +{ + axis2_char_t buffer_l[4999]; + int sockfd, + portno, + n, + i; + struct sockaddr_in serv_addr; + struct hostent *server; + struct stat buf; + axis2_char_t *buffer; + axis2_char_t tmpstr[10]; + int bufsize = 0; + + portno = atoi(port); + sockfd = socket(AF_INET, SOCK_STREAM, 0); + if (sockfd < 0) + error("ERROR opening socket"); + server = gethostbyname(address); + if (server == NULL) + { + fprintf(stderr, "ERROR, no such host\n"); + exit(0); + } + bzero((char *) &serv_addr, sizeof(serv_addr)); + serv_addr.sin_family = AF_INET; + bcopy((char *) server->h_addr, + (char *) &serv_addr.sin_addr.s_addr, server->h_length); + serv_addr.sin_port = htons(portno); + if (connect(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0) + error("ERROR connecting"); + + /* Read from file */ + stat(filename, &buf); + bufsize = (buf.st_size + 1) * sizeof(char); + buffer = (char *) malloc(bufsize); + int fd = open(filename, O_RDONLY, 0); + if (fd == -1) + { + printf("can't open file %s\n", filename); + return -1; + } + else + printf("opened file %s\n", filename); + + i = read(fd, buffer, bufsize - 1); + if (i > 0) + { + buffer[i] = '\0'; + printf("%s...\n", buffer); + } + sprintf(buffer_l, + "POST %s HTTP/1.1\r\nUser-Agent: Axis/2.0/C\r\nConnection: Keep-Alive\r\nHost: ", + endpoint); + strcat(buffer_l, address); + strcat(buffer_l, ":"); + strcat(buffer_l, port); + strcat(buffer_l, "\r\n"); + strcat(buffer_l, "Content-Length: "); + sprintf(tmpstr, "%d", (int) strlen(buffer)); + strcat(buffer_l, tmpstr); + strcat(buffer_l, "\r\n"); + /*strcat(buffer_l, "SOAPAction: http://localhost:9090/axis2/services/echo/echo\r\n"); */ + strcat(buffer_l, "Content-Type: application/soap+xml;\r\n"); + strcat(buffer_l, "\r\n"); + + printf("Writing buffer_1...\n%s", buffer_l); + n = write(sockfd, buffer_l, strlen(buffer_l)); + + n = write(sockfd, buffer, strlen(buffer)); + if (n < 0) + error("ERROR writing to socket"); + + printf("Done writing to server\n"); + + buffer[0] = '\0'; + + printf("Reading the reply from server :\n"); + while ((n = read(sockfd, buffer, bufsize - 1)) > 0) + { + buffer[n] = '\0'; + printf("%s", buffer); + } + printf("\nReading from server done ...\n"); + + if (n < 0) + { + error("ERROR reading from socket"); + buffer[0] = '\0'; + } + free(buffer); + return 0; +} diff --git a/test/core/clientapi/test_clientapi.c b/test/core/clientapi/test_clientapi.c new file mode 100644 index 0000000..e20d44a --- /dev/null +++ b/test/core/clientapi/test_clientapi.c @@ -0,0 +1,119 @@ + +/* + * 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 +#include +#include +#include +#include +#include +#include + +axiom_node_t *build_om_payload_for_echo_svc( + const axutil_env_t * env, + const axis2_char_t * echo_str); + +void +axis2_test_svc_client_blocking( + ) +{ + axutil_env_t *env = NULL; + axis2_options_t *options = NULL; + const axis2_char_t *client_home = NULL; + axis2_svc_client_t *svc_client = NULL; + axiom_node_t *payload = NULL; + axiom_node_t *ret_node = NULL; + const axis2_char_t *address = NULL; + axis2_endpoint_ref_t *endpoint_ref = NULL; + + axutil_allocator_t *allocator = axutil_allocator_init(NULL); + env = axutil_env_create(allocator); + axiom_element_t *result_ele = NULL; + const axis2_char_t *echo_text = "echo_text"; + axis2_char_t *result = NULL; + + address = "http://localhost:9090/axis2/services/echo/echo"; + endpoint_ref = axis2_endpoint_ref_create(env, address); + client_home = AXIS2_GETENV("AXIS2C_HOME"); + if (!client_home) + client_home = "../../deploy"; + + svc_client = axis2_svc_client_create(env, client_home); + + if (!svc_client) + { + printf("axis2_test axis2_svc_client_create FAILURE\n"); + printf + ("Client repository path not properly set. Please check AXIS2C_HOME setting\n"); + return; + } + + options = axis2_options_create(env); + axis2_options_set_to(options, env, endpoint_ref); + axis2_svc_client_set_options(svc_client, env, options); + + payload = build_om_payload_for_echo_svc(env, echo_text); + ret_node = axis2_svc_client_send_receive(svc_client, env, payload); + if (ret_node) + { + if (axiom_node_get_node_type(ret_node, env) == AXIOM_ELEMENT) + { + ret_node = axiom_node_get_first_child(ret_node, env); + result_ele = + (axiom_element_t *) axiom_node_get_data_element(ret_node, env); + result = axiom_element_get_text(result_ele, env, ret_node); + if (!strcmp(result, echo_text)) + printf("axis2_test SVC_CLIENT_SEND_RECEIVE SUCCESS\n"); + else + printf("axis2_test SVC_CLIENT_SEND_RECEIVE FAILURE\n"); + } + } + axis2_svc_client_free(svc_client, env); +} + +/* build SOAP request message content using OM */ +axiom_node_t * +build_om_payload_for_echo_svc( + const axutil_env_t * env, + const axis2_char_t * echo_text) +{ + axiom_node_t *echo_om_node = NULL; + axiom_element_t *echo_om_ele = NULL; + axiom_node_t *text_om_node = NULL; + axiom_element_t *text_om_ele = NULL; + axiom_namespace_t *ns1 = NULL; + + ns1 = + axiom_namespace_create(env, "http://ws.apache.org/axis2/c/samples", + "ns1"); + echo_om_ele = + axiom_element_create(env, NULL, "echoString", ns1, &echo_om_node); + text_om_ele = + axiom_element_create(env, echo_om_node, "text", NULL, &text_om_node); + axiom_element_set_text(text_om_ele, env, echo_text, text_om_node); + + return echo_om_node; +} + +int +main( + ) +{ + axis2_test_svc_client_blocking(); + return 0; +} diff --git a/test/core/clientapi/test_svc_client_handler_count.c b/test/core/clientapi/test_svc_client_handler_count.c new file mode 100644 index 0000000..a4904dd --- /dev/null +++ b/test/core/clientapi/test_svc_client_handler_count.c @@ -0,0 +1,22 @@ +#include +#include +#include + +int +main( + ) +{ + axutil_env_t *env = + axutil_env_create_all("hello_client.log", AXIS2_LOG_LEVEL_TRACE); + const int TIMES = 1000; + int i; + for (i = 1; i <= TIMES; ++i) + { + printf("%d\n", i); + axis2_svc_client_t *svc_client = + axis2_svc_client_create(env, AXIS2_GETENV("AXIS2C_HOME")); + axis2_svc_client_free(svc_client, env); + } + axutil_env_free(env); + return 0; +} diff --git a/test/core/context/Makefile.am b/test/core/context/Makefile.am new file mode 100644 index 0000000..01642e2 --- /dev/null +++ b/test/core/context/Makefile.am @@ -0,0 +1,21 @@ +TESTS = test_context +check_PROGRAMS = test_context +noinst_PROGRAMS = test_context +SUBDIRS = +AM_CFLAGS = -g -pthread +test_context_SOURCES = test_context.c + + +test_context_LDADD = ../../../util/src/libaxutil.la \ + ../../../axiom/src/om/libaxis2_axiom.la \ + ../../../axiom/src/parser/$(WRAPPER_DIR)/libaxis2_parser.la \ + $(top_builddir)/src/core/engine/libaxis2_engine.la \ + $(top_builddir)/src/core/transport/http/common/libaxis2_http_common.la \ + $(top_builddir)/neethi/src/libneethi.la + +INCLUDES = -I${CUTEST_HOME}/include \ + -I$(top_builddir)/src/xml/guththila/src \ + -I$(top_builddir)/include \ + -I$(top_builddir)/src/core/description \ + -I ../../../util/include \ + -I ../../../axiom/include diff --git a/test/core/context/test_context.c b/test/core/context/test_context.c new file mode 100644 index 0000000..253691a --- /dev/null +++ b/test/core/context/test_context.c @@ -0,0 +1,124 @@ + +/* + * 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 +#include +#include +#include +#include +#include + +void +axis2_test_conf_ctx_init( + ) +{ + struct axis2_conf *conf = NULL; + struct axis2_svc_grp_ctx *svc_grp_ctx1 = NULL; + struct axis2_svc_grp_ctx *svc_grp_ctx2 = NULL; + struct axis2_svc_grp *svc_grp1 = NULL; + struct axis2_svc_grp *svc_grp2 = NULL; + struct axis2_conf_ctx *conf_ctx = NULL; + struct axis2_svc_ctx *svc_ctx1 = NULL; + struct axis2_svc_ctx *svc_ctx2 = NULL; + struct axis2_svc *svc1 = NULL; + struct axis2_svc *svc2 = NULL; + struct axutil_qname *qname1 = NULL; + struct axutil_qname *qname2 = NULL; + struct axis2_op_ctx *op_ctx1 = NULL; + struct axis2_op_ctx *op_ctx2 = NULL; + struct axis2_op *op = NULL; + struct axutil_hash_t *op_ctx_map = NULL; + struct axutil_hash_t *svc_ctx_map = NULL; + struct axutil_hash_t *svc_grp_ctx_map = NULL; + + axis2_status_t status = AXIS2_FAILURE; + axutil_allocator_t *allocator = axutil_allocator_init(NULL); + const axutil_env_t *env = axutil_env_create(allocator); + + conf = axis2_conf_create(env); + + op = axis2_op_create(env); + + conf_ctx = axis2_conf_ctx_create(env, conf); + + svc_grp1 = axis2_svc_grp_create(env); + svc_grp2 = axis2_svc_grp_create(env); + + svc_grp_ctx1 = axis2_svc_grp_ctx_create(env, svc_grp1, conf_ctx); + svc_grp_ctx2 = axis2_svc_grp_ctx_create(env, svc_grp2, conf_ctx); + + qname1 = axutil_qname_create(env, "name1", NULL, NULL); + qname2 = axutil_qname_create(env, "name2", NULL, NULL); + + svc1 = axis2_svc_create_with_qname(env, qname1); + svc2 = axis2_svc_create_with_qname(env, qname2); + + svc_ctx1 = axis2_svc_ctx_create(env, svc1, svc_grp_ctx1); + svc_ctx2 = axis2_svc_ctx_create(env, svc2, svc_grp_ctx2); + + op = axis2_op_create(env); + op_ctx1 = axis2_op_ctx_create(env, op, svc_ctx1); + op_ctx2 = axis2_op_ctx_create(env, op, svc_ctx2); + + op_ctx_map = axis2_conf_ctx_get_op_ctx_map(conf_ctx, env); + + if (op_ctx_map) + { + axutil_hash_set(op_ctx_map, "op_ctx1", AXIS2_HASH_KEY_STRING, op_ctx1); + axutil_hash_set(op_ctx_map, "op_ctx2", AXIS2_HASH_KEY_STRING, op_ctx2); + } + + svc_ctx_map = axis2_conf_ctx_get_svc_ctx_map(conf_ctx, env); + + if (svc_ctx_map) + { + axutil_hash_set(svc_ctx_map, "svc_ctx1", AXIS2_HASH_KEY_STRING, + svc_ctx1); + axutil_hash_set(svc_ctx_map, "svc_ctx2", AXIS2_HASH_KEY_STRING, + svc_ctx2); + } + + svc_grp_ctx_map = axis2_conf_ctx_get_svc_grp_ctx_map(conf_ctx, env); + + if (svc_grp_ctx_map) + { + axutil_hash_set(svc_ctx_map, "svc_grp_ctx1", AXIS2_HASH_KEY_STRING, + svc_grp_ctx1); + axutil_hash_set(svc_ctx_map, "svc_grp_ctx2", AXIS2_HASH_KEY_STRING, + svc_grp_ctx2); + } + + status = axis2_conf_ctx_init(conf_ctx, env, conf); + + if (status != AXIS2_SUCCESS) + { + printf("ERROR %d\n", status); + } + else + printf("SUCCESS\n"); + + axis2_conf_ctx_free(conf_ctx, env); +} + +int +main( + ) +{ + axis2_test_conf_ctx_init(); + return 0; +} diff --git a/test/core/deployment/Makefile.am b/test/core/deployment/Makefile.am new file mode 100644 index 0000000..298457d --- /dev/null +++ b/test/core/deployment/Makefile.am @@ -0,0 +1,25 @@ +TESTS = test_deployment +noinst_PROGRAMS = test_deployment +SUBDIRS = +AM_CFLAGS = $(CFLAGS) -g -pthread +test_deployment_SOURCES = test_deployment.c + +test_deployment_LDADD = \ + ../../../util/src/libaxutil.la \ + ../../../axiom/src/om/libaxis2_axiom.la \ + ../../../axiom/src/parser/$(WRAPPER_DIR)/libaxis2_parser.la \ + $(top_builddir)/neethi/src/libneethi.la \ + $(top_builddir)/src/core/engine/libaxis2_engine.la \ + $(top_builddir)/src/core/transport/http/common/libaxis2_http_common.la + +INCLUDES = -I$(top_builddir)/include \ + -I$(top_builddir)/src/core/description \ + -I$(top_builddir)/src/core/context \ + -I$(top_builddir)/src/core/phaseresolver \ + -I$(top_builddir)/src/core/deployment \ + -I$(top_builddir)/src/core/engine \ + -I$(top_builddir)/src/core/clientapi \ + -I$(top_builddir)/src/core/util \ + -I ../../../util/include \ + -I ../../../axiom/include \ + -I ../../../neethi/include diff --git a/test/core/deployment/axis2.xml b/test/core/deployment/axis2.xml new file mode 100644 index 0000000..fb4ccc4 --- /dev/null +++ b/test/core/deployment/axis2.xml @@ -0,0 +1,126 @@ + + + + + true + false + true + + + + + admin + axis2 + + . + + + + + + + + + + + + + + + + + + + + N:S + + + + + + + + + + + + + + + 6060 + + + + + + 6060 + + + + + + + + + + HTTP/1.1 + + + HTTP/1.1 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/test/core/deployment/test_deployment.c b/test/core/deployment/test_deployment.c new file mode 100644 index 0000000..d0730d8 --- /dev/null +++ b/test/core/deployment/test_deployment.c @@ -0,0 +1,360 @@ + +/* + * 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 +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +const axutil_env_t *env = NULL; + +int +axis2_test_dep_engine_load( + ) +{ + axis2_dep_engine_t *dep_engine = NULL; + axis2_conf_t *conf = NULL; + axutil_hash_t *svc_map = NULL; + axutil_array_list_t *in_phases = NULL; + axis2_char_t *axis2c_home = NULL; + + printf("******************************************\n"); + printf("testing dep_engine_load method \n"); + printf("******************************************\n"); + + axis2c_home = AXIS2_GETENV("AXIS2C_HOME"); + dep_engine = axis2_dep_engine_create_with_repos_name(env, axis2c_home); + if (!dep_engine) + { + printf("dep engine is not created \n"); + return -1; + } + conf = axis2_dep_engine_load(dep_engine, env); + axis2_conf_set_dep_engine(conf, env, dep_engine); + if (!conf) + { + printf("conf is NULL\n)"); + return -1; + } + + svc_map = axis2_conf_get_all_svcs(conf, env); + if (svc_map) + printf("svc_map count = %d\n", axutil_hash_count(svc_map)); + else + printf("svc_map count = zero\n"); + + if (svc_map) + { + axutil_hash_index_t *hi = NULL; + void *service = NULL; + for (hi = axutil_hash_first(svc_map, env); + hi; hi = axutil_hash_next(env, hi)) + { + axutil_hash_t *ops = NULL; + axis2_svc_t *svc = NULL; + axutil_param_t *impl_info_param = NULL; + + axutil_hash_this(hi, NULL, NULL, &service); + svc = (axis2_svc_t *) service; + impl_info_param = + axis2_svc_get_param(svc, env, AXIS2_SERVICE_CLASS); + if (!impl_info_param) + { + printf("imple_info_param is null\n"); + } + ops = axis2_svc_get_all_ops(svc, env); + if (ops) + { + printf("ops count = %d\n", axutil_hash_count(ops)); + + axutil_hash_index_t *hi2 = NULL; + void *op = NULL; + axis2_char_t *oname = NULL; + + for (hi2 = axutil_hash_first(ops, env); hi2; + hi2 = axutil_hash_next(env, hi2)) + { + if (!hi2) + break; + axutil_hash_this(hi2, NULL, NULL, &op); + if (op) + { + const axutil_qname_t *qname = NULL; + qname = axis2_op_get_qname((axis2_op_t *) op, env); + oname = axutil_qname_get_localpart(qname, env); + printf("op name = %s\n", oname); + } + } + } + else + printf("ops count = zero\n"); + } + } + + in_phases = + axis2_conf_get_in_phases_upto_and_including_post_dispatch(conf, env); + if (!in_phases) + { + printf("in phases up to and including post dispatch is NULL\n"); + } + else + { + printf("dep engine load is successfull\n"); + } + axis2_conf_free(conf, env); + + return 0; +} + +int +axis2_test_transport_receiver_load( + ) +{ + axutil_dll_desc_t *dll_desc = NULL; + axis2_char_t *dll_name = NULL; + axis2_transport_receiver_t *transport_recv = NULL; + axutil_param_t *impl_info_param = NULL; + axis2_bool_t is_running = AXIS2_FALSE; + axis2_char_t *axis2c_home = NULL; + + printf("******************************************\n"); + printf("testing axis2_transport_recv load\n"); + printf("******************************************\n"); + + dll_desc = axutil_dll_desc_create(env); + + axis2c_home = AXIS2_GETENV("AXIS2C_HOME"); + dll_name = + axutil_stracat(env, axis2c_home, "/lib/libaxis2_http_receiver.so"); + printf("transport receiver name:%s\n", dll_name); + axutil_dll_desc_set_name(dll_desc, env, dll_name); + axutil_dll_desc_set_type(dll_desc, env, AXIS2_TRANSPORT_RECV_DLL); + impl_info_param = axutil_param_create(env, NULL, NULL); + axutil_param_set_value(impl_info_param, env, dll_desc); + axutil_class_loader_init(env); + transport_recv = + (axis2_transport_receiver_t *) axutil_class_loader_create_dll(env, + impl_info_param); + is_running = axis2_transport_receiver_is_running(transport_recv, env); + printf("is_running:%d\n", is_running); + AXIS2_FREE(env->allocator, dll_name); + printf("transport receiver load test successful\n"); + return 0; +} + +int +axis2_test_transport_sender_load( + ) +{ + axutil_dll_desc_t *dll_desc = NULL; + axis2_char_t *dll_name = NULL; + axis2_transport_sender_t *transport_sender = NULL; + axutil_param_t *impl_info_param = NULL; + axis2_char_t *axis2c_home = NULL; + axis2_msg_ctx_t *msg_ctx = NULL; + + printf("******************************************\n"); + printf("testing axis2_transport_sender load\n"); + printf("******************************************\n"); + + msg_ctx = (axis2_msg_ctx_t *) AXIS2_MALLOC(env->allocator, 5); + dll_desc = axutil_dll_desc_create(env); + + axis2c_home = AXIS2_GETENV("AXIS2C_HOME"); + dll_name = axutil_stracat(env, axis2c_home, "/lib/libaxis2_http_sender.so"); + printf("transport sender name:%s\n", dll_name); + axutil_dll_desc_set_name(dll_desc, env, dll_name); + axutil_dll_desc_set_type(dll_desc, env, AXIS2_TRANSPORT_SENDER_DLL); + impl_info_param = axutil_param_create(env, NULL, NULL); + axutil_param_set_value(impl_info_param, env, dll_desc); + axutil_class_loader_init(env); + transport_sender = + (axis2_transport_sender_t *) axutil_class_loader_create_dll(env, + impl_info_param); + + AXIS2_FREE(env->allocator, dll_name); + printf("transport sender load test successful\n"); + return 0; +} + +int +axis2_test_default_module_version( + ) +{ + + axis2_conf_t *axis_conf = NULL; + axutil_qname_t *mod_qname1 = NULL; + axutil_qname_t *mod_qname2 = NULL; + axutil_qname_t *mod_qname3 = NULL; + axutil_qname_t *mod_qname4 = NULL; + axutil_qname_t *mod_qname5 = NULL; + axis2_module_desc_t *module1 = NULL; + axis2_module_desc_t *module2 = NULL; + axis2_module_desc_t *module3 = NULL; + axis2_module_desc_t *module4 = NULL; + axis2_module_desc_t *module5 = NULL; + axis2_module_desc_t *def_mod = NULL; + axutil_array_list_t *engaged_modules = NULL; + axutil_qname_t *engage_qname = NULL; + axis2_bool_t found1 = AXIS2_FALSE; + axis2_bool_t found2 = AXIS2_FALSE; + axis2_bool_t found3 = AXIS2_FALSE; + + printf("******************************************\n"); + printf("testing axis2_default_module_version\n"); + printf("******************************************\n"); + + axis_conf = axis2_conf_create(env); + mod_qname1 = axutil_qname_create(env, "module1", NULL, NULL); + module1 = axis2_module_desc_create_with_qname(env, mod_qname1); + axis2_conf_add_module(axis_conf, env, module1); + + mod_qname2 = axutil_qname_create(env, "module2-0.90", NULL, NULL); + module2 = axis2_module_desc_create_with_qname(env, mod_qname2); + axis2_conf_add_module(axis_conf, env, module2); + + mod_qname3 = axutil_qname_create(env, "module2-0.92", NULL, NULL); + module3 = axis2_module_desc_create_with_qname(env, mod_qname3); + axis2_conf_add_module(axis_conf, env, module3); + + mod_qname4 = axutil_qname_create(env, "module2-0.91", NULL, NULL); + module4 = axis2_module_desc_create_with_qname(env, mod_qname4); + axis2_conf_add_module(axis_conf, env, module4); + + mod_qname5 = axutil_qname_create(env, "test_module-1.92", NULL, NULL); + module5 = axis2_module_desc_create_with_qname(env, mod_qname5); + axis2_conf_add_module(axis_conf, env, module5); + + axis2_core_utils_calculate_default_module_version(env, + axis2_conf_get_all_modules + (axis_conf, env), + axis_conf); + def_mod = axis2_conf_get_default_module(axis_conf, env, "module1"); + if (def_mod != module1) + { + printf("axis2_default_module_version (module1) .. FAILED\n"); + return AXIS2_FAILURE; + } + def_mod = axis2_conf_get_default_module(axis_conf, env, "module2"); + if (def_mod != module3) + { + printf("axis2_default_module_version (module2) .. FAILED\n"); + return AXIS2_FAILURE; + } + def_mod = axis2_conf_get_default_module(axis_conf, env, "test_module"); + if (def_mod != module5) + { + printf("axis2_default_module_version (test_module) .. FAILED\n"); + return AXIS2_FAILURE; + } + engage_qname = axutil_qname_create(env, "module2", NULL, NULL); + axis2_conf_engage_module(axis_conf, env, engage_qname); + axutil_qname_free(engage_qname, env); + engage_qname = NULL; + + engage_qname = axutil_qname_create(env, "module1", NULL, NULL); + axis2_conf_engage_module(axis_conf, env, engage_qname); + axutil_qname_free(engage_qname, env); + engage_qname = NULL; + + axis2_conf_engage_module_with_version(axis_conf, env, "test_module", + "1.92"); + + engaged_modules = axis2_conf_get_all_engaged_modules(axis_conf, env); + + if (engaged_modules) + { + int list_size = 0; + int i = 0; + list_size = axutil_array_list_size(engaged_modules, env); + for (i = 0; i < list_size; i++) + { + axutil_qname_t *engaged_mod_qname = NULL; + engaged_mod_qname = axutil_array_list_get(engaged_modules, env, i); + if (0 == axutil_strcmp("module2-0.92", + axutil_qname_get_localpart(engaged_mod_qname, + env))) + { + found1 = AXIS2_TRUE; + } + if (0 == axutil_strcmp("module1", + axutil_qname_get_localpart(engaged_mod_qname, + env))) + { + found2 = AXIS2_TRUE; + } + if (0 == axutil_strcmp("test_module-1.92", + axutil_qname_get_localpart(engaged_mod_qname, + env))) + { + found3 = AXIS2_TRUE; + } + + } + } + if (AXIS2_FALSE == found1) + { + printf("axis2_default_module_version (module2 engaging) .. FAILED\n"); + return AXIS2_FAILURE; + } + if (AXIS2_FALSE == found2) + { + printf("axis2_default_module_version (module1 engaging) .. FAILED\n"); + return AXIS2_FAILURE; + } + if (AXIS2_FALSE == found3) + { + printf + ("axis2_default_module_version (test_module engaging) .. FAILED\n"); + return AXIS2_FAILURE; + } + printf("axis2_default_module_version .. SUCCESS\n"); + axis2_conf_free(axis_conf, env); + return AXIS2_SUCCESS; +} + +int +main( + ) +{ + axutil_allocator_t *allocator = NULL; + axutil_error_t *error = NULL; + axutil_log_t *log = NULL; + + allocator = axutil_allocator_init(NULL); + error = axutil_error_create(allocator); + log = axutil_log_create(allocator, NULL, "test_deployment.log"); + env = axutil_env_create_with_error_log(allocator, error, log); + env->log->level = AXIS2_LOG_LEVEL_INFO; + /*axis2_test_transport_receiver_load(); + axis2_test_transport_sender_load(); */ + axis2_test_dep_engine_load(); + axis2_test_default_module_version(); + return 0; +} diff --git a/test/core/description/Makefile.am b/test/core/description/Makefile.am new file mode 100644 index 0000000..0241eeb --- /dev/null +++ b/test/core/description/Makefile.am @@ -0,0 +1,26 @@ +TESTS = test_description +noinst_PROGRAMS = test_description +SUBDIRS = +AM_CFLAGS = -g -O2 -pthread +test_description_SOURCES = test_description.c + +test_description_LDADD = \ + ../../../util/src/libaxutil.la \ + ../../../axiom/src/om/libaxis2_axiom.la \ + ../../../axiom/src/parser/$(WRAPPER_DIR)/libaxis2_parser.la \ + -lpthread \ + $(top_builddir)/neethi/src/libneethi.la \ + $(top_builddir)/src/core/engine/libaxis2_engine.la \ + $(top_builddir)/src/core/transport/http/common/libaxis2_http_common.la + +INCLUDES = -I$(top_builddir)/include \ + -I$(top_builddir)/src/core/description \ + -I$(top_builddir)/src/core/context \ + -I$(top_builddir)/src/core/phaseresolver \ + -I$(top_builddir)/src/core/deployment \ + -I$(top_builddir)/src/core/transport \ + -I$(top_builddir)/src/core/engine \ + -I$(top_builddir)/src/core/clientapi \ + -I ../../../util/include \ + -I ../../../axiom/include + diff --git a/test/core/description/test_description.c b/test/core/description/test_description.c new file mode 100644 index 0000000..17675ba --- /dev/null +++ b/test/core/description/test_description.c @@ -0,0 +1,215 @@ + +/* + * 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 +#include +#include +#include +#include +#include +#include + +struct axis2_module_desc *create_module_desc( + const axutil_env_t * env); + +int +axis2_test_op_engage_module( + ) +{ + struct axis2_module_desc *moduleref = NULL; + axis2_conf_t *conf = NULL; + + axis2_status_t status = AXIS2_FAILURE; + + printf("******************************************\n"); + printf("testing axis2_op_engage_module\n"); + printf("******************************************\n"); + + axutil_allocator_t *allocator = axutil_allocator_init(NULL); + axutil_env_t *env = axutil_env_create(allocator); + axis2_op_t *op = axis2_op_create(env); + + moduleref = axis2_module_desc_create(env); + conf = axis2_conf_create(env); + + status = axis2_op_engage_module(op, env, moduleref, conf); + moduleref = NULL; + if (status != AXIS2_SUCCESS) + { + axis2_op_free(op, env); + printf("ERROR %d\n", status); + } + + axis2_op_free(op, env); + axutil_env_free(env); + return 0; +} + +int +axis2_test_svc_add_module_ops( + ) +{ + struct axis2_svc *svc = NULL; + struct axutil_qname *qname = NULL; + struct axis2_module_desc *module_desc = NULL; + struct axis2_conf *axis2_config = NULL; + + axis2_status_t status = AXIS2_FAILURE; + + printf("******************************************\n"); + printf("testing axis2_svc_add_module_ops\n"); + printf("******************************************\n"); + + axutil_allocator_t *allocator = axutil_allocator_init(NULL); + const axutil_env_t *env = axutil_env_create(allocator); + qname = axutil_qname_create(env, "name1", NULL, NULL); + svc = axis2_svc_create_with_qname(env, qname); + module_desc = axis2_module_desc_create(env); + axis2_config = axis2_conf_create(env); + status = axis2_svc_add_module_ops(svc, env, module_desc, axis2_config); + if (status != AXIS2_SUCCESS) + { + printf("axis2_test_description_add_module_ops ERROR %d\n", status); + } + else + printf("axis2_test_add_module_ops SUCCESS\n"); + + axis2_svc_free(svc, env); + axutil_qname_free(qname, env); + axis2_module_desc_free(module_desc, env); + axis2_conf_free(axis2_config, env); + + return 0; +} + +int +axis2_test_svc_engage_module( + ) +{ + axis2_svc_t *svc = NULL; + axutil_qname_t *qname = NULL; + axis2_module_desc_t *moduleref = NULL; + axis2_conf_t *axis2_config = NULL; + axis2_status_t status = AXIS2_FAILURE; + + printf("******************************************\n"); + printf("testing axis2_svc_engage_module\n"); + printf("******************************************\n"); + + axutil_allocator_t *allocator = axutil_allocator_init(NULL); + const axutil_env_t *env = axutil_env_create(allocator); + qname = axutil_qname_create(env, "name1", NULL, NULL); + svc = axis2_svc_create_with_qname(env, qname); + moduleref = axis2_module_desc_create(env); + axis2_config = axis2_conf_create(env); + + status = axis2_svc_engage_module(svc, env, moduleref, axis2_config); + moduleref = NULL; + if (status != AXIS2_SUCCESS) + { + printf("axis2_test_description_svc_engage_module ERROR %d\n", status); + } + else + printf("axis2_test_svc_engage_module SUCCESS\n"); + + axis2_svc_free(svc, env); + axutil_qname_free(qname, env); + axis2_conf_free(axis2_config, env); + + return 0; +} + +int +axis2_test_svc_get_op( + ) +{ + struct axis2_svc *svc = NULL; + struct axutil_qname *qname = NULL; + struct axutil_hash_t *ops = NULL; + struct axis2_op *op = NULL; + axis2_status_t status = AXIS2_SUCCESS; + + printf("******************************************\n"); + printf("testing axis2_svc_get_op\n"); + printf("******************************************\n"); + + axutil_allocator_t *allocator = axutil_allocator_init(NULL); + const axutil_env_t *env = axutil_env_create(allocator); + qname = axutil_qname_create(env, "op1", NULL, NULL); + op = axis2_op_create_with_qname(env, qname); + qname = axutil_qname_create(env, "svc1", NULL, NULL); + svc = axis2_svc_create_with_qname(env, qname); + + status = axis2_svc_add_op(svc, env, op); + + qname = axutil_qname_create(env, "op2", NULL, NULL); + op = axis2_op_create_with_qname(env, qname); + status = axis2_svc_add_op(svc, env, op); + + ops = axis2_svc_get_all_ops(svc, env); + + if (ops) + printf("SUCCESS AXIS2_SVC_GET_OPS\n"); + else + { + printf("ERROR AXIS2_SVC_GET_OPS\n"); + return -1; + } + + if (ops) + { + printf("ops count = %d\n", axutil_hash_count(ops)); + + axutil_hash_index_t *hi2 = NULL; + void *op2 = NULL; + axis2_char_t *oname = NULL; + int count = 0; + + for (hi2 = axutil_hash_first(ops, env); hi2; + hi2 = axutil_hash_next(env, hi2)) + { + printf("count = %d \n", count++); + axis2_svc_get_all_ops(svc, env); + if (!(hi2)) + break; + axutil_hash_this(hi2, NULL, NULL, &op2); + if (op2) + { + const axutil_qname_t *qname = NULL; + qname = axis2_op_get_qname((axis2_op_t *) op2, env); + oname = axutil_qname_get_localpart(qname, env); + printf("op name = %s\n", oname); + } + } + } + else + printf("ops count = zero\n"); + + return 0; +} + +int +main( + ) +{ + axis2_test_op_engage_module(); + axis2_test_svc_add_module_ops(); + axis2_test_svc_engage_module(); + axis2_test_svc_get_op(); + return 0; +} diff --git a/test/core/engine/Makefile.am b/test/core/engine/Makefile.am new file mode 100644 index 0000000..e6d41de --- /dev/null +++ b/test/core/engine/Makefile.am @@ -0,0 +1,25 @@ +TESTS = test_engine +check_PROGRAMS = test_engine +noinst_PROGRAMS = test_engine +SUBDIRS = +AM_CFLAGS = -g -pthread +test_engine_SOURCES = test_engine.c + + +test_engine_LDADD = \ + ../../../util/src/libaxutil.la \ + ../../../axiom/src/om/libaxis2_axiom.la \ + ../../../axiom/src/parser/$(WRAPPER_DIR)/libaxis2_parser.la \ + $(top_builddir)/src/core/engine/libaxis2_engine.la \ + $(top_builddir)/src/core/transport/http/common/libaxis2_http_common.la \ + $(top_builddir)/neethi/src/libneethi.la + +INCLUDES = -I$(top_builddir)/src/xml/guththila \ + -I$(top_builddir)/include \ + -I$(top_builddir)/src/core/description \ + -I$(top_builddir)/src/core/deployment \ + -I$(top_builddir)/src/core/engine \ + -I ../../../util/include \ + -I ../../../axiom/include \ + -I ../../../neethi/include + diff --git a/test/core/engine/test_engine.c b/test/core/engine/test_engine.c new file mode 100644 index 0000000..4df5b1d --- /dev/null +++ b/test/core/engine/test_engine.c @@ -0,0 +1,123 @@ + +/* + * 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 +#include +#include +#include +#include +#include + +int +axis2_test_engine_send( + ) +{ + axis2_status_t status = AXIS2_FAILURE; + axutil_allocator_t *allocator = axutil_allocator_init(NULL); + const axutil_env_t *env = axutil_env_create(allocator); + struct axis2_conf *conf = NULL; + conf = axis2_conf_create(env); + + struct axis2_conf_ctx *conf_ctx; + struct axis2_msg_ctx *msg_ctx; + struct axis2_op_ctx *op_ctx; + struct axis2_op *op; + struct axis2_svc *svc; + struct axis2_svc_ctx *svc_ctx; + struct axis2_svc_grp *svc_grp; + struct axis2_svc_grp_ctx *svc_grp_ctx; + struct axutil_qname *qname; + + conf_ctx = axis2_conf_ctx_create(env, conf); + + svc_grp = axis2_svc_grp_create(env); + svc_grp_ctx = axis2_svc_grp_ctx_create(env, svc_grp, conf_ctx); + + qname = axutil_qname_create(env, "name1", NULL, NULL); + svc = axis2_svc_create_with_qname(env, qname); + svc_ctx = axis2_svc_ctx_create(env, svc, svc_grp_ctx); + + op = axis2_op_create(env); + op_ctx = axis2_op_ctx_create(env, op, svc_ctx); + + msg_ctx = axis2_msg_ctx_create(env, conf_ctx, NULL, NULL); + + axis2_msg_ctx_set_conf_ctx(msg_ctx, env, conf_ctx); + axis2_msg_ctx_set_op_ctx(msg_ctx, env, op_ctx); + axis2_msg_ctx_set_svc_ctx(msg_ctx, env, svc_ctx); + + axis2_engine_t *engine = axis2_engine_create(env, conf_ctx); + status = axis2_engine_send(engine, env, msg_ctx); + if (status != AXIS2_SUCCESS) + { + printf("axis2_test_engine_send ERROR %d\n", status); + } + else + printf("axis2_test_engine_send SUCCESS\n"); + + axis2_conf_ctx_free(conf_ctx, env); + axis2_msg_ctx_free(msg_ctx, env); + axutil_qname_free(qname, env); + axis2_svc_grp_ctx_free(svc_grp_ctx, env); + axis2_svc_ctx_free(svc_ctx, env); + axis2_svc_free(svc, env); + axis2_op_ctx_free(op_ctx, env); + axis2_op_free(op, env); + axis2_engine_free(engine, env); + return 0; +} + +int +axis2_test_engine_receive( + ) +{ + axis2_status_t status = AXIS2_FAILURE; + axutil_allocator_t *allocator = axutil_allocator_init(NULL); + const axutil_env_t *env = axutil_env_create(allocator); + axis2_conf_t *conf = NULL; + conf = axis2_conf_create(env); + + struct axis2_conf_ctx *conf_ctx; + struct axis2_msg_ctx *msg_ctx; + conf_ctx = axis2_conf_ctx_create(env, conf); + + msg_ctx = axis2_msg_ctx_create(env, conf_ctx, NULL, NULL); + + axis2_engine_t *engine = axis2_engine_create(env, conf_ctx); + + status = axis2_engine_receive(engine, env, msg_ctx); + if (status != AXIS2_SUCCESS) + { + printf("axis2_test_engine_receive ERROR %d\n", status); + } + else + printf("axis2_test_engine_receive SUCCESS\n"); + axis2_conf_ctx_free(conf_ctx, env); + axis2_msg_ctx_free(msg_ctx, env); + axis2_engine_free(engine, env); + return 0; +} + +int +main( + ) +{ + axis2_test_engine_send(); + axis2_test_engine_receive(); + return 0; +} diff --git a/test/core/transport/Makefile.am b/test/core/transport/Makefile.am new file mode 100644 index 0000000..b7e93db --- /dev/null +++ b/test/core/transport/Makefile.am @@ -0,0 +1 @@ +SUBDIRS = http diff --git a/test/core/transport/http/Makefile.am b/test/core/transport/http/Makefile.am new file mode 100644 index 0000000..34eeefe --- /dev/null +++ b/test/core/transport/http/Makefile.am @@ -0,0 +1,21 @@ +TESTS = test_http_transport +check_PROGRAMS = test_http_transport +noinst_PROGRAMS = test_http_transport +SUBDIRS = +AM_CFLAGS = -g -pthread +test_http_transport_SOURCES = test_http_transport.c + +test_http_transport_LDADD = \ + $(LDFLAGS) \ + ../../../../util/src/libaxutil.la \ + ../../../../axiom/src/om/libaxis2_axiom.la \ + $(top_builddir)/neethi/src/libneethi.la \ + ../../../../axiom/src/parser/$(WRAPPER_DIR)/libaxis2_parser.la \ + $(top_builddir)/src/core/engine/libaxis2_engine.la \ + $(top_builddir)/src/core/transport/http/sender/libaxis2_http_sender.la + +INCLUDES = -I${CUTEST_HOME}/include \ + -I$(top_builddir)/include \ + -I ../../../../util/include \ + -I ../../../../axiom/include + diff --git a/test/core/transport/http/test_http_transport.c b/test/core/transport/http/test_http_transport.c new file mode 100644 index 0000000..69134bc --- /dev/null +++ b/test/core/transport/http/test_http_transport.c @@ -0,0 +1,274 @@ + +/* + * 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 +#include +#include +#include +#include +#include +#include + +typedef struct a +{ + axis2_char_t *value; +} +a; + +axutil_env_t * +test_init( + ) +{ + axutil_allocator_t *allocator = axutil_allocator_init(NULL); + axutil_error_t *error = axutil_error_create(allocator); + axutil_env_t *env = axutil_env_create_with_error(allocator, error); + return env; +} + +void +test_http_request_line( + const axutil_env_t * env) +{ + const char *request_line_str = + "POST http://ws.apache.org/axis2/c/services/test_svc/test_op?x=1 HTTP/1.1\r\n"; + axis2_http_request_line_t *request_line; + + printf("Starting http_request_line tests\n"); + request_line = axis2_http_request_line_parse_line(env, request_line_str); + printf("Method: %s|URI: %s|HTTP Version: %s|\n", + axis2_http_request_line_get_method(request_line, env), + axis2_http_request_line_get_uri(request_line, env), + axis2_http_request_line_get_http_version(request_line, env)); + axis2_http_request_line_free(request_line, env); + printf("Finished http_request_line tests ..........\n\n"); +} + +void +test_http_status_line( + const axutil_env_t * env) +{ + const char *status_line_str = "HTTP/1.1 202 Accepted\r\n"; + axis2_http_status_line_t *status_line; + + printf("Starting http_status_line tests\n"); + status_line = axis2_http_status_line_create(env, status_line_str); + printf("Staus Line starts with HTTP ? :%d\n", + axis2_http_status_line_starts_with_http(status_line, env)); + printf("HTTP Version :%s|Status Code:%d|Reason Phrase:%s|\n", + axis2_http_status_line_get_http_version(status_line, env), + axis2_http_status_line_get_status_code(status_line, env), + axis2_http_status_line_get_reason_phrase(status_line, env)); + printf("to_string :%s\n", + axis2_http_status_line_to_string(status_line, env)); + axis2_http_status_line_free(status_line, env); + printf("Finished http_status_line tests ..........\n\n"); +} + +void +test_http_header( + const axutil_env_t * env) +{ + const char *header_name = "Content-Type"; + const char *header_value = "text/xml"; + const char *str_header = "Content-Type: text/xml; charset=UTF-8\r\n"; + axis2_http_header_t *http_header; + axis2_char_t *external_form = NULL; + + printf("Starting http_header tests\n"); + http_header = axis2_http_header_create(env, header_name, header_value); + external_form = axis2_http_header_to_external_form(http_header, env); + printf("Heder Name :%s|Header Value:%s|External Form:%s\n", + axis2_http_header_get_name(http_header, env), + axis2_http_header_get_value(http_header, env), external_form); + AXIS2_FREE(env->allocator, external_form); + axis2_http_header_free(http_header, env); + + http_header = axis2_http_header_create_by_str(env, str_header); + printf("Finished http_header tests ..........\n\n"); +} + +void +test_url( + const axutil_env_t * env) +{ + const axis2_char_t *str_url = "http://ws.apache.org/axis2/"; + axutil_url_t *url = axutil_url_parse_string(env, str_url); + if (!url) + { + printf("URL is NULL\n"); + return; + } + printf("Starting URL Test ....\n"); + printf + ("Parsed URL : \n Protocol :%s|\n Host :%s|\n Port :%d|\n Path : %s|\n", + axutil_url_get_protocol(url, env), axutil_url_get_host(url, env), + axutil_url_get_port(url, env), axutil_url_get_path(url, env)); + printf("End of URL Test ... \n"); + axutil_url_free(url, env); +} + +void +test_http_client( + const axutil_env_t * env) +{ + axis2_http_client_t *client = NULL; + axis2_http_simple_request_t *request = NULL; + axis2_http_request_line_t *request_line = NULL; + axutil_url_t *url = NULL; + axis2_http_header_t *header = NULL; + axutil_stream_t *request_body = NULL; + axis2_http_simple_response_t *response = NULL; + int status = 0; + char *body_bytes = NULL; + int body_bytes_len = 0; + + printf("Starting http_client tests\n"); + request_line = axis2_http_request_line_create(env, "GET", + "/axis2/services", + "HTTP/1.0"); + request_body = axutil_stream_create_basic(env); + request = axis2_http_simple_request_create(env, request_line, + NULL, 0, NULL); + url = axutil_url_create(env, "http", "localhost", 80, NULL); + header = + axis2_http_header_create(env, "Host", axutil_url_get_host(url, env)); + axis2_http_simple_request_add_header(request, env, header); + client = axis2_http_client_create(env, url); + + status = axis2_http_client_send(client, env, request, NULL); + if (status < 0) + { + printf("Test FAILED .........Can't send the request. Status :%d\n", + status); + return; + } + status = axis2_http_client_recieve_header(client, env); + if (status < 0) + { + printf("Test FAILED ......... Can't recieve. Status: %d\n", status); + return; + } + response = axis2_http_client_get_response(client, env); + if (!response) + { + printf("Test Failed : NULL response"); + return; + } + printf("Content Type :%s\n", + axis2_http_simple_response_get_content_type(response, env)); + printf("Content Length :%d\n", + axis2_http_simple_response_get_content_length(response, env)); + printf("Status code :%d\n", status); + body_bytes_len = + axis2_http_simple_response_get_body_bytes(response, env, &body_bytes); + printf("body :%s\n", body_bytes); + + axis2_http_client_free(client, env); + axis2_http_simple_request_free(request, env); + axutil_stream_free(request_body, env); + AXIS2_FREE(env->allocator, body_bytes); + printf("Finished http_client tests ..........\n\n"); +} + +void +test_https_client( + const axutil_env_t * env) +{ +#ifndef AXIS2_SSL_ENABLED + return; +#else + axis2_http_client_t *client = NULL; + axis2_http_simple_request_t *request = NULL; + axis2_http_request_line_t *request_line = NULL; + axutil_url_t *url = NULL; + axis2_http_header_t *header = NULL; + axutil_stream_t *request_body = NULL; + axis2_http_simple_response_t *response = NULL; + int status = 0; + char *body_bytes = NULL; + int body_bytes_len = 0; + + printf("Starting https_client tests\n"); + request_line = axis2_http_request_line_create(env, "GET", "/", "HTTP/1.0"); + request_body = axutil_stream_create_basic(env); + request = axis2_http_simple_request_create(env, request_line, + NULL, 0, NULL); + url = axutil_url_create(env, "https", "localhost", 9090, NULL); + + header = + axis2_http_header_create(env, "Host", axutil_url_get_host(url, env)); + axis2_http_simple_request_add_header(request, env, header); + client = axis2_http_client_create(env, url); + + /* if you weant to test the proxy uncomment following */ + /*axis2_http_client_set_proxy(client, env, "127.0.0.1", 8080); */ + + /* Add CA/Server certificate */ + status = axis2_http_client_set_server_cert(client, env, + "/home/dummy/dummyCA/demoCA/cacert.pem"); + + status = axis2_http_client_send(client, env, request, NULL); + if (status < 0) + { + printf("Test FAILED .........Can't send the request. Status :%d\n", + status); + return; + } + status = axis2_http_client_recieve_header(client, env); + if (status < 0) + { + printf("Test FAILED ......... Can't recieve. Status: %d\n", status); + return; + } + response = axis2_http_client_get_response(client, env); + if (!response) + { + printf("Test Failed : NULL response"); + return; + } + printf("Content Type :%s\n", + axis2_http_simple_response_get_content_type(response, env)); + printf("Content Length :%d\n", + axis2_http_simple_response_get_content_length(response, env)); + printf("Status code :%d\n", status); + body_bytes_len = + axis2_http_simple_response_get_body_bytes(response, env, &body_bytes); + + axis2_http_client_free(client, env); + axis2_http_simple_request_free(request, env); + axutil_stream_free(request_body, env); + AXIS2_FREE(env->allocator, body_bytes); + printf("Finished https_client tests ..........\n\n"); +#endif +} + +int +main( + void) +{ + axutil_env_t *env = test_init(); + test_http_request_line(env); + test_http_status_line(env); + test_http_header(env); + test_http_client(env); + test_https_client(env); + test_url(env); + + axutil_env_free(env); + return 0; +} -- cgit v1.1-32-gdbae