Vowpal Wabbit
Loading...
Searching...
No Matches
Classes | Namespaces | Macros | Typedefs | Functions | Variables
allreduce.h File Reference
#include <algorithm>
#include <string>
#include <utility>
#include <netdb.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <sys/socket.h>
#include <unistd.h>
#include <cstdio>
#include <cstdlib>
#include <cstring>
#include <future>
#include "vw/allreduce/allreduce_type.h"
#include "vw/common/future_compat.h"
#include "vw/common/vw_exception.h"
#include "vw/common/vw_throw.h"
#include "vw/io/errno_handling.h"
#include "vw/io/logger.h"
#include <cassert>
#include <condition_variable>
#include <mutex>

Classes

class  VW::details::node_socks
 
class  VW::all_reduce_base
 
class  VW::all_reduce_sync
 
class  VW::all_reduce_threads
 
class  VW::all_reduce_sockets
 

Namespaces

namespace  VW
 
namespace  VW::details
 

Macros

#define CLOSESOCK   close
 

Typedefs

using socket_t = int
 
using AllReduceType = VW::all_reduce_type
 
using AllReduce = VW::all_reduce_base
 
using AllReduceSync = VW::all_reduce_sync
 
using AllReduceSockets = VW::all_reduce_sockets
 
using AllReduceThreads = VW::all_reduce_threads
 

Functions

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

Variables

constexpr size_t VW::details::AR_BUF_SIZE = 1 << 16
 

Macro Definition Documentation

◆ CLOSESOCK

#define CLOSESOCK   close

Typedef Documentation

◆ AllReduce

◆ AllReduceSockets

◆ AllReduceSync

◆ AllReduceThreads

◆ AllReduceType

◆ socket_t

using socket_t = int