[10/34] qpid-proton git commit: PROTON-799: Added the pn_rbkey_t type to the Ruby APIs.

[mc...@apache.org]

PROTON-799: Added the pn_rbkey_t type to the Ruby APIs.

The pn_rbkey_t type provides a way, from Ruby, to attach pure Ruby
objects to Proton structs by means of an attachment.

The type holds a reference to an registry object, a method to invoke on
that object, and the value to pass to that method when invoked. This
method is then called when the rbkey is finalized, with the goal of
removing the referenced Ruby object so it can be safely garbage
collected.


Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/ff805e1e
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/ff805e1e
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/ff805e1e

Branch: refs/heads/master
Commit: ff805e1e5b234712dddc3e2cd7d892edd0b9187c
Parents: 0530d1a
Author: Darryl L. Pierce <mc...@gmail.com>
Authored: Fri Mar 6 09:36:35 2015 -0500
Committer: Darryl L. Pierce <mc...@gmail.com>
Committed: Wed Jun 3 16:29:21 2015 -0400

----------------------------------------------------------------------
 proton-c/bindings/ruby/lib/qpid_proton.rb | 22 +++++++
 proton-c/bindings/ruby/ruby.i             | 82 ++++++++++++++++++++++++++
 2 files changed, 104 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ff805e1e/proton-c/bindings/ruby/lib/qpid_proton.rb
----------------------------------------------------------------------
diff --git a/proton-c/bindings/ruby/lib/qpid_proton.rb b/proton-c/bindings/ruby/lib/qpid_proton.rb
index da9983c..28a83aa 100644
--- a/proton-c/bindings/ruby/lib/qpid_proton.rb
+++ b/proton-c/bindings/ruby/lib/qpid_proton.rb
@@ -53,3 +53,25 @@ require "messenger/tracker_status"
 require "messenger/tracker"
 require "messenger/selectable"
 require "messenger/messenger"
+
+module Qpid::Proton
+  # @private
+  def self.registry
+    @registry ||= {}
+  end
+
+  # @private
+  def self.add_to_registry(key, value)
+    self.registry[key] = value
+  end
+
+  # @private
+  def self.get_from_registry(key)
+    self.registry[key]
+  end
+
+  # @private
+  def self.delete_from_registry(key)
+    self.registry.delete(key)
+  end
+end

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ff805e1e/proton-c/bindings/ruby/ruby.i
----------------------------------------------------------------------
diff --git a/proton-c/bindings/ruby/ruby.i b/proton-c/bindings/ruby/ruby.i
index 7205f57..50f9abe 100644
--- a/proton-c/bindings/ruby/ruby.i
+++ b/proton-c/bindings/ruby/ruby.i
@@ -465,4 +465,86 @@ bool pn_ssl_get_protocol_name(pn_ssl_t *ssl, char *OUTPUT, size_t MAX_OUTPUT_SIZ
 %ignore pn_messenger_recv;
 %ignore pn_messenger_work;
 
+%inline %{
+
+#define CID_pn_rbkey CID_pn_void
+
+typedef struct {
+  void *registry;
+  char *method;
+  char *key_value;
+} pn_rbkey_t;
+
+void pn_rbkey_initialize(pn_rbkey_t *rbkey) {
+  assert(rbkey);
+  rbkey->registry = NULL;
+  rbkey->method = NULL;
+  rbkey->key_value = NULL;
+}
+
+void pn_rbkey_finalize(pn_rbkey_t *rbkey) {
+  if(rbkey && rbkey->registry && rbkey->method && rbkey->key_value) {
+    rb_funcall((VALUE )rbkey->registry, rb_intern(rbkey->method), 1, rb_str_new2(rbkey->key_value));
+  }
+  if(rbkey->key_value) {
+    free(rbkey->key_value);
+    rbkey->key_value = NULL;
+  }
+}
+
+#define pn_rbkey_inspect NULL
+#define pn_rbkey_compare NULL
+#define pn_rbkey_hashcode NULL
+
+PN_CLASSDEF(pn_rbkey)
+
+void pn_rbkey_set_registry(pn_rbkey_t *rbkey, void *registry) {
+  assert(rbkey);
+  rbkey->registry = registry;
+}
+
+void *pn_rbkey_get_registry(pn_rbkey_t *rbkey) {
+  assert(rbkey);
+  return rbkey->registry;
+}
+
+void pn_rbkey_set_method(pn_rbkey_t *rbkey, char *method) {
+  assert(rbkey);
+  rbkey->method = method;
+}
+
+char *pn_rbkey_get_method(pn_rbkey_t *rbkey) {
+  assert(rbkey);
+  return rbkey->method;
+}
+
+void pn_rbkey_set_key_value(pn_rbkey_t *rbkey, char *key_value) {
+  assert(rbkey);
+  rbkey->key_value = malloc(strlen(key_value) + 1);
+  strncpy(rbkey->key_value, key_value, strlen(key_value) + 1);
+}
+
+char *pn_rbkey_get_key_value(pn_rbkey_t *rbkey) {
+  assert(rbkey);
+  return rbkey->key_value;
+}
+
+pn_rbkey_t *pni_void2rbkey(void *object) {
+  return (pn_rbkey_t *)object;
+}
+
+VALUE pn_void2rb(void *object) {
+  return (VALUE )object;
+}
+
+void *pn_rb2void(VALUE object) {
+  return (void *)object;
+}
+
+VALUE pni_address_of(void *object) {
+  return ULL2NUM((unsigned long )object);
+}
+
+%}
+
 %include "proton/cproton.i"


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org