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

Go to the source code of this file.

Namespaces

 plasma
 

Macros

#define PLASMA_PROTOCOL_VERSION   0x0000000000000000
 
#define DISCONNECT_CLIENT   0
 

Functions

Status plasma::WriteBytes (int fd, uint8_t *cursor, size_t length)
 
Status plasma::WriteMessage (int fd, int64_t type, int64_t length, uint8_t *bytes)
 
Status plasma::ReadBytes (int fd, uint8_t *cursor, size_t length)
 
Status plasma::ReadMessage (int fd, int64_t *type, std::vector< uint8_t > *buffer)
 
int plasma::bind_ipc_sock (const std::string &pathname, bool shall_listen)
 
int plasma::connect_ipc_sock (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)
 
uint8_t * plasma::read_message_async (int sock)
 

Macro Definition Documentation

◆ DISCONNECT_CLIENT

#define DISCONNECT_CLIENT   0

◆ PLASMA_PROTOCOL_VERSION

#define PLASMA_PROTOCOL_VERSION   0x0000000000000000