X-Git-Url: http://mj.ucw.cz/gitweb/?a=blobdiff_plain;f=ucw%2Fsorter%2Fdebug%2Fradix-asio-test.c;h=257922702a9a73431f72e18d8c09ef33ece94abb;hb=d661e61c3019201dddd5d870ff9aabf23ec7e2f2;hp=6996766a30fb33389813161deb4060ed82e66ae7;hpb=fa7aa6d9457616ce28f97c83eaa616d0ff276870;p=libucw.git

diff --git a/ucw/sorter/debug/radix-asio-test.c b/ucw/sorter/debug/radix-asio-test.c
index 6996766a..25792270 100644
--- a/ucw/sorter/debug/radix-asio-test.c
+++ b/ucw/sorter/debug/radix-asio-test.c
@@ -8,6 +8,7 @@
 #include <ucw/conf.h>
 #include <ucw/io.h>
 #include <ucw/asio.h>
+#include <ucw/time.h>
 
 #include <stdio.h>
 #include <stdlib.h>
@@ -35,7 +36,7 @@ static struct asio_queue io_queue;
 
 int main(int argc, char **argv)
 {
-  uns files, bufsize;
+  uint files, bufsize;
   u64 total_size;
   if (argc != 4 ||
       cf_parse_int(argv[1], (int*) &files) ||
@@ -46,7 +47,7 @@ int main(int argc, char **argv)
       return 1;
     }
   u64 cnt, cnt_rep;
-  uns cnt_ms;
+  uint cnt_ms;
   int fd[files];
   byte name[files][16];
   struct asio_request *req[files];
@@ -63,14 +64,14 @@ int main(int argc, char **argv)
   ASSERT(in_fd >= 0);
   ASSERT(!(total_size % bufsize));
   P_INIT;
-  for (uns i=0; i<total_size/bufsize; i++)
+  for (uint i=0; i<total_size/bufsize; i++)
     {
       struct asio_request *r = asio_get(&io_queue);
       r->op = ASIO_WRITE_BACK;
       r->fd = in_fd;
       r->len = bufsize;
       byte *xbuf = r->buffer;
-      for (uns j=0; j<bufsize; j++)
+      for (uint j=0; j<bufsize; j++)
 	xbuf[j] = i+j;
       asio_submit(r);
       P_UPDATE(bufsize);
@@ -82,7 +83,7 @@ int main(int argc, char **argv)
 #endif
 
   msg(L_INFO, "Initializing output files");
-  for (uns i=0; i<files; i++)
+  for (uint i=0; i<files; i++)
     {
       sprintf(name[i], "tmp/ft-%d", i);
       fd[i] = ucw_open(name[i], O_RDWR | O_CREAT | O_TRUNC | DIRECT, 0666);
@@ -94,11 +95,11 @@ int main(int argc, char **argv)
 
   msg(L_INFO, "Writing %d MB to %d files in parallel with %d byte buffers", (int)(total_size >> 20), files, bufsize);
   P_INIT;
-  for (uns i=0; i<files; i++)
+  for (uint i=0; i<files; i++)
     req[i] = asio_get(&io_queue);
-  for (uns round=0; round<total_size/bufsize/files; round++)
+  for (uint round=0; round<total_size/bufsize/files; round++)
     {
-      for (uns i=0; i<files; i++)
+      for (uint i=0; i<files; i++)
 	{
 	  struct asio_request *r = req[i];
 #ifdef COPY
@@ -112,7 +113,7 @@ int main(int argc, char **argv)
 	  memcpy(r->buffer, rd->buffer, bufsize);
 	  asio_put(rr);
 #else
-	  for (uns j=0; j<bufsize; j++)
+	  for (uint j=0; j<bufsize; j++)
 	    r->buffer[j] = round+i+j;
 #endif
 	  r->op = ASIO_WRITE_BACK;
@@ -123,7 +124,7 @@ int main(int argc, char **argv)
 	  req[i] = asio_get(&io_queue);
 	}
     }
-  for (uns i=0; i<files; i++)
+  for (uint i=0; i<files; i++)
     asio_put(req[i]);
   asio_sync(&io_queue);
 #ifdef COPY
@@ -135,10 +136,10 @@ int main(int argc, char **argv)
 
   msg(L_INFO, "Reading the files sequentially");
   P_INIT;
-  for (uns i=0; i<files; i++)
+  for (uint i=0; i<files; i++)
     {
       lseek(fd[i], 0, SEEK_SET);
-      for (uns round=0; round<total_size/bufsize/files; round++)
+      for (uint round=0; round<total_size/bufsize/files; round++)
 	{
 	  struct asio_request *rr, *r = asio_get(&io_queue);
 	  r->op = ASIO_READ;
@@ -154,7 +155,7 @@ int main(int argc, char **argv)
     }
   P_FINAL;
 
-  for (uns i=0; i<files; i++)
+  for (uint i=0; i<files; i++)
     unlink(name[i]);
 #ifdef COPY
   unlink("tmp/ft-in");