http://git-wip-us.apache.org/repos/asf/arrow-site/blob/4c7c2f1b/docs/cpp/classplasma_1_1_plasma_client-members.html ---------------------------------------------------------------------- diff --git a/docs/cpp/classplasma_1_1_plasma_client-members.html b/docs/cpp/classplasma_1_1_plasma_client-members.html index 1cdc16e..2125990 100644 --- a/docs/cpp/classplasma_1_1_plasma_client-members.html +++ b/docs/cpp/classplasma_1_1_plasma_client-members.html @@ -76,7 +76,7 @@ $(function() { <tr class="even"><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html#a23c13f143dae9053bf3d39d36b40ee77">Abort</a>(const ObjectID &object_id)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html">plasma::PlasmaClient</a></td><td class="entry"></td></tr> <tr><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html#ac024b42271ad80c467636fc5b16968a3">Connect</a>(const std::string &store_socket_name, const std::string &manager_socket_name, int release_delay, int num_retries=-1)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html">plasma::PlasmaClient</a></td><td class="entry"></td></tr> <tr class="even"><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html#af573b2ba35f48bf012393e9438ef086d">Contains</a>(const ObjectID &object_id, bool *has_object)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html">plasma::PlasmaClient</a></td><td class="entry"></td></tr> - <tr><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html#ac18ab9cc792c620a97a3dcb165e0ecd7">Create</a>(const ObjectID &object_id, int64_t data_size, uint8_t *metadata, int64_t metadata_size, std::shared_ptr< Buffer > *data)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html">plasma::PlasmaClient</a></td><td class="entry"></td></tr> + <tr><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html#a0b6e4bc16429191e1449c60f020b4dd7">Create</a>(const ObjectID &object_id, int64_t data_size, uint8_t *metadata, int64_t metadata_size, std::shared_ptr< Buffer > *data, int device_num=0)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html">plasma::PlasmaClient</a></td><td class="entry"></td></tr> <tr class="even"><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html#a7a38517ca57a9a98814cac85aeff00c3">Delete</a>(const ObjectID &object_id)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html">plasma::PlasmaClient</a></td><td class="entry"></td></tr> <tr><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html#a82ff4d7b988c040aa46674a2fa907eff">Disconnect</a>()</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html">plasma::PlasmaClient</a></td><td class="entry"></td></tr> <tr class="even"><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html#ae1341d3da71394cb35c4d3ad7edc317e">Evict</a>(int64_t num_bytes, int64_t &num_bytes_evicted)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_client.html">plasma::PlasmaClient</a></td><td class="entry"></td></tr>
http://git-wip-us.apache.org/repos/asf/arrow-site/blob/4c7c2f1b/docs/cpp/classplasma_1_1_plasma_client.html ---------------------------------------------------------------------- diff --git a/docs/cpp/classplasma_1_1_plasma_client.html b/docs/cpp/classplasma_1_1_plasma_client.html index 3c147a8..d43168c 100644 --- a/docs/cpp/classplasma_1_1_plasma_client.html +++ b/docs/cpp/classplasma_1_1_plasma_client.html @@ -85,9 +85,9 @@ Public Member Functions</h2></td></tr> <tr class="memitem:ac024b42271ad80c467636fc5b16968a3"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classarrow_1_1_status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classplasma_1_1_plasma_client.html#ac024b42271ad80c467636fc5b16968a3">Connect</a> (const std::string &store_socket_name, const std::string &manager_socket_name, int release_delay, int num_retries=-1)</td></tr> <tr class="memdesc:ac024b42271ad80c467636fc5b16968a3"><td class="mdescLeft"> </td><td class="mdescRight">Connect to the local plasma store and plasma manager. <a href="#ac024b42271ad80c467636fc5b16968a3">More...</a><br /></td></tr> <tr class="separator:ac024b42271ad80c467636fc5b16968a3"><td class="memSeparator" colspan="2"> </td></tr> -<tr class="memitem:ac18ab9cc792c620a97a3dcb165e0ecd7"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classarrow_1_1_status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classplasma_1_1_plasma_client.html#ac18ab9cc792c620a97a3dcb165e0ecd7">Create</a> (const <a class="el" href="namespaceplasma.html#adf1aa2f87f6f11e1993628f574e31e75">ObjectID</a> &object_id, int64_t data_size, uint8_t *metadata, int64_t metadata_size, std::shared_ptr< <a class="el" href="classarrow_1_1_buffer.html">Buffer</a> > *data)</td></tr> -<tr class="memdesc:ac18ab9cc792c620a97a3dcb165e0ecd7"><td class="mdescLeft"> </td><td class="mdescRight">Create an object in the Plasma Store. <a href="#ac18ab9cc792c620a97a3dcb165e0ecd7">More...</a><br /></td></tr> -<tr class="separator:ac18ab9cc792c620a97a3dcb165e0ecd7"><td class="memSeparator" colspan="2"> </td></tr> +<tr class="memitem:a0b6e4bc16429191e1449c60f020b4dd7"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classarrow_1_1_status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classplasma_1_1_plasma_client.html#a0b6e4bc16429191e1449c60f020b4dd7">Create</a> (const <a class="el" href="namespaceplasma.html#adf1aa2f87f6f11e1993628f574e31e75">ObjectID</a> &object_id, int64_t data_size, uint8_t *metadata, int64_t metadata_size, std::shared_ptr< <a class="el" href="classarrow_1_1_buffer.html">Buffer</a> > *data, int device_num=0)</td></tr> +<tr class="memdesc:a0b6e4bc16429191e1449c60f020b4dd7"><td class="mdescLeft"> </td><td class="mdescRight">Create an object in the Plasma Store. <a href="#a0b6e4bc16429191e1449c60f020b4dd7">More...</a><br /></td></tr> +<tr class="separator:a0b6e4bc16429191e1449c60f020b4dd7"><td class="memSeparator" colspan="2"> </td></tr> <tr class="memitem:a3b0e952a210fbdf028f5727c2007977e"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classarrow_1_1_status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classplasma_1_1_plasma_client.html#a3b0e952a210fbdf028f5727c2007977e">Get</a> (const <a class="el" href="namespaceplasma.html#adf1aa2f87f6f11e1993628f574e31e75">ObjectID</a> *object_ids, int64_t num_objects, int64_t timeout_ms, <a class="el" href="structplasma_1_1_object_buffer.html">ObjectBuffer</a> *object_buffers)</td></tr> <tr class="memdesc:a3b0e952a210fbdf028f5727c2007977e"><td class="mdescLeft"> </td><td class="mdescRight">Get some objects from the Plasma Store. <a href="#a3b0e952a210fbdf028f5727c2007977e">More...</a><br /></td></tr> <tr class="separator:a3b0e952a210fbdf028f5727c2007977e"><td class="memSeparator" colspan="2"> </td></tr> @@ -294,8 +294,8 @@ Public Member Functions</h2></td></tr> </div> </div> -<a id="ac18ab9cc792c620a97a3dcb165e0ecd7"></a> -<h2 class="memtitle"><span class="permalink"><a href="#ac18ab9cc792c620a97a3dcb165e0ecd7">◆ </a></span>Create()</h2> +<a id="a0b6e4bc16429191e1449c60f020b4dd7"></a> +<h2 class="memtitle"><span class="permalink"><a href="#a0b6e4bc16429191e1449c60f020b4dd7">◆ </a></span>Create()</h2> <div class="memitem"> <div class="memproto"> @@ -328,7 +328,13 @@ Public Member Functions</h2></td></tr> <td class="paramkey"></td> <td></td> <td class="paramtype">std::shared_ptr< <a class="el" href="classarrow_1_1_buffer.html">Buffer</a> > * </td> - <td class="paramname"><em>data</em> </td> + <td class="paramname"><em>data</em>, </td> + </tr> + <tr> + <td class="paramkey"></td> + <td></td> + <td class="paramtype">int </td> + <td class="paramname"><em>device_num</em> = <code>0</code> </td> </tr> <tr> <td></td> @@ -346,7 +352,8 @@ Public Member Functions</h2></td></tr> <tr><td class="paramname">data_size</td><td>The size in bytes of the space to be allocated for this object's data (this does not include space used for metadata). </td></tr> <tr><td class="paramname">metadata</td><td>The object's metadata. If there is no metadata, this pointer should be NULL. </td></tr> <tr><td class="paramname">metadata_size</td><td>The size in bytes of the metadata. If there is no metadata, this should be 0. </td></tr> - <tr><td class="paramname">data</td><td>A buffer containing the address of the newly created object will be written here. </td></tr> + <tr><td class="paramname">data</td><td>The address of the newly created object will be written here. </td></tr> + <tr><td class="paramname">device_num</td><td>The number of the device where the object is being created. device_num = 0 corresponds to the host, device_num = 1 corresponds to GPU0, device_num = 2 corresponds to GPU1, etc. </td></tr> </table> </dd> </dl> http://git-wip-us.apache.org/repos/asf/arrow-site/blob/4c7c2f1b/docs/cpp/classplasma_1_1_plasma_store-members.html ---------------------------------------------------------------------- diff --git a/docs/cpp/classplasma_1_1_plasma_store-members.html b/docs/cpp/classplasma_1_1_plasma_store-members.html index fd1df23..04ba0cf 100644 --- a/docs/cpp/classplasma_1_1_plasma_store-members.html +++ b/docs/cpp/classplasma_1_1_plasma_store-members.html @@ -76,7 +76,7 @@ $(function() { <tr class="even"><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html#a93c8818d9177d954766dc03b4a81df3c">abort_object</a>(const ObjectID &object_id, Client *client)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html">plasma::PlasmaStore</a></td><td class="entry"></td></tr> <tr><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html#a8377412f57ffaa149e10ae4bf000ddab">connect_client</a>(int listener_sock)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html">plasma::PlasmaStore</a></td><td class="entry"></td></tr> <tr class="even"><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html#ac6a2cd1d799fcd3b1c372865c2a35eb2">contains_object</a>(const ObjectID &object_id)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html">plasma::PlasmaStore</a></td><td class="entry"></td></tr> - <tr><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html#a567af5bbb90deef80e73164ff4ff0974">create_object</a>(const ObjectID &object_id, int64_t data_size, int64_t metadata_size, Client *client, PlasmaObject *result)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html">plasma::PlasmaStore</a></td><td class="entry"></td></tr> + <tr><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html#a0185340ff2b548d6562c18c05b3307a6">create_object</a>(const ObjectID &object_id, int64_t data_size, int64_t metadata_size, int device_num, Client *client, PlasmaObject *result)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html">plasma::PlasmaStore</a></td><td class="entry"></td></tr> <tr class="even"><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html#a5ee9c58a4fedd9e7ea8f6e1a3ecdd004">delete_object</a>(ObjectID &object_id)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html">plasma::PlasmaStore</a></td><td class="entry"></td></tr> <tr><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html#a8fe436cd47aada12494315ff062d2316">delete_objects</a>(const std::vector< ObjectID > &object_ids)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html">plasma::PlasmaStore</a></td><td class="entry"></td></tr> <tr class="even"><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html#a9fb0d242de3a9a909f19da3b2d2bc46a">disconnect_client</a>(int client_fd)</td><td class="entry"><a class="el" href="classplasma_1_1_plasma_store.html">plasma::PlasmaStore</a></td><td class="entry"></td></tr> http://git-wip-us.apache.org/repos/asf/arrow-site/blob/4c7c2f1b/docs/cpp/classplasma_1_1_plasma_store.html ---------------------------------------------------------------------- diff --git a/docs/cpp/classplasma_1_1_plasma_store.html b/docs/cpp/classplasma_1_1_plasma_store.html index 3578be1..17cc12b 100644 --- a/docs/cpp/classplasma_1_1_plasma_store.html +++ b/docs/cpp/classplasma_1_1_plasma_store.html @@ -85,9 +85,9 @@ Public Member Functions</h2></td></tr> <tr class="memitem:a5ed7bf60d93154233ad816e8a576b4ad"><td class="memItemLeft" align="right" valign="top">const <a class="el" href="structplasma_1_1_plasma_store_info.html">PlasmaStoreInfo</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classplasma_1_1_plasma_store.html#a5ed7bf60d93154233ad816e8a576b4ad">get_plasma_store_info</a> ()</td></tr> <tr class="memdesc:a5ed7bf60d93154233ad816e8a576b4ad"><td class="mdescLeft"> </td><td class="mdescRight">Get a const pointer to the internal <a class="el" href="structplasma_1_1_plasma_store_info.html" title="The plasma store information that is exposed to the eviction policy. ">PlasmaStoreInfo</a> object. <a href="#a5ed7bf60d93154233ad816e8a576b4ad">More...</a><br /></td></tr> <tr class="separator:a5ed7bf60d93154233ad816e8a576b4ad"><td class="memSeparator" colspan="2"> </td></tr> -<tr class="memitem:a567af5bbb90deef80e73164ff4ff0974"><td class="memItemLeft" align="right" valign="top">int </td><td class="memItemRight" valign="bottom"><a class="el" href="classplasma_1_1_plasma_store.html#a567af5bbb90deef80e73164ff4ff0974">create_object</a> (const <a class="el" href="namespaceplasma.html#adf1aa2f87f6f11e1993628f574e31e75">ObjectID</a> &object_id, int64_t data_size, int64_t metadata_size, <a class="el" href="structplasma_1_1_client.html">Client</a> *client, <a class="el" href="structplasma_1_1_plasma_object.html">PlasmaObject</a> *result)</td></tr> -<tr class="memdesc:a567af5bbb90deef80e73164ff4ff0974"><td class="mdescLeft"> </td><td class="mdescRight">Create a new object. <a href="#a567af5bbb90deef80e73164ff4ff0974">More...</a><br /></td></tr> -<tr class="separator:a567af5bbb90deef80e73164ff4ff0974"><td class="memSeparator" colspan="2"> </td></tr> +<tr class="memitem:a0185340ff2b548d6562c18c05b3307a6"><td class="memItemLeft" align="right" valign="top">int </td><td class="memItemRight" valign="bottom"><a class="el" href="classplasma_1_1_plasma_store.html#a0185340ff2b548d6562c18c05b3307a6">create_object</a> (const <a class="el" href="namespaceplasma.html#adf1aa2f87f6f11e1993628f574e31e75">ObjectID</a> &object_id, int64_t data_size, int64_t metadata_size, int device_num, <a class="el" href="structplasma_1_1_client.html">Client</a> *client, <a class="el" href="structplasma_1_1_plasma_object.html">PlasmaObject</a> *result)</td></tr> +<tr class="memdesc:a0185340ff2b548d6562c18c05b3307a6"><td class="mdescLeft"> </td><td class="mdescRight">Create a new object. <a href="#a0185340ff2b548d6562c18c05b3307a6">More...</a><br /></td></tr> +<tr class="separator:a0185340ff2b548d6562c18c05b3307a6"><td class="memSeparator" colspan="2"> </td></tr> <tr class="memitem:a93c8818d9177d954766dc03b4a81df3c"><td class="memItemLeft" align="right" valign="top">int </td><td class="memItemRight" valign="bottom"><a class="el" href="classplasma_1_1_plasma_store.html#a93c8818d9177d954766dc03b4a81df3c">abort_object</a> (const <a class="el" href="namespaceplasma.html#adf1aa2f87f6f11e1993628f574e31e75">ObjectID</a> &object_id, <a class="el" href="structplasma_1_1_client.html">Client</a> *client)</td></tr> <tr class="memdesc:a93c8818d9177d954766dc03b4a81df3c"><td class="mdescLeft"> </td><td class="mdescRight">Abort a created but unsealed object. <a href="#a93c8818d9177d954766dc03b4a81df3c">More...</a><br /></td></tr> <tr class="separator:a93c8818d9177d954766dc03b4a81df3c"><td class="memSeparator" colspan="2"> </td></tr> @@ -274,8 +274,8 @@ Public Member Functions</h2></td></tr> </div> </div> -<a id="a567af5bbb90deef80e73164ff4ff0974"></a> -<h2 class="memtitle"><span class="permalink"><a href="#a567af5bbb90deef80e73164ff4ff0974">◆ </a></span>create_object()</h2> +<a id="a0185340ff2b548d6562c18c05b3307a6"></a> +<h2 class="memtitle"><span class="permalink"><a href="#a0185340ff2b548d6562c18c05b3307a6">◆ </a></span>create_object()</h2> <div class="memitem"> <div class="memproto"> @@ -301,6 +301,12 @@ Public Member Functions</h2></td></tr> <tr> <td class="paramkey"></td> <td></td> + <td class="paramtype">int </td> + <td class="paramname"><em>device_num</em>, </td> + </tr> + <tr> + <td class="paramkey"></td> + <td></td> <td class="paramtype"><a class="el" href="structplasma_1_1_client.html">Client</a> * </td> <td class="paramname"><em>client</em>, </td> </tr> @@ -325,6 +331,9 @@ Public Member Functions</h2></td></tr> <tr><td class="paramname">object_id</td><td>Object ID of the object to be created. </td></tr> <tr><td class="paramname">data_size</td><td>Size in bytes of the object to be created. </td></tr> <tr><td class="paramname">metadata_size</td><td>Size in bytes of the object metadata. </td></tr> + <tr><td class="paramname">device_num</td><td>The number of the device where the object is being created. device_num = 0 corresponds to the host, device_num = 1 corresponds to GPU0, device_num = 2 corresponds to GPU1, etc. </td></tr> + <tr><td class="paramname">client</td><td>The client that created the object. </td></tr> + <tr><td class="paramname">result</td><td>The object that has been created. </td></tr> </table> </dd> </dl> http://git-wip-us.apache.org/repos/asf/arrow-site/blob/4c7c2f1b/docs/cpp/client_8h_source.html ---------------------------------------------------------------------- diff --git a/docs/cpp/client_8h_source.html b/docs/cpp/client_8h_source.html index d182698..2ceb88a 100644 --- a/docs/cpp/client_8h_source.html +++ b/docs/cpp/client_8h_source.html @@ -70,32 +70,34 @@ $(function() { <div class="title">client.h</div> </div> </div><!--header--> <div class="contents"> -<a href="client_8h.html">Go to the documentation of this file.</a><div class="fragment"><div class="line"><a name="l00001"></a><span class="lineno"> 1</span> <span class="comment">// Licensed to the Apache Software Foundation (ASF) under one</span></div><div class="line"><a name="l00002"></a><span class="lineno"> 2</span> <span class="comment">// or more contributor license agreements. See the NOTICE file</span></div><div class="line"><a name="l00003"></a><span class="lineno"> 3</span> <span class="comment">// distributed with this work for additional information</span></div><div class="line"><a name="l00004"></a><span class="lineno"> 4</span> <span class="comment">// regarding copyright ownership. The ASF licenses this file</span></div><div class="line"><a name="l00005"></a><span class="lineno"> 5</span> <span class="comment">// to you under the Apache License, Version 2.0 (the</span></div><div class="line"><a name="l00006"></a><span class= "lineno"> 6</span> <span class="comment">// "License"); you may not use this file except in compliance</span></div><div class="line"><a name="l00007"></a><span class="lineno"> 7</span> <span class="comment">// with the License. You may obtain a copy of the License at</span></div><div class="line"><a name="l00008"></a><span class="lineno"> 8</span> <span class="comment">//</span></div><div class="line"><a name="l00009"></a><span class="lineno"> 9</span> <span class="comment">// http://www.apache.org/licenses/LICENSE-2.0</span></div><div class="line"><a name="l00010"></a><span class="lineno"> 10</span> <span class="comment">//</span></div><div class="line"><a name="l00011"></a><span class="lineno"> 11</span> <span class="comment">// Unless required by applicable law or agreed to in writing,</span></div><div class="line"><a name="l00012"></a><span class="lineno"> 12</span> <span class="comment">// software distributed un der the License is distributed on an</span></div><div class="line"><a name="l00013"></a><span class="lineno"> 13</span> <span class="comment">// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY</span></div><div class="line"><a name="l00014"></a><span class="lineno"> 14</span> <span class="comment">// KIND, either express or implied. See the License for the</span></div><div class="line"><a name="l00015"></a><span class="lineno"> 15</span> <span class="comment">// specific language governing permissions and limitations</span></div><div class="line"><a name="l00016"></a><span class="lineno"> 16</span> <span class="comment">// under the License.</span></div><div class="line"><a name="l00017"></a><span class="lineno"> 17</span> </div><div class="line"><a name="l00018"></a><span class="lineno"> 18</span> <span class="preprocessor">#ifndef PLASMA_CLIENT_H</span></div><div class="line"><a name="l00019"></a><span class="lineno"> 19 </span> <span class="preprocessor">#define PLASMA_CLIENT_H</span></div><div class="line"><a name="l00020"></a><span class="lineno"> 20</span> </div><div class="line"><a name="l00021"></a><span class="lineno"> 21</span> <span class="preprocessor">#include <stdbool.h></span></div><div class="line"><a name="l00022"></a><span class="lineno"> 22</span> <span class="preprocessor">#include <time.h></span></div><div class="line"><a name="l00023"></a><span class="lineno"> 23</span> </div><div class="line"><a name="l00024"></a><span class="lineno"> 24</span> <span class="preprocessor">#include <deque></span></div><div class="line"><a name="l00025"></a><span class="lineno"> 25</span> <span class="preprocessor">#include <memory></span></div><div class="line"><a name="l00026"></a><span class="lineno"> 26</span> <span class="preprocessor">#include <string></span></div><div class="line"><a name="l00027"></a><span c lass="lineno"> 27</span> <span class="preprocessor">#include <unordered_map></span></div><div class="line"><a name="l00028"></a><span class="lineno"> 28</span> </div><div class="line"><a name="l00029"></a><span class="lineno"> 29</span> <span class="preprocessor">#include "<a class="code" href="buffer_8h.html">arrow/buffer.h</a>"</span></div><div class="line"><a name="l00030"></a><span class="lineno"> 30</span> <span class="preprocessor">#include "<a class="code" href="status_8h.html">arrow/status.h</a>"</span></div><div class="line"><a name="l00031"></a><span class="lineno"> 31</span> <span class="preprocessor">#include "<a class="code" href="visibility_8h.html">arrow/util/visibility.h</a>"</span></div><div class="line"><a name="l00032"></a><span class="lineno"> 32</span> <span class="preprocessor">#include "<a class="code" href="plasma_2common_8h.html">plasma/common.h</a>"</span></div><div clas s="line"><a name="l00033"></a><span class="lineno"> 33</span> </div><div class="line"><a name="l00034"></a><span class="lineno"> 34</span> <span class="keyword">using</span> <a class="code" href="classarrow_1_1_status.html">arrow::Status</a>;</div><div class="line"><a name="l00035"></a><span class="lineno"> 35</span> <span class="keyword">using</span> <a class="code" href="classarrow_1_1_buffer.html">arrow::Buffer</a>;</div><div class="line"><a name="l00036"></a><span class="lineno"> 36</span> </div><div class="line"><a name="l00037"></a><span class="lineno"><a class="line" href="namespaceplasma.html"> 37</a></span> <span class="keyword">namespace </span><a class="code" href="namespaceplasma.html">plasma</a> {</div><div class="line"><a name="l00038"></a><span class="lineno"> 38</span> </div><div class="line"><a name="l00039"></a><span class="lineno"><a class="line" href="client_8h.html#ac6a4959f813315451e993a3dfe28cac7"> 39</a></span>  ;<span class="preprocessor">#define PLASMA_DEFAULT_RELEASE_DELAY 64</span></div><div class="line"><a name="l00040"></a><span class="lineno"> 40</span> </div><div class="line"><a name="l00041"></a><span class="lineno"> 41</span> <span class="comment">// Use 100MB as an overestimate of the L3 cache size.</span></div><div class="line"><a name="l00042"></a><span class="lineno"><a class="line" href="namespaceplasma.html#a86d1708e5e2f6438439db3f0c6e9309b"> 42</a></span> constexpr int64_t <a class="code" href="namespaceplasma.html#a86d1708e5e2f6438439db3f0c6e9309b">kL3CacheSizeBytes</a> = 100000000;</div><div class="line"><a name="l00043"></a><span class="lineno"> 43</span> </div><div class="line"><a name="l00045"></a><span class="lineno"><a class="line" href="structplasma_1_1_object_buffer.html"> 45</a></span> <span class="keyword">struct </span><a class="code" href="structplasma_1_1_object_buffer.html">ObjectBuffer</a> {</div><div class="line"><a name=" l00047"></a><span class="lineno"><a class="line" href="structplasma_1_1_object_buffer.html#ace0c6be03d13cc503d665fe976557558"> 47</a></span>  std::shared_ptr<Buffer> <a class="code" href="structplasma_1_1_object_buffer.html#ace0c6be03d13cc503d665fe976557558">data</a>;</div><div class="line"><a name="l00049"></a><span class="lineno"><a class="line" href="structplasma_1_1_object_buffer.html#a7f517c4d5049a45fd91056288fd9d572"> 49</a></span>  int64_t <a class="code" href="structplasma_1_1_object_buffer.html#a7f517c4d5049a45fd91056288fd9d572">data_size</a>;</div><div class="line"><a name="l00051"></a><span class="lineno"><a class="line" href="structplasma_1_1_object_buffer.html#aa02e9306fe2ccd501d2b2d8a0c69a39b"> 51</a></span>  std::shared_ptr<Buffer> <a class="code" href="structplasma_1_1_object_buffer.html#aa02e9306fe2ccd501d2b2d8a0c69a39b">metadata</a>;</div><div class="line"><a name="l00053"></a><span class="lineno"><a class="line" href="structplas ma_1_1_object_buffer.html#a4abaffd262b9ebd5fc6721fd55cc59b3"> 53</a></span>  int64_t <a class="code" href="structplasma_1_1_object_buffer.html#a4abaffd262b9ebd5fc6721fd55cc59b3">metadata_size</a>;</div><div class="line"><a name="l00055"></a><span class="lineno"><a class="line" href="structplasma_1_1_object_buffer.html#aea3d531aaf1cce269e6d8227c597d139"> 55</a></span>  <span class="keywordtype">int</span> <a class="code" href="structplasma_1_1_object_buffer.html#aea3d531aaf1cce269e6d8227c597d139">device_num</a>;</div><div class="line"><a name="l00056"></a><span class="lineno"> 56</span> };</div><div class="line"><a name="l00057"></a><span class="lineno"> 57</span> </div><div class="line"><a name="l00059"></a><span class="lineno"><a class="line" href="structplasma_1_1_plasma_client_config.html"> 59</a></span> <span class="keyword">struct </span><a class="code" href="structplasma_1_1_plasma_client_config.html">PlasmaClientConfig</a> {</div><div clas s="line"><a name="l00063"></a><span class="lineno"><a class="line" href="structplasma_1_1_plasma_client_config.html#ad14b9fc059c1c72f8fec04619dc75582"> 63</a></span>  <span class="keywordtype">size_t</span> <a class="code" href="structplasma_1_1_plasma_client_config.html#ad14b9fc059c1c72f8fec04619dc75582">release_delay</a>;</div><div class="line"><a name="l00064"></a><span class="lineno"> 64</span> };</div><div class="line"><a name="l00065"></a><span class="lineno"> 65</span> </div><div class="line"><a name="l00066"></a><span class="lineno"><a class="line" href="structplasma_1_1_client_mmap_table_entry.html"> 66</a></span> <span class="keyword">struct </span><a class="code" href="structplasma_1_1_client_mmap_table_entry.html">ClientMmapTableEntry</a> {</div><div class="line"><a name="l00068"></a><span class="lineno"><a class="line" href="structplasma_1_1_client_mmap_table_entry.html#a2b6f7159ad5ce1a60633648def026acf"> 68</a></span>  uint8_t* <a c lass="code" href="structplasma_1_1_client_mmap_table_entry.html#a2b6f7159ad5ce1a60633648def026acf">pointer</a>;</div><div class="line"><a name="l00070"></a><span class="lineno"><a class="line" href="structplasma_1_1_client_mmap_table_entry.html#a8004bc973d7f722332f83bb0d7992de6"> 70</a></span>  <span class="keywordtype">size_t</span> <a class="code" href="structplasma_1_1_client_mmap_table_entry.html#a8004bc973d7f722332f83bb0d7992de6">length</a>;</div><div class="line"><a name="l00073"></a><span class="lineno"><a class="line" href="structplasma_1_1_client_mmap_table_entry.html#a8cb00d743be149ddf58091a077561934"> 73</a></span>  <span class="keywordtype">int</span> <a class="code" href="structplasma_1_1_client_mmap_table_entry.html#a8cb00d743be149ddf58091a077561934">count</a>;</div><div class="line"><a name="l00074"></a><span class="lineno"> 74</span> };</div><div class="line"><a name="l00075"></a><span class="lineno"> 75</span> </div><div class="line"><a name="l00076"></a><span class="lineno"> 76</span> <span class="keyword">struct </span>ObjectInUseEntry;</div><div class="line"><a name="l00077"></a><span class="lineno"> 77</span> <span class="keyword">struct </span><a class="code" href="structplasma_1_1_object_request.html">ObjectRequest</a>;</div><div class="line"><a name="l00078"></a><span class="lineno"> 78</span> <span class="keyword">struct </span><a class="code" href="structplasma_1_1_plasma_object.html">PlasmaObject</a>;</div><div class="line"><a name="l00079"></a><span class="lineno"> 79</span> </div><div class="line"><a name="l00080"></a><span class="lineno"><a class="line" href="classplasma_1_1_plasma_client.html"> 80</a></span> <span class="keyword">class </span>ARROW_EXPORT <a class="code" href="classplasma_1_1_plasma_client.html">PlasmaClient</a> {</div><div class="line"><a name="l00081"></a><span class="lineno"> 81</span>  <span class="keyword">public</span>:</div><div class= "line"><a name="l00082"></a><span class="lineno"> 82</span>  <a class="code" href="classplasma_1_1_plasma_client.html">PlasmaClient</a>();</div><div class="line"><a name="l00083"></a><span class="lineno"> 83</span> </div><div class="line"><a name="l00084"></a><span class="lineno"> 84</span>  ~<a class="code" href="classplasma_1_1_plasma_client.html">PlasmaClient</a>();</div><div class="line"><a name="l00085"></a><span class="lineno"> 85</span> </div><div class="line"><a name="l00098"></a><span class="lineno"> 98</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Connect(<span class="keyword">const</span> std::string& store_socket_name,</div><div class="line"><a name="l00099"></a><span class="lineno"> 99</span>  <span class="keyword">const</span> std::string& manager_socket_name, <span class="keywordtype">int</span> release_delay,</div><div class="line"><a name="l00100"></a><span class="lineno"> 1 00</span>  <span class="keywordtype">int</span> num_retries = -1);</div><div class="line"><a name="l00101"></a><span class="lineno"> 101</span> </div><div class="line"><a name="l00117"></a><span class="lineno"> 117</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Create(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id, int64_t data_size, uint8_t* metadata,</div><div class="line"><a name="l00118"></a><span class="lineno"> 118</span>  int64_t metadata_size, std::shared_ptr<Buffer>* data);</div><div class="line"><a name="l00134"></a><span class="lineno"> 134</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Get(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>* object_ids, int64_t num_objects, int64_t timeout_ms,</div><div class="line"><a name="l00135"></a><spa n class="lineno"> 135</span>  <a class="code" href="structplasma_1_1_object_buffer.html">ObjectBuffer</a>* object_buffers);</div><div class="line"><a name="l00136"></a><span class="lineno"> 136</span> </div><div class="line"><a name="l00145"></a><span class="lineno"> 145</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Release(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id);</div><div class="line"><a name="l00146"></a><span class="lineno"> 146</span> </div><div class="line"><a name="l00157"></a><span class="lineno"> 157</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Contains(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id, <span class="keywordtype">bool</span>* has_object);</div><div class="line"><a name="l00158"></a><span class="lineno"> 158</span> </di v><div class="line"><a name="l00166"></a><span class="lineno"> 166</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Abort(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id);</div><div class="line"><a name="l00167"></a><span class="lineno"> 167</span> </div><div class="line"><a name="l00174"></a><span class="lineno"> 174</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Seal(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id);</div><div class="line"><a name="l00175"></a><span class="lineno"> 175</span> </div><div class="line"><a name="l00185"></a><span class="lineno"> 185</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Delete(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id);</div><div class= "line"><a name="l00186"></a><span class="lineno"> 186</span> </div><div class="line"><a name="l00194"></a><span class="lineno"> 194</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Evict(int64_t num_bytes, int64_t& num_bytes_evicted);</div><div class="line"><a name="l00195"></a><span class="lineno"> 195</span> </div><div class="line"><a name="l00202"></a><span class="lineno"> 202</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Hash(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id, uint8_t* digest);</div><div class="line"><a name="l00203"></a><span class="lineno"> 203</span> </div><div class="line"><a name="l00212"></a><span class="lineno"> 212</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Subscribe(<span class="keywordtype">int</span>* fd);</div><div class="line"><a name="l00213"></a><span class="lineno"> 213 </span> </div><div class="line"><a name="l00221"></a><span class="lineno"> 221</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> GetNotification(<span class="keywordtype">int</span> fd, <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>* object_id, int64_t* data_size,</div><div class="line"><a name="l00222"></a><span class="lineno"> 222</span>  int64_t* metadata_size);</div><div class="line"><a name="l00223"></a><span class="lineno"> 223</span> </div><div class="line"><a name="l00228"></a><span class="lineno"> 228</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Disconnect();</div><div class="line"><a name="l00229"></a><span class="lineno"> 229</span> </div><div class="line"><a name="l00255"></a><span class="lineno"> 255</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Fetch(<span class="keywordtype">int</span> num_object_ids, <span class="k eyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>* object_ids);</div><div class="line"><a name="l00256"></a><span class="lineno"> 256</span> </div><div class="line"><a name="l00288"></a><span class="lineno"> 288</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Wait(int64_t num_object_requests, <a class="code" href="structplasma_1_1_object_request.html">ObjectRequest</a>* object_requests,</div><div class="line"><a name="l00289"></a><span class="lineno"> 289</span>  <span class="keywordtype">int</span> num_ready_objects, int64_t timeout_ms, <span class="keywordtype">int</span>* num_objects_ready);</div><div class="line"><a name="l00290"></a><span class="lineno"> 290</span> </div><div class="line"><a name="l00297"></a><span class="lineno"> 297</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Transfer(<span class="keyword">const</span> <span class="keywordtype">cha r</span>* addr, <span class="keywordtype">int</span> port, <span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id);</div><div class="line"><a name="l00298"></a><span class="lineno"> 298</span> </div><div class="line"><a name="l00315"></a><span class="lineno"> 315</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Info(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id, <span class="keywordtype">int</span>* <a class="code" href="namespaceplasma.html#ab0498a778ef73ba70e2865dd2d4e9c8e">object_status</a>);</div><div class="line"><a name="l00316"></a><span class="lineno"> 316</span> </div><div class="line"><a name="l00321"></a><span class="lineno"> 321</span>  <span class="keywordtype">int</span> get_manager_fd() <span class="keyword">const</span>;</div><div class="line"><a name="l00322"></a><span class="lineno"> 32 2</span> </div><div class="line"><a name="l00323"></a><span class="lineno"> 323</span>  <span class="keyword">private</span>:</div><div class="line"><a name="l00328"></a><span class="lineno"> 328</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> UnmapObject(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id);</div><div class="line"><a name="l00329"></a><span class="lineno"> 329</span> </div><div class="line"><a name="l00332"></a><span class="lineno"> 332</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> FlushReleaseHistory();</div><div class="line"><a name="l00333"></a><span class="lineno"> 333</span> </div><div class="line"><a name="l00334"></a><span class="lineno"> 334</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> PerformRelease(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d. html">ObjectID</a>& object_id);</div><div class="line"><a name="l00335"></a><span class="lineno"> 335</span> </div><div class="line"><a name="l00336"></a><span class="lineno"> 336</span>  uint8_t* lookup_or_mmap(<span class="keywordtype">int</span> fd, <span class="keywordtype">int</span> store_fd_val, int64_t map_size);</div><div class="line"><a name="l00337"></a><span class="lineno"> 337</span> </div><div class="line"><a name="l00338"></a><span class="lineno"> 338</span>  uint8_t* lookup_mmapped_file(<span class="keywordtype">int</span> store_fd_val);</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>  <span class="keywordtype">void</span> increment_object_count(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id, <a class="code" href="structplasma_1_1_plasma_object.html" >PlasmaObject</a>* <span class="keywordtype">object</span>,</div><div >class="line"><a name="l00341"></a><span class="lineno"> 341</span>  > <span class="keywordtype">bool</span> >is_sealed);</div><div class="line"><a name="l00342"></a><span class="lineno"> > 342</span> </div><div class="line"><a name="l00344"></a><span >class="lineno"> 344</span>  <span class="keywordtype">int</span> >store_conn_;</div><div class="line"><a name="l00346"></a><span >class="lineno"> 346</span>  <span class="keywordtype">int</span> >manager_conn_;</div><div class="line"><a name="l00350"></a><span >class="lineno"> 350</span>  std::unordered_map<int, >ClientMmapTableEntry> mmap_table_;</div><div class="line"><a >name="l00353"></a><span class="lineno"> 353</span>  >std::unordered_map<ObjectID, std::unique_ptr<ObjectInUseEntry>, <a >class="code" >href="structplasma_1_1_unique_i_d_hasher.html">UniqueIDHasher</a>></div><div > class="line">< a name="l00354"></a><span class="lineno"> 354</span>  objects_in_use_;</div><div class="line"><a name="l00360"></a><span class="lineno"> 360</span>  std::deque<ObjectID> release_history_;</div><div class="line"><a name="l00364"></a><span class="lineno"> 364</span>  int64_t in_use_object_bytes_;</div><div class="line"><a name="l00366"></a><span class="lineno"> 366</span>  <a class="code" href="structplasma_1_1_plasma_client_config.html">PlasmaClientConfig</a> config_;</div><div class="line"><a name="l00370"></a><span class="lineno"> 370</span>  int64_t store_capacity_;</div><div class="line"><a name="l00371"></a><span class="lineno"> 371</span> };</div><div class="line"><a name="l00372"></a><span class="lineno"> 372</span> </div><div class="line"><a name="l00373"></a><span class="lineno"> 373</span> } <span class="comment">// namespace plasma</span></div><div class="line"><a name="l00374"></a><span class="lineno"> 374</ span> </div><div class="line"><a name="l00375"></a><span class="lineno"> 375</span> <span class="preprocessor">#endif // PLASMA_CLIENT_H</span></div><div class="ttc" id="structplasma_1_1_object_buffer_html"><div class="ttname"><a href="structplasma_1_1_object_buffer.html">plasma::ObjectBuffer</a></div><div class="ttdoc">Object buffer data structure. </div><div class="ttdef"><b>Definition:</b> client.h:45</div></div> -<div class="ttc" id="structplasma_1_1_client_mmap_table_entry_html"><div class="ttname"><a href="structplasma_1_1_client_mmap_table_entry.html">plasma::ClientMmapTableEntry</a></div><div class="ttdef"><b>Definition:</b> client.h:66</div></div> +<a href="client_8h.html">Go to the documentation of this file.</a><div class="fragment"><div class="line"><a name="l00001"></a><span class="lineno"> 1</span> <span class="comment">// Licensed to the Apache Software Foundation (ASF) under one</span></div><div class="line"><a name="l00002"></a><span class="lineno"> 2</span> <span class="comment">// or more contributor license agreements. See the NOTICE file</span></div><div class="line"><a name="l00003"></a><span class="lineno"> 3</span> <span class="comment">// distributed with this work for additional information</span></div><div class="line"><a name="l00004"></a><span class="lineno"> 4</span> <span class="comment">// regarding copyright ownership. The ASF licenses this file</span></div><div class="line"><a name="l00005"></a><span class="lineno"> 5</span> <span class="comment">// to you under the Apache License, Version 2.0 (the</span></div><div class="line"><a name="l00006"></a><span class= "lineno"> 6</span> <span class="comment">// "License"); you may not use this file except in compliance</span></div><div class="line"><a name="l00007"></a><span class="lineno"> 7</span> <span class="comment">// with the License. You may obtain a copy of the License at</span></div><div class="line"><a name="l00008"></a><span class="lineno"> 8</span> <span class="comment">//</span></div><div class="line"><a name="l00009"></a><span class="lineno"> 9</span> <span class="comment">// http://www.apache.org/licenses/LICENSE-2.0</span></div><div class="line"><a name="l00010"></a><span class="lineno"> 10</span> <span class="comment">//</span></div><div class="line"><a name="l00011"></a><span class="lineno"> 11</span> <span class="comment">// Unless required by applicable law or agreed to in writing,</span></div><div class="line"><a name="l00012"></a><span class="lineno"> 12</span> <span class="comment">// software distributed un der the License is distributed on an</span></div><div class="line"><a name="l00013"></a><span class="lineno"> 13</span> <span class="comment">// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY</span></div><div class="line"><a name="l00014"></a><span class="lineno"> 14</span> <span class="comment">// KIND, either express or implied. See the License for the</span></div><div class="line"><a name="l00015"></a><span class="lineno"> 15</span> <span class="comment">// specific language governing permissions and limitations</span></div><div class="line"><a name="l00016"></a><span class="lineno"> 16</span> <span class="comment">// under the License.</span></div><div class="line"><a name="l00017"></a><span class="lineno"> 17</span> </div><div class="line"><a name="l00018"></a><span class="lineno"> 18</span> <span class="preprocessor">#ifndef PLASMA_CLIENT_H</span></div><div class="line"><a name="l00019"></a><span class="lineno"> 19 </span> <span class="preprocessor">#define PLASMA_CLIENT_H</span></div><div class="line"><a name="l00020"></a><span class="lineno"> 20</span> </div><div class="line"><a name="l00021"></a><span class="lineno"> 21</span> <span class="preprocessor">#include <stdbool.h></span></div><div class="line"><a name="l00022"></a><span class="lineno"> 22</span> <span class="preprocessor">#include <time.h></span></div><div class="line"><a name="l00023"></a><span class="lineno"> 23</span> </div><div class="line"><a name="l00024"></a><span class="lineno"> 24</span> <span class="preprocessor">#include <deque></span></div><div class="line"><a name="l00025"></a><span class="lineno"> 25</span> <span class="preprocessor">#include <memory></span></div><div class="line"><a name="l00026"></a><span class="lineno"> 26</span> <span class="preprocessor">#include <string></span></div><div class="line"><a name="l00027"></a><span c lass="lineno"> 27</span> <span class="preprocessor">#include <unordered_map></span></div><div class="line"><a name="l00028"></a><span class="lineno"> 28</span> </div><div class="line"><a name="l00029"></a><span class="lineno"> 29</span> <span class="preprocessor">#include "<a class="code" href="buffer_8h.html">arrow/buffer.h</a>"</span></div><div class="line"><a name="l00030"></a><span class="lineno"> 30</span> <span class="preprocessor">#include "<a class="code" href="status_8h.html">arrow/status.h</a>"</span></div><div class="line"><a name="l00031"></a><span class="lineno"> 31</span> <span class="preprocessor">#include "<a class="code" href="visibility_8h.html">arrow/util/visibility.h</a>"</span></div><div class="line"><a name="l00032"></a><span class="lineno"> 32</span> <span class="preprocessor">#include "<a class="code" href="plasma_2common_8h.html">plasma/common.h</a>"</span></div><div clas s="line"><a name="l00033"></a><span class="lineno"> 33</span> <span class="preprocessor">#ifdef PLASMA_GPU</span></div><div class="line"><a name="l00034"></a><span class="lineno"> 34</span> <span class="preprocessor">#include "<a class="code" href="cuda__api_8h.html">arrow/gpu/cuda_api.h</a>"</span></div><div class="line"><a name="l00035"></a><span class="lineno"> 35</span> <span class="preprocessor">#endif</span></div><div class="line"><a name="l00036"></a><span class="lineno"> 36</span> </div><div class="line"><a name="l00037"></a><span class="lineno"> 37</span> <span class="keyword">using</span> <a class="code" href="classarrow_1_1_buffer.html">arrow::Buffer</a>;</div><div class="line"><a name="l00038"></a><span class="lineno"> 38</span> <span class="keyword">using</span> <a class="code" href="classarrow_1_1_status.html">arrow::Status</a>;</div><div class="line"><a name="l00039"></a><span class="lineno"> 39</span> </div>< div class="line"><a name="l00040"></a><span class="lineno"><a class="line" href="namespaceplasma.html"> 40</a></span> <span class="keyword">namespace </span><a class="code" href="namespaceplasma.html">plasma</a> {</div><div class="line"><a name="l00041"></a><span class="lineno"> 41</span> </div><div class="line"><a name="l00042"></a><span class="lineno"><a class="line" href="client_8h.html#ac6a4959f813315451e993a3dfe28cac7"> 42</a></span> <span class="preprocessor">#define PLASMA_DEFAULT_RELEASE_DELAY 64</span></div><div class="line"><a name="l00043"></a><span class="lineno"> 43</span> </div><div class="line"><a name="l00044"></a><span class="lineno"> 44</span> <span class="comment">// Use 100MB as an overestimate of the L3 cache size.</span></div><div class="line"><a name="l00045"></a><span class="lineno"><a class="line" href="namespaceplasma.html#a86d1708e5e2f6438439db3f0c6e9309b"> 45</a></span> constexpr int64_t <a class="code" href="name spaceplasma.html#a86d1708e5e2f6438439db3f0c6e9309b">kL3CacheSizeBytes</a> = 100000000;</div><div class="line"><a name="l00046"></a><span class="lineno"> 46</span> </div><div class="line"><a name="l00048"></a><span class="lineno"><a class="line" href="structplasma_1_1_object_buffer.html"> 48</a></span> <span class="keyword">struct </span><a class="code" href="structplasma_1_1_object_buffer.html">ObjectBuffer</a> {</div><div class="line"><a name="l00050"></a><span class="lineno"><a class="line" href="structplasma_1_1_object_buffer.html#ace0c6be03d13cc503d665fe976557558"> 50</a></span>  std::shared_ptr<Buffer> <a class="code" href="structplasma_1_1_object_buffer.html#ace0c6be03d13cc503d665fe976557558">data</a>;</div><div class="line"><a name="l00052"></a><span class="lineno"><a class="line" href="structplasma_1_1_object_buffer.html#a7f517c4d5049a45fd91056288fd9d572"> 52</a></span>  int64_t <a class="code" href="structplasma_1_1_object_buffer.html#a7f 517c4d5049a45fd91056288fd9d572">data_size</a>;</div><div class="line"><a name="l00054"></a><span class="lineno"><a class="line" href="structplasma_1_1_object_buffer.html#aa02e9306fe2ccd501d2b2d8a0c69a39b"> 54</a></span>  std::shared_ptr<Buffer> <a class="code" href="structplasma_1_1_object_buffer.html#aa02e9306fe2ccd501d2b2d8a0c69a39b">metadata</a>;</div><div class="line"><a name="l00056"></a><span class="lineno"><a class="line" href="structplasma_1_1_object_buffer.html#a4abaffd262b9ebd5fc6721fd55cc59b3"> 56</a></span>  int64_t <a class="code" href="structplasma_1_1_object_buffer.html#a4abaffd262b9ebd5fc6721fd55cc59b3">metadata_size</a>;</div><div class="line"><a name="l00058"></a><span class="lineno"><a class="line" href="structplasma_1_1_object_buffer.html#aea3d531aaf1cce269e6d8227c597d139"> 58</a></span>  <span class="keywordtype">int</span> <a class="code" href="structplasma_1_1_object_buffer.html#aea3d531aaf1cce269e6d8227c597d139">device_num</a>;</ div><div class="line"><a name="l00059"></a><span class="lineno"> 59</span> };</div><div class="line"><a name="l00060"></a><span class="lineno"> 60</span> </div><div class="line"><a name="l00062"></a><span class="lineno"><a class="line" href="structplasma_1_1_plasma_client_config.html"> 62</a></span> <span class="keyword">struct </span><a class="code" href="structplasma_1_1_plasma_client_config.html">PlasmaClientConfig</a> {</div><div class="line"><a name="l00066"></a><span class="lineno"><a class="line" href="structplasma_1_1_plasma_client_config.html#ad14b9fc059c1c72f8fec04619dc75582"> 66</a></span>  <span class="keywordtype">size_t</span> <a class="code" href="structplasma_1_1_plasma_client_config.html#ad14b9fc059c1c72f8fec04619dc75582">release_delay</a>;</div><div class="line"><a name="l00067"></a><span class="lineno"> 67</span> };</div><div class="line"><a name="l00068"></a><span class="lineno"> 68</span> </div><div class="line"><a name ="l00069"></a><span class="lineno"><a class="line" href="structplasma_1_1_client_mmap_table_entry.html"> 69</a></span> <span class="keyword">struct </span><a class="code" href="structplasma_1_1_client_mmap_table_entry.html">ClientMmapTableEntry</a> {</div><div class="line"><a name="l00071"></a><span class="lineno"><a class="line" href="structplasma_1_1_client_mmap_table_entry.html#a2b6f7159ad5ce1a60633648def026acf"> 71</a></span>  uint8_t* <a class="code" href="structplasma_1_1_client_mmap_table_entry.html#a2b6f7159ad5ce1a60633648def026acf">pointer</a>;</div><div class="line"><a name="l00073"></a><span class="lineno"><a class="line" href="structplasma_1_1_client_mmap_table_entry.html#a8004bc973d7f722332f83bb0d7992de6"> 73</a></span>  <span class="keywordtype">size_t</span> <a class="code" href="structplasma_1_1_client_mmap_table_entry.html#a8004bc973d7f722332f83bb0d7992de6">length</a>;</div><div class="line"><a name="l00076"></a><span class="lineno"><a class=" line" href="structplasma_1_1_client_mmap_table_entry.html#a8cb00d743be149ddf58091a077561934"> 76</a></span>  <span class="keywordtype">int</span> <a class="code" href="structplasma_1_1_client_mmap_table_entry.html#a8cb00d743be149ddf58091a077561934">count</a>;</div><div class="line"><a name="l00077"></a><span class="lineno"> 77</span> };</div><div class="line"><a name="l00078"></a><span class="lineno"> 78</span> </div><div class="line"><a name="l00079"></a><span class="lineno"> 79</span> <span class="keyword">struct </span>ObjectInUseEntry;</div><div class="line"><a name="l00080"></a><span class="lineno"> 80</span> <span class="keyword">struct </span><a class="code" href="structplasma_1_1_object_request.html">ObjectRequest</a>;</div><div class="line"><a name="l00081"></a><span class="lineno"> 81</span> <span class="keyword">struct </span><a class="code" href="structplasma_1_1_plasma_object.html">PlasmaObject</a>;</div><div class="line"><a na me="l00082"></a><span class="lineno"> 82</span> </div><div class="line"><a name="l00083"></a><span class="lineno"><a class="line" href="classplasma_1_1_plasma_client.html"> 83</a></span> <span class="keyword">class </span>ARROW_EXPORT <a class="code" href="classplasma_1_1_plasma_client.html">PlasmaClient</a> {</div><div class="line"><a name="l00084"></a><span class="lineno"> 84</span>  <span class="keyword">public</span>:</div><div class="line"><a name="l00085"></a><span class="lineno"> 85</span>  <a class="code" href="classplasma_1_1_plasma_client.html">PlasmaClient</a>();</div><div class="line"><a name="l00086"></a><span class="lineno"> 86</span> </div><div class="line"><a name="l00087"></a><span class="lineno"> 87</span>  ~<a class="code" href="classplasma_1_1_plasma_client.html">PlasmaClient</a>();</div><div class="line"><a name="l00088"></a><span class="lineno"> 88</span> </div><div class="line"><a name="l00101"></a><span class ="lineno"> 101</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Connect(<span class="keyword">const</span> std::string& store_socket_name,</div><div class="line"><a name="l00102"></a><span class="lineno"> 102</span>  <span class="keyword">const</span> std::string& manager_socket_name, <span class="keywordtype">int</span> release_delay,</div><div class="line"><a name="l00103"></a><span class="lineno"> 103</span>  <span class="keywordtype">int</span> num_retries = -1);</div><div class="line"><a name="l00104"></a><span class="lineno"> 104</span> </div><div class="line"><a name="l00124"></a><span class="lineno"> 124</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Create(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id, int64_t data_size, uint8_t* metadata,</div><div class="line"><a name="l00125"></a><span cl ass="lineno"> 125</span>  int64_t metadata_size, std::shared_ptr<Buffer>* data, <span class="keywordtype">int</span> device_num = 0);</div><div class="line"><a name="l00141"></a><span class="lineno"> 141</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Get(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>* object_ids, int64_t num_objects, int64_t timeout_ms,</div><div class="line"><a name="l00142"></a><span class="lineno"> 142</span>  <a class="code" href="structplasma_1_1_object_buffer.html">ObjectBuffer</a>* object_buffers);</div><div class="line"><a name="l00143"></a><span class="lineno"> 143</span> </div><div class="line"><a name="l00152"></a><span class="lineno"> 152</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Release(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a >& object_id);</div><div class="line"><a name="l00153"></a><span >class="lineno"> 153</span> </div><div class="line"><a >name="l00164"></a><span class="lineno"> 164</span>  <a class="code" >href="classarrow_1_1_status.html">Status</a> Contains(<span >class="keyword">const</span> <a class="code" >href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id, <span >class="keywordtype">bool</span>* has_object);</div><div class="line"><a >name="l00165"></a><span class="lineno"> 165</span> </div><div >class="line"><a name="l00173"></a><span class="lineno"> 173</span>  <a >class="code" href="classarrow_1_1_status.html">Status</a> Abort(<span >class="keyword">const</span> <a class="code" >href="classplasma_1_1_unique_i_d.html">ObjectID</a>& >object_id);</div><div class="line"><a name="l00174"></a><span class="lineno"> > 174</span> </div><div class="line"><a name="l00181"></a><span >class="lineno"> 181</span>  <a class="code" href="classarrow_1_1_status .html">Status</a> Seal(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id);</div><div class="line"><a name="l00182"></a><span class="lineno"> 182</span> </div><div class="line"><a name="l00192"></a><span class="lineno"> 192</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Delete(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id);</div><div class="line"><a name="l00193"></a><span class="lineno"> 193</span> </div><div class="line"><a name="l00201"></a><span class="lineno"> 201</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Evict(int64_t num_bytes, int64_t& num_bytes_evicted);</div><div class="line"><a name="l00202"></a><span class="lineno"> 202</span> </div><div class="line"><a name="l00209"></a><span class="lineno"> 209</span>  <a class="code" href="classarrow_1_1_sta tus.html">Status</a> Hash(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id, uint8_t* digest);</div><div class="line"><a name="l00210"></a><span class="lineno"> 210</span> </div><div class="line"><a name="l00219"></a><span class="lineno"> 219</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Subscribe(<span class="keywordtype">int</span>* fd);</div><div class="line"><a name="l00220"></a><span class="lineno"> 220</span> </div><div class="line"><a name="l00228"></a><span class="lineno"> 228</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> GetNotification(<span class="keywordtype">int</span> fd, <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>* object_id, int64_t* data_size,</div><div class="line"><a name="l00229"></a><span class="lineno"> 229</span>  int64_t* metadata_size);</div><div class="line"><a name= "l00230"></a><span class="lineno"> 230</span> </div><div class="line"><a name="l00235"></a><span class="lineno"> 235</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Disconnect();</div><div class="line"><a name="l00236"></a><span class="lineno"> 236</span> </div><div class="line"><a name="l00262"></a><span class="lineno"> 262</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Fetch(<span class="keywordtype">int</span> num_object_ids, <span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>* object_ids);</div><div class="line"><a name="l00263"></a><span class="lineno"> 263</span> </div><div class="line"><a name="l00295"></a><span class="lineno"> 295</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Wait(int64_t num_object_requests, <a class="code" href="structplasma_1_1_object_request.html">ObjectRequest</a>* object_requests,</div><div class="l ine"><a name="l00296"></a><span class="lineno"> 296</span>  <span class="keywordtype">int</span> num_ready_objects, int64_t timeout_ms, <span class="keywordtype">int</span>* num_objects_ready);</div><div class="line"><a name="l00297"></a><span class="lineno"> 297</span> </div><div class="line"><a name="l00304"></a><span class="lineno"> 304</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Transfer(<span class="keyword">const</span> <span class="keywordtype">char</span>* addr, <span class="keywordtype">int</span> port, <span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id);</div><div class="line"><a name="l00305"></a><span class="lineno"> 305</span> </div><div class="line"><a name="l00322"></a><span class="lineno"> 322</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> Info(<span class="keyword">const</span> <a class="code" href="classplasm a_1_1_unique_i_d.html">ObjectID</a>& object_id, <span class="keywordtype">int</span>* <a class="code" href="namespaceplasma.html#ab0498a778ef73ba70e2865dd2d4e9c8e">object_status</a>);</div><div class="line"><a name="l00323"></a><span class="lineno"> 323</span> </div><div class="line"><a name="l00328"></a><span class="lineno"> 328</span>  <span class="keywordtype">int</span> get_manager_fd() <span class="keyword">const</span>;</div><div class="line"><a name="l00329"></a><span class="lineno"> 329</span> </div><div class="line"><a name="l00330"></a><span class="lineno"> 330</span>  <span class="keyword">private</span>:</div><div class="line"><a name="l00335"></a><span class="lineno"> 335</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> UnmapObject(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id);</div><div class="line"><a name="l00336"></a><span class="lineno"> 336</span> </div><div class="line"><a name="l00339"></a><span class="lineno"> 339</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> FlushReleaseHistory();</div><div class="line"><a name="l00340"></a><span class="lineno"> 340</span> </div><div class="line"><a name="l00341"></a><span class="lineno"> 341</span>  <a class="code" href="classarrow_1_1_status.html">Status</a> PerformRelease(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id);</div><div class="line"><a name="l00342"></a><span class="lineno"> 342</span> </div><div class="line"><a name="l00343"></a><span class="lineno"> 343</span>  uint8_t* lookup_or_mmap(<span class="keywordtype">int</span> fd, <span class="keywordtype">int</span> store_fd_val, int64_t map_size);</div><div class="line"><a name="l00344"></a><span class="lineno"> 344</span> </div><div class="line"><a name="l00345"></a><span class=" lineno"> 345</span>  uint8_t* lookup_mmapped_file(<span class="keywordtype">int</span> store_fd_val);</div><div class="line"><a name="l00346"></a><span class="lineno"> 346</span> </div><div class="line"><a name="l00347"></a><span class="lineno"> 347</span>  <span class="keywordtype">void</span> increment_object_count(<span class="keyword">const</span> <a class="code" href="classplasma_1_1_unique_i_d.html">ObjectID</a>& object_id, <a class="code" href="structplasma_1_1_plasma_object.html">PlasmaObject</a>* <span class="keywordtype">object</span>,</div><div class="line"><a name="l00348"></a><span class="lineno"> 348</span>  <span class="keywordtype">bool</span> is_sealed);</div><div class="line"><a name="l00349"></a><span class="lineno"> 349</span> </div><div class="line"><a name="l00351"></a><span class="lineno"> 351</span>  <span class="keywordtype">int</span> store_conn_;</div><div class="line"><a name="l00353" ></a><span class="lineno"> 353</span>  <span >class="keywordtype">int</span> manager_conn_;</div><div class="line"><a >name="l00357"></a><span class="lineno"> 357</span>  >std::unordered_map<int, ClientMmapTableEntry> mmap_table_;</div><div >class="line"><a name="l00360"></a><span class="lineno"> 360</span>  >std::unordered_map<ObjectID, std::unique_ptr<ObjectInUseEntry>, <a >class="code" >href="structplasma_1_1_unique_i_d_hasher.html">UniqueIDHasher</a>></div><div > class="line"><a name="l00361"></a><span class="lineno"> 361</span>  > objects_in_use_;</div><div class="line"><a name="l00367"></a><span >class="lineno"> 367</span>  std::deque<ObjectID> >release_history_;</div><div class="line"><a name="l00371"></a><span >class="lineno"> 371</span>  int64_t in_use_object_bytes_;</div><div >class="line"><a name="l00373"></a><span class="lineno"> 373</span>  <a >class="code" href="structplasma_1_1_plasma_client_config.html">Pla smaClientConfig</a> config_;</div><div class="line"><a name="l00377"></a><span class="lineno"> 377</span>  int64_t store_capacity_;</div><div class="line"><a name="l00378"></a><span class="lineno"> 378</span> <span class="preprocessor">#ifdef PLASMA_GPU</span></div><div class="line"><a name="l00379"></a><span class="lineno"> 379</span>  <a class="code" href="classarrow_1_1gpu_1_1_cuda_device_manager.html">arrow::gpu::CudaDeviceManager</a>* manager_;</div><div class="line"><a name="l00381"></a><span class="lineno"> 381</span> <span class="preprocessor">#endif</span></div><div class="line"><a name="l00382"></a><span class="lineno"> 382</span> };</div><div class="line"><a name="l00383"></a><span class="lineno"> 383</span> </div><div class="line"><a name="l00384"></a><span class="lineno"> 384</span> } <span class="comment">// namespace plasma</span></div><div class="line"><a name="l00385"></a><span class="lineno"> 385</span> </div><div class="line"><a name="l00386"></a><span class="lineno"> 386</span> <span class="preprocessor">#endif // PLASMA_CLIENT_H</span></div><div class="ttc" id="structplasma_1_1_object_buffer_html"><div class="ttname"><a href="structplasma_1_1_object_buffer.html">plasma::ObjectBuffer</a></div><div class="ttdoc">Object buffer data structure. </div><div class="ttdef"><b>Definition:</b> client.h:48</div></div> +<div class="ttc" id="structplasma_1_1_client_mmap_table_entry_html"><div class="ttname"><a href="structplasma_1_1_client_mmap_table_entry.html">plasma::ClientMmapTableEntry</a></div><div class="ttdef"><b>Definition:</b> client.h:69</div></div> <div class="ttc" id="structplasma_1_1_object_request_html"><div class="ttname"><a href="structplasma_1_1_object_request.html">plasma::ObjectRequest</a></div><div class="ttdoc">Object request data structure. Used for Wait. </div><div class="ttdef"><b>Definition:</b> common.h:71</div></div> <div class="ttc" id="classplasma_1_1_unique_i_d_html"><div class="ttname"><a href="classplasma_1_1_unique_i_d.html">plasma::UniqueID</a></div><div class="ttdef"><b>Definition:</b> common.h:38</div></div> <div class="ttc" id="classarrow_1_1_status_html"><div class="ttname"><a href="classarrow_1_1_status.html">arrow::Status</a></div><div class="ttdef"><b>Definition:</b> status.h:106</div></div> -<div class="ttc" id="structplasma_1_1_object_buffer_html_a4abaffd262b9ebd5fc6721fd55cc59b3"><div class="ttname"><a href="structplasma_1_1_object_buffer.html#a4abaffd262b9ebd5fc6721fd55cc59b3">plasma::ObjectBuffer::metadata_size</a></div><div class="ttdeci">int64_t metadata_size</div><div class="ttdoc">The metadata size in bytes. </div><div class="ttdef"><b>Definition:</b> client.h:53</div></div> -<div class="ttc" id="structplasma_1_1_plasma_object_html"><div class="ttname"><a href="structplasma_1_1_plasma_object.html">plasma::PlasmaObject</a></div><div class="ttdef"><b>Definition:</b> plasma.h:78</div></div> -<div class="ttc" id="structplasma_1_1_object_buffer_html_aea3d531aaf1cce269e6d8227c597d139"><div class="ttname"><a href="structplasma_1_1_object_buffer.html#aea3d531aaf1cce269e6d8227c597d139">plasma::ObjectBuffer::device_num</a></div><div class="ttdeci">int device_num</div><div class="ttdoc">The device number. </div><div class="ttdef"><b>Definition:</b> client.h:55</div></div> -<div class="ttc" id="structplasma_1_1_object_buffer_html_ace0c6be03d13cc503d665fe976557558"><div class="ttname"><a href="structplasma_1_1_object_buffer.html#ace0c6be03d13cc503d665fe976557558">plasma::ObjectBuffer::data</a></div><div class="ttdeci">std::shared_ptr< Buffer > data</div><div class="ttdoc">The data buffer. </div><div class="ttdef"><b>Definition:</b> client.h:47</div></div> -<div class="ttc" id="structplasma_1_1_plasma_client_config_html"><div class="ttname"><a href="structplasma_1_1_plasma_client_config.html">plasma::PlasmaClientConfig</a></div><div class="ttdoc">Configuration options for the plasma client. </div><div class="ttdef"><b>Definition:</b> client.h:59</div></div> +<div class="ttc" id="structplasma_1_1_object_buffer_html_a4abaffd262b9ebd5fc6721fd55cc59b3"><div class="ttname"><a href="structplasma_1_1_object_buffer.html#a4abaffd262b9ebd5fc6721fd55cc59b3">plasma::ObjectBuffer::metadata_size</a></div><div class="ttdeci">int64_t metadata_size</div><div class="ttdoc">The metadata size in bytes. </div><div class="ttdef"><b>Definition:</b> client.h:56</div></div> +<div class="ttc" id="classarrow_1_1gpu_1_1_cuda_device_manager_html"><div class="ttname"><a href="classarrow_1_1gpu_1_1_cuda_device_manager.html">arrow::gpu::CudaDeviceManager</a></div><div class="ttdef"><b>Definition:</b> cuda_context.h:35</div></div> +<div class="ttc" id="structplasma_1_1_plasma_object_html"><div class="ttname"><a href="structplasma_1_1_plasma_object.html">plasma::PlasmaObject</a></div><div class="ttdef"><b>Definition:</b> plasma.h:76</div></div> +<div class="ttc" id="structplasma_1_1_object_buffer_html_aea3d531aaf1cce269e6d8227c597d139"><div class="ttname"><a href="structplasma_1_1_object_buffer.html#aea3d531aaf1cce269e6d8227c597d139">plasma::ObjectBuffer::device_num</a></div><div class="ttdeci">int device_num</div><div class="ttdoc">The device number. </div><div class="ttdef"><b>Definition:</b> client.h:58</div></div> +<div class="ttc" id="structplasma_1_1_object_buffer_html_ace0c6be03d13cc503d665fe976557558"><div class="ttname"><a href="structplasma_1_1_object_buffer.html#ace0c6be03d13cc503d665fe976557558">plasma::ObjectBuffer::data</a></div><div class="ttdeci">std::shared_ptr< Buffer > data</div><div class="ttdoc">The data buffer. </div><div class="ttdef"><b>Definition:</b> client.h:50</div></div> +<div class="ttc" id="structplasma_1_1_plasma_client_config_html"><div class="ttname"><a href="structplasma_1_1_plasma_client_config.html">plasma::PlasmaClientConfig</a></div><div class="ttdoc">Configuration options for the plasma client. </div><div class="ttdef"><b>Definition:</b> client.h:62</div></div> <div class="ttc" id="plasma_2common_8h_html"><div class="ttname"><a href="plasma_2common_8h.html">common.h</a></div></div> -<div class="ttc" id="structplasma_1_1_client_mmap_table_entry_html_a2b6f7159ad5ce1a60633648def026acf"><div class="ttname"><a href="structplasma_1_1_client_mmap_table_entry.html#a2b6f7159ad5ce1a60633648def026acf">plasma::ClientMmapTableEntry::pointer</a></div><div class="ttdeci">uint8_t * pointer</div><div class="ttdoc">The result of mmap for this file descriptor. </div><div class="ttdef"><b>Definition:</b> client.h:68</div></div> +<div class="ttc" id="structplasma_1_1_client_mmap_table_entry_html_a2b6f7159ad5ce1a60633648def026acf"><div class="ttname"><a href="structplasma_1_1_client_mmap_table_entry.html#a2b6f7159ad5ce1a60633648def026acf">plasma::ClientMmapTableEntry::pointer</a></div><div class="ttdeci">uint8_t * pointer</div><div class="ttdoc">The result of mmap for this file descriptor. </div><div class="ttdef"><b>Definition:</b> client.h:71</div></div> <div class="ttc" id="visibility_8h_html"><div class="ttname"><a href="visibility_8h.html">visibility.h</a></div></div> -<div class="ttc" id="structplasma_1_1_client_mmap_table_entry_html_a8004bc973d7f722332f83bb0d7992de6"><div class="ttname"><a href="structplasma_1_1_client_mmap_table_entry.html#a8004bc973d7f722332f83bb0d7992de6">plasma::ClientMmapTableEntry::length</a></div><div class="ttdeci">size_t length</div><div class="ttdoc">The length of the memory-mapped file. </div><div class="ttdef"><b>Definition:</b> client.h:70</div></div> -<div class="ttc" id="structplasma_1_1_object_buffer_html_aa02e9306fe2ccd501d2b2d8a0c69a39b"><div class="ttname"><a href="structplasma_1_1_object_buffer.html#aa02e9306fe2ccd501d2b2d8a0c69a39b">plasma::ObjectBuffer::metadata</a></div><div class="ttdeci">std::shared_ptr< Buffer > metadata</div><div class="ttdoc">The metadata buffer. </div><div class="ttdef"><b>Definition:</b> client.h:51</div></div> -<div class="ttc" id="namespaceplasma_html"><div class="ttname"><a href="namespaceplasma.html">plasma</a></div><div class="ttdef"><b>Definition:</b> client.h:37</div></div> +<div class="ttc" id="structplasma_1_1_client_mmap_table_entry_html_a8004bc973d7f722332f83bb0d7992de6"><div class="ttname"><a href="structplasma_1_1_client_mmap_table_entry.html#a8004bc973d7f722332f83bb0d7992de6">plasma::ClientMmapTableEntry::length</a></div><div class="ttdeci">size_t length</div><div class="ttdoc">The length of the memory-mapped file. </div><div class="ttdef"><b>Definition:</b> client.h:73</div></div> +<div class="ttc" id="structplasma_1_1_object_buffer_html_aa02e9306fe2ccd501d2b2d8a0c69a39b"><div class="ttname"><a href="structplasma_1_1_object_buffer.html#aa02e9306fe2ccd501d2b2d8a0c69a39b">plasma::ObjectBuffer::metadata</a></div><div class="ttdeci">std::shared_ptr< Buffer > metadata</div><div class="ttdoc">The metadata buffer. </div><div class="ttdef"><b>Definition:</b> client.h:54</div></div> +<div class="ttc" id="namespaceplasma_html"><div class="ttname"><a href="namespaceplasma.html">plasma</a></div><div class="ttdef"><b>Definition:</b> client.h:40</div></div> <div class="ttc" id="structplasma_1_1_unique_i_d_hasher_html"><div class="ttname"><a href="structplasma_1_1_unique_i_d_hasher.html">plasma::UniqueIDHasher</a></div><div class="ttdef"><b>Definition:</b> common.h:54</div></div> <div class="ttc" id="status_8h_html"><div class="ttname"><a href="status_8h.html">status.h</a></div></div> <div class="ttc" id="buffer_8h_html"><div class="ttname"><a href="buffer_8h.html">buffer.h</a></div></div> -<div class="ttc" id="structplasma_1_1_object_buffer_html_a7f517c4d5049a45fd91056288fd9d572"><div class="ttname"><a href="structplasma_1_1_object_buffer.html#a7f517c4d5049a45fd91056288fd9d572">plasma::ObjectBuffer::data_size</a></div><div class="ttdeci">int64_t data_size</div><div class="ttdoc">The size in bytes of the data object. </div><div class="ttdef"><b>Definition:</b> client.h:49</div></div> -<div class="ttc" id="namespaceplasma_html_ab0498a778ef73ba70e2865dd2d4e9c8e"><div class="ttname"><a href="namespaceplasma.html#ab0498a778ef73ba70e2865dd2d4e9c8e">plasma::object_status</a></div><div class="ttdeci">object_status</div><div class="ttdef"><b>Definition:</b> plasma.h:98</div></div> -<div class="ttc" id="classarrow_1_1_buffer_html"><div class="ttname"><a href="classarrow_1_1_buffer.html">arrow::Buffer</a></div><div class="ttdoc">Immutable API for a chunk of bytes which may or may not be owned by the class instance. </div><div class="ttdef"><b>Definition:</b> buffer.h:48</div></div> -<div class="ttc" id="classplasma_1_1_plasma_client_html"><div class="ttname"><a href="classplasma_1_1_plasma_client.html">plasma::PlasmaClient</a></div><div class="ttdef"><b>Definition:</b> client.h:80</div></div> -<div class="ttc" id="structplasma_1_1_client_mmap_table_entry_html_a8cb00d743be149ddf58091a077561934"><div class="ttname"><a href="structplasma_1_1_client_mmap_table_entry.html#a8cb00d743be149ddf58091a077561934">plasma::ClientMmapTableEntry::count</a></div><div class="ttdeci">int count</div><div class="ttdoc">The number of objects in this memory-mapped file that are currently being used by the client...</div><div class="ttdef"><b>Definition:</b> client.h:73</div></div> -<div class="ttc" id="structplasma_1_1_plasma_client_config_html_ad14b9fc059c1c72f8fec04619dc75582"><div class="ttname"><a href="structplasma_1_1_plasma_client_config.html#ad14b9fc059c1c72f8fec04619dc75582">plasma::PlasmaClientConfig::release_delay</a></div><div class="ttdeci">size_t release_delay</div><div class="ttdoc">Number of release calls we wait until the object is actually released. </div><div class="ttdef"><b>Definition:</b> client.h:63</div></div> -<div class="ttc" id="namespaceplasma_html_a86d1708e5e2f6438439db3f0c6e9309b"><div class="ttname"><a href="namespaceplasma.html#a86d1708e5e2f6438439db3f0c6e9309b">plasma::kL3CacheSizeBytes</a></div><div class="ttdeci">constexpr int64_t kL3CacheSizeBytes</div><div class="ttdef"><b>Definition:</b> client.h:42</div></div> +<div class="ttc" id="structplasma_1_1_object_buffer_html_a7f517c4d5049a45fd91056288fd9d572"><div class="ttname"><a href="structplasma_1_1_object_buffer.html#a7f517c4d5049a45fd91056288fd9d572">plasma::ObjectBuffer::data_size</a></div><div class="ttdeci">int64_t data_size</div><div class="ttdoc">The size in bytes of the data object. </div><div class="ttdef"><b>Definition:</b> client.h:52</div></div> +<div class="ttc" id="namespaceplasma_html_ab0498a778ef73ba70e2865dd2d4e9c8e"><div class="ttname"><a href="namespaceplasma.html#ab0498a778ef73ba70e2865dd2d4e9c8e">plasma::object_status</a></div><div class="ttdeci">object_status</div><div class="ttdef"><b>Definition:</b> plasma.h:104</div></div> +<div class="ttc" id="cuda__api_8h_html"><div class="ttname"><a href="cuda__api_8h.html">cuda_api.h</a></div></div> +<div class="ttc" id="classarrow_1_1_buffer_html"><div class="ttname"><a href="classarrow_1_1_buffer.html">arrow::Buffer</a></div><div class="ttdoc">Object containing a pointer to a piece of contiguous memory with a particular size. </div><div class="ttdef"><b>Definition:</b> buffer.h:48</div></div> +<div class="ttc" id="classplasma_1_1_plasma_client_html"><div class="ttname"><a href="classplasma_1_1_plasma_client.html">plasma::PlasmaClient</a></div><div class="ttdef"><b>Definition:</b> client.h:83</div></div> +<div class="ttc" id="structplasma_1_1_client_mmap_table_entry_html_a8cb00d743be149ddf58091a077561934"><div class="ttname"><a href="structplasma_1_1_client_mmap_table_entry.html#a8cb00d743be149ddf58091a077561934">plasma::ClientMmapTableEntry::count</a></div><div class="ttdeci">int count</div><div class="ttdoc">The number of objects in this memory-mapped file that are currently being used by the client...</div><div class="ttdef"><b>Definition:</b> client.h:76</div></div> +<div class="ttc" id="structplasma_1_1_plasma_client_config_html_ad14b9fc059c1c72f8fec04619dc75582"><div class="ttname"><a href="structplasma_1_1_plasma_client_config.html#ad14b9fc059c1c72f8fec04619dc75582">plasma::PlasmaClientConfig::release_delay</a></div><div class="ttdeci">size_t release_delay</div><div class="ttdoc">Number of release calls we wait until the object is actually released. </div><div class="ttdef"><b>Definition:</b> client.h:66</div></div> +<div class="ttc" id="namespaceplasma_html_a86d1708e5e2f6438439db3f0c6e9309b"><div class="ttname"><a href="namespaceplasma.html#a86d1708e5e2f6438439db3f0c6e9309b">plasma::kL3CacheSizeBytes</a></div><div class="ttdeci">constexpr int64_t kL3CacheSizeBytes</div><div class="ttdef"><b>Definition:</b> client.h:45</div></div> </div><!-- fragment --></div><!-- contents --> <!-- start footer part --> <hr class="footer"/><address class="footer"><small> http://git-wip-us.apache.org/repos/asf/arrow-site/blob/4c7c2f1b/docs/cpp/compare_8h.html ---------------------------------------------------------------------- diff --git a/docs/cpp/compare_8h.html b/docs/cpp/compare_8h.html index 909446b..7fc3f1f 100644 --- a/docs/cpp/compare_8h.html +++ b/docs/cpp/compare_8h.html @@ -86,20 +86,6 @@ Namespaces</h2></td></tr> </table><table class="memberdecls"> <tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="func-members"></a> Functions</h2></td></tr> -<tr class="memitem:a8753654b0dc794946d5205aa30fa54c6"><td class="memItemLeft" align="right" valign="top">Status </td><td class="memItemRight" valign="bottom"><a class="el" href="namespacearrow.html#a8753654b0dc794946d5205aa30fa54c6">arrow::ArrayEquals</a> (const Array &left, const Array &right, bool *are_equal)</td></tr> -<tr class="memdesc:a8753654b0dc794946d5205aa30fa54c6"><td class="mdescLeft"> </td><td class="mdescRight">Returns true if the arrays are exactly equal. <a href="namespacearrow.html#a8753654b0dc794946d5205aa30fa54c6">More...</a><br /></td></tr> -<tr class="separator:a8753654b0dc794946d5205aa30fa54c6"><td class="memSeparator" colspan="2"> </td></tr> -<tr class="memitem:a94b24ab7fc29a4ccfd9035f008e6e7e9"><td class="memItemLeft" align="right" valign="top">Status </td><td class="memItemRight" valign="bottom"><a class="el" href="namespacearrow.html#a94b24ab7fc29a4ccfd9035f008e6e7e9">arrow::TensorEquals</a> (const Tensor &left, const Tensor &right, bool *are_equal)</td></tr> -<tr class="separator:a94b24ab7fc29a4ccfd9035f008e6e7e9"><td class="memSeparator" colspan="2"> </td></tr> -<tr class="memitem:aefba3083236a8c610ba6e47b1e8f077f"><td class="memItemLeft" align="right" valign="top">Status </td><td class="memItemRight" valign="bottom"><a class="el" href="namespacearrow.html#aefba3083236a8c610ba6e47b1e8f077f">arrow::ArrayApproxEquals</a> (const Array &left, const Array &right, bool *are_equal)</td></tr> -<tr class="memdesc:aefba3083236a8c610ba6e47b1e8f077f"><td class="mdescLeft"> </td><td class="mdescRight">Returns true if the arrays are approximately equal. <a href="namespacearrow.html#aefba3083236a8c610ba6e47b1e8f077f">More...</a><br /></td></tr> -<tr class="separator:aefba3083236a8c610ba6e47b1e8f077f"><td class="memSeparator" colspan="2"> </td></tr> -<tr class="memitem:a6f9150ffb3b41c37044eea962e0e0845"><td class="memItemLeft" align="right" valign="top">Status </td><td class="memItemRight" valign="bottom"><a class="el" href="namespacearrow.html#a6f9150ffb3b41c37044eea962e0e0845">arrow::ArrayRangeEquals</a> (const Array &left, const Array &right, int64_t start_idx, int64_t end_idx, int64_t other_start_idx, bool *are_equal)</td></tr> -<tr class="memdesc:a6f9150ffb3b41c37044eea962e0e0845"><td class="mdescLeft"> </td><td class="mdescRight">Returns true if indicated equal-length segment of arrays is exactly equal. <a href="namespacearrow.html#a6f9150ffb3b41c37044eea962e0e0845">More...</a><br /></td></tr> -<tr class="separator:a6f9150ffb3b41c37044eea962e0e0845"><td class="memSeparator" colspan="2"> </td></tr> -<tr class="memitem:a73533bccd4b4e0d9ddb068f2b4876ded"><td class="memItemLeft" align="right" valign="top">Status </td><td class="memItemRight" valign="bottom"><a class="el" href="namespacearrow.html#a73533bccd4b4e0d9ddb068f2b4876ded">arrow::TypeEquals</a> (const DataType &left, const DataType &right, bool *are_equal)</td></tr> -<tr class="memdesc:a73533bccd4b4e0d9ddb068f2b4876ded"><td class="mdescLeft"> </td><td class="mdescRight">Returns true if the type metadata are exactly equal. <a href="namespacearrow.html#a73533bccd4b4e0d9ddb068f2b4876ded">More...</a><br /></td></tr> -<tr class="separator:a73533bccd4b4e0d9ddb068f2b4876ded"><td class="memSeparator" colspan="2"> </td></tr> <tr class="memitem:a48cc628afeb953d5acb013f89d82b54e"><td class="memItemLeft" align="right" valign="top">bool </td><td class="memItemRight" valign="bottom"><a class="el" href="namespacearrow.html#a48cc628afeb953d5acb013f89d82b54e">arrow::ArrayEquals</a> (const Array &left, const Array &right)</td></tr> <tr class="memdesc:a48cc628afeb953d5acb013f89d82b54e"><td class="mdescLeft"> </td><td class="mdescRight">Returns true if the arrays are exactly equal. <a href="namespacearrow.html#a48cc628afeb953d5acb013f89d82b54e">More...</a><br /></td></tr> <tr class="separator:a48cc628afeb953d5acb013f89d82b54e"><td class="memSeparator" colspan="2"> </td></tr>
