1.1 --- a/tests/dstest_pipe_client.cc Fri Sep 16 22:08:44 2022 +0200
1.2 +++ b/tests/dstest_pipe_client.cc Fri Sep 16 22:49:39 2022 +0200
1.3 @@ -64,7 +64,7 @@
1.4
1.5 offset_t nwritten = client_write(writer, buffer, TO_TRANSFER);
1.6
1.7 - printf("Written %ld/%ld in #%d of %d/%d to pipe #%d...\n", nwritten, TO_TRANSFER, region, loop, 2, number);
1.8 + printf("Written %lld/%lld in #%d of %d/%d to pipe #%d...\n", nwritten, TO_TRANSFER, region, loop, 2, number);
1.9 }
1.10
1.11 sleep(1);
1.12 @@ -130,7 +130,7 @@
1.13 {
1.14 totals[p] += nread;
1.15
1.16 - printf("Read %ld/%ld, total %ld, first %c, last %c, from pipe #%d...\n", nread, TO_TRANSFER, totals[p], *buffer, *(buffer + nread - 1), p + 1);
1.17 + printf("Read %lld/%lld, total %lld, first %c, last %c, from pipe #%d...\n", nread, TO_TRANSFER, totals[p], *buffer, *(buffer + nread - 1), p + 1);
1.18 nread = client_read(reader, buffer, TO_TRANSFER);
1.19 }
1.20
1.21 @@ -151,7 +151,7 @@
1.22
1.23 for (int p = 0; p < 2; p++)
1.24 {
1.25 - printf("Data received for pipe #%d: %ld\n", p, totals[p]);
1.26 + printf("Data received for pipe #%d: %lld\n", p, totals[p]);
1.27 printf("Data shown for pipe #%d: %s\n", p, totals[p] == TO_TRANSFER * 26 * NUMBER_OF_ITERATIONS ? "True" : "False");
1.28 }
1.29 }
1.30 @@ -160,6 +160,8 @@
1.31 {
1.32 /* Obtain pipe endpoint references. Blocking will be set up manually. */
1.33
1.34 + printf("Obtaining pipes...\n");
1.35 +
1.36 file_t *reader1, *reader2, *writer1, *writer2;
1.37 long err = client_pipe(&reader1, &writer1, O_NONBLOCK) ||
1.38 client_pipe(&reader2, &writer2, O_NONBLOCK);
1.39 @@ -170,6 +172,8 @@
1.40 return 1;
1.41 }
1.42
1.43 + printf("Starting activities...\n");
1.44 +
1.45 /* Schedule reader and writer threads. */
1.46
1.47 std::thread *activities[3];