Vowpal Wabbit
|
#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 |
#define CLOSESOCK close |
using AllReduce = VW::all_reduce_base |
using AllReduceSync = VW::all_reduce_sync |
using AllReduceType = VW::all_reduce_type |
using socket_t = int |