|
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 |