mirror of
https://github.com/data61/MP-SPDZ.git
synced 2026-04-20 03:01:31 -04:00
43 lines
675 B
C++
43 lines
675 B
C++
/*
|
|
* Sender.h
|
|
*
|
|
*/
|
|
|
|
#ifndef NETWORKING_SENDER_H_
|
|
#define NETWORKING_SENDER_H_
|
|
|
|
#include <pthread.h>
|
|
|
|
#include "Tools/octetStream.h"
|
|
#include "Tools/WaitQueue.h"
|
|
#include "Tools/time-func.h"
|
|
|
|
template<class T>
|
|
class Sender
|
|
{
|
|
T socket;
|
|
WaitQueue<const octetStream*> in;
|
|
WaitQueue<const octetStream*> out;
|
|
pthread_t thread;
|
|
|
|
static void* run_thread(void* sender);
|
|
|
|
// prevent copying
|
|
Sender(const Sender& other);
|
|
|
|
void start();
|
|
void stop();
|
|
void run();
|
|
|
|
public:
|
|
Timer timer;
|
|
|
|
Sender(T socket);
|
|
~Sender();
|
|
|
|
void request(const octetStream& os);
|
|
void wait(const octetStream& os);
|
|
};
|
|
|
|
#endif /* NETWORKING_SENDER_H_ */
|