svn commit: r1384825 - in /qpid/proton/trunk/proton-c: include/proton/engine.h src/engine/engine-internal.h src/engine/engine.c

[tr...@apache.org]

Author: tross
Date: Fri Sep 14 15:42:13 2012
New Revision: 1384825

URL: http://svn.apache.org/viewvc?rev=1384825&view=rev
Log:
PROTON-24 - Added app-context to pn_session_t and pn_link_t.

Modified:
    qpid/proton/trunk/proton-c/include/proton/engine.h
    qpid/proton/trunk/proton-c/src/engine/engine-internal.h
    qpid/proton/trunk/proton-c/src/engine/engine.c

Modified: qpid/proton/trunk/proton-c/include/proton/engine.h
URL: http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/include/proton/engine.h?rev=1384825&r1=1384824&r2=1384825&view=diff
==============================================================================
--- qpid/proton/trunk/proton-c/include/proton/engine.h (original)
+++ qpid/proton/trunk/proton-c/include/proton/engine.h Fri Sep 14 15:42:13 2012
@@ -264,6 +264,8 @@ pn_connection_t *pn_get_connection(pn_se
 void pn_session_open(pn_session_t *session);
 void pn_session_close(pn_session_t *session);
 void pn_session_free(pn_session_t *session);
+void *pn_session_context(pn_session_t *session);
+void pn_session_set_context(pn_session_t *session, void *context);
 
 // link
 const char *pn_link_name(pn_link_t *link);
@@ -291,6 +293,8 @@ pn_delivery_t *pn_unsettled_next(pn_deli
 void pn_link_open(pn_link_t *sender);
 void pn_link_close(pn_link_t *sender);
 void pn_link_free(pn_link_t *sender);
+void *pn_link_context(pn_link_t *link);
+void pn_link_set_context(pn_link_t *link, void *context);
 
 // sender
 //void pn_offer(pn_sender_t *sender, int credits);

Modified: qpid/proton/trunk/proton-c/src/engine/engine-internal.h
URL: http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/src/engine/engine-internal.h?rev=1384825&r1=1384824&r2=1384825&view=diff
==============================================================================
--- qpid/proton/trunk/proton-c/src/engine/engine-internal.h (original)
+++ qpid/proton/trunk/proton-c/src/engine/engine-internal.h Fri Sep 14 15:42:13 2012
@@ -136,6 +136,7 @@ struct pn_session_t {
   size_t link_capacity;
   size_t link_count;
   size_t id;
+  void *context;
 };
 
 struct pn_link_t {
@@ -157,6 +158,7 @@ struct pn_link_t {
   bool drain;
   bool drained; // sender only
   size_t id;
+  void *context;
 };
 
 struct pn_delivery_t {

Modified: qpid/proton/trunk/proton-c/src/engine/engine.c
URL: http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/src/engine/engine.c?rev=1384825&r1=1384824&r2=1384825&view=diff
==============================================================================
--- qpid/proton/trunk/proton-c/src/engine/engine.c (original)
+++ qpid/proton/trunk/proton-c/src/engine/engine.c Fri Sep 14 15:42:13 2012
@@ -294,6 +294,18 @@ void pn_session_free(pn_session_t *sessi
   free(session);
 }
 
+void *pn_session_context(pn_session_t *session)
+{
+    return session ? session->context : 0;
+}
+
+void pn_session_set_context(pn_session_t *session, void *context)
+{
+    if (session)
+        session->context = context;
+}
+
+
 void pn_add_link(pn_session_t *ssn, pn_link_t *link)
 {
   PN_ENSURE(ssn->links, ssn->link_capacity, ssn->link_count + 1);
@@ -359,6 +371,17 @@ void pn_link_free(pn_link_t *link)
   free(link);
 }
 
+void *pn_link_context(pn_link_t *link)
+{
+    return link ? link->context : 0;
+}
+
+void pn_link_set_context(pn_link_t *link, void *context)
+{
+    if (link)
+        link->context = context;
+}
+
 void pn_endpoint_init(pn_endpoint_t *endpoint, int type, pn_connection_t *conn)
 {
   endpoint->type = type;
@@ -639,6 +662,7 @@ pn_session_t *pn_session(pn_connection_t
   ssn->links = NULL;
   ssn->link_capacity = 0;
   ssn->link_count = 0;
+  ssn->context = 0;
 
   return ssn;
 }
@@ -790,6 +814,7 @@ void pn_link_init(pn_link_t *link, int t
   link->queued = 0;
   link->drain = false;
   link->drained = false;
+  link->context = 0;
 }
 
 const char *pn_source(pn_link_t *link)



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