Apache Arrow (C++)
A columnar in-memory analytics layer designed to accelerate big data.
Namespaces | Functions
protocol.h File Reference
#include <vector>
#include "arrow/status.h"
#include "plasma/plasma.h"
#include "plasma/plasma_generated.h"

Go to the source code of this file.

Namespaces

 plasma
 

Functions

template<class T >
bool plasma::verify_flatbuffer (T *object, uint8_t *data, size_t size)
 
Status plasma::PlasmaReceive (int sock, int64_t message_type, std::vector< uint8_t > *buffer)
 
Status plasma::SendCreateRequest (int sock, ObjectID object_id, int64_t data_size, int64_t metadata_size)
 
Status plasma::ReadCreateRequest (uint8_t *data, size_t size, ObjectID *object_id, int64_t *data_size, int64_t *metadata_size)
 
Status plasma::SendCreateReply (int sock, ObjectID object_id, PlasmaObject *object, int error)
 
Status plasma::ReadCreateReply (uint8_t *data, size_t size, ObjectID *object_id, PlasmaObject *object)
 
Status plasma::SendSealRequest (int sock, ObjectID object_id, unsigned char *digest)
 
Status plasma::ReadSealRequest (uint8_t *data, size_t size, ObjectID *object_id, unsigned char *digest)
 
Status plasma::SendSealReply (int sock, ObjectID object_id, int error)
 
Status plasma::ReadSealReply (uint8_t *data, size_t size, ObjectID *object_id)
 
Status plasma::SendGetRequest (int sock, const ObjectID *object_ids, int64_t num_objects, int64_t timeout_ms)
 
Status plasma::ReadGetRequest (uint8_t *data, size_t size, std::vector< ObjectID > &object_ids, int64_t *timeout_ms)
 
Status plasma::SendGetReply (int sock, ObjectID object_ids[], std::unordered_map< ObjectID, PlasmaObject, UniqueIDHasher > &plasma_objects, int64_t num_objects)
 
Status plasma::ReadGetReply (uint8_t *data, size_t size, ObjectID object_ids[], PlasmaObject plasma_objects[], int64_t num_objects)
 
Status plasma::SendReleaseRequest (int sock, ObjectID object_id)
 
Status plasma::ReadReleaseRequest (uint8_t *data, size_t size, ObjectID *object_id)
 
Status plasma::SendReleaseReply (int sock, ObjectID object_id, int error)
 
Status plasma::ReadReleaseReply (uint8_t *data, size_t size, ObjectID *object_id)
 
Status plasma::SendDeleteRequest (int sock, ObjectID object_id)
 
Status plasma::ReadDeleteRequest (uint8_t *data, size_t size, ObjectID *object_id)
 
Status plasma::SendDeleteReply (int sock, ObjectID object_id, int error)
 
Status plasma::ReadDeleteReply (uint8_t *data, size_t size, ObjectID *object_id)
 
Status plasma::SendStatusRequest (int sock, const ObjectID *object_ids, int64_t num_objects)
 
Status plasma::ReadStatusRequest (uint8_t *data, size_t size, ObjectID object_ids[], int64_t num_objects)
 
Status plasma::SendStatusReply (int sock, ObjectID object_ids[], int object_status[], int64_t num_objects)
 
int64_t plasma::ReadStatusReply_num_objects (uint8_t *data, size_t size)
 
Status plasma::ReadStatusReply (uint8_t *data, size_t size, ObjectID object_ids[], int object_status[], int64_t num_objects)
 
Status plasma::SendContainsRequest (int sock, ObjectID object_id)
 
Status plasma::ReadContainsRequest (uint8_t *data, size_t size, ObjectID *object_id)
 
Status plasma::SendContainsReply (int sock, ObjectID object_id, bool has_object)
 
Status plasma::ReadContainsReply (uint8_t *data, size_t size, ObjectID *object_id, bool *has_object)
 
Status plasma::SendConnectRequest (int sock)
 
Status plasma::ReadConnectRequest (uint8_t *data, size_t size)
 
Status plasma::SendConnectReply (int sock, int64_t memory_capacity)
 
Status plasma::ReadConnectReply (uint8_t *data, size_t size, int64_t *memory_capacity)
 
Status plasma::SendEvictRequest (int sock, int64_t num_bytes)
 
Status plasma::ReadEvictRequest (uint8_t *data, size_t size, int64_t *num_bytes)
 
Status plasma::SendEvictReply (int sock, int64_t num_bytes)
 
Status plasma::ReadEvictReply (uint8_t *data, size_t size, int64_t &num_bytes)
 
Status plasma::SendFetchRequest (int sock, const ObjectID *object_ids, int64_t num_objects)
 
Status plasma::ReadFetchRequest (uint8_t *data, size_t size, std::vector< ObjectID > &object_ids)
 
Status plasma::SendWaitRequest (int sock, ObjectRequest object_requests[], int64_t num_requests, int num_ready_objects, int64_t timeout_ms)
 
Status plasma::ReadWaitRequest (uint8_t *data, size_t size, ObjectRequestMap &object_requests, int64_t *timeout_ms, int *num_ready_objects)
 
Status plasma::SendWaitReply (int sock, const ObjectRequestMap &object_requests, int num_ready_objects)
 
Status plasma::ReadWaitReply (uint8_t *data, size_t size, ObjectRequest object_requests[], int *num_ready_objects)
 
Status plasma::SendSubscribeRequest (int sock)
 
Status plasma::SendDataRequest (int sock, ObjectID object_id, const char *address, int port)
 
Status plasma::ReadDataRequest (uint8_t *data, size_t size, ObjectID *object_id, char **address, int *port)
 
Status plasma::SendDataReply (int sock, ObjectID object_id, int64_t object_size, int64_t metadata_size)
 
Status plasma::ReadDataReply (uint8_t *data, size_t size, ObjectID *object_id, int64_t *object_size, int64_t *metadata_size)