ext/cproton/cproton.c in qpid_proton-0.5 vs ext/cproton/cproton.c in qpid_proton-0.6

- old
+ new

@@ -1,13 +1,13 @@ /* ---------------------------------------------------------------------------- * This file was automatically generated by SWIG (http://www.swig.org). - * Version 2.0.10 - * - * This file is not intended to be easily readable and contains a number of + * Version 2.0.11 + * + * This file is not intended to be easily readable and contains a number of * coding conventions designed to improve portability and efficiency. Do not make - * changes to this file unless you know what you are doing--modify the SWIG - * interface file instead. + * changes to this file unless you know what you are doing--modify the SWIG + * interface file instead. * ----------------------------------------------------------------------------- */ #define SWIGRUBY /* ----------------------------------------------------------------------------- @@ -39,32 +39,32 @@ /* attribute recognised by some compilers to avoid 'unused' warnings */ #ifndef SWIGUNUSED # if defined(__GNUC__) # if !(defined(__cplusplus)) || (__GNUC__ > 3 || (__GNUC__ == 3 && __GNUC_MINOR__ >= 4)) -# define SWIGUNUSED __attribute__ ((__unused__)) +# define SWIGUNUSED __attribute__ ((__unused__)) # else # define SWIGUNUSED # endif # elif defined(__ICC) -# define SWIGUNUSED __attribute__ ((__unused__)) +# define SWIGUNUSED __attribute__ ((__unused__)) # else -# define SWIGUNUSED +# define SWIGUNUSED # endif #endif #ifndef SWIG_MSC_UNSUPPRESS_4505 # if defined(_MSC_VER) # pragma warning(disable : 4505) /* unreferenced local function has been removed */ -# endif +# endif #endif #ifndef SWIGUNUSEDPARM # ifdef __cplusplus # define SWIGUNUSEDPARM(p) # else -# define SWIGUNUSEDPARM(p) p SWIGUNUSED +# define SWIGUNUSEDPARM(p) p SWIGUNUSED # endif #endif /* internal SWIG method */ #ifndef SWIGINTERN @@ -103,11 +103,11 @@ #ifndef SWIGSTDCALL # if defined(_WIN32) || defined(__WIN32__) || defined(__CYGWIN__) # define SWIGSTDCALL __stdcall # else # define SWIGSTDCALL -# endif +# endif #endif /* Deal with Microsoft's attempt at deprecating C standard runtime functions */ #if !defined(SWIG_NO_CRT_SECURE_NO_DEPRECATE) && defined(_MSC_VER) && !defined(_CRT_SECURE_NO_DEPRECATE) # define _CRT_SECURE_NO_DEPRECATE @@ -148,32 +148,32 @@ /* attribute recognised by some compilers to avoid 'unused' warnings */ #ifndef SWIGUNUSED # if defined(__GNUC__) # if !(defined(__cplusplus)) || (__GNUC__ > 3 || (__GNUC__ == 3 && __GNUC_MINOR__ >= 4)) -# define SWIGUNUSED __attribute__ ((__unused__)) +# define SWIGUNUSED __attribute__ ((__unused__)) # else # define SWIGUNUSED # endif # elif defined(__ICC) -# define SWIGUNUSED __attribute__ ((__unused__)) +# define SWIGUNUSED __attribute__ ((__unused__)) # else -# define SWIGUNUSED +# define SWIGUNUSED # endif #endif #ifndef SWIG_MSC_UNSUPPRESS_4505 # if defined(_MSC_VER) # pragma warning(disable : 4505) /* unreferenced local function has been removed */ -# endif +# endif #endif #ifndef SWIGUNUSEDPARM # ifdef __cplusplus # define SWIGUNUSEDPARM(p) # else -# define SWIGUNUSEDPARM(p) p SWIGUNUSED +# define SWIGUNUSEDPARM(p) p SWIGUNUSED # endif #endif /* internal SWIG method */ #ifndef SWIGINTERN @@ -212,11 +212,11 @@ #ifndef SWIGSTDCALL # if defined(_WIN32) || defined(__WIN32__) || defined(__CYGWIN__) # define SWIGSTDCALL __stdcall # else # define SWIGSTDCALL -# endif +# endif #endif /* Deal with Microsoft's attempt at deprecating C standard runtime functions */ #if !defined(SWIG_NO_CRT_SECURE_NO_DEPRECATE) && defined(_MSC_VER) && !defined(_CRT_SECURE_NO_DEPRECATE) # define _CRT_SECURE_NO_DEPRECATE @@ -250,11 +250,11 @@ /* You can use the SWIGRUNTIME and SWIGRUNTIMEINLINE macros for creating a static or dynamic library from the SWIG runtime code. In 99.9% of the cases, SWIG just needs to declare them as 'static'. - + But only do this if strictly necessary, ie, if you have problems with your compiler or suchlike. */ #ifndef SWIGRUNTIME @@ -276,20 +276,20 @@ /* Flags for new pointer objects */ #define SWIG_POINTER_OWN 0x1 -/* +/* Flags/methods for returning states. - - The SWIG conversion methods, as ConvertPtr, return an integer + + The SWIG conversion methods, as ConvertPtr, return an integer that tells if the conversion was successful or not. And if not, an error code can be returned (see swigerrors.swg for the codes). - + Use the following macros/flags to set or process the returning states. - + In old versions of SWIG, code such as the following was usually written: if (SWIG_ConvertPtr(obj,vptr,ty.flags) != -1) { // success code } else { @@ -318,27 +318,27 @@ ... } } else { // fail code } - + I.e., now SWIG_ConvertPtr can return new objects and you can identify the case and take care of the deallocation. Of course that also requires SWIG_ConvertPtr to return new result values, such as - int SWIG_ConvertPtr(obj, ptr,...) { - if (<obj is ok>) { - if (<need new object>) { - *ptr = <ptr to new allocated object>; - return SWIG_NEWOBJ; - } else { - *ptr = <ptr to old object>; - return SWIG_OLDOBJ; - } - } else { - return SWIG_BADOBJ; - } + int SWIG_ConvertPtr(obj, ptr,...) { + if (<obj is ok>) { + if (<need new object>) { + *ptr = <ptr to new allocated object>; + return SWIG_NEWOBJ; + } else { + *ptr = <ptr to old object>; + return SWIG_OLDOBJ; + } + } else { + return SWIG_BADOBJ; + } } Of course, returning the plain '0(success)/-1(fail)' still works, but you can be more explicit by returning SWIG_BADOBJ, SWIG_ERROR or any of the SWIG errors code. @@ -348,21 +348,21 @@ int food(double) int fooi(int); and you call - + food(1) // cast rank '1' (1 -> 1.0) fooi(1) // cast rank '0' just use the SWIG_AddCast()/SWIG_CheckState() */ -#define SWIG_OK (0) +#define SWIG_OK (0) #define SWIG_ERROR (-1) #define SWIG_IsOK(r) (r >= 0) -#define SWIG_ArgError(r) ((r != SWIG_ERROR) ? r : SWIG_TypeError) +#define SWIG_ArgError(r) ((r != SWIG_ERROR) ? r : SWIG_TypeError) /* The CastRankLimit says how many bits are used for the cast rank */ #define SWIG_CASTRANKLIMIT (1 << 8) /* The NewMask denotes the object was created (using new/malloc) */ #define SWIG_NEWOBJMASK (SWIG_CASTRANKLIMIT << 1) @@ -389,15 +389,15 @@ # ifndef SWIG_MAXCASTRANK /* Default cast allowed */ # define SWIG_MAXCASTRANK (2) # endif # define SWIG_CASTRANKMASK ((SWIG_CASTRANKLIMIT) -1) # define SWIG_CastRank(r) (r & SWIG_CASTRANKMASK) -SWIGINTERNINLINE int SWIG_AddCast(int r) { +SWIGINTERNINLINE int SWIG_AddCast(int r) { return SWIG_IsOK(r) ? ((SWIG_CastRank(r) < SWIG_MAXCASTRANK) ? (r + 1) : SWIG_ERROR) : r; } -SWIGINTERNINLINE int SWIG_CheckState(int r) { - return SWIG_IsOK(r) ? SWIG_CastRank(r) + 1 : 0; +SWIGINTERNINLINE int SWIG_CheckState(int r) { + return SWIG_IsOK(r) ? SWIG_CastRank(r) + 1 : 0; } #else /* no cast-rank mode */ # define SWIG_AddCast(r) (r) # define SWIG_CheckState(r) (SWIG_IsOK(r) ? 1 : 0) #endif @@ -440,11 +440,11 @@ swig_type_info **type_initial; /* Array of initially generated type structures */ swig_cast_info **cast_initial; /* Array of initially generated casting structures */ void *clientdata; /* Language specific module data */ } swig_module_info; -/* +/* Compare two type names skipping the space characters, therefore "char*" == "char *" and "Class<int>" == "Class<int >", etc. Return 0 when the two name types are equivalent, as in strncmp, but skipping ' '. @@ -513,11 +513,11 @@ } } return 0; } -/* +/* Identical to SWIG_TypeCheck, except strcmp is replaced with a pointer comparison */ SWIGRUNTIME swig_cast_info * SWIG_TypeCheckStruct(swig_type_info *from, swig_type_info *ty) { if (ty) { @@ -548,11 +548,11 @@ SWIGRUNTIMEINLINE void * SWIG_TypeCast(swig_cast_info *ty, void *ptr, int *newmemory) { return ((!ty) || (!ty->converter)) ? ptr : (*ty->converter)(ptr, newmemory); } -/* +/* Dynamic pointer casting. Down an inheritance hierarchy */ SWIGRUNTIME swig_type_info * SWIG_TypeDynamicCast(swig_type_info *ty, void **ptr) { swig_type_info *lastty = ty; @@ -592,59 +592,59 @@ } else return type->name; } -/* +/* Set the clientdata field for a type */ SWIGRUNTIME void SWIG_TypeClientData(swig_type_info *ti, void *clientdata) { swig_cast_info *cast = ti->cast; /* if (ti->clientdata == clientdata) return; */ ti->clientdata = clientdata; - + while (cast) { if (!cast->converter) { swig_type_info *tc = cast->type; if (!tc->clientdata) { SWIG_TypeClientData(tc, clientdata); } - } + } cast = cast->next; } } SWIGRUNTIME void SWIG_TypeNewClientData(swig_type_info *ti, void *clientdata) { SWIG_TypeClientData(ti, clientdata); ti->owndata = 1; } - + /* Search for a swig_type_info structure only by mangled name Search is a O(log #types) - - We start searching at module start, and finish searching when start == end. + + We start searching at module start, and finish searching when start == end. Note: if start == end at the beginning of the function, we go all the way around the circular list. */ SWIGRUNTIME swig_type_info * -SWIG_MangledTypeQueryModule(swig_module_info *start, - swig_module_info *end, +SWIG_MangledTypeQueryModule(swig_module_info *start, + swig_module_info *end, const char *name) { swig_module_info *iter = start; do { if (iter->size) { register size_t l = 0; register size_t r = iter->size - 1; do { /* since l+r >= 0, we can (>> 1) instead (/ 2) */ - register size_t i = (l + r) >> 1; + register size_t i = (l + r) >> 1; const char *iname = iter->types[i]->name; if (iname) { register int compare = strcmp(name, iname); - if (compare == 0) { + if (compare == 0) { return iter->types[i]; } else if (compare < 0) { if (i) { r = i - 1; } else { @@ -665,18 +665,18 @@ /* Search for a swig_type_info structure for either a mangled name or a human readable name. It first searches the mangled names of the types, which is a O(log #types) If a type is not found it then searches the human readable names, which is O(#types). - - We start searching at module start, and finish searching when start == end. + + We start searching at module start, and finish searching when start == end. Note: if start == end at the beginning of the function, we go all the way around the circular list. */ SWIGRUNTIME swig_type_info * -SWIG_TypeQueryModule(swig_module_info *start, - swig_module_info *end, +SWIG_TypeQueryModule(swig_module_info *start, + swig_module_info *end, const char *name) { /* STEP 1: Search the name field using binary search */ swig_type_info *ret = SWIG_MangledTypeQueryModule(start, end, name); if (ret) { return ret; @@ -691,16 +691,16 @@ return iter->types[i]; } iter = iter->next; } while (iter != end); } - + /* neither found a match */ return 0; } -/* +/* Pack binary data into a string */ SWIGRUNTIME char * SWIG_PackData(char *c, void *ptr, size_t sz) { static const char hex[17] = "0123456789abcdef"; @@ -712,11 +712,11 @@ *(c++) = hex[uu & 0xf]; } return c; } -/* +/* Unpack binary data from a string */ SWIGRUNTIME const char * SWIG_UnpackData(const char *c, void *ptr, size_t sz) { register unsigned char *u = (unsigned char *) ptr; @@ -726,25 +726,25 @@ register unsigned char uu; if ((d >= '0') && (d <= '9')) uu = ((d - '0') << 4); else if ((d >= 'a') && (d <= 'f')) uu = ((d - ('a'-10)) << 4); - else + else return (char *) 0; d = *(c++); if ((d >= '0') && (d <= '9')) uu |= (d - '0'); else if ((d >= 'a') && (d <= 'f')) uu |= (d - ('a'-10)); - else + else return (char *) 0; *u = uu; } return c; } -/* +/* Pack 'void *' into a string buffer. */ SWIGRUNTIME char * SWIG_PackVoidPtr(char *buff, void *ptr, const char *name, size_t bsz) { char *r = buff; @@ -800,22 +800,22 @@ #ifdef __cplusplus } #endif /* Errors in SWIG */ -#define SWIG_UnknownError -1 -#define SWIG_IOError -2 -#define SWIG_RuntimeError -3 -#define SWIG_IndexError -4 -#define SWIG_TypeError -5 -#define SWIG_DivisionByZero -6 -#define SWIG_OverflowError -7 -#define SWIG_SyntaxError -8 -#define SWIG_ValueError -9 +#define SWIG_UnknownError -1 +#define SWIG_IOError -2 +#define SWIG_RuntimeError -3 +#define SWIG_IndexError -4 +#define SWIG_TypeError -5 +#define SWIG_DivisionByZero -6 +#define SWIG_OverflowError -7 +#define SWIG_SyntaxError -8 +#define SWIG_ValueError -9 #define SWIG_SystemError -10 #define SWIG_AttributeError -11 -#define SWIG_MemoryError -12 +#define SWIG_MemoryError -12 #define SWIG_NullReferenceError -13 #include <ruby.h> @@ -1777,75 +1777,76 @@ /* -------- TYPES TABLE (BEGIN) -------- */ #define SWIGTYPE_p_char swig_types[0] -#define SWIGTYPE_p_f_p_void__uintptr_t swig_types[1] -#define SWIGTYPE_p_f_p_void__void swig_types[2] -#define SWIGTYPE_p_f_p_void_p_struct_pn_string_t__int swig_types[3] -#define SWIGTYPE_p_f_p_void_p_void__intptr_t swig_types[4] -#define SWIGTYPE_p_int swig_types[5] -#define SWIGTYPE_p_intptr_t swig_types[6] -#define SWIGTYPE_p_long swig_types[7] -#define SWIGTYPE_p_long_long swig_types[8] -#define SWIGTYPE_p_p_char swig_types[9] -#define SWIGTYPE_p_pn_activate_criteria_t swig_types[10] -#define SWIGTYPE_p_pn_atom_t swig_types[11] -#define SWIGTYPE_p_pn_atom_t_u swig_types[12] -#define SWIGTYPE_p_pn_bytes_t swig_types[13] -#define SWIGTYPE_p_pn_class_t swig_types[14] -#define SWIGTYPE_p_pn_condition_t swig_types[15] -#define SWIGTYPE_p_pn_connection_t swig_types[16] -#define SWIGTYPE_p_pn_connector_t swig_types[17] -#define SWIGTYPE_p_pn_data_t swig_types[18] -#define SWIGTYPE_p_pn_decimal128_t swig_types[19] -#define SWIGTYPE_p_pn_delivery_t swig_types[20] -#define SWIGTYPE_p_pn_delivery_tag_t swig_types[21] -#define SWIGTYPE_p_pn_disposition_t swig_types[22] -#define SWIGTYPE_p_pn_distribution_mode_t swig_types[23] -#define SWIGTYPE_p_pn_driver_t swig_types[24] -#define SWIGTYPE_p_pn_durability_t swig_types[25] -#define SWIGTYPE_p_pn_error_t swig_types[26] -#define SWIGTYPE_p_pn_expiry_policy_t swig_types[27] -#define SWIGTYPE_p_pn_format_t swig_types[28] -#define SWIGTYPE_p_pn_hash_t swig_types[29] -#define SWIGTYPE_p_pn_link_t swig_types[30] -#define SWIGTYPE_p_pn_list_t swig_types[31] -#define SWIGTYPE_p_pn_listener_t swig_types[32] -#define SWIGTYPE_p_pn_map_t swig_types[33] -#define SWIGTYPE_p_pn_message_t swig_types[34] -#define SWIGTYPE_p_pn_messenger_t swig_types[35] -#define SWIGTYPE_p_pn_rcv_settle_mode_t swig_types[36] -#define SWIGTYPE_p_pn_sasl_outcome_t swig_types[37] -#define SWIGTYPE_p_pn_sasl_state_t swig_types[38] -#define SWIGTYPE_p_pn_sasl_t swig_types[39] -#define SWIGTYPE_p_pn_session_t swig_types[40] -#define SWIGTYPE_p_pn_snd_settle_mode_t swig_types[41] -#define SWIGTYPE_p_pn_ssl_domain_t swig_types[42] -#define SWIGTYPE_p_pn_ssl_mode_t swig_types[43] -#define SWIGTYPE_p_pn_ssl_resume_status_t swig_types[44] -#define SWIGTYPE_p_pn_ssl_t swig_types[45] -#define SWIGTYPE_p_pn_ssl_verify_mode_t swig_types[46] -#define SWIGTYPE_p_pn_status_t swig_types[47] -#define SWIGTYPE_p_pn_string_t swig_types[48] -#define SWIGTYPE_p_pn_subscription_t swig_types[49] -#define SWIGTYPE_p_pn_terminus_t swig_types[50] -#define SWIGTYPE_p_pn_terminus_type_t swig_types[51] -#define SWIGTYPE_p_pn_transport_t swig_types[52] -#define SWIGTYPE_p_pn_type_t swig_types[53] -#define SWIGTYPE_p_pn_uuid_t swig_types[54] -#define SWIGTYPE_p_short swig_types[55] -#define SWIGTYPE_p_signed_char swig_types[56] -#define SWIGTYPE_p_uintptr_t swig_types[57] -#define SWIGTYPE_p_unsigned_char swig_types[58] -#define SWIGTYPE_p_unsigned_int swig_types[59] -#define SWIGTYPE_p_unsigned_long swig_types[60] -#define SWIGTYPE_p_unsigned_long_long swig_types[61] -#define SWIGTYPE_p_unsigned_short swig_types[62] -#define SWIGTYPE_p_void swig_types[63] -static swig_type_info *swig_types[65]; -static swig_module_info swig_module = {swig_types, 64, 0, 0, 0, 0}; +#define SWIGTYPE_p_f_p_struct_pn_transport_t_p_q_const__char__void swig_types[1] +#define SWIGTYPE_p_f_p_void__uintptr_t swig_types[2] +#define SWIGTYPE_p_f_p_void__void swig_types[3] +#define SWIGTYPE_p_f_p_void_p_struct_pn_string_t__int swig_types[4] +#define SWIGTYPE_p_f_p_void_p_void__intptr_t swig_types[5] +#define SWIGTYPE_p_int swig_types[6] +#define SWIGTYPE_p_intptr_t swig_types[7] +#define SWIGTYPE_p_long swig_types[8] +#define SWIGTYPE_p_long_long swig_types[9] +#define SWIGTYPE_p_p_char swig_types[10] +#define SWIGTYPE_p_pn_activate_criteria_t swig_types[11] +#define SWIGTYPE_p_pn_atom_t swig_types[12] +#define SWIGTYPE_p_pn_atom_t_u swig_types[13] +#define SWIGTYPE_p_pn_bytes_t swig_types[14] +#define SWIGTYPE_p_pn_class_t swig_types[15] +#define SWIGTYPE_p_pn_condition_t swig_types[16] +#define SWIGTYPE_p_pn_connection_t swig_types[17] +#define SWIGTYPE_p_pn_connector_t swig_types[18] +#define SWIGTYPE_p_pn_data_t swig_types[19] +#define SWIGTYPE_p_pn_decimal128_t swig_types[20] +#define SWIGTYPE_p_pn_delivery_t swig_types[21] +#define SWIGTYPE_p_pn_delivery_tag_t swig_types[22] +#define SWIGTYPE_p_pn_disposition_t swig_types[23] +#define SWIGTYPE_p_pn_distribution_mode_t swig_types[24] +#define SWIGTYPE_p_pn_driver_t swig_types[25] +#define SWIGTYPE_p_pn_durability_t swig_types[26] +#define SWIGTYPE_p_pn_error_t swig_types[27] +#define SWIGTYPE_p_pn_expiry_policy_t swig_types[28] +#define SWIGTYPE_p_pn_format_t swig_types[29] +#define SWIGTYPE_p_pn_hash_t swig_types[30] +#define SWIGTYPE_p_pn_link_t swig_types[31] +#define SWIGTYPE_p_pn_list_t swig_types[32] +#define SWIGTYPE_p_pn_listener_t swig_types[33] +#define SWIGTYPE_p_pn_map_t swig_types[34] +#define SWIGTYPE_p_pn_message_t swig_types[35] +#define SWIGTYPE_p_pn_messenger_t swig_types[36] +#define SWIGTYPE_p_pn_rcv_settle_mode_t swig_types[37] +#define SWIGTYPE_p_pn_sasl_outcome_t swig_types[38] +#define SWIGTYPE_p_pn_sasl_state_t swig_types[39] +#define SWIGTYPE_p_pn_sasl_t swig_types[40] +#define SWIGTYPE_p_pn_session_t swig_types[41] +#define SWIGTYPE_p_pn_snd_settle_mode_t swig_types[42] +#define SWIGTYPE_p_pn_ssl_domain_t swig_types[43] +#define SWIGTYPE_p_pn_ssl_mode_t swig_types[44] +#define SWIGTYPE_p_pn_ssl_resume_status_t swig_types[45] +#define SWIGTYPE_p_pn_ssl_t swig_types[46] +#define SWIGTYPE_p_pn_ssl_verify_mode_t swig_types[47] +#define SWIGTYPE_p_pn_status_t swig_types[48] +#define SWIGTYPE_p_pn_string_t swig_types[49] +#define SWIGTYPE_p_pn_subscription_t swig_types[50] +#define SWIGTYPE_p_pn_terminus_t swig_types[51] +#define SWIGTYPE_p_pn_terminus_type_t swig_types[52] +#define SWIGTYPE_p_pn_transport_t swig_types[53] +#define SWIGTYPE_p_pn_type_t swig_types[54] +#define SWIGTYPE_p_pn_uuid_t swig_types[55] +#define SWIGTYPE_p_short swig_types[56] +#define SWIGTYPE_p_signed_char swig_types[57] +#define SWIGTYPE_p_uintptr_t swig_types[58] +#define SWIGTYPE_p_unsigned_char swig_types[59] +#define SWIGTYPE_p_unsigned_int swig_types[60] +#define SWIGTYPE_p_unsigned_long swig_types[61] +#define SWIGTYPE_p_unsigned_long_long swig_types[62] +#define SWIGTYPE_p_unsigned_short swig_types[63] +#define SWIGTYPE_p_void swig_types[64] +static swig_type_info *swig_types[66]; +static swig_module_info swig_module = {swig_types, 65, 0, 0, 0, 0}; #define SWIG_TypeQuery(name) SWIG_TypeQueryModule(&swig_module, &swig_module, name) #define SWIG_MangledTypeQuery(name) SWIG_MangledTypeQueryModule(&swig_module, &swig_module, name) /* -------- TYPES TABLE (END) -------- */ @@ -1856,11 +1857,11 @@ #define SWIG_RUBY_THREAD_BEGIN_BLOCK #define SWIG_RUBY_THREAD_END_BLOCK -#define SWIGVERSION 0x020010 +#define SWIGVERSION 0x020011 #define SWIG_VERSION SWIGVERSION #define SWIG_as_voidptr(a) (void *)((const void *)(a)) #define SWIG_as_voidptrptr(a) ((void)SWIG_as_voidptr(*a),(void**)(a)) @@ -1940,11 +1941,11 @@ { return Qnil; } -/*@SWIG:/usr/share/swig/2.0.10/ruby/rubyprimtypes.swg,19,%ruby_aux_method@*/ +/*@SWIG:/usr/share/swig/2.0.11/ruby/rubyprimtypes.swg,19,%ruby_aux_method@*/ SWIGINTERN VALUE SWIG_AUX_NUM2ULONG(VALUE *args) { VALUE obj = args[0]; VALUE type = TYPE(obj); unsigned long *res = (unsigned long *)(args[1]); @@ -2114,11 +2115,11 @@ { return SWIG_From_unsigned_SS_long ((unsigned long)(value)); } -/*@SWIG:/usr/share/swig/2.0.10/ruby/rubyprimtypes.swg,19,%ruby_aux_method@*/ +/*@SWIG:/usr/share/swig/2.0.11/ruby/rubyprimtypes.swg,19,%ruby_aux_method@*/ SWIGINTERN VALUE SWIG_AUX_NUM2LONG(VALUE *args) { VALUE obj = args[0]; VALUE type = TYPE(obj); long *res = (long *)(args[1]); @@ -2162,11 +2163,35 @@ #include <float.h> -/*@SWIG:/usr/share/swig/2.0.10/ruby/rubyprimtypes.swg,19,%ruby_aux_method@*/ +#include <math.h> + + +/* Getting isfinite working pre C99 across multiple platforms is non-trivial. Users can provide SWIG_isfinite on older platforms. */ +#ifndef SWIG_isfinite +# if defined(isfinite) +# define SWIG_isfinite(X) (isfinite(X)) +# elif defined(_MSC_VER) +# define SWIG_isfinite(X) (_finite(X)) +# elif defined(__sun) && defined(__SVR4) +# include <ieeefp.h> +# define SWIG_isfinite(X) (finite(X)) +# endif +#endif + + +/* Accept infinite as a valid float value unless we are unable to check if a value is finite */ +#ifdef SWIG_isfinite +# define SWIG_Float_Overflow_Check(X) ((X < -FLT_MAX || X > FLT_MAX) && SWIG_isfinite(X)) +#else +# define SWIG_Float_Overflow_Check(X) ((X < -FLT_MAX || X > FLT_MAX)) +#endif + + +/*@SWIG:/usr/share/swig/2.0.11/ruby/rubyprimtypes.swg,19,%ruby_aux_method@*/ SWIGINTERN VALUE SWIG_AUX_NUM2DBL(VALUE *args) { VALUE obj = args[0]; VALUE type = TYPE(obj); double *res = (double *)(args[1]); @@ -2197,21 +2222,21 @@ SWIG_AsVal_float (VALUE obj, float *val) { double v; int res = SWIG_AsVal_double (obj, &v); if (SWIG_IsOK(res)) { - if ((v < -FLT_MAX || v > FLT_MAX)) { + if (SWIG_Float_Overflow_Check(v)) { return SWIG_OverflowError; } else { if (val) *val = (float)(v); } } return res; } -/*@SWIG:/usr/share/swig/2.0.10/ruby/rubyprimtypes.swg,19,%ruby_aux_method@*/ +/*@SWIG:/usr/share/swig/2.0.11/ruby/rubyprimtypes.swg,19,%ruby_aux_method@*/ SWIGINTERN VALUE SWIG_AUX_NUM2LL(VALUE *args) { VALUE obj = args[0]; VALUE type = TYPE(obj); long long *res = (long long *)(args[1]); @@ -2270,11 +2295,11 @@ } return SWIG_TypeError; } -/*@SWIG:/usr/share/swig/2.0.10/ruby/rubyprimtypes.swg,19,%ruby_aux_method@*/ +/*@SWIG:/usr/share/swig/2.0.11/ruby/rubyprimtypes.swg,19,%ruby_aux_method@*/ SWIGINTERN VALUE SWIG_AUX_NUM2ULL(VALUE *args) { VALUE obj = args[0]; VALUE type = TYPE(obj); long long *res = (long long *)(args[1]); @@ -2340,11 +2365,10 @@ pn_decimal32_t as_decimal32; pn_decimal64_t as_decimal64; pn_decimal128_t as_decimal128; pn_uuid_t as_uuid; pn_bytes_t as_bytes; - size_t as_count; } pn_atom_t_u; SWIGINTERN int @@ -3658,10 +3682,62 @@ static swig_class SwigClassPn_class_t; SWIGINTERN VALUE +_wrap_pn_class_t_initialize_set(int argc, VALUE *argv, VALUE self) { + pn_class_t *arg1 = (pn_class_t *) 0 ; + void (*arg2)(void *) = (void (*)(void *)) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + + if ((argc < 1) || (argc > 1)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_pn_class_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_class_t *","initialize", 1, self )); + } + arg1 = (pn_class_t *)(argp1); + { + int res = SWIG_ConvertFunctionPtr(argv[0], (void**)(&arg2), SWIGTYPE_p_f_p_void__void); + if (!SWIG_IsOK(res)) { + SWIG_exception_fail(SWIG_ArgError(res), Ruby_Format_TypeError( "", "void (*)(void *)","initialize", 2, argv[0] )); + } + } + if (arg1) (arg1)->initialize = arg2; + return Qnil; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_class_t_initialize_get(int argc, VALUE *argv, VALUE self) { + pn_class_t *arg1 = (pn_class_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + void (*result)(void *) = 0 ; + VALUE vresult = Qnil; + + if ((argc < 0) || (argc > 0)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 0)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_pn_class_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_class_t *","initialize", 1, self )); + } + arg1 = (pn_class_t *)(argp1); + result = (void (*)(void *)) ((arg1)->initialize); + vresult = SWIG_NewFunctionPtrObj((void *)(result), SWIGTYPE_p_f_p_void__void); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE _wrap_pn_class_t_finalize_set(int argc, VALUE *argv, VALUE self) { pn_class_t *arg1 = (pn_class_t *) 0 ; void (*arg2)(void *) = (void (*)(void *)) 0 ; void *argp1 = 0 ; int res1 = 0 ; @@ -3953,10 +4029,37 @@ return Qnil; } SWIGINTERN VALUE +_wrap_pn_initialize(int argc, VALUE *argv, VALUE self) { + void *arg1 = (void *) 0 ; + pn_class_t *arg2 = (pn_class_t *) 0 ; + int res1 ; + void *argp2 = 0 ; + int res2 = 0 ; + + if ((argc < 2) || (argc > 2)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 2)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0],SWIG_as_voidptrptr(&arg1), 0, 0); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "void *","pn_initialize", 1, argv[0] )); + } + res2 = SWIG_ConvertPtr(argv[1], &argp2,SWIGTYPE_p_pn_class_t, 0 | 0 ); + if (!SWIG_IsOK(res2)) { + SWIG_exception_fail(SWIG_ArgError(res2), Ruby_Format_TypeError( "", "pn_class_t *","pn_initialize", 2, argv[1] )); + } + arg2 = (pn_class_t *)(argp2); + pn_initialize(arg1,arg2); + return Qnil; +fail: + return Qnil; +} + + +SWIGINTERN VALUE _wrap_pn_incref(int argc, VALUE *argv, VALUE self) { void *arg1 = (void *) 0 ; int res1 ; void *result = 0 ; VALUE vresult = Qnil; @@ -4016,10 +4119,29 @@ return Qnil; } SWIGINTERN VALUE +_wrap_pn_finalize(int argc, VALUE *argv, VALUE self) { + void *arg1 = (void *) 0 ; + int res1 ; + + if ((argc < 1) || (argc > 1)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0],SWIG_as_voidptrptr(&arg1), 0, 0); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "void *","pn_finalize", 1, argv[0] )); + } + pn_finalize(arg1); + return Qnil; +fail: + return Qnil; +} + + +SWIGINTERN VALUE _wrap_pn_free(int argc, VALUE *argv, VALUE self) { void *arg1 = (void *) 0 ; int res1 ; if ((argc < 1) || (argc > 1)) { @@ -5600,12 +5722,10 @@ if ((argc < 0) || (argc > 0)) { rb_raise(rb_eArgError, "wrong # of arguments(%d for 0)",argc); SWIG_fail; } result = (pn_error_t *)pn_error(); - SWIG_contract_assert((result!=NULL), "Contract violation: ensure: (result!=NULL)"); - vresult = SWIG_NewPointerObj(SWIG_as_voidptr(result), SWIGTYPE_p_pn_error_t, 0 | 0 ); return vresult; fail: return Qnil; } @@ -7220,10 +7340,178 @@ return Qnil; } SWIGINTERN VALUE +_wrap_pn_transport_set_tracer(int argc, VALUE *argv, VALUE self) { + pn_transport_t *arg1 = (pn_transport_t *) 0 ; + pn_tracer_t *arg2 = (pn_tracer_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + + if ((argc < 2) || (argc > 2)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 2)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_transport_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_transport_t *","pn_transport_set_tracer", 1, argv[0] )); + } + arg1 = (pn_transport_t *)(argp1); + { + int res = SWIG_ConvertFunctionPtr(argv[1], (void**)(&arg2), SWIGTYPE_p_f_p_struct_pn_transport_t_p_q_const__char__void); + if (!SWIG_IsOK(res)) { + SWIG_exception_fail(SWIG_ArgError(res), Ruby_Format_TypeError( "", "pn_tracer_t *","pn_transport_set_tracer", 2, argv[1] )); + } + } + pn_transport_set_tracer(arg1,arg2); + return Qnil; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_transport_get_tracer(int argc, VALUE *argv, VALUE self) { + pn_transport_t *arg1 = (pn_transport_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + pn_tracer_t *result = 0 ; + VALUE vresult = Qnil; + + if ((argc < 1) || (argc > 1)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_transport_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_transport_t *","pn_transport_get_tracer", 1, argv[0] )); + } + arg1 = (pn_transport_t *)(argp1); + result = (pn_tracer_t *)pn_transport_get_tracer(arg1); + vresult = SWIG_NewFunctionPtrObj((void *)(result), SWIGTYPE_p_f_p_struct_pn_transport_t_p_q_const__char__void); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_transport_set_context(int argc, VALUE *argv, VALUE self) { + pn_transport_t *arg1 = (pn_transport_t *) 0 ; + void *arg2 = (void *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + int res2 ; + + if ((argc < 2) || (argc > 2)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 2)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_transport_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_transport_t *","pn_transport_set_context", 1, argv[0] )); + } + arg1 = (pn_transport_t *)(argp1); + res2 = SWIG_ConvertPtr(argv[1],SWIG_as_voidptrptr(&arg2), 0, 0); + if (!SWIG_IsOK(res2)) { + SWIG_exception_fail(SWIG_ArgError(res2), Ruby_Format_TypeError( "", "void *","pn_transport_set_context", 2, argv[1] )); + } + pn_transport_set_context(arg1,arg2); + return Qnil; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_transport_get_context(int argc, VALUE *argv, VALUE self) { + pn_transport_t *arg1 = (pn_transport_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + void *result = 0 ; + VALUE vresult = Qnil; + + if ((argc < 1) || (argc > 1)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_transport_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_transport_t *","pn_transport_get_context", 1, argv[0] )); + } + arg1 = (pn_transport_t *)(argp1); + result = (void *)pn_transport_get_context(arg1); + vresult = SWIG_NewPointerObj(SWIG_as_voidptr(result), SWIGTYPE_p_void, 0 | 0 ); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_transport_log(int argc, VALUE *argv, VALUE self) { + pn_transport_t *arg1 = (pn_transport_t *) 0 ; + char *arg2 = (char *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + int res2 ; + char *buf2 = 0 ; + int alloc2 = 0 ; + + if ((argc < 2) || (argc > 2)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 2)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_transport_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_transport_t *","pn_transport_log", 1, argv[0] )); + } + arg1 = (pn_transport_t *)(argp1); + res2 = SWIG_AsCharPtrAndSize(argv[1], &buf2, NULL, &alloc2); + if (!SWIG_IsOK(res2)) { + SWIG_exception_fail(SWIG_ArgError(res2), Ruby_Format_TypeError( "", "char const *","pn_transport_log", 2, argv[1] )); + } + arg2 = (char *)(buf2); + pn_transport_log(arg1,(char const *)arg2); + if (alloc2 == SWIG_NEWOBJ) free((char*)buf2); + return Qnil; +fail: + if (alloc2 == SWIG_NEWOBJ) free((char*)buf2); + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_transport_logf(int argc, VALUE *argv, VALUE self) { + pn_transport_t *arg1 = (pn_transport_t *) 0 ; + char *arg2 = (char *) 0 ; + void *arg3 = 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + int res2 ; + char *buf2 = 0 ; + int alloc2 = 0 ; + + if (argc < 2) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 2)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_transport_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_transport_t *","pn_transport_logf", 1, argv[0] )); + } + arg1 = (pn_transport_t *)(argp1); + res2 = SWIG_AsCharPtrAndSize(argv[1], &buf2, NULL, &alloc2); + if (!SWIG_IsOK(res2)) { + SWIG_exception_fail(SWIG_ArgError(res2), Ruby_Format_TypeError( "", "char const *","pn_transport_logf", 2, argv[1] )); + } + arg2 = (char *)(buf2); + pn_transport_logf(arg1,(char const *)arg2,arg3); + if (alloc2 == SWIG_NEWOBJ) free((char*)buf2); + return Qnil; +fail: + if (alloc2 == SWIG_NEWOBJ) free((char*)buf2); + return Qnil; +} + + +SWIGINTERN VALUE _wrap_pn_transport_get_max_frame(int argc, VALUE *argv, VALUE self) { pn_transport_t *arg1 = (pn_transport_t *) 0 ; void *argp1 = 0 ; int res1 = 0 ; uint32_t result; @@ -8109,10 +8397,34 @@ return Qnil; } SWIGINTERN VALUE +_wrap_pn_link_remote_credit(int argc, VALUE *argv, VALUE self) { + pn_link_t *arg1 = (pn_link_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + int result; + VALUE vresult = Qnil; + + if ((argc < 1) || (argc > 1)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_link_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_link_t *","pn_link_remote_credit", 1, argv[0] )); + } + arg1 = (pn_link_t *)(argp1); + result = (int)pn_link_remote_credit(arg1); + vresult = SWIG_From_int((int)(result)); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE _wrap_pn_link_available(int argc, VALUE *argv, VALUE self) { pn_link_t *arg1 = (pn_link_t *) 0 ; void *argp1 = 0 ; int res1 = 0 ; int result; @@ -8485,10 +8797,34 @@ return Qnil; } SWIGINTERN VALUE +_wrap_pn_link_get_drain(int argc, VALUE *argv, VALUE self) { + pn_link_t *arg1 = (pn_link_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + bool result; + VALUE vresult = Qnil; + + if ((argc < 1) || (argc > 1)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_link_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_link_t *","pn_link_get_drain", 1, argv[0] )); + } + arg1 = (pn_link_t *)(argp1); + result = (bool)pn_link_get_drain(arg1); + vresult = SWIG_From_bool((bool)(result)); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE _wrap_pn_link_offered(int argc, VALUE *argv, VALUE self) { pn_link_t *arg1 = (pn_link_t *) 0 ; int arg2 ; void *argp1 = 0 ; int res1 = 0 ; @@ -8518,10 +8854,12 @@ SWIGINTERN VALUE _wrap_pn_link_drained(int argc, VALUE *argv, VALUE self) { pn_link_t *arg1 = (pn_link_t *) 0 ; void *argp1 = 0 ; int res1 = 0 ; + int result; + VALUE vresult = Qnil; if ((argc < 1) || (argc > 1)) { rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; } res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_link_t, 0 | 0 ); @@ -8529,12 +8867,13 @@ SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_link_t *","pn_link_drained", 1, argv[0] )); } arg1 = (pn_link_t *)(argp1); SWIG_contract_assert((arg1!=NULL), "Contract violation: require: (arg1!=NULL)"); - pn_link_drained(arg1); - return Qnil; + result = (int)pn_link_drained(arg1); + vresult = SWIG_From_int((int)(result)); + return vresult; fail: return Qnil; } @@ -8599,10 +8938,63 @@ return Qnil; } SWIGINTERN VALUE +_wrap_pn_link_set_drain(int argc, VALUE *argv, VALUE self) { + pn_link_t *arg1 = (pn_link_t *) 0 ; + bool arg2 ; + void *argp1 = 0 ; + int res1 = 0 ; + bool val2 ; + int ecode2 = 0 ; + + if ((argc < 2) || (argc > 2)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 2)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_link_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_link_t *","pn_link_set_drain", 1, argv[0] )); + } + arg1 = (pn_link_t *)(argp1); + ecode2 = SWIG_AsVal_bool(argv[1], &val2); + if (!SWIG_IsOK(ecode2)) { + SWIG_exception_fail(SWIG_ArgError(ecode2), Ruby_Format_TypeError( "", "bool","pn_link_set_drain", 2, argv[1] )); + } + arg2 = (bool)(val2); + pn_link_set_drain(arg1,arg2); + return Qnil; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_link_draining(int argc, VALUE *argv, VALUE self) { + pn_link_t *arg1 = (pn_link_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + bool result; + VALUE vresult = Qnil; + + if ((argc < 1) || (argc > 1)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_link_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_link_t *","pn_link_draining", 1, argv[0] )); + } + arg1 = (pn_link_t *)(argp1); + result = (bool)pn_link_draining(arg1); + vresult = SWIG_From_bool((bool)(result)); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE _wrap_pn_terminus_get_type(int argc, VALUE *argv, VALUE self) { pn_terminus_t *arg1 = (pn_terminus_t *) 0 ; void *argp1 = 0 ; int res1 = 0 ; pn_terminus_type_t result; @@ -9551,10 +9943,34 @@ return Qnil; } SWIGINTERN VALUE +_wrap_pn_delivery_buffered(int argc, VALUE *argv, VALUE self) { + pn_delivery_t *arg1 = (pn_delivery_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + bool result; + VALUE vresult = Qnil; + + if ((argc < 1) || (argc > 1)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_delivery_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_delivery_t *","pn_delivery_buffered", 1, argv[0] )); + } + arg1 = (pn_delivery_t *)(argp1); + result = (bool)pn_delivery_buffered(arg1); + vresult = SWIG_From_bool((bool)(result)); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE _wrap_pn_disposition_type(int argc, VALUE *argv, VALUE self) { pn_disposition_t *arg1 = (pn_disposition_t *) 0 ; void *argp1 = 0 ; int res1 = 0 ; uint64_t result; @@ -14196,10 +14612,34 @@ return Qnil; } SWIGINTERN VALUE +_wrap_pn_subscription_address(int argc, VALUE *argv, VALUE self) { + pn_subscription_t *arg1 = (pn_subscription_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + char *result = 0 ; + VALUE vresult = Qnil; + + if ((argc < 1) || (argc > 1)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_subscription_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_subscription_t *","pn_subscription_address", 1, argv[0] )); + } + arg1 = (pn_subscription_t *)(argp1); + result = (char *)pn_subscription_address(arg1); + vresult = SWIG_FromCharPtr((const char *)result); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE _wrap_pn_messenger_put(int argc, VALUE *argv, VALUE self) { pn_messenger_t *arg1 = (pn_messenger_t *) 0 ; pn_message_t *arg2 = (pn_message_t *) 0 ; void *argp1 = 0 ; int res1 = 0 ; @@ -14262,10 +14702,42 @@ return Qnil; } SWIGINTERN VALUE +_wrap_pn_messenger_buffered(int argc, VALUE *argv, VALUE self) { + pn_messenger_t *arg1 = (pn_messenger_t *) 0 ; + pn_tracker_t arg2 ; + void *argp1 = 0 ; + int res1 = 0 ; + long long val2 ; + int ecode2 = 0 ; + bool result; + VALUE vresult = Qnil; + + if ((argc < 2) || (argc > 2)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 2)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_messenger_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_messenger_t *","pn_messenger_buffered", 1, argv[0] )); + } + arg1 = (pn_messenger_t *)(argp1); + ecode2 = SWIG_AsVal_long_SS_long(argv[1], &val2); + if (!SWIG_IsOK(ecode2)) { + SWIG_exception_fail(SWIG_ArgError(ecode2), Ruby_Format_TypeError( "", "pn_tracker_t","pn_messenger_buffered", 2, argv[1] )); + } + arg2 = (pn_tracker_t)(val2); + result = (bool)pn_messenger_buffered(arg1,arg2); + vresult = SWIG_From_bool((bool)(result)); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE _wrap_pn_messenger_settle(int argc, VALUE *argv, VALUE self) { pn_messenger_t *arg1 = (pn_messenger_t *) 0 ; pn_tracker_t arg2 ; int arg3 ; void *argp1 = 0 ; @@ -16246,63 +16718,10 @@ fail: return Qnil; } -SWIGINTERN VALUE -_wrap_pn_atom_t_u_as_count_set(int argc, VALUE *argv, VALUE self) { - pn_atom_t_u *arg1 = (pn_atom_t_u *) 0 ; - size_t arg2 ; - void *argp1 = 0 ; - int res1 = 0 ; - size_t val2 ; - int ecode2 = 0 ; - - if ((argc < 1) || (argc > 1)) { - rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; - } - res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_pn_atom_t_u, 0 | 0 ); - if (!SWIG_IsOK(res1)) { - SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_atom_t_u *","as_count", 1, self )); - } - arg1 = (pn_atom_t_u *)(argp1); - ecode2 = SWIG_AsVal_size_t(argv[0], &val2); - if (!SWIG_IsOK(ecode2)) { - SWIG_exception_fail(SWIG_ArgError(ecode2), Ruby_Format_TypeError( "", "size_t","as_count", 2, argv[0] )); - } - arg2 = (size_t)(val2); - if (arg1) (arg1)->as_count = arg2; - return Qnil; -fail: - return Qnil; -} - - -SWIGINTERN VALUE -_wrap_pn_atom_t_u_as_count_get(int argc, VALUE *argv, VALUE self) { - pn_atom_t_u *arg1 = (pn_atom_t_u *) 0 ; - void *argp1 = 0 ; - int res1 = 0 ; - size_t result; - VALUE vresult = Qnil; - - if ((argc < 0) || (argc > 0)) { - rb_raise(rb_eArgError, "wrong # of arguments(%d for 0)",argc); SWIG_fail; - } - res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_pn_atom_t_u, 0 | 0 ); - if (!SWIG_IsOK(res1)) { - SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_atom_t_u *","as_count", 1, self )); - } - arg1 = (pn_atom_t_u *)(argp1); - result = (size_t) ((arg1)->as_count); - vresult = SWIG_From_size_t((size_t)(result)); - return vresult; -fail: - return Qnil; -} - - #ifdef HAVE_RB_DEFINE_ALLOC_FUNC SWIGINTERN VALUE _wrap_pn_atom_t_u_allocate(VALUE self) { #else SWIGINTERN VALUE @@ -16410,23 +16829,23 @@ SWIGINTERN VALUE _wrap_pn_data_error(int argc, VALUE *argv, VALUE self) { pn_data_t *arg1 = (pn_data_t *) 0 ; void *argp1 = 0 ; int res1 = 0 ; - char *result = 0 ; + pn_error_t *result = 0 ; VALUE vresult = Qnil; if ((argc < 1) || (argc > 1)) { rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; } res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_data_t, 0 | 0 ); if (!SWIG_IsOK(res1)) { SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_data_t *","pn_data_error", 1, argv[0] )); } arg1 = (pn_data_t *)(argp1); - result = (char *)pn_data_error(arg1); - vresult = SWIG_FromCharPtr((const char *)result); + result = (pn_error_t *)pn_data_error(arg1); + vresult = SWIG_NewPointerObj(SWIG_as_voidptr(result), SWIGTYPE_p_pn_error_t, 0 | 0 ); return vresult; fail: return Qnil; } @@ -18749,10 +19168,11 @@ /* -------- TYPE CONVERSION AND EQUIVALENCE RULES (BEGIN) -------- */ static swig_type_info _swigt__p_char = {"_p_char", "char *", 0, 0, (void*)0, 0}; +static swig_type_info _swigt__p_f_p_struct_pn_transport_t_p_q_const__char__void = {"_p_f_p_struct_pn_transport_t_p_q_const__char__void", "void (*)(struct pn_transport_t *,char const *)|pn_tracer_t *", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_f_p_void__uintptr_t = {"_p_f_p_void__uintptr_t", "uintptr_t (*)(void *)", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_f_p_void__void = {"_p_f_p_void__void", "void (*)(void *)", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_f_p_void_p_struct_pn_string_t__int = {"_p_f_p_void_p_struct_pn_string_t__int", "int (*)(void *,struct pn_string_t *)|int (*)(void *,pn_string_t *)", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_f_p_void_p_void__intptr_t = {"_p_f_p_void_p_void__intptr_t", "intptr_t (*)(void *,void *)", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_int = {"_p_int", "int *|ssize_t *|pn_state_t *|pn_trace_t *|pn_socket_t *", 0, 0, (void*)0, 0}; @@ -18815,10 +19235,11 @@ static swig_type_info _swigt__p_unsigned_short = {"_p_unsigned_short", "unsigned short *|uint16_t *", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_void = {"_p_void", "void *", 0, 0, (void*)0, 0}; static swig_type_info *swig_type_initial[] = { &_swigt__p_char, + &_swigt__p_f_p_struct_pn_transport_t_p_q_const__char__void, &_swigt__p_f_p_void__uintptr_t, &_swigt__p_f_p_void__void, &_swigt__p_f_p_void_p_struct_pn_string_t__int, &_swigt__p_f_p_void_p_void__intptr_t, &_swigt__p_int, @@ -18881,10 +19302,11 @@ &_swigt__p_unsigned_short, &_swigt__p_void, }; static swig_cast_info _swigc__p_char[] = { {&_swigt__p_char, 0, 0, 0},{0, 0, 0, 0}}; +static swig_cast_info _swigc__p_f_p_struct_pn_transport_t_p_q_const__char__void[] = { {&_swigt__p_f_p_struct_pn_transport_t_p_q_const__char__void, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_f_p_void__uintptr_t[] = { {&_swigt__p_f_p_void__uintptr_t, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_f_p_void__void[] = { {&_swigt__p_f_p_void__void, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_f_p_void_p_struct_pn_string_t__int[] = { {&_swigt__p_f_p_void_p_struct_pn_string_t__int, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_f_p_void_p_void__intptr_t[] = { {&_swigt__p_f_p_void_p_void__intptr_t, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_int[] = { {&_swigt__p_int, 0, 0, 0},{0, 0, 0, 0}}; @@ -18947,10 +19369,11 @@ static swig_cast_info _swigc__p_unsigned_short[] = { {&_swigt__p_unsigned_short, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_void[] = { {&_swigt__p_void, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info *swig_cast_initial[] = { _swigc__p_char, + _swigc__p_f_p_struct_pn_transport_t_p_q_const__char__void, _swigc__p_f_p_void__uintptr_t, _swigc__p_f_p_void__void, _swigc__p_f_p_void_p_struct_pn_string_t__int, _swigc__p_f_p_void_p_void__intptr_t, _swigc__p_int, @@ -19017,42 +19440,42 @@ /* -------- TYPE CONVERSION AND EQUIVALENCE RULES (END) -------- */ /* ----------------------------------------------------------------------------- * Type initialization: - * This problem is tough by the requirement that no dynamic - * memory is used. Also, since swig_type_info structures store pointers to + * This problem is tough by the requirement that no dynamic + * memory is used. Also, since swig_type_info structures store pointers to * swig_cast_info structures and swig_cast_info structures store pointers back - * to swig_type_info structures, we need some lookup code at initialization. - * The idea is that swig generates all the structures that are needed. - * The runtime then collects these partially filled structures. - * The SWIG_InitializeModule function takes these initial arrays out of + * to swig_type_info structures, we need some lookup code at initialization. + * The idea is that swig generates all the structures that are needed. + * The runtime then collects these partially filled structures. + * The SWIG_InitializeModule function takes these initial arrays out of * swig_module, and does all the lookup, filling in the swig_module.types * array with the correct data and linking the correct swig_cast_info * structures together. * - * The generated swig_type_info structures are assigned staticly to an initial + * The generated swig_type_info structures are assigned staticly to an initial * array. We just loop through that array, and handle each type individually. * First we lookup if this type has been already loaded, and if so, use the * loaded structure instead of the generated one. Then we have to fill in the * cast linked list. The cast data is initially stored in something like a * two-dimensional array. Each row corresponds to a type (there are the same * number of rows as there are in the swig_type_initial array). Each entry in * a column is one of the swig_cast_info structures for that type. * The cast_initial array is actually an array of arrays, because each row has * a variable number of columns. So to actually build the cast linked list, - * we find the array of casts associated with the type, and loop through it + * we find the array of casts associated with the type, and loop through it * adding the casts to the list. The one last trick we need to do is making * sure the type pointer in the swig_cast_info struct is correct. * - * First off, we lookup the cast->type name to see if it is already loaded. + * First off, we lookup the cast->type name to see if it is already loaded. * There are three cases to handle: * 1) If the cast->type has already been loaded AND the type we are adding * casting info to has not been loaded (it is in this module), THEN we * replace the cast->type pointer with the type pointer that has already * been loaded. - * 2) If BOTH types (the one we are adding casting info to, and the + * 2) If BOTH types (the one we are adding casting info to, and the * cast->type) are loaded, THEN the cast info has already been loaded by * the previous module so we just ignore it. * 3) Finally, if cast->type has not already been loaded, then we add that * swig_cast_info to the linked list (because the cast->type) pointer will * be correct. @@ -19111,11 +19534,11 @@ /* otherwise we must add out module into the list */ swig_module.next = module_head->next; module_head->next = &swig_module; } - /* When multiple interpeters are used, a module could have already been initialized in + /* When multiple interpreters are used, a module could have already been initialized in a different interpreter, but not yet have a pointer in this interpreter. In this case, we do not want to continue adding types... everything should be set up already */ if (init == 0) return; @@ -19125,11 +19548,11 @@ #endif for (i = 0; i < swig_module.size; ++i) { swig_type_info *type = 0; swig_type_info *ret; swig_cast_info *cast; - + #ifdef SWIGRUNTIME_DEBUG printf("SWIG_InitializeModule: type %d %s\n", i, swig_module.type_initial[i]->name); #endif /* if there is another module already loaded */ @@ -19152,11 +19575,11 @@ } /* Insert casting types */ cast = swig_module.cast_initial[i]; while (cast->type) { - + /* Don't need to add information already in the list */ ret = 0; #ifdef SWIGRUNTIME_DEBUG printf("SWIG_InitializeModule: look cast %s\n", cast->type->name); #endif @@ -19330,10 +19753,12 @@ SwigClassPn_class_t.klass = rb_define_class_under(mCproton, "Pn_class_t", rb_cObject); SWIG_TypeClientData(SWIGTYPE_p_pn_class_t, (void *) &SwigClassPn_class_t); rb_define_alloc_func(SwigClassPn_class_t.klass, _wrap_pn_class_t_allocate); rb_define_method(SwigClassPn_class_t.klass, "initialize", _wrap_new_pn_class_t, -1); + rb_define_method(SwigClassPn_class_t.klass, "initialize=", _wrap_pn_class_t_initialize_set, -1); + rb_define_method(SwigClassPn_class_t.klass, "initialize", _wrap_pn_class_t_initialize_get, -1); rb_define_method(SwigClassPn_class_t.klass, "finalize=", _wrap_pn_class_t_finalize_set, -1); rb_define_method(SwigClassPn_class_t.klass, "finalize", _wrap_pn_class_t_finalize_get, -1); rb_define_method(SwigClassPn_class_t.klass, "hashcode=", _wrap_pn_class_t_hashcode_set, -1); rb_define_method(SwigClassPn_class_t.klass, "hashcode", _wrap_pn_class_t_hashcode_get, -1); rb_define_method(SwigClassPn_class_t.klass, "compare=", _wrap_pn_class_t_compare_set, -1); @@ -19342,13 +19767,15 @@ rb_define_method(SwigClassPn_class_t.klass, "inspect", _wrap_pn_class_t_inspect_get, -1); SwigClassPn_class_t.mark = 0; SwigClassPn_class_t.destroy = (void (*)(void *)) free_pn_class_t; SwigClassPn_class_t.trackObjects = 0; rb_define_module_function(mCproton, "pn_new", _wrap_pn_new, -1); + rb_define_module_function(mCproton, "pn_initialize", _wrap_pn_initialize, -1); rb_define_module_function(mCproton, "pn_incref", _wrap_pn_incref, -1); rb_define_module_function(mCproton, "pn_decref", _wrap_pn_decref, -1); rb_define_module_function(mCproton, "pn_refcount", _wrap_pn_refcount, -1); + rb_define_module_function(mCproton, "pn_finalize", _wrap_pn_finalize, -1); rb_define_module_function(mCproton, "pn_free", _wrap_pn_free, -1); rb_define_module_function(mCproton, "pn_class", _wrap_pn_class, -1); rb_define_module_function(mCproton, "pn_hashcode", _wrap_pn_hashcode, -1); rb_define_module_function(mCproton, "pn_compare", _wrap_pn_compare, -1); rb_define_module_function(mCproton, "pn_equals", _wrap_pn_equals, -1); @@ -19509,10 +19936,16 @@ rb_define_module_function(mCproton, "pn_transport_peek", _wrap_pn_transport_peek, -1); rb_define_module_function(mCproton, "pn_transport_pop", _wrap_pn_transport_pop, -1); rb_define_module_function(mCproton, "pn_transport_close_head", _wrap_pn_transport_close_head, -1); rb_define_module_function(mCproton, "pn_transport_tick", _wrap_pn_transport_tick, -1); rb_define_module_function(mCproton, "pn_transport_trace", _wrap_pn_transport_trace, -1); + rb_define_module_function(mCproton, "pn_transport_set_tracer", _wrap_pn_transport_set_tracer, -1); + rb_define_module_function(mCproton, "pn_transport_get_tracer", _wrap_pn_transport_get_tracer, -1); + rb_define_module_function(mCproton, "pn_transport_set_context", _wrap_pn_transport_set_context, -1); + rb_define_module_function(mCproton, "pn_transport_get_context", _wrap_pn_transport_get_context, -1); + rb_define_module_function(mCproton, "pn_transport_log", _wrap_pn_transport_log, -1); + rb_define_module_function(mCproton, "pn_transport_logf", _wrap_pn_transport_logf, -1); rb_define_module_function(mCproton, "pn_transport_get_max_frame", _wrap_pn_transport_get_max_frame, -1); rb_define_module_function(mCproton, "pn_transport_set_max_frame", _wrap_pn_transport_set_max_frame, -1); rb_define_module_function(mCproton, "pn_transport_get_remote_max_frame", _wrap_pn_transport_get_remote_max_frame, -1); rb_define_module_function(mCproton, "pn_transport_get_idle_timeout", _wrap_pn_transport_get_idle_timeout, -1); rb_define_module_function(mCproton, "pn_transport_set_idle_timeout", _wrap_pn_transport_set_idle_timeout, -1); @@ -19543,10 +19976,11 @@ rb_define_module_function(mCproton, "pn_link_remote_target", _wrap_pn_link_remote_target, -1); rb_define_module_function(mCproton, "pn_link_current", _wrap_pn_link_current, -1); rb_define_module_function(mCproton, "pn_link_advance", _wrap_pn_link_advance, -1); rb_define_module_function(mCproton, "pn_link_credit", _wrap_pn_link_credit, -1); rb_define_module_function(mCproton, "pn_link_queued", _wrap_pn_link_queued, -1); + rb_define_module_function(mCproton, "pn_link_remote_credit", _wrap_pn_link_remote_credit, -1); rb_define_module_function(mCproton, "pn_link_available", _wrap_pn_link_available, -1); rb_define_module_function(mCproton, "pn_link_snd_settle_mode", _wrap_pn_link_snd_settle_mode, -1); rb_define_module_function(mCproton, "pn_link_rcv_settle_mode", _wrap_pn_link_rcv_settle_mode, -1); rb_define_module_function(mCproton, "pn_link_remote_snd_settle_mode", _wrap_pn_link_remote_snd_settle_mode, -1); rb_define_module_function(mCproton, "pn_link_remote_rcv_settle_mode", _wrap_pn_link_remote_rcv_settle_mode, -1); @@ -19558,14 +19992,17 @@ rb_define_module_function(mCproton, "pn_link_open", _wrap_pn_link_open, -1); rb_define_module_function(mCproton, "pn_link_close", _wrap_pn_link_close, -1); rb_define_module_function(mCproton, "pn_link_free", _wrap_pn_link_free, -1); rb_define_module_function(mCproton, "pn_link_get_context", _wrap_pn_link_get_context, -1); rb_define_module_function(mCproton, "pn_link_set_context", _wrap_pn_link_set_context, -1); + rb_define_module_function(mCproton, "pn_link_get_drain", _wrap_pn_link_get_drain, -1); rb_define_module_function(mCproton, "pn_link_offered", _wrap_pn_link_offered, -1); rb_define_module_function(mCproton, "pn_link_drained", _wrap_pn_link_drained, -1); rb_define_module_function(mCproton, "pn_link_flow", _wrap_pn_link_flow, -1); rb_define_module_function(mCproton, "pn_link_drain", _wrap_pn_link_drain, -1); + rb_define_module_function(mCproton, "pn_link_set_drain", _wrap_pn_link_set_drain, -1); + rb_define_module_function(mCproton, "pn_link_draining", _wrap_pn_link_draining, -1); rb_define_module_function(mCproton, "pn_terminus_get_type", _wrap_pn_terminus_get_type, -1); rb_define_module_function(mCproton, "pn_terminus_set_type", _wrap_pn_terminus_set_type, -1); rb_define_module_function(mCproton, "pn_terminus_get_address", _wrap_pn_terminus_get_address, -1); rb_define_module_function(mCproton, "pn_terminus_set_address", _wrap_pn_terminus_set_address, -1); rb_define_module_function(mCproton, "pn_terminus_get_durability", _wrap_pn_terminus_get_durability, -1); @@ -19598,10 +20035,11 @@ rb_define_module_function(mCproton, "pn_delivery_clear", _wrap_pn_delivery_clear, -1); rb_define_module_function(mCproton, "pn_delivery_settle", _wrap_pn_delivery_settle, -1); rb_define_module_function(mCproton, "pn_delivery_dump", _wrap_pn_delivery_dump, -1); rb_define_module_function(mCproton, "pn_delivery_get_context", _wrap_pn_delivery_get_context, -1); rb_define_module_function(mCproton, "pn_delivery_set_context", _wrap_pn_delivery_set_context, -1); + rb_define_module_function(mCproton, "pn_delivery_buffered", _wrap_pn_delivery_buffered, -1); rb_define_module_function(mCproton, "pn_disposition_type", _wrap_pn_disposition_type, -1); rb_define_module_function(mCproton, "pn_disposition_data", _wrap_pn_disposition_data, -1); rb_define_module_function(mCproton, "pn_disposition_get_section_number", _wrap_pn_disposition_get_section_number, -1); rb_define_module_function(mCproton, "pn_disposition_set_section_number", _wrap_pn_disposition_set_section_number, -1); rb_define_module_function(mCproton, "pn_disposition_get_section_offset", _wrap_pn_disposition_get_section_offset, -1); @@ -19755,11 +20193,14 @@ rb_define_const(mCproton, "PROTON_MESSENGER_H", SWIG_From_int((int)(1))); rb_define_const(mCproton, "PN_STATUS_UNKNOWN", SWIG_From_int((int)(PN_STATUS_UNKNOWN))); rb_define_const(mCproton, "PN_STATUS_PENDING", SWIG_From_int((int)(PN_STATUS_PENDING))); rb_define_const(mCproton, "PN_STATUS_ACCEPTED", SWIG_From_int((int)(PN_STATUS_ACCEPTED))); rb_define_const(mCproton, "PN_STATUS_REJECTED", SWIG_From_int((int)(PN_STATUS_REJECTED))); + rb_define_const(mCproton, "PN_STATUS_RELEASED", SWIG_From_int((int)(PN_STATUS_RELEASED))); rb_define_const(mCproton, "PN_STATUS_MODIFIED", SWIG_From_int((int)(PN_STATUS_MODIFIED))); + rb_define_const(mCproton, "PN_STATUS_ABORTED", SWIG_From_int((int)(PN_STATUS_ABORTED))); + rb_define_const(mCproton, "PN_STATUS_SETTLED", SWIG_From_int((int)(PN_STATUS_SETTLED))); rb_define_module_function(mCproton, "pn_messenger", _wrap_pn_messenger, -1); rb_define_module_function(mCproton, "pn_messenger_name", _wrap_pn_messenger_name, -1); rb_define_module_function(mCproton, "pn_messenger_set_certificate", _wrap_pn_messenger_set_certificate, -1); rb_define_module_function(mCproton, "pn_messenger_get_certificate", _wrap_pn_messenger_get_certificate, -1); rb_define_module_function(mCproton, "pn_messenger_set_private_key", _wrap_pn_messenger_set_private_key, -1); @@ -19783,12 +20224,14 @@ rb_define_module_function(mCproton, "pn_messenger_stop", _wrap_pn_messenger_stop, -1); rb_define_module_function(mCproton, "pn_messenger_stopped", _wrap_pn_messenger_stopped, -1); rb_define_module_function(mCproton, "pn_messenger_subscribe", _wrap_pn_messenger_subscribe, -1); rb_define_module_function(mCproton, "pn_subscription_get_context", _wrap_pn_subscription_get_context, -1); rb_define_module_function(mCproton, "pn_subscription_set_context", _wrap_pn_subscription_set_context, -1); + rb_define_module_function(mCproton, "pn_subscription_address", _wrap_pn_subscription_address, -1); rb_define_module_function(mCproton, "pn_messenger_put", _wrap_pn_messenger_put, -1); rb_define_module_function(mCproton, "pn_messenger_status", _wrap_pn_messenger_status, -1); + rb_define_module_function(mCproton, "pn_messenger_buffered", _wrap_pn_messenger_buffered, -1); rb_define_module_function(mCproton, "pn_messenger_settle", _wrap_pn_messenger_settle, -1); rb_define_module_function(mCproton, "pn_messenger_outgoing_tracker", _wrap_pn_messenger_outgoing_tracker, -1); rb_define_module_function(mCproton, "pn_messenger_work", _wrap_pn_messenger_work, -1); rb_define_module_function(mCproton, "pn_messenger_interrupt", _wrap_pn_messenger_interrupt, -1); rb_define_module_function(mCproton, "pn_messenger_send", _wrap_pn_messenger_send, -1); @@ -19902,11 +20345,9 @@ rb_define_method(SwigClassPn_atom_t_u.klass, "as_decimal128", _wrap_pn_atom_t_u_as_decimal128_get, -1); rb_define_method(SwigClassPn_atom_t_u.klass, "as_uuid=", _wrap_pn_atom_t_u_as_uuid_set, -1); rb_define_method(SwigClassPn_atom_t_u.klass, "as_uuid", _wrap_pn_atom_t_u_as_uuid_get, -1); rb_define_method(SwigClassPn_atom_t_u.klass, "as_bytes=", _wrap_pn_atom_t_u_as_bytes_set, -1); rb_define_method(SwigClassPn_atom_t_u.klass, "as_bytes", _wrap_pn_atom_t_u_as_bytes_get, -1); - rb_define_method(SwigClassPn_atom_t_u.klass, "as_count=", _wrap_pn_atom_t_u_as_count_set, -1); - rb_define_method(SwigClassPn_atom_t_u.klass, "as_count", _wrap_pn_atom_t_u_as_count_get, -1); SwigClassPn_atom_t_u.mark = 0; SwigClassPn_atom_t_u.destroy = (void (*)(void *)) free_pn_atom_t_u; SwigClassPn_atom_t_u.trackObjects = 0; rb_define_module_function(mCproton, "pn_data", _wrap_pn_data, -1); rb_define_module_function(mCproton, "pn_data_free", _wrap_pn_data_free, -1);