mirror of
https://github.com/data61/MP-SPDZ.git
synced 2026-04-20 03:01:31 -04:00
46 lines
877 B
C++
46 lines
877 B
C++
/*
|
|
* Summer.h
|
|
*
|
|
*/
|
|
|
|
#ifndef OFFLINE_SUMMER_H_
|
|
#define OFFLINE_SUMMER_H_
|
|
|
|
#include "Networking/Player.h"
|
|
#include "Tools/WaitQueue.h"
|
|
#include "Tools/time-func.h"
|
|
|
|
#include <pthread.h>
|
|
#include <vector>
|
|
using namespace std;
|
|
|
|
template<class T>
|
|
class Parallel_MAC_Check;
|
|
|
|
template<class T>
|
|
class Summer
|
|
{
|
|
int sum_players, last_sum_players, next_sum_players;
|
|
int base_player;
|
|
Parallel_MAC_Check<T>& MC;
|
|
Player* send_player;
|
|
Player* receive_player;
|
|
Timer timer;
|
|
|
|
public:
|
|
vector<T> values;
|
|
|
|
pthread_t thread;
|
|
WaitQueue<int> input_queue, output_queue;
|
|
bool stop;
|
|
int size;
|
|
WaitQueue< vector<T> > share_queue;
|
|
|
|
Summer(int sum_players, int last_sum_players, int next_sum_players,
|
|
Player* send_player, Player* receive_player, Parallel_MAC_Check<T>& MC);
|
|
~Summer();
|
|
void run();
|
|
};
|
|
|
|
#endif /* OFFLINE_SUMMER_H_ */
|