#ifndef PROTON_CODEC_H #define PROTON_CODEC_H 1 /* * * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. * */ #include #include #include #include #include #include #ifdef __cplusplus extern "C" { #endif /** * @file * * @copybrief codec */ /** * Identifies an AMQP type. * * @ingroup amqp_types */ typedef enum { /** * The NULL AMQP type. */ PN_NULL = 1, /** * The boolean AMQP type. */ PN_BOOL = 2, /** * The unsigned byte AMQP type. An 8 bit unsigned integer. */ PN_UBYTE = 3, /** * The byte AMQP type. An 8 bit signed integer. */ PN_BYTE = 4, /** * The unsigned short AMQP type. A 16 bit unsigned integer. */ PN_USHORT = 5, /** * The short AMQP type. A 16 bit signed integer. */ PN_SHORT = 6, /** * The unsigned int AMQP type. A 32 bit unsigned integer. */ PN_UINT = 7, /** * The signed int AMQP type. A 32 bit signed integer. */ PN_INT = 8, /** * The char AMQP type. A 32 bit unicode character. */ PN_CHAR = 9, /** * The ulong AMQP type. An unsigned 64 bit integer. */ PN_ULONG = 10, /** * The long AMQP type. A signed 64 bit integer. */ PN_LONG = 11, /** * The timestamp AMQP type. A signed 64 bit value measuring * milliseconds since the epoch. */ PN_TIMESTAMP = 12, /** * The float AMQP type. A 32 bit floating point value. */ PN_FLOAT = 13, /** * The double AMQP type. A 64 bit floating point value. */ PN_DOUBLE = 14, /** * The decimal32 AMQP type. A 32 bit decimal floating point value. */ PN_DECIMAL32 = 15, /** * The decimal64 AMQP type. A 64 bit decimal floating point value. */ PN_DECIMAL64 = 16, /** * The decimal128 AMQP type. A 128 bit decimal floating point value. */ PN_DECIMAL128 = 17, /** * The UUID AMQP type. A 16 byte UUID. */ PN_UUID = 18, /** * The binary AMQP type. A variable length sequence of bytes. */ PN_BINARY = 19, /** * The string AMQP type. A variable length sequence of unicode * characters. */ PN_STRING = 20, /** * The symbol AMQP type. A variable length sequence of unicode * characters. */ PN_SYMBOL = 21, /** * A described AMQP type. */ PN_DESCRIBED = 22, /** * An AMQP array. A monomorphic sequence of other AMQP values. */ PN_ARRAY = 23, /** * An AMQP list. A polymorphic sequence of other AMQP values. */ PN_LIST = 24, /** * An AMQP map. A polymorphic container of other AMQP values formed * into key/value pairs. */ PN_MAP = 25, /** * A special invalid type value that is returned when no valid type * is available. */ PN_INVALID = -1 } pn_type_t; /** * Return a string name for an AMQP type. * * @ingroup amqp_types * @param type an AMQP type * @return the string name of the given type */ PN_EXTERN const char *pn_type_name(pn_type_t type); /** * A discriminated union that holds any scalar AMQP value. The type * field indicates the AMQP type of the value, and the union may be * used to access the value for a given type. * * @ingroup api_types */ typedef struct { /** * Indicates the type of value the atom is currently pointing to. * See ::pn_type_t for details on AMQP types. */ pn_type_t type; union { /** * Valid when type is ::PN_BOOL. */ bool as_bool; /** * Valid when type is ::PN_UBYTE. */ uint8_t as_ubyte; /** * Valid when type is ::PN_BYTE. */ int8_t as_byte; /** * Valid when type is ::PN_USHORT. */ uint16_t as_ushort; /** * Valid when type is ::PN_SHORT. */ int16_t as_short; /** * Valid when type is ::PN_UINT. */ uint32_t as_uint; /** * Valid when type is ::PN_INT. */ int32_t as_int; /** * Valid when type is ::PN_CHAR. */ pn_char_t as_char; /** * Valid when type is ::PN_ULONG. */ uint64_t as_ulong; /** * Valid when type is ::PN_LONG. */ int64_t as_long; /** * Valid when type is ::PN_TIMESTAMP. */ pn_timestamp_t as_timestamp; /** * Valid when type is ::PN_FLOAT. */ float as_float; /** * Valid when type is ::PN_DOUBLE. */ double as_double; /** * Valid when type is ::PN_DECIMAL32. */ pn_decimal32_t as_decimal32; /** * Valid when type is ::PN_DECIMAL64. */ pn_decimal64_t as_decimal64; /** * Valid when type is ::PN_DECIMAL128. */ pn_decimal128_t as_decimal128; /** * Valid when type is ::PN_UUID. */ pn_uuid_t as_uuid; /** * Valid when type is ::PN_BINARY or ::PN_STRING or ::PN_SYMBOL. * When the type is ::PN_STRING the field will point to utf8 * encoded unicode. When the type is ::PN_SYMBOL, the field will * point to 7-bit ASCII. In the latter two cases, the bytes * pointed to are *not* necessarily null terminated. */ pn_bytes_t as_bytes; } u; } pn_atom_t; /** * @addtogroup data * @{ */ /** * An AMQP Data object. * * A pn_data_t object provides an interface for decoding, extracting, * creating, and encoding arbitrary AMQP data. A pn_data_t object * contains a tree of AMQP values. Leaf nodes in this tree correspond * to scalars in the AMQP type system such as @link ::PN_INT ints * @endlink or @link ::PN_STRING strings @endlink. Non-leaf nodes in * this tree correspond to compound values in the AMQP type system * such as @link ::PN_LIST lists @endlink, @link ::PN_MAP maps * @endlink, @link ::PN_ARRAY arrays @endlink, or @link ::PN_DESCRIBED * described @endlink values. The root node of the tree is the * pn_data_t object itself and can have an arbitrary number of * children. * * A pn_data_t object maintains the notion of the current node and the * current parent node. Siblings are ordered within their parent. * Values are accessed and/or added by using the ::pn_data_next(), * ::pn_data_prev(), ::pn_data_enter(), and ::pn_data_exit() * operations to navigate to the desired location in the tree and * using the supplied variety of pn_data_put_* / pn_data_get_* * operations to access or add a value of the desired type. * * The pn_data_put_* operations will always add a value _after_ the * current node in the tree. If the current node has a next sibling * the pn_data_put_* operations will overwrite the value on this node. * If there is no current node or the current node has no next sibling * then one will be added. The pn_data_put_* operations always set the * added/modified node to the current node. The pn_data_get_* * operations read the value of the current node and do not change * which node is current. * * The following types of scalar values are supported: * * - ::PN_NULL * - ::PN_BOOL * - ::PN_UBYTE * - ::PN_USHORT * - ::PN_SHORT * - ::PN_UINT * - ::PN_INT * - ::PN_ULONG * - ::PN_LONG * - ::PN_FLOAT * - ::PN_DOUBLE * - ::PN_BINARY * - ::PN_STRING * - ::PN_SYMBOL * * The following types of compound values are supported: * * - ::PN_DESCRIBED * - ::PN_ARRAY * - ::PN_LIST * - ::PN_MAP */ typedef struct pn_data_t pn_data_t; /** * Construct a pn_data_t object with the supplied initial capacity. A * pn_data_t will grow automatically as needed, so an initial capacity * of 0 is permitted. * * @param capacity the initial capacity * @return the newly constructed pn_data_t */ PN_EXTERN pn_data_t *pn_data(size_t capacity); /** * Free a pn_data_t object. * * @param data a pn_data_t object or NULL */ PN_EXTERN void pn_data_free(pn_data_t *data); /** * Access the current error code for a given pn_data_t. * * @param data a pn_data_t object * @return the current error code */ PN_EXTERN int pn_data_errno(pn_data_t *data); /** * Access the current error for a given pn_data_t. * * Every pn_data_t has an error descriptor that is created with the * pn_data_t and dies with the pn_data_t. The error descriptor is * updated whenever an operation fails. The ::pn_data_error() function * may be used to access a pn_data_t's error descriptor. * * @param data a pn_data_t object * @return a pointer to the pn_data_t's error descriptor */ PN_EXTERN pn_error_t *pn_data_error(pn_data_t *data); /** * @cond INTERNAL */ PN_EXTERN int pn_data_vfill(pn_data_t *data, const char *fmt, va_list ap); PN_EXTERN int pn_data_fill(pn_data_t *data, const char *fmt, ...); PN_EXTERN int pn_data_vscan(pn_data_t *data, const char *fmt, va_list ap); PN_EXTERN int pn_data_scan(pn_data_t *data, const char *fmt, ...); /** * @endcond */ /** * Clears a pn_data_t object. * * A cleared pn_data_t object is equivalent to a newly constructed * one. * * @param data the pn_data_t object to clear */ PN_EXTERN void pn_data_clear(pn_data_t *data); /** * Returns the total number of nodes contained in a pn_data_t object. * This includes all parents, children, siblings, grandchildren, etc. * In other words the count of all ancestors and descendants of the * current node, along with the current node if there is one. * * @param data a pn_data_t object * @return the total number of nodes in the pn_data_t object */ PN_EXTERN size_t pn_data_size(pn_data_t *data); /** * Clears current node pointer and sets the parent to the root node. * Clearing the current node sets it _before_ the first node, calling * ::pn_data_next() will advance to the first node. */ PN_EXTERN void pn_data_rewind(pn_data_t *data); /** * Advances the current node to its next sibling and returns true. If * there is no next sibling the current node remains unchanged and * false is returned. * * @param data a pn_data_t object * @return true iff the current node was changed */ PN_EXTERN bool pn_data_next(pn_data_t *data); /** * Moves the current node to its previous sibling and returns true. If * there is no previous sibling the current node remains unchanged and * false is returned. * * @param data a pn_data_t object * @return true iff the current node was changed */ PN_EXTERN bool pn_data_prev(pn_data_t *data); /** * Sets the parent node to the current node and clears the current * node. Clearing the current node sets it _before_ the first child, * calling ::pn_data_next() advances to the first child. This * operation will return false if there is no current node or if the * current node is not a compound type. * * @param data a pn_data_object * @return true iff the pointers to the current/parent nodes are changed */ PN_EXTERN bool pn_data_enter(pn_data_t *data); /** * Sets the current node to the parent node and the parent node to its * own parent. This operation will return false if there is no current * node or parent node. * * @param data a pn_data object * @return true iff the pointers to the current/parent nodes are * changed */ PN_EXTERN bool pn_data_exit(pn_data_t *data); /** * @cond INTERNAL */ PN_EXTERN bool pn_data_lookup(pn_data_t *data, const char *name); /** * @endcond */ /** * Access the type of the current node. Returns PN_INVALID if there is no * current node. * * @param data a data object * @return the type of the current node */ PN_EXTERN pn_type_t pn_data_type(pn_data_t *data); /** * Prints the contents of a pn_data_t object using ::pn_data_format() * to stdout. * * @param data a pn_data_t object * @return zero on success or an error on failure */ PN_EXTERN int pn_data_print(pn_data_t *data); /** * Formats the contents of a pn_data_t object in a human readable way * and writes them to the indicated location. The size pointer must * hold the amount of free space following the bytes pointer, and upon * success will be updated to indicate how much space has been used. * * @param data a pn_data_t object * @param bytes a buffer to write the output to * @param size a pointer to the size of the buffer * @return zero on success, or an error on failure */ PN_EXTERN int pn_data_format(pn_data_t *data, char *bytes, size_t *size); /** * Writes the contents of a data object to the given buffer as an AMQP * data stream. * * @param data the data object to encode * @param bytes the buffer for encoded data * @param size the size of the buffer * * @return the size of the encoded data on success or an error code on failure */ PN_EXTERN ssize_t pn_data_encode(pn_data_t *data, char *bytes, size_t size); /** * Returns the number of bytes needed to encode a data object. * * @param data the data object * * @return the size of the encoded data or an error code if data is invalid. */ PN_EXTERN ssize_t pn_data_encoded_size(pn_data_t *data); /** * Decodes a single value from the contents of the AMQP data stream * into the current data object. Note that if the pn_data_t object is * pointing to a current node, the decoded value will overwrite the * current one. If the pn_data_t object has no current node then a * node will be appended to the current parent. If there is no current * parent then a node will be appended to the pn_data_t itself. * * Upon success, this operation returns the number of bytes consumed * from the AMQP data stream. Upon failure, this operation returns an * error code. * * @param data a pn_data_t object * @param bytes a pointer to an encoded AMQP data stream * @param size the size of the encoded AMQP data stream * @return the number of bytes consumed from the AMQP data stream or an error code */ PN_EXTERN ssize_t pn_data_decode(pn_data_t *data, const char *bytes, size_t size); /** * Puts an empty list value into a pn_data_t. Elements may be filled * by entering the list node using ::pn_data_enter() and using * pn_data_put_* to add the desired contents. Once done, * ::pn_data_exit() may be used to return to the current level in the * tree and put more values. * * @code * pn_data_t *data = pn_data(0); * ... * pn_data_put_list(data); * pn_data_enter(data); * pn_data_put_int(data, 1); * pn_data_put_int(data, 2); * pn_data_put_int(data, 3); * pn_data_exit(data); * ... * @endcode * * @param data a pn_data_t object * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_list(pn_data_t *data); /** * Puts an empty map value into a pn_data_t. Elements may be filled by * entering the map node and putting alternating key value pairs. * * @code * pn_data_t *data = pn_data(0); * ... * pn_data_put_map(data); * pn_data_enter(data); * pn_data_put_string(data, pn_bytes(3, "key")); * pn_data_put_string(data, pn_bytes(5, "value")); * pn_data_exit(data); * ... * @endcode * * @param data a pn_data_t object * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_map(pn_data_t *data); /** * Puts an empty array value into a pn_data_t. Elements may be filled * by entering the array node and putting the element values. The * values must all be of the specified array element type. If an array * is described then the first child value of the array is the * descriptor and may be of any type. * * @code * pn_data_t *data = pn_data(0); * ... * pn_data_put_array(data, false, PN_INT); * pn_data_enter(data); * pn_data_put_int(data, 1); * pn_data_put_int(data, 2); * pn_data_put_int(data, 3); * pn_data_exit(data); * ... * pn_data_put_array(data, True, Data.DOUBLE); * pn_data_enter(data); * pn_data_put_symbol(data, "array-descriptor"); * pn_data_put_double(data, 1.1); * pn_data_put_double(data, 1.2); * pn_data_put_double(data, 1.3); * pn_data_exit(data); * ... * @endcode * * @param data a pn_data_t object * @param described specifies whether the array is described * @param type the type of the array * * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_array(pn_data_t *data, bool described, pn_type_t type); /** * Puts a described value into a pn_data_t object. A described node * has two children, the descriptor and the value. These are specified * by entering the node and putting the desired values. * * @code * pn_data_t *data = pn_data(0); * ... * pn_data_put_described(data); * pn_data_enter(data); * pn_data_put_symbol(data, pn_bytes(16, "value-descriptor")); * pn_data_put_string(data, pn_bytes(9, "the value")); * pn_data_exit(data); * ... * @endcode * * @param data a pn_data_t object * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_described(pn_data_t *data); /** * Puts a ::PN_NULL value. * * @param data a pn_data_t object * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_null(pn_data_t *data); /** * Puts a ::PN_BOOL value. * * @param data a pn_data_t object * @param b the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_bool(pn_data_t *data, bool b); /** * Puts a ::PN_UBYTE value. * * @param data a pn_data_t object * @param ub the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_ubyte(pn_data_t *data, uint8_t ub); /** * Puts a ::PN_BYTE value. * * @param data a pn_data_t object * @param b the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_byte(pn_data_t *data, int8_t b); /** * Puts a ::PN_USHORT value. * * @param data a pn_data_t object * @param us the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_ushort(pn_data_t *data, uint16_t us); /** * Puts a ::PN_SHORT value. * * @param data a pn_data_t object * @param s the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_short(pn_data_t *data, int16_t s); /** * Puts a ::PN_UINT value. * * @param data a pn_data_t object * @param ui the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_uint(pn_data_t *data, uint32_t ui); /** * Puts a ::PN_INT value. * * @param data a pn_data_t object * @param i the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_int(pn_data_t *data, int32_t i); /** * Puts a ::PN_CHAR value. * * @param data a pn_data_t object * @param c the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_char(pn_data_t *data, pn_char_t c); /** * Puts a ::PN_ULONG value. * * @param data a pn_data_t object * @param ul the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_ulong(pn_data_t *data, uint64_t ul); /** * Puts a ::PN_LONG value. * * @param data a pn_data_t object * @param l the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_long(pn_data_t *data, int64_t l); /** * Puts a ::PN_TIMESTAMP value. * * @param data a pn_data_t object * @param t the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_timestamp(pn_data_t *data, pn_timestamp_t t); /** * Puts a ::PN_FLOAT value. * * @param data a pn_data_t object * @param f the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_float(pn_data_t *data, float f); /** * Puts a ::PN_DOUBLE value. * * @param data a pn_data_t object * @param d the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_double(pn_data_t *data, double d); /** * Puts a ::PN_DECIMAL32 value. * * @param data a pn_data_t object * @param d the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_decimal32(pn_data_t *data, pn_decimal32_t d); /** * Puts a ::PN_DECIMAL64 value. * * @param data a pn_data_t object * @param d the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_decimal64(pn_data_t *data, pn_decimal64_t d); /** * Puts a ::PN_DECIMAL128 value. * * @param data a pn_data_t object * @param d the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_decimal128(pn_data_t *data, pn_decimal128_t d); /** * Puts a ::PN_UUID value. * * @param data a pn_data_t object * @param u the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_uuid(pn_data_t *data, pn_uuid_t u); /** * Puts a ::PN_BINARY value. The bytes referenced by the pn_bytes_t * argument are copied and stored inside the pn_data_t object. * * @param data a pn_data_t object * @param bytes the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_binary(pn_data_t *data, pn_bytes_t bytes); /** * Puts a ::PN_STRING value. The bytes referenced by the pn_bytes_t * argument are copied and stored inside the pn_data_t object. * * @param data a pn_data_t object * @param string utf8 encoded unicode * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_string(pn_data_t *data, pn_bytes_t string); /** * Puts a ::PN_SYMBOL value. The bytes referenced by the pn_bytes_t * argument are copied and stored inside the pn_data_t object. * * @param data a pn_data_t object * @param symbol ascii encoded symbol * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_symbol(pn_data_t *data, pn_bytes_t symbol); /** * Puts any scalar value value. * * @param data a pn_data_t object * @param atom the value * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_put_atom(pn_data_t *data, pn_atom_t atom); /** * If the current node is a list, return the number of elements, * otherwise return zero. List elements can be accessed by entering * the list. * * @code * ... * size_t count = pn_data_get_list(data); * pn_data_enter(data); * for (size_t i = 0; i < count; i++) { * if (pn_data_next(data)) { * switch (pn_data_type(data)) { * case PN_STRING: * ... * break; * case PN_INT: * ... * break; * } * } * pn_data_exit(data); * ... * @endcode .* * @param data a pn_data_t object * @return the size of a list node */ PN_EXTERN size_t pn_data_get_list(pn_data_t *data); /** * If the current node is a map, return the number of child elements, * otherwise return zero. Key value pairs can be accessed by entering * the map. * * @code * ... * size_t count = pn_data_get_map(data); * pn_data_enter(data); * for (size_t i = 0; i < count/2; i++) { * // read key * if (pn_data_next(data)) { * switch (pn_data_type(data)) { * case PN_STRING: * ... * break; * ... * } * } * ... * // read value * if (pn_data_next(data)) { * switch (pn_data_type(data)) { * case PN_INT: * ... * break; * ... * } * } * ... * } * pn_data_exit(data); * ... * @endcode * * @param data a pn_data_t object * @return the number of child elements of a map node */ PN_EXTERN size_t pn_data_get_map(pn_data_t *data); /** * If the current node is an array, return the number of elements in * the array, otherwise return 0. Array data can be accessed by * entering the array. If the array is described, the first child node * will be the descriptor, and the remaining count child nodes * will be the elements of the array. * * @code * ... * size_t count = pn_data_get_array(data); * bool described = pn_data_is_array_described(data); * pn_type_t type = pn_data_get_array_type(data); * * pn_data_enter(data); * * if (described && pn_data_next(data)) { * // the descriptor could be another type, but let's assume it's a symbol * pn_bytes_t descriptor = pn_data_get_symbol(data); * } * * for (size_t i = 0; i < count; i++) { * if (pn_data_next(data)) { * // all elements will be values of the array type retrieved above * ... * } * } * pn_data_exit(data); * ... * @endcode * * @param data a pn_data_t object * @return the number of elements of an array node */ PN_EXTERN size_t pn_data_get_array(pn_data_t *data); /** * Returns true if the current node points to a described array. * * @param data a pn_data_t object * @return true if the current node points to a described array */ PN_EXTERN bool pn_data_is_array_described(pn_data_t *data); /** * Return the array type if the current node points to an array, * PN_INVALID otherwise. * * @param data a pn_data_t object * @return the element type of an array node */ PN_EXTERN pn_type_t pn_data_get_array_type(pn_data_t *data); /** * Checks if the current node is a described value. The descriptor and * value may be accessed by entering the described value node. * * @code * ... * // read a symbolically described string * if (pn_data_is_described(data)) { * pn_data_enter(data); * pn_data_next(data); * assert(pn_data_type(data) == PN_SYMBOL); * pn_bytes_t symbol = pn_data_get_symbol(data); * pn_data_next(data); * assert(pn_data_type(data) == PN_STRING); * pn_bytes_t utf8 = pn_data_get_string(data); * pn_data_exit(data); * } * ... * @endcode * * @param data a pn_data_t object * @return true if the current node is a described type */ PN_EXTERN bool pn_data_is_described(pn_data_t *data); /** * Checks if the current node is a ::PN_NULL. * * @param data a pn_data_t object * @return true iff the current node is ::PN_NULL */ PN_EXTERN bool pn_data_is_null(pn_data_t *data); /** * If the current node is a ::PN_BOOL, returns its value. * * @param data a pn_data_t object */ PN_EXTERN bool pn_data_get_bool(pn_data_t *data); /** * If the current node is a ::PN_UBYTE, return its value, otherwise * return 0. * * @param data a pn_data_t object */ PN_EXTERN uint8_t pn_data_get_ubyte(pn_data_t *data); /** * If the current node is a signed byte, returns its value, returns 0 * otherwise. * * @param data a pn_data_t object */ PN_EXTERN int8_t pn_data_get_byte(pn_data_t *data); /** * If the current node is an unsigned short, returns its value, * returns 0 otherwise. * * @param data a pn_data_t object */ PN_EXTERN uint16_t pn_data_get_ushort(pn_data_t *data); /** * If the current node is a signed short, returns its value, returns 0 * otherwise. * * @param data a pn_data_t object */ PN_EXTERN int16_t pn_data_get_short(pn_data_t *data); /** * If the current node is an unsigned int, returns its value, returns * 0 otherwise. * * @param data a pn_data_t object */ PN_EXTERN uint32_t pn_data_get_uint(pn_data_t *data); /** * If the current node is a signed int, returns its value, returns 0 * otherwise. * * @param data a pn_data_t object */ PN_EXTERN int32_t pn_data_get_int(pn_data_t *data); /** * If the current node is a char, returns its value, returns 0 * otherwise. * * @param data a pn_data_t object */ PN_EXTERN pn_char_t pn_data_get_char(pn_data_t *data); /** * If the current node is an unsigned long, returns its value, returns * 0 otherwise. * * @param data a pn_data_t object */ PN_EXTERN uint64_t pn_data_get_ulong(pn_data_t *data); /** * If the current node is an signed long, returns its value, returns 0 * otherwise. * * @param data a pn_data_t object */ PN_EXTERN int64_t pn_data_get_long(pn_data_t *data); /** * If the current node is a timestamp, returns its value, returns 0 * otherwise. * * @param data a pn_data_t object */ PN_EXTERN pn_timestamp_t pn_data_get_timestamp(pn_data_t *data); /** * If the current node is a float, returns its value, returns 0 * otherwise. * * @param data a pn_data_t object */ PN_EXTERN float pn_data_get_float(pn_data_t *data); /** * If the current node is a double, returns its value, returns 0 * otherwise. * * @param data a pn_data_t object */ PN_EXTERN double pn_data_get_double(pn_data_t *data); /** * If the current node is a decimal32, returns its value, returns 0 * otherwise. * * @param data a pn_data_t object */ PN_EXTERN pn_decimal32_t pn_data_get_decimal32(pn_data_t *data); /** * If the current node is a decimal64, returns its value, returns 0 * otherwise. * * @param data a pn_data_t object */ PN_EXTERN pn_decimal64_t pn_data_get_decimal64(pn_data_t *data); /** * If the current node is a decimal128, returns its value, returns 0 * otherwise. * * @param data a pn_data_t object */ PN_EXTERN pn_decimal128_t pn_data_get_decimal128(pn_data_t *data); /** * If the current node is a UUID, returns its value, returns None * otherwise. * * @param data a pn_data_t object * @return a uuid value */ PN_EXTERN pn_uuid_t pn_data_get_uuid(pn_data_t *data); /** * If the current node is binary, returns its value, returns "" * otherwise. The pn_bytes_t returned will point to memory held inside * the pn_data_t. When the pn_data_t is cleared or freed, this memory * will be reclaimed. * * @param data a pn_data_t object */ PN_EXTERN pn_bytes_t pn_data_get_binary(pn_data_t *data); /** * If the current node is a string, returns its value, returns "" * otherwise. The pn_bytes_t returned will point to memory held inside * the pn_data_t. When the pn_data_t is cleared or freed, this memory * will be reclaimed. * * @param data a pn_data_t object * @return a pn_bytes_t pointing to utf8 */ PN_EXTERN pn_bytes_t pn_data_get_string(pn_data_t *data); /** * If the current node is a symbol, returns its value, returns "" * otherwise. The pn_bytes_t returned will point to memory held inside * the pn_data_t. When the pn_data_t is cleared or freed, this memory * will be reclaimed. * * @param data a pn_data_t object * @return a pn_bytes_t pointing to ascii */ PN_EXTERN pn_bytes_t pn_data_get_symbol(pn_data_t *data); /** * If the current node is a symbol, string, or binary, return the * bytes representing its value. The pn_bytes_t returned will point to * memory held inside the pn_data_t. When the pn_data_t is cleared or * freed, this memory will be reclaimed. * * @param data a pn_data_t object * @return a pn_bytes_t pointing to the node's value */ PN_EXTERN pn_bytes_t pn_data_get_bytes(pn_data_t *data); /** * If the current node is a scalar value, return it as a pn_atom_t. * * @param data a pn_data_t object * @return the value of the current node as pn_atom_t */ PN_EXTERN pn_atom_t pn_data_get_atom(pn_data_t *data); /** * Copy the contents of another pn_data_t object. Any values in the * data object will be lost. * * @param data a pn_data_t object * @param src the source pn_data_t to copy from * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_copy(pn_data_t *data, pn_data_t *src); /** * Append the contents of another pn_data_t object. * * @param data a pn_data_t object * @param src the source pn_data_t to append from * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_append(pn_data_t *data, pn_data_t *src); /** * Append up to _n_ values from the contents of another pn_data_t * object. * * @param data a pn_data_t object * @param src the source pn_data_t to append from * @param limit the maximum number of values to append * @return zero on success or an error code on failure */ PN_EXTERN int pn_data_appendn(pn_data_t *data, pn_data_t *src, int limit); /** * Modify a pn_data_t object to behave as if the current node is the * root node of the tree. This impacts the behaviour of * ::pn_data_rewind(), ::pn_data_next(), ::pn_data_prev(), and * anything else that depends on the navigational state of the * pn_data_t object. Use ::pn_data_widen() to reverse the effect of * this operation. * * @param data a pn_data_t object */ PN_EXTERN void pn_data_narrow(pn_data_t *data); /** * Reverse the effect of ::pn_data_narrow(). * * @param data a pn_data_t object */ PN_EXTERN void pn_data_widen(pn_data_t *data); /** * Returns a handle for the current navigational state of a pn_data_t * so that it can be later restored using ::pn_data_restore(). * * @param data a pn_data_t object * @return a handle for the current navigational state */ PN_EXTERN pn_handle_t pn_data_point(pn_data_t *data); /** * Restores a prior navigational state that was saved using * ::pn_data_point(). If the data object has been modified in such a * way that the prior navigational state cannot be restored, then this * will return false and the navigational state will remain unchanged, * otherwise it will return true. * * @param data a pn_data_t object * @param point a handle referencing the saved navigational state * @return true iff the prior navigational state was restored */ PN_EXTERN bool pn_data_restore(pn_data_t *data, pn_handle_t point); /** * Dumps a debug representation of the internal state of the pn_data_t * object that includes its navigational state to stdout for debugging * purposes. * * @param data a pn_data_t object that is behaving in a confusing way */ PN_EXTERN void pn_data_dump(pn_data_t *data); /** * @} */ #ifdef __cplusplus } #endif #endif /* codec.h */