#include <aerospike/as_std.h>
#include <aerospike/as_error.h>
#include <citrusleaf/cf_byte_order.h>
#include <stddef.h>
Go to the source code of this file.
Data Structures | |
struct | as_compressed_proto_s |
struct | as_msg_s |
struct | as_proto_msg_s |
struct | as_proto_s |
Macros | |
#define | AS_ADMIN_MESSAGE_TYPE 2 |
#define | AS_COMPRESSED_MESSAGE_TYPE 4 |
#define | AS_INFO_MESSAGE_TYPE 1 |
#define | AS_MESSAGE_TYPE 3 |
#define | AS_PROTO_VERSION 2 |
#define | PROTO_SIZE_MAX (128 * 1024 * 1024) |
Functions | |
as_status | as_compressed_size_error (as_error *err, size_t size) |
static as_status | as_compressed_size_parse (as_error *err, const uint8_t *buf, size_t *size) |
static as_status | as_msg_parse (as_error *err, as_msg *msg, size_t size) |
void | as_msg_swap_header_from_be (as_msg *m) |
as_status | as_proto_decompress (as_error *err, uint8_t *trg, size_t trg_sz, uint8_t *src, size_t src_sz) |
as_status | as_proto_parse (as_error *err, as_proto *proto) |
static as_status | as_proto_parse_type (as_error *err, as_proto *proto, uint8_t expected_type) |
as_status | as_proto_size_error (as_error *err, size_t size) |
void | as_proto_swap_from_be (as_proto *m) |
void | as_proto_swap_to_be (as_proto *m) |
as_status | as_proto_type_error (as_error *err, as_proto *proto, uint8_t expected) |
as_status | as_proto_version_error (as_error *err, as_proto *proto) |
Variables | |
uint8_t | data [0] |
uint32_t | generation |
uint8_t | header_sz |
uint8_t | info1 |
uint8_t | info2 |
uint8_t | info3 |
as_msg | m |
uint16_t | n_fields |
uint16_t | n_ops |
as_proto | proto |
uint32_t | record_ttl |
uint8_t | result_code |
uint64_t | sz |
uint32_t | transaction_ttl |
uint8_t | type |
uint64_t | uncompressed_sz |
uint8_t | unused |
uint8_t | version |
#define AS_ADMIN_MESSAGE_TYPE 2 |
Definition at line 37 of file as_proto.h.
#define AS_COMPRESSED_MESSAGE_TYPE 4 |
Definition at line 39 of file as_proto.h.
#define AS_INFO_MESSAGE_TYPE 1 |
Definition at line 36 of file as_proto.h.
#define AS_MESSAGE_TYPE 3 |
Definition at line 38 of file as_proto.h.
#define AS_PROTO_VERSION 2 |
Definition at line 33 of file as_proto.h.
#define PROTO_SIZE_MAX (128 * 1024 * 1024) |
Definition at line 40 of file as_proto.h.
|
inlinestatic |
Definition at line 158 of file as_proto.h.
References AEROSPIKE_OK, as_compressed_size_error(), and PROTO_SIZE_MAX.
Definition at line 148 of file as_proto.h.
References AEROSPIKE_OK, as_msg_swap_header_from_be(), and as_proto_size_error().
void as_msg_swap_header_from_be | ( | as_msg * | m | ) |
as_status as_proto_decompress | ( | as_error * | err, |
uint8_t * | trg, | ||
size_t | trg_sz, | ||
uint8_t * | src, | ||
size_t | src_sz | ||
) |
|
inlinestatic |
Definition at line 139 of file as_proto.h.
References as_proto_parse(), and as_proto_type_error().
void as_proto_swap_from_be | ( | as_proto * | m | ) |
void as_proto_swap_to_be | ( | as_proto * | m | ) |
uint8_t data |
Definition at line 38 of file as_proto.h.
uint32_t generation |
Definition at line 41 of file as_proto.h.
uint8_t header_sz |
Definition at line 35 of file as_proto.h.
uint8_t info1 |
Definition at line 36 of file as_proto.h.
uint8_t info2 |
Definition at line 37 of file as_proto.h.
uint8_t info3 |
Definition at line 38 of file as_proto.h.
as_msg m |
Definition at line 36 of file as_proto.h.
uint16_t n_fields |
Definition at line 44 of file as_proto.h.
uint16_t n_ops |
Definition at line 45 of file as_proto.h.
as_proto proto |
Definition at line 35 of file as_proto.h.
uint32_t record_ttl |
Definition at line 42 of file as_proto.h.
uint8_t result_code |
Definition at line 40 of file as_proto.h.
uint64_t sz |
Definition at line 37 of file as_proto.h.
uint32_t transaction_ttl |
Definition at line 43 of file as_proto.h.
uint8_t type |
Definition at line 36 of file as_proto.h.
uint64_t uncompressed_sz |
Definition at line 36 of file as_proto.h.
uint8_t unused |
Definition at line 39 of file as_proto.h.
uint8_t version |
Definition at line 35 of file as_proto.h.