You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by di...@apache.org on 2007/07/20 07:05:15 UTC
svn commit: r557866 - in
/webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp:
receiver/s receiver/tcp_svr_thread.c receiver/tcp_worker.c
sender/tcp_transport_sender.c
Author: dinesh
Date: Thu Jul 19 22:05:14 2007
New Revision: 557866
URL: http://svn.apache.org/viewvc?view=rev&rev=557866
Log:
transport sender imporved
Modified:
webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/s
webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/tcp_svr_thread.c
webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/tcp_worker.c
webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/sender/tcp_transport_sender.c
Modified: webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/s
URL: http://svn.apache.org/viewvc/webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/s?view=diff&rev=557866&r1=557865&r2=557866
==============================================================================
--- webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/s (original)
+++ webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/s Thu Jul 19 22:05:14 2007
@@ -1,4 +1,5 @@
gcc -ggdb3 -shared -o libaxis2_tcp_receiver.so *.c -I../.. -I$AXIS2C_HOME/include/axis2-1.1 -I ../ \
+-D AXIS2_SVR_MULTI_THREADED \
-L$AXIS2C_HOME/lib -laxutil -laxis2_axiom \
-L/home/dinesh/axis2c/src/core/transport/http/common/libaxis2_http_common.la \
-L/home/dinesh/axis2c/src/core/transport/http/util/libaxis2_http_util.la \
Modified: webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/tcp_svr_thread.c
URL: http://svn.apache.org/viewvc/webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/tcp_svr_thread.c?view=diff&rev=557866&r1=557865&r2=557866
==============================================================================
--- webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/tcp_svr_thread.c (original)
+++ webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/tcp_svr_thread.c Thu Jul 19 22:05:14 2007
@@ -260,7 +260,7 @@
request);
/* axis2_simple_tcp_svr_conn_free(svr_conn, thread_env); */
/* if (request) */
-/* axis2_tcp_simple_request_free(request, thread_env); */
+/* AXIS2_FREE (env->allocator, request); */
AXIS2_PLATFORM_GET_TIME_IN_MILLIS(&t2);
millisecs = t2.millitm - t1.millitm;
secs = difftime(t2.time, t1.time);
Modified: webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/tcp_worker.c
URL: http://svn.apache.org/viewvc/webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/tcp_worker.c?view=diff&rev=557866&r1=557865&r2=557866
==============================================================================
--- webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/tcp_worker.c (original)
+++ webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/receiver/tcp_worker.c Thu Jul 19 22:05:14 2007
@@ -183,13 +183,13 @@
if (svr_stream && buffer)
{
- write = axutil_stream_write (svr_stream, env, buffer, len + 1);
+ write = axutil_stream_write_socket (svr_stream, env, buffer, len + 1);
if (write < 0)
{
AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "stream write failed");
return AXIS2_FAILURE;
}
- axutil_stream_close (svr_stream, env);
+ axutil_network_handler_close_socket (env, svr_stream->socket);
AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, "stream wrote:%s", buffer);
}
Modified: webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/sender/tcp_transport_sender.c
URL: http://svn.apache.org/viewvc/webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/sender/tcp_transport_sender.c?view=diff&rev=557866&r1=557865&r2=557866
==============================================================================
--- webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/sender/tcp_transport_sender.c (original)
+++ webservices/axis2/scratch/c/dinesh/602/c/src/core/transport/tcp/sender/tcp_transport_sender.c Thu Jul 19 22:05:14 2007
@@ -277,7 +277,7 @@
return AXIS2_FAILURE;
}
- write = axutil_stream_write (stream, env, buffer, buffer_size);
+ write = axutil_stream_write_socket (stream, env, buffer, buffer_size);
if (write < 0)
{
AXIS2_LOG_ERROR (env->log, AXIS2_LOG_SI, "stream write error");
@@ -286,7 +286,7 @@
AXIS2_LOG_DEBUG (env->log, AXIS2_LOG_SI, "stream wrote soap msg: %s",
buffer);
size = RES_BUFF;
- while ((read = axutil_stream_read (stream, env, &buff, 1)) > 0)
+ while ((read = axutil_stream_read_socket (stream, env, &buff, 1)) > 0)
{
if (res_size >= size)
{
---------------------------------------------------------------------
To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org