allreduce.h File Reference

#include <string>
#include <algorithm>
#include <utility>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <netdb.h>
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <future>
#include "vw_exception.h"
#include "vwvis.h"
#include "io/logger.h"
#include <cassert>
#include <condition_variable>
#include <mutex>

Classes
struct	node_socks
class	AllReduce
struct	Data
class	AllReduceSync
class	AllReduceThreads
class	AllReduceSockets

Macros
#define	CLOSESOCK   close

Typedefs
using	socket_t = int

Functions
template<class T , void(*)(T &, const T &) f>
void	addbufs (T *buf1, const T *buf2, const size_t n)

Variables
constexpr size_t	ar_buf_size = 1 << 16

Macro Definition Documentation

CLOSESOCK

#define CLOSESOCK   close

Typedef Documentation

socket_t

using socket_t = int

Function Documentation

addbufs()

template<class T , void(*)(T &, const T &) f>

void addbufs	(	T *	buf1,
		const T *	buf2,
		const size_t	n
	)

Variable Documentation

ar_buf_size

constexpr size_t ar_buf_size = 1 << 16