|
@@ -54,7 +54,7 @@ int main(int argc, char * argv[])
|
|
|
const size_t expo = atoi(argv[4]);
|
|
|
const size_t op = atoi(argv[5]);
|
|
|
const size_t maxRAM = atoi(argv[6]);
|
|
|
- std::cout << "n_threads = " << n_threads << std::endl;
|
|
|
+ //std::cout << "n_threads = " << n_threads << std::endl;
|
|
|
|
|
|
|
|
|
|
|
@@ -69,14 +69,14 @@ int main(int argc, char * argv[])
|
|
|
make_connections(party, host1, host2, io_context, socketsPb, socketsP2, ports, ports2_1, ports2_0, number_of_sockets);
|
|
|
|
|
|
const size_t db_nitems = 1ULL << atoi(argv[4]);
|
|
|
- std::cout << "maxRAM = " << maxRAM << std::endl;
|
|
|
+ //std::cout << "maxRAM = " << maxRAM << std::endl;
|
|
|
size_t RAM_needed = 0;
|
|
|
RAM_needed = n_threads * 9 * ((sizeof(__m128i) * db_nitems));
|
|
|
- std::cout << "RAM needed = " << RAM_needed << " bytes = " << RAM_needed/1073741824 << " GiB" << std::endl;
|
|
|
+ //std::cout << "RAM needed = " << RAM_needed << " bytes = " << RAM_needed/1073741824 << " GiB" << std::endl;
|
|
|
size_t n_batches = std::ceil(double(RAM_needed)/(1073741824 * maxRAM));
|
|
|
- std::cout << "n_batches = " << n_batches << std::endl;
|
|
|
+ //std::cout << "n_batches = " << n_batches << std::endl;
|
|
|
size_t thread_per_batch = std::ceil(double(n_threads)/n_batches);
|
|
|
- std::cout << "thread_per_batch = " << thread_per_batch << std::endl;
|
|
|
+ //std::cout << "thread_per_batch = " << thread_per_batch << std::endl;
|
|
|
|
|
|
if(n_batches > n_threads)
|
|
|
{
|
|
@@ -150,7 +150,6 @@ int main(int argc, char * argv[])
|
|
|
{
|
|
|
for(size_t iter = 0; iter < n_batches; ++iter)
|
|
|
{
|
|
|
- std::cout << "iter = " << iter << std::endl;
|
|
|
boost::asio::thread_pool pool2(thread_per_batch);
|
|
|
for(size_t j = 0; j < thread_per_batch; ++j)
|
|
|
{
|