home *** CD-ROM | disk | FTP | other *** search
/ ftp.parl.clemson.edu / 2015-02-07.ftp.parl.clemson.edu.tar / ftp.parl.clemson.edu / pub / pvfs2 / orangefs-2.8.3-20110323.tar.gz / orangefs-2.8.3-20110323.tar / orangefs / test / io / description / test-request4.c < prev    next >
C/C++ Source or Header  |  2005-07-07  |  4KB  |  141 lines
  1. /*
  2.  * (C) 2002 Clemson University.
  3.  *
  4.  * See COPYING in top-level directory.
  5.  */       
  6.  
  7. #include <stdlib.h>
  8. #include <stdio.h>
  9. #include <pvfs2-types.h>
  10. #include <gossip.h>
  11. #include <pvfs2-debug.h>
  12.  
  13. #include <pint-distribution.h>
  14.  
  15. #include <simple-stripe.h>
  16.  
  17. extern PVFS_Distribution simple_stripe;
  18.  
  19. #define SEGMAX 32
  20. #define BYTEMAX 250
  21.  
  22. main(int argc, char **argv)
  23. {
  24.     int i;
  25.     PINT_Request req1;
  26.     PINT_Request req2;
  27.     PINT_Request req3;
  28.  
  29.     // PVFS_Process_request arguments
  30.     int retval;
  31.     PINT_Request_state *reqs;
  32.     PVFS_Dist_parm dparm;
  33.     PINT_Request_file_data rfdata;
  34.     int32_t segmax;
  35.     PVFS_offset *offset_array;
  36.     PVFS_size *size_array;
  37.     PVFS_offset offset;
  38.     PVFS_size bytemax;
  39.     PVFS_boolean eof_flag;
  40.  
  41.    // Turn on debugging
  42.     gossip_enable_stderr();
  43.     //gossip_set_debug_mask(1,REQUEST_DEBUG);
  44.  
  45.     req2.offset = 0; // This is a byte type
  46.     req2.num_ereqs = 1;
  47.     req2.stride = 0;
  48.     req2.num_blocks = 1;
  49.     req2.ub = 1;
  50.     req2.lb = 0;
  51.     req2.aggregate_size = 1;
  52.     req2.depth = 0;
  53.     req2.num_contig_chunks = 1;
  54.     req2.ereq = NULL;
  55.     req2.sreq = NULL;
  56.  
  57.     req3.offset = 0;
  58.     req3.num_ereqs = 8;
  59.     req3.stride = 20;
  60.     req3.num_blocks = 20;
  61.     req3.ub = 400;
  62.     req3.lb = 0;
  63.     req3.aggregate_size = 160;
  64.     req3.depth = 1;
  65.     req3.num_contig_chunks = 20;
  66.     req3.ereq = &req2;
  67.     req3.sreq = NULL;
  68.  
  69.     req1.offset = 0;
  70.     req1.num_ereqs = 4;
  71.     req1.stride = 2000;
  72.     req1.num_blocks = 10;
  73.     req1.ub = 19600;
  74.     req1.lb = 0;
  75.     req1.aggregate_size = 6400;
  76.     req1.depth = 2;
  77.     req1.num_contig_chunks = 800;
  78.     req1.ereq = &req3;
  79.     req1.sreq = NULL;
  80.  
  81.     reqs = PINT_new_request_state(&req1);
  82.     rfdata.server_nr = 0;
  83.     rfdata.server_ct = 2;
  84.     rfdata.fsize = 10000000;
  85.     rfdata.dist = PINT_lookup_distribution("simple stripe");
  86.     dparm.strip_size = 1024;
  87.     rfdata.dparm = &dparm;
  88.     rfdata.extend_flag = 0;
  89.     offset_array = (int64_t *)malloc(SEGMAX * sizeof(int64_t));
  90.     size_array = (int64_t *)malloc(SEGMAX * sizeof(int64_t));
  91.     eof_flag = 0;
  92.     offset = 0;
  93.     segmax = 1;
  94.     bytemax = BYTEMAX;
  95.     retval = PINT_process_request(reqs, &rfdata, &segmax, NULL, NULL,
  96.             &offset, &bytemax, &eof_flag, PINT_CKSIZE);
  97.     printf("\nreturn %d, %d segments: offset=%lld bytemax=%lld\n",
  98.             retval, segmax, offset, bytemax);
  99.     offset = 0;
  100.     do {
  101.         segmax = SEGMAX;
  102.         bytemax = BYTEMAX;
  103.         PINT_process_request(reqs, &rfdata, &segmax, offset_array,
  104.                 size_array, &offset, &bytemax, &eof_flag, PINT_CLIENT);
  105.         printf("processed %lld bytes in %d segments\n", bytemax, segmax);
  106.         for (i = 0; i < segmax; i++)
  107.         {
  108.             printf("segment %d: offset=%lld size=%lld\n", i,
  109.                     offset_array[i], size_array[i]);
  110.         }
  111.     } while (offset != -1);
  112.     printf("finished processing request\n");
  113.     segmax = 1;
  114.     bytemax = BYTEMAX;
  115.     retval = PINT_process_request(reqs, &rfdata, &segmax, NULL, NULL,
  116.             &offset, &bytemax, &eof_flag, PINT_CKSIZE);
  117.     printf("\nreturn %d, %d segments: offset=%lld bytemax=%lld\n",
  118.             retval, segmax, offset, bytemax);
  119.     offset = 0;
  120.     segmax = 1;
  121.     bytemax = BYTEMAX;
  122.     retval = PINT_process_request(reqs, &rfdata, &segmax, NULL, NULL,
  123.             &offset, &bytemax, &eof_flag, PINT_CKSIZE);
  124.     printf("\nreturn %d, %d segments: offset=%lld bytemax=%lld\n",
  125.             retval, segmax, offset, bytemax);
  126.     offset = 0;
  127.     do {
  128.         segmax = SEGMAX;
  129.         bytemax = BYTEMAX;
  130.         PINT_process_request(reqs, &rfdata, &segmax, offset_array,
  131.                 size_array, &offset, &bytemax, &eof_flag, PINT_SERVER);
  132.         printf("processed %lld bytes in %d segments\n", bytemax, segmax);
  133.         for (i = 0; i < segmax; i++)
  134.         {
  135.             printf("segment %d: offset=%lld size=%lld\n", i,
  136.                     offset_array[i], size_array[i]);
  137.         }
  138.     } while (offset != -1);
  139.     printf("finished processing request\n");
  140. }
  141.