<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html><head><meta http-equiv="Content-Type" content="text/html;charset=UTF-8">
<title>DTN Reference Implementation: BundleActions.cc Source File</title>
<link href="tabs.css" rel="stylesheet" type="text/css">
<link href="doxygen.css" rel="stylesheet" type="text/css">
</head><body>
<!-- Generated by Doxygen 1.5.8 -->
<div class="navigation" id="top">
<div class="tabs">
<ul>
<li><a href="main.html"><span>Main Page</span></a></li>
<li><a href="namespaces.html"><span>Namespaces</span></a></li>
<li><a href="annotated.html"><span>Classes</span></a></li>
<li class="current"><a href="files.html"><span>Files</span></a></li>
</ul>
</div>
<div class="tabs">
<ul>
<li><a href="files.html"><span>File List</span></a></li>
<li><a href="globals.html"><span>File Members</span></a></li>
</ul>
</div>
<h1>BundleActions.cc</h1><a href="BundleActions_8cc.html">Go to the documentation of this file.</a><div class="fragment"><pre class="fragment"><a name="l00001"></a>00001 <span class="comment">/*</span>
<a name="l00002"></a>00002 <span class="comment"> * Copyright 2005-2006 Intel Corporation</span>
<a name="l00003"></a>00003 <span class="comment"> * </span>
<a name="l00004"></a>00004 <span class="comment"> * Licensed under the Apache License, Version 2.0 (the "License");</span>
<a name="l00005"></a>00005 <span class="comment"> * you may not use this file except in compliance with the License.</span>
<a name="l00006"></a>00006 <span class="comment"> * You may obtain a copy of the License at</span>
<a name="l00007"></a>00007 <span class="comment"> * </span>
<a name="l00008"></a>00008 <span class="comment"> * http://www.apache.org/licenses/LICENSE-2.0</span>
<a name="l00009"></a>00009 <span class="comment"> * </span>
<a name="l00010"></a>00010 <span class="comment"> * Unless required by applicable law or agreed to in writing, software</span>
<a name="l00011"></a>00011 <span class="comment"> * distributed under the License is distributed on an "AS IS" BASIS,</span>
<a name="l00012"></a>00012 <span class="comment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</span>
<a name="l00013"></a>00013 <span class="comment"> * See the License for the specific language governing permissions and</span>
<a name="l00014"></a>00014 <span class="comment"> * limitations under the License.</span>
<a name="l00015"></a>00015 <span class="comment"> */</span>
<a name="l00016"></a>00016
<a name="l00017"></a>00017 <span class="preprocessor">#ifdef HAVE_CONFIG_H</span>
<a name="l00018"></a>00018 <span class="preprocessor"></span><span class="preprocessor"># include <<a class="code" href="dtn-config_8h.html">dtn-config.h</a>></span>
<a name="l00019"></a>00019 <span class="preprocessor">#endif</span>
<a name="l00020"></a>00020 <span class="preprocessor"></span>
<a name="l00021"></a>00021 <span class="preprocessor">#include "<a class="code" href="BundleActions_8h.html">BundleActions.h</a>"</span>
<a name="l00022"></a>00022 <span class="preprocessor">#include "<a class="code" href="bundling_2Bundle_8h.html">Bundle.h</a>"</span>
<a name="l00023"></a>00023 <span class="preprocessor">#include "<a class="code" href="BundleDaemon_8h.html">BundleDaemon.h</a>"</span>
<a name="l00024"></a>00024 <span class="preprocessor">#include "<a class="code" href="bundling_2BundleList_8h.html">BundleList.h</a>"</span>
<a name="l00025"></a>00025 <span class="preprocessor">#include "<a class="code" href="ConvergenceLayer_8h.html">conv_layers/ConvergenceLayer.h</a>"</span>
<a name="l00026"></a>00026 <span class="preprocessor">#include "<a class="code" href="contacts_2Link_8h.html">contacts/Link.h</a>"</span>
<a name="l00027"></a>00027 <span class="preprocessor">#include "<a class="code" href="BundleStore_8h.html">storage/BundleStore.h</a>"</span>
<a name="l00028"></a>00028
<a name="l00029"></a>00029 <span class="keyword">namespace </span>dtn {
<a name="l00030"></a>00030
<a name="l00031"></a>00031 <span class="comment">//----------------------------------------------------------------------</span>
<a name="l00032"></a>00032 <span class="keywordtype">void</span>
<a name="l00033"></a><a class="code" href="classdtn_1_1BundleActions.html#0cb4ef96c172a1943d32d19747a00438">00033</a> <a class="code" href="classdtn_1_1BundleActions.html#0cb4ef96c172a1943d32d19747a00438" title="Open a link for bundle transmission.">BundleActions::open_link</a>(<span class="keyword">const</span> <a class="code" href="namespacedtn.html#6efb37e503f8062c537b022eb755b94e" title="Typedef for a reference on a link.">LinkRef</a>& link)
<a name="l00034"></a>00034 {
<a name="l00035"></a>00035 <a class="code" href="SDNV_8cc.html#ca68c0d4ac8df0838e209fb5300f7be3">ASSERT</a>(link != NULL);
<a name="l00036"></a>00036 <span class="keywordflow">if</span> (link->isdeleted()) {
<a name="l00037"></a>00037 log_debug(<span class="stringliteral">"BundleActions::open_link: "</span>
<a name="l00038"></a>00038 <span class="stringliteral">"cannot open deleted link %s"</span>, link->name());
<a name="l00039"></a>00039 <span class="keywordflow">return</span>;
<a name="l00040"></a>00040 }
<a name="l00041"></a>00041
<a name="l00042"></a>00042 oasys::ScopeLock l(link->lock(), <span class="stringliteral">"BundleActions::open_link"</span>);
<a name="l00043"></a>00043
<a name="l00044"></a>00044 <span class="keywordflow">if</span> (link->isopen() || link->contact() != NULL) {
<a name="l00045"></a>00045 log_err(<span class="stringliteral">"not opening link %s since already open"</span>, link->name());
<a name="l00046"></a>00046 <span class="keywordflow">return</span>;
<a name="l00047"></a>00047 }
<a name="l00048"></a>00048
<a name="l00049"></a>00049 <span class="keywordflow">if</span> (! link->isavailable()) {
<a name="l00050"></a>00050 log_err(<span class="stringliteral">"not opening link %s since not available"</span>, link->name());
<a name="l00051"></a>00051 <span class="keywordflow">return</span>;
<a name="l00052"></a>00052 }
<a name="l00053"></a>00053
<a name="l00054"></a>00054 log_debug(<span class="stringliteral">"BundleActions::open_link: opening link %s"</span>, link->name());
<a name="l00055"></a>00055
<a name="l00056"></a>00056 link->open();
<a name="l00057"></a>00057 }
<a name="l00058"></a>00058
<a name="l00059"></a>00059 <span class="comment">//----------------------------------------------------------------------</span>
<a name="l00060"></a>00060 <span class="keywordtype">void</span>
<a name="l00061"></a><a class="code" href="classdtn_1_1BundleActions.html#7785a114a3789ffb4eda31e3dbb19f1e">00061</a> <a class="code" href="classdtn_1_1BundleActions.html#7785a114a3789ffb4eda31e3dbb19f1e" title="Open a link for bundle transmission.">BundleActions::close_link</a>(<span class="keyword">const</span> <a class="code" href="namespacedtn.html#6efb37e503f8062c537b022eb755b94e" title="Typedef for a reference on a link.">LinkRef</a>& link)
<a name="l00062"></a>00062 {
<a name="l00063"></a>00063 <a class="code" href="SDNV_8cc.html#ca68c0d4ac8df0838e209fb5300f7be3">ASSERT</a>(link != NULL);
<a name="l00064"></a>00064
<a name="l00065"></a>00065 <span class="keywordflow">if</span> (! link->isopen() && ! link->isopening()) {
<a name="l00066"></a>00066 log_err(<span class="stringliteral">"not closing link %s since not open"</span>, link->name());
<a name="l00067"></a>00067 <span class="keywordflow">return</span>;
<a name="l00068"></a>00068 }
<a name="l00069"></a>00069
<a name="l00070"></a>00070 log_debug(<span class="stringliteral">"BundleActions::close_link: closing link %s"</span>, link->name());
<a name="l00071"></a>00071
<a name="l00072"></a>00072 link->close();
<a name="l00073"></a>00073 <a class="code" href="SDNV_8cc.html#ca68c0d4ac8df0838e209fb5300f7be3">ASSERT</a>(link->contact() == NULL);
<a name="l00074"></a>00074 }
<a name="l00075"></a>00075
<a name="l00076"></a>00076 <span class="comment">//----------------------------------------------------------------------</span>
<a name="l00077"></a>00077 <span class="keywordtype">bool</span>
<a name="l00078"></a><a class="code" href="classdtn_1_1BundleActions.html#7a75826fd1b4515b9d9aa2b98acbde68">00078</a> <a class="code" href="classdtn_1_1BundleActions.html#7a75826fd1b4515b9d9aa2b98acbde68" title="Queue the bundle for transmission on the given link.">BundleActions::queue_bundle</a>(<a class="code" href="classdtn_1_1Bundle.html" title="The internal representation of a bundle.">Bundle</a>* bundle, <span class="keyword">const</span> <a class="code" href="namespacedtn.html#6efb37e503f8062c537b022eb755b94e" title="Typedef for a reference on a link.">LinkRef</a>& link,
<a name="l00079"></a>00079 <a class="code" href="classdtn_1_1ForwardingInfo.html#18ec95dc1b1b8a7e9df9873a0d9b5947" title="The forwarding action type codes.">ForwardingInfo::action_t</a> action,
<a name="l00080"></a>00080 <span class="keyword">const</span> <a class="code" href="classdtn_1_1CustodyTimerSpec.html" title="Utility class to abstract out various parameters that can be used to calculate custody...">CustodyTimerSpec</a>& custody_timer)
<a name="l00081"></a>00081 {
<a name="l00082"></a>00082 <a class="code" href="namespacedtn.html#87094f3b26b9f1d469e616d311ae57b1" title="Class definition for a Bundle reference.">BundleRef</a> bref(bundle, <span class="stringliteral">"BundleActions::queue_bundle"</span>);
<a name="l00083"></a>00083
<a name="l00084"></a>00084 <a class="code" href="SDNV_8cc.html#ca68c0d4ac8df0838e209fb5300f7be3">ASSERT</a>(link != NULL);
<a name="l00085"></a>00085 <span class="keywordflow">if</span> (link->isdeleted()) {
<a name="l00086"></a>00086 log_warn(<span class="stringliteral">"BundleActions::queue_bundle: "</span>
<a name="l00087"></a>00087 <span class="stringliteral">"failed to send bundle *%p on link %s"</span>,
<a name="l00088"></a>00088 bundle, link->name());
<a name="l00089"></a>00089 <span class="keywordflow">return</span> <span class="keyword">false</span>;
<a name="l00090"></a>00090 }
<a name="l00091"></a>00091
<a name="l00092"></a>00092 log_debug(<span class="stringliteral">"trying to find xmit blocks for bundle id:%d on link %s"</span>,
<a name="l00093"></a>00093 bundle-><a class="code" href="classdtn_1_1Bundle.html#7031e2e5e4078445bf4ad39cdcdea3b2" title="Accessors.">bundleid</a>(), link->name());
<a name="l00094"></a>00094
<a name="l00095"></a>00095 <span class="keywordflow">if</span> (bundle-><a class="code" href="classdtn_1_1Bundle.html#0ce0961036dd0da1fd322721cbb794aa" title="Setters and mutable accessors.">xmit_blocks</a>()-><a class="code" href="classdtn_1_1LinkBlockSet.html#07658a9543619b3ab3f1493a2dd68e85" title="Find the BlockInfoVec for the given link.">find_blocks</a>(link) != NULL) {
<a name="l00096"></a>00096 log_err(<span class="stringliteral">"BundleActions::queue_bundle: "</span>
<a name="l00097"></a>00097 <span class="stringliteral">"link not ready to handle bundle (block vector already exists), "</span>
<a name="l00098"></a>00098 <span class="stringliteral">"dropping send request"</span>);
<a name="l00099"></a>00099 <span class="keywordflow">return</span> <span class="keyword">false</span>;
<a name="l00100"></a>00100 }
<a name="l00101"></a>00101
<a name="l00102"></a>00102 <span class="comment">// XXX/demmer this should be moved somewhere in the router</span>
<a name="l00103"></a>00103 <span class="comment">// interface so it can select options for the outgoing bundle</span>
<a name="l00104"></a>00104 <span class="comment">// blocks (e.g. security)</span>
<a name="l00105"></a>00105 <span class="comment">// XXX/ngoffee It's true the router should be able to select</span>
<a name="l00106"></a>00106 <span class="comment">// blocks for various purposes, but I'd like the security policy</span>
<a name="l00107"></a>00107 <span class="comment">// checks and subsequent block selection to remain inside the BPA,</span>
<a name="l00108"></a>00108 <span class="comment">// with the DP pushing (firewall-like) policies and keys down via</span>
<a name="l00109"></a>00109 <span class="comment">// a PF_KEY-like interface.</span>
<a name="l00110"></a>00110 log_debug(<span class="stringliteral">"trying to create xmit blocks for bundle id:%d on link %s"</span>,
<a name="l00111"></a>00111 bundle-><a class="code" href="classdtn_1_1Bundle.html#7031e2e5e4078445bf4ad39cdcdea3b2" title="Accessors.">bundleid</a>(), link->name());
<a name="l00112"></a>00112 <a class="code" href="classdtn_1_1BlockInfoVec.html" title="Class for a vector of BlockInfo structures.">BlockInfoVec</a>* blocks = <a class="code" href="classdtn_1_1BundleProtocol.html#ef1c34c75b476f408546f73b4de1f2f5" title="Generate a BlockInfoVec for the outgoing link and put it into xmit_blocks_.">BundleProtocol::prepare_blocks</a>(bundle, link);
<a name="l00113"></a>00113 <span class="keywordtype">size_t</span> total_len = <a class="code" href="classdtn_1_1BundleProtocol.html#77305bae9d1251ebd42e2b602684f59b" title="Generate contents for the given BlockInfoVec on the given Link.">BundleProtocol::generate_blocks</a>(bundle, blocks, link);
<a name="l00114"></a>00114
<a name="l00115"></a>00115 log_debug(<span class="stringliteral">"queue bundle *%p on %s link %s (%s) (total len %zu)"</span>,
<a name="l00116"></a>00116 bundle, link->type_str(), link->name(), link->nexthop(),
<a name="l00117"></a>00117 total_len);
<a name="l00118"></a>00118
<a name="l00119"></a>00119 <a class="code" href="classdtn_1_1ForwardingInfo.html#acf01ca8a774e80f6f7bf56c2b099fad" title="The forwarding log state codes.">ForwardingInfo::state_t</a> state = bundle-><a class="code" href="classdtn_1_1Bundle.html#249ac137ef76e253d8e0587f2662bca7" title="Accessors.">fwdlog</a>()-><a class="code" href="classdtn_1_1ForwardingLog.html#57192cc969b46bc646ae411a8d7c27ee" title="Get the most recent entry for the given link from the log.">get_latest_entry</a>(link);
<a name="l00120"></a>00120 <span class="keywordflow">if</span> (state == <a class="code" href="classdtn_1_1ForwardingInfo.html#acf01ca8a774e80f6f7bf56c2b099fade904c54b91c284fb69c0e6f6acccc99b" title="Currently queued or being sent.">ForwardingInfo::QUEUED</a>) {
<a name="l00121"></a>00121 log_err(<span class="stringliteral">"queue bundle *%p on %s link %s (%s): "</span>
<a name="l00122"></a>00122 <span class="stringliteral">"already queued or in flight"</span>,
<a name="l00123"></a>00123 bundle, link->type_str(), link->name(), link->nexthop());
<a name="l00124"></a>00124 <span class="keywordflow">return</span> <span class="keyword">false</span>;
<a name="l00125"></a>00125 }
<a name="l00126"></a>00126
<a name="l00127"></a>00127 <span class="keywordflow">if</span> ((link->params().mtu_ != 0) && (total_len > link->params().mtu_)) {
<a name="l00128"></a>00128 log_err(<span class="stringliteral">"queue bundle *%p on %s link %s (%s): length %zu > mtu %u"</span>,
<a name="l00129"></a>00129 bundle, link->type_str(), link->name(), link->nexthop(),
<a name="l00130"></a>00130 total_len, link->params().mtu_);
<a name="l00131"></a>00131 <span class="keywordflow">return</span> <span class="keyword">false</span>;
<a name="l00132"></a>00132 }
<a name="l00133"></a>00133
<a name="l00134"></a>00134 <span class="comment">// Make sure that the bundle isn't unexpectedly already on the</span>
<a name="l00135"></a>00135 <span class="comment">// queue or in flight on the link</span>
<a name="l00136"></a>00136 <span class="keywordflow">if</span> (link->queue()->contains(bundle))
<a name="l00137"></a>00137 {
<a name="l00138"></a>00138 log_err(<span class="stringliteral">"queue bundle *%p on link *%p: already queued on link"</span>,
<a name="l00139"></a>00139 bundle, link.object());
<a name="l00140"></a>00140 <span class="keywordflow">return</span> <span class="keyword">false</span>;
<a name="l00141"></a>00141 }
<a name="l00142"></a>00142
<a name="l00143"></a>00143 <span class="keywordflow">if</span> (link->inflight()->contains(bundle))
<a name="l00144"></a>00144 {
<a name="l00145"></a>00145 log_err(<span class="stringliteral">"queue bundle *%p on link *%p: already in flight on link"</span>,
<a name="l00146"></a>00146 bundle, link.object());
<a name="l00147"></a>00147 <span class="keywordflow">return</span> <span class="keyword">false</span>;
<a name="l00148"></a>00148 }
<a name="l00149"></a>00149
<a name="l00150"></a>00150 log_debug(<span class="stringliteral">"adding QUEUED forward log entry for %s link %s "</span>
<a name="l00151"></a>00151 <span class="stringliteral">"with nexthop %s and remote eid %s to *%p"</span>,
<a name="l00152"></a>00152 link->type_str(), link->name(),
<a name="l00153"></a>00153 link->nexthop(), link->remote_eid().c_str(), bundle);
<a name="l00154"></a>00154
<a name="l00155"></a>00155 bundle-><a class="code" href="classdtn_1_1Bundle.html#249ac137ef76e253d8e0587f2662bca7" title="Accessors.">fwdlog</a>()-><a class="code" href="classdtn_1_1ForwardingLog.html#3a0080cfb70b95af31a780bf71910004" title="Add a new forwarding info entry for the given link.">add_entry</a>(link, action, <a class="code" href="classdtn_1_1ForwardingInfo.html#acf01ca8a774e80f6f7bf56c2b099fade904c54b91c284fb69c0e6f6acccc99b" title="Currently queued or being sent.">ForwardingInfo::QUEUED</a>,
<a name="l00156"></a>00156 custody_timer);
<a name="l00157"></a>00157
<a name="l00158"></a>00158 log_debug(<span class="stringliteral">"adding *%p to link %s's queue (length %u)"</span>,
<a name="l00159"></a>00159 bundle, link->name(), link->bundles_queued());
<a name="l00160"></a>00160
<a name="l00161"></a>00161 <span class="keywordflow">if</span> (! link->add_to_queue(bref, total_len)) {
<a name="l00162"></a>00162 log_err(<span class="stringliteral">"error adding bundle *%p to link *%p queue"</span>,
<a name="l00163"></a>00163 bundle, link.object());
<a name="l00164"></a>00164 }
<a name="l00165"></a>00165
<a name="l00166"></a>00166 <span class="comment">// finally, kick the convergence layer</span>
<a name="l00167"></a>00167 link->clayer()->bundle_queued(link, bref);
<a name="l00168"></a>00168
<a name="l00169"></a>00169 <span class="keywordflow">return</span> <span class="keyword">true</span>;
<a name="l00170"></a>00170 }
<a name="l00171"></a>00171
<a name="l00172"></a>00172 <span class="comment">//----------------------------------------------------------------------</span>
<a name="l00173"></a>00173 <span class="keywordtype">void</span>
<a name="l00174"></a><a class="code" href="classdtn_1_1BundleActions.html#3835034086b8a07e5a767fa028104830">00174</a> <a class="code" href="classdtn_1_1BundleActions.html#3835034086b8a07e5a767fa028104830" title="Attempt to cancel transmission of a bundle on the given link.">BundleActions::cancel_bundle</a>(<a class="code" href="classdtn_1_1Bundle.html" title="The internal representation of a bundle.">Bundle</a>* bundle, <span class="keyword">const</span> <a class="code" href="namespacedtn.html#6efb37e503f8062c537b022eb755b94e" title="Typedef for a reference on a link.">LinkRef</a>& link)
<a name="l00175"></a>00175 {
<a name="l00176"></a>00176 <a class="code" href="namespacedtn.html#87094f3b26b9f1d469e616d311ae57b1" title="Class definition for a Bundle reference.">BundleRef</a> bref(bundle, <span class="stringliteral">"BundleActions::cancel_bundle"</span>);
<a name="l00177"></a>00177
<a name="l00178"></a>00178 <a class="code" href="SDNV_8cc.html#ca68c0d4ac8df0838e209fb5300f7be3">ASSERT</a>(link != NULL);
<a name="l00179"></a>00179 <span class="keywordflow">if</span> (link->isdeleted()) {
<a name="l00180"></a>00180 log_debug(<span class="stringliteral">"BundleActions::cancel_bundle: "</span>
<a name="l00181"></a>00181 <span class="stringliteral">"cannot cancel bundle on deleted link %s"</span>, link->name());
<a name="l00182"></a>00182 <span class="keywordflow">return</span>;
<a name="l00183"></a>00183 }
<a name="l00184"></a>00184
<a name="l00185"></a>00185 log_debug(<span class="stringliteral">"BundleActions::cancel_bundle: cancelling *%p on *%p"</span>,
<a name="l00186"></a>00186 bundle, link.object());
<a name="l00187"></a>00187
<a name="l00188"></a>00188 <span class="comment">// First try to remove the bundle from the link's delayed-send</span>
<a name="l00189"></a>00189 <span class="comment">// queue. If it's there, then safely remove it and post the send</span>
<a name="l00190"></a>00190 <span class="comment">// cancelled request without involving the convergence layer.</span>
<a name="l00191"></a>00191 <span class="comment">//</span>
<a name="l00192"></a>00192 <span class="comment">// If instead it's actually in flight on the link, then call down</span>
<a name="l00193"></a>00193 <span class="comment">// to the convergence layer to see if it can interrupt</span>
<a name="l00194"></a>00194 <span class="comment">// transmission, in which case it's responsible for posting the</span>
<a name="l00195"></a>00195 <span class="comment">// send cancelled event.</span>
<a name="l00196"></a>00196
<a name="l00197"></a>00197 <a class="code" href="classdtn_1_1BlockInfoVec.html" title="Class for a vector of BlockInfo structures.">BlockInfoVec</a>* blocks = bundle-><a class="code" href="classdtn_1_1Bundle.html#0ce0961036dd0da1fd322721cbb794aa" title="Setters and mutable accessors.">xmit_blocks</a>()-><a class="code" href="classdtn_1_1LinkBlockSet.html#07658a9543619b3ab3f1493a2dd68e85" title="Find the BlockInfoVec for the given link.">find_blocks</a>(link);
<a name="l00198"></a>00198 <span class="keywordflow">if</span> (blocks == NULL) {
<a name="l00199"></a>00199 log_warn(<span class="stringliteral">"BundleActions::cancel_bundle: "</span>
<a name="l00200"></a>00200 <span class="stringliteral">"cancel *%p but no blocks queued or inflight on *%p"</span>,
<a name="l00201"></a>00201 bundle, link.object());
<a name="l00202"></a>00202 <span class="keywordflow">return</span>;
<a name="l00203"></a>00203 }
<a name="l00204"></a>00204
<a name="l00205"></a>00205 <span class="keywordtype">size_t</span> total_len = <a class="code" href="classdtn_1_1BundleProtocol.html#a1dedd9ea4300339bc2a3f7a231ca5dd" title="Return the total length of the formatted bundle block data.">BundleProtocol::total_length</a>(blocks);
<a name="l00206"></a>00206
<a name="l00207"></a>00207 <span class="keywordflow">if</span> (link->del_from_queue(bref, total_len)) {
<a name="l00208"></a>00208 <a class="code" href="classdtn_1_1BundleDaemon.html#370a80f7dd9fd9297e76d7f830d737a8" title="Queues the event at the tail of the queue for processing by the daemon thread.">BundleDaemon::post</a>(<span class="keyword">new</span> <a class="code" href="classdtn_1_1BundleSendCancelledEvent.html" title="Event class for succesful cancellation of a bundle send.">BundleSendCancelledEvent</a>(bundle, link));
<a name="l00209"></a>00209
<a name="l00210"></a>00210 } <span class="keywordflow">else</span> <span class="keywordflow">if</span> (link->inflight()->contains(bundle)) {
<a name="l00211"></a>00211 link->clayer()->cancel_bundle(link, bref);
<a name="l00212"></a>00212 }
<a name="l00213"></a>00213 <span class="keywordflow">else</span> {
<a name="l00214"></a>00214 log_warn(<span class="stringliteral">"BundleActions::cancel_bundle: "</span>
<a name="l00215"></a>00215 <span class="stringliteral">"cancel *%p but not queued or inflight on *%p"</span>,
<a name="l00216"></a>00216 bundle, link.object());
<a name="l00217"></a>00217 }
<a name="l00218"></a>00218 }
<a name="l00219"></a>00219
<a name="l00220"></a>00220 <span class="comment">//----------------------------------------------------------------------</span>
<a name="l00221"></a>00221 <span class="keywordtype">void</span>
<a name="l00222"></a><a class="code" href="classdtn_1_1BundleActions.html#064552c93debb6dec1bea07fb02b719f">00222</a> <a class="code" href="classdtn_1_1BundleActions.html#064552c93debb6dec1bea07fb02b719f" title="Inject a new bundle into the core system, which places it in the pending bundles...">BundleActions::inject_bundle</a>(<a class="code" href="classdtn_1_1Bundle.html" title="The internal representation of a bundle.">Bundle</a>* bundle)
<a name="l00223"></a>00223 {
<a name="l00224"></a>00224 PANIC(<span class="stringliteral">"XXX/demmer fix inject bundle"</span>);
<a name="l00225"></a>00225
<a name="l00226"></a>00226 log_debug(<span class="stringliteral">"inject bundle *%p"</span>, bundle);
<a name="l00227"></a>00227 BundleDaemon::instance()->pending_bundles()->push_back(bundle);
<a name="l00228"></a>00228 <a class="code" href="classdtn_1_1BundleActions.html#b7f86cdfb095c0fd9705f7b7605ca578" title="Add the given bundle to the data store.">store_add</a>(bundle);
<a name="l00229"></a>00229 }
<a name="l00230"></a>00230
<a name="l00231"></a>00231 <span class="comment">//----------------------------------------------------------------------</span>
<a name="l00232"></a>00232 <span class="keywordtype">bool</span>
<a name="l00233"></a><a class="code" href="classdtn_1_1BundleActions.html#afdfbef5763f8f8ec84616977d3ca68d">00233</a> <a class="code" href="classdtn_1_1BundleActions.html#afdfbef5763f8f8ec84616977d3ca68d" title="Attempt to delete a bundle from the system.">BundleActions::delete_bundle</a>(<a class="code" href="classdtn_1_1Bundle.html" title="The internal representation of a bundle.">Bundle</a>* bundle,
<a name="l00234"></a>00234 <a class="code" href="classdtn_1_1BundleProtocol.html#37b000d94172c06970bb8af32889f917" title="Bundle Status Report &quot;Reason Code&quot; flags.">BundleProtocol::status_report_reason_t</a> reason,
<a name="l00235"></a>00235 <span class="keywordtype">bool</span> log_on_error)
<a name="l00236"></a>00236 {
<a name="l00237"></a>00237 <a class="code" href="namespacedtn.html#87094f3b26b9f1d469e616d311ae57b1" title="Class definition for a Bundle reference.">BundleRef</a> bref(bundle, <span class="stringliteral">"BundleActions::delete_bundle"</span>);
<a name="l00238"></a>00238
<a name="l00239"></a>00239 log_debug(<span class="stringliteral">"attempting to delete bundle *%p from data store"</span>, bundle);
<a name="l00240"></a>00240 <span class="keywordtype">bool</span> del = BundleDaemon::instance()->delete_bundle(bref, reason);
<a name="l00241"></a>00241
<a name="l00242"></a>00242 <span class="keywordflow">if</span> (log_on_error && !del) {
<a name="l00243"></a>00243 log_err(<span class="stringliteral">"Failed to delete bundle *%p from data store"</span>, bundle);
<a name="l00244"></a>00244 }
<a name="l00245"></a>00245 <span class="keywordflow">return</span> del;
<a name="l00246"></a>00246 }
<a name="l00247"></a>00247
<a name="l00248"></a>00248 <span class="comment">//----------------------------------------------------------------------</span>
<a name="l00249"></a>00249 <span class="keywordtype">void</span>
<a name="l00250"></a><a class="code" href="classdtn_1_1BundleActions.html#b7f86cdfb095c0fd9705f7b7605ca578">00250</a> <a class="code" href="classdtn_1_1BundleActions.html#b7f86cdfb095c0fd9705f7b7605ca578" title="Add the given bundle to the data store.">BundleActions::store_add</a>(<a class="code" href="classdtn_1_1Bundle.html" title="The internal representation of a bundle.">Bundle</a>* bundle)
<a name="l00251"></a>00251 {
<a name="l00252"></a>00252 log_debug(<span class="stringliteral">"adding bundle %d to data store"</span>, bundle-><a class="code" href="classdtn_1_1Bundle.html#7031e2e5e4078445bf4ad39cdcdea3b2" title="Accessors.">bundleid</a>());
<a name="l00253"></a>00253 <span class="keywordtype">bool</span> added = BundleStore::instance()->add(bundle);
<a name="l00254"></a>00254 <span class="keywordflow">if</span> (! added) {
<a name="l00255"></a>00255 log_crit(<span class="stringliteral">"error adding bundle %d to data store!!"</span>, bundle-><a class="code" href="classdtn_1_1Bundle.html#7031e2e5e4078445bf4ad39cdcdea3b2" title="Accessors.">bundleid</a>());
<a name="l00256"></a>00256 }
<a name="l00257"></a>00257 }
<a name="l00258"></a>00258
<a name="l00259"></a>00259 <span class="comment">//----------------------------------------------------------------------</span>
<a name="l00260"></a>00260 <span class="keywordtype">void</span>
<a name="l00261"></a><a class="code" href="classdtn_1_1BundleActions.html#ae6c692e776bdde10921c307b57b203d">00261</a> <a class="code" href="classdtn_1_1BundleActions.html#ae6c692e776bdde10921c307b57b203d" title="Update the on-disk version of the given bundle, after it&#39;s bookkeeping or header...">BundleActions::store_update</a>(<a class="code" href="classdtn_1_1Bundle.html" title="The internal representation of a bundle.">Bundle</a>* bundle)
<a name="l00262"></a>00262 {
<a name="l00263"></a>00263 log_debug(<span class="stringliteral">"updating bundle %d in data store"</span>, bundle-><a class="code" href="classdtn_1_1Bundle.html#7031e2e5e4078445bf4ad39cdcdea3b2" title="Accessors.">bundleid</a>());
<a name="l00264"></a>00264 <span class="keywordtype">bool</span> updated = BundleStore::instance()->update(bundle);
<a name="l00265"></a>00265 <span class="keywordflow">if</span> (! updated) {
<a name="l00266"></a>00266 log_crit(<span class="stringliteral">"error updating bundle %d in data store!!"</span>, bundle-><a class="code" href="classdtn_1_1Bundle.html#7031e2e5e4078445bf4ad39cdcdea3b2" title="Accessors.">bundleid</a>());
<a name="l00267"></a>00267 }
<a name="l00268"></a>00268 }
<a name="l00269"></a>00269
<a name="l00270"></a>00270 <span class="comment">//----------------------------------------------------------------------</span>
<a name="l00271"></a>00271 <span class="keywordtype">void</span>
<a name="l00272"></a><a class="code" href="classdtn_1_1BundleActions.html#fdbaada645504895226a83f8a92c2a40">00272</a> <a class="code" href="classdtn_1_1BundleActions.html#fdbaada645504895226a83f8a92c2a40" title="Remove the given bundle from the data store.">BundleActions::store_del</a>(<a class="code" href="classdtn_1_1Bundle.html" title="The internal representation of a bundle.">Bundle</a>* bundle)
<a name="l00273"></a>00273 {
<a name="l00274"></a>00274 log_debug(<span class="stringliteral">"removing bundle %d from data store"</span>, bundle-><a class="code" href="classdtn_1_1Bundle.html#7031e2e5e4078445bf4ad39cdcdea3b2" title="Accessors.">bundleid</a>());
<a name="l00275"></a>00275 <span class="keywordtype">bool</span> removed = BundleStore::instance()->del(bundle);
<a name="l00276"></a>00276 <span class="keywordflow">if</span> (! removed) {
<a name="l00277"></a>00277 log_crit(<span class="stringliteral">"error removing bundle %d from data store!!"</span>,
<a name="l00278"></a>00278 bundle-><a class="code" href="classdtn_1_1Bundle.html#7031e2e5e4078445bf4ad39cdcdea3b2" title="Accessors.">bundleid</a>());
<a name="l00279"></a>00279 }
<a name="l00280"></a>00280 }
<a name="l00281"></a>00281
<a name="l00282"></a>00282 } <span class="comment">// namespace dtn</span>
</pre></div></div>
<hr size="1"><address style="text-align: right;"><small>Generated on Fri Jan 30 09:26:52 2009 for DTN Reference Implementation by
<a href="http://www.doxygen.org/index.html">
<img src="doxygen.png" alt="doxygen" align="middle" border="0"></a> 1.5.8 </small></address>
</body>
</html>
distrib
>
Mandriva
>
2010.0
>
i586
>
media
>
contrib-release
>
by-pkgid
>
29c369053a983cc5d8c880dc6e0a2237
>
files
>
86
