You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2014/10/10 14:54:14 UTC
svn commit: r1630829 - in /qpid/proton/branches/examples/proton-c:
include/proton/messenger.h src/messenger/messenger.c
Author: gsim
Date: Fri Oct 10 12:54:13 2014
New Revision: 1630829
URL: http://svn.apache.org/r1630829
Log:
PROTON-670: applied patch from dominic for link accessors
Modified:
qpid/proton/branches/examples/proton-c/include/proton/messenger.h
qpid/proton/branches/examples/proton-c/src/messenger/messenger.c
Modified: qpid/proton/branches/examples/proton-c/include/proton/messenger.h
URL: http://svn.apache.org/viewvc/qpid/proton/branches/examples/proton-c/include/proton/messenger.h?rev=1630829&r1=1630828&r2=1630829&view=diff
==============================================================================
--- qpid/proton/branches/examples/proton-c/include/proton/messenger.h (original)
+++ qpid/proton/branches/examples/proton-c/include/proton/messenger.h Fri Oct 10 12:54:13 2014
@@ -752,6 +752,16 @@ PN_EXTERN int pn_messenger_accept(pn_mes
PN_EXTERN int pn_messenger_reject(pn_messenger_t *messenger, pn_tracker_t tracker, int flags);
/**
+ * Get link for the message referenced by the given tracker.
+ *
+ * @param[in] messenger a messenger object
+ * @param[in] tracker a tracker object
+ * @return a pn_link_t or NULL if the link could not be determined.
+ */
+PN_EXTERN pn_link_t *pn_messenger_tracker_link(pn_messenger_t *messenger,
+ pn_tracker_t tracker);
+
+/**
* Get the number of messages in the outgoing message queue of a
* messenger.
*
Modified: qpid/proton/branches/examples/proton-c/src/messenger/messenger.c
URL: http://svn.apache.org/viewvc/qpid/proton/branches/examples/proton-c/src/messenger/messenger.c?rev=1630829&r1=1630828&r2=1630829&view=diff
==============================================================================
--- qpid/proton/branches/examples/proton-c/src/messenger/messenger.c (original)
+++ qpid/proton/branches/examples/proton-c/src/messenger/messenger.c Fri Oct 10 12:54:13 2014
@@ -2188,6 +2188,20 @@ int pn_messenger_reject(pn_messenger_t *
PN_STATUS_REJECTED, flags, false, false);
}
+PN_EXTERN pn_link_t *pn_messenger_tracker_link(pn_messenger_t *messenger,
+ pn_tracker_t tracker)
+{
+ pni_store_t *store = pn_tracker_store(messenger, tracker);
+ pni_entry_t *e = pni_store_entry(store, pn_tracker_sequence(tracker));
+ if (e) {
+ pn_delivery_t *d = pni_entry_get_delivery(e);
+ if (d) {
+ return pn_delivery_link(d);
+ }
+ }
+ return NULL;
+}
+
int pn_messenger_queued(pn_messenger_t *messenger, bool sender)
{
if (!messenger) return 0;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org