| <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "https://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"> |
| <html xmlns="http://www.w3.org/1999/xhtml"> |
| <head> |
| <meta http-equiv="Content-Type" content="text/xhtml;charset=UTF-8"/> |
| <meta http-equiv="X-UA-Compatible" content="IE=9"/> |
| <meta name="generator" content="Doxygen 1.8.20"/> |
| <meta name="viewport" content="width=device-width, initial-scale=1"/> |
| <title>Qpid Proton C API: send.c</title> |
| <link href="tabs.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="jquery.js"></script> |
| <script type="text/javascript" src="dynsections.js"></script> |
| <link href="navtree.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="resize.js"></script> |
| <script type="text/javascript" src="navtreedata.js"></script> |
| <script type="text/javascript" src="navtree.js"></script> |
| <link href="search/search.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="search/searchdata.js"></script> |
| <script type="text/javascript" src="search/search.js"></script> |
| <script type="text/javascript"> |
| /* @license magnet:?xt=urn:btih:cf05388f2679ee054f2beb29a391d25f4e673ac3&dn=gpl-2.0.txt GPL-v2 */ |
| $(document).ready(function() { init_search(); }); |
| /* @license-end */ |
| </script> |
| <link href="doxygen.css" rel="stylesheet" type="text/css" /> |
| </head> |
| <body> |
| <div id="top"><!-- do not remove this div, it is closed by doxygen! --> |
| <div id="titlearea"> |
| <table cellspacing="0" cellpadding="0"> |
| <tbody> |
| <tr style="height: 56px;"> |
| <td id="projectalign" style="padding-left: 0.5em;"> |
| <div id="projectname">Qpid Proton C API |
|  <span id="projectnumber">0.32.0</span> |
| </div> |
| </td> |
| <td> <div id="MSearchBox" class="MSearchBoxInactive"> |
| <span class="left"> |
| <img id="MSearchSelect" src="search/mag_sel.svg" |
| onmouseover="return searchBox.OnSearchSelectShow()" |
| onmouseout="return searchBox.OnSearchSelectHide()" |
| alt=""/> |
| <input type="text" id="MSearchField" value="Search" accesskey="S" |
| onfocus="searchBox.OnSearchFieldFocus(true)" |
| onblur="searchBox.OnSearchFieldFocus(false)" |
| onkeyup="searchBox.OnSearchFieldChange(event)"/> |
| </span><span class="right"> |
| <a id="MSearchClose" href="javascript:searchBox.CloseResultsWindow()"><img id="MSearchCloseImg" border="0" src="search/close.svg" alt=""/></a> |
| </span> |
| </div> |
| </td> |
| </tr> |
| </tbody> |
| </table> |
| </div> |
| <!-- end header part --> |
| <!-- Generated by Doxygen 1.8.20 --> |
| <script type="text/javascript"> |
| /* @license magnet:?xt=urn:btih:cf05388f2679ee054f2beb29a391d25f4e673ac3&dn=gpl-2.0.txt GPL-v2 */ |
| var searchBox = new SearchBox("searchBox", "search",false,'Search'); |
| /* @license-end */ |
| </script> |
| </div><!-- top --> |
| <div id="side-nav" class="ui-resizable side-nav-resizable"> |
| <div id="nav-tree"> |
| <div id="nav-tree-contents"> |
| <div id="nav-sync" class="sync"></div> |
| </div> |
| </div> |
| <div id="splitbar" style="-moz-user-select:none;" |
| class="ui-resizable-handle"> |
| </div> |
| </div> |
| <script type="text/javascript"> |
| /* @license magnet:?xt=urn:btih:cf05388f2679ee054f2beb29a391d25f4e673ac3&dn=gpl-2.0.txt GPL-v2 */ |
| $(document).ready(function(){initNavTree('send_8c-example.html',''); initResizable(); }); |
| /* @license-end */ |
| </script> |
| <div id="doc-content"> |
| <!-- window showing the filter options --> |
| <div id="MSearchSelectWindow" |
| onmouseover="return searchBox.OnSearchSelectShow()" |
| onmouseout="return searchBox.OnSearchSelectHide()" |
| onkeydown="return searchBox.OnSearchSelectKey(event)"> |
| </div> |
| |
| <!-- iframe showing the search results (closed by default) --> |
| <div id="MSearchResultsWindow"> |
| <iframe src="javascript:void(0)" frameborder="0" |
| name="MSearchResults" id="MSearchResults"> |
| </iframe> |
| </div> |
| |
| <div class="header"> |
| <div class="headertitle"> |
| <div class="title">send.c</div> </div> |
| </div><!--header--> |
| <div class="contents"> |
| <p>Send a fixed number of messages to the "examples" node.Can be used with <a class="el" href="broker_8c-example.html">broker.c</a>, <a class="el" href="direct_8c-example.html">direct.c</a> or an external AMQP broker.</p> |
| <div class="fragment"><div class="line"><span class="comment">/*</span></div> |
| <div class="line"><span class="comment"> *</span></div> |
| <div class="line"><span class="comment"> * Licensed to the Apache Software Foundation (ASF) under one</span></div> |
| <div class="line"><span class="comment"> * or more contributor license agreements. See the NOTICE file</span></div> |
| <div class="line"><span class="comment"> * distributed with this work for additional information</span></div> |
| <div class="line"><span class="comment"> * regarding copyright ownership. The ASF licenses this file</span></div> |
| <div class="line"><span class="comment"> * to you under the Apache License, Version 2.0 (the</span></div> |
| <div class="line"><span class="comment"> * "License"); you may not use this file except in compliance</span></div> |
| <div class="line"><span class="comment"> * with the License. You may obtain a copy of the License at</span></div> |
| <div class="line"><span class="comment"> *</span></div> |
| <div class="line"><span class="comment"> * http://www.apache.org/licenses/LICENSE-2.0</span></div> |
| <div class="line"><span class="comment"> *</span></div> |
| <div class="line"><span class="comment"> * Unless required by applicable law or agreed to in writing,</span></div> |
| <div class="line"><span class="comment"> * software distributed under the License is distributed on an</span></div> |
| <div class="line"><span class="comment"> * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY</span></div> |
| <div class="line"><span class="comment"> * KIND, either express or implied. See the License for the</span></div> |
| <div class="line"><span class="comment"> * specific language governing permissions and limitations</span></div> |
| <div class="line"><span class="comment"> * under the License.</span></div> |
| <div class="line"><span class="comment"> *</span></div> |
| <div class="line"><span class="comment"> */</span></div> |
| <div class="line"> </div> |
| <div class="line"><span class="preprocessor">#include <<a class="code" href="connection_8h.html">proton/connection.h</a>></span></div> |
| <div class="line"><span class="preprocessor">#include <<a class="code" href="condition_8h.html">proton/condition.h</a>></span></div> |
| <div class="line"><span class="preprocessor">#include <<a class="code" href="delivery_8h.html">proton/delivery.h</a>></span></div> |
| <div class="line"><span class="preprocessor">#include <<a class="code" href="link_8h.html">proton/link.h</a>></span></div> |
| <div class="line"><span class="preprocessor">#include <<a class="code" href="message_8h.html">proton/message.h</a>></span></div> |
| <div class="line"><span class="preprocessor">#include <<a class="code" href="proactor_8h.html">proton/proactor.h</a>></span></div> |
| <div class="line"><span class="preprocessor">#include <<a class="code" href="session_8h.html">proton/session.h</a>></span></div> |
| <div class="line"><span class="preprocessor">#include <<a class="code" href="transport_8h.html">proton/transport.h</a>></span></div> |
| <div class="line"> </div> |
| <div class="line"><span class="preprocessor">#include <stdio.h></span></div> |
| <div class="line"><span class="preprocessor">#include <stdlib.h></span></div> |
| <div class="line"> </div> |
| <div class="line"><span class="keyword">typedef</span> <span class="keyword">struct </span>app_data_t {</div> |
| <div class="line"> <span class="keyword">const</span> <span class="keywordtype">char</span> *host, *port;</div> |
| <div class="line"> <span class="keyword">const</span> <span class="keywordtype">char</span> *amqp_address;</div> |
| <div class="line"> <span class="keyword">const</span> <span class="keywordtype">char</span> *container_id;</div> |
| <div class="line"> <span class="keywordtype">int</span> message_count;</div> |
| <div class="line"> </div> |
| <div class="line"> <a class="code" href="group__proactor.html#gabba42c7929dfceb9d296535bad0c93dc">pn_proactor_t</a> *proactor;</div> |
| <div class="line"> <a class="code" href="group__message.html#gad9259fa9271e8844c8e05a7e8978e3b2">pn_message_t</a> *message;</div> |
| <div class="line"> <a name="_a0"></a><a class="code" href="group__api__types.html#structpn__rwbytes__t">pn_rwbytes_t</a> message_buffer;</div> |
| <div class="line"> <span class="keywordtype">int</span> sent;</div> |
| <div class="line"> <span class="keywordtype">int</span> acknowledged;</div> |
| <div class="line">} app_data_t;</div> |
| <div class="line"> </div> |
| <div class="line"><span class="keyword">static</span> <span class="keywordtype">int</span> exit_code = 0;</div> |
| <div class="line"> </div> |
| <div class="line"><span class="keyword">static</span> <span class="keywordtype">void</span> check_condition(<a class="code" href="group__event.html#ga87f3028b4888632bbd56fb71ac737ae8">pn_event_t</a> *e, <a class="code" href="group__condition.html#ga11eb7db7d2c205169fe3d47c996a95a5">pn_condition_t</a> *cond) {</div> |
| <div class="line"> <span class="keywordflow">if</span> (<a name="a1"></a><a class="code" href="group__condition.html#ga112611a7a4087e050c476a430db2cfb9">pn_condition_is_set</a>(cond)) {</div> |
| <div class="line"> fprintf(stderr, <span class="stringliteral">"%s: %s: %s\n"</span>, <a name="a2"></a><a class="code" href="group__event.html#ga3a85c046c11ce692c23b9566b022d54b">pn_event_type_name</a>(<a name="a3"></a><a class="code" href="group__event.html#gacaea54ca51885933b4987c131a3d1b0d">pn_event_type</a>(e)),</div> |
| <div class="line"> <a name="a4"></a><a class="code" href="group__condition.html#ga05b0d374d90f11d9ebbf818662569689">pn_condition_get_name</a>(cond), <a name="a5"></a><a class="code" href="group__condition.html#gaabebb65bfcf47b6f7d83ab6fb0153bb8">pn_condition_get_description</a>(cond));</div> |
| <div class="line"> <a name="a6"></a><a class="code" href="group__connection.html#gac25afdf810ad188b2cb3bf31a7482ca0">pn_connection_close</a>(<a name="a7"></a><a class="code" href="group__event.html#ga4f2c6a0fdf86a43e7e9874fcd2ccaf52">pn_event_connection</a>(e));</div> |
| <div class="line"> exit_code = 1;</div> |
| <div class="line"> }</div> |
| <div class="line">}</div> |
| <div class="line"> </div> |
| <div class="line"><span class="comment">/* Create a message with a map { "sequence" : number } encode it and return the encoded buffer. */</span></div> |
| <div class="line"><span class="keyword">static</span> <span class="keywordtype">void</span> send_message(app_data_t* app, <a class="code" href="group__link.html#ga89dad3aa7934329a7ff467c636687bc0">pn_link_t</a> *sender) {</div> |
| <div class="line"> <span class="comment">/* Construct a message with the map { "sequence": app.sent } */</span></div> |
| <div class="line"> <a class="code" href="group__data.html#ga5d6cf528776e8b6ad6d67caf095986bf">pn_data_t</a>* body;</div> |
| <div class="line"> <a name="a8"></a><a class="code" href="group__message.html#ga918c90a049d6b39041b0a2044f9048c6">pn_message_clear</a>(app->message);</div> |
| <div class="line"> body = <a name="a9"></a><a class="code" href="group__message.html#ga145c06edbcccfbe97136bfb5cb2b22b1">pn_message_body</a>(app->message);</div> |
| <div class="line"> <a name="a10"></a><a class="code" href="group__data.html#ga6cfb9e64b87f8d90a5b4237ca016a016">pn_data_put_int</a>(<a name="a11"></a><a class="code" href="group__message.html#ga296bd7b984c4b9cfabc297ab5badf7de">pn_message_id</a>(app->message), app->sent); <span class="comment">/* Set the message_id also */</span></div> |
| <div class="line"> <a name="a12"></a><a class="code" href="group__data.html#ga4c77c7a884bbd9a757b31060962d8543">pn_data_put_map</a>(body);</div> |
| <div class="line"> <a name="a13"></a><a class="code" href="group__data.html#ga1093449b80357dabf3f70a4bf804f4f7">pn_data_enter</a>(body);</div> |
| <div class="line"> <a name="a14"></a><a class="code" href="group__data.html#ga5dc9c9c7db2018d12753767c075cc6ee">pn_data_put_string</a>(body, <a name="a15"></a><a class="code" href="group__api__types.html#gab4f7e8d204246a3702c6e31a404b0edb">pn_bytes</a>(<span class="keyword">sizeof</span>(<span class="stringliteral">"sequence"</span>)-1, <span class="stringliteral">"sequence"</span>));</div> |
| <div class="line"> <a class="code" href="group__data.html#ga6cfb9e64b87f8d90a5b4237ca016a016">pn_data_put_int</a>(body, app->sent); <span class="comment">/* The sequence number */</span></div> |
| <div class="line"> <a name="a16"></a><a class="code" href="group__data.html#ga67a656cbdbf0a47a223ff1c8507ecf48">pn_data_exit</a>(body);</div> |
| <div class="line"> <span class="keywordflow">if</span> (<a name="a17"></a><a class="code" href="group__message.html#ga86cd32577f0e78bab29bd0e49869f0b5">pn_message_send</a>(app->message, sender, &app->message_buffer) < 0) {</div> |
| <div class="line"> fprintf(stderr, <span class="stringliteral">"error sending message: %s\n"</span>, <a name="a18"></a><a class="code" href="group__error.html#ga67cbe6ebb143370e0604f5b84d716c56">pn_error_text</a>(<a name="a19"></a><a class="code" href="group__message.html#ga9ad09178e7682efde76e2d39f352dfe8">pn_message_error</a>(app->message)));</div> |
| <div class="line"> exit(1);</div> |
| <div class="line"> }</div> |
| <div class="line">}</div> |
| <div class="line"> </div> |
| <div class="line"><span class="comment">/* Returns true to continue, false if finished */</span></div> |
| <div class="line"><span class="keyword">static</span> <span class="keywordtype">bool</span> handle(app_data_t* app, <a class="code" href="group__event.html#ga87f3028b4888632bbd56fb71ac737ae8">pn_event_t</a>* event) {</div> |
| <div class="line"> <span class="keywordflow">switch</span> (<a class="code" href="group__event.html#gacaea54ca51885933b4987c131a3d1b0d">pn_event_type</a>(event)) {</div> |
| <div class="line"> </div> |
| <div class="line"> <span class="keywordflow">case</span> <a name="a20"></a><a class="code" href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa182e571a0310028514bce66a41063a6e">PN_CONNECTION_INIT</a>: {</div> |
| <div class="line"> <a class="code" href="group__connection.html#ga886351d81ff3a977a284a206526c5aff">pn_connection_t</a>* c = <a class="code" href="group__event.html#ga4f2c6a0fdf86a43e7e9874fcd2ccaf52">pn_event_connection</a>(event);</div> |
| <div class="line"> <a class="code" href="group__session.html#ga38ccb93b8f5c2892adafce5d5f0fbcd9">pn_session_t</a>* s = <a name="a21"></a><a class="code" href="group__session.html#ga1feff407b8fe308a14f283d193246f3c">pn_session</a>(<a class="code" href="group__event.html#ga4f2c6a0fdf86a43e7e9874fcd2ccaf52">pn_event_connection</a>(event));</div> |
| <div class="line"> <a name="a22"></a><a class="code" href="group__connection.html#gac4a34e0b1fc5665b26ae47a80a422a1a">pn_connection_set_container</a>(c, app->container_id);</div> |
| <div class="line"> <a name="a23"></a><a class="code" href="group__connection.html#ga4c0a2d40bb95202477ccc5aaa7456670">pn_connection_open</a>(c);</div> |
| <div class="line"> <a name="a24"></a><a class="code" href="group__session.html#ga2b345eada2c15249caaefaa894d1aae3">pn_session_open</a>(s);</div> |
| <div class="line"> {</div> |
| <div class="line"> <a class="code" href="group__link.html#ga89dad3aa7934329a7ff467c636687bc0">pn_link_t</a>* l = <a name="a25"></a><a class="code" href="group__link.html#ga469bef2e81c53e85899ffbb277616a8c">pn_sender</a>(s, <span class="stringliteral">"my_sender"</span>);</div> |
| <div class="line"> <a name="a26"></a><a class="code" href="group__terminus.html#ga0603db45f03fcef0ef18f4f89ebf3de1">pn_terminus_set_address</a>(<a name="a27"></a><a class="code" href="group__link.html#ga997c85388b9fb30151ea3b40b946e958">pn_link_target</a>(l), app->amqp_address);</div> |
| <div class="line"> <a name="a28"></a><a class="code" href="group__link.html#gaabaca3f5d03970a122240eebc588add6">pn_link_open</a>(l);</div> |
| <div class="line"> <span class="keywordflow">break</span>;</div> |
| <div class="line"> }</div> |
| <div class="line"> }</div> |
| <div class="line"> </div> |
| <div class="line"> <span class="keywordflow">case</span> <a name="a29"></a><a class="code" href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa4eaecc54c07cdc9b0df7b1d536a7dc3f">PN_LINK_FLOW</a>: {</div> |
| <div class="line"> <span class="comment">/* The peer has given us some credit, now we can send messages */</span></div> |
| <div class="line"> <a class="code" href="group__link.html#ga89dad3aa7934329a7ff467c636687bc0">pn_link_t</a> *sender = <a name="a30"></a><a class="code" href="group__event.html#ga75f230ef55f03a1f943df79279f8d111">pn_event_link</a>(event);</div> |
| <div class="line"> <span class="keywordflow">while</span> (<a name="a31"></a><a class="code" href="group__link.html#ga55428637f3b8c446efd5fea3f26c932d">pn_link_credit</a>(sender) > 0 && app->sent < app->message_count) {</div> |
| <div class="line"> ++app->sent;</div> |
| <div class="line"> <span class="comment">/* Use sent counter as unique delivery tag. */</span></div> |
| <div class="line"> <a name="a32"></a><a class="code" href="group__delivery.html#ga6a7ef2e317b4ed292cafbb358f0ba6ad">pn_delivery</a>(sender, <a name="a33"></a><a class="code" href="group__delivery.html#gaea4522ac1fef9228fb6c743d2a36fd27">pn_dtag</a>((<span class="keyword">const</span> <span class="keywordtype">char</span> *)&app->sent, <span class="keyword">sizeof</span>(app->sent)));</div> |
| <div class="line"> send_message(app, sender);</div> |
| <div class="line"> }</div> |
| <div class="line"> <span class="keywordflow">break</span>;</div> |
| <div class="line"> }</div> |
| <div class="line"> </div> |
| <div class="line"> <span class="keywordflow">case</span> <a name="a34"></a><a class="code" href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa70bbfc163d85732b5652dc70fb3330fe">PN_DELIVERY</a>: {</div> |
| <div class="line"> <span class="comment">/* We received acknowledgement from the peer that a message was delivered. */</span></div> |
| <div class="line"> <a class="code" href="group__delivery.html#gacdfce854066c0a4ff4db9f9a0478f340">pn_delivery_t</a>* d = <a name="a35"></a><a class="code" href="group__event.html#ga10fa6f53bdabe0851ebb2d8a0bf6a52c">pn_event_delivery</a>(event);</div> |
| <div class="line"> <span class="keywordflow">if</span> (<a name="a36"></a><a class="code" href="group__delivery.html#gac1c3f2e7217b51f0e2f8c4264b0689d1">pn_delivery_remote_state</a>(d) == <a name="a37"></a><a class="code" href="group__delivery.html#gac64952b813a707586c6b3898e09552e4">PN_ACCEPTED</a>) {</div> |
| <div class="line"> <span class="keywordflow">if</span> (++app->acknowledged == app->message_count) {</div> |
| <div class="line"> printf(<span class="stringliteral">"%d messages sent and acknowledged\n"</span>, app->acknowledged);</div> |
| <div class="line"> <a class="code" href="group__connection.html#gac25afdf810ad188b2cb3bf31a7482ca0">pn_connection_close</a>(<a class="code" href="group__event.html#ga4f2c6a0fdf86a43e7e9874fcd2ccaf52">pn_event_connection</a>(event));</div> |
| <div class="line"> <span class="comment">/* Continue handling events till we receive TRANSPORT_CLOSED */</span></div> |
| <div class="line"> }</div> |
| <div class="line"> } <span class="keywordflow">else</span> {</div> |
| <div class="line"> fprintf(stderr, <span class="stringliteral">"unexpected delivery state %d\n"</span>, (<span class="keywordtype">int</span>)<a class="code" href="group__delivery.html#gac1c3f2e7217b51f0e2f8c4264b0689d1">pn_delivery_remote_state</a>(d));</div> |
| <div class="line"> <a class="code" href="group__connection.html#gac25afdf810ad188b2cb3bf31a7482ca0">pn_connection_close</a>(<a class="code" href="group__event.html#ga4f2c6a0fdf86a43e7e9874fcd2ccaf52">pn_event_connection</a>(event));</div> |
| <div class="line"> exit_code=1;</div> |
| <div class="line"> }</div> |
| <div class="line"> <span class="keywordflow">break</span>;</div> |
| <div class="line"> }</div> |
| <div class="line"> </div> |
| <div class="line"> <span class="keywordflow">case</span> <a name="a38"></a><a class="code" href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa1ca722ce3c0b2c13a33636cded8430ba">PN_TRANSPORT_CLOSED</a>:</div> |
| <div class="line"> check_condition(event, <a name="a39"></a><a class="code" href="group__transport.html#gac458d9fdb684f9501e89b96fc51f5c34">pn_transport_condition</a>(<a name="a40"></a><a class="code" href="group__event.html#ga14525ae84870388141898bbf57f2b151">pn_event_transport</a>(event)));</div> |
| <div class="line"> <span class="keywordflow">break</span>;</div> |
| <div class="line"> </div> |
| <div class="line"> <span class="keywordflow">case</span> <a name="a41"></a><a class="code" href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa1252529cf9f03d214c9b4fea5cf11b2f">PN_CONNECTION_REMOTE_CLOSE</a>:</div> |
| <div class="line"> check_condition(event, <a name="a42"></a><a class="code" href="group__connection.html#ga72a362389b99d8e891bf2e4fb4290754">pn_connection_remote_condition</a>(<a class="code" href="group__event.html#ga4f2c6a0fdf86a43e7e9874fcd2ccaf52">pn_event_connection</a>(event)));</div> |
| <div class="line"> <a class="code" href="group__connection.html#gac25afdf810ad188b2cb3bf31a7482ca0">pn_connection_close</a>(<a class="code" href="group__event.html#ga4f2c6a0fdf86a43e7e9874fcd2ccaf52">pn_event_connection</a>(event));</div> |
| <div class="line"> <span class="keywordflow">break</span>;</div> |
| <div class="line"> </div> |
| <div class="line"> <span class="keywordflow">case</span> <a name="a43"></a><a class="code" href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa3410075b825c59b8f4efdcddf5a5b135">PN_SESSION_REMOTE_CLOSE</a>:</div> |
| <div class="line"> check_condition(event, <a name="a44"></a><a class="code" href="group__session.html#gae21b3fda1567bad1f8a8fe162ffaeece">pn_session_remote_condition</a>(<a name="a45"></a><a class="code" href="group__event.html#gaf4af0bfbe0e0a8e432f0e803df14ecb5">pn_event_session</a>(event)));</div> |
| <div class="line"> <a class="code" href="group__connection.html#gac25afdf810ad188b2cb3bf31a7482ca0">pn_connection_close</a>(<a class="code" href="group__event.html#ga4f2c6a0fdf86a43e7e9874fcd2ccaf52">pn_event_connection</a>(event));</div> |
| <div class="line"> <span class="keywordflow">break</span>;</div> |
| <div class="line"> </div> |
| <div class="line"> <span class="keywordflow">case</span> <a name="a46"></a><a class="code" href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa1153f0108be071c31210dd1cd3e40a1f">PN_LINK_REMOTE_CLOSE</a>:</div> |
| <div class="line"> <span class="keywordflow">case</span> <a name="a47"></a><a class="code" href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa5a84b68a2bd5ca705187381a785121d2">PN_LINK_REMOTE_DETACH</a>:</div> |
| <div class="line"> check_condition(event, <a name="a48"></a><a class="code" href="group__link.html#ga97dc5133125c9b7e4afbb1b76e6efe7b">pn_link_remote_condition</a>(<a class="code" href="group__event.html#ga75f230ef55f03a1f943df79279f8d111">pn_event_link</a>(event)));</div> |
| <div class="line"> <a class="code" href="group__connection.html#gac25afdf810ad188b2cb3bf31a7482ca0">pn_connection_close</a>(<a class="code" href="group__event.html#ga4f2c6a0fdf86a43e7e9874fcd2ccaf52">pn_event_connection</a>(event));</div> |
| <div class="line"> <span class="keywordflow">break</span>;</div> |
| <div class="line"> </div> |
| <div class="line"> <span class="keywordflow">case</span> <a name="a49"></a><a class="code" href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa894e93f167ef39e28a07c9cdf6b1181b">PN_PROACTOR_INACTIVE</a>:</div> |
| <div class="line"> <span class="keywordflow">return</span> <span class="keyword">false</span>;</div> |
| <div class="line"> </div> |
| <div class="line"> <span class="keywordflow">default</span>: <span class="keywordflow">break</span>;</div> |
| <div class="line"> }</div> |
| <div class="line"> <span class="keywordflow">return</span> <span class="keyword">true</span>;</div> |
| <div class="line">}</div> |
| <div class="line"> </div> |
| <div class="line"><span class="keywordtype">void</span> run(app_data_t *app) {</div> |
| <div class="line"> <span class="comment">/* Loop and handle events */</span></div> |
| <div class="line"> <span class="keywordflow">do</span> {</div> |
| <div class="line"> <a class="code" href="group__proactor.html#ga6bc581dfeaa8e8d46d07d37229d565c9">pn_event_batch_t</a> *events = <a name="a50"></a><a class="code" href="group__proactor.html#ga2b66a46f3e557010ec61bd105326753d">pn_proactor_wait</a>(app->proactor);</div> |
| <div class="line"> <a class="code" href="group__event.html#ga87f3028b4888632bbd56fb71ac737ae8">pn_event_t</a> *e;</div> |
| <div class="line"> <span class="keywordflow">for</span> (e = <a name="a51"></a><a class="code" href="group__proactor.html#ga6dafc0823e7f5a815600d0c9738555f5">pn_event_batch_next</a>(events); e; e = <a class="code" href="group__proactor.html#ga6dafc0823e7f5a815600d0c9738555f5">pn_event_batch_next</a>(events)) {</div> |
| <div class="line"> <span class="keywordflow">if</span> (!handle(app, e)) {</div> |
| <div class="line"> <span class="keywordflow">return</span>;</div> |
| <div class="line"> }</div> |
| <div class="line"> }</div> |
| <div class="line"> <a name="a52"></a><a class="code" href="group__proactor.html#gade60ff2292b74841766f953b906285c0">pn_proactor_done</a>(app->proactor, events);</div> |
| <div class="line"> } <span class="keywordflow">while</span>(<span class="keyword">true</span>);</div> |
| <div class="line">}</div> |
| <div class="line"> </div> |
| <div class="line"><span class="keywordtype">int</span> main(<span class="keywordtype">int</span> argc, <span class="keywordtype">char</span> **argv) {</div> |
| <div class="line"> <span class="keyword">struct </span>app_data_t app = {0};</div> |
| <div class="line"> <span class="keywordtype">char</span> addr[<a name="a53"></a><a class="code" href="group__proactor.html#ga29ae114b42fb797c103dc9883ebcb256">PN_MAX_ADDR</a>];</div> |
| <div class="line"> </div> |
| <div class="line"> app.container_id = argv[0]; <span class="comment">/* Should be unique */</span></div> |
| <div class="line"> app.host = (argc > 1) ? argv[1] : <span class="stringliteral">""</span>;</div> |
| <div class="line"> app.port = (argc > 2) ? argv[2] : <span class="stringliteral">"amqp"</span>;</div> |
| <div class="line"> app.amqp_address = (argc > 3) ? argv[3] : <span class="stringliteral">"examples"</span>;</div> |
| <div class="line"> app.message_count = (argc > 4) ? atoi(argv[4]) : 10;</div> |
| <div class="line"> app.message = <a name="a54"></a><a class="code" href="group__message.html#gaaf98d84b9ddc1c6537dddd4c9c5b979e">pn_message</a>();</div> |
| <div class="line"> </div> |
| <div class="line"> app.proactor = <a name="a55"></a><a class="code" href="group__proactor.html#gac2a925b3de00efd8cd40fa9920169554">pn_proactor</a>();</div> |
| <div class="line"> <a name="a56"></a><a class="code" href="group__proactor.html#gaf67a7642c9003b36255b58776b494c96">pn_proactor_addr</a>(addr, <span class="keyword">sizeof</span>(addr), app.host, app.port);</div> |
| <div class="line"> <a name="a57"></a><a class="code" href="group__proactor.html#gabb093e51449351cf5530bb300bd67ba1">pn_proactor_connect2</a>(app.proactor, NULL, NULL, addr);</div> |
| <div class="line"> run(&app);</div> |
| <div class="line"> <a name="a58"></a><a class="code" href="group__proactor.html#ga5260c2653d4af5eb2f1c8c6190e9d6cf">pn_proactor_free</a>(app.proactor);</div> |
| <div class="line"> free(app.message_buffer.start);</div> |
| <div class="line"> <a name="a59"></a><a class="code" href="group__message.html#ga69aadbc3a80f1fa16962774e711392f8">pn_message_free</a>(app.message);</div> |
| <div class="line"> <span class="keywordflow">return</span> exit_code;</div> |
| <div class="line">}</div> |
| </div><!-- fragment --> </div><!-- contents --> |
| </div><!-- doc-content --> |
| <div class="ttc" id="agroup__data_html_ga4c77c7a884bbd9a757b31060962d8543"><div class="ttname"><a href="group__data.html#ga4c77c7a884bbd9a757b31060962d8543">pn_data_put_map</a></div><div class="ttdeci">int pn_data_put_map(pn_data_t *data)</div><div class="ttdoc">Puts an empty map value into a pn_data_t.</div></div> |
| <div class="ttc" id="agroup__connection_html_ga72a362389b99d8e891bf2e4fb4290754"><div class="ttname"><a href="group__connection.html#ga72a362389b99d8e891bf2e4fb4290754">pn_connection_remote_condition</a></div><div class="ttdeci">pn_condition_t * pn_connection_remote_condition(pn_connection_t *connection)</div><div class="ttdoc">Get the remote condition associated with the connection endpoint.</div></div> |
| <div class="ttc" id="agroup__proactor_html_ga6bc581dfeaa8e8d46d07d37229d565c9"><div class="ttname"><a href="group__proactor.html#ga6bc581dfeaa8e8d46d07d37229d565c9">pn_event_batch_t</a></div><div class="ttdeci">struct pn_event_batch_t pn_event_batch_t</div><div class="ttdoc">A batch of events that must be handled in sequence.</div><div class="ttdef"><b>Definition:</b> types.h:462</div></div> |
| <div class="ttc" id="agroup__link_html_gaabaca3f5d03970a122240eebc588add6"><div class="ttname"><a href="group__link.html#gaabaca3f5d03970a122240eebc588add6">pn_link_open</a></div><div class="ttdeci">void pn_link_open(pn_link_t *link)</div><div class="ttdoc">Open a link.</div></div> |
| <div class="ttc" id="agroup__proactor_html_ga2b66a46f3e557010ec61bd105326753d"><div class="ttname"><a href="group__proactor.html#ga2b66a46f3e557010ec61bd105326753d">pn_proactor_wait</a></div><div class="ttdeci">PNP_EXTERN pn_event_batch_t * pn_proactor_wait(pn_proactor_t *proactor)</div><div class="ttdoc">Wait until there are Proactor events to handle.</div></div> |
| <div class="ttc" id="agroup__event_html_ga87f3028b4888632bbd56fb71ac737ae8"><div class="ttname"><a href="group__event.html#ga87f3028b4888632bbd56fb71ac737ae8">pn_event_t</a></div><div class="ttdeci">struct pn_event_t pn_event_t</div><div class="ttdoc">Notification of a state change in the protocol engine.</div><div class="ttdef"><b>Definition:</b> event.h:75</div></div> |
| <div class="ttc" id="agroup__proactor_html_ga6dafc0823e7f5a815600d0c9738555f5"><div class="ttname"><a href="group__proactor.html#ga6dafc0823e7f5a815600d0c9738555f5">pn_event_batch_next</a></div><div class="ttdeci">PNP_EXTERN pn_event_t * pn_event_batch_next(pn_event_batch_t *batch)</div><div class="ttdoc">Remove the next event from the batch and return it.</div></div> |
| <div class="ttc" id="agroup__terminus_html_ga0603db45f03fcef0ef18f4f89ebf3de1"><div class="ttname"><a href="group__terminus.html#ga0603db45f03fcef0ef18f4f89ebf3de1">pn_terminus_set_address</a></div><div class="ttdeci">int pn_terminus_set_address(pn_terminus_t *terminus, const char *address)</div><div class="ttdoc">Set the address of a terminus object.</div></div> |
| <div class="ttc" id="agroup__message_html_ga69aadbc3a80f1fa16962774e711392f8"><div class="ttname"><a href="group__message.html#ga69aadbc3a80f1fa16962774e711392f8">pn_message_free</a></div><div class="ttdeci">void pn_message_free(pn_message_t *msg)</div><div class="ttdoc">Free a previously constructed pn_message_t.</div></div> |
| <div class="ttc" id="agroup__event_html_gga4876e2eed24a4d4e4c52b99842103cdaa70bbfc163d85732b5652dc70fb3330fe"><div class="ttname"><a href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa70bbfc163d85732b5652dc70fb3330fe">PN_DELIVERY</a></div><div class="ttdeci">@ PN_DELIVERY</div><div class="ttdoc">A delivery has been created or updated.</div><div class="ttdef"><b>Definition:</b> event.h:254</div></div> |
| <div class="ttc" id="agroup__event_html_gga4876e2eed24a4d4e4c52b99842103cdaa1153f0108be071c31210dd1cd3e40a1f"><div class="ttname"><a href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa1153f0108be071c31210dd1cd3e40a1f">PN_LINK_REMOTE_CLOSE</a></div><div class="ttdeci">@ PN_LINK_REMOTE_CLOSE</div><div class="ttdoc">The remote endpoint has closed the link.</div><div class="ttdef"><b>Definition:</b> event.h:223</div></div> |
| <div class="ttc" id="alink_8h_html"><div class="ttname"><a href="link_8h.html">link.h</a></div><div class="ttdoc">A channel for transferring messages.</div></div> |
| <div class="ttc" id="agroup__event_html_gga4876e2eed24a4d4e4c52b99842103cdaa1ca722ce3c0b2c13a33636cded8430ba"><div class="ttname"><a href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa1ca722ce3c0b2c13a33636cded8430ba">PN_TRANSPORT_CLOSED</a></div><div class="ttdeci">@ PN_TRANSPORT_CLOSED</div><div class="ttdoc">Indicates that the both the head and tail of the transport are closed.</div><div class="ttdef"><b>Definition:</b> event.h:295</div></div> |
| <div class="ttc" id="agroup__condition_html_ga05b0d374d90f11d9ebbf818662569689"><div class="ttname"><a href="group__condition.html#ga05b0d374d90f11d9ebbf818662569689">pn_condition_get_name</a></div><div class="ttdeci">const char * pn_condition_get_name(pn_condition_t *condition)</div><div class="ttdoc">Returns the name associated with the exceptional condition, or NULL if there is no conditional inform...</div></div> |
| <div class="ttc" id="agroup__event_html_gga4876e2eed24a4d4e4c52b99842103cdaa894e93f167ef39e28a07c9cdf6b1181b"><div class="ttname"><a href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa894e93f167ef39e28a07c9cdf6b1181b">PN_PROACTOR_INACTIVE</a></div><div class="ttdeci">@ PN_PROACTOR_INACTIVE</div><div class="ttdoc">The proactor has become inactive: all listeners and connections were closed and the timeout (if set) ...</div><div class="ttdef"><b>Definition:</b> event.h:344</div></div> |
| <div class="ttc" id="agroup__message_html_ga296bd7b984c4b9cfabc297ab5badf7de"><div class="ttname"><a href="group__message.html#ga296bd7b984c4b9cfabc297ab5badf7de">pn_message_id</a></div><div class="ttdeci">pn_data_t * pn_message_id(pn_message_t *msg)</div><div class="ttdoc">Get/set the id for a message.</div></div> |
| <div class="ttc" id="agroup__session_html_ga2b345eada2c15249caaefaa894d1aae3"><div class="ttname"><a href="group__session.html#ga2b345eada2c15249caaefaa894d1aae3">pn_session_open</a></div><div class="ttdeci">void pn_session_open(pn_session_t *session)</div><div class="ttdoc">Open a session.</div></div> |
| <div class="ttc" id="agroup__link_html_ga97dc5133125c9b7e4afbb1b76e6efe7b"><div class="ttname"><a href="group__link.html#ga97dc5133125c9b7e4afbb1b76e6efe7b">pn_link_remote_condition</a></div><div class="ttdeci">pn_condition_t * pn_link_remote_condition(pn_link_t *link)</div><div class="ttdoc">Get the remote condition associated with a link endpoint.</div></div> |
| <div class="ttc" id="agroup__session_html_ga1feff407b8fe308a14f283d193246f3c"><div class="ttname"><a href="group__session.html#ga1feff407b8fe308a14f283d193246f3c">pn_session</a></div><div class="ttdeci">pn_session_t * pn_session(pn_connection_t *connection)</div><div class="ttdoc">Factory for creating a new session on a given connection object.</div></div> |
| <div class="ttc" id="agroup__link_html_ga997c85388b9fb30151ea3b40b946e958"><div class="ttname"><a href="group__link.html#ga997c85388b9fb30151ea3b40b946e958">pn_link_target</a></div><div class="ttdeci">pn_terminus_t * pn_link_target(pn_link_t *link)</div><div class="ttdoc">Access the locally defined target definition for a link.</div></div> |
| <div class="ttc" id="agroup__proactor_html_gabb093e51449351cf5530bb300bd67ba1"><div class="ttname"><a href="group__proactor.html#gabb093e51449351cf5530bb300bd67ba1">pn_proactor_connect2</a></div><div class="ttdeci">PNP_EXTERN void pn_proactor_connect2(pn_proactor_t *proactor, pn_connection_t *connection, pn_transport_t *transport, const char *addr)</div><div class="ttdoc">Connect transport to addr and bind to connection.</div></div> |
| <div class="ttc" id="agroup__message_html_gad9259fa9271e8844c8e05a7e8978e3b2"><div class="ttname"><a href="group__message.html#gad9259fa9271e8844c8e05a7e8978e3b2">pn_message_t</a></div><div class="ttdeci">struct pn_message_t pn_message_t</div><div class="ttdoc">An AMQP Message object.</div><div class="ttdef"><b>Definition:</b> message.h:51</div></div> |
| <div class="ttc" id="agroup__condition_html_gaabebb65bfcf47b6f7d83ab6fb0153bb8"><div class="ttname"><a href="group__condition.html#gaabebb65bfcf47b6f7d83ab6fb0153bb8">pn_condition_get_description</a></div><div class="ttdeci">const char * pn_condition_get_description(pn_condition_t *condition)</div><div class="ttdoc">Gets the description associated with the exceptional condition.</div></div> |
| <div class="ttc" id="agroup__message_html_ga918c90a049d6b39041b0a2044f9048c6"><div class="ttname"><a href="group__message.html#ga918c90a049d6b39041b0a2044f9048c6">pn_message_clear</a></div><div class="ttdeci">void pn_message_clear(pn_message_t *msg)</div><div class="ttdoc">Clears the content of a pn_message_t.</div></div> |
| <div class="ttc" id="agroup__message_html_gaaf98d84b9ddc1c6537dddd4c9c5b979e"><div class="ttname"><a href="group__message.html#gaaf98d84b9ddc1c6537dddd4c9c5b979e">pn_message</a></div><div class="ttdeci">pn_message_t * pn_message(void)</div><div class="ttdoc">Construct a new pn_message_t.</div></div> |
| <div class="ttc" id="agroup__api__types_html_structpn__rwbytes__t"><div class="ttname"><a href="group__api__types.html#structpn__rwbytes__t">pn_rwbytes_t</a></div><div class="ttdoc">A non-const byte buffer.</div><div class="ttdef"><b>Definition:</b> types.h:235</div></div> |
| <div class="ttc" id="acondition_8h_html"><div class="ttname"><a href="condition_8h.html">condition.h</a></div><div class="ttdoc">An endpoint error state.</div></div> |
| <div class="ttc" id="agroup__proactor_html_gabba42c7929dfceb9d296535bad0c93dc"><div class="ttname"><a href="group__proactor.html#gabba42c7929dfceb9d296535bad0c93dc">pn_proactor_t</a></div><div class="ttdeci">struct pn_proactor_t pn_proactor_t</div><div class="ttdoc">A harness for multithreaded IO.</div><div class="ttdef"><b>Definition:</b> types.h:442</div></div> |
| <div class="ttc" id="agroup__event_html_ga10fa6f53bdabe0851ebb2d8a0bf6a52c"><div class="ttname"><a href="group__event.html#ga10fa6f53bdabe0851ebb2d8a0bf6a52c">pn_event_delivery</a></div><div class="ttdeci">pn_delivery_t * pn_event_delivery(pn_event_t *event)</div><div class="ttdoc">Get the delivery associated with an event.</div></div> |
| <div class="ttc" id="amessage_8h_html"><div class="ttname"><a href="message_8h.html">message.h</a></div><div class="ttdoc">A mutable holder of application content.</div></div> |
| <div class="ttc" id="agroup__event_html_gga4876e2eed24a4d4e4c52b99842103cdaa182e571a0310028514bce66a41063a6e"><div class="ttname"><a href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa182e571a0310028514bce66a41063a6e">PN_CONNECTION_INIT</a></div><div class="ttdeci">@ PN_CONNECTION_INIT</div><div class="ttdoc">The connection has been created.</div><div class="ttdef"><b>Definition:</b> event.h:113</div></div> |
| <div class="ttc" id="agroup__proactor_html_gac2a925b3de00efd8cd40fa9920169554"><div class="ttname"><a href="group__proactor.html#gac2a925b3de00efd8cd40fa9920169554">pn_proactor</a></div><div class="ttdeci">PNP_EXTERN pn_proactor_t * pn_proactor(void)</div><div class="ttdoc">Create a proactor.</div></div> |
| <div class="ttc" id="agroup__delivery_html_gacdfce854066c0a4ff4db9f9a0478f340"><div class="ttname"><a href="group__delivery.html#gacdfce854066c0a4ff4db9f9a0478f340">pn_delivery_t</a></div><div class="ttdeci">struct pn_delivery_t pn_delivery_t</div><div class="ttdoc">An AMQP Delivery object.</div><div class="ttdef"><b>Definition:</b> types.h:405</div></div> |
| <div class="ttc" id="agroup__data_html_ga5d6cf528776e8b6ad6d67caf095986bf"><div class="ttname"><a href="group__data.html#ga5d6cf528776e8b6ad6d67caf095986bf">pn_data_t</a></div><div class="ttdeci">struct pn_data_t pn_data_t</div><div class="ttdoc">An AMQP Data object.</div><div class="ttdef"><b>Definition:</b> codec.h:364</div></div> |
| <div class="ttc" id="agroup__data_html_ga6cfb9e64b87f8d90a5b4237ca016a016"><div class="ttname"><a href="group__data.html#ga6cfb9e64b87f8d90a5b4237ca016a016">pn_data_put_int</a></div><div class="ttdeci">int pn_data_put_int(pn_data_t *data, int32_t i)</div><div class="ttdoc">Puts a PN_INT value.</div></div> |
| <div class="ttc" id="agroup__condition_html_ga11eb7db7d2c205169fe3d47c996a95a5"><div class="ttname"><a href="group__condition.html#ga11eb7db7d2c205169fe3d47c996a95a5">pn_condition_t</a></div><div class="ttdeci">struct pn_condition_t pn_condition_t</div><div class="ttdoc">An AMQP Condition object.</div><div class="ttdef"><b>Definition:</b> condition.h:64</div></div> |
| <div class="ttc" id="agroup__delivery_html_gac1c3f2e7217b51f0e2f8c4264b0689d1"><div class="ttname"><a href="group__delivery.html#gac1c3f2e7217b51f0e2f8c4264b0689d1">pn_delivery_remote_state</a></div><div class="ttdeci">uint64_t pn_delivery_remote_state(pn_delivery_t *delivery)</div><div class="ttdoc">Get the remote disposition state for a delivery.</div></div> |
| <div class="ttc" id="agroup__data_html_ga1093449b80357dabf3f70a4bf804f4f7"><div class="ttname"><a href="group__data.html#ga1093449b80357dabf3f70a4bf804f4f7">pn_data_enter</a></div><div class="ttdeci">bool pn_data_enter(pn_data_t *data)</div><div class="ttdoc">Sets the parent node to the current node and clears the current node.</div></div> |
| <div class="ttc" id="agroup__event_html_gga4876e2eed24a4d4e4c52b99842103cdaa5a84b68a2bd5ca705187381a785121d2"><div class="ttname"><a href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa5a84b68a2bd5ca705187381a785121d2">PN_LINK_REMOTE_DETACH</a></div><div class="ttdeci">@ PN_LINK_REMOTE_DETACH</div><div class="ttdoc">The remote endpoint has detached the link.</div><div class="ttdef"><b>Definition:</b> event.h:235</div></div> |
| <div class="ttc" id="agroup__message_html_ga86cd32577f0e78bab29bd0e49869f0b5"><div class="ttname"><a href="group__message.html#ga86cd32577f0e78bab29bd0e49869f0b5">pn_message_send</a></div><div class="ttdeci">ssize_t pn_message_send(pn_message_t *msg, pn_link_t *sender, pn_rwbytes_t *buf)</div><div class="ttdoc">Unsettled API</div></div> |
| <div class="ttc" id="agroup__message_html_ga9ad09178e7682efde76e2d39f352dfe8"><div class="ttname"><a href="group__message.html#ga9ad09178e7682efde76e2d39f352dfe8">pn_message_error</a></div><div class="ttdeci">pn_error_t * pn_message_error(pn_message_t *msg)</div><div class="ttdoc">Access the error information for a message.</div></div> |
| <div class="ttc" id="agroup__event_html_ga4f2c6a0fdf86a43e7e9874fcd2ccaf52"><div class="ttname"><a href="group__event.html#ga4f2c6a0fdf86a43e7e9874fcd2ccaf52">pn_event_connection</a></div><div class="ttdeci">pn_connection_t * pn_event_connection(pn_event_t *event)</div><div class="ttdoc">Get the connection associated with an event.</div></div> |
| <div class="ttc" id="agroup__event_html_gga4876e2eed24a4d4e4c52b99842103cdaa1252529cf9f03d214c9b4fea5cf11b2f"><div class="ttname"><a href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa1252529cf9f03d214c9b4fea5cf11b2f">PN_CONNECTION_REMOTE_CLOSE</a></div><div class="ttdeci">@ PN_CONNECTION_REMOTE_CLOSE</div><div class="ttdoc">The remote endpoint has closed the connection.</div><div class="ttdef"><b>Definition:</b> event.h:149</div></div> |
| <div class="ttc" id="agroup__condition_html_ga112611a7a4087e050c476a430db2cfb9"><div class="ttname"><a href="group__condition.html#ga112611a7a4087e050c476a430db2cfb9">pn_condition_is_set</a></div><div class="ttdeci">bool pn_condition_is_set(pn_condition_t *condition)</div><div class="ttdoc">Returns true if the condition object is holding some information, i.e.</div></div> |
| <div class="ttc" id="agroup__connection_html_ga886351d81ff3a977a284a206526c5aff"><div class="ttname"><a href="group__connection.html#ga886351d81ff3a977a284a206526c5aff">pn_connection_t</a></div><div class="ttdeci">struct pn_connection_t pn_connection_t</div><div class="ttdoc">An AMQP Connection object.</div><div class="ttdef"><b>Definition:</b> types.h:285</div></div> |
| <div class="ttc" id="agroup__link_html_ga469bef2e81c53e85899ffbb277616a8c"><div class="ttname"><a href="group__link.html#ga469bef2e81c53e85899ffbb277616a8c">pn_sender</a></div><div class="ttdeci">pn_link_t * pn_sender(pn_session_t *session, const char *name)</div><div class="ttdoc">Construct a new sender on a session.</div></div> |
| <div class="ttc" id="agroup__event_html_gga4876e2eed24a4d4e4c52b99842103cdaa3410075b825c59b8f4efdcddf5a5b135"><div class="ttname"><a href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa3410075b825c59b8f4efdcddf5a5b135">PN_SESSION_REMOTE_CLOSE</a></div><div class="ttdeci">@ PN_SESSION_REMOTE_CLOSE</div><div class="ttdoc">The remote endpoint has closed the session.</div><div class="ttdef"><b>Definition:</b> event.h:186</div></div> |
| <div class="ttc" id="agroup__connection_html_gac25afdf810ad188b2cb3bf31a7482ca0"><div class="ttname"><a href="group__connection.html#gac25afdf810ad188b2cb3bf31a7482ca0">pn_connection_close</a></div><div class="ttdeci">void pn_connection_close(pn_connection_t *connection)</div><div class="ttdoc">Close a connection.</div></div> |
| <div class="ttc" id="agroup__event_html_gaf4af0bfbe0e0a8e432f0e803df14ecb5"><div class="ttname"><a href="group__event.html#gaf4af0bfbe0e0a8e432f0e803df14ecb5">pn_event_session</a></div><div class="ttdeci">pn_session_t * pn_event_session(pn_event_t *event)</div><div class="ttdoc">Get the session associated with an event.</div></div> |
| <div class="ttc" id="agroup__proactor_html_ga5260c2653d4af5eb2f1c8c6190e9d6cf"><div class="ttname"><a href="group__proactor.html#ga5260c2653d4af5eb2f1c8c6190e9d6cf">pn_proactor_free</a></div><div class="ttdeci">PNP_EXTERN void pn_proactor_free(pn_proactor_t *proactor)</div><div class="ttdoc">Free the proactor.</div></div> |
| <div class="ttc" id="aproactor_8h_html"><div class="ttname"><a href="proactor_8h.html">proactor.h</a></div><div class="ttdoc">Unsettled API - An API for multithreaded IO.</div></div> |
| <div class="ttc" id="aconnection_8h_html"><div class="ttname"><a href="connection_8h.html">connection.h</a></div><div class="ttdoc">A connection to a remote AMQP peer.</div></div> |
| <div class="ttc" id="agroup__api__types_html_gab4f7e8d204246a3702c6e31a404b0edb"><div class="ttname"><a href="group__api__types.html#gab4f7e8d204246a3702c6e31a404b0edb">pn_bytes</a></div><div class="ttdeci">pn_bytes_t pn_bytes(size_t size, const char *start)</div><div class="ttdoc">Create a pn_bytes_t.</div></div> |
| <div class="ttc" id="agroup__data_html_ga5dc9c9c7db2018d12753767c075cc6ee"><div class="ttname"><a href="group__data.html#ga5dc9c9c7db2018d12753767c075cc6ee">pn_data_put_string</a></div><div class="ttdeci">int pn_data_put_string(pn_data_t *data, pn_bytes_t string)</div><div class="ttdoc">Puts a PN_STRING value.</div></div> |
| <div class="ttc" id="agroup__connection_html_ga4c0a2d40bb95202477ccc5aaa7456670"><div class="ttname"><a href="group__connection.html#ga4c0a2d40bb95202477ccc5aaa7456670">pn_connection_open</a></div><div class="ttdeci">void pn_connection_open(pn_connection_t *connection)</div><div class="ttdoc">Open a connection.</div></div> |
| <div class="ttc" id="agroup__link_html_ga89dad3aa7934329a7ff467c636687bc0"><div class="ttname"><a href="group__link.html#ga89dad3aa7934329a7ff467c636687bc0">pn_link_t</a></div><div class="ttdeci">struct pn_link_t pn_link_t</div><div class="ttdoc">An AMQP Link object.</div><div class="ttdef"><b>Definition:</b> types.h:315</div></div> |
| <div class="ttc" id="agroup__proactor_html_gade60ff2292b74841766f953b906285c0"><div class="ttname"><a href="group__proactor.html#gade60ff2292b74841766f953b906285c0">pn_proactor_done</a></div><div class="ttdeci">PNP_EXTERN void pn_proactor_done(pn_proactor_t *proactor, pn_event_batch_t *events)</div><div class="ttdoc">Call when finished handling a batch of events.</div></div> |
| <div class="ttc" id="agroup__delivery_html_gac64952b813a707586c6b3898e09552e4"><div class="ttname"><a href="group__delivery.html#gac64952b813a707586c6b3898e09552e4">PN_ACCEPTED</a></div><div class="ttdeci">#define PN_ACCEPTED</div><div class="ttdoc">The PN_ACCEPTED delivery state is a terminal state indicating that the delivery was successfully proc...</div><div class="ttdef"><b>Definition:</b> disposition.h:66</div></div> |
| <div class="ttc" id="agroup__delivery_html_ga6a7ef2e317b4ed292cafbb358f0ba6ad"><div class="ttname"><a href="group__delivery.html#ga6a7ef2e317b4ed292cafbb358f0ba6ad">pn_delivery</a></div><div class="ttdeci">pn_delivery_t * pn_delivery(pn_link_t *link, pn_delivery_tag_t tag)</div><div class="ttdoc">Create a delivery on a link.</div></div> |
| <div class="ttc" id="agroup__connection_html_gac4a34e0b1fc5665b26ae47a80a422a1a"><div class="ttname"><a href="group__connection.html#gac4a34e0b1fc5665b26ae47a80a422a1a">pn_connection_set_container</a></div><div class="ttdeci">void pn_connection_set_container(pn_connection_t *connection, const char *container)</div><div class="ttdoc">Set the AMQP Container name advertised by a connection object.</div></div> |
| <div class="ttc" id="agroup__session_html_gae21b3fda1567bad1f8a8fe162ffaeece"><div class="ttname"><a href="group__session.html#gae21b3fda1567bad1f8a8fe162ffaeece">pn_session_remote_condition</a></div><div class="ttdeci">pn_condition_t * pn_session_remote_condition(pn_session_t *session)</div><div class="ttdoc">Get the remote condition associated with the session endpoint.</div></div> |
| <div class="ttc" id="adelivery_8h_html"><div class="ttname"><a href="delivery_8h.html">delivery.h</a></div><div class="ttdoc">A message transfer.</div></div> |
| <div class="ttc" id="atransport_8h_html"><div class="ttname"><a href="transport_8h.html">transport.h</a></div><div class="ttdoc">A network channel supporting an AMQP connection.</div></div> |
| <div class="ttc" id="agroup__event_html_gga4876e2eed24a4d4e4c52b99842103cdaa4eaecc54c07cdc9b0df7b1d536a7dc3f"><div class="ttname"><a href="group__event.html#gga4876e2eed24a4d4e4c52b99842103cdaa4eaecc54c07cdc9b0df7b1d536a7dc3f">PN_LINK_FLOW</a></div><div class="ttdeci">@ PN_LINK_FLOW</div><div class="ttdoc">The flow control state for a link has changed.</div><div class="ttdef"><b>Definition:</b> event.h:241</div></div> |
| <div class="ttc" id="asession_8h_html"><div class="ttname"><a href="session_8h.html">session.h</a></div><div class="ttdoc">A container of links.</div></div> |
| <div class="ttc" id="agroup__session_html_ga38ccb93b8f5c2892adafce5d5f0fbcd9"><div class="ttname"><a href="group__session.html#ga38ccb93b8f5c2892adafce5d5f0fbcd9">pn_session_t</a></div><div class="ttdeci">struct pn_session_t pn_session_t</div><div class="ttdoc">An AMQP Session object.</div><div class="ttdef"><b>Definition:</b> types.h:296</div></div> |
| <div class="ttc" id="agroup__data_html_ga67a656cbdbf0a47a223ff1c8507ecf48"><div class="ttname"><a href="group__data.html#ga67a656cbdbf0a47a223ff1c8507ecf48">pn_data_exit</a></div><div class="ttdeci">bool pn_data_exit(pn_data_t *data)</div><div class="ttdoc">Sets the current node to the parent node and the parent node to its own parent.</div></div> |
| <div class="ttc" id="agroup__message_html_ga145c06edbcccfbe97136bfb5cb2b22b1"><div class="ttname"><a href="group__message.html#ga145c06edbcccfbe97136bfb5cb2b22b1">pn_message_body</a></div><div class="ttdeci">pn_data_t * pn_message_body(pn_message_t *msg)</div><div class="ttdoc">Get and set the body of a message.</div></div> |
| <div class="ttc" id="agroup__transport_html_gac458d9fdb684f9501e89b96fc51f5c34"><div class="ttname"><a href="group__transport.html#gac458d9fdb684f9501e89b96fc51f5c34">pn_transport_condition</a></div><div class="ttdeci">pn_condition_t * pn_transport_condition(pn_transport_t *transport)</div><div class="ttdoc">Get additional information about the condition of the transport.</div></div> |
| <div class="ttc" id="agroup__delivery_html_gaea4522ac1fef9228fb6c743d2a36fd27"><div class="ttname"><a href="group__delivery.html#gaea4522ac1fef9228fb6c743d2a36fd27">pn_dtag</a></div><div class="ttdeci">pn_delivery_tag_t pn_dtag(const char *bytes, size_t size)</div><div class="ttdoc">Construct a delivery tag.</div></div> |
| <div class="ttc" id="agroup__error_html_ga67cbe6ebb143370e0604f5b84d716c56"><div class="ttname"><a href="group__error.html#ga67cbe6ebb143370e0604f5b84d716c56">pn_error_text</a></div><div class="ttdeci">const char * pn_error_text(pn_error_t *error)</div><div class="ttdoc">Get the error text.</div></div> |
| <div class="ttc" id="agroup__event_html_gacaea54ca51885933b4987c131a3d1b0d"><div class="ttname"><a href="group__event.html#gacaea54ca51885933b4987c131a3d1b0d">pn_event_type</a></div><div class="ttdeci">pn_event_type_t pn_event_type(pn_event_t *event)</div><div class="ttdoc">Get the type of an event.</div></div> |
| <div class="ttc" id="agroup__event_html_ga3a85c046c11ce692c23b9566b022d54b"><div class="ttname"><a href="group__event.html#ga3a85c046c11ce692c23b9566b022d54b">pn_event_type_name</a></div><div class="ttdeci">const char * pn_event_type_name(pn_event_type_t type)</div><div class="ttdoc">Get a human readable name for an event type.</div></div> |
| <div class="ttc" id="agroup__proactor_html_ga29ae114b42fb797c103dc9883ebcb256"><div class="ttname"><a href="group__proactor.html#ga29ae114b42fb797c103dc9883ebcb256">PN_MAX_ADDR</a></div><div class="ttdeci">#define PN_MAX_ADDR</div><div class="ttdoc">Size of buffer that can hold the largest connection or listening address.</div><div class="ttdef"><b>Definition:</b> proactor.h:74</div></div> |
| <div class="ttc" id="agroup__link_html_ga55428637f3b8c446efd5fea3f26c932d"><div class="ttname"><a href="group__link.html#ga55428637f3b8c446efd5fea3f26c932d">pn_link_credit</a></div><div class="ttdeci">int pn_link_credit(pn_link_t *link)</div><div class="ttdoc">Get the credit balance for a link.</div></div> |
| <div class="ttc" id="agroup__event_html_ga14525ae84870388141898bbf57f2b151"><div class="ttname"><a href="group__event.html#ga14525ae84870388141898bbf57f2b151">pn_event_transport</a></div><div class="ttdeci">pn_transport_t * pn_event_transport(pn_event_t *event)</div><div class="ttdoc">Get the transport associated with an event.</div></div> |
| <div class="ttc" id="agroup__event_html_ga75f230ef55f03a1f943df79279f8d111"><div class="ttname"><a href="group__event.html#ga75f230ef55f03a1f943df79279f8d111">pn_event_link</a></div><div class="ttdeci">pn_link_t * pn_event_link(pn_event_t *event)</div><div class="ttdoc">Get the link associated with an event.</div></div> |
| <div class="ttc" id="agroup__proactor_html_gaf67a7642c9003b36255b58776b494c96"><div class="ttname"><a href="group__proactor.html#gaf67a7642c9003b36255b58776b494c96">pn_proactor_addr</a></div><div class="ttdeci">PNP_EXTERN int pn_proactor_addr(char *addr, size_t size, const char *host, const char *port)</div><div class="ttdoc">Format a host:port address string for pn_proactor_connect() or pn_proactor_listen()</div></div> |
| <!-- start footer part --> |
| <div id="nav-path" class="navpath"><!-- id is needed for treeview function! --> |
| <ul> |
| <li class="footer">Generated by <a href="http://www.doxygen.org/index.html"><img class="footer" src="doxygen.svg" width="104" height="31" alt="doxygen"/></a> 1.8.20 </li> |
| </ul> |
| </div> |
| </body> |
| </html> |
