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 pi...@apache.org on 2006/08/23 15:56:34 UTC

svn commit: r434048 - in /webservices/axis2/trunk/c: include/axis2_http_chunked_stream.h modules/core/transport/http/http_chunked_stream.c

Author: pini
Date: Wed Aug 23 06:56:33 2006
New Revision: 434048

URL: http://svn.apache.org/viewvc?rev=434048&view=rev
Log:
Fomatting fixes and parameter changes to const

Modified:
    webservices/axis2/trunk/c/include/axis2_http_chunked_stream.h
    webservices/axis2/trunk/c/modules/core/transport/http/http_chunked_stream.c

Modified: webservices/axis2/trunk/c/include/axis2_http_chunked_stream.h
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/include/axis2_http_chunked_stream.h?rev=434048&r1=434047&r2=434048&view=diff
==============================================================================
--- webservices/axis2/trunk/c/include/axis2_http_chunked_stream.h (original)
+++ webservices/axis2/trunk/c/include/axis2_http_chunked_stream.h Wed Aug 23 06:56:33 2006
@@ -47,60 +47,60 @@
 
 
     /**
-     * @brief HTTP Chunked Stream ops struct
+     * HTTP Chunked Stream ops struct
      * Encapsulator struct for ops of axis2_http_chunked_stream
      */
-    AXIS2_DECLARE_DATA struct axis2_http_chunked_stream_ops
+    struct axis2_http_chunked_stream_ops
     {
         /**
-    * @param chunked_stream pointer to chunked stream
-    * @param env pointer to environment struct
-    * @param buffer 
-    * @param count
-    */
+        * @param chunked_stream pointer to chunked stream
+        * @param env pointer to environment struct
+        * @param buffer 
+        * @param count
+        */
         int (AXIS2_CALL *
                 read)(
                     axis2_http_chunked_stream_t *chunked_stream,
-                    const axis2_env_t *env, 
-          void *buffer, 
-          size_t count);
+                    const axis2_env_t *env,
+                    void *buffer,
+                    size_t count);
 
         /**
-    * @param env pointer to environment struct
-    * @param buffer
-    * @param count
-    */
+        * @param env pointer to environment struct
+        * @param buffer
+        * @param count
+        */
         int (AXIS2_CALL *
                 write)(
                     axis2_http_chunked_stream_t *chunked_stream,
-                    const axis2_env_t *env, 
-          const void *buffer,
+                    const axis2_env_t *env,
+                    const void *buffer,
                     size_t count);
-          
+
         /**
-    * @param chunked_stream pointer to chunked stream
-    * @param env pointer to environment struct
-    */
+        * @param chunked_stream pointer to chunked stream
+        * @param env pointer to environment struct
+        */
         int (AXIS2_CALL *
                 get_current_chunk_size)(
-                    axis2_http_chunked_stream_t *chunked_stream,
+                    const axis2_http_chunked_stream_t *chunked_stream,
                     const axis2_env_t *env);
 
         /**
-    * @param chunked_stream pointer to chunked stream
-    * @param env pointer to environment struct
-    * @return AXIS2_SUCCESS on success, else AXIS2_FAILURE
-    */
+        * @param chunked_stream pointer to chunked stream
+        * @param env pointer to environment struct
+        * @return AXIS2_SUCCESS on success, else AXIS2_FAILURE
+        */
         axis2_status_t (AXIS2_CALL *
                 write_last_chunk)(
                     axis2_http_chunked_stream_t *chunked_stream,
                     const axis2_env_t *env);
 
         /**
-    * @param chunked_stream pointer to chunked stream
-    * @param env pointer to environment struct
-    * @return AXIS2_SUCCESS on success, else AXIS2_FAILURE
-    */
+        * @param chunked_stream pointer to chunked stream
+        * @param env pointer to environment struct
+        * @return AXIS2_SUCCESS on success, else AXIS2_FAILURE
+        */
         axis2_status_t (AXIS2_CALL *
                 free)(
                     axis2_http_chunked_stream_t *chunked_stream,
@@ -110,7 +110,7 @@
     /**
      * axis2 http chunked stream
      */
-    AXIS2_DECLARE_DATA struct axis2_http_chunked_stream
+    struct axis2_http_chunked_stream
     {
         /** operations of axis2 http chucnked stream */
         axis2_http_chunked_stream_ops_t *ops;
@@ -122,9 +122,9 @@
      * @param stream pointer to stream
      */
     AXIS2_EXTERN axis2_http_chunked_stream_t * AXIS2_CALL
-            axis2_http_chunked_stream_create(
-                const axis2_env_t *env, 
-      axis2_stream_t* stream);
+    axis2_http_chunked_stream_create(
+        const axis2_env_t *env,
+        axis2_stream_t* stream);
 
 /********************* Start of function macros   ***************************/
 

Modified: webservices/axis2/trunk/c/modules/core/transport/http/http_chunked_stream.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/modules/core/transport/http/http_chunked_stream.c?rev=434048&r1=434047&r2=434048&view=diff
==============================================================================
--- webservices/axis2/trunk/c/modules/core/transport/http/http_chunked_stream.c (original)
+++ webservices/axis2/trunk/c/modules/core/transport/http/http_chunked_stream.c Wed Aug 23 06:56:33 2006
@@ -13,205 +13,222 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
- 
+
 #include <axis2_http_chunked_stream.h>
 #include <axis2_string.h>
 #include <string.h>
 #include <axis2_http_transport.h>
 #include <stdlib.h>
 
-/** 
- * @brief HTTP Chunked Stream struct impl
- *   Axis2 HTTP Chunked Stream impl  
+/**
+ * HTTP Chunked Stream struct impl
+ * Axis2 HTTP Chunked Stream impl  
  */
-typedef struct axis2_http_chunked_stream_impl axis2_http_chunked_stream_impl_t;  
-  
-struct axis2_http_chunked_stream_impl
+
+typedef struct axis2_http_chunked_stream_impl
 {
-   axis2_http_chunked_stream_t chunked_stream;
-   axis2_stream_t *stream;
-   int current_chunk_size;
-   int unread_len;
-   axis2_bool_t end_of_chunks;
-   axis2_bool_t chunk_started;
-};
+    axis2_http_chunked_stream_t chunked_stream;
+    axis2_stream_t *stream;
+    int current_chunk_size;
+    int unread_len;
+    axis2_bool_t end_of_chunks;
+    axis2_bool_t chunk_started;
+}
+axis2_http_chunked_stream_impl_t;
 
 #define AXIS2_INTF_TO_IMPL(chunked_stream) \
                  ((axis2_http_chunked_stream_impl_t *)(chunked_stream))
 
 /***************************** Function headers *******************************/
-int AXIS2_CALL 
-axis2_http_chunked_stream_read (axis2_http_chunked_stream_t *chunked_stream,
-                  const axis2_env_t *env, void *buffer, size_t count);
-int AXIS2_CALL 
-axis2_http_chunked_stream_write (axis2_http_chunked_stream_t *chunked_stream, 
-                  const axis2_env_t *env, const void *buffer, 
-                  size_t count);
-int AXIS2_CALL 
-axis2_http_chunked_stream_get_current_chunk_size
-                        (axis2_http_chunked_stream_t *chunked_stream, 
-                        const axis2_env_t *env);
+int AXIS2_CALL
+axis2_http_chunked_stream_read(
+    axis2_http_chunked_stream_t *chunked_stream,
+    const axis2_env_t *env, 
+    void *buffer, 
+    size_t count);
+
+int AXIS2_CALL
+axis2_http_chunked_stream_write(
+    axis2_http_chunked_stream_t *chunked_stream,
+    const axis2_env_t *env, 
+    const void *buffer,
+    size_t count);
+
+int AXIS2_CALL
+axis2_http_chunked_stream_get_current_chunk_size(
+    const axis2_http_chunked_stream_t *chunked_stream,
+    const axis2_env_t *env);
 
 axis2_status_t AXIS2_CALL
 axis2_http_chunked_stream_start_chunk(
-                  axis2_http_chunked_stream_t *chunked_stream, 
-                        const axis2_env_t *env);
-                  
+    axis2_http_chunked_stream_t *chunked_stream,
+    const axis2_env_t *env);
+
 axis2_status_t AXIS2_CALL
 axis2_http_chunked_stream_write_last_chunk(
-                  axis2_http_chunked_stream_t *chunked_stream, 
-                        const axis2_env_t *env);
+    axis2_http_chunked_stream_t *chunked_stream,
+    const axis2_env_t *env);
+
+axis2_status_t AXIS2_CALL
+axis2_http_chunked_stream_free(
+    axis2_http_chunked_stream_t *chunked_stream,
+    const axis2_env_t *env);
 
-axis2_status_t AXIS2_CALL 
-axis2_http_chunked_stream_free (axis2_http_chunked_stream_t *chunked_stream, 
-                        const axis2_env_t *env);            
 /***************************** End of function headers ************************/
 
-AXIS2_EXTERN axis2_http_chunked_stream_t * AXIS2_CALL
-axis2_http_chunked_stream_create(const axis2_env_t *env, axis2_stream_t *stream)
+AXIS2_EXTERN axis2_http_chunked_stream_t *AXIS2_CALL
+axis2_http_chunked_stream_create(
+    const axis2_env_t *env, 
+    axis2_stream_t *stream)
 {
     axis2_http_chunked_stream_impl_t *chunked_stream_impl = NULL;
     AXIS2_ENV_CHECK(env, NULL);
     AXIS2_PARAM_CHECK(env->error, stream, NULL);
-        
-    chunked_stream_impl = (axis2_http_chunked_stream_impl_t *)AXIS2_MALLOC 
-                        (env->allocator, sizeof(
+
+    chunked_stream_impl = (axis2_http_chunked_stream_impl_t *)AXIS2_MALLOC
+            (env->allocator, sizeof(
                         axis2_http_chunked_stream_impl_t));
-   
+
     if(NULL == chunked_stream_impl)
-   {
-      AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
+    {
+        AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
         return NULL;
-   }
+    }
     chunked_stream_impl->stream = stream;
     chunked_stream_impl->current_chunk_size = -1;
-   chunked_stream_impl->unread_len = -1;
-   chunked_stream_impl->end_of_chunks = AXIS2_FALSE;
-   chunked_stream_impl->chunk_started = AXIS2_FALSE;
-   
+    chunked_stream_impl->unread_len = -1;
+    chunked_stream_impl->end_of_chunks = AXIS2_FALSE;
+    chunked_stream_impl->chunk_started = AXIS2_FALSE;
+
     chunked_stream_impl->chunked_stream.ops = AXIS2_MALLOC(env->allocator,
-                    sizeof(axis2_http_chunked_stream_ops_t));
+            sizeof(axis2_http_chunked_stream_ops_t));
     if(NULL == chunked_stream_impl->chunked_stream.ops)
-   {
-      axis2_http_chunked_stream_free((axis2_http_chunked_stream_t*)
-                         chunked_stream_impl, env);
+    {
+        axis2_http_chunked_stream_free((axis2_http_chunked_stream_t *)
+                chunked_stream_impl, env);
         AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
         return NULL;
-   }
-    
+    }
+
     chunked_stream_impl->chunked_stream.ops->read =
-                        axis2_http_chunked_stream_read;
+        axis2_http_chunked_stream_read;
     chunked_stream_impl->chunked_stream.ops->write =
-                        axis2_http_chunked_stream_write;
+        axis2_http_chunked_stream_write;
     chunked_stream_impl->chunked_stream.ops->get_current_chunk_size =
-                        axis2_http_chunked_stream_get_current_chunk_size;
-   chunked_stream_impl->chunked_stream.ops->write_last_chunk =
-                  axis2_http_chunked_stream_write_last_chunk;
+        axis2_http_chunked_stream_get_current_chunk_size;
+    chunked_stream_impl->chunked_stream.ops->write_last_chunk =
+        axis2_http_chunked_stream_write_last_chunk;
     chunked_stream_impl->chunked_stream.ops->free =
-                        axis2_http_chunked_stream_free;
-   return &(chunked_stream_impl->chunked_stream);
+        axis2_http_chunked_stream_free;
+    return &(chunked_stream_impl->chunked_stream);
 }
 
 axis2_status_t AXIS2_CALL
-axis2_http_chunked_stream_free(axis2_http_chunked_stream_t *chunked_stream, 
-                        const axis2_env_t *env)
+axis2_http_chunked_stream_free(
+    axis2_http_chunked_stream_t *chunked_stream,
+    const axis2_env_t *env)
 {
-   AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
+    AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
     if(NULL != chunked_stream->ops)
         AXIS2_FREE(env->allocator, chunked_stream->ops);
-    
-   AXIS2_FREE(env->allocator, AXIS2_INTF_TO_IMPL(chunked_stream));
-   return AXIS2_SUCCESS;
+
+    AXIS2_FREE(env->allocator, AXIS2_INTF_TO_IMPL(chunked_stream));
+    return AXIS2_SUCCESS;
 }
 
-int AXIS2_CALL 
-axis2_http_chunked_stream_read (axis2_http_chunked_stream_t *chunked_stream,
-                  const axis2_env_t *env, void *buffer, size_t count)
+int AXIS2_CALL
+axis2_http_chunked_stream_read(
+    axis2_http_chunked_stream_t *chunked_stream,
+    const axis2_env_t *env, 
+    void *buffer, 
+    size_t count)
 {
-   int len = -1;
-   int yet_to_read = 0;
-   axis2_http_chunked_stream_impl_t *chunked_stream_impl = AXIS2_INTF_TO_IMPL
-                  (chunked_stream);
+    int len = -1;
+    int yet_to_read = 0;
+    axis2_http_chunked_stream_impl_t *chunked_stream_impl = AXIS2_INTF_TO_IMPL
+            (chunked_stream);
     axis2_stream_t *stream = chunked_stream_impl->stream;
-      AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
-   
-   if(NULL == buffer)
-   {
-      return -1;
-   }
-   if(NULL == stream)
-   {
-      AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NULL_STREAM_IN_CHUNKED_STREAM
-                  , AXIS2_FAILURE);
-      return -1;
-   }
+    AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
+
+    if(NULL == buffer)
+    {
+        return -1;
+    }
+    if(NULL == stream)
+    {
+        AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NULL_STREAM_IN_CHUNKED_STREAM
+                , AXIS2_FAILURE);
+        return -1;
+    }
     if(AXIS2_TRUE == chunked_stream_impl->end_of_chunks)
-   {
-      return 0;
-   }
-   if(AXIS2_FALSE == chunked_stream_impl->chunk_started)
-   {
-      axis2_http_chunked_stream_start_chunk(chunked_stream, env);
-   }
-   yet_to_read = count;
-   while(AXIS2_FALSE == chunked_stream_impl->end_of_chunks && yet_to_read > 0)
-   {
-      if(chunked_stream_impl->unread_len < yet_to_read)
-      {
-         len = AXIS2_STREAM_READ(chunked_stream_impl->stream, env, 
-                  (axis2_char_t*)buffer + count - yet_to_read, 
-                  chunked_stream_impl->unread_len);
-         yet_to_read -= len;
-         chunked_stream_impl->unread_len -= len;
-         if(chunked_stream_impl->unread_len <= 0)
-         {
-            axis2_http_chunked_stream_start_chunk(chunked_stream, env);
-         }
-      }
-      else
-      {
-         len = AXIS2_STREAM_READ(chunked_stream_impl->stream, env, 
-                  (axis2_char_t*)buffer + count - yet_to_read, 
-                  yet_to_read);
-         yet_to_read -= len;   
-         chunked_stream_impl->unread_len -= len;
-      }   
-   }
+    {
+        return 0;
+    }
+    if(AXIS2_FALSE == chunked_stream_impl->chunk_started)
+    {
+        axis2_http_chunked_stream_start_chunk(chunked_stream, env);
+    }
+    yet_to_read = count;
+    while(AXIS2_FALSE == chunked_stream_impl->end_of_chunks && yet_to_read > 0)
+    {
+        if(chunked_stream_impl->unread_len < yet_to_read)
+        {
+            len = AXIS2_STREAM_READ(chunked_stream_impl->stream, env,
+                    (axis2_char_t *)buffer + count - yet_to_read,
+                    chunked_stream_impl->unread_len);
+            yet_to_read -= len;
+            chunked_stream_impl->unread_len -= len;
+            if(chunked_stream_impl->unread_len <= 0)
+            {
+                axis2_http_chunked_stream_start_chunk(chunked_stream, env);
+            }
+        }
+        else
+        {
+            len = AXIS2_STREAM_READ(chunked_stream_impl->stream, env,
+                    (axis2_char_t *)buffer + count - yet_to_read,
+                    yet_to_read);
+            yet_to_read -= len;
+            chunked_stream_impl->unread_len -= len;
+        }
+    }
     return count - yet_to_read;
 }
 
 int AXIS2_CALL
-axis2_http_chunked_stream_write (axis2_http_chunked_stream_t *chunked_stream
-                  , const axis2_env_t *env, const void *buffer, 
-                  size_t count)
+axis2_http_chunked_stream_write(
+    axis2_http_chunked_stream_t *chunked_stream, 
+    const axis2_env_t *env, 
+    const void *buffer,
+    size_t count)
 {
-   axis2_stream_t *stream = AXIS2_INTF_TO_IMPL(chunked_stream)->stream;
-   int len = -1;
-   axis2_char_t tmp_buf[10];
+    axis2_stream_t *stream = AXIS2_INTF_TO_IMPL(chunked_stream)->stream;
+    int len = -1;
+    axis2_char_t tmp_buf[10];
     AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
-      
-   if(NULL == buffer)
-   {
-      return -1;
-   }
-   if(NULL == stream)
-   {
-      AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NULL_STREAM_IN_CHUNKED_STREAM
-                  , AXIS2_FAILURE);
-      return -1;
-   }
-   sprintf(tmp_buf, "%x%s", (unsigned int)count, AXIS2_HTTP_CRLF);
-   len = AXIS2_STREAM_WRITE(stream, env, tmp_buf, AXIS2_STRLEN(tmp_buf));
-   len = AXIS2_STREAM_WRITE(stream, env, buffer, count);
-   AXIS2_STREAM_WRITE(stream, env, AXIS2_HTTP_CRLF, 2);
+
+    if(NULL == buffer)
+    {
+        return -1;
+    }
+    if(NULL == stream)
+    {
+        AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NULL_STREAM_IN_CHUNKED_STREAM
+                , AXIS2_FAILURE);
+        return -1;
+    }
+    sprintf(tmp_buf, "%x%s", (unsigned int)count, AXIS2_HTTP_CRLF);
+    len = AXIS2_STREAM_WRITE(stream, env, tmp_buf, AXIS2_STRLEN(tmp_buf));
+    len = AXIS2_STREAM_WRITE(stream, env, buffer, count);
+    AXIS2_STREAM_WRITE(stream, env, AXIS2_HTTP_CRLF, 2);
     return len;
 }
 
 
-int AXIS2_CALL 
-axis2_http_chunked_stream_get_current_chunk_size
-                        (axis2_http_chunked_stream_t *chunked_stream, 
-                        const axis2_env_t *env)
+int AXIS2_CALL
+axis2_http_chunked_stream_get_current_chunk_size(
+    const axis2_http_chunked_stream_t *chunked_stream,
+    const axis2_env_t *env)
 {
     AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
     return AXIS2_INTF_TO_IMPL(chunked_stream)->current_chunk_size;
@@ -220,69 +237,69 @@
 
 axis2_status_t AXIS2_CALL
 axis2_http_chunked_stream_start_chunk(
-                  axis2_http_chunked_stream_t *chunked_stream, 
-                        const axis2_env_t *env)
+    axis2_http_chunked_stream_t *chunked_stream,
+    const axis2_env_t *env)
 {
-   axis2_char_t tmp_buf[3] = "";
-   axis2_char_t str_chunk_len[512] = "";
-   axis2_char_t *tmp = NULL;
-   int read = -1;
-   axis2_http_chunked_stream_impl_t *chunked_stream_impl = NULL;
-   AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
-   
-   chunked_stream_impl = AXIS2_INTF_TO_IMPL(chunked_stream);
-   /* remove the last CRLF of the previous chunk if any */
-   if(AXIS2_TRUE == chunked_stream_impl->chunk_started)
-   {
-      read = AXIS2_STREAM_READ(chunked_stream_impl->stream, env, tmp_buf, 2);
-      chunked_stream_impl->chunk_started = AXIS2_FALSE;
-   }
-   /* read the len and chunk extension */
-   while((read = AXIS2_STREAM_READ(chunked_stream_impl->stream, env, tmp_buf, 
-                  1)) > 0)
-   {
-      tmp_buf[read] = '\0';
-      strcat(str_chunk_len, tmp_buf);
-      if(0 != strstr(str_chunk_len, AXIS2_HTTP_CRLF))
-      {
-         break;
-      }
-   }
-   /* check whether we have extensions */
-   tmp = strchr(str_chunk_len, ';');
-   if(NULL != tmp)
-   {
-      /* we don't use extensions right now */
-      *tmp = '\0';
-   }
-   chunked_stream_impl->current_chunk_size = strtol(str_chunk_len, NULL, 16);
-   if(0 == chunked_stream_impl->current_chunk_size)
-   {
+    axis2_char_t tmp_buf[3] = "";
+    axis2_char_t str_chunk_len[512] = "";
+    axis2_char_t *tmp = NULL;
+    int read = -1;
+    axis2_http_chunked_stream_impl_t *chunked_stream_impl = NULL;
+    AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
+
+    chunked_stream_impl = AXIS2_INTF_TO_IMPL(chunked_stream);
+    /* remove the last CRLF of the previous chunk if any */
+    if(AXIS2_TRUE == chunked_stream_impl->chunk_started)
+    {
+        read = AXIS2_STREAM_READ(chunked_stream_impl->stream, env, tmp_buf, 2);
+        chunked_stream_impl->chunk_started = AXIS2_FALSE;
+    }
+    /* read the len and chunk extension */
+    while((read = AXIS2_STREAM_READ(chunked_stream_impl->stream, env, tmp_buf,
+            1)) > 0)
+    {
+        tmp_buf[read] = '\0';
+        strcat(str_chunk_len, tmp_buf);
+        if(0 != strstr(str_chunk_len, AXIS2_HTTP_CRLF))
+        {
+            break;
+        }
+    }
+    /* check whether we have extensions */
+    tmp = strchr(str_chunk_len, ';');
+    if(NULL != tmp)
+    {
+        /* we don't use extensions right now */
+        *tmp = '\0';
+    }
+    chunked_stream_impl->current_chunk_size = strtol(str_chunk_len, NULL, 16);
+    if(0 == chunked_stream_impl->current_chunk_size)
+    {
         /* Read the last CRLF */
         read = AXIS2_STREAM_READ(chunked_stream_impl->stream, env, tmp_buf, 2);
-      chunked_stream_impl->end_of_chunks = AXIS2_TRUE;
-   }
-   else
-   {
-      chunked_stream_impl->chunk_started = AXIS2_TRUE;
-      chunked_stream_impl->unread_len = 
-                  chunked_stream_impl->current_chunk_size;
-   }
-   return AXIS2_SUCCESS;
+        chunked_stream_impl->end_of_chunks = AXIS2_TRUE;
+    }
+    else
+    {
+        chunked_stream_impl->chunk_started = AXIS2_TRUE;
+        chunked_stream_impl->unread_len =
+            chunked_stream_impl->current_chunk_size;
+    }
+    return AXIS2_SUCCESS;
 }
 
 axis2_status_t AXIS2_CALL
 axis2_http_chunked_stream_write_last_chunk(
-                  axis2_http_chunked_stream_t *chunked_stream, 
-                        const axis2_env_t *env)
+    axis2_http_chunked_stream_t *chunked_stream,
+    const axis2_env_t *env)
 {
-   axis2_stream_t *stream = NULL;
-   AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
-   
-   stream = AXIS2_INTF_TO_IMPL(chunked_stream)->stream;
-   if(AXIS2_STREAM_WRITE(stream, env, "0\r\n\r\n", 5) == 5)
-   {
-      return AXIS2_SUCCESS;
-   }
-   return AXIS2_FAILURE;
+    axis2_stream_t *stream = NULL;
+    AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
+
+    stream = AXIS2_INTF_TO_IMPL(chunked_stream)->stream;
+    if(AXIS2_STREAM_WRITE(stream, env, "0\r\n\r\n", 5) == 5)
+    {
+        return AXIS2_SUCCESS;
+    }
+    return AXIS2_FAILURE;
 }



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