Searched refs:num_pipes (Results 1 – 2 of 2) sorted by relevance
| /libevent-2.1.12/test/ |
| H A D | bench_cascade.c | 81 run_once(int num_pipes) in run_once() argument
87 events = (struct event *)calloc(num_pipes, sizeof(struct event)); in run_once()
88 pipes = (evutil_socket_t *)calloc(num_pipes * 2, sizeof(evutil_socket_t)); in run_once()
95 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
109 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
110 evutil_socket_t fd = i < num_pipes - 1 ? cp[3] : -1; in run_once()
127 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
148 int num_pipes = 100; in main() local
157 num_pipes = atoi(optarg); in main()
166 rl.rlim_cur = rl.rlim_max = num_pipes * 2 + 50; in main()
[all …]
|
| H A D | bench.c | 71 static int num_pipes, num_active, num_writes; variable
89 if (widx >= num_pipes) in read_cb()
90 widx -= num_pipes; in read_cb()
106 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
116 space = num_pipes / num_active; in run_once()
159 num_pipes = 100;
161 num_writes = num_pipes;
165 num_pipes = atoi(optarg);
190 rl.rlim_cur = rl.rlim_max = num_pipes * 2 + 50;
197 events = calloc(num_pipes, sizeof(struct event));
[all …]
|