You are viewing a plain text version of this content. The canonical link for it is here.
Posted to axis-cvs@ws.apache.org by di...@apache.org on 2007/07/23 07:34:32 UTC

svn commit: r558604 - in /webservices/axis2/trunk/c/src/core/transport/tcp: receiver/tcp_svr_thread.c receiver/tcp_worker.c sender/tcp_transport_sender.c

Author: dinesh
Date: Sun Jul 22 22:34:28 2007
New Revision: 558604

URL: http://svn.apache.org/viewvc?view=rev&rev=558604
Log:
axis2 tcp transport sender modified, extra bytes at response buffer

Modified:
    webservices/axis2/trunk/c/src/core/transport/tcp/receiver/tcp_svr_thread.c
    webservices/axis2/trunk/c/src/core/transport/tcp/receiver/tcp_worker.c
    webservices/axis2/trunk/c/src/core/transport/tcp/sender/tcp_transport_sender.c

Modified: webservices/axis2/trunk/c/src/core/transport/tcp/receiver/tcp_svr_thread.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/transport/tcp/receiver/tcp_svr_thread.c?view=diff&rev=558604&r1=558603&r2=558604
==============================================================================
--- webservices/axis2/trunk/c/src/core/transport/tcp/receiver/tcp_svr_thread.c (original)
+++ webservices/axis2/trunk/c/src/core/transport/tcp/receiver/tcp_svr_thread.c Sun Jul 22 22:34:28 2007
@@ -17,6 +17,7 @@
 
 #include <platforms/axutil_platform_auto_sense.h>
 #include <axis2_tcp_svr_thread.h>
+#include <axis2_simple_tcp_svr_conn.h>
 #include <axis2_tcp_server.h>
 #include <axis2_tcp_transport.h>
 #include <axutil_string.h>

Modified: webservices/axis2/trunk/c/src/core/transport/tcp/receiver/tcp_worker.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/transport/tcp/receiver/tcp_worker.c?view=diff&rev=558604&r1=558603&r2=558604
==============================================================================
--- webservices/axis2/trunk/c/src/core/transport/tcp/receiver/tcp_worker.c (original)
+++ webservices/axis2/trunk/c/src/core/transport/tcp/receiver/tcp_worker.c Sun Jul 22 22:34:28 2007
@@ -30,7 +30,7 @@
 #include <string.h>
 #include <axiom_soap.h>
 #include <axiom.h>
-
+#include <axis2_simple_tcp_svr_conn.h>
 struct axis2_tcp_worker
 {
     axis2_conf_ctx_t *conf_ctx;

Modified: webservices/axis2/trunk/c/src/core/transport/tcp/sender/tcp_transport_sender.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/transport/tcp/sender/tcp_transport_sender.c?view=diff&rev=558604&r1=558603&r2=558604
==============================================================================
--- webservices/axis2/trunk/c/src/core/transport/tcp/sender/tcp_transport_sender.c (original)
+++ webservices/axis2/trunk/c/src/core/transport/tcp/sender/tcp_transport_sender.c Sun Jul 22 22:34:28 2007
@@ -36,13 +36,9 @@
 typedef struct axis2_tcp_transport_sender_impl
 {
     axis2_transport_sender_t transport_sender;
-    axis2_char_t *tcp_version;
-    axis2_bool_t chunked;
     int connection_timeout;
     int so_timeout;
-
-}
-    axis2_tcp_transport_sender_impl_t;
+}axis2_tcp_transport_sender_impl_t;
 
 #define AXIS2_WS_RM_ANONYMOUS_URL "tcp://docs.oasis-open.org/ws-rx/wsmc/200702/anonymous?id="
 
@@ -111,7 +107,6 @@
         AXIS2_TCP_DEFAULT_CONNECTION_TIMEOUT;
     transport_sender_impl->so_timeout = AXIS2_TCP_DEFAULT_SO_TIMEOUT;
     transport_sender_impl->transport_sender.ops = &tcp_transport_sender_ops_var;
-
     return &(transport_sender_impl->transport_sender);
 }
 
@@ -274,7 +269,7 @@
             AXIS2_LOG_ERROR (env->log, AXIS2_LOG_SI, "stream write error");
             return AXIS2_FAILURE;
         }
-        AXIS2_LOG_DEBUG (env->log, AXIS2_LOG_SI, "stream wrote soap msg: %s", 
+        AXIS2_LOG_TRACE (env->log, AXIS2_LOG_SI, "stream wrote soap msg: %s", 
                          buffer);
         write = axutil_stream_write (stream, env, "\r\n\r\n", 4);
         size = RES_BUFF;
@@ -292,9 +287,15 @@
             memcpy (res_buffer + res_size, buff, 1);
             res_size ++;
         }
-        
+
+        axutil_network_handler_close_socket (stream->socket, env);
+        axutil_stream_close (stream, env);
+        axutil_stream_free (stream, env);
+
+        AXIS2_LOG_TRACE (env->log, AXIS2_LOG_SI, "%s", res_buffer);
+
         reader = axiom_xml_reader_create_for_memory(
-            env, res_buffer, res_size, 
+            env, res_buffer, (res_size - 1), 
             NULL, 
             AXIS2_XML_PARSER_TYPE_BUFFER);
         



---------------------------------------------------------------------
To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org