http://git-wip-us.apache.org/repos/asf/mesos-site/blob/aac7827c/content/api/latest/c++/http__connection_8hpp_source.html ---------------------------------------------------------------------- diff --git a/content/api/latest/c++/http__connection_8hpp_source.html b/content/api/latest/c++/http__connection_8hpp_source.html index 15aa2f7..740809c 100644 --- a/content/api/latest/c++/http__connection_8hpp_source.html +++ b/content/api/latest/c++/http__connection_8hpp_source.html @@ -119,13 +119,13 @@ <div class="line"><a name="l00086"></a><span class="lineno"> 86</span>  <a class="code" href="classprocess_1_1Owned.html">process::Owned<EndpointDetector></a> _detector,</div> <div class="line"><a name="l00087"></a><span class="lineno"> 87</span>  <a class="code" href="namespacemesos.html#a13035ce0cc66cca4a467787b4716039e">ContentType</a> _contentType,</div> <div class="line"><a name="l00088"></a><span class="lineno"> 88</span>  <span class="keyword">const</span> std::function<<a class="code" href="classOption.html">Option<Error></a>(<span class="keyword">const</span> <a class="code" href="namespacemesos_1_1internal_1_1tests_1_1v1_1_1scheduler.html#acb18ceaa5f6f2338f2a9727af398eb79">Call</a>&)>& <a class="code" href="namespaceappc_1_1spec.html#a1f003511d7ad7c4792223d0b11b60f62">validate</a>,</div> -<div class="line"><a name="l00089"></a><span class="lineno"> 89</span>  <span class="keyword">const</span> std::function<<span class="keywordtype">void</span>(<span class="keywordtype">void</span>)>& <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a4cf4849ca2c97005b37d5664817d2038">connected</a>,</div> -<div class="line"><a name="l00090"></a><span class="lineno"> 90</span>  <span class="keyword">const</span> std::function<<span class="keywordtype">void</span>(<span class="keywordtype">void</span>)>& <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0301fc0eed2d69534e6819869cbb4680">disconnected</a>,</div> +<div class="line"><a name="l00089"></a><span class="lineno"> 89</span>  <span class="keyword">const</span> std::function<<span class="keywordtype">void</span>(<span class="keywordtype">void</span>)>& <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a6205fa14f66139a8c54ad3c3619fba1b">connected</a>,</div> +<div class="line"><a name="l00090"></a><span class="lineno"> 90</span>  <span class="keyword">const</span> std::function<<span class="keywordtype">void</span>(<span class="keywordtype">void</span>)>& <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a9f23195038588deaae134bba01b6f79a">disconnected</a>,</div> <div class="line"><a name="l00091"></a><span class="lineno"> 91</span>  <span class="keyword">const</span> std::function<<span class="keywordtype">void</span>(<span class="keyword">const</span> std::queue<Event>&)>& received)</div> <div class="line"><a name="l00092"></a><span class="lineno"> 92</span>  : <a class="code" href="namespaceos.html#ae19e4161a51b86a1f330f3bf1dc75389">process</a>::<a class="code" href="classprocess_1_1ProcessBase.html#a318038bacd95e4260864533f7cfe12fd">ProcessBase</a>(<a class="code" href="namespaceos.html#ae19e4161a51b86a1f330f3bf1dc75389">process</a>::ID::<a class="code" href="namespaceprocess_1_1ID.html#aeb11a48c9def1da169d8455a30d0ee39">generate</a>(prefix)),</div> <div class="line"><a name="l00093"></a><span class="lineno"> 93</span>  state(State::DISCONNECTED),</div> <div class="line"><a name="l00094"></a><span class="lineno"> 94</span>  contentType(_contentType),</div> -<div class="line"><a name="l00095"></a><span class="lineno"> 95</span>  callbacks {<a class="code" href="namespaceappc_1_1spec.html#a1f003511d7ad7c4792223d0b11b60f62">validate</a>, <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a4cf4849ca2c97005b37d5664817d2038">connected</a>, <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0301fc0eed2d69534e6819869cbb4680">disconnected</a>, received},</div> +<div class="line"><a name="l00095"></a><span class="lineno"> 95</span>  callbacks {<a class="code" href="namespaceappc_1_1spec.html#a1f003511d7ad7c4792223d0b11b60f62">validate</a>, <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a6205fa14f66139a8c54ad3c3619fba1b">connected</a>, <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a9f23195038588deaae134bba01b6f79a">disconnected</a>, received},</div> <div class="line"><a name="l00096"></a><span class="lineno"> 96</span>  detector(std::move(_detector)) {}</div> <div class="line"><a name="l00097"></a><span class="lineno"> 97</span> </div> <div class="line"><a name="l00098"></a><span class="lineno"><a class="line" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a07daef2f77a33b44451c4cf7d53ff627"> 98</a></span>  <a class="code" href="classprocess_1_1Future.html">process::Future<Nothing></a> <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a07daef2f77a33b44451c4cf7d53ff627">send</a>(<span class="keyword">const</span> <a class="code" href="namespacemesos_1_1internal_1_1tests_1_1v1_1_1scheduler.html#acb18ceaa5f6f2338f2a9727af398eb79">Call</a>& call)</div> @@ -189,7 +189,7 @@ <div class="line"><a name="l00156"></a><span class="lineno"> 156</span> </div> <div class="line"><a name="l00157"></a><span class="lineno"> 157</span>  <span class="keywordflow">return</span> response.<a class="code" href="classprocess_1_1Future.html#a269dcc23e03e8868067c24fe70b65a41">then</a>(</div> <div class="line"><a name="l00158"></a><span class="lineno"> 158</span>  <a class="code" href="namespaceprocess.html#a8b27a2ef76eb133bf0ce7a5eea4fb77c">defer</a>(<span class="keyword">self</span>(),</div> -<div class="line"><a name="l00159"></a><span class="lineno"> 159</span>  &<a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#ac6cb9f6ea262bc7e08c56ad4fcb3c04e">Self::_send</a>,</div> +<div class="line"><a name="l00159"></a><span class="lineno"> 159</span>  &<a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a6c415777d634e0b4ffed169eeef13838">Self::_send</a>,</div> <div class="line"><a name="l00160"></a><span class="lineno"> 160</span>  connectionId.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>(),</div> <div class="line"><a name="l00161"></a><span class="lineno"> 161</span>  call,</div> <div class="line"><a name="l00162"></a><span class="lineno"> 162</span>  lambda::_1));</div> @@ -253,16 +253,16 @@ <div class="line"><a name="l00220"></a><span class="lineno"> 220</span> </div> <div class="line"><a name="l00221"></a><span class="lineno"> 221</span>  LOG(INFO) << <span class="stringliteral">"New endpoint detected at "</span> << endpoint.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>();</div> <div class="line"><a name="l00222"></a><span class="lineno"> 222</span> </div> -<div class="line"><a name="l00223"></a><span class="lineno"> 223</span>  connectionId = <a class="code" href="namespaceos.html#aede9f61dcb4b7d1f276302a7bce37446">UUID::random</a>();</div> +<div class="line"><a name="l00223"></a><span class="lineno"> 223</span>  connectionId = <a class="code" href="structid_1_1UUID.html#a6d8296fba33c5d84a64e4a882fcdc280">id::UUID::random</a>();</div> <div class="line"><a name="l00224"></a><span class="lineno"> 224</span> </div> -<div class="line"><a name="l00225"></a><span class="lineno"> 225</span>  <a class="code" href="namespaceprocess_1_1internal.html#ac34bccdf47fcfa46cedf2a03771eb221">dispatch</a>(<span class="keyword">self</span>(), &<a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#ad53eb7c846b84480e2d18d4837a2d802">Self::connect</a>, connectionId.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>());</div> +<div class="line"><a name="l00225"></a><span class="lineno"> 225</span>  <a class="code" href="namespaceprocess_1_1internal.html#ac34bccdf47fcfa46cedf2a03771eb221">dispatch</a>(<span class="keyword">self</span>(), &<a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0e32a05c88072b7db23e87a384ffa1ea">Self::connect</a>, connectionId.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>());</div> <div class="line"><a name="l00226"></a><span class="lineno"> 226</span>  }</div> <div class="line"><a name="l00227"></a><span class="lineno"> 227</span> </div> <div class="line"><a name="l00228"></a><span class="lineno"> 228</span>  detection = detector->detect(endpoint)</div> <div class="line"><a name="l00229"></a><span class="lineno"> 229</span>  .onAny(<a class="code" href="namespaceprocess.html#a8b27a2ef76eb133bf0ce7a5eea4fb77c">defer</a>(<span class="keyword">self</span>(), &<a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#afb0a8be87808f508914cc2207ae59428">Self::detected</a>, lambda::_1));</div> <div class="line"><a name="l00230"></a><span class="lineno"> 230</span>  }</div> <div class="line"><a name="l00231"></a><span class="lineno"> 231</span> </div> -<div class="line"><a name="l00232"></a><span class="lineno"><a class="line" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#ad53eb7c846b84480e2d18d4837a2d802"> 232</a></span>  <span class="keywordtype">void</span> <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#ad53eb7c846b84480e2d18d4837a2d802">connect</a>(<span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">UUID</a>& _connectionId)</div> +<div class="line"><a name="l00232"></a><span class="lineno"><a class="line" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0e32a05c88072b7db23e87a384ffa1ea"> 232</a></span>  <span class="keywordtype">void</span> <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0e32a05c88072b7db23e87a384ffa1ea">connect</a>(<span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">id::UUID</a>& _connectionId)</div> <div class="line"><a name="l00233"></a><span class="lineno"> 233</span>  {</div> <div class="line"><a name="l00234"></a><span class="lineno"> 234</span>  <span class="comment">// It is possible that a new endpoint was detected while we were</span></div> <div class="line"><a name="l00235"></a><span class="lineno"> 235</span>  <span class="comment">// waiting to establish a connection with the old master.</span></div> @@ -282,11 +282,11 @@ <div class="line"><a name="l00249"></a><span class="lineno"> 249</span>  <a class="code" href="namespaceprocess.html#a0f89a937c1caa20e3048e16aeb0c9736">collect</a>(</div> <div class="line"><a name="l00250"></a><span class="lineno"> 250</span>  <a class="code" href="namespaceprocess_1_1http.html#a54e53c8006298fe99e3fb5f55c0e8c41">process::http::connect</a>(endpoint.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>()),</div> <div class="line"><a name="l00251"></a><span class="lineno"> 251</span>  <a class="code" href="namespaceprocess_1_1http.html#a54e53c8006298fe99e3fb5f55c0e8c41">process::http::connect</a>(endpoint.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>()))</div> -<div class="line"><a name="l00252"></a><span class="lineno"> 252</span>  .<a class="code" href="classprocess_1_1Future.html#a71bde220aed3c725cef2040f63adf42a">onAny</a>(<a class="code" href="namespaceprocess.html#a8b27a2ef76eb133bf0ce7a5eea4fb77c">defer</a>(<span class="keyword">self</span>(), &<a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a4cf4849ca2c97005b37d5664817d2038">Self::connected</a>, connectionId.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>(), lambda::_1));</div> +<div class="line"><a name="l00252"></a><span class="lineno"> 252</span>  .<a class="code" href="classprocess_1_1Future.html#a71bde220aed3c725cef2040f63adf42a">onAny</a>(<a class="code" href="namespaceprocess.html#a8b27a2ef76eb133bf0ce7a5eea4fb77c">defer</a>(<span class="keyword">self</span>(), &<a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a6205fa14f66139a8c54ad3c3619fba1b">Self::connected</a>, connectionId.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>(), lambda::_1));</div> <div class="line"><a name="l00253"></a><span class="lineno"> 253</span>  }</div> <div class="line"><a name="l00254"></a><span class="lineno"> 254</span> </div> -<div class="line"><a name="l00255"></a><span class="lineno"><a class="line" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a4cf4849ca2c97005b37d5664817d2038"> 255</a></span>  <span class="keywordtype">void</span> <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a4cf4849ca2c97005b37d5664817d2038">connected</a>(</div> -<div class="line"><a name="l00256"></a><span class="lineno"> 256</span>  <span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">UUID</a>& _connectionId,</div> +<div class="line"><a name="l00255"></a><span class="lineno"><a class="line" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a6205fa14f66139a8c54ad3c3619fba1b"> 255</a></span>  <span class="keywordtype">void</span> <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a6205fa14f66139a8c54ad3c3619fba1b">connected</a>(</div> +<div class="line"><a name="l00256"></a><span class="lineno"> 256</span>  <span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">id::UUID</a>& _connectionId,</div> <div class="line"><a name="l00257"></a><span class="lineno"> 257</span>  <span class="keyword">const</span> <a class="code" href="classprocess_1_1Future.html">process::Future</a><std::tuple<</div> <div class="line"><a name="l00258"></a><span class="lineno"> 258</span>  <a class="code" href="classprocess_1_1http_1_1Connection.html">process::http::Connection</a>, <a class="code" href="classprocess_1_1http_1_1Connection.html">process::http::Connection</a>>>& _connections)</div> <div class="line"><a name="l00259"></a><span class="lineno"> 259</span>  {</div> @@ -300,7 +300,7 @@ <div class="line"><a name="l00267"></a><span class="lineno"> 267</span>  CHECK_EQ(<a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a35a7a60a0e5a768c91915db644e61805a9a14f95e151eec641316e7c784ce832d">State::CONNECTING</a>, state);</div> <div class="line"><a name="l00268"></a><span class="lineno"> 268</span> </div> <div class="line"><a name="l00269"></a><span class="lineno"> 269</span>  <span class="keywordflow">if</span> (!_connections.isReady()) {</div> -<div class="line"><a name="l00270"></a><span class="lineno"> 270</span>  <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0301fc0eed2d69534e6819869cbb4680">disconnected</a>(connectionId.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>(),</div> +<div class="line"><a name="l00270"></a><span class="lineno"> 270</span>  <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a9f23195038588deaae134bba01b6f79a">disconnected</a>(connectionId.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>(),</div> <div class="line"><a name="l00271"></a><span class="lineno"> 271</span>  _connections.isFailed()</div> <div class="line"><a name="l00272"></a><span class="lineno"> 272</span>  ? _connections.failure()</div> <div class="line"><a name="l00273"></a><span class="lineno"> 273</span>  : <span class="stringliteral">"Connection future discarded"</span>);</div> @@ -318,14 +318,14 @@ <div class="line"><a name="l00285"></a><span class="lineno"> 285</span>  connections->subscribe.disconnected()</div> <div class="line"><a name="l00286"></a><span class="lineno"> 286</span>  .onAny(<a class="code" href="namespaceprocess.html#a8b27a2ef76eb133bf0ce7a5eea4fb77c">defer</a>(</div> <div class="line"><a name="l00287"></a><span class="lineno"> 287</span>  <span class="keyword">self</span>(),</div> -<div class="line"><a name="l00288"></a><span class="lineno"> 288</span>  &<a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0301fc0eed2d69534e6819869cbb4680">Self::disconnected</a>,</div> +<div class="line"><a name="l00288"></a><span class="lineno"> 288</span>  &<a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a9f23195038588deaae134bba01b6f79a">Self::disconnected</a>,</div> <div class="line"><a name="l00289"></a><span class="lineno"> 289</span>  connectionId.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>(),</div> <div class="line"><a name="l00290"></a><span class="lineno"> 290</span>  <span class="stringliteral">"Subscribe connection interrupted"</span>));</div> <div class="line"><a name="l00291"></a><span class="lineno"> 291</span> </div> <div class="line"><a name="l00292"></a><span class="lineno"> 292</span>  connections->nonSubscribe.disconnected()</div> <div class="line"><a name="l00293"></a><span class="lineno"> 293</span>  .onAny(<a class="code" href="namespaceprocess.html#a8b27a2ef76eb133bf0ce7a5eea4fb77c">defer</a>(</div> <div class="line"><a name="l00294"></a><span class="lineno"> 294</span>  <span class="keyword">self</span>(),</div> -<div class="line"><a name="l00295"></a><span class="lineno"> 295</span>  &<a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0301fc0eed2d69534e6819869cbb4680">Self::disconnected</a>,</div> +<div class="line"><a name="l00295"></a><span class="lineno"> 295</span>  &<a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a9f23195038588deaae134bba01b6f79a">Self::disconnected</a>,</div> <div class="line"><a name="l00296"></a><span class="lineno"> 296</span>  connectionId.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>(),</div> <div class="line"><a name="l00297"></a><span class="lineno"> 297</span>  <span class="stringliteral">"Non-subscribe connection interrupted"</span>));</div> <div class="line"><a name="l00298"></a><span class="lineno"> 298</span> </div> @@ -357,7 +357,7 @@ <div class="line"><a name="l00324"></a><span class="lineno"> 324</span>  connectionId = <a class="code" href="structNone.html">None</a>();</div> <div class="line"><a name="l00325"></a><span class="lineno"> 325</span>  }</div> <div class="line"><a name="l00326"></a><span class="lineno"> 326</span> </div> -<div class="line"><a name="l00327"></a><span class="lineno"><a class="line" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0301fc0eed2d69534e6819869cbb4680"> 327</a></span>  <span class="keywordtype">void</span> <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0301fc0eed2d69534e6819869cbb4680">disconnected</a>(<span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">UUID</a>& _connectionId, <span class="keyword">const</span> std::string& failure)</div> +<div class="line"><a name="l00327"></a><span class="lineno"><a class="line" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a9f23195038588deaae134bba01b6f79a"> 327</a></span>  <span class="keywordtype">void</span> <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a9f23195038588deaae134bba01b6f79a">disconnected</a>(<span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">id::UUID</a>& _connectionId, <span class="keyword">const</span> std::string& failure)</div> <div class="line"><a name="l00328"></a><span class="lineno"> 328</span>  {</div> <div class="line"><a name="l00329"></a><span class="lineno"> 329</span>  <span class="comment">// Ignore if the disconnection happened from an old stale connection.</span></div> <div class="line"><a name="l00330"></a><span class="lineno"> 330</span>  <span class="keywordflow">if</span> (connectionId != _connectionId) {</div> @@ -371,8 +371,8 @@ <div class="line"><a name="l00338"></a><span class="lineno"> 338</span>  detection.<a class="code" href="classprocess_1_1Future.html#a4012f3faa6191fc13874dca62c14ced0">discard</a>();</div> <div class="line"><a name="l00339"></a><span class="lineno"> 339</span>  }</div> <div class="line"><a name="l00340"></a><span class="lineno"> 340</span> </div> -<div class="line"><a name="l00341"></a><span class="lineno"><a class="line" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#ac6cb9f6ea262bc7e08c56ad4fcb3c04e"> 341</a></span>  <a class="code" href="classprocess_1_1Future.html">process::Future<Nothing></a> <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#ac6cb9f6ea262bc7e08c56ad4fcb3c04e">_send</a>(</div> -<div class="line"><a name="l00342"></a><span class="lineno"> 342</span>  <span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">UUID</a>& _connectionId,</div> +<div class="line"><a name="l00341"></a><span class="lineno"><a class="line" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a6c415777d634e0b4ffed169eeef13838"> 341</a></span>  <a class="code" href="classprocess_1_1Future.html">process::Future<Nothing></a> <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a6c415777d634e0b4ffed169eeef13838">_send</a>(</div> +<div class="line"><a name="l00342"></a><span class="lineno"> 342</span>  <span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">id::UUID</a>& _connectionId,</div> <div class="line"><a name="l00343"></a><span class="lineno"> 343</span>  <span class="keyword">const</span> <a class="code" href="namespacemesos_1_1internal_1_1tests_1_1v1_1_1scheduler.html#acb18ceaa5f6f2338f2a9727af398eb79">Call</a>& call,</div> <div class="line"><a name="l00344"></a><span class="lineno"> 344</span>  <span class="keyword">const</span> <a class="code" href="structprocess_1_1http_1_1Response.html">process::http::Response</a>& response)</div> <div class="line"><a name="l00345"></a><span class="lineno"> 345</span>  {</div> @@ -405,8 +405,8 @@ <div class="line"><a name="l00372"></a><span class="lineno"> 372</span>  subscribed = SubscribedResponse(reader, std::move(decoder));</div> <div class="line"><a name="l00373"></a><span class="lineno"> 373</span> </div> <div class="line"><a name="l00374"></a><span class="lineno"> 374</span>  <span class="keywordflow">if</span> (response.<a class="code" href="structprocess_1_1http_1_1Response.html#ae463c5c7a083aea98a89cf9b675b59ab">headers</a>.<a class="code" href="classhashmap.html#ac142b3f8b73c76d5d4545bbd299007e5">contains</a>(<span class="stringliteral">"Mesos-Stream-Id"</span>)) {</div> -<div class="line"><a name="l00375"></a><span class="lineno"> 375</span>  <a class="code" href="classTry.html">Try<UUID></a> uuid =</div> -<div class="line"><a name="l00376"></a><span class="lineno"> 376</span>  UUID::fromString(response.<a class="code" href="structprocess_1_1http_1_1Response.html#ae463c5c7a083aea98a89cf9b675b59ab">headers</a>.at(<span class="stringliteral">"Mesos-Stream-Id"</span>));</div> +<div class="line"><a name="l00375"></a><span class="lineno"> 375</span>  <a class="code" href="classTry.html">Try<id::UUID></a> uuid =</div> +<div class="line"><a name="l00376"></a><span class="lineno"> 376</span>  <a class="code" href="structid_1_1UUID.html#a51931642cf2febf1689357b40b376798">id::UUID::fromString</a>(response.<a class="code" href="structprocess_1_1http_1_1Response.html#ae463c5c7a083aea98a89cf9b675b59ab">headers</a>.at(<span class="stringliteral">"Mesos-Stream-Id"</span>));</div> <div class="line"><a name="l00377"></a><span class="lineno"> 377</span> </div> <div class="line"><a name="l00378"></a><span class="lineno"> 378</span>  <a class="code" href="stout_2include_2stout_2check_8hpp.html#aee320e7c6e107071f4b85d4cc135a265">CHECK_SOME</a>(uuid);</div> <div class="line"><a name="l00379"></a><span class="lineno"> 379</span> </div> @@ -469,7 +469,7 @@ <div class="line"><a name="l00436"></a><span class="lineno"> 436</span>  LOG(ERROR) << <span class="stringliteral">"Failed to decode stream of events: "</span></div> <div class="line"><a name="l00437"></a><span class="lineno"> 437</span>  << <span class="keyword">event</span>.failure();</div> <div class="line"><a name="l00438"></a><span class="lineno"> 438</span> </div> -<div class="line"><a name="l00439"></a><span class="lineno"> 439</span>  <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0301fc0eed2d69534e6819869cbb4680">disconnected</a>(connectionId.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>(), <span class="keyword">event</span>.failure());</div> +<div class="line"><a name="l00439"></a><span class="lineno"> 439</span>  <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a9f23195038588deaae134bba01b6f79a">disconnected</a>(connectionId.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>(), <span class="keyword">event</span>.failure());</div> <div class="line"><a name="l00440"></a><span class="lineno"> 440</span>  <span class="keywordflow">return</span>;</div> <div class="line"><a name="l00441"></a><span class="lineno"> 441</span>  }</div> <div class="line"><a name="l00442"></a><span class="lineno"> 442</span> </div> @@ -477,7 +477,7 @@ <div class="line"><a name="l00444"></a><span class="lineno"> 444</span>  <span class="keyword">const</span> std::string <a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a> = <span class="stringliteral">"End-Of-File received"</span>;</div> <div class="line"><a name="l00445"></a><span class="lineno"> 445</span>  LOG(ERROR) << <a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>;</div> <div class="line"><a name="l00446"></a><span class="lineno"> 446</span> </div> -<div class="line"><a name="l00447"></a><span class="lineno"> 447</span>  <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0301fc0eed2d69534e6819869cbb4680">disconnected</a>(connectionId.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>(), <a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>);</div> +<div class="line"><a name="l00447"></a><span class="lineno"> 447</span>  <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a9f23195038588deaae134bba01b6f79a">disconnected</a>(connectionId.<a class="code" href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">get</a>(), <a class="code" href="namespacemesos_1_1internal_1_1slave_1_1cni_1_1spec.html#ae58e703656ab4a1bd5d9870441236727">error</a>);</div> <div class="line"><a name="l00448"></a><span class="lineno"> 448</span>  <span class="keywordflow">return</span>;</div> <div class="line"><a name="l00449"></a><span class="lineno"> 449</span>  }</div> <div class="line"><a name="l00450"></a><span class="lineno"> 450</span> </div> @@ -520,8 +520,8 @@ <div class="line"><a name="l00487"></a><span class="lineno"> 487</span>  <span class="keyword">struct </span>Callbacks</div> <div class="line"><a name="l00488"></a><span class="lineno"> 488</span>  {</div> <div class="line"><a name="l00489"></a><span class="lineno"> 489</span>  std::function<Option<Error>(<span class="keyword">const</span> <a class="code" href="namespacemesos_1_1internal_1_1tests_1_1v1_1_1scheduler.html#acb18ceaa5f6f2338f2a9727af398eb79">Call</a>&)> <a class="code" href="namespaceappc_1_1spec.html#a1f003511d7ad7c4792223d0b11b60f62">validate</a>;</div> -<div class="line"><a name="l00490"></a><span class="lineno"> 490</span>  std::function<void(void)> <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a4cf4849ca2c97005b37d5664817d2038">connected</a>;</div> -<div class="line"><a name="l00491"></a><span class="lineno"> 491</span>  std::function<void(void)> <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0301fc0eed2d69534e6819869cbb4680">disconnected</a>;</div> +<div class="line"><a name="l00490"></a><span class="lineno"> 490</span>  std::function<void(void)> <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a6205fa14f66139a8c54ad3c3619fba1b">connected</a>;</div> +<div class="line"><a name="l00491"></a><span class="lineno"> 491</span>  std::function<void(void)> <a class="code" href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a9f23195038588deaae134bba01b6f79a">disconnected</a>;</div> <div class="line"><a name="l00492"></a><span class="lineno"> 492</span>  std::function<void(const std::queue<Event>&)> received;</div> <div class="line"><a name="l00493"></a><span class="lineno"> 493</span>  };</div> <div class="line"><a name="l00494"></a><span class="lineno"> 494</span> </div> @@ -586,8 +586,8 @@ <div class="line"><a name="l00553"></a><span class="lineno"> 553</span>  <span class="comment">// while an attempt was in progress). This helps us in uniquely</span></div> <div class="line"><a name="l00554"></a><span class="lineno"> 554</span>  <span class="comment">// identifying the current connection instance and ignoring the</span></div> <div class="line"><a name="l00555"></a><span class="lineno"> 555</span>  <span class="comment">// stale instance.</span></div> -<div class="line"><a name="l00556"></a><span class="lineno"> 556</span>  <a class="code" href="classOption.html">Option<UUID></a> connectionId;</div> -<div class="line"><a name="l00557"></a><span class="lineno"> 557</span>  <a class="code" href="classOption.html">Option<UUID></a> streamId;</div> +<div class="line"><a name="l00556"></a><span class="lineno"> 556</span>  <a class="code" href="classOption.html">Option<id::UUID></a> connectionId;</div> +<div class="line"><a name="l00557"></a><span class="lineno"> 557</span>  <a class="code" href="classOption.html">Option<id::UUID></a> streamId;</div> <div class="line"><a name="l00558"></a><span class="lineno"> 558</span> </div> <div class="line"><a name="l00559"></a><span class="lineno"> 559</span>  <a class="code" href="classprocess_1_1Future.html">process::Future<Option<process::http::URL></a>> detection;</div> <div class="line"><a name="l00560"></a><span class="lineno"> 560</span> };</div> @@ -597,8 +597,9 @@ <div class="line"><a name="l00564"></a><span class="lineno"> 564</span> </div> <div class="line"><a name="l00565"></a><span class="lineno"> 565</span> <span class="preprocessor">#endif // __RESOURCE_PROVIDER_HTTP_CONNECTION_HPP__</span></div> <div class="ttc" id="include_2mesos_2http_8hpp_html"><div class="ttname"><a href="include_2mesos_2http_8hpp.html">http.hpp</a></div></div> +<div class="ttc" id="classmesos_1_1internal_1_1HttpConnectionProcess_html_a6205fa14f66139a8c54ad3c3619fba1b"><div class="ttname"><a href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a6205fa14f66139a8c54ad3c3619fba1b">mesos::internal::HttpConnectionProcess::connected</a></div><div class="ttdeci">void connected(const id::UUID &_connectionId, const process::Future< std::tuple< process::http::Connection, process::http::Connection >> &_connections)</div><div class="ttdef"><b>Definition:</b> http_connection.hpp:255</div></div> <div class="ttc" id="namespaceprocess_1_1ID_html_aeb11a48c9def1da169d8455a30d0ee39"><div class="ttname"><a href="namespaceprocess_1_1ID.html#aeb11a48c9def1da169d8455a30d0ee39">process::ID::generate</a></div><div class="ttdeci">std::string generate(const std::string &prefix="")</div><div class="ttdoc">Returns &#39;prefix(N)&#39; where N represents the number of instances where the same prefix (wrt...</div></div> -<div class="ttc" id="classmesos_1_1internal_1_1HttpConnectionProcess_html_a0301fc0eed2d69534e6819869cbb4680"><div class="ttname"><a href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0301fc0eed2d69534e6819869cbb4680">mesos::internal::HttpConnectionProcess::disconnected</a></div><div class="ttdeci">void disconnected(const UUID &_connectionId, const std::string &failure)</div><div class="ttdef"><b>Definition:</b> http_connection.hpp:327</div></div> +<div class="ttc" id="classmesos_1_1internal_1_1HttpConnectionProcess_html_a9f23195038588deaae134bba01b6f79a"><div class="ttname"><a href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a9f23195038588deaae134bba01b6f79a">mesos::internal::HttpConnectionProcess::disconnected</a></div><div class="ttdeci">void disconnected(const id::UUID &_connectionId, const std::string &failure)</div><div class="ttdef"><b>Definition:</b> http_connection.hpp:327</div></div> <div class="ttc" id="structNothing_html"><div class="ttname"><a href="structNothing.html">Nothing</a></div><div class="ttdef"><b>Definition:</b> nothing.hpp:16</div></div> <div class="ttc" id="namespacemesos_html_a13035ce0cc66cca4a467787b4716039e"><div class="ttname"><a href="namespacemesos.html#a13035ce0cc66cca4a467787b4716039e">mesos::ContentType</a></div><div class="ttdeci">ContentType</div><div class="ttdef"><b>Definition:</b> http.hpp:43</div></div> <div class="ttc" id="namespaceappc_1_1spec_html_a1f003511d7ad7c4792223d0b11b60f62"><div class="ttname"><a href="namespaceappc_1_1spec.html#a1f003511d7ad7c4792223d0b11b60f62">appc::spec::validate</a></div><div class="ttdeci">Option< Error > validate(const std::string &imageDir)</div></div> @@ -608,13 +609,11 @@ <div class="ttc" id="namespaceprocess_1_1http_html_ad8f400b5e54038df7e5662ec35da05fa"><div class="ttname"><a href="namespaceprocess_1_1http.html#ad8f400b5e54038df7e5662ec35da05fa">process::http::request</a></div><div class="ttdeci">Future< Response > request(const Request &request, bool streamedResponse=false)</div><div class="ttdoc">Asynchronously sends an HTTP request to the process and returns the HTTP response once the entire res...</div></div> <div class="ttc" id="classprocess_1_1ProcessBase_html_a318038bacd95e4260864533f7cfe12fd"><div class="ttname"><a href="classprocess_1_1ProcessBase.html#a318038bacd95e4260864533f7cfe12fd">process::ProcessBase::ProcessBase</a></div><div class="ttdeci">ProcessBase(const std::string &id="")</div></div> <div class="ttc" id="structprocess_1_1http_1_1Request_html_aba3024fe3e1028d19f5fb4e92519cb56"><div class="ttname"><a href="structprocess_1_1http_1_1Request.html#aba3024fe3e1028d19f5fb4e92519cb56">process::http::Request::url</a></div><div class="ttdeci">URL url</div><div class="ttdef"><b>Definition:</b> http.hpp:529</div></div> -<div class="ttc" id="classmesos_1_1internal_1_1HttpConnectionProcess_html_ac6cb9f6ea262bc7e08c56ad4fcb3c04e"><div class="ttname"><a href="classmesos_1_1internal_1_1HttpConnectionProcess.html#ac6cb9f6ea262bc7e08c56ad4fcb3c04e">mesos::internal::HttpConnectionProcess::_send</a></div><div class="ttdeci">process::Future< Nothing > _send(const UUID &_connectionId, const Call &call, const process::http::Response &response)</div><div class="ttdef"><b>Definition:</b> http_connection.hpp:341</div></div> <div class="ttc" id="classTry_html"><div class="ttname"><a href="classTry.html">Try</a></div><div class="ttdef"><b>Definition:</b> try.hpp:34</div></div> <div class="ttc" id="structprocess_1_1http_1_1Response_html_a8fcbd2073ace160af24a9ee531cb4378"><div class="ttname"><a href="structprocess_1_1http_1_1Response.html#a8fcbd2073ace160af24a9ee531cb4378">process::http::Response::status</a></div><div class="ttdeci">std::string status</div><div class="ttdef"><b>Definition:</b> http.hpp:621</div></div> <div class="ttc" id="mutex_8hpp_html"><div class="ttname"><a href="mutex_8hpp.html">mutex.hpp</a></div></div> <div class="ttc" id="structprocess_1_1Failure_html"><div class="ttname"><a href="structprocess_1_1Failure.html">process::Failure</a></div><div class="ttdef"><b>Definition:</b> future.hpp:664</div></div> <div class="ttc" id="structprocess_1_1http_1_1Response_html_a6dd5881e0450540a106e37257434eaada8d713d3c6326b2c6f5730c5f46f3e3f0"><div class="ttname"><a href="structprocess_1_1http_1_1Response.html#a6dd5881e0450540a106e37257434eaada8d713d3c6326b2c6f5730c5f46f3e3f0">process::http::Response::PIPE</a></div><div class="ttdef"><b>Definition:</b> http.hpp:651</div></div> -<div class="ttc" id="classmesos_1_1internal_1_1HttpConnectionProcess_html_a4cf4849ca2c97005b37d5664817d2038"><div class="ttname"><a href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a4cf4849ca2c97005b37d5664817d2038">mesos::internal::HttpConnectionProcess::connected</a></div><div class="ttdeci">void connected(const UUID &_connectionId, const process::Future< std::tuple< process::http::Connection, process::http::Connection >> &_connections)</div><div class="ttdef"><b>Definition:</b> http_connection.hpp:255</div></div> <div class="ttc" id="structprocess_1_1http_1_1Response_html_ad6530fddd03380dbb3b23b17523cb242"><div class="ttname"><a href="structprocess_1_1http_1_1Response.html#ad6530fddd03380dbb3b23b17523cb242">process::http::Response::code</a></div><div class="ttdeci">uint16_t code</div><div class="ttdef"><b>Definition:</b> http.hpp:658</div></div> <div class="ttc" id="namespaceos_1_1libraries_1_1Library_html_ab0e1a0e311049b6d685de1068e8f4690"><div class="ttname"><a href="namespaceos_1_1libraries_1_1Library.html#ab0e1a0e311049b6d685de1068e8f4690">os::libraries::Library::prefix</a></div><div class="ttdeci">constexpr const char * prefix</div><div class="ttdef"><b>Definition:</b> os.hpp:94</div></div> <div class="ttc" id="classmesos_1_1internal_1_1HttpConnectionProcess_html_a81fc91fa235309d5486bf019260e6480"><div class="ttname"><a href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a81fc91fa235309d5486bf019260e6480">mesos::internal::HttpConnectionProcess::receive</a></div><div class="ttdeci">void receive(const Event &event)</div><div class="ttdef"><b>Definition:</b> http_connection.hpp:460</div></div> @@ -626,6 +625,7 @@ <div class="ttc" id="classResult_html"><div class="ttname"><a href="classResult.html">Result</a></div><div class="ttdef"><b>Definition:</b> result.hpp:40</div></div> <div class="ttc" id="src_2common_2http_8hpp_html"><div class="ttname"><a href="src_2common_2http_8hpp.html">http.hpp</a></div></div> <div class="ttc" id="classOption_html_a4e3bf8416d95246f43c91f1b5c309323"><div class="ttname"><a href="classOption.html#a4e3bf8416d95246f43c91f1b5c309323">Option::isSome</a></div><div class="ttdeci">bool isSome() const </div><div class="ttdef"><b>Definition:</b> option.hpp:115</div></div> +<div class="ttc" id="classmesos_1_1internal_1_1HttpConnectionProcess_html_a0e32a05c88072b7db23e87a384ffa1ea"><div class="ttname"><a href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a0e32a05c88072b7db23e87a384ffa1ea">mesos::internal::HttpConnectionProcess::connect</a></div><div class="ttdeci">void connect(const id::UUID &_connectionId)</div><div class="ttdef"><b>Definition:</b> http_connection.hpp:232</div></div> <div class="ttc" id="structprocess_1_1http_1_1Request_html"><div class="ttname"><a href="structprocess_1_1http_1_1Request.html">process::http::Request</a></div><div class="ttdef"><b>Definition:</b> http.hpp:518</div></div> <div class="ttc" id="namespacemesos_1_1internal_1_1tests_1_1v1_1_1scheduler_html_acd3fa8addac36f513726743665631d79"><div class="ttname"><a href="namespacemesos_1_1internal_1_1tests_1_1v1_1_1scheduler.html#acd3fa8addac36f513726743665631d79">mesos::internal::tests::v1::scheduler::Event</a></div><div class="ttdeci">mesos::v1::scheduler::Event Event</div><div class="ttdef"><b>Definition:</b> mesos.hpp:2563</div></div> <div class="ttc" id="classmesos_1_1internal_1_1HttpConnectionProcess_html_a35a7a60a0e5a768c91915db644e61805a8bcc991ed7d906ec5cb1f21990e73450"><div class="ttname"><a href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a35a7a60a0e5a768c91915db644e61805a8bcc991ed7d906ec5cb1f21990e73450">mesos::internal::HttpConnectionProcess::State::SUBSCRIBING</a></div></div> @@ -637,6 +637,7 @@ <div class="ttc" id="classmesos_1_1internal_1_1recordio_1_1Reader_html"><div class="ttname"><a href="classmesos_1_1internal_1_1recordio_1_1Reader.html">mesos::internal::recordio::Reader</a></div><div class="ttdoc">Provides RecordIO decoding on top of an http::Pipe::Reader. </div><div class="ttdef"><b>Definition:</b> recordio.hpp:62</div></div> <div class="ttc" id="classmesos_1_1internal_1_1HttpConnectionProcess_html_a07daef2f77a33b44451c4cf7d53ff627"><div class="ttname"><a href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a07daef2f77a33b44451c4cf7d53ff627">mesos::internal::HttpConnectionProcess::send</a></div><div class="ttdeci">process::Future< Nothing > send(const Call &call)</div><div class="ttdef"><b>Definition:</b> http_connection.hpp:98</div></div> <div class="ttc" id="stout_2include_2stout_2check_8hpp_html_aee320e7c6e107071f4b85d4cc135a265"><div class="ttname"><a href="stout_2include_2stout_2check_8hpp.html#aee320e7c6e107071f4b85d4cc135a265">CHECK_SOME</a></div><div class="ttdeci">#define CHECK_SOME(expression)</div><div class="ttdef"><b>Definition:</b> check.hpp:44</div></div> +<div class="ttc" id="structid_1_1UUID_html_a6d8296fba33c5d84a64e4a882fcdc280"><div class="ttname"><a href="structid_1_1UUID.html#a6d8296fba33c5d84a64e4a882fcdc280">id::UUID::random</a></div><div class="ttdeci">static UUID random()</div><div class="ttdef"><b>Definition:</b> uuid.hpp:38</div></div> <div class="ttc" id="structprocess_1_1http_1_1Response_html_a5f6d23dd77e1eeb0737dc728e0109905"><div class="ttname"><a href="structprocess_1_1http_1_1Response.html#a5f6d23dd77e1eeb0737dc728e0109905">process::http::Response::body</a></div><div class="ttdeci">std::string body</div><div class="ttdef"><b>Definition:</b> http.hpp:654</div></div> <div class="ttc" id="src_2common_2recordio_8hpp_html"><div class="ttname"><a href="src_2common_2recordio_8hpp.html">recordio.hpp</a></div></div> <div class="ttc" id="nothing_8hpp_html"><div class="ttname"><a href="nothing_8hpp.html">nothing.hpp</a></div></div> @@ -644,16 +645,14 @@ <div class="ttc" id="structprocess_1_1http_1_1Status_html_ac38d2d21e08b9d2af0511c216613db0f"><div class="ttname"><a href="structprocess_1_1http_1_1Status.html#ac38d2d21e08b9d2af0511c216613db0f">process::http::Status::SERVICE_UNAVAILABLE</a></div><div class="ttdeci">static const uint16_t SERVICE_UNAVAILABLE</div><div class="ttdef"><b>Definition:</b> http.hpp:253</div></div> <div class="ttc" id="classprocess_1_1Future_html_a71bde220aed3c725cef2040f63adf42a"><div class="ttname"><a href="classprocess_1_1Future.html#a71bde220aed3c725cef2040f63adf42a">process::Future::onAny</a></div><div class="ttdeci">const Future< T > & onAny(AnyCallback &&callback) const </div><div class="ttdef"><b>Definition:</b> future.hpp:1458</div></div> <div class="ttc" id="classmesos_1_1internal_1_1HttpConnectionProcess_html_afb0a8be87808f508914cc2207ae59428"><div class="ttname"><a href="classmesos_1_1internal_1_1HttpConnectionProcess.html#afb0a8be87808f508914cc2207ae59428">mesos::internal::HttpConnectionProcess::detected</a></div><div class="ttdeci">void detected(const process::Future< Option< process::http::URL >> &future)</div><div class="ttdef"><b>Definition:</b> http_connection.hpp:182</div></div> -<div class="ttc" id="structid_1_1UUID_html"><div class="ttname"><a href="structid_1_1UUID.html">id::UUID</a></div><div class="ttdef"><b>Definition:</b> uuid.hpp:40</div></div> +<div class="ttc" id="structid_1_1UUID_html"><div class="ttname"><a href="structid_1_1UUID.html">id::UUID</a></div><div class="ttdef"><b>Definition:</b> uuid.hpp:35</div></div> <div class="ttc" id="structprocess_1_1http_1_1Status_html_a5d2b09dd7b99e2519b641b682dc976b0"><div class="ttname"><a href="structprocess_1_1http_1_1Status.html#a5d2b09dd7b99e2519b641b682dc976b0">process::http::Status::ACCEPTED</a></div><div class="ttdeci">static const uint16_t ACCEPTED</div><div class="ttdef"><b>Definition:</b> http.hpp:220</div></div> <div class="ttc" id="classmesos_1_1internal_1_1HttpConnectionProcess_html_aa5d1d7deac2035597a715a0c115ca38e"><div class="ttname"><a href="classmesos_1_1internal_1_1HttpConnectionProcess.html#aa5d1d7deac2035597a715a0c115ca38e">mesos::internal::HttpConnectionProcess::HttpConnectionProcess</a></div><div class="ttdeci">HttpConnectionProcess(const std::string &prefix, process::Owned< EndpointDetector > _detector, ContentType _contentType, const std::function< Option< Error >(const Call &)> &validate, const std::function< void(void)> &connected, const std::function< void(void)> &disconnected, const std::function< void(const std::queue< Event > &)> &received)</div><div class="ttdoc">Construct a HTTP connection process. </div><div class="ttdef"><b>Definition:</b> http_connection.hpp:84</div></div> <div class="ttc" id="classOption_html_a21358442c0fac1cc978a67a9a9089a79"><div class="ttname"><a href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">Option::get</a></div><div class="ttdeci">const T & get() const &</div><div class="ttdef"><b>Definition:</b> option.hpp:118</div></div> <div class="ttc" id="namespaceprocess_1_1http_html_a54e53c8006298fe99e3fb5f55c0e8c41"><div class="ttname"><a href="namespaceprocess_1_1http.html#a54e53c8006298fe99e3fb5f55c0e8c41">process::http::connect</a></div><div class="ttdeci">Future< Connection > connect(const network::Address &address, Scheme scheme)</div></div> -<div class="ttc" id="namespaceos_html_aede9f61dcb4b7d1f276302a7bce37446"><div class="ttname"><a href="namespaceos.html#aede9f61dcb4b7d1f276302a7bce37446">os::random</a></div><div class="ttdeci">int random()</div><div class="ttdef"><b>Definition:</b> os.hpp:635</div></div> <div class="ttc" id="structprocess_1_1http_1_1Request_html_a3a459e9dbce042511e6359533f6925d4"><div class="ttname"><a href="structprocess_1_1http_1_1Request.html#a3a459e9dbce042511e6359533f6925d4">process::http::Request::keepAlive</a></div><div class="ttdeci">bool keepAlive</div><div class="ttdef"><b>Definition:</b> http.hpp:543</div></div> <div class="ttc" id="3rdparty_2stout_2include_2stout_2recordio_8hpp_html"><div class="ttname"><a href="3rdparty_2stout_2include_2stout_2recordio_8hpp.html">recordio.hpp</a></div></div> <div class="ttc" id="structprocess_1_1http_1_1Status_html_ae105d018cfcf82f5c19c79196101fd9b"><div class="ttname"><a href="structprocess_1_1http_1_1Status.html#ae105d018cfcf82f5c19c79196101fd9b">process::http::Status::OK</a></div><div class="ttdeci">static const uint16_t OK</div><div class="ttdef"><b>Definition:</b> http.hpp:218</div></div> -<div class="ttc" id="classmesos_1_1internal_1_1HttpConnectionProcess_html_ad53eb7c846b84480e2d18d4837a2d802"><div class="ttname"><a href="classmesos_1_1internal_1_1HttpConnectionProcess.html#ad53eb7c846b84480e2d18d4837a2d802">mesos::internal::HttpConnectionProcess::connect</a></div><div class="ttdeci">void connect(const UUID &_connectionId)</div><div class="ttdef"><b>Definition:</b> http_connection.hpp:232</div></div> <div class="ttc" id="namespaceprocess_1_1internal_html_ac34bccdf47fcfa46cedf2a03771eb221"><div class="ttname"><a href="namespaceprocess_1_1internal.html#ac34bccdf47fcfa46cedf2a03771eb221">process::internal::dispatch</a></div><div class="ttdeci">void dispatch(const UPID &pid, std::unique_ptr< lambda::CallableOnce< void(ProcessBase *)>> f, const Option< const std::type_info * > &functionType=None())</div></div> <div class="ttc" id="namespaceprocess_html_a92b69ab22f734498cfe8cf6edd92fd2a"><div class="ttname"><a href="namespaceprocess.html#a92b69ab22f734498cfe8cf6edd92fd2a">process::async</a></div><div class="ttdeci">Future< typename result_of< F()>::type > async(const F &f, typename std::enable_if<!std::is_void< typename result_of< F()>::type >::value >::type *=nullptr)</div><div class="ttdef"><b>Definition:</b> async.hpp:238</div></div> <div class="ttc" id="unreachable_8hpp_html_a0bc63b24b654ca433be7b97a3edde132"><div class="ttname"><a href="unreachable_8hpp.html#a0bc63b24b654ca433be7b97a3edde132">UNREACHABLE</a></div><div class="ttdeci">#define UNREACHABLE()</div><div class="ttdef"><b>Definition:</b> unreachable.hpp:22</div></div> @@ -673,8 +672,9 @@ <div class="ttc" id="structprocess_1_1http_1_1Request_html_a78dfcfa785afc80e221d92543ff617f1"><div class="ttname"><a href="structprocess_1_1http_1_1Request.html#a78dfcfa785afc80e221d92543ff617f1">process::http::Request::body</a></div><div class="ttdeci">std::string body</div><div class="ttdef"><b>Definition:</b> http.hpp:563</div></div> <div class="ttc" id="classprocess_1_1Process_html_abef2d54388c5262af19b057b1a6eee8e"><div class="ttname"><a href="classprocess_1_1Process.html#abef2d54388c5262af19b057b1a6eee8e">process::Process< HttpConnectionProcess< Call, Event > >::self</a></div><div class="ttdeci">PID< HttpConnectionProcess< Call, Event > > self() const</div><div class="ttdoc">Returns the PID of the process. </div><div class="ttdef"><b>Definition:</b> process.hpp:502</div></div> <div class="ttc" id="classOption_html_a06eab791122ebc1f8af4ad310e5e7d7e"><div class="ttname"><a href="classOption.html#a06eab791122ebc1f8af4ad310e5e7d7e">Option::isNone</a></div><div class="ttdeci">bool isNone() const </div><div class="ttdef"><b>Definition:</b> option.hpp:116</div></div> +<div class="ttc" id="classmesos_1_1internal_1_1HttpConnectionProcess_html_a6c415777d634e0b4ffed169eeef13838"><div class="ttname"><a href="classmesos_1_1internal_1_1HttpConnectionProcess.html#a6c415777d634e0b4ffed169eeef13838">mesos::internal::HttpConnectionProcess::_send</a></div><div class="ttdeci">process::Future< Nothing > _send(const id::UUID &_connectionId, const Call &call, const process::http::Response &response)</div><div class="ttdef"><b>Definition:</b> http_connection.hpp:341</div></div> <div class="ttc" id="owned_8hpp_html"><div class="ttname"><a href="owned_8hpp.html">owned.hpp</a></div></div> -<div class="ttc" id="structid_1_1UUID_html_af024badbc379374ac635031eed57dc5f"><div class="ttname"><a href="structid_1_1UUID.html#af024badbc379374ac635031eed57dc5f">id::UUID::toString</a></div><div class="ttdeci">std::string toString() const </div><div class="ttdef"><b>Definition:</b> uuid.hpp:92</div></div> +<div class="ttc" id="structid_1_1UUID_html_af024badbc379374ac635031eed57dc5f"><div class="ttname"><a href="structid_1_1UUID.html#af024badbc379374ac635031eed57dc5f">id::UUID::toString</a></div><div class="ttdeci">std::string toString() const </div><div class="ttdef"><b>Definition:</b> uuid.hpp:87</div></div> <div class="ttc" id="classprocess_1_1Mutex_html"><div class="ttname"><a href="classprocess_1_1Mutex.html">process::Mutex</a></div><div class="ttdef"><b>Definition:</b> mutex.hpp:28</div></div> <div class="ttc" id="async_8hpp_html"><div class="ttname"><a href="async_8hpp.html">async.hpp</a></div></div> <div class="ttc" id="namespaceprocess_1_1network_html_ad067110a4b38cc83785a43f49bf6c8e2"><div class="ttname"><a href="namespaceprocess_1_1network.html#ad067110a4b38cc83785a43f49bf6c8e2">process::network::bind</a></div><div class="ttdeci">Try< Nothing > bind(int_fd s, const Address &address)</div><div class="ttdef"><b>Definition:</b> network.hpp:46</div></div> @@ -693,6 +693,7 @@ <div class="ttc" id="defer_8hpp_html"><div class="ttname"><a href="defer_8hpp.html">defer.hpp</a></div></div> <div class="ttc" id="namespaceprocess_html_a8b27a2ef76eb133bf0ce7a5eea4fb77c"><div class="ttname"><a href="namespaceprocess.html#a8b27a2ef76eb133bf0ce7a5eea4fb77c">process::defer</a></div><div class="ttdeci">Deferred< void()> defer(const PID< T > &pid, void(T::*method)())</div><div class="ttdef"><b>Definition:</b> defer.hpp:35</div></div> <div class="ttc" id="classhashmap_html_ac142b3f8b73c76d5d4545bbd299007e5"><div class="ttname"><a href="classhashmap.html#ac142b3f8b73c76d5d4545bbd299007e5">hashmap::contains</a></div><div class="ttdeci">bool contains(const Key &key) const </div><div class="ttdef"><b>Definition:</b> hashmap.hpp:86</div></div> +<div class="ttc" id="structid_1_1UUID_html_a51931642cf2febf1689357b40b376798"><div class="ttname"><a href="structid_1_1UUID.html#a51931642cf2febf1689357b40b376798">id::UUID::fromString</a></div><div class="ttdeci">static Try< UUID > fromString(const std::string &s)</div><div class="ttdef"><b>Definition:</b> uuid.hpp:67</div></div> <div class="ttc" id="classprocess_1_1http_1_1Connection_html"><div class="ttname"><a href="classprocess_1_1http_1_1Connection.html">process::http::Connection</a></div><div class="ttdoc">Represents a connection to an HTTP server. </div><div class="ttdef"><b>Definition:</b> http.hpp:945</div></div> <div class="ttc" id="classrecordio_1_1Decoder_html"><div class="ttname"><a href="classrecordio_1_1Decoder.html">recordio::Decoder</a></div><div class="ttdoc">Given a decoding function for individual records, this provides decoding from &quot;Record-IO&quot; data into t...</div><div class="ttdef"><b>Definition:</b> recordio.hpp:82</div></div> <div class="ttc" id="libprocess_2include_2process_2process_8hpp_html"><div class="ttname"><a href="libprocess_2include_2process_2process_8hpp.html">process.hpp</a></div></div>
http://git-wip-us.apache.org/repos/asf/mesos-site/blob/aac7827c/content/api/latest/c++/in__memory_8hpp_source.html ---------------------------------------------------------------------- diff --git a/content/api/latest/c++/in__memory_8hpp_source.html b/content/api/latest/c++/in__memory_8hpp_source.html index 969726b..5d33505 100644 --- a/content/api/latest/c++/in__memory_8hpp_source.html +++ b/content/api/latest/c++/in__memory_8hpp_source.html @@ -97,9 +97,9 @@ <div class="line"><a name="l00043"></a><span class="lineno"> 43</span>  <span class="comment">// Storage implementation.</span></div> <div class="line"><a name="l00044"></a><span class="lineno"> 44</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<Option<internal::state::Entry></a>> <span class="keyword">get</span>(</div> <div class="line"><a name="l00045"></a><span class="lineno"> 45</span>  <span class="keyword">const</span> std::string& <a class="code" href="namespaceos_1_1Shell.html#acfe16ef2b1146ad49a8651c0a457ce46">name</a>);</div> -<div class="line"><a name="l00046"></a><span class="lineno"> 46</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<bool></a> <a class="code" href="classmesos_1_1state_1_1InMemoryStorage.html#a2360962c403869fb7beb5c596035ca62">set</a>(</div> +<div class="line"><a name="l00046"></a><span class="lineno"> 46</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<bool></a> <a class="code" href="classmesos_1_1state_1_1InMemoryStorage.html#ad8ed2d363ea2fb5c972b4146473568b2">set</a>(</div> <div class="line"><a name="l00047"></a><span class="lineno"> 47</span>  <span class="keyword">const</span> internal::state::Entry& entry,</div> -<div class="line"><a name="l00048"></a><span class="lineno"> 48</span>  <span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">UUID</a>& uuid);</div> +<div class="line"><a name="l00048"></a><span class="lineno"> 48</span>  <span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">id::UUID</a>& uuid);</div> <div class="line"><a name="l00049"></a><span class="lineno"> 49</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<bool></a> <a class="code" href="classmesos_1_1state_1_1InMemoryStorage.html#a896ba01f55add683da51a11f54a7a189">expunge</a>(<span class="keyword">const</span> internal::state::Entry& entry);</div> <div class="line"><a name="l00050"></a><span class="lineno"> 50</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<std::set<std::string></a>> <a class="code" href="classmesos_1_1state_1_1InMemoryStorage.html#a925005a12b6c88e5bc2b53d3a6f47757">names</a>();</div> <div class="line"><a name="l00051"></a><span class="lineno"> 51</span> </div> @@ -112,12 +112,12 @@ <div class="line"><a name="l00058"></a><span class="lineno"> 58</span> </div> <div class="line"><a name="l00059"></a><span class="lineno"> 59</span> <span class="preprocessor">#endif // __MESOS_STATE_IN_MEMORY_HPP__</span></div> <div class="ttc" id="include_2mesos_2state_2storage_8hpp_html"><div class="ttname"><a href="include_2mesos_2state_2storage_8hpp.html">storage.hpp</a></div></div> -<div class="ttc" id="classmesos_1_1state_1_1InMemoryStorage_html_a2360962c403869fb7beb5c596035ca62"><div class="ttname"><a href="classmesos_1_1state_1_1InMemoryStorage.html#a2360962c403869fb7beb5c596035ca62">mesos::state::InMemoryStorage::set</a></div><div class="ttdeci">virtual process::Future< bool > set(const internal::state::Entry &entry, const UUID &uuid)</div></div> <div class="ttc" id="classmesos_1_1state_1_1InMemoryStorage_html_a280ac8d1b880f76d8f38b2e340dced48"><div class="ttname"><a href="classmesos_1_1state_1_1InMemoryStorage.html#a280ac8d1b880f76d8f38b2e340dced48">mesos::state::InMemoryStorage::InMemoryStorage</a></div><div class="ttdeci">InMemoryStorage()</div></div> <div class="ttc" id="classmesos_1_1state_1_1InMemoryStorage_html_a896ba01f55add683da51a11f54a7a189"><div class="ttname"><a href="classmesos_1_1state_1_1InMemoryStorage.html#a896ba01f55add683da51a11f54a7a189">mesos::state::InMemoryStorage::expunge</a></div><div class="ttdeci">virtual process::Future< bool > expunge(const internal::state::Entry &entry)</div></div> +<div class="ttc" id="classmesos_1_1state_1_1InMemoryStorage_html_ad8ed2d363ea2fb5c972b4146473568b2"><div class="ttname"><a href="classmesos_1_1state_1_1InMemoryStorage.html#ad8ed2d363ea2fb5c972b4146473568b2">mesos::state::InMemoryStorage::set</a></div><div class="ttdeci">virtual process::Future< bool > set(const internal::state::Entry &entry, const id::UUID &uuid)</div></div> <div class="ttc" id="classmesos_1_1state_1_1InMemoryStorage_html"><div class="ttname"><a href="classmesos_1_1state_1_1InMemoryStorage.html">mesos::state::InMemoryStorage</a></div><div class="ttdef"><b>Definition:</b> in_memory.hpp:37</div></div> <div class="ttc" id="classmesos_1_1state_1_1InMemoryStorage_html_afc2a10fe56c0144750dbe94c96abf926"><div class="ttname"><a href="classmesos_1_1state_1_1InMemoryStorage.html#afc2a10fe56c0144750dbe94c96abf926">mesos::state::InMemoryStorage::~InMemoryStorage</a></div><div class="ttdeci">virtual ~InMemoryStorage()</div></div> -<div class="ttc" id="structid_1_1UUID_html"><div class="ttname"><a href="structid_1_1UUID.html">id::UUID</a></div><div class="ttdef"><b>Definition:</b> uuid.hpp:40</div></div> +<div class="ttc" id="structid_1_1UUID_html"><div class="ttname"><a href="structid_1_1UUID.html">id::UUID</a></div><div class="ttdef"><b>Definition:</b> uuid.hpp:35</div></div> <div class="ttc" id="classmesos_1_1state_1_1InMemoryStorage_html_a925005a12b6c88e5bc2b53d3a6f47757"><div class="ttname"><a href="classmesos_1_1state_1_1InMemoryStorage.html#a925005a12b6c88e5bc2b53d3a6f47757">mesos::state::InMemoryStorage::names</a></div><div class="ttdeci">virtual process::Future< std::set< std::string > > names()</div></div> <div class="ttc" id="option_8hpp_html"><div class="ttname"><a href="option_8hpp.html">option.hpp</a></div></div> <div class="ttc" id="future_8hpp_html"><div class="ttname"><a href="future_8hpp.html">future.hpp</a></div></div> http://git-wip-us.apache.org/repos/asf/mesos-site/blob/aac7827c/content/api/latest/c++/include_2mesos_2state_2leveldb_8hpp_source.html ---------------------------------------------------------------------- diff --git a/content/api/latest/c++/include_2mesos_2state_2leveldb_8hpp_source.html b/content/api/latest/c++/include_2mesos_2state_2leveldb_8hpp_source.html index ca2d02c..9a87c95 100644 --- a/content/api/latest/c++/include_2mesos_2state_2leveldb_8hpp_source.html +++ b/content/api/latest/c++/include_2mesos_2state_2leveldb_8hpp_source.html @@ -98,9 +98,9 @@ <div class="line"><a name="l00044"></a><span class="lineno"> 44</span>  <span class="comment">// Storage implementation.</span></div> <div class="line"><a name="l00045"></a><span class="lineno"> 45</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<Option<internal::state::Entry></a>> <span class="keyword">get</span>(</div> <div class="line"><a name="l00046"></a><span class="lineno"> 46</span>  <span class="keyword">const</span> std::string& <a class="code" href="namespaceos_1_1Shell.html#acfe16ef2b1146ad49a8651c0a457ce46">name</a>);</div> -<div class="line"><a name="l00047"></a><span class="lineno"> 47</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<bool></a> <a class="code" href="classmesos_1_1state_1_1LevelDBStorage.html#ada72113682fd384ddf1715d47dda5af3">set</a>(</div> +<div class="line"><a name="l00047"></a><span class="lineno"> 47</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<bool></a> <a class="code" href="classmesos_1_1state_1_1LevelDBStorage.html#a24d4406a07e7f4305267f2fff9072818">set</a>(</div> <div class="line"><a name="l00048"></a><span class="lineno"> 48</span>  <span class="keyword">const</span> internal::state::Entry& entry,</div> -<div class="line"><a name="l00049"></a><span class="lineno"> 49</span>  <span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">UUID</a>& uuid);</div> +<div class="line"><a name="l00049"></a><span class="lineno"> 49</span>  <span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">id::UUID</a>& uuid);</div> <div class="line"><a name="l00050"></a><span class="lineno"> 50</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<bool></a> <a class="code" href="classmesos_1_1state_1_1LevelDBStorage.html#a37c5cd35a205184f3f4174d22012fef3">expunge</a>(<span class="keyword">const</span> internal::state::Entry& entry);</div> <div class="line"><a name="l00051"></a><span class="lineno"> 51</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<std::set<std::string></a>> <a class="code" href="classmesos_1_1state_1_1LevelDBStorage.html#a83d4b4508da929fb1329ea31d24a43b8">names</a>();</div> <div class="line"><a name="l00052"></a><span class="lineno"> 52</span> </div> @@ -115,8 +115,9 @@ <div class="ttc" id="classmesos_1_1state_1_1LevelDBStorage_html_a9c52ed8fe6e832c59be133b264ab4aa8"><div class="ttname"><a href="classmesos_1_1state_1_1LevelDBStorage.html#a9c52ed8fe6e832c59be133b264ab4aa8">mesos::state::LevelDBStorage::~LevelDBStorage</a></div><div class="ttdeci">virtual ~LevelDBStorage()</div></div> <div class="ttc" id="include_2mesos_2state_2storage_8hpp_html"><div class="ttname"><a href="include_2mesos_2state_2storage_8hpp.html">storage.hpp</a></div></div> <div class="ttc" id="classmesos_1_1state_1_1LevelDBStorage_html_a37c5cd35a205184f3f4174d22012fef3"><div class="ttname"><a href="classmesos_1_1state_1_1LevelDBStorage.html#a37c5cd35a205184f3f4174d22012fef3">mesos::state::LevelDBStorage::expunge</a></div><div class="ttdeci">virtual process::Future< bool > expunge(const internal::state::Entry &entry)</div></div> -<div class="ttc" id="structid_1_1UUID_html"><div class="ttname"><a href="structid_1_1UUID.html">id::UUID</a></div><div class="ttdef"><b>Definition:</b> uuid.hpp:40</div></div> +<div class="ttc" id="structid_1_1UUID_html"><div class="ttname"><a href="structid_1_1UUID.html">id::UUID</a></div><div class="ttdef"><b>Definition:</b> uuid.hpp:35</div></div> <div class="ttc" id="classmesos_1_1state_1_1LevelDBStorage_html_a93757d6c035e7ed338c8949d65842856"><div class="ttname"><a href="classmesos_1_1state_1_1LevelDBStorage.html#a93757d6c035e7ed338c8949d65842856">mesos::state::LevelDBStorage::LevelDBStorage</a></div><div class="ttdeci">LevelDBStorage(const std::string &path)</div></div> +<div class="ttc" id="classmesos_1_1state_1_1LevelDBStorage_html_a24d4406a07e7f4305267f2fff9072818"><div class="ttname"><a href="classmesos_1_1state_1_1LevelDBStorage.html#a24d4406a07e7f4305267f2fff9072818">mesos::state::LevelDBStorage::set</a></div><div class="ttdeci">virtual process::Future< bool > set(const internal::state::Entry &entry, const id::UUID &uuid)</div></div> <div class="ttc" id="option_8hpp_html"><div class="ttname"><a href="option_8hpp.html">option.hpp</a></div></div> <div class="ttc" id="future_8hpp_html"><div class="ttname"><a href="future_8hpp.html">future.hpp</a></div></div> <div class="ttc" id="classmesos_1_1state_1_1Storage_html"><div class="ttname"><a href="classmesos_1_1state_1_1Storage.html">mesos::state::Storage</a></div><div class="ttdef"><b>Definition:</b> storage.hpp:33</div></div> @@ -125,7 +126,6 @@ <div class="ttc" id="uuid_8hpp_html"><div class="ttname"><a href="uuid_8hpp.html">uuid.hpp</a></div></div> <div class="ttc" id="classmesos_1_1state_1_1LevelDBStorage_html"><div class="ttname"><a href="classmesos_1_1state_1_1LevelDBStorage.html">mesos::state::LevelDBStorage</a></div><div class="ttdef"><b>Definition:</b> leveldb.hpp:38</div></div> <div class="ttc" id="namespaceos_1_1Shell_html_acfe16ef2b1146ad49a8651c0a457ce46"><div class="ttname"><a href="namespaceos_1_1Shell.html#acfe16ef2b1146ad49a8651c0a457ce46">os::Shell::name</a></div><div class="ttdeci">constexpr const char * name</div><div class="ttdef"><b>Definition:</b> shell.hpp:41</div></div> -<div class="ttc" id="classmesos_1_1state_1_1LevelDBStorage_html_ada72113682fd384ddf1715d47dda5af3"><div class="ttname"><a href="classmesos_1_1state_1_1LevelDBStorage.html#ada72113682fd384ddf1715d47dda5af3">mesos::state::LevelDBStorage::set</a></div><div class="ttdeci">virtual process::Future< bool > set(const internal::state::Entry &entry, const UUID &uuid)</div></div> <div class="ttc" id="classprocess_1_1Future_html"><div class="ttname"><a href="classprocess_1_1Future.html">process::Future</a></div><div class="ttdef"><b>Definition:</b> future.hpp:57</div></div> </div><!-- fragment --></div><!-- contents --> <!-- start footer part --> http://git-wip-us.apache.org/repos/asf/mesos-site/blob/aac7827c/content/api/latest/c++/include_2mesos_2state_2log_8hpp_source.html ---------------------------------------------------------------------- diff --git a/content/api/latest/c++/include_2mesos_2state_2log_8hpp_source.html b/content/api/latest/c++/include_2mesos_2state_2log_8hpp_source.html index f9b024c..8d75809 100644 --- a/content/api/latest/c++/include_2mesos_2state_2log_8hpp_source.html +++ b/content/api/latest/c++/include_2mesos_2state_2log_8hpp_source.html @@ -100,9 +100,9 @@ <div class="line"><a name="l00046"></a><span class="lineno"> 46</span>  <span class="comment">// Storage implementation.</span></div> <div class="line"><a name="l00047"></a><span class="lineno"> 47</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<Option<internal::state::Entry></a>> <span class="keyword">get</span>(</div> <div class="line"><a name="l00048"></a><span class="lineno"> 48</span>  <span class="keyword">const</span> std::string& <a class="code" href="namespaceos_1_1Shell.html#acfe16ef2b1146ad49a8651c0a457ce46">name</a>);</div> -<div class="line"><a name="l00049"></a><span class="lineno"> 49</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<bool></a> <a class="code" href="classmesos_1_1state_1_1LogStorage.html#a8d1cd4745be1e75abf319098059c3629">set</a>(</div> +<div class="line"><a name="l00049"></a><span class="lineno"> 49</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<bool></a> <a class="code" href="classmesos_1_1state_1_1LogStorage.html#ae8f96058ec60224d296e8fcca2eebb66">set</a>(</div> <div class="line"><a name="l00050"></a><span class="lineno"> 50</span>  <span class="keyword">const</span> internal::state::Entry& entry,</div> -<div class="line"><a name="l00051"></a><span class="lineno"> 51</span>  <span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">UUID</a>& uuid);</div> +<div class="line"><a name="l00051"></a><span class="lineno"> 51</span>  <span class="keyword">const</span> <a class="code" href="structid_1_1UUID.html">id::UUID</a>& uuid);</div> <div class="line"><a name="l00052"></a><span class="lineno"> 52</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<bool></a> <a class="code" href="classmesos_1_1state_1_1LogStorage.html#af87c8bc9be35c91ae1613adf356d8226">expunge</a>(<span class="keyword">const</span> internal::state::Entry& entry);</div> <div class="line"><a name="l00053"></a><span class="lineno"> 53</span>  <span class="keyword">virtual</span> <a class="code" href="classprocess_1_1Future.html">process::Future<std::set<std::string></a>> <a class="code" href="classmesos_1_1state_1_1LogStorage.html#af7a09127968c95d9a93e8c4a735e7d2c">names</a>();</div> <div class="line"><a name="l00054"></a><span class="lineno"> 54</span> </div> @@ -115,18 +115,18 @@ <div class="line"><a name="l00061"></a><span class="lineno"> 61</span> </div> <div class="line"><a name="l00062"></a><span class="lineno"> 62</span> <span class="preprocessor">#endif // __MESOS_STATE_LOG_HPP__</span></div> <div class="ttc" id="include_2mesos_2state_2storage_8hpp_html"><div class="ttname"><a href="include_2mesos_2state_2storage_8hpp.html">storage.hpp</a></div></div> -<div class="ttc" id="classmesos_1_1state_1_1LogStorage_html_a8d1cd4745be1e75abf319098059c3629"><div class="ttname"><a href="classmesos_1_1state_1_1LogStorage.html#a8d1cd4745be1e75abf319098059c3629">mesos::state::LogStorage::set</a></div><div class="ttdeci">virtual process::Future< bool > set(const internal::state::Entry &entry, const UUID &uuid)</div></div> <div class="ttc" id="classmesos_1_1state_1_1LogStorage_html_af87c8bc9be35c91ae1613adf356d8226"><div class="ttname"><a href="classmesos_1_1state_1_1LogStorage.html#af87c8bc9be35c91ae1613adf356d8226">mesos::state::LogStorage::expunge</a></div><div class="ttdeci">virtual process::Future< bool > expunge(const internal::state::Entry &entry)</div></div> <div class="ttc" id="classmesos_1_1state_1_1LogStorage_html_a5a332dac55730c5e10efb44a1069b8c7"><div class="ttname"><a href="classmesos_1_1state_1_1LogStorage.html#a5a332dac55730c5e10efb44a1069b8c7">mesos::state::LogStorage::LogStorage</a></div><div class="ttdeci">LogStorage(mesos::log::Log *log, size_t diffsBetweenSnapshots=0)</div></div> <div class="ttc" id="include_2mesos_2log_2log_8hpp_html"><div class="ttname"><a href="include_2mesos_2log_2log_8hpp.html">log.hpp</a></div></div> <div class="ttc" id="classmesos_1_1state_1_1LogStorage_html"><div class="ttname"><a href="classmesos_1_1state_1_1LogStorage.html">mesos::state::LogStorage</a></div><div class="ttdef"><b>Definition:</b> log.hpp:39</div></div> <div class="ttc" id="classmesos_1_1log_1_1Log_html"><div class="ttname"><a href="classmesos_1_1log_1_1Log.html">mesos::log::Log</a></div><div class="ttdef"><b>Definition:</b> log.hpp:52</div></div> -<div class="ttc" id="structid_1_1UUID_html"><div class="ttname"><a href="structid_1_1UUID.html">id::UUID</a></div><div class="ttdef"><b>Definition:</b> uuid.hpp:40</div></div> +<div class="ttc" id="structid_1_1UUID_html"><div class="ttname"><a href="structid_1_1UUID.html">id::UUID</a></div><div class="ttdef"><b>Definition:</b> uuid.hpp:35</div></div> <div class="ttc" id="option_8hpp_html"><div class="ttname"><a href="option_8hpp.html">option.hpp</a></div></div> <div class="ttc" id="future_8hpp_html"><div class="ttname"><a href="future_8hpp.html">future.hpp</a></div></div> <div class="ttc" id="classmesos_1_1state_1_1Storage_html"><div class="ttname"><a href="classmesos_1_1state_1_1Storage.html">mesos::state::Storage</a></div><div class="ttdef"><b>Definition:</b> storage.hpp:33</div></div> <div class="ttc" id="classmesos_1_1state_1_1LogStorage_html_af7a09127968c95d9a93e8c4a735e7d2c"><div class="ttname"><a href="classmesos_1_1state_1_1LogStorage.html#af7a09127968c95d9a93e8c4a735e7d2c">mesos::state::LogStorage::names</a></div><div class="ttdeci">virtual process::Future< std::set< std::string > > names()</div></div> <div class="ttc" id="uuid_8hpp_html"><div class="ttname"><a href="uuid_8hpp.html">uuid.hpp</a></div></div> +<div class="ttc" id="classmesos_1_1state_1_1LogStorage_html_ae8f96058ec60224d296e8fcca2eebb66"><div class="ttname"><a href="classmesos_1_1state_1_1LogStorage.html#ae8f96058ec60224d296e8fcca2eebb66">mesos::state::LogStorage::set</a></div><div class="ttdeci">virtual process::Future< bool > set(const internal::state::Entry &entry, const id::UUID &uuid)</div></div> <div class="ttc" id="classmesos_1_1state_1_1LogStorage_html_a3dbcc6a13ac0ad4c4836511f76f2ae31"><div class="ttname"><a href="classmesos_1_1state_1_1LogStorage.html#a3dbcc6a13ac0ad4c4836511f76f2ae31">mesos::state::LogStorage::~LogStorage</a></div><div class="ttdeci">virtual ~LogStorage()</div></div> <div class="ttc" id="namespaceos_1_1Shell_html_acfe16ef2b1146ad49a8651c0a457ce46"><div class="ttname"><a href="namespaceos_1_1Shell.html#acfe16ef2b1146ad49a8651c0a457ce46">os::Shell::name</a></div><div class="ttdeci">constexpr const char * name</div><div class="ttdef"><b>Definition:</b> shell.hpp:41</div></div> <div class="ttc" id="classprocess_1_1Future_html"><div class="ttname"><a href="classprocess_1_1Future.html">process::Future</a></div><div class="ttdef"><b>Definition:</b> future.hpp:57</div></div> http://git-wip-us.apache.org/repos/asf/mesos-site/blob/aac7827c/content/api/latest/c++/include_2mesos_2state_2state_8hpp_source.html ---------------------------------------------------------------------- diff --git a/content/api/latest/c++/include_2mesos_2state_2state_8hpp_source.html b/content/api/latest/c++/include_2mesos_2state_2state_8hpp_source.html index 87c5329..ff2d8f5 100644 --- a/content/api/latest/c++/include_2mesos_2state_2state_8hpp_source.html +++ b/content/api/latest/c++/include_2mesos_2state_2state_8hpp_source.html @@ -197,7 +197,7 @@ <div class="line"><a name="l00143"></a><span class="lineno"> 143</span>  <span class="comment">// UUID and no value to start).</span></div> <div class="line"><a name="l00144"></a><span class="lineno"> 144</span>  internal::state::Entry entry;</div> <div class="line"><a name="l00145"></a><span class="lineno"> 145</span>  entry.set_name(name);</div> -<div class="line"><a name="l00146"></a><span class="lineno"> 146</span>  entry.set_uuid(<a class="code" href="namespaceos.html#aede9f61dcb4b7d1f276302a7bce37446">UUID::random</a>().toBytes());</div> +<div class="line"><a name="l00146"></a><span class="lineno"> 146</span>  entry.set_uuid(<a class="code" href="structid_1_1UUID.html#a6d8296fba33c5d84a64e4a882fcdc280">id::UUID::random</a>().toBytes());</div> <div class="line"><a name="l00147"></a><span class="lineno"> 147</span> </div> <div class="line"><a name="l00148"></a><span class="lineno"> 148</span>  <span class="keywordflow">return</span> Variable(entry);</div> <div class="line"><a name="l00149"></a><span class="lineno"> 149</span> }</div> @@ -206,16 +206,16 @@ <div class="line"><a name="l00152"></a><span class="lineno"><a class="line" href="classmesos_1_1state_1_1State.html#aee80fd693c8c027bbdf05a3d887ffaf6"> 152</a></span> <span class="keyword">inline</span> <a class="code" href="classprocess_1_1Future.html">process::Future<Option<Variable></a>> <a class="code" href="classmesos_1_1state_1_1State.html#aee80fd693c8c027bbdf05a3d887ffaf6">State::store</a>(<span class="keyword">const</span> <a class="code" href="classmesos_1_1state_1_1Variable.html">Variable</a>& variable)</div> <div class="line"><a name="l00153"></a><span class="lineno"> 153</span> {</div> <div class="line"><a name="l00154"></a><span class="lineno"> 154</span>  <span class="comment">// Note that we try and swap an entry even if the value didn't change!</span></div> -<div class="line"><a name="l00155"></a><span class="lineno"> 155</span>  <a class="code" href="structid_1_1UUID.html">UUID</a> uuid = UUID::fromBytes(variable.entry.uuid()).<span class="keyword">get</span>();</div> +<div class="line"><a name="l00155"></a><span class="lineno"> 155</span>  <a class="code" href="structid_1_1UUID.html">id::UUID</a> uuid = <a class="code" href="structid_1_1UUID.html#afd66db1d29a4ee4be9c82581437dda74">id::UUID::fromBytes</a>(variable.entry.uuid()).<span class="keyword">get</span>();</div> <div class="line"><a name="l00156"></a><span class="lineno"> 156</span> </div> <div class="line"><a name="l00157"></a><span class="lineno"> 157</span>  <span class="comment">// Create a new entry to replace the existing entry provided the</span></div> <div class="line"><a name="l00158"></a><span class="lineno"> 158</span>  <span class="comment">// UUID matches.</span></div> <div class="line"><a name="l00159"></a><span class="lineno"> 159</span>  internal::state::Entry entry;</div> <div class="line"><a name="l00160"></a><span class="lineno"> 160</span>  entry.set_name(variable.entry.name());</div> -<div class="line"><a name="l00161"></a><span class="lineno"> 161</span>  entry.set_uuid(<a class="code" href="namespaceos.html#aede9f61dcb4b7d1f276302a7bce37446">UUID::random</a>().toBytes());</div> +<div class="line"><a name="l00161"></a><span class="lineno"> 161</span>  entry.set_uuid(<a class="code" href="structid_1_1UUID.html#a6d8296fba33c5d84a64e4a882fcdc280">id::UUID::random</a>().toBytes());</div> <div class="line"><a name="l00162"></a><span class="lineno"> 162</span>  entry.set_value(variable.entry.value());</div> <div class="line"><a name="l00163"></a><span class="lineno"> 163</span> </div> -<div class="line"><a name="l00164"></a><span class="lineno"> 164</span>  <span class="keywordflow">return</span> storage-><a class="code" href="classmesos_1_1state_1_1Storage.html#a069fded54c8f59a04b825f4ee7c79cf4">set</a>(entry, uuid)</div> +<div class="line"><a name="l00164"></a><span class="lineno"> 164</span>  <span class="keywordflow">return</span> storage-><a class="code" href="classmesos_1_1state_1_1Storage.html#aa6db1d2a565596d7cc65a505f9e99028">set</a>(entry, uuid)</div> <div class="line"><a name="l00165"></a><span class="lineno"> 165</span>  .<a class="code" href="classprocess_1_1Future.html#a269dcc23e03e8868067c24fe70b65a41">then</a>(<a class="code" href="namespaceprocess_1_1network.html#ad067110a4b38cc83785a43f49bf6c8e2">lambda::bind</a>(&State::_store, entry, lambda::_1));</div> <div class="line"><a name="l00166"></a><span class="lineno"> 166</span> }</div> <div class="line"><a name="l00167"></a><span class="lineno"> 167</span> </div> @@ -255,7 +255,6 @@ <div class="ttc" id="classmesos_1_1state_1_1State_html"><div class="ttname"><a href="classmesos_1_1state_1_1State.html">mesos::state::State</a></div><div class="ttdef"><b>Definition:</b> state.hpp:90</div></div> <div class="ttc" id="include_2mesos_2state_2storage_8hpp_html"><div class="ttname"><a href="include_2mesos_2state_2storage_8hpp.html">storage.hpp</a></div></div> <div class="ttc" id="some_8hpp_html"><div class="ttname"><a href="some_8hpp.html">some.hpp</a></div></div> -<div class="ttc" id="classmesos_1_1state_1_1Storage_html_a069fded54c8f59a04b825f4ee7c79cf4"><div class="ttname"><a href="classmesos_1_1state_1_1Storage.html#a069fded54c8f59a04b825f4ee7c79cf4">mesos::state::Storage::set</a></div><div class="ttdeci">virtual process::Future< bool > set(const internal::state::Entry &entry, const UUID &uuid)=0</div></div> <div class="ttc" id="classmesos_1_1state_1_1Variable_html_ade8ed8f89ceb5e3ab004e2922a5b35fa"><div class="ttname"><a href="classmesos_1_1state_1_1Variable.html#ade8ed8f89ceb5e3ab004e2922a5b35fa">mesos::state::Variable::value</a></div><div class="ttdeci">std::string value() const </div><div class="ttdef"><b>Definition:</b> state.hpp:67</div></div> <div class="ttc" id="classmesos_1_1state_1_1State_html_a3966e025554f6b786eb13bdac9fb53b5"><div class="ttname"><a href="classmesos_1_1state_1_1State.html#a3966e025554f6b786eb13bdac9fb53b5">mesos::state::State::names</a></div><div class="ttdeci">process::Future< std::set< std::string > > names()</div><div class="ttdef"><b>Definition:</b> state.hpp:187</div></div> <div class="ttc" id="none_8hpp_html"><div class="ttname"><a href="none_8hpp.html">none.hpp</a></div></div> @@ -263,11 +262,11 @@ <div class="ttc" id="lambda_8hpp_html"><div class="ttname"><a href="lambda_8hpp.html">lambda.hpp</a></div></div> <div class="ttc" id="classmesos_1_1state_1_1Storage_html_ae7f901a5273922d60386d059bcb419eb"><div class="ttname"><a href="classmesos_1_1state_1_1Storage.html#ae7f901a5273922d60386d059bcb419eb">mesos::state::Storage::expunge</a></div><div class="ttdeci">virtual process::Future< bool > expunge(const internal::state::Entry &entry)=0</div></div> <div class="ttc" id="classOption_html_a4e3bf8416d95246f43c91f1b5c309323"><div class="ttname"><a href="classOption.html#a4e3bf8416d95246f43c91f1b5c309323">Option::isSome</a></div><div class="ttdeci">bool isSome() const </div><div class="ttdef"><b>Definition:</b> option.hpp:115</div></div> +<div class="ttc" id="structid_1_1UUID_html_a6d8296fba33c5d84a64e4a882fcdc280"><div class="ttname"><a href="structid_1_1UUID.html#a6d8296fba33c5d84a64e4a882fcdc280">id::UUID::random</a></div><div class="ttdeci">static UUID random()</div><div class="ttdef"><b>Definition:</b> uuid.hpp:38</div></div> <div class="ttc" id="classmesos_1_1state_1_1Variable_html"><div class="ttname"><a href="classmesos_1_1state_1_1Variable.html">mesos::state::Variable</a></div><div class="ttdef"><b>Definition:</b> state.hpp:64</div></div> <div class="ttc" id="classmesos_1_1state_1_1Variable_html_abb0a232f470a26e935076cc6dd8f114a"><div class="ttname"><a href="classmesos_1_1state_1_1Variable.html#abb0a232f470a26e935076cc6dd8f114a">mesos::state::Variable::mutate</a></div><div class="ttdeci">Variable mutate(const std::string &value) const </div><div class="ttdef"><b>Definition:</b> state.hpp:72</div></div> -<div class="ttc" id="structid_1_1UUID_html"><div class="ttname"><a href="structid_1_1UUID.html">id::UUID</a></div><div class="ttdef"><b>Definition:</b> uuid.hpp:40</div></div> +<div class="ttc" id="structid_1_1UUID_html"><div class="ttname"><a href="structid_1_1UUID.html">id::UUID</a></div><div class="ttdef"><b>Definition:</b> uuid.hpp:35</div></div> <div class="ttc" id="classOption_html_a21358442c0fac1cc978a67a9a9089a79"><div class="ttname"><a href="classOption.html#a21358442c0fac1cc978a67a9a9089a79">Option::get</a></div><div class="ttdeci">const T & get() const &</div><div class="ttdef"><b>Definition:</b> option.hpp:118</div></div> -<div class="ttc" id="namespaceos_html_aede9f61dcb4b7d1f276302a7bce37446"><div class="ttname"><a href="namespaceos.html#aede9f61dcb4b7d1f276302a7bce37446">os::random</a></div><div class="ttdeci">int random()</div><div class="ttdef"><b>Definition:</b> os.hpp:635</div></div> <div class="ttc" id="option_8hpp_html"><div class="ttname"><a href="option_8hpp.html">option.hpp</a></div></div> <div class="ttc" id="future_8hpp_html"><div class="ttname"><a href="future_8hpp.html">future.hpp</a></div></div> <div class="ttc" id="classmesos_1_1state_1_1Storage_html"><div class="ttname"><a href="classmesos_1_1state_1_1Storage.html">mesos::state::Storage</a></div><div class="ttdef"><b>Definition:</b> storage.hpp:33</div></div> @@ -275,7 +274,9 @@ <div class="ttc" id="classmesos_1_1state_1_1State_html_acd5a045c3daa593a574f6335f63eda9d"><div class="ttname"><a href="classmesos_1_1state_1_1State.html#acd5a045c3daa593a574f6335f63eda9d">mesos::state::State::fetch</a></div><div class="ttdeci">process::Future< Variable > fetch(const std::string &name)</div><div class="ttdef"><b>Definition:</b> state.hpp:127</div></div> <div class="ttc" id="some_8hpp_html_a2048f5c3b4ee79448c012cf6dc82a020"><div class="ttname"><a href="some_8hpp.html#a2048f5c3b4ee79448c012cf6dc82a020">Some</a></div><div class="ttdeci">_Some< typename std::decay< T >::type > Some(T &&t)</div><div class="ttdef"><b>Definition:</b> some.hpp:42</div></div> <div class="ttc" id="structNone_html"><div class="ttname"><a href="structNone.html">None</a></div><div class="ttdef"><b>Definition:</b> none.hpp:27</div></div> +<div class="ttc" id="structid_1_1UUID_html_afd66db1d29a4ee4be9c82581437dda74"><div class="ttname"><a href="structid_1_1UUID.html#afd66db1d29a4ee4be9c82581437dda74">id::UUID::fromBytes</a></div><div class="ttdeci">static Try< UUID > fromBytes(const std::string &s)</div><div class="ttdef"><b>Definition:</b> uuid.hpp:49</div></div> <div class="ttc" id="try_8hpp_html"><div class="ttname"><a href="try_8hpp.html">try.hpp</a></div></div> +<div class="ttc" id="classmesos_1_1state_1_1Storage_html_aa6db1d2a565596d7cc65a505f9e99028"><div class="ttname"><a href="classmesos_1_1state_1_1Storage.html#aa6db1d2a565596d7cc65a505f9e99028">mesos::state::Storage::set</a></div><div class="ttdeci">virtual process::Future< bool > set(const internal::state::Entry &entry, const id::UUID &uuid)=0</div></div> <div class="ttc" id="deferred_8hpp_html"><div class="ttname"><a href="deferred_8hpp.html">deferred.hpp</a></div></div> <div class="ttc" id="classmesos_1_1state_1_1Storage_html_abf909dbdb474653209c4ffdc83f1f794"><div class="ttname"><a href="classmesos_1_1state_1_1Storage.html#abf909dbdb474653209c4ffdc83f1f794">mesos::state::Storage::names</a></div><div class="ttdeci">virtual process::Future< std::set< std::string > > names()=0</div></div> <div class="ttc" id="namespaceprocess_1_1network_html_ad067110a4b38cc83785a43f49bf6c8e2"><div class="ttname"><a href="namespaceprocess_1_1network.html#ad067110a4b38cc83785a43f49bf6c8e2">process::network::bind</a></div><div class="ttdeci">Try< Nothing > bind(int_fd s, const Address &address)</div><div class="ttdef"><b>Definition:</b> network.hpp:46</div></div>
