Implemented synchronous and asynchronous sending

[frescor/fwp.git] / fwp / lib / fwp / tests / fwp_vrestest / fwp_vrestest1.c

diff --git a/fwp/lib/fwp/tests/fwp_vrestest/fwp_vrestest1.c b/fwp/lib/fwp/tests/fwp_vrestest/fwp_vrestest1.c
index 0ac9cdc296dec1f7182f686ff7a98d7c5071f889..fc0faab2fcd62af389077111e747fb1bfade2099 100644 (file)
--- a/fwp/lib/fwp/tests/fwp_vrestest/fwp_vrestest1.c
+++ b/fwp/lib/fwp/tests/fwp_vrestest/fwp_vrestest1.c
@@ -16,6 +16,8 @@
 
 #include <errno.h>
 #include <stdio.h>
+#include <arpa/inet.h>
+#include <time.h>
 
 #define  NUM  10000
 
@@ -23,11 +25,11 @@ int main()
 {
 //     struct sockaddr_in local_addr, rem_addr, from;
         ssize_t len;
-       fwp_vres_d_t vresd1, vresd2;
+       fwp_vres_t *vres1, *vres2;
        struct fwp_vres_params vparam1;
        char msg1[15];
        char buffer[30];
-       fwp_endpoint_d_t sepoint_d1, repoint_d;
+       struct fwp_endpoint *sepoint, *repoint;
        int count;
        struct timespec  sendtime;
        fwp_endpoint_attr_t attr;
@@ -47,47 +49,47 @@ int main()
        }       
        
        printf("Create vres1\n");
-       if ((fwp_vres_create(&vparam1, &vresd1) < 0)) {
+       if ((fwp_vres_create(&vparam1, &vres1) < 0)) {
                printf("Unable to create vres1\n");
                return -1;
        }
        printf("Vres1 created\n");
        
        printf("Create vres2\n");
-       if ((fwp_vres_create(&vparam1, &vresd2) < 0)) {
+       if ((fwp_vres_create(&vparam1, &vres2) < 0)) {
                printf("Unable to create vres2\n");
                return -1;
        }
        printf("Vres2 created\n");
        /* local_addr should be handled when creating socket */
-       if (fwp_receive_endpoint_create(7777, &attr, &repoint_d) < 0) {
+       if (fwp_receive_endpoint_create(7777, &attr, &repoint) < 0) {
                return -1;
        }
        printf("Receive endpoint created\n");
        
        if (fwp_send_endpoint_create(inet_addr("127.0.0.1"), 7777, &attr, 
-                                       &sepoint_d1) < 0){
+                                    &sepoint) < 0){
                return -1;
        }
        printf("Send endpoint 1 created\n");
-       fwp_send_endpoint_bind(sepoint_d1, vresd1);
+       fwp_send_endpoint_bind(sepoint, vres1);
        
        for (count = 0; count < NUM; count++) { 
                sprintf(msg1,"msg%d",count);
-               fwp_send(sepoint_d1, msg1, sizeof(msg1), 0);
+               fwp_send_sync(sepoint, msg1, sizeof(msg1));
                
                clock_gettime(CLOCK_MONOTONIC, &sendtime);
-               FWP_DEBUG("Sent: sec = %ld nsec = %ld \n", sendtime.tv_sec,
-                               sendtime.tv_nsec);
+               printf("Sent: sec = %ld nsec = %ld \n", sendtime.tv_sec,
+                      sendtime.tv_nsec);
                
-               if ((len = fwp_recv(repoint_d, buffer, sizeof(buffer), &from, 0)) < 0) {
+               if ((len = fwp_recv(repoint, buffer, sizeof(buffer), &from, 0)) < 0) {
                        perror("Error while receiving data");
                        return -1;
                } 
                        else printf("Received - %s\n", buffer);
        }
 
-       if (fwp_vres_destroy(vresd1) < 0) {
+       if (fwp_vres_destroy(vres1) < 0) {
                perror("Unable to destroy vres1\n");
                return -1;
        }