Re: [Axis2] test_client patch

[Samisa Abeysinghe]

Thanks for the patch.
Samisa...

Sanjaya Ratnaweera wrote:

Hi,

The attached patch only reading xml from file and the rest is hard coded in test_client.c. And also added options for hostname, filename, port and endpoint.

Please apply.

Thanks

   ~sanjaya

------------------------------------------------------------------------

Index: test_client.c
===================================================================
--- test_client.c       (revision 372161)
+++ test_client.c       (working copy)
@@ -7,6 +7,8 @@
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
+#include <unistd.h>
+#include <axis2.h>

void error(char *msg)
{
@@ -16,13 +18,13 @@

int main(int argc, char *argv[])
{
-    char *hostname = "localhost";
-    char *port = "9090";
-    char *filename = "soap_req";
-    char* endpoint = "/axis2/services/echo/echo";
-    char c;
+    axis2_char_t *hostname = "localhost";
+    axis2_char_t *port = "9090";
+    axis2_char_t *filename = "soap_req";
+    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) @@ -41,20 +43,22 @@

                break;
        }
    }
-
+       
        write_to_socket(hostname, port, filename);
    return 0;
}

int write_to_socket(char *address, char* port, char* filename)
{
+       axis2_char_t buffer_l[4999];
    int sockfd, portno, n, i;
    struct sockaddr_in serv_addr;
    struct hostent *server;
    struct stat buf;
-    char *buffer;
+    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) @@ -76,27 +80,39 @@

    stat(filename, &buf);
    bufsize = buf.st_size* sizeof(char);
    buffer = (char *) malloc(bufsize);
+       strcpy(buffer_l, "POST /axis2/services/RMInteropService\r\nUser-Agent: 
Axis/2.0\r\nConnection: Keep-Alive\r\nHost: ");
+       strcat(buffer_l, address);
+       strcat(buffer_l, ":");
+       strcat(buffer_l, port);
+       strcat(buffer_l, "\r\n");
+       strcat(buffer_l, "Content-Length: ");
+       sprintf(tmpstr, "%d", buf.st_size);
+       strcat(buffer_l, tmpstr);
+       strcat(buffer_l, "\r\n");
+       strcat(buffer_l, "application/soap+xml; 
charset=UTF-8;action=\"http://127.0.0.1:8070/axis2/services/RMInteropService/__OPERATION_OUT_IN__\"";);
+       strcat(buffer_l, "\r\n\r\n");
+
    int fd = open(filename, O_RDONLY, 0);
    if (fd == -1)
    {
-        printf("can't open file soap_req\n");
+        printf("can't open file %s\n", filename);
        return;
    }
    else
-        printf("opened file soap_req\n");
+        printf("opened file %s\n", filename);
        
+       n = write(sockfd, buffer_l, strlen(buffer_l));
+
    while((i = read(fd, buffer, bufsize - 1)) > 0)
    {
        buffer[i] = '\0';
        n = write(sockfd,buffer,strlen(buffer));
-           printf("buffer = %s %d...", buffer, i);

if (n < 0) error("ERROR writing to socket");

    }

    printf("Done writing to server\n");

-/*    bzero(buffer,2000);*/
    buffer[0] = '\0';
        
    while((n = read(sockfd, buffer, bufsize -1)) > 0)
@@ -108,5 +124,6 @@

if (n < 0) error("ERROR reading from socket");

    printf("%s\n",buffer);
+       free(buffer);
}