File: test_pthread_proxy_hammer.cpp

package info (click to toggle)
emscripten 3.1.69%2Bdfsg-4
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 121,872 kB
  • sloc: ansic: 636,110; cpp: 425,974; javascript: 78,401; python: 58,404; sh: 49,154; pascal: 5,237; makefile: 3,365; asm: 2,415; lisp: 1,869
file content (72 lines) | stat: -rw-r--r-- 1,393 bytes parent folder | download | duplicates (3)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
#include <errno.h>
#include <stdlib.h>
#include <fcntl.h>
#include <unistd.h>
#include <emscripten.h>
#include <stdio.h>

class random_device
{
    int __f_;
public:
    // constructors
    explicit random_device();
    ~random_device();

    // generating functions
    unsigned operator()();
};

random_device::random_device()
{
    __f_ = open("/dev/urandom", O_RDONLY);
    if (__f_ < 0) abort();
}

random_device::~random_device()
{
    close(__f_);
}

unsigned
random_device::operator()()
{
    unsigned r;
    size_t n = sizeof(r);
    char* p = reinterpret_cast<char*>(&r);
    while (n > 0)
    {
        ssize_t s = read(__f_, p, 1);
        if (s == 0) abort();
        if (s == -1)
        {
            if (errno != EINTR) abort();
            continue;
        }
        n -= static_cast<size_t>(s);
        p += static_cast<size_t>(s);
    }
    return r;
}

int main() {
  int total = 0;
  for (int i = 0; i < ITERATIONS; i++) {
    // printf causes proxying
    printf("%d %d\n", i, total);
    for (int j = 0; j < 1024; j++) {
      // allocation uses a mutex
      auto* rd = new random_device();
      // reading data causes proxying
      for (int k = 0; k < 4; k++) {
        total += (*rd)();
      }
      // make sure the optimizer doesn't remove the allocation
      EM_ASM({ out("iter") }, rd);
      delete rd;
    }
  }
  printf("done: %d", total);
  return 0;
}