ext/cproton/cproton.c in qpid_proton-0.31.0 vs ext/cproton/cproton.c in qpid_proton-0.32.0
- old
+ new
@@ -1838,41 +1838,42 @@
#define SWIGTYPE_p_pn_logger_t swig_types[35]
#define SWIGTYPE_p_pn_map_t swig_types[36]
#define SWIGTYPE_p_pn_message_t swig_types[37]
#define SWIGTYPE_p_pn_messenger_t swig_types[38]
#define SWIGTYPE_p_pn_proactor_t swig_types[39]
-#define SWIGTYPE_p_pn_rcv_settle_mode_t swig_types[40]
-#define SWIGTYPE_p_pn_record_t swig_types[41]
-#define SWIGTYPE_p_pn_rwbytes_t swig_types[42]
-#define SWIGTYPE_p_pn_sasl_outcome_t swig_types[43]
-#define SWIGTYPE_p_pn_sasl_t swig_types[44]
-#define SWIGTYPE_p_pn_session_t swig_types[45]
-#define SWIGTYPE_p_pn_snd_settle_mode_t swig_types[46]
-#define SWIGTYPE_p_pn_ssl_cert_subject_subfield swig_types[47]
-#define SWIGTYPE_p_pn_ssl_domain_t swig_types[48]
-#define SWIGTYPE_p_pn_ssl_hash_alg swig_types[49]
-#define SWIGTYPE_p_pn_ssl_mode_t swig_types[50]
-#define SWIGTYPE_p_pn_ssl_resume_status_t swig_types[51]
-#define SWIGTYPE_p_pn_ssl_t swig_types[52]
-#define SWIGTYPE_p_pn_ssl_verify_mode_t swig_types[53]
-#define SWIGTYPE_p_pn_string_t swig_types[54]
-#define SWIGTYPE_p_pn_terminus_t swig_types[55]
-#define SWIGTYPE_p_pn_terminus_type_t swig_types[56]
-#define SWIGTYPE_p_pn_transport_t swig_types[57]
-#define SWIGTYPE_p_pn_type_t swig_types[58]
-#define SWIGTYPE_p_pn_url_t swig_types[59]
-#define SWIGTYPE_p_pn_uuid_t swig_types[60]
-#define SWIGTYPE_p_short swig_types[61]
-#define SWIGTYPE_p_signed_char swig_types[62]
-#define SWIGTYPE_p_unsigned_char swig_types[63]
-#define SWIGTYPE_p_unsigned_int swig_types[64]
-#define SWIGTYPE_p_unsigned_long swig_types[65]
-#define SWIGTYPE_p_unsigned_long_long swig_types[66]
-#define SWIGTYPE_p_unsigned_short swig_types[67]
-#define SWIGTYPE_p_void swig_types[68]
-static swig_type_info *swig_types[70];
-static swig_module_info swig_module = {swig_types, 69, 0, 0, 0, 0};
+#define SWIGTYPE_p_pn_raw_connection_t swig_types[40]
+#define SWIGTYPE_p_pn_rcv_settle_mode_t swig_types[41]
+#define SWIGTYPE_p_pn_record_t swig_types[42]
+#define SWIGTYPE_p_pn_rwbytes_t swig_types[43]
+#define SWIGTYPE_p_pn_sasl_outcome_t swig_types[44]
+#define SWIGTYPE_p_pn_sasl_t swig_types[45]
+#define SWIGTYPE_p_pn_session_t swig_types[46]
+#define SWIGTYPE_p_pn_snd_settle_mode_t swig_types[47]
+#define SWIGTYPE_p_pn_ssl_cert_subject_subfield swig_types[48]
+#define SWIGTYPE_p_pn_ssl_domain_t swig_types[49]
+#define SWIGTYPE_p_pn_ssl_hash_alg swig_types[50]
+#define SWIGTYPE_p_pn_ssl_mode_t swig_types[51]
+#define SWIGTYPE_p_pn_ssl_resume_status_t swig_types[52]
+#define SWIGTYPE_p_pn_ssl_t swig_types[53]
+#define SWIGTYPE_p_pn_ssl_verify_mode_t swig_types[54]
+#define SWIGTYPE_p_pn_string_t swig_types[55]
+#define SWIGTYPE_p_pn_terminus_t swig_types[56]
+#define SWIGTYPE_p_pn_terminus_type_t swig_types[57]
+#define SWIGTYPE_p_pn_transport_t swig_types[58]
+#define SWIGTYPE_p_pn_type_t swig_types[59]
+#define SWIGTYPE_p_pn_url_t swig_types[60]
+#define SWIGTYPE_p_pn_uuid_t swig_types[61]
+#define SWIGTYPE_p_short swig_types[62]
+#define SWIGTYPE_p_signed_char swig_types[63]
+#define SWIGTYPE_p_unsigned_char swig_types[64]
+#define SWIGTYPE_p_unsigned_int swig_types[65]
+#define SWIGTYPE_p_unsigned_long swig_types[66]
+#define SWIGTYPE_p_unsigned_long_long swig_types[67]
+#define SWIGTYPE_p_unsigned_short swig_types[68]
+#define SWIGTYPE_p_void swig_types[69]
+static swig_type_info *swig_types[71];
+static swig_module_info swig_module = {swig_types, 70, 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) -------- */
@@ -9863,10 +9864,58 @@
return Qnil;
}
SWIGINTERN VALUE
+_wrap_pn_link_properties(int argc, VALUE *argv, VALUE self) {
+ pn_link_t *arg1 = (pn_link_t *) 0 ;
+ void *argp1 = 0 ;
+ int res1 = 0 ;
+ pn_data_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_link_t, 0 | 0 );
+ if (!SWIG_IsOK(res1)) {
+ SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_link_t *","pn_link_properties", 1, argv[0] ));
+ }
+ arg1 = (pn_link_t *)(argp1);
+ result = (pn_data_t *)pn_link_properties(arg1);
+ vresult = SWIG_NewPointerObj(SWIG_as_voidptr(result), SWIGTYPE_p_pn_data_t, 0 | 0 );
+ return vresult;
+fail:
+ return Qnil;
+}
+
+
+SWIGINTERN VALUE
+_wrap_pn_link_remote_properties(int argc, VALUE *argv, VALUE self) {
+ pn_link_t *arg1 = (pn_link_t *) 0 ;
+ void *argp1 = 0 ;
+ int res1 = 0 ;
+ pn_data_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_link_t, 0 | 0 );
+ if (!SWIG_IsOK(res1)) {
+ SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "pn_link_t *","pn_link_remote_properties", 1, argv[0] ));
+ }
+ arg1 = (pn_link_t *)(argp1);
+ result = (pn_data_t *)pn_link_remote_properties(arg1);
+ vresult = SWIG_NewPointerObj(SWIG_as_voidptr(result), SWIGTYPE_p_pn_data_t, 0 | 0 );
+ 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;
@@ -19147,10 +19196,11 @@
static swig_type_info _swigt__p_pn_logger_t = {"_p_pn_logger_t", "pn_logger_t *", 0, 0, (void*)0, 0};
static swig_type_info _swigt__p_pn_map_t = {"_p_pn_map_t", "struct pn_map_t *|pn_map_t *", 0, 0, (void*)0, 0};
static swig_type_info _swigt__p_pn_message_t = {"_p_pn_message_t", "struct pn_message_t *|pn_message_t *", 0, 0, (void*)0, 0};
static swig_type_info _swigt__p_pn_messenger_t = {"_p_pn_messenger_t", "pn_messenger_t *", 0, 0, (void*)0, 0};
static swig_type_info _swigt__p_pn_proactor_t = {"_p_pn_proactor_t", "struct pn_proactor_t *|pn_proactor_t *", 0, 0, (void*)0, 0};
+static swig_type_info _swigt__p_pn_raw_connection_t = {"_p_pn_raw_connection_t", "struct pn_raw_connection_t *|pn_raw_connection_t *", 0, 0, (void*)0, 0};
static swig_type_info _swigt__p_pn_rcv_settle_mode_t = {"_p_pn_rcv_settle_mode_t", "enum pn_rcv_settle_mode_t *|pn_rcv_settle_mode_t *", 0, 0, (void*)0, 0};
static swig_type_info _swigt__p_pn_record_t = {"_p_pn_record_t", "struct pn_record_t *|pn_record_t *", 0, 0, (void*)0, 0};
static swig_type_info _swigt__p_pn_rwbytes_t = {"_p_pn_rwbytes_t", "struct pn_rwbytes_t *|pn_rwbytes_t *", 0, 0, (void*)0, 0};
static swig_type_info _swigt__p_pn_sasl_outcome_t = {"_p_pn_sasl_outcome_t", "enum pn_sasl_outcome_t *|pn_sasl_outcome_t *", 0, 0, (void*)0, 0};
static swig_type_info _swigt__p_pn_sasl_t = {"_p_pn_sasl_t", "struct pn_sasl_t *|pn_sasl_t *", 0, 0, (void*)0, 0};
@@ -19218,10 +19268,11 @@
&_swigt__p_pn_logger_t,
&_swigt__p_pn_map_t,
&_swigt__p_pn_message_t,
&_swigt__p_pn_messenger_t,
&_swigt__p_pn_proactor_t,
+ &_swigt__p_pn_raw_connection_t,
&_swigt__p_pn_rcv_settle_mode_t,
&_swigt__p_pn_record_t,
&_swigt__p_pn_rwbytes_t,
&_swigt__p_pn_sasl_outcome_t,
&_swigt__p_pn_sasl_t,
@@ -19289,10 +19340,11 @@
static swig_cast_info _swigc__p_pn_logger_t[] = { {&_swigt__p_pn_logger_t, 0, 0, 0},{0, 0, 0, 0}};
static swig_cast_info _swigc__p_pn_map_t[] = { {&_swigt__p_pn_map_t, 0, 0, 0},{0, 0, 0, 0}};
static swig_cast_info _swigc__p_pn_message_t[] = { {&_swigt__p_pn_message_t, 0, 0, 0},{0, 0, 0, 0}};
static swig_cast_info _swigc__p_pn_messenger_t[] = { {&_swigt__p_pn_messenger_t, 0, 0, 0},{0, 0, 0, 0}};
static swig_cast_info _swigc__p_pn_proactor_t[] = { {&_swigt__p_pn_proactor_t, 0, 0, 0},{0, 0, 0, 0}};
+static swig_cast_info _swigc__p_pn_raw_connection_t[] = { {&_swigt__p_pn_raw_connection_t, 0, 0, 0},{0, 0, 0, 0}};
static swig_cast_info _swigc__p_pn_rcv_settle_mode_t[] = { {&_swigt__p_pn_rcv_settle_mode_t, 0, 0, 0},{0, 0, 0, 0}};
static swig_cast_info _swigc__p_pn_record_t[] = { {&_swigt__p_pn_record_t, 0, 0, 0},{0, 0, 0, 0}};
static swig_cast_info _swigc__p_pn_rwbytes_t[] = { {&_swigt__p_pn_rwbytes_t, 0, 0, 0},{0, 0, 0, 0}};
static swig_cast_info _swigc__p_pn_sasl_outcome_t[] = { {&_swigt__p_pn_sasl_outcome_t, 0, 0, 0},{0, 0, 0, 0}};
static swig_cast_info _swigc__p_pn_sasl_t[] = { {&_swigt__p_pn_sasl_t, 0, 0, 0},{0, 0, 0, 0}};
@@ -19360,10 +19412,11 @@
_swigc__p_pn_logger_t,
_swigc__p_pn_map_t,
_swigc__p_pn_message_t,
_swigc__p_pn_messenger_t,
_swigc__p_pn_proactor_t,
+ _swigc__p_pn_raw_connection_t,
_swigc__p_pn_rcv_settle_mode_t,
_swigc__p_pn_record_t,
_swigc__p_pn_rwbytes_t,
_swigc__p_pn_sasl_outcome_t,
_swigc__p_pn_sasl_t,
@@ -19695,11 +19748,11 @@
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)(31)));
+ rb_define_const(mCproton, "PN_VERSION_MINOR", SWIG_From_int((int)(32)));
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);
@@ -19949,10 +20002,12 @@
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_link_max_message_size", _wrap_pn_link_max_message_size, -1);
rb_define_module_function(mCproton, "pn_link_set_max_message_size", _wrap_pn_link_set_max_message_size, -1);
rb_define_module_function(mCproton, "pn_link_remote_max_message_size", _wrap_pn_link_remote_max_message_size, -1);
+ rb_define_module_function(mCproton, "pn_link_properties", _wrap_pn_link_properties, -1);
+ rb_define_module_function(mCproton, "pn_link_remote_properties", _wrap_pn_link_remote_properties, -1);
rb_define_const(mCproton, "PROTON_TERMINUS_H", SWIG_From_int((int)(1)));
rb_define_const(mCproton, "PN_UNSPECIFIED", SWIG_From_int((int)(PN_UNSPECIFIED)));
rb_define_const(mCproton, "PN_SOURCE", SWIG_From_int((int)(PN_SOURCE)));
rb_define_const(mCproton, "PN_TARGET", SWIG_From_int((int)(PN_TARGET)));
rb_define_const(mCproton, "PN_COORDINATOR", SWIG_From_int((int)(PN_COORDINATOR)));
@@ -20132,10 +20187,19 @@
rb_define_const(mCproton, "PN_LISTENER_CLOSE", SWIG_From_int((int)(PN_LISTENER_CLOSE)));
rb_define_const(mCproton, "PN_PROACTOR_INTERRUPT", SWIG_From_int((int)(PN_PROACTOR_INTERRUPT)));
rb_define_const(mCproton, "PN_PROACTOR_TIMEOUT", SWIG_From_int((int)(PN_PROACTOR_TIMEOUT)));
rb_define_const(mCproton, "PN_PROACTOR_INACTIVE", SWIG_From_int((int)(PN_PROACTOR_INACTIVE)));
rb_define_const(mCproton, "PN_LISTENER_OPEN", SWIG_From_int((int)(PN_LISTENER_OPEN)));
+ rb_define_const(mCproton, "PN_RAW_CONNECTION_CONNECTED", SWIG_From_int((int)(PN_RAW_CONNECTION_CONNECTED)));
+ rb_define_const(mCproton, "PN_RAW_CONNECTION_CLOSED_READ", SWIG_From_int((int)(PN_RAW_CONNECTION_CLOSED_READ)));
+ rb_define_const(mCproton, "PN_RAW_CONNECTION_CLOSED_WRITE", SWIG_From_int((int)(PN_RAW_CONNECTION_CLOSED_WRITE)));
+ rb_define_const(mCproton, "PN_RAW_CONNECTION_DISCONNECTED", SWIG_From_int((int)(PN_RAW_CONNECTION_DISCONNECTED)));
+ rb_define_const(mCproton, "PN_RAW_CONNECTION_NEED_READ_BUFFERS", SWIG_From_int((int)(PN_RAW_CONNECTION_NEED_READ_BUFFERS)));
+ rb_define_const(mCproton, "PN_RAW_CONNECTION_NEED_WRITE_BUFFERS", SWIG_From_int((int)(PN_RAW_CONNECTION_NEED_WRITE_BUFFERS)));
+ rb_define_const(mCproton, "PN_RAW_CONNECTION_READ", SWIG_From_int((int)(PN_RAW_CONNECTION_READ)));
+ rb_define_const(mCproton, "PN_RAW_CONNECTION_WRITTEN", SWIG_From_int((int)(PN_RAW_CONNECTION_WRITTEN)));
+ rb_define_const(mCproton, "PN_RAW_CONNECTION_WAKE", SWIG_From_int((int)(PN_RAW_CONNECTION_WAKE)));
rb_define_module_function(mCproton, "pn_event_type_name", _wrap_pn_event_type_name, -1);
rb_define_module_function(mCproton, "pn_collector", _wrap_pn_collector, -1);
rb_define_module_function(mCproton, "pn_collector_free", _wrap_pn_collector_free, -1);
rb_define_module_function(mCproton, "pn_collector_release", _wrap_pn_collector_release, -1);
rb_define_module_function(mCproton, "pn_collector_drain", _wrap_pn_collector_drain, -1);
@@ -20430,9 +20494,10 @@
rb_define_const(mCproton, "CID_pn_url", SWIG_From_int((int)(CID_pn_url)));
rb_define_const(mCproton, "CID_pn_strdup", SWIG_From_int((int)(CID_pn_strdup)));
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)));
+ rb_define_const(mCproton, "CID_pn_raw_connection", SWIG_From_int((int)(CID_pn_raw_connection)));
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);