Apache Arrow (C++)
A columnar in-memory analytics layer designed to accelerate big data.
Namespaces | Functions | Variables
io.h File Reference
#include <inttypes.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <unistd.h>
#include <memory>
#include <string>
#include <vector>
#include "arrow/status.h"
#include "plasma/compat.h"

Go to the source code of this file.




Status plasma::WriteBytes (int fd, uint8_t *cursor, size_t length)
Status plasma::WriteMessage (int fd, flatbuf::MessageType type, int64_t length, uint8_t *bytes)
Status plasma::ReadBytes (int fd, uint8_t *cursor, size_t length)
Status plasma::ReadMessage (int fd, flatbuf::MessageType *type, std::vector< uint8_t > *buffer)
int plasma::BindIpcSock (const std::string &pathname, bool shall_listen)
int plasma::ConnectIpcSock (const std::string &pathname)
Status plasma::ConnectIpcSocketRetry (const std::string &pathname, int num_retries, int64_t timeout, int *fd)
int plasma::AcceptClient (int socket_fd)
std::unique_ptr< uint8_t[]> plasma::ReadMessageAsync (int sock)


constexpr int64_t plasma::kPlasmaProtocolVersion = 0x0000000000000000