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-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org