You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by gi...@apache.org on 2017/12/21 06:10:06 UTC
[20/51] [partial] mesos-site git commit: Updated the website built
from mesos SHA: 760ab18.
http://git-wip-us.apache.org/repos/asf/mesos-site/blob/6dce3457/content/api/latest/c++/status__update__manager__process_8hpp_source.html
----------------------------------------------------------------------
diff --git a/content/api/latest/c++/status__update__manager__process_8hpp_source.html b/content/api/latest/c++/status__update__manager__process_8hpp_source.html
index 59c7059..c7ec951 100644
--- a/content/api/latest/c++/status__update__manager__process_8hpp_source.html
+++ b/content/api/latest/c++/status__update__manager__process_8hpp_source.html
@@ -623,8 +623,8 @@
<div class="line"><a name="l00569"></a><span class="lineno"> 569</span>  }</div>
<div class="line"><a name="l00570"></a><span class="lineno"> 570</span>  }</div>
<div class="line"><a name="l00571"></a><span class="lineno"> 571</span> </div>
-<div class="line"><a name="l00572"></a><span class="lineno"> 572</span>  <span class="comment">// Type of status updates handled by the stream, e.g., "offer operation</span></div>
-<div class="line"><a name="l00573"></a><span class="lineno"> 573</span>  <span class="comment">// status update".</span></div>
+<div class="line"><a name="l00572"></a><span class="lineno"> 572</span>  <span class="comment">// Type of status updates handled by the stream, e.g., "operation status</span></div>
+<div class="line"><a name="l00573"></a><span class="lineno"> 573</span>  <span class="comment">// update".</span></div>
<div class="line"><a name="l00574"></a><span class="lineno"> 574</span>  <span class="keyword">const</span> std::string statusUpdateType;</div>
<div class="line"><a name="l00575"></a><span class="lineno"> 575</span> </div>
<div class="line"><a name="l00576"></a><span class="lineno"> 576</span>  lambda::function<void(UpdateType)> forwardCallback;</div>
@@ -843,245 +843,227 @@
<div class="line"><a name="l00789"></a><span class="lineno"> 789</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>.get());</div>
<div class="line"><a name="l00790"></a><span class="lineno"> 790</span>  }</div>
<div class="line"><a name="l00791"></a><span class="lineno"> 791</span> </div>
-<div class="line"><a name="l00792"></a><span class="lineno"> 792</span>  <span class="comment">// TODO(gkleiman): This won't work with `StatusUpdate`, because the field</span></div>
-<div class="line"><a name="l00793"></a><span class="lineno"> 793</span>  <span class="comment">// containing the status update uuid has a different name. In order to</span></div>
-<div class="line"><a name="l00794"></a><span class="lineno"> 794</span>  <span class="comment">// make the `TaskStatusUpdateManager` use this process, we should avoid</span></div>
-<div class="line"><a name="l00795"></a><span class="lineno"> 795</span>  <span class="comment">// depending on identical field names.</span></div>
-<div class="line"><a name="l00796"></a><span class="lineno"> 796</span>  <span class="keywordflow">if</span> (!update.status().has_status_uuid()) {</div>
-<div class="line"><a name="l00797"></a><span class="lineno"> 797</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(<span class="stringliteral">"Status update is missing 'status_uuid'"</span>);</div>
-<div class="line"><a name="l00798"></a><span class="lineno"> 798</span>  }</div>
-<div class="line"><a name="l00799"></a><span class="lineno"> 799</span>  <a class="code" href="classTry.html">Try<id::UUID></a> statusUuid =</div>
-<div class="line"><a name="l00800"></a><span class="lineno"> 800</span>  <a class="code" href="structid_1_1UUID.html#afd66db1d29a4ee4be9c82581437dda74">id::UUID::fromBytes</a>(update.status().status_uuid().value());</div>
-<div class="line"><a name="l00801"></a><span class="lineno"> 801</span>  <a class="code" href="stout_2include_2stout_2check_8hpp.html#aee320e7c6e107071f4b85d4cc135a265">CHECK_SOME</a>(statusUuid);</div>
-<div class="line"><a name="l00802"></a><span class="lineno"> 802</span> </div>
-<div class="line"><a name="l00803"></a><span class="lineno"> 803</span>  <span class="comment">// Check that this status update has not already been acknowledged.</span></div>
-<div class="line"><a name="l00804"></a><span class="lineno"> 804</span>  <span class="keywordflow">if</span> (acknowledged.contains(statusUuid.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>())) {</div>
-<div class="line"><a name="l00805"></a><span class="lineno"> 805</span>  LOG(WARNING) << <span class="stringliteral">"Ignoring "</span> << statusUpdateType << <span class="stringliteral">" "</span> << update</div>
-<div class="line"><a name="l00806"></a><span class="lineno"> 806</span>  << <span class="stringliteral">" that has already been acknowledged"</span>;</div>
-<div class="line"><a name="l00807"></a><span class="lineno"> 807</span>  <span class="keywordflow">return</span> <span class="keyword">false</span>;</div>
-<div class="line"><a name="l00808"></a><span class="lineno"> 808</span>  }</div>
-<div class="line"><a name="l00809"></a><span class="lineno"> 809</span> </div>
-<div class="line"><a name="l00810"></a><span class="lineno"> 810</span>  <span class="comment">// Check that this update has not already been received.</span></div>
-<div class="line"><a name="l00811"></a><span class="lineno"> 811</span>  <span class="keywordflow">if</span> (received.contains(statusUuid.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>())) {</div>
-<div class="line"><a name="l00812"></a><span class="lineno"> 812</span>  LOG(WARNING) << <span class="stringliteral">"Ignoring duplicate "</span> << statusUpdateType << <span class="stringliteral">" "</span></div>
-<div class="line"><a name="l00813"></a><span class="lineno"> 813</span>  << <a class="code" href="classmesos_1_1internal_1_1StatusUpdateManagerProcess.html#a1658b4adb952dc5e20465e31d572633b">update</a>;</div>
-<div class="line"><a name="l00814"></a><span class="lineno"> 814</span>  <span class="keywordflow">return</span> <span class="keyword">false</span>;</div>
-<div class="line"><a name="l00815"></a><span class="lineno"> 815</span>  }</div>
-<div class="line"><a name="l00816"></a><span class="lineno"> 816</span> </div>
-<div class="line"><a name="l00817"></a><span class="lineno"> 817</span>  <span class="comment">// Handle the update, checkpointing if necessary.</span></div>
-<div class="line"><a name="l00818"></a><span class="lineno"> 818</span>  <a class="code" href="classTry.html">Try<Nothing></a> result = handle(update, CheckpointType::UPDATE);</div>
-<div class="line"><a name="l00819"></a><span class="lineno"> 819</span>  <span class="keywordflow">if</span> (result.<a class="code" href="classTry.html#a0b98f95163b8a38daafd1651b043a276">isError</a>()) {</div>
-<div class="line"><a name="l00820"></a><span class="lineno"> 820</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(result.<a class="code" href="classTry.html#aec4a11ddd3c036e889d90b7eb6258ba7">error</a>());</div>
-<div class="line"><a name="l00821"></a><span class="lineno"> 821</span>  }</div>
-<div class="line"><a name="l00822"></a><span class="lineno"> 822</span> </div>
-<div class="line"><a name="l00823"></a><span class="lineno"> 823</span>  <span class="keywordflow">return</span> <span class="keyword">true</span>;</div>
-<div class="line"><a name="l00824"></a><span class="lineno"> 824</span>  }</div>
-<div class="line"><a name="l00825"></a><span class="lineno"> 825</span> </div>
-<div class="line"><a name="l00826"></a><span class="lineno"> 826</span>  <span class="comment">// This function handles the ACK, checkpointing if necessary.</span></div>
-<div class="line"><a name="l00827"></a><span class="lineno"> 827</span>  <span class="comment">//</span></div>
-<div class="line"><a name="l00828"></a><span class="lineno"> 828</span>  <span class="comment">// Returns `true`: if the acknowledgement is successfully handled.</span></div>
-<div class="line"><a name="l00829"></a><span class="lineno"> 829</span>  <span class="comment">// `false`: if the acknowledgement is a duplicate.</span></div>
-<div class="line"><a name="l00830"></a><span class="lineno"> 830</span>  <span class="comment">// `Error`: Any errors (e.g., checkpointing).</span></div>
-<div class="line"><a name="l00831"></a><span class="lineno"> 831</span>  <a class="code" href="classTry.html">Try<bool></a> <a class="code" href="classmesos_1_1internal_1_1StatusUpdateManagerProcess.html#a9aa45e70ff97941eefdc582b410c1221">acknowledgement</a>(<span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">id::UUID</a>& statusUuid)</div>
-<div class="line"><a name="l00832"></a><span class="lineno"> 832</span>  {</div>
-<div class="line"><a name="l00833"></a><span class="lineno"> 833</span>  <span class="keywordflow">if</span> (<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>.isSome()) {</div>
-<div class="line"><a name="l00834"></a><span class="lineno"> 834</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>.get());</div>
-<div class="line"><a name="l00835"></a><span class="lineno"> 835</span>  }</div>
-<div class="line"><a name="l00836"></a><span class="lineno"> 836</span> </div>
-<div class="line"><a name="l00837"></a><span class="lineno"> 837</span>  <span class="comment">// Get the corresponding update for this ACK.</span></div>
-<div class="line"><a name="l00838"></a><span class="lineno"> 838</span>  <span class="keyword">const</span> <a class="code" href="classResult.html">Result<UpdateType></a>& update_ = next();</div>
-<div class="line"><a name="l00839"></a><span class="lineno"> 839</span>  <span class="keywordflow">if</span> (update_.<a class="code" href="classResult.html#aeca16ad17d299ad885c9b46c83b12a3d">isError</a>()) {</div>
-<div class="line"><a name="l00840"></a><span class="lineno"> 840</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(update_.<a class="code" href="classResult.html#a521adf96f5c27d26d6b1d580aae8aaee">error</a>());</div>
-<div class="line"><a name="l00841"></a><span class="lineno"> 841</span>  }</div>
-<div class="line"><a name="l00842"></a><span class="lineno"> 842</span> </div>
-<div class="line"><a name="l00843"></a><span class="lineno"> 843</span>  <span class="comment">// This might happen if we retried a status update and got back</span></div>
-<div class="line"><a name="l00844"></a><span class="lineno"> 844</span>  <span class="comment">// acknowledgments for both the original and the retried update.</span></div>
-<div class="line"><a name="l00845"></a><span class="lineno"> 845</span>  <span class="keywordflow">if</span> (update_.<a class="code" href="classResult.html#ac2cdc0db9f9d29a5bb2f1cf19c29da49">isNone</a>()) {</div>
-<div class="line"><a name="l00846"></a><span class="lineno"> 846</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(</div>
-<div class="line"><a name="l00847"></a><span class="lineno"> 847</span>  <span class="stringliteral">"Unexpected acknowledgment (UUID: "</span> + statusUuid.<a class="code" href="structid_1_1UUID.html#af024badbc379374ac635031eed57dc5f">toString</a>() +</div>
-<div class="line"><a name="l00848"></a><span class="lineno"> 848</span>  <span class="stringliteral">") for "</span> + statusUpdateType + <span class="stringliteral">" stream "</span> + <a class="code" href="namespacens.html#a28116b46e6543597a11733424cd1aa20">stringify</a>(streamId));</div>
-<div class="line"><a name="l00849"></a><span class="lineno"> 849</span>  }</div>
-<div class="line"><a name="l00850"></a><span class="lineno"> 850</span> </div>
-<div class="line"><a name="l00851"></a><span class="lineno"> 851</span>  <span class="keyword">const</span> UpdateType& update = update_.<a class="code" href="classResult.html#aedf79f3b14dcda5791b84a64ada4d412">get</a>();</div>
-<div class="line"><a name="l00852"></a><span class="lineno"> 852</span> </div>
-<div class="line"><a name="l00853"></a><span class="lineno"> 853</span>  <span class="keywordflow">if</span> (acknowledged.contains(statusUuid)) {</div>
-<div class="line"><a name="l00854"></a><span class="lineno"> 854</span>  LOG(WARNING) << <span class="stringliteral">"Duplicate acknowledgment for "</span> << statusUpdateType</div>
-<div class="line"><a name="l00855"></a><span class="lineno"> 855</span>  << <span class="stringliteral">" "</span> << <a class="code" href="classmesos_1_1internal_1_1StatusUpdateManagerProcess.html#a1658b4adb952dc5e20465e31d572633b">update</a>;</div>
-<div class="line"><a name="l00856"></a><span class="lineno"> 856</span>  <span class="keywordflow">return</span> <span class="keyword">false</span>;</div>
-<div class="line"><a name="l00857"></a><span class="lineno"> 857</span>  }</div>
-<div class="line"><a name="l00858"></a><span class="lineno"> 858</span> </div>
-<div class="line"><a name="l00859"></a><span class="lineno"> 859</span>  <span class="comment">// TODO(gkleiman): This won't work with `StatusUpdate`, because the field</span></div>
-<div class="line"><a name="l00860"></a><span class="lineno"> 860</span>  <span class="comment">// containing the status update uuid has a different name. In order to</span></div>
-<div class="line"><a name="l00861"></a><span class="lineno"> 861</span>  <span class="comment">// make the `TaskStatusUpdateManager` use this process, we should avoid</span></div>
-<div class="line"><a name="l00862"></a><span class="lineno"> 862</span>  <span class="comment">// depending on identical field names.</span></div>
-<div class="line"><a name="l00863"></a><span class="lineno"> 863</span>  <a class="code" href="classTry.html">Try<id::UUID></a> updateStatusUuid =</div>
-<div class="line"><a name="l00864"></a><span class="lineno"> 864</span>  <a class="code" href="structid_1_1UUID.html#afd66db1d29a4ee4be9c82581437dda74">id::UUID::fromBytes</a>(update.status().status_uuid().value());</div>
-<div class="line"><a name="l00865"></a><span class="lineno"> 865</span>  <a class="code" href="stout_2include_2stout_2check_8hpp.html#aee320e7c6e107071f4b85d4cc135a265">CHECK_SOME</a>(updateStatusUuid);</div>
-<div class="line"><a name="l00866"></a><span class="lineno"> 866</span> </div>
-<div class="line"><a name="l00867"></a><span class="lineno"> 867</span>  <span class="comment">// This might happen if we retried a status update and got back</span></div>
-<div class="line"><a name="l00868"></a><span class="lineno"> 868</span>  <span class="comment">// acknowledgments for both the original and the retried update.</span></div>
-<div class="line"><a name="l00869"></a><span class="lineno"> 869</span>  <span class="keywordflow">if</span> (statusUuid != updateStatusUuid.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>()) {</div>
-<div class="line"><a name="l00870"></a><span class="lineno"> 870</span>  LOG(WARNING) << <span class="stringliteral">"Unexpected "</span> << statusUpdateType</div>
-<div class="line"><a name="l00871"></a><span class="lineno"> 871</span>  << <span class="stringliteral">" acknowledgment (received "</span> << statusUuid</div>
-<div class="line"><a name="l00872"></a><span class="lineno"> 872</span>  << <span class="stringliteral">", expecting "</span> << updateStatusUuid.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>() << <span class="stringliteral">") for "</span></div>
-<div class="line"><a name="l00873"></a><span class="lineno"> 873</span>  << <a class="code" href="classmesos_1_1internal_1_1StatusUpdateManagerProcess.html#a1658b4adb952dc5e20465e31d572633b">update</a>;</div>
-<div class="line"><a name="l00874"></a><span class="lineno"> 874</span>  <span class="keywordflow">return</span> <span class="keyword">false</span>;</div>
-<div class="line"><a name="l00875"></a><span class="lineno"> 875</span>  }</div>
+<div class="line"><a name="l00792"></a><span class="lineno"> 792</span>  <span class="keywordflow">if</span> (!update.status().has_uuid()) {</div>
+<div class="line"><a name="l00793"></a><span class="lineno"> 793</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(<span class="stringliteral">"Status update is missing 'uuid'"</span>);</div>
+<div class="line"><a name="l00794"></a><span class="lineno"> 794</span>  }</div>
+<div class="line"><a name="l00795"></a><span class="lineno"> 795</span>  <a class="code" href="classTry.html">Try<id::UUID></a> uuid = <a class="code" href="structid_1_1UUID.html#afd66db1d29a4ee4be9c82581437dda74">id::UUID::fromBytes</a>(update.status().uuid().value());</div>
+<div class="line"><a name="l00796"></a><span class="lineno"> 796</span>  <a class="code" href="stout_2include_2stout_2check_8hpp.html#aee320e7c6e107071f4b85d4cc135a265">CHECK_SOME</a>(uuid);</div>
+<div class="line"><a name="l00797"></a><span class="lineno"> 797</span> </div>
+<div class="line"><a name="l00798"></a><span class="lineno"> 798</span>  <span class="comment">// Check that this status update has not already been acknowledged.</span></div>
+<div class="line"><a name="l00799"></a><span class="lineno"> 799</span>  <span class="keywordflow">if</span> (acknowledged.contains(uuid.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>())) {</div>
+<div class="line"><a name="l00800"></a><span class="lineno"> 800</span>  LOG(WARNING) << <span class="stringliteral">"Ignoring "</span> << statusUpdateType << <span class="stringliteral">" "</span> << update</div>
+<div class="line"><a name="l00801"></a><span class="lineno"> 801</span>  << <span class="stringliteral">" that has already been acknowledged"</span>;</div>
+<div class="line"><a name="l00802"></a><span class="lineno"> 802</span>  <span class="keywordflow">return</span> <span class="keyword">false</span>;</div>
+<div class="line"><a name="l00803"></a><span class="lineno"> 803</span>  }</div>
+<div class="line"><a name="l00804"></a><span class="lineno"> 804</span> </div>
+<div class="line"><a name="l00805"></a><span class="lineno"> 805</span>  <span class="comment">// Check that this update has not already been received.</span></div>
+<div class="line"><a name="l00806"></a><span class="lineno"> 806</span>  <span class="keywordflow">if</span> (received.contains(uuid.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>())) {</div>
+<div class="line"><a name="l00807"></a><span class="lineno"> 807</span>  LOG(WARNING) << <span class="stringliteral">"Ignoring duplicate "</span> << statusUpdateType << <span class="stringliteral">" "</span></div>
+<div class="line"><a name="l00808"></a><span class="lineno"> 808</span>  << <a class="code" href="classmesos_1_1internal_1_1StatusUpdateManagerProcess.html#a1658b4adb952dc5e20465e31d572633b">update</a>;</div>
+<div class="line"><a name="l00809"></a><span class="lineno"> 809</span>  <span class="keywordflow">return</span> <span class="keyword">false</span>;</div>
+<div class="line"><a name="l00810"></a><span class="lineno"> 810</span>  }</div>
+<div class="line"><a name="l00811"></a><span class="lineno"> 811</span> </div>
+<div class="line"><a name="l00812"></a><span class="lineno"> 812</span>  <span class="comment">// Handle the update, checkpointing if necessary.</span></div>
+<div class="line"><a name="l00813"></a><span class="lineno"> 813</span>  <a class="code" href="classTry.html">Try<Nothing></a> result = handle(update, CheckpointType::UPDATE);</div>
+<div class="line"><a name="l00814"></a><span class="lineno"> 814</span>  <span class="keywordflow">if</span> (result.<a class="code" href="classTry.html#a0b98f95163b8a38daafd1651b043a276">isError</a>()) {</div>
+<div class="line"><a name="l00815"></a><span class="lineno"> 815</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(result.<a class="code" href="classTry.html#aec4a11ddd3c036e889d90b7eb6258ba7">error</a>());</div>
+<div class="line"><a name="l00816"></a><span class="lineno"> 816</span>  }</div>
+<div class="line"><a name="l00817"></a><span class="lineno"> 817</span> </div>
+<div class="line"><a name="l00818"></a><span class="lineno"> 818</span>  <span class="keywordflow">return</span> <span class="keyword">true</span>;</div>
+<div class="line"><a name="l00819"></a><span class="lineno"> 819</span>  }</div>
+<div class="line"><a name="l00820"></a><span class="lineno"> 820</span> </div>
+<div class="line"><a name="l00821"></a><span class="lineno"> 821</span>  <span class="comment">// This function handles the ACK, checkpointing if necessary.</span></div>
+<div class="line"><a name="l00822"></a><span class="lineno"> 822</span>  <span class="comment">//</span></div>
+<div class="line"><a name="l00823"></a><span class="lineno"> 823</span>  <span class="comment">// Returns `true`: if the acknowledgement is successfully handled.</span></div>
+<div class="line"><a name="l00824"></a><span class="lineno"> 824</span>  <span class="comment">// `false`: if the acknowledgement is a duplicate.</span></div>
+<div class="line"><a name="l00825"></a><span class="lineno"> 825</span>  <span class="comment">// `Error`: Any errors (e.g., checkpointing).</span></div>
+<div class="line"><a name="l00826"></a><span class="lineno"> 826</span>  <a class="code" href="classTry.html">Try<bool></a> <a class="code" href="classmesos_1_1internal_1_1StatusUpdateManagerProcess.html#a9aa45e70ff97941eefdc582b410c1221">acknowledgement</a>(<span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">id::UUID</a>& uuid)</div>
+<div class="line"><a name="l00827"></a><span class="lineno"> 827</span>  {</div>
+<div class="line"><a name="l00828"></a><span class="lineno"> 828</span>  <span class="keywordflow">if</span> (<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>.isSome()) {</div>
+<div class="line"><a name="l00829"></a><span class="lineno"> 829</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>.get());</div>
+<div class="line"><a name="l00830"></a><span class="lineno"> 830</span>  }</div>
+<div class="line"><a name="l00831"></a><span class="lineno"> 831</span> </div>
+<div class="line"><a name="l00832"></a><span class="lineno"> 832</span>  <span class="comment">// Get the corresponding update for this ACK.</span></div>
+<div class="line"><a name="l00833"></a><span class="lineno"> 833</span>  <span class="keyword">const</span> <a class="code" href="classResult.html">Result<UpdateType></a>& update_ = next();</div>
+<div class="line"><a name="l00834"></a><span class="lineno"> 834</span>  <span class="keywordflow">if</span> (update_.<a class="code" href="classResult.html#aeca16ad17d299ad885c9b46c83b12a3d">isError</a>()) {</div>
+<div class="line"><a name="l00835"></a><span class="lineno"> 835</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(update_.<a class="code" href="classResult.html#a521adf96f5c27d26d6b1d580aae8aaee">error</a>());</div>
+<div class="line"><a name="l00836"></a><span class="lineno"> 836</span>  }</div>
+<div class="line"><a name="l00837"></a><span class="lineno"> 837</span> </div>
+<div class="line"><a name="l00838"></a><span class="lineno"> 838</span>  <span class="comment">// This might happen if we retried a status update and got back</span></div>
+<div class="line"><a name="l00839"></a><span class="lineno"> 839</span>  <span class="comment">// acknowledgments for both the original and the retried update.</span></div>
+<div class="line"><a name="l00840"></a><span class="lineno"> 840</span>  <span class="keywordflow">if</span> (update_.<a class="code" href="classResult.html#ac2cdc0db9f9d29a5bb2f1cf19c29da49">isNone</a>()) {</div>
+<div class="line"><a name="l00841"></a><span class="lineno"> 841</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(</div>
+<div class="line"><a name="l00842"></a><span class="lineno"> 842</span>  <span class="stringliteral">"Unexpected acknowledgment (UUID: "</span> + uuid.<a class="code" href="structid_1_1UUID.html#af024badbc379374ac635031eed57dc5f">toString</a>() +</div>
+<div class="line"><a name="l00843"></a><span class="lineno"> 843</span>  <span class="stringliteral">") for "</span> + statusUpdateType + <span class="stringliteral">" stream "</span> + <a class="code" href="namespacens.html#a28116b46e6543597a11733424cd1aa20">stringify</a>(streamId));</div>
+<div class="line"><a name="l00844"></a><span class="lineno"> 844</span>  }</div>
+<div class="line"><a name="l00845"></a><span class="lineno"> 845</span> </div>
+<div class="line"><a name="l00846"></a><span class="lineno"> 846</span>  <span class="keyword">const</span> UpdateType& update = update_.<a class="code" href="classResult.html#aedf79f3b14dcda5791b84a64ada4d412">get</a>();</div>
+<div class="line"><a name="l00847"></a><span class="lineno"> 847</span> </div>
+<div class="line"><a name="l00848"></a><span class="lineno"> 848</span>  <span class="keywordflow">if</span> (acknowledged.contains(uuid)) {</div>
+<div class="line"><a name="l00849"></a><span class="lineno"> 849</span>  LOG(WARNING) << <span class="stringliteral">"Duplicate acknowledgment for "</span> << statusUpdateType</div>
+<div class="line"><a name="l00850"></a><span class="lineno"> 850</span>  << <span class="stringliteral">" "</span> << <a class="code" href="classmesos_1_1internal_1_1StatusUpdateManagerProcess.html#a1658b4adb952dc5e20465e31d572633b">update</a>;</div>
+<div class="line"><a name="l00851"></a><span class="lineno"> 851</span>  <span class="keywordflow">return</span> <span class="keyword">false</span>;</div>
+<div class="line"><a name="l00852"></a><span class="lineno"> 852</span>  }</div>
+<div class="line"><a name="l00853"></a><span class="lineno"> 853</span> </div>
+<div class="line"><a name="l00854"></a><span class="lineno"> 854</span>  <a class="code" href="classTry.html">Try<id::UUID></a> updateUuid =</div>
+<div class="line"><a name="l00855"></a><span class="lineno"> 855</span>  <a class="code" href="structid_1_1UUID.html#afd66db1d29a4ee4be9c82581437dda74">id::UUID::fromBytes</a>(update.status().uuid().value());</div>
+<div class="line"><a name="l00856"></a><span class="lineno"> 856</span>  <a class="code" href="stout_2include_2stout_2check_8hpp.html#aee320e7c6e107071f4b85d4cc135a265">CHECK_SOME</a>(updateUuid);</div>
+<div class="line"><a name="l00857"></a><span class="lineno"> 857</span> </div>
+<div class="line"><a name="l00858"></a><span class="lineno"> 858</span>  <span class="comment">// This might happen if we retried a status update and got back</span></div>
+<div class="line"><a name="l00859"></a><span class="lineno"> 859</span>  <span class="comment">// acknowledgments for both the original and the retried update.</span></div>
+<div class="line"><a name="l00860"></a><span class="lineno"> 860</span>  <span class="keywordflow">if</span> (uuid != updateUuid.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>()) {</div>
+<div class="line"><a name="l00861"></a><span class="lineno"> 861</span>  LOG(WARNING) << <span class="stringliteral">"Unexpected "</span> << statusUpdateType</div>
+<div class="line"><a name="l00862"></a><span class="lineno"> 862</span>  << <span class="stringliteral">" acknowledgment (received "</span> << uuid</div>
+<div class="line"><a name="l00863"></a><span class="lineno"> 863</span>  << <span class="stringliteral">", expecting "</span> << updateUuid.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>() << <span class="stringliteral">") for "</span></div>
+<div class="line"><a name="l00864"></a><span class="lineno"> 864</span>  << <a class="code" href="classmesos_1_1internal_1_1StatusUpdateManagerProcess.html#a1658b4adb952dc5e20465e31d572633b">update</a>;</div>
+<div class="line"><a name="l00865"></a><span class="lineno"> 865</span>  <span class="keywordflow">return</span> <span class="keyword">false</span>;</div>
+<div class="line"><a name="l00866"></a><span class="lineno"> 866</span>  }</div>
+<div class="line"><a name="l00867"></a><span class="lineno"> 867</span> </div>
+<div class="line"><a name="l00868"></a><span class="lineno"> 868</span>  <span class="comment">// Handle the ACK, checkpointing if necessary.</span></div>
+<div class="line"><a name="l00869"></a><span class="lineno"> 869</span>  <a class="code" href="classTry.html">Try<Nothing></a> result = handle(update, CheckpointType::ACK);</div>
+<div class="line"><a name="l00870"></a><span class="lineno"> 870</span>  <span class="keywordflow">if</span> (result.<a class="code" href="classTry.html#a0b98f95163b8a38daafd1651b043a276">isError</a>()) {</div>
+<div class="line"><a name="l00871"></a><span class="lineno"> 871</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(result.<a class="code" href="classTry.html#aec4a11ddd3c036e889d90b7eb6258ba7">error</a>());</div>
+<div class="line"><a name="l00872"></a><span class="lineno"> 872</span>  }</div>
+<div class="line"><a name="l00873"></a><span class="lineno"> 873</span> </div>
+<div class="line"><a name="l00874"></a><span class="lineno"> 874</span>  <span class="keywordflow">return</span> <span class="keyword">true</span>;</div>
+<div class="line"><a name="l00875"></a><span class="lineno"> 875</span>  }</div>
<div class="line"><a name="l00876"></a><span class="lineno"> 876</span> </div>
-<div class="line"><a name="l00877"></a><span class="lineno"> 877</span>  <span class="comment">// Handle the ACK, checkpointing if necessary.</span></div>
-<div class="line"><a name="l00878"></a><span class="lineno"> 878</span>  <a class="code" href="classTry.html">Try<Nothing></a> result = handle(update, CheckpointType::ACK);</div>
-<div class="line"><a name="l00879"></a><span class="lineno"> 879</span>  <span class="keywordflow">if</span> (result.<a class="code" href="classTry.html#a0b98f95163b8a38daafd1651b043a276">isError</a>()) {</div>
-<div class="line"><a name="l00880"></a><span class="lineno"> 880</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(result.<a class="code" href="classTry.html#aec4a11ddd3c036e889d90b7eb6258ba7">error</a>());</div>
-<div class="line"><a name="l00881"></a><span class="lineno"> 881</span>  }</div>
-<div class="line"><a name="l00882"></a><span class="lineno"> 882</span> </div>
-<div class="line"><a name="l00883"></a><span class="lineno"> 883</span>  <span class="keywordflow">return</span> <span class="keyword">true</span>;</div>
-<div class="line"><a name="l00884"></a><span class="lineno"> 884</span>  }</div>
-<div class="line"><a name="l00885"></a><span class="lineno"> 885</span> </div>
-<div class="line"><a name="l00886"></a><span class="lineno"> 886</span>  <span class="comment">// Returns the next update (or none, if empty) in the queue.</span></div>
-<div class="line"><a name="l00887"></a><span class="lineno"> 887</span>  <a class="code" href="classResult.html">Result<UpdateType></a> next()</div>
-<div class="line"><a name="l00888"></a><span class="lineno"> 888</span>  {</div>
-<div class="line"><a name="l00889"></a><span class="lineno"> 889</span>  <span class="keywordflow">if</span> (<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>.isSome()) {</div>
-<div class="line"><a name="l00890"></a><span class="lineno"> 890</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>.get());</div>
-<div class="line"><a name="l00891"></a><span class="lineno"> 891</span>  }</div>
-<div class="line"><a name="l00892"></a><span class="lineno"> 892</span> </div>
-<div class="line"><a name="l00893"></a><span class="lineno"> 893</span>  <span class="keywordflow">if</span> (!<a class="code" href="namespaceos_1_1signals.html#a712c95e437c6ae6caa6fbc6dcce30f26">pending</a>.empty()) {</div>
-<div class="line"><a name="l00894"></a><span class="lineno"> 894</span>  <span class="keywordflow">return</span> <a class="code" href="namespaceos_1_1signals.html#a712c95e437c6ae6caa6fbc6dcce30f26">pending</a>.front();</div>
-<div class="line"><a name="l00895"></a><span class="lineno"> 895</span>  }</div>
-<div class="line"><a name="l00896"></a><span class="lineno"> 896</span> </div>
-<div class="line"><a name="l00897"></a><span class="lineno"> 897</span>  <span class="keywordflow">return</span> <a class="code" href="structNone.html">None</a>();</div>
-<div class="line"><a name="l00898"></a><span class="lineno"> 898</span>  }</div>
-<div class="line"><a name="l00899"></a><span class="lineno"> 899</span> </div>
-<div class="line"><a name="l00900"></a><span class="lineno"> 900</span>  <span class="comment">// Returns `true` if the stream is checkpointed, `false` otherwise.</span></div>
-<div class="line"><a name="l00901"></a><span class="lineno"> 901</span>  <span class="keywordtype">bool</span> checkpointed() { <span class="keywordflow">return</span> path.isSome(); }</div>
-<div class="line"><a name="l00902"></a><span class="lineno"> 902</span> </div>
-<div class="line"><a name="l00903"></a><span class="lineno"> 903</span>  <span class="keyword">const</span> IDType streamId;</div>
-<div class="line"><a name="l00904"></a><span class="lineno"> 904</span> </div>
-<div class="line"><a name="l00905"></a><span class="lineno"> 905</span>  <span class="keywordtype">bool</span> terminated;</div>
-<div class="line"><a name="l00906"></a><span class="lineno"> 906</span>  <a class="code" href="classOption.html">Option<FrameworkID></a> frameworkId;</div>
-<div class="line"><a name="l00907"></a><span class="lineno"> 907</span>  <a class="code" href="classOption.html">Option<process::Timeout></a> timeout; <span class="comment">// Timeout for resending status update.</span></div>
-<div class="line"><a name="l00908"></a><span class="lineno"> 908</span>  std::queue<UpdateType> <a class="code" href="namespaceos_1_1signals.html#a712c95e437c6ae6caa6fbc6dcce30f26">pending</a>;</div>
-<div class="line"><a name="l00909"></a><span class="lineno"> 909</span> </div>
-<div class="line"><a name="l00910"></a><span class="lineno"> 910</span>  <span class="keyword">private</span>:</div>
-<div class="line"><a name="l00911"></a><span class="lineno"> 911</span>  StatusUpdateStream(</div>
-<div class="line"><a name="l00912"></a><span class="lineno"> 912</span>  <span class="keyword">const</span> std::string& _statusUpdateType,</div>
-<div class="line"><a name="l00913"></a><span class="lineno"> 913</span>  <span class="keyword">const</span> IDType& _streamId,</div>
-<div class="line"><a name="l00914"></a><span class="lineno"> 914</span>  <span class="keyword">const</span> <a class="code" href="classOption.html">Option<std::string></a>& _path,</div>
-<div class="line"><a name="l00915"></a><span class="lineno"> 915</span>  <a class="code" href="classOption.html">Option<int_fd></a> _fd)</div>
-<div class="line"><a name="l00916"></a><span class="lineno"> 916</span>  : streamId(_streamId),</div>
-<div class="line"><a name="l00917"></a><span class="lineno"> 917</span>  terminated(false),</div>
-<div class="line"><a name="l00918"></a><span class="lineno"> 918</span>  statusUpdateType(_statusUpdateType),</div>
-<div class="line"><a name="l00919"></a><span class="lineno"> 919</span>  path(_path),</div>
-<div class="line"><a name="l00920"></a><span class="lineno"> 920</span>  fd(_fd) {}</div>
-<div class="line"><a name="l00921"></a><span class="lineno"> 921</span> </div>
-<div class="line"><a name="l00922"></a><span class="lineno"> 922</span>  <span class="comment">// Handles the status update and writes it to disk, if necessary.</span></div>
-<div class="line"><a name="l00923"></a><span class="lineno"> 923</span>  <span class="comment">//</span></div>
-<div class="line"><a name="l00924"></a><span class="lineno"> 924</span>  <span class="comment">// TODO(vinod): The write has to be asynchronous to avoid status updates</span></div>
-<div class="line"><a name="l00925"></a><span class="lineno"> 925</span>  <span class="comment">// that are being checkpointed, blocking the processing of other updates.</span></div>
-<div class="line"><a name="l00926"></a><span class="lineno"> 926</span>  <span class="comment">// One solution is to wrap the protobuf::write inside async, but it's</span></div>
-<div class="line"><a name="l00927"></a><span class="lineno"> 927</span>  <span class="comment">// probably too much of an overhead to spin up a new libprocess per status</span></div>
-<div class="line"><a name="l00928"></a><span class="lineno"> 928</span>  <span class="comment">// update?</span></div>
-<div class="line"><a name="l00929"></a><span class="lineno"> 929</span>  <span class="comment">// A better solution might be to be have async write capability for file IO.</span></div>
-<div class="line"><a name="l00930"></a><span class="lineno"> 930</span>  <a class="code" href="classTry.html">Try<Nothing></a> handle(</div>
-<div class="line"><a name="l00931"></a><span class="lineno"> 931</span>  <span class="keyword">const</span> UpdateType& update,</div>
-<div class="line"><a name="l00932"></a><span class="lineno"> 932</span>  <span class="keyword">const</span> <span class="keyword">typename</span> <a class="code" href="namespacemesos_1_1internal_1_1capabilities.html#aaa5ec6d56ccbeba718b9e8fc6ec2f7c9">CheckpointType::Type</a>& <a class="code" href="namespacemesos_1_1internal_1_1fs.html#a2343e2642db514496ba8380776487fba">type</a>)</div>
-<div class="line"><a name="l00933"></a><span class="lineno"> 933</span>  {</div>
-<div class="line"><a name="l00934"></a><span class="lineno"> 934</span>  <a class="code" href="stout_2include_2stout_2check_8hpp.html#ab8738e43a60086f3b434c0278933e85e">CHECK_NONE</a>(<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>);</div>
-<div class="line"><a name="l00935"></a><span class="lineno"> 935</span> </div>
-<div class="line"><a name="l00936"></a><span class="lineno"> 936</span>  <span class="comment">// Checkpoint the update if necessary.</span></div>
-<div class="line"><a name="l00937"></a><span class="lineno"> 937</span>  <span class="keywordflow">if</span> (checkpointed()) {</div>
-<div class="line"><a name="l00938"></a><span class="lineno"> 938</span>  LOG(INFO) << <span class="stringliteral">"Checkpointing "</span> << type << <span class="stringliteral">" for "</span> << statusUpdateType</div>
-<div class="line"><a name="l00939"></a><span class="lineno"> 939</span>  << <span class="stringliteral">" "</span> << <a class="code" href="classmesos_1_1internal_1_1StatusUpdateManagerProcess.html#a1658b4adb952dc5e20465e31d572633b">update</a>;</div>
-<div class="line"><a name="l00940"></a><span class="lineno"> 940</span> </div>
-<div class="line"><a name="l00941"></a><span class="lineno"> 941</span>  <a class="code" href="stout_2include_2stout_2check_8hpp.html#aee320e7c6e107071f4b85d4cc135a265">CHECK_SOME</a>(fd);</div>
-<div class="line"><a name="l00942"></a><span class="lineno"> 942</span> </div>
-<div class="line"><a name="l00943"></a><span class="lineno"> 943</span>  CheckpointType record;</div>
-<div class="line"><a name="l00944"></a><span class="lineno"> 944</span>  record.set_type(type);</div>
+<div class="line"><a name="l00877"></a><span class="lineno"> 877</span>  <span class="comment">// Returns the next update (or none, if empty) in the queue.</span></div>
+<div class="line"><a name="l00878"></a><span class="lineno"> 878</span>  <a class="code" href="classResult.html">Result<UpdateType></a> next()</div>
+<div class="line"><a name="l00879"></a><span class="lineno"> 879</span>  {</div>
+<div class="line"><a name="l00880"></a><span class="lineno"> 880</span>  <span class="keywordflow">if</span> (<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>.isSome()) {</div>
+<div class="line"><a name="l00881"></a><span class="lineno"> 881</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>.get());</div>
+<div class="line"><a name="l00882"></a><span class="lineno"> 882</span>  }</div>
+<div class="line"><a name="l00883"></a><span class="lineno"> 883</span> </div>
+<div class="line"><a name="l00884"></a><span class="lineno"> 884</span>  <span class="keywordflow">if</span> (!<a class="code" href="namespaceos_1_1signals.html#a712c95e437c6ae6caa6fbc6dcce30f26">pending</a>.empty()) {</div>
+<div class="line"><a name="l00885"></a><span class="lineno"> 885</span>  <span class="keywordflow">return</span> <a class="code" href="namespaceos_1_1signals.html#a712c95e437c6ae6caa6fbc6dcce30f26">pending</a>.front();</div>
+<div class="line"><a name="l00886"></a><span class="lineno"> 886</span>  }</div>
+<div class="line"><a name="l00887"></a><span class="lineno"> 887</span> </div>
+<div class="line"><a name="l00888"></a><span class="lineno"> 888</span>  <span class="keywordflow">return</span> <a class="code" href="structNone.html">None</a>();</div>
+<div class="line"><a name="l00889"></a><span class="lineno"> 889</span>  }</div>
+<div class="line"><a name="l00890"></a><span class="lineno"> 890</span> </div>
+<div class="line"><a name="l00891"></a><span class="lineno"> 891</span>  <span class="comment">// Returns `true` if the stream is checkpointed, `false` otherwise.</span></div>
+<div class="line"><a name="l00892"></a><span class="lineno"> 892</span>  <span class="keywordtype">bool</span> checkpointed() { <span class="keywordflow">return</span> path.isSome(); }</div>
+<div class="line"><a name="l00893"></a><span class="lineno"> 893</span> </div>
+<div class="line"><a name="l00894"></a><span class="lineno"> 894</span>  <span class="keyword">const</span> IDType streamId;</div>
+<div class="line"><a name="l00895"></a><span class="lineno"> 895</span> </div>
+<div class="line"><a name="l00896"></a><span class="lineno"> 896</span>  <span class="keywordtype">bool</span> terminated;</div>
+<div class="line"><a name="l00897"></a><span class="lineno"> 897</span>  <a class="code" href="classOption.html">Option<FrameworkID></a> frameworkId;</div>
+<div class="line"><a name="l00898"></a><span class="lineno"> 898</span>  <a class="code" href="classOption.html">Option<process::Timeout></a> timeout; <span class="comment">// Timeout for resending status update.</span></div>
+<div class="line"><a name="l00899"></a><span class="lineno"> 899</span>  std::queue<UpdateType> <a class="code" href="namespaceos_1_1signals.html#a712c95e437c6ae6caa6fbc6dcce30f26">pending</a>;</div>
+<div class="line"><a name="l00900"></a><span class="lineno"> 900</span> </div>
+<div class="line"><a name="l00901"></a><span class="lineno"> 901</span>  <span class="keyword">private</span>:</div>
+<div class="line"><a name="l00902"></a><span class="lineno"> 902</span>  StatusUpdateStream(</div>
+<div class="line"><a name="l00903"></a><span class="lineno"> 903</span>  <span class="keyword">const</span> std::string& _statusUpdateType,</div>
+<div class="line"><a name="l00904"></a><span class="lineno"> 904</span>  <span class="keyword">const</span> IDType& _streamId,</div>
+<div class="line"><a name="l00905"></a><span class="lineno"> 905</span>  <span class="keyword">const</span> <a class="code" href="classOption.html">Option<std::string></a>& _path,</div>
+<div class="line"><a name="l00906"></a><span class="lineno"> 906</span>  <a class="code" href="classOption.html">Option<int_fd></a> _fd)</div>
+<div class="line"><a name="l00907"></a><span class="lineno"> 907</span>  : streamId(_streamId),</div>
+<div class="line"><a name="l00908"></a><span class="lineno"> 908</span>  terminated(false),</div>
+<div class="line"><a name="l00909"></a><span class="lineno"> 909</span>  statusUpdateType(_statusUpdateType),</div>
+<div class="line"><a name="l00910"></a><span class="lineno"> 910</span>  path(_path),</div>
+<div class="line"><a name="l00911"></a><span class="lineno"> 911</span>  fd(_fd) {}</div>
+<div class="line"><a name="l00912"></a><span class="lineno"> 912</span> </div>
+<div class="line"><a name="l00913"></a><span class="lineno"> 913</span>  <span class="comment">// Handles the status update and writes it to disk, if necessary.</span></div>
+<div class="line"><a name="l00914"></a><span class="lineno"> 914</span>  <span class="comment">//</span></div>
+<div class="line"><a name="l00915"></a><span class="lineno"> 915</span>  <span class="comment">// TODO(vinod): The write has to be asynchronous to avoid status updates</span></div>
+<div class="line"><a name="l00916"></a><span class="lineno"> 916</span>  <span class="comment">// that are being checkpointed, blocking the processing of other updates.</span></div>
+<div class="line"><a name="l00917"></a><span class="lineno"> 917</span>  <span class="comment">// One solution is to wrap the protobuf::write inside async, but it's</span></div>
+<div class="line"><a name="l00918"></a><span class="lineno"> 918</span>  <span class="comment">// probably too much of an overhead to spin up a new libprocess per status</span></div>
+<div class="line"><a name="l00919"></a><span class="lineno"> 919</span>  <span class="comment">// update?</span></div>
+<div class="line"><a name="l00920"></a><span class="lineno"> 920</span>  <span class="comment">// A better solution might be to be have async write capability for file IO.</span></div>
+<div class="line"><a name="l00921"></a><span class="lineno"> 921</span>  <a class="code" href="classTry.html">Try<Nothing></a> handle(</div>
+<div class="line"><a name="l00922"></a><span class="lineno"> 922</span>  <span class="keyword">const</span> UpdateType& update,</div>
+<div class="line"><a name="l00923"></a><span class="lineno"> 923</span>  <span class="keyword">const</span> <span class="keyword">typename</span> <a class="code" href="namespacemesos_1_1internal_1_1capabilities.html#aaa5ec6d56ccbeba718b9e8fc6ec2f7c9">CheckpointType::Type</a>& <a class="code" href="namespacemesos_1_1internal_1_1fs.html#a2343e2642db514496ba8380776487fba">type</a>)</div>
+<div class="line"><a name="l00924"></a><span class="lineno"> 924</span>  {</div>
+<div class="line"><a name="l00925"></a><span class="lineno"> 925</span>  <a class="code" href="stout_2include_2stout_2check_8hpp.html#ab8738e43a60086f3b434c0278933e85e">CHECK_NONE</a>(<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>);</div>
+<div class="line"><a name="l00926"></a><span class="lineno"> 926</span> </div>
+<div class="line"><a name="l00927"></a><span class="lineno"> 927</span>  <span class="comment">// Checkpoint the update if necessary.</span></div>
+<div class="line"><a name="l00928"></a><span class="lineno"> 928</span>  <span class="keywordflow">if</span> (checkpointed()) {</div>
+<div class="line"><a name="l00929"></a><span class="lineno"> 929</span>  LOG(INFO) << <span class="stringliteral">"Checkpointing "</span> << type << <span class="stringliteral">" for "</span> << statusUpdateType</div>
+<div class="line"><a name="l00930"></a><span class="lineno"> 930</span>  << <span class="stringliteral">" "</span> << <a class="code" href="classmesos_1_1internal_1_1StatusUpdateManagerProcess.html#a1658b4adb952dc5e20465e31d572633b">update</a>;</div>
+<div class="line"><a name="l00931"></a><span class="lineno"> 931</span> </div>
+<div class="line"><a name="l00932"></a><span class="lineno"> 932</span>  <a class="code" href="stout_2include_2stout_2check_8hpp.html#aee320e7c6e107071f4b85d4cc135a265">CHECK_SOME</a>(fd);</div>
+<div class="line"><a name="l00933"></a><span class="lineno"> 933</span> </div>
+<div class="line"><a name="l00934"></a><span class="lineno"> 934</span>  CheckpointType record;</div>
+<div class="line"><a name="l00935"></a><span class="lineno"> 935</span>  record.set_type(type);</div>
+<div class="line"><a name="l00936"></a><span class="lineno"> 936</span> </div>
+<div class="line"><a name="l00937"></a><span class="lineno"> 937</span>  <span class="keywordflow">switch</span> (type) {</div>
+<div class="line"><a name="l00938"></a><span class="lineno"> 938</span>  <span class="keywordflow">case</span> CheckpointType::UPDATE:</div>
+<div class="line"><a name="l00939"></a><span class="lineno"> 939</span>  record.mutable_update()->CopyFrom(update);</div>
+<div class="line"><a name="l00940"></a><span class="lineno"> 940</span>  <span class="keywordflow">break</span>;</div>
+<div class="line"><a name="l00941"></a><span class="lineno"> 941</span>  <span class="keywordflow">case</span> CheckpointType::ACK:</div>
+<div class="line"><a name="l00942"></a><span class="lineno"> 942</span>  record.mutable_uuid()->CopyFrom(update.status().uuid());</div>
+<div class="line"><a name="l00943"></a><span class="lineno"> 943</span>  <span class="keywordflow">break</span>;</div>
+<div class="line"><a name="l00944"></a><span class="lineno"> 944</span>  }</div>
<div class="line"><a name="l00945"></a><span class="lineno"> 945</span> </div>
-<div class="line"><a name="l00946"></a><span class="lineno"> 946</span>  <span class="keywordflow">switch</span> (type) {</div>
-<div class="line"><a name="l00947"></a><span class="lineno"> 947</span>  <span class="keywordflow">case</span> CheckpointType::UPDATE:</div>
-<div class="line"><a name="l00948"></a><span class="lineno"> 948</span>  record.mutable_update()->CopyFrom(update);</div>
-<div class="line"><a name="l00949"></a><span class="lineno"> 949</span>  <span class="keywordflow">break</span>;</div>
-<div class="line"><a name="l00950"></a><span class="lineno"> 950</span>  <span class="keywordflow">case</span> CheckpointType::ACK:</div>
-<div class="line"><a name="l00951"></a><span class="lineno"> 951</span>  <span class="comment">// TODO(gkleiman): This won't work with `StatusUpdate`, because the</span></div>
-<div class="line"><a name="l00952"></a><span class="lineno"> 952</span>  <span class="comment">// field containing the status update uuid has a different name.</span></div>
-<div class="line"><a name="l00953"></a><span class="lineno"> 953</span>  <span class="comment">// In order to make the `TaskStatusUpdateManager` use this process,</span></div>
-<div class="line"><a name="l00954"></a><span class="lineno"> 954</span>  <span class="comment">// we should avoid depending on identical field names.</span></div>
-<div class="line"><a name="l00955"></a><span class="lineno"> 955</span>  record.mutable_uuid()->CopyFrom(update.status().status_uuid());</div>
-<div class="line"><a name="l00956"></a><span class="lineno"> 956</span>  <span class="keywordflow">break</span>;</div>
-<div class="line"><a name="l00957"></a><span class="lineno"> 957</span>  }</div>
-<div class="line"><a name="l00958"></a><span class="lineno"> 958</span> </div>
-<div class="line"><a name="l00959"></a><span class="lineno"> 959</span>  <a class="code" href="classTry.html">Try<Nothing></a> <a class="code" href="namespacemesos_1_1internal_1_1log_1_1protocol.html#a66ff2d5af4db53227f787281c0765d8d">write</a> = <a class="code" href="namespacemesos_1_1internal_1_1log_1_1protocol.html#a66ff2d5af4db53227f787281c0765d8d">::protobuf::write</a>(fd.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>(), record);</div>
-<div class="line"><a name="l00960"></a><span class="lineno"> 960</span>  <span class="keywordflow">if</span> (write.<a class="code" href="classTry.html#a0b98f95163b8a38daafd1651b043a276">isError</a>()) {</div>
-<div class="line"><a name="l00961"></a><span class="lineno"> 961</span>  <a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a> =</div>
-<div class="line"><a name="l00962"></a><span class="lineno"> 962</span>  <span class="stringliteral">"Failed to write to file '"</span> + path.get() + <span class="stringliteral">"': "</span> + write.<a class="code" href="classTry.html#aec4a11ddd3c036e889d90b7eb6258ba7">error</a>();</div>
-<div class="line"><a name="l00963"></a><span class="lineno"> 963</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>.get());</div>
-<div class="line"><a name="l00964"></a><span class="lineno"> 964</span>  }</div>
-<div class="line"><a name="l00965"></a><span class="lineno"> 965</span>  }</div>
-<div class="line"><a name="l00966"></a><span class="lineno"> 966</span> </div>
-<div class="line"><a name="l00967"></a><span class="lineno"> 967</span>  <span class="comment">// Now actually handle the update.</span></div>
-<div class="line"><a name="l00968"></a><span class="lineno"> 968</span>  _handle(update, type);</div>
-<div class="line"><a name="l00969"></a><span class="lineno"> 969</span> </div>
-<div class="line"><a name="l00970"></a><span class="lineno"> 970</span>  <span class="keywordflow">return</span> <a class="code" href="structNothing.html">Nothing</a>();</div>
-<div class="line"><a name="l00971"></a><span class="lineno"> 971</span>  }</div>
-<div class="line"><a name="l00972"></a><span class="lineno"> 972</span> </div>
-<div class="line"><a name="l00973"></a><span class="lineno"> 973</span> </div>
-<div class="line"><a name="l00974"></a><span class="lineno"> 974</span>  <span class="comment">// Handles the status update without checkpointing.</span></div>
-<div class="line"><a name="l00975"></a><span class="lineno"> 975</span>  <span class="keywordtype">void</span> _handle(</div>
-<div class="line"><a name="l00976"></a><span class="lineno"> 976</span>  <span class="keyword">const</span> UpdateType& update,</div>
-<div class="line"><a name="l00977"></a><span class="lineno"> 977</span>  <span class="keyword">const</span> <span class="keyword">typename</span> <a class="code" href="namespacemesos_1_1internal_1_1capabilities.html#aaa5ec6d56ccbeba718b9e8fc6ec2f7c9">CheckpointType::Type</a>& type)</div>
-<div class="line"><a name="l00978"></a><span class="lineno"> 978</span>  {</div>
-<div class="line"><a name="l00979"></a><span class="lineno"> 979</span>  <a class="code" href="stout_2include_2stout_2check_8hpp.html#ab8738e43a60086f3b434c0278933e85e">CHECK_NONE</a>(<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>);</div>
-<div class="line"><a name="l00980"></a><span class="lineno"> 980</span> </div>
-<div class="line"><a name="l00981"></a><span class="lineno"> 981</span>  <span class="comment">// TODO(gkleiman): This won't work with `StatusUpdate`, because the field</span></div>
-<div class="line"><a name="l00982"></a><span class="lineno"> 982</span>  <span class="comment">// containing the status update uuid has a different name. In order to</span></div>
-<div class="line"><a name="l00983"></a><span class="lineno"> 983</span>  <span class="comment">// make the `TaskStatusUpdateManager` use this process, we should avoid</span></div>
-<div class="line"><a name="l00984"></a><span class="lineno"> 984</span>  <span class="comment">// depending on identical field names.</span></div>
-<div class="line"><a name="l00985"></a><span class="lineno"> 985</span>  <a class="code" href="classTry.html">Try<id::UUID></a> statusUuid =</div>
-<div class="line"><a name="l00986"></a><span class="lineno"> 986</span>  <a class="code" href="structid_1_1UUID.html#afd66db1d29a4ee4be9c82581437dda74">id::UUID::fromBytes</a>(update.status().status_uuid().value());</div>
-<div class="line"><a name="l00987"></a><span class="lineno"> 987</span>  <a class="code" href="stout_2include_2stout_2check_8hpp.html#aee320e7c6e107071f4b85d4cc135a265">CHECK_SOME</a>(statusUuid);</div>
-<div class="line"><a name="l00988"></a><span class="lineno"> 988</span> </div>
-<div class="line"><a name="l00989"></a><span class="lineno"> 989</span>  <span class="keywordflow">switch</span> (type) {</div>
-<div class="line"><a name="l00990"></a><span class="lineno"> 990</span>  <span class="keywordflow">case</span> CheckpointType::UPDATE:</div>
-<div class="line"><a name="l00991"></a><span class="lineno"> 991</span>  <span class="keywordflow">if</span> (update.has_framework_id()) {</div>
-<div class="line"><a name="l00992"></a><span class="lineno"> 992</span>  frameworkId = update.framework_id();</div>
-<div class="line"><a name="l00993"></a><span class="lineno"> 993</span>  }</div>
+<div class="line"><a name="l00946"></a><span class="lineno"> 946</span>  <a class="code" href="classTry.html">Try<Nothing></a> <a class="code" href="namespacemesos_1_1internal_1_1log_1_1protocol.html#a66ff2d5af4db53227f787281c0765d8d">write</a> = <a class="code" href="namespacemesos_1_1internal_1_1log_1_1protocol.html#a66ff2d5af4db53227f787281c0765d8d">::protobuf::write</a>(fd.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>(), record);</div>
+<div class="line"><a name="l00947"></a><span class="lineno"> 947</span>  <span class="keywordflow">if</span> (write.<a class="code" href="classTry.html#a0b98f95163b8a38daafd1651b043a276">isError</a>()) {</div>
+<div class="line"><a name="l00948"></a><span class="lineno"> 948</span>  <a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a> =</div>
+<div class="line"><a name="l00949"></a><span class="lineno"> 949</span>  <span class="stringliteral">"Failed to write to file '"</span> + path.get() + <span class="stringliteral">"': "</span> + write.<a class="code" href="classTry.html#aec4a11ddd3c036e889d90b7eb6258ba7">error</a>();</div>
+<div class="line"><a name="l00950"></a><span class="lineno"> 950</span>  <span class="keywordflow">return</span> <a class="code" href="classError.html">Error</a>(<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>.get());</div>
+<div class="line"><a name="l00951"></a><span class="lineno"> 951</span>  }</div>
+<div class="line"><a name="l00952"></a><span class="lineno"> 952</span>  }</div>
+<div class="line"><a name="l00953"></a><span class="lineno"> 953</span> </div>
+<div class="line"><a name="l00954"></a><span class="lineno"> 954</span>  <span class="comment">// Now actually handle the update.</span></div>
+<div class="line"><a name="l00955"></a><span class="lineno"> 955</span>  _handle(update, type);</div>
+<div class="line"><a name="l00956"></a><span class="lineno"> 956</span> </div>
+<div class="line"><a name="l00957"></a><span class="lineno"> 957</span>  <span class="keywordflow">return</span> <a class="code" href="structNothing.html">Nothing</a>();</div>
+<div class="line"><a name="l00958"></a><span class="lineno"> 958</span>  }</div>
+<div class="line"><a name="l00959"></a><span class="lineno"> 959</span> </div>
+<div class="line"><a name="l00960"></a><span class="lineno"> 960</span> </div>
+<div class="line"><a name="l00961"></a><span class="lineno"> 961</span>  <span class="comment">// Handles the status update without checkpointing.</span></div>
+<div class="line"><a name="l00962"></a><span class="lineno"> 962</span>  <span class="keywordtype">void</span> _handle(</div>
+<div class="line"><a name="l00963"></a><span class="lineno"> 963</span>  <span class="keyword">const</span> UpdateType& update,</div>
+<div class="line"><a name="l00964"></a><span class="lineno"> 964</span>  <span class="keyword">const</span> <span class="keyword">typename</span> <a class="code" href="namespacemesos_1_1internal_1_1capabilities.html#aaa5ec6d56ccbeba718b9e8fc6ec2f7c9">CheckpointType::Type</a>& type)</div>
+<div class="line"><a name="l00965"></a><span class="lineno"> 965</span>  {</div>
+<div class="line"><a name="l00966"></a><span class="lineno"> 966</span>  <a class="code" href="stout_2include_2stout_2check_8hpp.html#ab8738e43a60086f3b434c0278933e85e">CHECK_NONE</a>(<a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>);</div>
+<div class="line"><a name="l00967"></a><span class="lineno"> 967</span> </div>
+<div class="line"><a name="l00968"></a><span class="lineno"> 968</span>  <a class="code" href="classTry.html">Try<id::UUID></a> uuid = <a class="code" href="structid_1_1UUID.html#afd66db1d29a4ee4be9c82581437dda74">id::UUID::fromBytes</a>(update.status().uuid().value());</div>
+<div class="line"><a name="l00969"></a><span class="lineno"> 969</span>  <a class="code" href="stout_2include_2stout_2check_8hpp.html#aee320e7c6e107071f4b85d4cc135a265">CHECK_SOME</a>(uuid);</div>
+<div class="line"><a name="l00970"></a><span class="lineno"> 970</span> </div>
+<div class="line"><a name="l00971"></a><span class="lineno"> 971</span>  <span class="keywordflow">switch</span> (type) {</div>
+<div class="line"><a name="l00972"></a><span class="lineno"> 972</span>  <span class="keywordflow">case</span> CheckpointType::UPDATE:</div>
+<div class="line"><a name="l00973"></a><span class="lineno"> 973</span>  <span class="keywordflow">if</span> (update.has_framework_id()) {</div>
+<div class="line"><a name="l00974"></a><span class="lineno"> 974</span>  frameworkId = update.framework_id();</div>
+<div class="line"><a name="l00975"></a><span class="lineno"> 975</span>  }</div>
+<div class="line"><a name="l00976"></a><span class="lineno"> 976</span> </div>
+<div class="line"><a name="l00977"></a><span class="lineno"> 977</span>  received.insert(uuid.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>());</div>
+<div class="line"><a name="l00978"></a><span class="lineno"> 978</span> </div>
+<div class="line"><a name="l00979"></a><span class="lineno"> 979</span>  <span class="comment">// Add it to the pending updates queue.</span></div>
+<div class="line"><a name="l00980"></a><span class="lineno"> 980</span>  <a class="code" href="namespaceos_1_1signals.html#a712c95e437c6ae6caa6fbc6dcce30f26">pending</a>.push(update);</div>
+<div class="line"><a name="l00981"></a><span class="lineno"> 981</span>  <span class="keywordflow">break</span>;</div>
+<div class="line"><a name="l00982"></a><span class="lineno"> 982</span>  <span class="keywordflow">case</span> CheckpointType::ACK:</div>
+<div class="line"><a name="l00983"></a><span class="lineno"> 983</span>  acknowledged.insert(uuid.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>());</div>
+<div class="line"><a name="l00984"></a><span class="lineno"> 984</span> </div>
+<div class="line"><a name="l00985"></a><span class="lineno"> 985</span>  <span class="comment">// Remove the corresponding update from the pending queue.</span></div>
+<div class="line"><a name="l00986"></a><span class="lineno"> 986</span>  <a class="code" href="namespaceos_1_1signals.html#a712c95e437c6ae6caa6fbc6dcce30f26">pending</a>.pop();</div>
+<div class="line"><a name="l00987"></a><span class="lineno"> 987</span> </div>
+<div class="line"><a name="l00988"></a><span class="lineno"> 988</span>  <span class="keywordflow">if</span> (!terminated) {</div>
+<div class="line"><a name="l00989"></a><span class="lineno"> 989</span>  terminated = <a class="code" href="namespacemesos_1_1internal_1_1protobuf.html#aa31907fb62769822a77c06ffbf10451f">protobuf::isTerminalState</a>(update.status().state());</div>
+<div class="line"><a name="l00990"></a><span class="lineno"> 990</span>  }</div>
+<div class="line"><a name="l00991"></a><span class="lineno"> 991</span>  <span class="keywordflow">break</span>;</div>
+<div class="line"><a name="l00992"></a><span class="lineno"> 992</span>  }</div>
+<div class="line"><a name="l00993"></a><span class="lineno"> 993</span>  }</div>
<div class="line"><a name="l00994"></a><span class="lineno"> 994</span> </div>
-<div class="line"><a name="l00995"></a><span class="lineno"> 995</span>  received.insert(statusUuid.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>());</div>
-<div class="line"><a name="l00996"></a><span class="lineno"> 996</span> </div>
-<div class="line"><a name="l00997"></a><span class="lineno"> 997</span>  <span class="comment">// Add it to the pending updates queue.</span></div>
-<div class="line"><a name="l00998"></a><span class="lineno"> 998</span>  <a class="code" href="namespaceos_1_1signals.html#a712c95e437c6ae6caa6fbc6dcce30f26">pending</a>.push(update);</div>
-<div class="line"><a name="l00999"></a><span class="lineno"> 999</span>  <span class="keywordflow">break</span>;</div>
-<div class="line"><a name="l01000"></a><span class="lineno"> 1000</span>  <span class="keywordflow">case</span> CheckpointType::ACK:</div>
-<div class="line"><a name="l01001"></a><span class="lineno"> 1001</span>  acknowledged.insert(statusUuid.<a class="code" href="classTry.html#a7be0768038e0628632492edf6cc1515a">get</a>());</div>
-<div class="line"><a name="l01002"></a><span class="lineno"> 1002</span> </div>
-<div class="line"><a name="l01003"></a><span class="lineno"> 1003</span>  <span class="comment">// Remove the corresponding update from the pending queue.</span></div>
-<div class="line"><a name="l01004"></a><span class="lineno"> 1004</span>  <a class="code" href="namespaceos_1_1signals.html#a712c95e437c6ae6caa6fbc6dcce30f26">pending</a>.pop();</div>
-<div class="line"><a name="l01005"></a><span class="lineno"> 1005</span> </div>
-<div class="line"><a name="l01006"></a><span class="lineno"> 1006</span>  <span class="keywordflow">if</span> (!terminated) {</div>
-<div class="line"><a name="l01007"></a><span class="lineno"> 1007</span>  terminated = <a class="code" href="namespacemesos_1_1internal_1_1protobuf.html#aa31907fb62769822a77c06ffbf10451f">protobuf::isTerminalState</a>(update.status().state());</div>
-<div class="line"><a name="l01008"></a><span class="lineno"> 1008</span>  }</div>
-<div class="line"><a name="l01009"></a><span class="lineno"> 1009</span>  <span class="keywordflow">break</span>;</div>
-<div class="line"><a name="l01010"></a><span class="lineno"> 1010</span>  }</div>
-<div class="line"><a name="l01011"></a><span class="lineno"> 1011</span>  }</div>
-<div class="line"><a name="l01012"></a><span class="lineno"> 1012</span> </div>
-<div class="line"><a name="l01013"></a><span class="lineno"> 1013</span>  <span class="comment">// Type of status updates handled by the stream, e.g., "offer operation</span></div>
-<div class="line"><a name="l01014"></a><span class="lineno"> 1014</span>  <span class="comment">// status update".</span></div>
-<div class="line"><a name="l01015"></a><span class="lineno"> 1015</span>  <span class="keyword">const</span> std::string& statusUpdateType;</div>
-<div class="line"><a name="l01016"></a><span class="lineno"> 1016</span> </div>
-<div class="line"><a name="l01017"></a><span class="lineno"> 1017</span>  <span class="keyword">const</span> <a class="code" href="classOption.html">Option<std::string></a> path; <span class="comment">// File path of the update stream.</span></div>
-<div class="line"><a name="l01018"></a><span class="lineno"> 1018</span>  <span class="keyword">const</span> <a class="code" href="classOption.html">Option<int_fd></a> fd; <span class="comment">// File descriptor to the update stream.</span></div>
-<div class="line"><a name="l01019"></a><span class="lineno"> 1019</span> </div>
-<div class="line"><a name="l01020"></a><span class="lineno"> 1020</span>  <a class="code" href="classhashset.html">hashset<id::UUID></a> received;</div>
-<div class="line"><a name="l01021"></a><span class="lineno"> 1021</span>  <a class="code" href="classhashset.html">hashset<id::UUID></a> acknowledged;</div>
-<div class="line"><a name="l01022"></a><span class="lineno"> 1022</span> </div>
-<div class="line"><a name="l01023"></a><span class="lineno"> 1023</span>  <a class="code" href="classOption.html">Option<std::string></a> <a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>; <span class="comment">// Potential non-retryable error.</span></div>
-<div class="line"><a name="l01024"></a><span class="lineno"> 1024</span>  };</div>
-<div class="line"><a name="l01025"></a><span class="lineno"> 1025</span> };</div>
-<div class="line"><a name="l01026"></a><span class="lineno"> 1026</span> </div>
-<div class="line"><a name="l01027"></a><span class="lineno"> 1027</span> } <span class="comment">// namespace internal {</span></div>
-<div class="line"><a name="l01028"></a><span class="lineno"> 1028</span> } <span class="comment">// namespace mesos {</span></div>
-<div class="line"><a name="l01029"></a><span class="lineno"> 1029</span> </div>
-<div class="line"><a name="l01030"></a><span class="lineno"> 1030</span> <span class="preprocessor">#endif // __STATUS_UPDATE_MANAGER_PROCESS_HPP__</span></div>
+<div class="line"><a name="l00995"></a><span class="lineno"> 995</span>  <span class="comment">// Type of status updates handled by the stream, e.g., "operation status</span></div>
+<div class="line"><a name="l00996"></a><span class="lineno"> 996</span>  <span class="comment">// update".</span></div>
+<div class="line"><a name="l00997"></a><span class="lineno"> 997</span>  <span class="keyword">const</span> std::string& statusUpdateType;</div>
+<div class="line"><a name="l00998"></a><span class="lineno"> 998</span> </div>
+<div class="line"><a name="l00999"></a><span class="lineno"> 999</span>  <span class="keyword">const</span> <a class="code" href="classOption.html">Option<std::string></a> path; <span class="comment">// File path of the update stream.</span></div>
+<div class="line"><a name="l01000"></a><span class="lineno"> 1000</span>  <span class="keyword">const</span> <a class="code" href="classOption.html">Option<int_fd></a> fd; <span class="comment">// File descriptor to the update stream.</span></div>
+<div class="line"><a name="l01001"></a><span class="lineno"> 1001</span> </div>
+<div class="line"><a name="l01002"></a><span class="lineno"> 1002</span>  <a class="code" href="classhashset.html">hashset<id::UUID></a> received;</div>
+<div class="line"><a name="l01003"></a><span class="lineno"> 1003</span>  <a class="code" href="classhashset.html">hashset<id::UUID></a> acknowledged;</div>
+<div class="line"><a name="l01004"></a><span class="lineno"> 1004</span> </div>
+<div class="line"><a name="l01005"></a><span class="lineno"> 1005</span>  <a class="code" href="classOption.html">Option<std::string></a> <a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>; <span class="comment">// Potential non-retryable error.</span></div>
+<div class="line"><a name="l01006"></a><span class="lineno"> 1006</span>  };</div>
+<div class="line"><a name="l01007"></a><span class="lineno"> 1007</span> };</div>
+<div class="line"><a name="l01008"></a><span class="lineno"> 1008</span> </div>
+<div class="line"><a name="l01009"></a><span class="lineno"> 1009</span> } <span class="comment">// namespace internal {</span></div>
+<div class="line"><a name="l01010"></a><span class="lineno"> 1010</span> } <span class="comment">// namespace mesos {</span></div>
+<div class="line"><a name="l01011"></a><span class="lineno"> 1011</span> </div>
+<div class="line"><a name="l01012"></a><span class="lineno"> 1012</span> <span class="preprocessor">#endif // __STATUS_UPDATE_MANAGER_PROCESS_HPP__</span></div>
<div class="ttc" id="ftruncate_8hpp_html"><div class="ttname"><a href="ftruncate_8hpp.html">ftruncate.hpp</a></div></div>
<div class="ttc" id="namespacemesos_1_1internal_1_1log_1_1protocol_html_afa485608d261b11b9b4c619b4b4d6e28"><div class="ttname"><a href="namespacemesos_1_1internal_1_1log_1_1protocol.html#afa485608d261b11b9b4c619b4b4d6e28">mesos::internal::log::protocol::recover</a></div><div class="ttdeci">Protocol< RecoverRequest, RecoverResponse > recover</div></div>
<div class="ttc" id="namespacemesos_1_1internal_1_1slave_html_ad21670291a9464020160f8b9048ef582"><div class="ttname"><a href="namespacemesos_1_1internal_1_1slave.html#ad21670291a9464020160f8b9048ef582">mesos::internal::slave::STATUS_UPDATE_RETRY_INTERVAL_MAX</a></div><div class="ttdeci">constexpr Duration STATUS_UPDATE_RETRY_INTERVAL_MAX</div><div class="ttdef"><b>Definition:</b> constants.hpp:56</div></div>
http://git-wip-us.apache.org/repos/asf/mesos-site/blob/6dce3457/content/api/latest/c++/structmesos_1_1internal_1_1ResourceProviderMessage-members.html
----------------------------------------------------------------------
diff --git a/content/api/latest/c++/structmesos_1_1internal_1_1ResourceProviderMessage-members.html b/content/api/latest/c++/structmesos_1_1internal_1_1ResourceProviderMessage-members.html
index 9d8a5a9..bb8b974 100644
--- a/content/api/latest/c++/structmesos_1_1internal_1_1ResourceProviderMessage-members.html
+++ b/content/api/latest/c++/structmesos_1_1internal_1_1ResourceProviderMessage-members.html
@@ -60,7 +60,7 @@
<tr class="even"><td class="entry"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#a93a1d9c59fcd0bf006dda4a6b043c040">disconnect</a></td><td class="entry"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html">mesos::internal::ResourceProviderMessage</a></td><td class="entry"></td></tr>
<tr><td class="entry"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#a52b40b56ae9bf3e8d7d96e4a71929cf9">type</a></td><td class="entry"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html">mesos::internal::ResourceProviderMessage</a></td><td class="entry"></td></tr>
<tr class="even"><td class="entry"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#a1d0830e5e578ade7d92f9908efe8a5c5">Type</a> enum name</td><td class="entry"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html">mesos::internal::ResourceProviderMessage</a></td><td class="entry"></td></tr>
- <tr><td class="entry"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#a64193f7bebb36d8224fee9fda4897fb2">updateOfferOperationStatus</a></td><td class="entry"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html">mesos::internal::ResourceProviderMessage</a></td><td class="entry"></td></tr>
+ <tr><td class="entry"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#ab54b58010937df63162a7273be161c65">updateOperationStatus</a></td><td class="entry"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html">mesos::internal::ResourceProviderMessage</a></td><td class="entry"></td></tr>
<tr class="even"><td class="entry"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#adcf9dcdcfbc488ffefbaf9e3445ef963">updateState</a></td><td class="entry"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html">mesos::internal::ResourceProviderMessage</a></td><td class="entry"></td></tr>
</table></div><!-- contents -->
<!-- start footer part -->
http://git-wip-us.apache.org/repos/asf/mesos-site/blob/6dce3457/content/api/latest/c++/structmesos_1_1internal_1_1ResourceProviderMessage.html
----------------------------------------------------------------------
diff --git a/content/api/latest/c++/structmesos_1_1internal_1_1ResourceProviderMessage.html b/content/api/latest/c++/structmesos_1_1internal_1_1ResourceProviderMessage.html
index 432ce11..55fccbf 100644
--- a/content/api/latest/c++/structmesos_1_1internal_1_1ResourceProviderMessage.html
+++ b/content/api/latest/c++/structmesos_1_1internal_1_1ResourceProviderMessage.html
@@ -66,7 +66,7 @@
Classes</h2></td></tr>
<tr class="memitem:"><td class="memItemLeft" align="right" valign="top">struct  </td><td class="memItemRight" valign="bottom"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage_1_1Disconnect.html">Disconnect</a></td></tr>
<tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr>
-<tr class="memitem:"><td class="memItemLeft" align="right" valign="top">struct  </td><td class="memItemRight" valign="bottom"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage_1_1UpdateOfferOperationStatus.html">UpdateOfferOperationStatus</a></td></tr>
+<tr class="memitem:"><td class="memItemLeft" align="right" valign="top">struct  </td><td class="memItemRight" valign="bottom"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage_1_1UpdateOperationStatus.html">UpdateOperationStatus</a></td></tr>
<tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr>
<tr class="memitem:"><td class="memItemLeft" align="right" valign="top">struct  </td><td class="memItemRight" valign="bottom"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage_1_1UpdateState.html">UpdateState</a></td></tr>
<tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr>
@@ -74,7 +74,7 @@ Classes</h2></td></tr>
<tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pub-types"></a>
Public Types</h2></td></tr>
<tr class="memitem:a1d0830e5e578ade7d92f9908efe8a5c5"><td class="memItemLeft" align="right" valign="top">enum  </td><td class="memItemRight" valign="bottom"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#a1d0830e5e578ade7d92f9908efe8a5c5">Type</a> { <a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#a1d0830e5e578ade7d92f9908efe8a5c5a43aaf51818cc73eefc47a36fecaa3280">Type::UPDATE_STATE</a>,
-<a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#a1d0830e5e578ade7d92f9908efe8a5c5ae4d52b6f6af1f2283f92616c8a76d941">Type::UPDATE_OFFER_OPERATION_STATUS</a>,
+<a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#a1d0830e5e578ade7d92f9908efe8a5c5a1e0c38c118d67e9e3845bdfa8703cc13">Type::UPDATE_OPERATION_STATUS</a>,
<a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#a1d0830e5e578ade7d92f9908efe8a5c5add7cd0eb57db08d4f98abc48e5593462">Type::DISCONNECT</a>
}</td></tr>
<tr class="separator:a1d0830e5e578ade7d92f9908efe8a5c5"><td class="memSeparator" colspan="2"> </td></tr>
@@ -85,9 +85,8 @@ Public Attributes</h2></td></tr>
<tr class="separator:a52b40b56ae9bf3e8d7d96e4a71929cf9"><td class="memSeparator" colspan="2"> </td></tr>
<tr class="memitem:adcf9dcdcfbc488ffefbaf9e3445ef963"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classOption.html">Option</a>< <a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage_1_1UpdateState.html">UpdateState</a> > </td><td class="memItemRight" valign="bottom"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#adcf9dcdcfbc488ffefbaf9e3445ef963">updateState</a></td></tr>
<tr class="separator:adcf9dcdcfbc488ffefbaf9e3445ef963"><td class="memSeparator" colspan="2"> </td></tr>
-<tr class="memitem:a64193f7bebb36d8224fee9fda4897fb2"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classOption.html">Option</a><br class="typebreak"/>
-< <a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage_1_1UpdateOfferOperationStatus.html">UpdateOfferOperationStatus</a> > </td><td class="memItemRight" valign="bottom"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#a64193f7bebb36d8224fee9fda4897fb2">updateOfferOperationStatus</a></td></tr>
-<tr class="separator:a64193f7bebb36d8224fee9fda4897fb2"><td class="memSeparator" colspan="2"> </td></tr>
+<tr class="memitem:ab54b58010937df63162a7273be161c65"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classOption.html">Option</a>< <a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage_1_1UpdateOperationStatus.html">UpdateOperationStatus</a> > </td><td class="memItemRight" valign="bottom"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#ab54b58010937df63162a7273be161c65">updateOperationStatus</a></td></tr>
+<tr class="separator:ab54b58010937df63162a7273be161c65"><td class="memSeparator" colspan="2"> </td></tr>
<tr class="memitem:a93a1d9c59fcd0bf006dda4a6b043c040"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classOption.html">Option</a>< <a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage_1_1Disconnect.html">Disconnect</a> > </td><td class="memItemRight" valign="bottom"><a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage.html#a93a1d9c59fcd0bf006dda4a6b043c040">disconnect</a></td></tr>
<tr class="separator:a93a1d9c59fcd0bf006dda4a6b043c040"><td class="memSeparator" colspan="2"> </td></tr>
</table>
@@ -112,7 +111,7 @@ Public Attributes</h2></td></tr>
<table class="fieldtable">
<tr><th colspan="2">Enumerator</th></tr><tr><td class="fieldname"><em><a class="anchor" id="a1d0830e5e578ade7d92f9908efe8a5c5a43aaf51818cc73eefc47a36fecaa3280"></a>UPDATE_STATE</em> </td><td class="fielddoc">
</td></tr>
-<tr><td class="fieldname"><em><a class="anchor" id="a1d0830e5e578ade7d92f9908efe8a5c5ae4d52b6f6af1f2283f92616c8a76d941"></a>UPDATE_OFFER_OPERATION_STATUS</em> </td><td class="fielddoc">
+<tr><td class="fieldname"><em><a class="anchor" id="a1d0830e5e578ade7d92f9908efe8a5c5a1e0c38c118d67e9e3845bdfa8703cc13"></a>UPDATE_OPERATION_STATUS</em> </td><td class="fielddoc">
</td></tr>
<tr><td class="fieldname"><em><a class="anchor" id="a1d0830e5e578ade7d92f9908efe8a5c5add7cd0eb57db08d4f98abc48e5593462"></a>DISCONNECT</em> </td><td class="fielddoc">
</td></tr>
@@ -145,12 +144,12 @@ Public Attributes</h2></td></tr>
</div>
</div>
-<a class="anchor" id="a64193f7bebb36d8224fee9fda4897fb2"></a>
+<a class="anchor" id="ab54b58010937df63162a7273be161c65"></a>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
- <td class="memname"><a class="el" href="classOption.html">Option</a><<a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage_1_1UpdateOfferOperationStatus.html">UpdateOfferOperationStatus</a>> mesos::internal::ResourceProviderMessage::updateOfferOperationStatus</td>
+ <td class="memname"><a class="el" href="classOption.html">Option</a><<a class="el" href="structmesos_1_1internal_1_1ResourceProviderMessage_1_1UpdateOperationStatus.html">UpdateOperationStatus</a>> mesos::internal::ResourceProviderMessage::updateOperationStatus</td>
</tr>
</table>
</div><div class="memdoc">