ext/cproton/cproton.c in qpid_proton-0.18.1 vs ext/cproton/cproton.c in qpid_proton-0.19.0

- old
+ new

@@ -1818,69 +1818,70 @@ #define SWIGTYPE_p_pn_bytes_t swig_types[15] #define SWIGTYPE_p_pn_cid_t swig_types[16] #define SWIGTYPE_p_pn_class_t swig_types[17] #define SWIGTYPE_p_pn_collector_t swig_types[18] #define SWIGTYPE_p_pn_condition_t swig_types[19] -#define SWIGTYPE_p_pn_connection_t swig_types[20] -#define SWIGTYPE_p_pn_data_t swig_types[21] -#define SWIGTYPE_p_pn_decimal128_t swig_types[22] -#define SWIGTYPE_p_pn_delivery_t swig_types[23] -#define SWIGTYPE_p_pn_disposition_t swig_types[24] -#define SWIGTYPE_p_pn_distribution_mode_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_event_batch_t swig_types[28] -#define SWIGTYPE_p_pn_event_t swig_types[29] -#define SWIGTYPE_p_pn_event_type_t swig_types[30] -#define SWIGTYPE_p_pn_expiry_policy_t swig_types[31] -#define SWIGTYPE_p_pn_handler_t swig_types[32] -#define SWIGTYPE_p_pn_hash_t swig_types[33] -#define SWIGTYPE_p_pn_iterator_t swig_types[34] -#define SWIGTYPE_p_pn_link_t swig_types[35] -#define SWIGTYPE_p_pn_list_t swig_types[36] -#define SWIGTYPE_p_pn_listener_t swig_types[37] -#define SWIGTYPE_p_pn_map_t swig_types[38] -#define SWIGTYPE_p_pn_message_t swig_types[39] -#define SWIGTYPE_p_pn_messenger_t swig_types[40] -#define SWIGTYPE_p_pn_proactor_t swig_types[41] -#define SWIGTYPE_p_pn_rcv_settle_mode_t swig_types[42] -#define SWIGTYPE_p_pn_reactor_t swig_types[43] -#define SWIGTYPE_p_pn_record_t swig_types[44] -#define SWIGTYPE_p_pn_rwbytes_t swig_types[45] -#define SWIGTYPE_p_pn_sasl_outcome_t swig_types[46] -#define SWIGTYPE_p_pn_sasl_t swig_types[47] -#define SWIGTYPE_p_pn_selectable_t swig_types[48] -#define SWIGTYPE_p_pn_session_t swig_types[49] -#define SWIGTYPE_p_pn_snd_settle_mode_t swig_types[50] -#define SWIGTYPE_p_pn_ssl_cert_subject_subfield swig_types[51] -#define SWIGTYPE_p_pn_ssl_domain_t swig_types[52] -#define SWIGTYPE_p_pn_ssl_hash_alg swig_types[53] -#define SWIGTYPE_p_pn_ssl_mode_t swig_types[54] -#define SWIGTYPE_p_pn_ssl_resume_status_t swig_types[55] -#define SWIGTYPE_p_pn_ssl_t swig_types[56] -#define SWIGTYPE_p_pn_ssl_verify_mode_t swig_types[57] -#define SWIGTYPE_p_pn_status_t swig_types[58] -#define SWIGTYPE_p_pn_string_t swig_types[59] -#define SWIGTYPE_p_pn_subscription_t swig_types[60] -#define SWIGTYPE_p_pn_task_t swig_types[61] -#define SWIGTYPE_p_pn_terminus_t swig_types[62] -#define SWIGTYPE_p_pn_terminus_type_t swig_types[63] -#define SWIGTYPE_p_pn_timer_t swig_types[64] -#define SWIGTYPE_p_pn_transport_t swig_types[65] -#define SWIGTYPE_p_pn_type_t swig_types[66] -#define SWIGTYPE_p_pn_url_t swig_types[67] -#define SWIGTYPE_p_pn_uuid_t swig_types[68] -#define SWIGTYPE_p_short swig_types[69] -#define SWIGTYPE_p_signed_char swig_types[70] -#define SWIGTYPE_p_unsigned_char swig_types[71] -#define SWIGTYPE_p_unsigned_int swig_types[72] -#define SWIGTYPE_p_unsigned_long swig_types[73] -#define SWIGTYPE_p_unsigned_long_long swig_types[74] -#define SWIGTYPE_p_unsigned_short swig_types[75] -#define SWIGTYPE_p_void swig_types[76] -static swig_type_info *swig_types[78]; -static swig_module_info swig_module = {swig_types, 77, 0, 0, 0, 0}; +#define SWIGTYPE_p_pn_connection_driver_t swig_types[20] +#define SWIGTYPE_p_pn_connection_t swig_types[21] +#define SWIGTYPE_p_pn_data_t swig_types[22] +#define SWIGTYPE_p_pn_decimal128_t swig_types[23] +#define SWIGTYPE_p_pn_delivery_t swig_types[24] +#define SWIGTYPE_p_pn_disposition_t swig_types[25] +#define SWIGTYPE_p_pn_distribution_mode_t swig_types[26] +#define SWIGTYPE_p_pn_durability_t swig_types[27] +#define SWIGTYPE_p_pn_error_t swig_types[28] +#define SWIGTYPE_p_pn_event_batch_t swig_types[29] +#define SWIGTYPE_p_pn_event_t swig_types[30] +#define SWIGTYPE_p_pn_event_type_t swig_types[31] +#define SWIGTYPE_p_pn_expiry_policy_t swig_types[32] +#define SWIGTYPE_p_pn_handler_t swig_types[33] +#define SWIGTYPE_p_pn_hash_t swig_types[34] +#define SWIGTYPE_p_pn_iterator_t swig_types[35] +#define SWIGTYPE_p_pn_link_t swig_types[36] +#define SWIGTYPE_p_pn_list_t swig_types[37] +#define SWIGTYPE_p_pn_listener_t swig_types[38] +#define SWIGTYPE_p_pn_map_t swig_types[39] +#define SWIGTYPE_p_pn_message_t swig_types[40] +#define SWIGTYPE_p_pn_messenger_t swig_types[41] +#define SWIGTYPE_p_pn_proactor_t swig_types[42] +#define SWIGTYPE_p_pn_rcv_settle_mode_t swig_types[43] +#define SWIGTYPE_p_pn_reactor_t swig_types[44] +#define SWIGTYPE_p_pn_record_t swig_types[45] +#define SWIGTYPE_p_pn_rwbytes_t swig_types[46] +#define SWIGTYPE_p_pn_sasl_outcome_t swig_types[47] +#define SWIGTYPE_p_pn_sasl_t swig_types[48] +#define SWIGTYPE_p_pn_selectable_t swig_types[49] +#define SWIGTYPE_p_pn_session_t swig_types[50] +#define SWIGTYPE_p_pn_snd_settle_mode_t swig_types[51] +#define SWIGTYPE_p_pn_ssl_cert_subject_subfield swig_types[52] +#define SWIGTYPE_p_pn_ssl_domain_t swig_types[53] +#define SWIGTYPE_p_pn_ssl_hash_alg swig_types[54] +#define SWIGTYPE_p_pn_ssl_mode_t swig_types[55] +#define SWIGTYPE_p_pn_ssl_resume_status_t swig_types[56] +#define SWIGTYPE_p_pn_ssl_t swig_types[57] +#define SWIGTYPE_p_pn_ssl_verify_mode_t swig_types[58] +#define SWIGTYPE_p_pn_status_t swig_types[59] +#define SWIGTYPE_p_pn_string_t swig_types[60] +#define SWIGTYPE_p_pn_subscription_t swig_types[61] +#define SWIGTYPE_p_pn_task_t swig_types[62] +#define SWIGTYPE_p_pn_terminus_t swig_types[63] +#define SWIGTYPE_p_pn_terminus_type_t swig_types[64] +#define SWIGTYPE_p_pn_timer_t swig_types[65] +#define SWIGTYPE_p_pn_transport_t swig_types[66] +#define SWIGTYPE_p_pn_type_t swig_types[67] +#define SWIGTYPE_p_pn_url_t swig_types[68] +#define SWIGTYPE_p_pn_uuid_t swig_types[69] +#define SWIGTYPE_p_short swig_types[70] +#define SWIGTYPE_p_signed_char swig_types[71] +#define SWIGTYPE_p_unsigned_char swig_types[72] +#define SWIGTYPE_p_unsigned_int swig_types[73] +#define SWIGTYPE_p_unsigned_long swig_types[74] +#define SWIGTYPE_p_unsigned_long_long swig_types[75] +#define SWIGTYPE_p_unsigned_short swig_types[76] +#define SWIGTYPE_p_void swig_types[77] +static swig_type_info *swig_types[79]; +static swig_module_info swig_module = {swig_types, 78, 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) -------- */ @@ -1899,23 +1900,24 @@ #define SWIG_as_voidptr(a) (void *)((const void *)(a)) #define SWIG_as_voidptrptr(a) ((void)SWIG_as_voidptr(*a),(void**)(a)) +#include <proton/connection_driver.h> #include <proton/engine.h> +#include <proton/handlers.h> #include <proton/message.h> -#include <proton/sasl.h> #include <proton/messenger.h> +#include <proton/reactor.h> +#include <proton/sasl.h> #include <proton/ssl.h> #include <proton/types.h> #include <proton/url.h> -#include <proton/reactor.h> -#include <proton/handlers.h> #if !defined(RSTRING_LEN) -# define RSTRING_LEN(x) (RSTRING(X)->len) +# define RSTRING_LEN(x) (RSTRING(x)->len) # define RSTRING_PTR(x) (RSTRING(x)->ptr) #endif SWIGINTERN VALUE @@ -2486,25 +2488,54 @@ return chandler; } + /* Helpers for working with pn_connection_driver_t */ + size_t pni_connection_driver_read_size(pn_connection_driver_t* d) { + return pn_connection_driver_read_buffer(d).size; + } + + size_t pni_connection_driver_write_size(pn_connection_driver_t* d) { + return pn_connection_driver_write_buffer(d).size; + } + + pn_connection_t *pni_connection_driver_connection(pn_connection_driver_t* d) { + return d->connection; + } + + pn_transport_t *pni_connection_driver_transport(pn_connection_driver_t* d) { + return d->transport; + } + + size_t pni_connection_driver_read_copy(pn_connection_driver_t* d, char *STRING, size_t LENGTH ) { + pn_rwbytes_t rbuf = pn_connection_driver_read_buffer(d); + size_t n = LENGTH < rbuf.size ? LENGTH : rbuf.size; + memcpy(rbuf.start, STRING, n); + pn_connection_driver_read_done(d, n); + return n; + } + + pn_connection_driver_t *pni_connection_driver() { + pn_connection_driver_t *d = (pn_connection_driver_t*)malloc(sizeof(*d)); + if (pn_connection_driver_init(d, NULL, NULL) != 0) { + free(d); + return NULL; + } + return d; + } + + + SWIGINTERNINLINE VALUE SWIG_From_unsigned_SS_long (unsigned long value) { return ULONG2NUM(value); } -SWIGINTERNINLINE VALUE -SWIG_From_unsigned_SS_int (unsigned int value) -{ - return SWIG_From_unsigned_SS_long (value); -} - - #ifdef SWIG_LONG_LONG_AVAILABLE SWIGINTERNINLINE VALUE SWIG_From_unsigned_SS_long_SS_long (unsigned long long value) { return ULL2NUM(value); @@ -2526,10 +2557,17 @@ } #endif } +SWIGINTERNINLINE VALUE +SWIG_From_unsigned_SS_int (unsigned int value) +{ + return SWIG_From_unsigned_SS_long (value); +} + + #include <float.h> #include <math.h> @@ -2788,10 +2826,13 @@ pn_transport_t *pn_cast_pn_transport(void *x) { return (pn_transport_t *) x; } pn_reactor_t *pn_cast_pn_reactor(void *x) { return (pn_reactor_t *) x; } pn_task_t *pn_cast_pn_task(void *x) { return (pn_task_t *) x; } pn_selectable_t *pn_cast_pn_selectable(void *x) { return (pn_selectable_t *) x; } + +#include <proton/connection_driver.h> + SWIGINTERN VALUE _wrap_pn_message_encode(int argc, VALUE *argv, VALUE self) { pn_message_t *arg1 = (pn_message_t *) 0 ; char *arg2 = (char *) 0 ; size_t *arg3 = (size_t *) 0 ; @@ -3843,10 +3884,160 @@ return Qnil; } SWIGINTERN VALUE +_wrap_pni_connection_driver_read_size(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + size_t 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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pni_connection_driver_read_size", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + result = (size_t)pni_connection_driver_read_size(arg1); + vresult = SWIG_From_size_t((size_t)(result)); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pni_connection_driver_write_size(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + size_t 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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pni_connection_driver_write_size", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + result = (size_t)pni_connection_driver_write_size(arg1); + vresult = SWIG_From_size_t((size_t)(result)); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pni_connection_driver_connection(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + pn_connection_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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pni_connection_driver_connection", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + result = (pn_connection_t *)pni_connection_driver_connection(arg1); + vresult = SWIG_NewPointerObj(SWIG_as_voidptr(result), SWIGTYPE_p_pn_connection_t, 0 | 0 ); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pni_connection_driver_transport(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + pn_transport_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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pni_connection_driver_transport", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + result = (pn_transport_t *)pni_connection_driver_transport(arg1); + vresult = SWIG_NewPointerObj(SWIG_as_voidptr(result), SWIGTYPE_p_pn_transport_t, 0 | 0 ); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pni_connection_driver_read_copy(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 0 ; + char *arg2 = (char *) 0 ; + size_t arg3 ; + void *argp1 = 0 ; + int res1 = 0 ; + int res2 ; + char *buf2 = 0 ; + size_t size2 = 0 ; + int alloc2 = 0 ; + size_t 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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pni_connection_driver_read_copy", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + res2 = SWIG_AsCharPtrAndSize(argv[1], &buf2, &size2, &alloc2); + if (!SWIG_IsOK(res2)) { + SWIG_exception_fail(SWIG_ArgError(res2), Ruby_Format_TypeError( "", "char *","pni_connection_driver_read_copy", 2, argv[1] )); + } + arg2 = (char *)(buf2); + arg3 = (size_t)(size2 - 1); + result = (size_t)pni_connection_driver_read_copy(arg1,arg2,arg3); + vresult = SWIG_From_size_t((size_t)(result)); + if (alloc2 == SWIG_NEWOBJ) free((char*)buf2); + return vresult; +fail: + if (alloc2 == SWIG_NEWOBJ) free((char*)buf2); + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pni_connection_driver(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *result = 0 ; + VALUE vresult = Qnil; + + if ((argc < 0) || (argc > 0)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 0)",argc); SWIG_fail; + } + result = (pn_connection_driver_t *)pni_connection_driver(); + vresult = SWIG_NewPointerObj(SWIG_as_voidptr(result), SWIGTYPE_p_pn_connection_driver_t, 0 | 0 ); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE _wrap_pn_bytes(int argc, VALUE *argv, VALUE self) { size_t arg1 ; char *arg2 = (char *) 0 ; size_t val1 ; int ecode1 = 0 ; @@ -3975,12 +4166,12 @@ res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_class_t, 0 | 0 ); if (!SWIG_IsOK(res1)) { SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_class_t const *","pn_class_id", 1, argv[0] )); } arg1 = (pn_class_t *)(argp1); - result = pn_class_id((struct pn_class_t const *)arg1); - vresult = SWIG_NewPointerObj((pn_cid_t *)memcpy((pn_cid_t *)calloc(1,sizeof(pn_cid_t)),&result,sizeof(pn_cid_t)), SWIGTYPE_p_pn_cid_t, SWIG_POINTER_OWN | 0 ); + result = (pn_cid_t)pn_class_id((struct pn_class_t const *)arg1); + vresult = SWIG_From_int((int)(result)); return vresult; fail: return Qnil; } @@ -17627,10 +17818,45 @@ return Qnil; } SWIGINTERN VALUE +_wrap_pn_ssl_domain_set_protocols(int argc, VALUE *argv, VALUE self) { + pn_ssl_domain_t *arg1 = (pn_ssl_domain_t *) 0 ; + char *arg2 = (char *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + int res2 ; + char *buf2 = 0 ; + int alloc2 = 0 ; + int 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_ssl_domain_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_ssl_domain_t *","pn_ssl_domain_set_protocols", 1, argv[0] )); + } + arg1 = (pn_ssl_domain_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_ssl_domain_set_protocols", 2, argv[1] )); + } + arg2 = (char *)(buf2); + result = (int)pn_ssl_domain_set_protocols(arg1,(char const *)arg2); + vresult = SWIG_From_int((int)(result)); + if (alloc2 == SWIG_NEWOBJ) free((char*)buf2); + return vresult; +fail: + if (alloc2 == SWIG_NEWOBJ) free((char*)buf2); + return Qnil; +} + + +SWIGINTERN VALUE _wrap_pn_ssl_domain_set_ciphers(int argc, VALUE *argv, VALUE self) { pn_ssl_domain_t *arg1 = (pn_ssl_domain_t *) 0 ; char *arg2 = (char *) 0 ; void *argp1 = 0 ; int res1 = 0 ; @@ -20416,10 +20642,510 @@ return Qnil; } SWIGINTERN VALUE +_wrap_pn_connection_driver_init(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 0 ; + pn_connection_t *arg2 = (pn_connection_t *) 0 ; + pn_transport_t *arg3 = (pn_transport_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + void *argp2 = 0 ; + int res2 = 0 ; + void *argp3 = 0 ; + int res3 = 0 ; + int result; + VALUE vresult = Qnil; + + if ((argc < 3) || (argc > 3)) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 3)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_init", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + res2 = SWIG_ConvertPtr(argv[1], &argp2,SWIGTYPE_p_pn_connection_t, 0 | 0 ); + if (!SWIG_IsOK(res2)) { + SWIG_exception_fail(SWIG_ArgError(res2), Ruby_Format_TypeError( "", "pn_connection_t *","pn_connection_driver_init", 2, argv[1] )); + } + arg2 = (pn_connection_t *)(argp2); + res3 = SWIG_ConvertPtr(argv[2], &argp3,SWIGTYPE_p_pn_transport_t, 0 | 0 ); + if (!SWIG_IsOK(res3)) { + SWIG_exception_fail(SWIG_ArgError(res3), Ruby_Format_TypeError( "", "pn_transport_t *","pn_connection_driver_init", 3, argv[2] )); + } + arg3 = (pn_transport_t *)(argp3); + result = (int)pn_connection_driver_init(arg1,arg2,arg3); + vresult = SWIG_From_int((int)(result)); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_bind(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_bind", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + result = (int)pn_connection_driver_bind(arg1); + vresult = SWIG_From_int((int)(result)); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_destroy(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 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(argv[0], &argp1,SWIGTYPE_p_pn_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_destroy", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + pn_connection_driver_destroy(arg1); + return Qnil; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_release_connection(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + pn_connection_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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_release_connection", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + result = (pn_connection_t *)pn_connection_driver_release_connection(arg1); + vresult = SWIG_NewPointerObj(SWIG_as_voidptr(result), SWIGTYPE_p_pn_connection_t, 0 | 0 ); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_read_buffer(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + pn_rwbytes_t 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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_read_buffer", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + result = pn_connection_driver_read_buffer(arg1); + vresult = SWIG_NewPointerObj((pn_rwbytes_t *)memcpy((pn_rwbytes_t *)calloc(1,sizeof(pn_rwbytes_t)),&result,sizeof(pn_rwbytes_t)), SWIGTYPE_p_pn_rwbytes_t, SWIG_POINTER_OWN | 0 ); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_read_done(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 0 ; + size_t arg2 ; + void *argp1 = 0 ; + int res1 = 0 ; + size_t 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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_read_done", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + ecode2 = SWIG_AsVal_size_t(argv[1], &val2); + if (!SWIG_IsOK(ecode2)) { + SWIG_exception_fail(SWIG_ArgError(ecode2), Ruby_Format_TypeError( "", "size_t","pn_connection_driver_read_done", 2, argv[1] )); + } + arg2 = (size_t)(val2); + pn_connection_driver_read_done(arg1,arg2); + return Qnil; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_read_close(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 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(argv[0], &argp1,SWIGTYPE_p_pn_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_read_close", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + pn_connection_driver_read_close(arg1); + return Qnil; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_read_closed(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_read_closed", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + result = (bool)pn_connection_driver_read_closed(arg1); + vresult = SWIG_From_bool((bool)(result)); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_write_buffer(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + pn_bytes_t 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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_write_buffer", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + result = pn_connection_driver_write_buffer(arg1); + { + vresult = rb_str_new((&result)->start, (&result)->size); + } + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_write_done(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 0 ; + size_t arg2 ; + void *argp1 = 0 ; + int res1 = 0 ; + size_t 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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_write_done", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + ecode2 = SWIG_AsVal_size_t(argv[1], &val2); + if (!SWIG_IsOK(ecode2)) { + SWIG_exception_fail(SWIG_ArgError(ecode2), Ruby_Format_TypeError( "", "size_t","pn_connection_driver_write_done", 2, argv[1] )); + } + arg2 = (size_t)(val2); + pn_connection_driver_write_done(arg1,arg2); + return Qnil; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_write_close(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 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(argv[0], &argp1,SWIGTYPE_p_pn_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_write_close", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + pn_connection_driver_write_close(arg1); + return Qnil; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_write_closed(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_write_closed", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + result = (bool)pn_connection_driver_write_closed(arg1); + vresult = SWIG_From_bool((bool)(result)); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_close(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 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(argv[0], &argp1,SWIGTYPE_p_pn_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_close", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + pn_connection_driver_close(arg1); + return Qnil; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_next_event(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + pn_event_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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_next_event", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + result = (pn_event_t *)pn_connection_driver_next_event(arg1); + vresult = SWIG_NewPointerObj(SWIG_as_voidptr(result), SWIGTYPE_p_pn_event_t, 0 | 0 ); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_has_event(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_has_event", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + result = (bool)pn_connection_driver_has_event(arg1); + vresult = SWIG_From_bool((bool)(result)); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_finished(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_finished", 1, argv[0] )); + } + arg1 = (pn_connection_driver_t *)(argp1); + result = (bool)pn_connection_driver_finished(arg1); + vresult = SWIG_From_bool((bool)(result)); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_errorf(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_t *) 0 ; + char *arg2 = (char *) 0 ; + char *arg3 = (char *) 0 ; + void *arg4 = 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + int res2 ; + char *buf2 = 0 ; + int alloc2 = 0 ; + int res3 ; + char *buf3 = 0 ; + int alloc3 = 0 ; + + if (argc < 3) { + rb_raise(rb_eArgError, "wrong # of arguments(%d for 3)",argc); SWIG_fail; + } + res1 = SWIG_ConvertPtr(argv[0], &argp1,SWIGTYPE_p_pn_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_errorf", 1, argv[0] )); + } + arg1 = (pn_connection_driver_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_connection_driver_errorf", 2, argv[1] )); + } + arg2 = (char *)(buf2); + res3 = SWIG_AsCharPtrAndSize(argv[2], &buf3, NULL, &alloc3); + if (!SWIG_IsOK(res3)) { + SWIG_exception_fail(SWIG_ArgError(res3), Ruby_Format_TypeError( "", "char const *","pn_connection_driver_errorf", 3, argv[2] )); + } + arg3 = (char *)(buf3); + pn_connection_driver_errorf(arg1,(char const *)arg2,(char const *)arg3,arg4); + if (alloc2 == SWIG_NEWOBJ) free((char*)buf2); + if (alloc3 == SWIG_NEWOBJ) free((char*)buf3); + return Qnil; +fail: + if (alloc2 == SWIG_NEWOBJ) free((char*)buf2); + if (alloc3 == SWIG_NEWOBJ) free((char*)buf3); + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_event_batch_connection_driver(int argc, VALUE *argv, VALUE self) { + pn_event_batch_t *arg1 = (pn_event_batch_t *) 0 ; + void *argp1 = 0 ; + int res1 = 0 ; + pn_connection_driver_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_event_batch_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_event_batch_t *","pn_event_batch_connection_driver", 1, argv[0] )); + } + arg1 = (pn_event_batch_t *)(argp1); + result = (pn_connection_driver_t *)pn_event_batch_connection_driver(arg1); + vresult = SWIG_NewPointerObj(SWIG_as_voidptr(result), SWIGTYPE_p_pn_connection_driver_t, 0 | 0 ); + return vresult; +fail: + return Qnil; +} + + +SWIGINTERN VALUE +_wrap_pn_connection_driver_log(int argc, VALUE *argv, VALUE self) { + pn_connection_driver_t *arg1 = (pn_connection_driver_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_connection_driver_t, 0 | 0 ); + if (!SWIG_IsOK(res1)) { + SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_connection_driver_t *","pn_connection_driver_log", 1, argv[0] )); + } + arg1 = (pn_connection_driver_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_connection_driver_log", 2, argv[1] )); + } + arg2 = (char *)(buf2); + pn_connection_driver_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_url(int argc, VALUE *argv, VALUE self) { pn_url_t *result = 0 ; VALUE vresult = Qnil; if ((argc < 0) || (argc > 0)) { @@ -22345,14 +23071,15 @@ static swig_type_info _swigt__p_long_long = {"_p_long_long", "int64_t *|long long *|pn_tracker_t *|pn_timestamp_t *", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_p_char = {"_p_p_char", "char **", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_pn_acceptor_t = {"_p_pn_acceptor_t", "struct pn_acceptor_t *|pn_acceptor_t *", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_pn_atom_t = {"_p_pn_atom_t", "pn_atom_t *", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_pn_bytes_t = {"_p_pn_bytes_t", "struct pn_bytes_t *|pn_bytes_t *", 0, 0, (void*)0, 0}; -static swig_type_info _swigt__p_pn_cid_t = {"_p_pn_cid_t", "pn_cid_t *", 0, 0, (void*)0, 0}; +static swig_type_info _swigt__p_pn_cid_t = {"_p_pn_cid_t", "enum pn_cid_t *|pn_cid_t *", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_pn_class_t = {"_p_pn_class_t", "struct pn_class_t *|pn_class_t *", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_pn_collector_t = {"_p_pn_collector_t", "struct pn_collector_t *|pn_collector_t *", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_pn_condition_t = {"_p_pn_condition_t", "struct pn_condition_t *|pn_condition_t *", 0, 0, (void*)0, 0}; +static swig_type_info _swigt__p_pn_connection_driver_t = {"_p_pn_connection_driver_t", "struct pn_connection_driver_t *|pn_connection_driver_t *", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_pn_connection_t = {"_p_pn_connection_t", "struct pn_connection_t *|pn_connection_t *", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_pn_data_t = {"_p_pn_data_t", "struct pn_data_t *|pn_data_t *", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_pn_decimal128_t = {"_p_pn_decimal128_t", "pn_decimal128_t *", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_pn_delivery_t = {"_p_pn_delivery_t", "struct pn_delivery_t *|pn_delivery_t *", 0, 0, (void*)0, 0}; static swig_type_info _swigt__p_pn_disposition_t = {"_p_pn_disposition_t", "struct pn_disposition_t *|pn_disposition_t *", 0, 0, (void*)0, 0}; @@ -22428,10 +23155,11 @@ &_swigt__p_pn_bytes_t, &_swigt__p_pn_cid_t, &_swigt__p_pn_class_t, &_swigt__p_pn_collector_t, &_swigt__p_pn_condition_t, + &_swigt__p_pn_connection_driver_t, &_swigt__p_pn_connection_t, &_swigt__p_pn_data_t, &_swigt__p_pn_decimal128_t, &_swigt__p_pn_delivery_t, &_swigt__p_pn_disposition_t, @@ -22507,10 +23235,11 @@ static swig_cast_info _swigc__p_pn_bytes_t[] = { {&_swigt__p_pn_bytes_t, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_pn_cid_t[] = { {&_swigt__p_pn_cid_t, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_pn_class_t[] = { {&_swigt__p_pn_class_t, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_pn_collector_t[] = { {&_swigt__p_pn_collector_t, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_pn_condition_t[] = { {&_swigt__p_pn_condition_t, 0, 0, 0},{0, 0, 0, 0}}; +static swig_cast_info _swigc__p_pn_connection_driver_t[] = { {&_swigt__p_pn_connection_driver_t, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_pn_connection_t[] = { {&_swigt__p_pn_connection_t, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_pn_data_t[] = { {&_swigt__p_pn_data_t, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_pn_decimal128_t[] = { {&_swigt__p_pn_decimal128_t, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_pn_delivery_t[] = { {&_swigt__p_pn_delivery_t, 0, 0, 0},{0, 0, 0, 0}}; static swig_cast_info _swigc__p_pn_disposition_t[] = { {&_swigt__p_pn_disposition_t, 0, 0, 0},{0, 0, 0, 0}}; @@ -22586,10 +23315,11 @@ _swigc__p_pn_bytes_t, _swigc__p_pn_cid_t, _swigc__p_pn_class_t, _swigc__p_pn_collector_t, _swigc__p_pn_condition_t, + _swigc__p_pn_connection_driver_t, _swigc__p_pn_connection_t, _swigc__p_pn_data_t, _swigc__p_pn_decimal128_t, _swigc__p_pn_delivery_t, _swigc__p_pn_disposition_t, @@ -22941,14 +23671,20 @@ SwigClassPni_rbhandler_t.trackObjects = 0; rb_define_module_function(mCproton, "pni_rbhandler", _wrap_pni_rbhandler, -1); rb_define_module_function(mCproton, "pni_rbdispatch", _wrap_pni_rbdispatch, -1); rb_define_module_function(mCproton, "pni_rbhandler_finalize", _wrap_pni_rbhandler_finalize, -1); rb_define_module_function(mCproton, "pn_rbhandler", _wrap_pn_rbhandler, -1); + rb_define_module_function(mCproton, "pni_connection_driver_read_size", _wrap_pni_connection_driver_read_size, -1); + rb_define_module_function(mCproton, "pni_connection_driver_write_size", _wrap_pni_connection_driver_write_size, -1); + rb_define_module_function(mCproton, "pni_connection_driver_connection", _wrap_pni_connection_driver_connection, -1); + rb_define_module_function(mCproton, "pni_connection_driver_transport", _wrap_pni_connection_driver_transport, -1); + rb_define_module_function(mCproton, "pni_connection_driver_read_copy", _wrap_pni_connection_driver_read_copy, -1); + rb_define_module_function(mCproton, "pni_connection_driver", _wrap_pni_connection_driver, -1); rb_define_const(mCproton, "PROTON_IMPORT_EXPORT_H", SWIG_From_int((int)(1))); rb_define_const(mCproton, "PN_VERSION_MAJOR", SWIG_From_int((int)(0))); - rb_define_const(mCproton, "PN_VERSION_MINOR", SWIG_From_int((int)(18))); - rb_define_const(mCproton, "PN_VERSION_POINT", SWIG_From_int((int)(1))); + rb_define_const(mCproton, "PN_VERSION_MINOR", SWIG_From_int((int)(19))); + rb_define_const(mCproton, "PN_VERSION_POINT", SWIG_From_int((int)(0))); rb_define_const(mCproton, "PROTON_TYPES_H", SWIG_From_int((int)(1))); rb_define_const(mCproton, "PN_MILLIS_MAX", SWIG_From_unsigned_SS_int((unsigned int)((~0U)))); rb_define_module_function(mCproton, "pn_bytes", _wrap_pn_bytes, -1); rb_define_singleton_method(mCproton, "pn_bytes_null", _wrap_pn_bytes_null_get, 0); rb_define_module_function(mCproton, "pn_rwbytes", _wrap_pn_rwbytes, -1); @@ -23591,10 +24327,11 @@ rb_define_const(mCproton, "PN_SSL_VERIFY_NULL", SWIG_From_int((int)(PN_SSL_VERIFY_NULL))); rb_define_const(mCproton, "PN_SSL_VERIFY_PEER", SWIG_From_int((int)(PN_SSL_VERIFY_PEER))); rb_define_const(mCproton, "PN_SSL_ANONYMOUS_PEER", SWIG_From_int((int)(PN_SSL_ANONYMOUS_PEER))); rb_define_const(mCproton, "PN_SSL_VERIFY_PEER_NAME", SWIG_From_int((int)(PN_SSL_VERIFY_PEER_NAME))); rb_define_module_function(mCproton, "pn_ssl_domain_set_peer_authentication", _wrap_pn_ssl_domain_set_peer_authentication, -1); + rb_define_module_function(mCproton, "pn_ssl_domain_set_protocols", _wrap_pn_ssl_domain_set_protocols, -1); rb_define_module_function(mCproton, "pn_ssl_domain_set_ciphers", _wrap_pn_ssl_domain_set_ciphers, -1); rb_define_module_function(mCproton, "pn_ssl_domain_allow_unsecured_client", _wrap_pn_ssl_domain_allow_unsecured_client, -1); rb_define_module_function(mCproton, "pn_ssl", _wrap_pn_ssl, -1); rb_define_module_function(mCproton, "pn_ssl_init", _wrap_pn_ssl_init, -1); rb_define_module_function(mCproton, "pn_ssl_get_ssf", _wrap_pn_ssl_get_ssf, -1); @@ -23728,10 +24465,30 @@ rb_define_module_function(mCproton, "pn_cast_pn_delivery", _wrap_pn_cast_pn_delivery, -1); rb_define_module_function(mCproton, "pn_cast_pn_transport", _wrap_pn_cast_pn_transport, -1); rb_define_module_function(mCproton, "pn_cast_pn_reactor", _wrap_pn_cast_pn_reactor, -1); rb_define_module_function(mCproton, "pn_cast_pn_task", _wrap_pn_cast_pn_task, -1); rb_define_module_function(mCproton, "pn_cast_pn_selectable", _wrap_pn_cast_pn_selectable, -1); + rb_define_const(mCproton, "PROTON_CONNECTION_DRIVER_H", SWIG_From_int((int)(1))); + rb_define_module_function(mCproton, "pn_connection_driver_init", _wrap_pn_connection_driver_init, -1); + rb_define_module_function(mCproton, "pn_connection_driver_bind", _wrap_pn_connection_driver_bind, -1); + rb_define_module_function(mCproton, "pn_connection_driver_destroy", _wrap_pn_connection_driver_destroy, -1); + rb_define_module_function(mCproton, "pn_connection_driver_release_connection", _wrap_pn_connection_driver_release_connection, -1); + rb_define_module_function(mCproton, "pn_connection_driver_read_buffer", _wrap_pn_connection_driver_read_buffer, -1); + rb_define_module_function(mCproton, "pn_connection_driver_read_done", _wrap_pn_connection_driver_read_done, -1); + rb_define_module_function(mCproton, "pn_connection_driver_read_close", _wrap_pn_connection_driver_read_close, -1); + rb_define_module_function(mCproton, "pn_connection_driver_read_closed", _wrap_pn_connection_driver_read_closed, -1); + rb_define_module_function(mCproton, "pn_connection_driver_write_buffer", _wrap_pn_connection_driver_write_buffer, -1); + rb_define_module_function(mCproton, "pn_connection_driver_write_done", _wrap_pn_connection_driver_write_done, -1); + rb_define_module_function(mCproton, "pn_connection_driver_write_close", _wrap_pn_connection_driver_write_close, -1); + rb_define_module_function(mCproton, "pn_connection_driver_write_closed", _wrap_pn_connection_driver_write_closed, -1); + rb_define_module_function(mCproton, "pn_connection_driver_close", _wrap_pn_connection_driver_close, -1); + rb_define_module_function(mCproton, "pn_connection_driver_next_event", _wrap_pn_connection_driver_next_event, -1); + rb_define_module_function(mCproton, "pn_connection_driver_has_event", _wrap_pn_connection_driver_has_event, -1); + rb_define_module_function(mCproton, "pn_connection_driver_finished", _wrap_pn_connection_driver_finished, -1); + rb_define_module_function(mCproton, "pn_connection_driver_errorf", _wrap_pn_connection_driver_errorf, -1); + rb_define_module_function(mCproton, "pn_event_batch_connection_driver", _wrap_pn_event_batch_connection_driver, -1); + rb_define_module_function(mCproton, "pn_connection_driver_log", _wrap_pn_connection_driver_log, -1); rb_define_const(mCproton, "PROTON_URL_H", SWIG_From_int((int)(1))); rb_define_module_function(mCproton, "pn_url", _wrap_pn_url, -1); rb_define_module_function(mCproton, "pn_url_parse", _wrap_pn_url_parse, -1); rb_define_module_function(mCproton, "pn_url_free", _wrap_pn_url_free, -1); rb_define_module_function(mCproton, "pn_url_clear", _wrap_pn_url_clear, -1); @@ -23803,7 +24560,38 @@ rb_define_module_function(mCproton, "pn_event_root", _wrap_pn_event_root, -1); rb_define_const(mCproton, "PROTON_HANDLERS_H", SWIG_From_int((int)(1))); rb_define_module_function(mCproton, "pn_handshaker", _wrap_pn_handshaker, -1); rb_define_module_function(mCproton, "pn_iohandler", _wrap_pn_iohandler, -1); rb_define_module_function(mCproton, "pn_flowcontroller", _wrap_pn_flowcontroller, -1); + rb_define_const(mCproton, "PROTON_CID_H", SWIG_From_int((int)(1))); + rb_define_const(mCproton, "CID_pn_object", SWIG_From_int((int)(CID_pn_object))); + rb_define_const(mCproton, "CID_pn_void", SWIG_From_int((int)(CID_pn_void))); + rb_define_const(mCproton, "CID_pn_weakref", SWIG_From_int((int)(CID_pn_weakref))); + rb_define_const(mCproton, "CID_pn_string", SWIG_From_int((int)(CID_pn_string))); + rb_define_const(mCproton, "CID_pn_list", SWIG_From_int((int)(CID_pn_list))); + rb_define_const(mCproton, "CID_pn_map", SWIG_From_int((int)(CID_pn_map))); + rb_define_const(mCproton, "CID_pn_hash", SWIG_From_int((int)(CID_pn_hash))); + rb_define_const(mCproton, "CID_pn_record", SWIG_From_int((int)(CID_pn_record))); + rb_define_const(mCproton, "CID_pn_collector", SWIG_From_int((int)(CID_pn_collector))); + rb_define_const(mCproton, "CID_pn_event", SWIG_From_int((int)(CID_pn_event))); + rb_define_const(mCproton, "CID_pn_encoder", SWIG_From_int((int)(CID_pn_encoder))); + rb_define_const(mCproton, "CID_pn_decoder", SWIG_From_int((int)(CID_pn_decoder))); + rb_define_const(mCproton, "CID_pn_data", SWIG_From_int((int)(CID_pn_data))); + rb_define_const(mCproton, "CID_pn_connection", SWIG_From_int((int)(CID_pn_connection))); + rb_define_const(mCproton, "CID_pn_session", SWIG_From_int((int)(CID_pn_session))); + rb_define_const(mCproton, "CID_pn_link", SWIG_From_int((int)(CID_pn_link))); + rb_define_const(mCproton, "CID_pn_delivery", SWIG_From_int((int)(CID_pn_delivery))); + rb_define_const(mCproton, "CID_pn_transport", SWIG_From_int((int)(CID_pn_transport))); + rb_define_const(mCproton, "CID_pn_message", SWIG_From_int((int)(CID_pn_message))); + rb_define_const(mCproton, "CID_pn_reactor", SWIG_From_int((int)(CID_pn_reactor))); + rb_define_const(mCproton, "CID_pn_handler", SWIG_From_int((int)(CID_pn_handler))); + rb_define_const(mCproton, "CID_pn_timer", SWIG_From_int((int)(CID_pn_timer))); + rb_define_const(mCproton, "CID_pn_task", SWIG_From_int((int)(CID_pn_task))); + rb_define_const(mCproton, "CID_pn_io", SWIG_From_int((int)(CID_pn_io))); + rb_define_const(mCproton, "CID_pn_selector", SWIG_From_int((int)(CID_pn_selector))); + rb_define_const(mCproton, "CID_pn_selectable", SWIG_From_int((int)(CID_pn_selectable))); + rb_define_const(mCproton, "CID_pn_url", SWIG_From_int((int)(CID_pn_url))); + rb_define_const(mCproton, "CID_pn_listener", SWIG_From_int((int)(CID_pn_listener))); + rb_define_const(mCproton, "CID_pn_proactor", SWIG_From_int((int)(CID_pn_proactor))); + rb_define_const(mCproton, "CID_pn_listener_socket", SWIG_From_int((int)(CID_pn_listener_socket))); }