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

Go to the source code of this file.




template<class T >
bool plasma::VerifyFlatbuffer (T *object, uint8_t *data, size_t size)
Status plasma::PlasmaReceive (int sock, MessageType message_type, std::vector< uint8_t > *buffer)
Status plasma::SendCreateRequest (int sock, ObjectID object_id, int64_t data_size, int64_t metadata_size, int device_num)
Status plasma::ReadCreateRequest (uint8_t *data, size_t size, ObjectID *object_id, int64_t *data_size, int64_t *metadata_size, int *device_num)
Status plasma::SendCreateReply (int sock, ObjectID object_id, PlasmaObject *object, PlasmaError error, int64_t mmap_size)
Status plasma::ReadCreateReply (uint8_t *data, size_t size, ObjectID *object_id, PlasmaObject *object, int *store_fd, int64_t *mmap_size)
Status plasma::SendAbortRequest (int sock, ObjectID object_id)
Status plasma::ReadAbortRequest (uint8_t *data, size_t size, ObjectID *object_id)
Status plasma::SendAbortReply (int sock, ObjectID object_id)
Status plasma::ReadAbortReply (uint8_t *data, size_t size, ObjectID *object_id)
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, PlasmaError 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 > &plasma_objects, int64_t num_objects, const std::vector< int > &store_fds, const std::vector< int64_t > &mmap_sizes)
Status plasma::ReadGetReply (uint8_t *data, size_t size, ObjectID object_ids[], PlasmaObject plasma_objects[], int64_t num_objects, std::vector< int > &store_fds, std::vector< int64_t > &mmap_sizes)
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, PlasmaError error)
Status plasma::ReadReleaseReply (uint8_t *data, size_t size, ObjectID *object_id)
Status plasma::SendDeleteRequest (int sock, const std::vector< ObjectID > &object_ids)
Status plasma::ReadDeleteRequest (uint8_t *data, size_t size, std::vector< ObjectID > *object_ids)
Status plasma::SendDeleteReply (int sock, const std::vector< ObjectID > &object_ids, const std::vector< PlasmaError > &errors)
Status plasma::ReadDeleteReply (uint8_t *data, size_t size, std::vector< ObjectID > *object_ids, std::vector< PlasmaError > *errors)
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::SendListRequest (int sock)
Status plasma::ReadListRequest (uint8_t *data, size_t size)
Status plasma::SendListReply (int sock, const ObjectTable &objects)
Status plasma::ReadListReply (uint8_t *data, size_t size, ObjectTable *objects)
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)