Revision e602902e xseg/peers/user/peer.c
| b/xseg/peers/user/peer.c | ||
|---|---|---|
| 700 | 700 |
for (i = 0; i < nr_threads; i++) {
|
| 701 | 701 |
peer->thread[i].thread_no = i; |
| 702 | 702 |
peer->thread[i].peer = peer; |
| 703 |
if (!xq_alloc_empty(&peer->thread[i].free_thread_reqs, nr_ops/nr_threads))
|
|
| 703 |
if (!xq_alloc_empty(&peer->thread[i].free_thread_reqs, nr_ops)) |
|
| 704 | 704 |
goto malloc_fail; |
| 705 | 705 |
} |
| 706 | 706 |
for (i = 0; i < nr_ops; i++) {
|
Also available in: Unified diff