Google Git
Sign in
apache / impala / asf-site / . / doc / html / classimpala_1_1DiskIoMgrStress.html
blob: ce2f4881340af9d0c07f162ce0701a67ec7949db [file] [log] [blame]
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<meta http-equiv="Content-Type" content="text/xhtml;charset=UTF-8"/>
<meta http-equiv="X-UA-Compatible" content="IE=9"/>
<meta name="generator" content="Doxygen 1.8.6"/>
<title>Impala: impala::DiskIoMgrStress Class Reference</title>
<link href="tabs.css" rel="stylesheet" type="text/css"/>
<script type="text/javascript" src="jquery.js"></script>
<script type="text/javascript" src="dynsections.js"></script>
<link href="navtree.css" rel="stylesheet" type="text/css"/>
<script type="text/javascript" src="resize.js"></script>
<script type="text/javascript" src="navtree.js"></script>
<script type="text/javascript">
$(document).ready(initResizable);
$(window).load(resizeHeight);
</script>
<link href="search/search.css" rel="stylesheet" type="text/css"/>
<script type="text/javascript" src="search/search.js"></script>
<script type="text/javascript">
$(document).ready(function() { searchBox.OnSelectItem(0); });
</script>
<link href="doxygen.css" rel="stylesheet" type="text/css" />
</head>
<body>
<div id="top"><!-- do not remove this div, it is closed by doxygen! -->
<div id="titlearea">
<table cellspacing="0" cellpadding="0">
<tbody>
<tr style="height: 56px;">
<td style="padding-left: 0.5em;">
<div id="projectname">Impala
</div>
<div id="projectbrief">Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.</div>
</td>
</tr>
</tbody>
</table>
</div>
<!-- end header part -->
<!-- Generated by Doxygen 1.8.6 -->
<script type="text/javascript">
var searchBox = new SearchBox("searchBox", "search",false,'Search');
</script>
<div id="navrow1" class="tabs">
<ul class="tablist">
<li><a href="index.html"><span>Main&#160;Page</span></a></li>
<li><a href="namespaces.html"><span>Namespaces</span></a></li>
<li class="current"><a href="annotated.html"><span>Classes</span></a></li>
<li><a href="files.html"><span>Files</span></a></li>
<li>
<div id="MSearchBox" class="MSearchBoxInactive">
<span class="left">
<img id="MSearchSelect" src="search/mag_sel.png"
onmouseover="return searchBox.OnSearchSelectShow()"
onmouseout="return searchBox.OnSearchSelectHide()"
alt=""/>
<input type="text" id="MSearchField" value="Search" accesskey="S"
onfocus="searchBox.OnSearchFieldFocus(true)"
onblur="searchBox.OnSearchFieldFocus(false)"
onkeyup="searchBox.OnSearchFieldChange(event)"/>
</span><span class="right">
<a id="MSearchClose" href="javascript:searchBox.CloseResultsWindow()"><img id="MSearchCloseImg" border="0" src="search/close.png" alt=""/></a>
</span>
</div>
</li>
</ul>
</div>
<div id="navrow2" class="tabs2">
<ul class="tablist">
<li><a href="annotated.html"><span>Class&#160;List</span></a></li>
<li><a href="classes.html"><span>Class&#160;Index</span></a></li>
<li><a href="inherits.html"><span>Class&#160;Hierarchy</span></a></li>
<li><a href="functions.html"><span>Class&#160;Members</span></a></li>
</ul>
</div>
</div><!-- top -->
<div id="side-nav" class="ui-resizable side-nav-resizable">
<div id="nav-tree">
<div id="nav-tree-contents">
<div id="nav-sync" class="sync"></div>
</div>
</div>
<div id="splitbar" style="-moz-user-select:none;"
class="ui-resizable-handle">
</div>
</div>
<script type="text/javascript">
$(document).ready(function(){initNavTree('classimpala_1_1DiskIoMgrStress.html','');});
</script>
<div id="doc-content">
<!-- window showing the filter options -->
<div id="MSearchSelectWindow"
onmouseover="return searchBox.OnSearchSelectShow()"
onmouseout="return searchBox.OnSearchSelectHide()"
onkeydown="return searchBox.OnSearchSelectKey(event)">
<a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(0)"><span class="SelectionMark">&#160;</span>All</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(1)"><span class="SelectionMark">&#160;</span>Classes</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(2)"><span class="SelectionMark">&#160;</span>Namespaces</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(3)"><span class="SelectionMark">&#160;</span>Files</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(4)"><span class="SelectionMark">&#160;</span>Functions</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(5)"><span class="SelectionMark">&#160;</span>Variables</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(6)"><span class="SelectionMark">&#160;</span>Typedefs</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(7)"><span class="SelectionMark">&#160;</span>Enumerations</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(8)"><span class="SelectionMark">&#160;</span>Enumerator</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(9)"><span class="SelectionMark">&#160;</span>Friends</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(10)"><span class="SelectionMark">&#160;</span>Macros</a></div>
<!-- iframe showing the search results (closed by default) -->
<div id="MSearchResultsWindow">
<iframe src="javascript:void(0)" frameborder="0"
name="MSearchResults" id="MSearchResults">
</iframe>
</div>
<div class="header">
<div class="summary">
<a href="#nested-classes">Classes</a> &#124;
<a href="#pub-methods">Public Member Functions</a> &#124;
<a href="#pri-methods">Private Member Functions</a> &#124;
<a href="#pri-attribs">Private Attributes</a> &#124;
<a href="classimpala_1_1DiskIoMgrStress-members.html">List of all members</a> </div>
<div class="headertitle">
<div class="title">impala::DiskIoMgrStress Class Reference</div> </div>
</div><!--header-->
<div class="contents">
<p><code>#include &lt;<a class="el" href="disk-io-mgr-stress_8h_source.html">disk-io-mgr-stress.h</a>&gt;</code></p>
<div class="dynheader">
Collaboration diagram for impala::DiskIoMgrStress:</div>
<div class="dyncontent">
<div class="center"><div class="zoom"><iframe scrolling="no" frameborder="0" src="classimpala_1_1DiskIoMgrStress__coll__graph.svg" width="100%" height="600"><p><b>This browser is not able to show SVG: try Firefox, Chrome, Safari, or Opera instead.</b></p></iframe></div></div>
</div>
<table class="memberdecls">
<tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="nested-classes"></a>
Classes</h2></td></tr>
<tr class="memitem:"><td class="memItemLeft" align="right" valign="top">struct &#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="structDiskIoMgrStress_1_1Client.html">Client</a></td></tr>
<tr class="separator:"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:"><td class="memItemLeft" align="right" valign="top">struct &#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="structimpala_1_1DiskIoMgrStress_1_1File.html">File</a></td></tr>
<tr class="separator:"><td class="memSeparator" colspan="2">&#160;</td></tr>
</table><table class="memberdecls">
<tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pub-methods"></a>
Public Member Functions</h2></td></tr>
<tr class="memitem:acf1271a0c0f31ffe149c1ad0fcdf0e3b"><td class="memItemLeft" align="right" valign="top">&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DiskIoMgrStress.html#acf1271a0c0f31ffe149c1ad0fcdf0e3b">DiskIoMgrStress</a> (int num_disks, int num_threads_per_disk, int num_clients, <a class="el" href="classbool.html">bool</a> includes_cancellation)</td></tr>
<tr class="separator:acf1271a0c0f31ffe149c1ad0fcdf0e3b"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a6b4b31d6bf2600c6dceb296c8a4eb494"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DiskIoMgrStress.html#a6b4b31d6bf2600c6dceb296c8a4eb494">Run</a> (int sec)</td></tr>
<tr class="memdesc:a6b4b31d6bf2600c6dceb296c8a4eb494"><td class="mdescLeft">&#160;</td><td class="mdescRight">Run the test for 'sec'. If 0, run forever. <a href="#a6b4b31d6bf2600c6dceb296c8a4eb494">More...</a><br/></td></tr>
<tr class="separator:a6b4b31d6bf2600c6dceb296c8a4eb494"><td class="memSeparator" colspan="2">&#160;</td></tr>
</table><table class="memberdecls">
<tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pri-methods"></a>
Private Member Functions</h2></td></tr>
<tr class="memitem:aa753dad3780180c37a6b2855a5e0579e"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DiskIoMgrStress.html#aa753dad3780180c37a6b2855a5e0579e">NewClient</a> (int i)</td></tr>
<tr class="separator:aa753dad3780180c37a6b2855a5e0579e"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a3e78d8953d71bab86818f9c4ec2f3a28"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DiskIoMgrStress.html#a3e78d8953d71bab86818f9c4ec2f3a28">ClientThread</a> (int client_id)</td></tr>
<tr class="separator:a3e78d8953d71bab86818f9c4ec2f3a28"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a4f0b851c243b8e0a1020155ab26354a6"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DiskIoMgrStress.html#a4f0b851c243b8e0a1020155ab26354a6">CancelRandomReader</a> ()</td></tr>
<tr class="memdesc:a4f0b851c243b8e0a1020155ab26354a6"><td class="mdescLeft">&#160;</td><td class="mdescRight">Possibly cancels a random reader. <a href="#a4f0b851c243b8e0a1020155ab26354a6">More...</a><br/></td></tr>
<tr class="separator:a4f0b851c243b8e0a1020155ab26354a6"><td class="memSeparator" colspan="2">&#160;</td></tr>
</table><table class="memberdecls">
<tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pri-attribs"></a>
Private Attributes</h2></td></tr>
<tr class="memitem:a9e22b52eb543f9701545e033644035fc"><td class="memItemLeft" align="right" valign="top">std::vector&lt; <a class="el" href="structimpala_1_1DiskIoMgrStress_1_1File.html">File</a> &gt;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DiskIoMgrStress.html#a9e22b52eb543f9701545e033644035fc">files_</a></td></tr>
<tr class="separator:a9e22b52eb543f9701545e033644035fc"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a2bbe68e951015faaed24c77397708182"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1MemTracker.html">MemTracker</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DiskIoMgrStress.html#a2bbe68e951015faaed24c77397708182">dummy_tracker_</a></td></tr>
<tr class="memdesc:a2bbe68e951015faaed24c77397708182"><td class="mdescLeft">&#160;</td><td class="mdescRight">Dummy mem tracker. <a href="#a2bbe68e951015faaed24c77397708182">More...</a><br/></td></tr>
<tr class="separator:a2bbe68e951015faaed24c77397708182"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a31585d1ce2c805c621f745acd9175870"><td class="memItemLeft" align="right" valign="top">boost::scoped_ptr&lt; <a class="el" href="classimpala_1_1DiskIoMgr.html">DiskIoMgr</a> &gt;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DiskIoMgrStress.html#a31585d1ce2c805c621f745acd9175870">io_mgr_</a></td></tr>
<tr class="memdesc:a31585d1ce2c805c621f745acd9175870"><td class="mdescLeft">&#160;</td><td class="mdescRight">io manager <a href="#a31585d1ce2c805c621f745acd9175870">More...</a><br/></td></tr>
<tr class="separator:a31585d1ce2c805c621f745acd9175870"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:ae187f8a8e55155181b0ae72b7a1b969d"><td class="memItemLeft" align="right" valign="top">boost::thread_group&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DiskIoMgrStress.html#ae187f8a8e55155181b0ae72b7a1b969d">readers_</a></td></tr>
<tr class="memdesc:ae187f8a8e55155181b0ae72b7a1b969d"><td class="mdescLeft">&#160;</td><td class="mdescRight"><a class="el" href="classimpala_1_1Thread.html" title="TODO: Consider allowing fragment IDs as category parameters. ">Thread</a> group for reader threads. <a href="#ae187f8a8e55155181b0ae72b7a1b969d">More...</a><br/></td></tr>
<tr class="separator:ae187f8a8e55155181b0ae72b7a1b969d"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:ac7e60e998ed562d9c782957c0f648fd8"><td class="memItemLeft" align="right" valign="top">int&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DiskIoMgrStress.html#ac7e60e998ed562d9c782957c0f648fd8">num_clients_</a></td></tr>
<tr class="memdesc:ac7e60e998ed562d9c782957c0f648fd8"><td class="mdescLeft">&#160;</td><td class="mdescRight">Array of clients. <a href="#ac7e60e998ed562d9c782957c0f648fd8">More...</a><br/></td></tr>
<tr class="separator:ac7e60e998ed562d9c782957c0f648fd8"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a6e9031a17f4abc61c04f335540d1cddf"><td class="memItemLeft" align="right" valign="top"><a class="el" href="structDiskIoMgrStress_1_1Client.html">Client</a> *&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DiskIoMgrStress.html#a6e9031a17f4abc61c04f335540d1cddf">clients_</a></td></tr>
<tr class="separator:a6e9031a17f4abc61c04f335540d1cddf"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a5e7f8224b852974cf5dca3b1fcaf4509"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classbool.html">bool</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DiskIoMgrStress.html#a5e7f8224b852974cf5dca3b1fcaf4509">includes_cancellation_</a></td></tr>
<tr class="memdesc:a5e7f8224b852974cf5dca3b1fcaf4509"><td class="mdescLeft">&#160;</td><td class="mdescRight">If true, tests cancelling readers. <a href="#a5e7f8224b852974cf5dca3b1fcaf4509">More...</a><br/></td></tr>
<tr class="separator:a5e7f8224b852974cf5dca3b1fcaf4509"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:abe1a5cd193800d3c704be2dc61746614"><td class="memItemLeft" align="right" valign="top">volatile <a class="el" href="classbool.html">bool</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DiskIoMgrStress.html#abe1a5cd193800d3c704be2dc61746614">shutdown_</a></td></tr>
<tr class="memdesc:abe1a5cd193800d3c704be2dc61746614"><td class="mdescLeft">&#160;</td><td class="mdescRight">Flag to signal that client reader threads should exit. <a href="#abe1a5cd193800d3c704be2dc61746614">More...</a><br/></td></tr>
<tr class="separator:abe1a5cd193800d3c704be2dc61746614"><td class="memSeparator" colspan="2">&#160;</td></tr>
</table>
<a name="details" id="details"></a><h2 class="groupheader">Detailed Description</h2>
<div class="textblock"><p>Test utility to stress the disk io mgr. It allows for a configurable number of clients. The clients continuously issue work to the io mgr and asynchronously get cancelled. The stress test can be run forever or for a fixed duration. The unit test runs this for a fixed duration. </p>
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8h_source.html#l00036">36</a> of file <a class="el" href="disk-io-mgr-stress_8h_source.html">disk-io-mgr-stress.h</a>.</p>
</div><h2 class="groupheader">Constructor &amp; Destructor Documentation</h2>
<a class="anchor" id="acf1271a0c0f31ffe149c1ad0fcdf0e3b"></a>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">DiskIoMgrStress::DiskIoMgrStress </td>
<td>(</td>
<td class="paramtype">int&#160;</td>
<td class="paramname"><em>num_disks</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype">int&#160;</td>
<td class="paramname"><em>num_threads_per_disk</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype">int&#160;</td>
<td class="paramname"><em>num_clients</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype"><a class="el" href="classbool.html">bool</a>&#160;</td>
<td class="paramname"><em>includes_cancellation</em>&#160;</td>
</tr>
<tr>
<td></td>
<td>)</td>
<td></td><td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00064">64</a> of file <a class="el" href="disk-io-mgr-stress_8cc_source.html">disk-io-mgr-stress.cc</a>.</p>
<p>References <a class="el" href="disk-io-mgr-stress_8h_source.html#l00068">clients_</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00038">CreateTempFile()</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00058">dummy_tracker_</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00055">files_</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00045">GenerateRandomData()</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00061">io_mgr_</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00034">MAX_READ_BUFFER_SIZE</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00033">MIN_READ_BUFFER_SIZE</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00204">NewClient()</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00067">num_clients_</a>, and <a class="el" href="status_8h_source.html#l00172">impala::Status::ok()</a>.</p>
</div>
</div>
<h2 class="groupheader">Member Function Documentation</h2>
<a class="anchor" id="a4f0b851c243b8e0a1020155ab26354a6"></a>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">void DiskIoMgrStress::CancelRandomReader </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td></td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Possibly cancels a random reader. </p>
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00165">165</a> of file <a class="el" href="disk-io-mgr-stress_8cc_source.html">disk-io-mgr-stress.cc</a>.</p>
<p>References <a class="el" href="disk-io-mgr-stress_8h_source.html#l00068">clients_</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00071">includes_cancellation_</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00061">io_mgr_</a>, and <a class="el" href="disk-io-mgr-stress_8h_source.html#l00067">num_clients_</a>.</p>
<p>Referenced by <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00174">Run()</a>.</p>
</div>
</div>
<a class="anchor" id="a3e78d8953d71bab86818f9c4ec2f3a28"></a>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">void DiskIoMgrStress::ClientThread </td>
<td>(</td>
<td class="paramtype">int&#160;</td>
<td class="paramname"><em>client_id</em></td><td>)</td>
<td></td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p><a class="el" href="classimpala_1_1Thread.html" title="TODO: Consider allowing fragment IDs as category parameters. ">Thread</a> running the reader. When the current reader is done (either normally or cancelled), it picks up a new reader </p>
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00094">94</a> of file <a class="el" href="disk-io-mgr-stress_8cc_source.html">disk-io-mgr-stress.cc</a>.</p>
<p>References <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00060">impala::DiskIoMgrStress::Client::abort_at_byte</a>, <a class="el" href="disk-io-mgr_8h_source.html#l00199">impala::DiskIoMgr::BufferDescriptor::buffer()</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00068">clients_</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00058">impala::DiskIoMgrStress::Client::file_idx</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00055">files_</a>, <a class="el" href="disk-io-mgr-scan-range_8cc_source.html#l00070">impala::DiskIoMgr::ScanRange::GetNext()</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00061">io_mgr_</a>, <a class="el" href="status_8h_source.html#l00174">impala::Status::IsCancelled()</a>, <a class="el" href="disk-io-mgr_8h_source.html#l00201">impala::DiskIoMgr::BufferDescriptor::len()</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00056">impala::DiskIoMgrStress::Client::lock</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00028">MAX_FILE_LEN</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00204">NewClient()</a>, <a class="el" href="disk-io-mgr_8h_source.html#l00267">impala::DiskIoMgr::RequestRange::offset()</a>, <a class="el" href="status_8h_source.html#l00172">impala::Status::ok()</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00057">impala::DiskIoMgrStress::Client::reader</a>, <a class="el" href="disk-io-mgr_8cc_source.html#l00182">impala::DiskIoMgr::BufferDescriptor::Return()</a>, <a class="el" href="disk-io-mgr_8h_source.html#l00205">impala::DiskIoMgr::BufferDescriptor::scan_range_offset()</a>, and <a class="el" href="disk-io-mgr-stress_8h_source.html#l00074">shutdown_</a>.</p>
<p>Referenced by <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00174">Run()</a>.</p>
</div>
</div>
<a class="anchor" id="aa753dad3780180c37a6b2855a5e0579e"></a>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">void DiskIoMgrStress::NewClient </td>
<td>(</td>
<td class="paramtype">int&#160;</td>
<td class="paramname"><em>i</em></td><td>)</td>
<td></td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Helper to initialize a new reader client, registering a new reader with the io mgr and initializing the scan ranges </p>
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00204">204</a> of file <a class="el" href="disk-io-mgr-stress_8cc_source.html">disk-io-mgr-stress.cc</a>.</p>
<p>References <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00060">impala::DiskIoMgrStress::Client::abort_at_byte</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00023">ABORT_CHANCE</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00068">clients_</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00058">impala::DiskIoMgrStress::Client::file_idx</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00055">files_</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00061">impala::DiskIoMgrStress::Client::files_processed</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00071">includes_cancellation_</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00061">io_mgr_</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00025">MAX_READ_LEN</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00024">MIN_READ_LEN</a>, <a class="el" href="disk-io-mgr_8h_source.html#l00299">impala::DiskIoMgr::ScanRange::NEVER_CACHE</a>, <a class="el" href="status_8h_source.html#l00172">impala::Status::ok()</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00057">impala::DiskIoMgrStress::Client::reader</a>, <a class="el" href="disk-io-mgr-scan-range_8cc_source.html#l00215">impala::DiskIoMgr::ScanRange::Reset()</a>, and <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00059">impala::DiskIoMgrStress::Client::scan_ranges</a>.</p>
<p>Referenced by <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00094">ClientThread()</a>, and <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00064">DiskIoMgrStress()</a>.</p>
</div>
</div>
<a class="anchor" id="a6b4b31d6bf2600c6dceb296c8a4eb494"></a>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">void DiskIoMgrStress::Run </td>
<td>(</td>
<td class="paramtype">int&#160;</td>
<td class="paramname"><em>sec</em></td><td>)</td>
<td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Run the test for 'sec'. If 0, run forever. </p>
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00174">174</a> of file <a class="el" href="disk-io-mgr-stress_8cc_source.html">disk-io-mgr-stress.cc</a>.</p>
<p>References <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00036">CANCEL_READER_PERIOD_MS</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00165">CancelRandomReader()</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00068">clients_</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00094">ClientThread()</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00061">io_mgr_</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00067">num_clients_</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00064">readers_</a>, <a class="el" href="disk-io-mgr-stress_8h_source.html#l00074">shutdown_</a>, and <a class="el" href="time_8cc_source.html#l00021">impala::SleepForMs()</a>.</p>
<p>Referenced by <a class="el" href="disk-io-mgr-stress-test_8cc_source.html#l00033">main()</a>, and <a class="el" href="disk-io-mgr-test_8cc_source.html#l00958">impala::TEST_F()</a>.</p>
</div>
</div>
<h2 class="groupheader">Member Data Documentation</h2>
<a class="anchor" id="a6e9031a17f4abc61c04f335540d1cddf"></a>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="structDiskIoMgrStress_1_1Client.html">Client</a>* impala::DiskIoMgrStress::clients_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8h_source.html#l00068">68</a> of file <a class="el" href="disk-io-mgr-stress_8h_source.html">disk-io-mgr-stress.h</a>.</p>
<p>Referenced by <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00165">CancelRandomReader()</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00094">ClientThread()</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00064">DiskIoMgrStress()</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00204">NewClient()</a>, and <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00174">Run()</a>.</p>
</div>
</div>
<a class="anchor" id="a2bbe68e951015faaed24c77397708182"></a>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="classimpala_1_1MemTracker.html">MemTracker</a> impala::DiskIoMgrStress::dummy_tracker_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Dummy mem tracker. </p>
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8h_source.html#l00058">58</a> of file <a class="el" href="disk-io-mgr-stress_8h_source.html">disk-io-mgr-stress.h</a>.</p>
<p>Referenced by <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00064">DiskIoMgrStress()</a>.</p>
</div>
</div>
<a class="anchor" id="a9e22b52eb543f9701545e033644035fc"></a>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">std::vector&lt;<a class="el" href="structimpala_1_1DiskIoMgrStress_1_1File.html">File</a>&gt; impala::DiskIoMgrStress::files_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Files used for testing. These are created at startup and recycled during the test </p>
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8h_source.html#l00055">55</a> of file <a class="el" href="disk-io-mgr-stress_8h_source.html">disk-io-mgr-stress.h</a>.</p>
<p>Referenced by <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00094">ClientThread()</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00064">DiskIoMgrStress()</a>, and <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00204">NewClient()</a>.</p>
</div>
</div>
<a class="anchor" id="a5e7f8224b852974cf5dca3b1fcaf4509"></a>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="classbool.html">bool</a> impala::DiskIoMgrStress::includes_cancellation_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>If true, tests cancelling readers. </p>
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8h_source.html#l00071">71</a> of file <a class="el" href="disk-io-mgr-stress_8h_source.html">disk-io-mgr-stress.h</a>.</p>
<p>Referenced by <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00165">CancelRandomReader()</a>, and <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00204">NewClient()</a>.</p>
</div>
</div>
<a class="anchor" id="a31585d1ce2c805c621f745acd9175870"></a>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">boost::scoped_ptr&lt;<a class="el" href="classimpala_1_1DiskIoMgr.html">DiskIoMgr</a>&gt; impala::DiskIoMgrStress::io_mgr_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>io manager </p>
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8h_source.html#l00061">61</a> of file <a class="el" href="disk-io-mgr-stress_8h_source.html">disk-io-mgr-stress.h</a>.</p>
<p>Referenced by <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00165">CancelRandomReader()</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00094">ClientThread()</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00064">DiskIoMgrStress()</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00204">NewClient()</a>, and <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00174">Run()</a>.</p>
</div>
</div>
<a class="anchor" id="ac7e60e998ed562d9c782957c0f648fd8"></a>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">int impala::DiskIoMgrStress::num_clients_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Array of clients. </p>
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8h_source.html#l00067">67</a> of file <a class="el" href="disk-io-mgr-stress_8h_source.html">disk-io-mgr-stress.h</a>.</p>
<p>Referenced by <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00165">CancelRandomReader()</a>, <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00064">DiskIoMgrStress()</a>, and <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00174">Run()</a>.</p>
</div>
</div>
<a class="anchor" id="ae187f8a8e55155181b0ae72b7a1b969d"></a>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">boost::thread_group impala::DiskIoMgrStress::readers_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p><a class="el" href="classimpala_1_1Thread.html" title="TODO: Consider allowing fragment IDs as category parameters. ">Thread</a> group for reader threads. </p>
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8h_source.html#l00064">64</a> of file <a class="el" href="disk-io-mgr-stress_8h_source.html">disk-io-mgr-stress.h</a>.</p>
<p>Referenced by <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00174">Run()</a>.</p>
</div>
</div>
<a class="anchor" id="abe1a5cd193800d3c704be2dc61746614"></a>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">volatile <a class="el" href="classbool.html">bool</a> impala::DiskIoMgrStress::shutdown_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Flag to signal that client reader threads should exit. </p>
<p>Definition at line <a class="el" href="disk-io-mgr-stress_8h_source.html#l00074">74</a> of file <a class="el" href="disk-io-mgr-stress_8h_source.html">disk-io-mgr-stress.h</a>.</p>
<p>Referenced by <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00094">ClientThread()</a>, and <a class="el" href="disk-io-mgr-stress_8cc_source.html#l00174">Run()</a>.</p>
</div>
</div>
<hr/>The documentation for this class was generated from the following files:<ul>
<li>be/src/runtime/<a class="el" href="disk-io-mgr-stress_8h_source.html">disk-io-mgr-stress.h</a></li>
<li>be/src/runtime/<a class="el" href="disk-io-mgr-stress_8cc_source.html">disk-io-mgr-stress.cc</a></li>
</ul>
</div><!-- contents -->
</div><!-- doc-content -->
<!-- start footer part -->
<div id="nav-path" class="navpath"><!-- id is needed for treeview function! -->
<ul>
<li class="navelem"><a class="el" href="namespaceimpala.html">impala</a></li><li class="navelem"><a class="el" href="classimpala_1_1DiskIoMgrStress.html">DiskIoMgrStress</a></li>
<li class="footer">Generated on Thu May 7 2015 16:10:49 for Impala by
<a href="http://www.doxygen.org/index.html">
<img class="footer" src="doxygen.png" alt="doxygen"/></a> 1.8.6 </li>
</ul>
</div>
</body>
</html>