Method run

Machines/TripleMachine.cpp:173–267

}

void TripleMachine::run()
{
    cout << "my_num: " << my_num << endl;
    network_opts.start_networking(N[0], my_num);
    nConnections = 1;
    if (bonding)
    {
        if (network_opts.ip_filename.empty())
        {
            cerr << "Bonding only works with --ip-file-name" << endl;
            exit(1);
        }
        N[1].init(my_num, network_opts.portnum_base + 1000,
                network_opts.ip_filename + "2", nplayers);
        nConnections = 2;
    }
    // do the base OTs
    PlainPlayer P(N[0], "base");
    OTTripleSetup setup(P, true);
    player = &P;

    vector<GeneratorThread*> generators(nthreads);
    vector<pthread_t> threads(nthreads);

    for (int i = 0; i < nthreads; i++)
    {
        if (prime)
            generators[i] = new_generator<Share<gfpvar1>>(setup, i, mac_keyp);
        else if (z2k)
        {
            if (z2k == 32 and z2s == 32)
                generators[i] = new_generator<Spdz2kShare<32, 32>>(setup, i, mac_keyz);
            else if (z2k == 64 and z2s == 64)
                generators[i] = new_generator<Spdz2kShare<64, 64>>(setup, i, mac_keyz);
            else if (z2k == 64 and z2s == 48)
                generators[i] = new_generator<Spdz2kShare<64, 48>>(setup, i, mac_keyz);
            else if (z2k == 66 and z2s == 64)
                generators[i] = new_generator<Spdz2kShare<66, 64>>(setup, i, mac_keyz);
            else if (z2k == 66 and z2s == 48)
                generators[i] = new_generator<Spdz2kShare<66, 48>>(setup, i, mac_keyz);
#ifdef RING_SIZE
            else if (z2k == RING_SIZE and z2s == SPDZ2K_DEFAULT_SECURITY)
                generators[i] = new_generator<Spdz2kShare<RING_SIZE, SPDZ2K_DEFAULT_SECURITY>>(setup, i, mac_keyz);
#endif
            else
                throw runtime_error("not compiled for k=" + to_string(z2k) + " and s=" + to_string(z2s));
        }
        else
            generators[i] = new_generator<Share<gf2n>>(setup, i, mac_key2);
    }
    ntriples = generators[0]->nTriples * nthreads;
    cout <<"Setup generators\n";
    for (int i = 0; i < nthreads; i++)
    {
        // lock before starting thread to avoid race condition
        generators[i]->lock();
        pthread_create(&threads[i], 0, run_ngenerator_thread, generators[i]);
    }