<!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"/>
<title>GNU Radio 3.2.2 C++ API: gc_job_manager_impl.h Source File</title>
<link href="tabs.css" rel="stylesheet" type="text/css"/>
<link href="navtree.css" rel="stylesheet" type="text/css"/>
<script type="text/javascript" src="jquery.js"></script>
<script type="text/javascript" src="navtree.js"></script>
<script type="text/javascript" src="resize.js"></script>
<script type="text/javascript">
$(document).ready(initResizable);
</script>
<link href="doxygen.css" rel="stylesheet" type="text/css"/>
</head>
<body>
<!-- Generated by Doxygen 1.7.3 -->
<div id="top">
<div id="titlearea">
<table cellspacing="0" cellpadding="0">
<tbody>
<tr style="height: 56px;">
<td style="padding-left: 0.5em;">
<div id="projectname">GNU Radio 3.2.2 C++ API</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
<div id="side-nav" class="ui-resizable side-nav-resizable">
<div id="nav-tree">
<div id="nav-tree-contents">
</div>
</div>
<div id="splitbar" style="-moz-user-select:none;"
class="ui-resizable-handle">
</div>
</div>
<script type="text/javascript">
initNavTree('gc__job__manager__impl_8h.html','');
</script>
<div id="doc-content">
<div class="header">
<div class="headertitle">
<h1>gc_job_manager_impl.h</h1> </div>
</div>
<div class="contents">
<a href="gc__job__manager__impl_8h.html">Go to the documentation of this file.</a><div class="fragment"><pre class="fragment"><a name="l00001"></a>00001 <span class="comment">/* -*- c++ -*- */</span>
<a name="l00002"></a>00002 <span class="comment">/*</span>
<a name="l00003"></a>00003 <span class="comment"> * Copyright 2007,2008,2009 Free Software Foundation, Inc.</span>
<a name="l00004"></a>00004 <span class="comment"> * </span>
<a name="l00005"></a>00005 <span class="comment"> * This file is part of GNU Radio</span>
<a name="l00006"></a>00006 <span class="comment"> * </span>
<a name="l00007"></a>00007 <span class="comment"> * GNU Radio is free software; you can redistribute it and/or modify</span>
<a name="l00008"></a>00008 <span class="comment"> * it under the terms of the GNU General Public License as published by</span>
<a name="l00009"></a>00009 <span class="comment"> * the Free Software Foundation; either version 3, or (at your option)</span>
<a name="l00010"></a>00010 <span class="comment"> * any later version.</span>
<a name="l00011"></a>00011 <span class="comment"> * </span>
<a name="l00012"></a>00012 <span class="comment"> * GNU Radio is distributed in the hope that it will be useful,</span>
<a name="l00013"></a>00013 <span class="comment"> * but WITHOUT ANY WARRANTY; without even the implied warranty of</span>
<a name="l00014"></a>00014 <span class="comment"> * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the</span>
<a name="l00015"></a>00015 <span class="comment"> * GNU General Public License for more details.</span>
<a name="l00016"></a>00016 <span class="comment"> * </span>
<a name="l00017"></a>00017 <span class="comment"> * You should have received a copy of the GNU General Public License along</span>
<a name="l00018"></a>00018 <span class="comment"> * with this program; if not, write to the Free Software Foundation, Inc.,</span>
<a name="l00019"></a>00019 <span class="comment"> * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.</span>
<a name="l00020"></a>00020 <span class="comment"> */</span>
<a name="l00021"></a>00021
<a name="l00022"></a>00022 <span class="preprocessor">#ifndef INCLUDED_GC_JOB_MANAGER_IMPL_H</span>
<a name="l00023"></a>00023 <span class="preprocessor"></span><span class="preprocessor">#define INCLUDED_GC_JOB_MANAGER_IMPL_H</span>
<a name="l00024"></a>00024 <span class="preprocessor"></span>
<a name="l00025"></a>00025 <span class="preprocessor">#include <gcell/gc_job_manager.h></span>
<a name="l00026"></a>00026 <span class="preprocessor">#include <gcell/gc_jd_stack.h></span>
<a name="l00027"></a>00027 <span class="preprocessor">#include <gcell/gc_jd_queue.h></span>
<a name="l00028"></a>00028 <span class="preprocessor">#include <gcell/gc_spu_args.h></span>
<a name="l00029"></a>00029 <span class="preprocessor">#include "<a class="code" href="gc__client__thread__info_8h.html">gc_client_thread_info.h</a>"</span>
<a name="l00030"></a>00030 <span class="preprocessor">#include <libspe2.h></span>
<a name="l00031"></a>00031 <span class="preprocessor">#include <vector></span>
<a name="l00032"></a>00032 <span class="preprocessor">#include <boost/scoped_array.hpp></span>
<a name="l00033"></a>00033
<a name="l00034"></a>00034 <span class="keyword">typedef</span> <a class="code" href="classboost_1_1shared__ptr.html">boost::shared_ptr<spe_gang_context></a> <a class="code" href="classboost_1_1shared__ptr.html">spe_gang_context_sptr</a>;
<a name="l00035"></a>00035 <span class="keyword">typedef</span> <a class="code" href="classboost_1_1shared__ptr.html">boost::shared_ptr<spe_program_handle_t></a> <a class="code" href="classboost_1_1shared__ptr.html">spe_program_handle_sptr</a>;
<a name="l00036"></a><a class="code" href="gc__job__manager__impl_8h.html#ad87b3fba7d38c319dd12f035bcb2de88">00036</a> <span class="keyword">typedef</span> boost::scoped_array<gc_client_thread_info> <a class="code" href="gc__job__manager__impl_8h.html#ad87b3fba7d38c319dd12f035bcb2de88">gc_client_thread_info_sa</a>;
<a name="l00037"></a>00037
<a name="l00038"></a>00038
<a name="l00039"></a><a class="code" href="gc__job__manager__impl_8h.html#a74d6a8e9b05f036ec5b86d00abaffea6">00039</a> <span class="keyword">enum</span> <a class="code" href="gc__job__manager__impl_8h.html#a74d6a8e9b05f036ec5b86d00abaffea6">worker_state</a> {
<a name="l00040"></a><a class="code" href="gc__job__manager__impl_8h.html#a74d6a8e9b05f036ec5b86d00abaffea6a72a2a1e2fc6bdcddf3177a182a9f0d75">00040</a> <a class="code" href="gc__job__manager__impl_8h.html#a74d6a8e9b05f036ec5b86d00abaffea6a72a2a1e2fc6bdcddf3177a182a9f0d75">WS_FREE</a>, <span class="comment">// not in use</span>
<a name="l00041"></a><a class="code" href="gc__job__manager__impl_8h.html#a74d6a8e9b05f036ec5b86d00abaffea6ac12066f1abb529955c551ca857274906">00041</a> <a class="code" href="gc__job__manager__impl_8h.html#a74d6a8e9b05f036ec5b86d00abaffea6ac12066f1abb529955c551ca857274906">WS_INIT</a>, <span class="comment">// allocated and being initialized</span>
<a name="l00042"></a><a class="code" href="gc__job__manager__impl_8h.html#a74d6a8e9b05f036ec5b86d00abaffea6a7bc615bf5944313f56fbd5664aa4b611">00042</a> <a class="code" href="gc__job__manager__impl_8h.html#a74d6a8e9b05f036ec5b86d00abaffea6a7bc615bf5944313f56fbd5664aa4b611">WS_RUNNING</a>, <span class="comment">// the thread is running</span>
<a name="l00043"></a><a class="code" href="gc__job__manager__impl_8h.html#a74d6a8e9b05f036ec5b86d00abaffea6a4025e660cb00c6c8b6e3d0fd0e838bda">00043</a> <a class="code" href="gc__job__manager__impl_8h.html#a74d6a8e9b05f036ec5b86d00abaffea6a4025e660cb00c6c8b6e3d0fd0e838bda">WS_DEAD</a>, <span class="comment">// the thread is dead</span>
<a name="l00044"></a>00044 };
<a name="l00045"></a>00045
<a name="l00046"></a><a class="code" href="structworker__ctx.html">00046</a> <span class="keyword">struct </span><a class="code" href="structworker__ctx.html">worker_ctx</a> {
<a name="l00047"></a><a class="code" href="structworker__ctx.html#a3e4c1b8c39ebe7c16d55d740f50f54cb">00047</a> <span class="keyword">volatile</span> <a class="code" href="gc__job__manager__impl_8h.html#a74d6a8e9b05f036ec5b86d00abaffea6">worker_state</a> <a class="code" href="structworker__ctx.html#a3e4c1b8c39ebe7c16d55d740f50f54cb">state</a>;
<a name="l00048"></a><a class="code" href="structworker__ctx.html#a3d7f83662735dfdca2197602fa126298">00048</a> <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> <a class="code" href="structworker__ctx.html#a3d7f83662735dfdca2197602fa126298">spe_idx</a>; <span class="comment">// [0, nspes-1]</span>
<a name="l00049"></a><a class="code" href="structworker__ctx.html#ae3c3c4c2b99c726b3e6059f4cf8de112">00049</a> spe_context_ptr_t <a class="code" href="structworker__ctx.html#ae3c3c4c2b99c726b3e6059f4cf8de112">spe_ctx</a>;
<a name="l00050"></a><a class="code" href="structworker__ctx.html#a32ae86dd768ae015838224df2a913b87">00050</a> spe_spu_control_area_t *<a class="code" href="structworker__ctx.html#a32ae86dd768ae015838224df2a913b87">spe_ctrl</a>;
<a name="l00051"></a><a class="code" href="structworker__ctx.html#a1a138e959580825d26183b069ce1ef76">00051</a> <a class="code" href="struct____pthread__transp__t.html">pthread_t</a> <a class="code" href="structworker__ctx.html#a1a138e959580825d26183b069ce1ef76">thread</a>;
<a name="l00052"></a><a class="code" href="structworker__ctx.html#ac9db815b4316bd78c23404ff448f6caa">00052</a> <a class="code" href="structgc__spu__args.html">gc_spu_args_t</a> *<a class="code" href="structworker__ctx.html#ac9db815b4316bd78c23404ff448f6caa">spu_args</a>; <span class="comment">// pointer to 16-byte aligned struct</span>
<a name="l00053"></a>00053
<a name="l00054"></a><a class="code" href="structworker__ctx.html#af2a8132f7f45d328813937680dd8dd1a">00054</a> <a class="code" href="structworker__ctx.html#af2a8132f7f45d328813937680dd8dd1a">worker_ctx</a>()
<a name="l00055"></a>00055 : <a class="code" href="structworker__ctx.html#a3e4c1b8c39ebe7c16d55d740f50f54cb">state</a>(<a class="code" href="gc__job__manager__impl_8h.html#a74d6a8e9b05f036ec5b86d00abaffea6a72a2a1e2fc6bdcddf3177a182a9f0d75">WS_FREE</a>), <a class="code" href="structworker__ctx.html#a3d7f83662735dfdca2197602fa126298">spe_idx</a>(0), <a class="code" href="structworker__ctx.html#ae3c3c4c2b99c726b3e6059f4cf8de112">spe_ctx</a>(0), <a class="code" href="structworker__ctx.html#a32ae86dd768ae015838224df2a913b87">spe_ctrl</a>(0),
<a name="l00056"></a>00056 <a class="code" href="structworker__ctx.html#a1a138e959580825d26183b069ce1ef76">thread</a>(0), <a class="code" href="structworker__ctx.html#ac9db815b4316bd78c23404ff448f6caa">spu_args</a>(0) {}
<a name="l00057"></a>00057 <a class="code" href="structworker__ctx.html#a75ce2dff5d51f902bda482e16ac7f6fb">~worker_ctx</a>();
<a name="l00058"></a>00058 };
<a name="l00059"></a>00059
<a name="l00060"></a><a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31">00060</a> <span class="keyword">enum</span> <a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31">evt_handler_state</a> {
<a name="l00061"></a><a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31a937e1324e35c4f1a64fba5106ac4eb64">00061</a> <a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31a937e1324e35c4f1a64fba5106ac4eb64">EHS_INIT</a>, <span class="comment">// being initialized</span>
<a name="l00062"></a><a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31a6781dcf9580cd8927c9dcf0c260a45d4">00062</a> <a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31a6781dcf9580cd8927c9dcf0c260a45d4">EHS_RUNNING</a>, <span class="comment">// thread is running</span>
<a name="l00063"></a><a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31ab3677045d887913fcc0aacdf61e79a5b">00063</a> <a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31ab3677045d887913fcc0aacdf61e79a5b">EHS_SHUTTING_DOWN</a>, <span class="comment">// in process of shutting down everything</span>
<a name="l00064"></a><a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31a88ece3638467835ccda5e7d5ae876247">00064</a> <a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31a88ece3638467835ccda5e7d5ae876247">EHS_WAITING_FOR_WORKERS_TO_DIE</a>,
<a name="l00065"></a><a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31ad7bd69154cc65b9aa5d4efc801f42092">00065</a> <a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31ad7bd69154cc65b9aa5d4efc801f42092">EHS_DEAD</a>, <span class="comment">// thread is dead</span>
<a name="l00066"></a>00066 };
<a name="l00067"></a>00067
<a name="l00068"></a><a class="code" href="gc__job__manager__impl_8h.html#a36f32c1cf3f8307edaa2010844bdfbe8">00068</a> <span class="keyword">enum</span> <a class="code" href="gc__job__manager__impl_8h.html#a36f32c1cf3f8307edaa2010844bdfbe8">job_completer_state</a> {
<a name="l00069"></a><a class="code" href="gc__job__manager__impl_8h.html#a36f32c1cf3f8307edaa2010844bdfbe8a2d10559c5a5ca27cb77fab4771ad3973">00069</a> <a class="code" href="gc__job__manager__impl_8h.html#a36f32c1cf3f8307edaa2010844bdfbe8a2d10559c5a5ca27cb77fab4771ad3973">JCS_INIT</a>, <span class="comment">// being initialized</span>
<a name="l00070"></a><a class="code" href="gc__job__manager__impl_8h.html#a36f32c1cf3f8307edaa2010844bdfbe8a7483ceeda1c2ce2670e7e5133adb0b4a">00070</a> <a class="code" href="gc__job__manager__impl_8h.html#a36f32c1cf3f8307edaa2010844bdfbe8a7483ceeda1c2ce2670e7e5133adb0b4a">JCS_RUNNING</a>, <span class="comment">// thread is running</span>
<a name="l00071"></a><a class="code" href="gc__job__manager__impl_8h.html#a36f32c1cf3f8307edaa2010844bdfbe8adc2865a913296284cc1b4b9123e9d3bb">00071</a> <a class="code" href="gc__job__manager__impl_8h.html#a36f32c1cf3f8307edaa2010844bdfbe8adc2865a913296284cc1b4b9123e9d3bb">JCS_DEAD</a>, <span class="comment">// thread is dead</span>
<a name="l00072"></a>00072 };
<a name="l00073"></a>00073
<a name="l00074"></a><a class="code" href="structspe__event__handler.html">00074</a> <span class="keyword">struct </span><a class="code" href="structspe__event__handler.html">spe_event_handler</a> {
<a name="l00075"></a><a class="code" href="structspe__event__handler.html#a275257db07e695c324e829541cc3fa68">00075</a> spe_event_handler_ptr_t <a class="code" href="structspe__event__handler.html#a275257db07e695c324e829541cc3fa68">ptr</a>;
<a name="l00076"></a>00076
<a name="l00077"></a><a class="code" href="structspe__event__handler.html#a95f69a745ce5e72a6c01320cdd1601e4">00077</a> <a class="code" href="structspe__event__handler.html#a95f69a745ce5e72a6c01320cdd1601e4">spe_event_handler</a>() : <a class="code" href="structspe__event__handler.html#a275257db07e695c324e829541cc3fa68">ptr</a>(0) {}
<a name="l00078"></a><a class="code" href="structspe__event__handler.html#a10c274b27802de045fc2a39201071828">00078</a> <a class="code" href="structspe__event__handler.html#a10c274b27802de045fc2a39201071828">~spe_event_handler</a>(){
<a name="l00079"></a>00079 <span class="keywordflow">if</span> (<a class="code" href="structspe__event__handler.html#a275257db07e695c324e829541cc3fa68">ptr</a>){
<a name="l00080"></a>00080 <span class="keywordflow">if</span> (spe_event_handler_destroy(<a class="code" href="structspe__event__handler.html#a275257db07e695c324e829541cc3fa68">ptr</a>) != 0){
<a name="l00081"></a>00081 perror(<span class="stringliteral">"spe_event_handler_destroy"</span>);
<a name="l00082"></a>00082 }
<a name="l00083"></a>00083 }
<a name="l00084"></a>00084 }
<a name="l00085"></a>00085 };
<a name="l00086"></a>00086
<a name="l00087"></a>00087 <span class="comment"></span>
<a name="l00088"></a>00088 <span class="comment">/*!</span>
<a name="l00089"></a>00089 <span class="comment"> * \brief Concrete class that manages SPE jobs.</span>
<a name="l00090"></a>00090 <span class="comment"> *</span>
<a name="l00091"></a>00091 <span class="comment"> * This class contains all the implementation details.</span>
<a name="l00092"></a>00092 <span class="comment"> */</span>
<a name="l00093"></a><a class="code" href="classgc__job__manager__impl.html">00093</a> <span class="keyword">class </span><a class="code" href="classgc__job__manager__impl.html" title="Concrete class that manages SPE jobs.">gc_job_manager_impl</a> : <span class="keyword">public</span> <a class="code" href="classgc__job__manager.html" title="Abstract class that manages SPE jobs.There is typically a single instance derived from this class...">gc_job_manager</a>
<a name="l00094"></a>00094 {
<a name="l00095"></a>00095 <span class="keyword">enum</span> { MAX_SPES = 16 };
<a name="l00096"></a>00096
<a name="l00097"></a>00097 <span class="keywordtype">int</span> d_debug;
<a name="l00098"></a>00098 <a class="code" href="structgc__jm__options.html">gc_jm_options</a> d_options;
<a name="l00099"></a>00099 <a class="code" href="classboost_1_1shared__ptr.html">spe_program_handle_sptr</a> d_spe_image;
<a name="l00100"></a>00100 <a class="code" href="classboost_1_1shared__ptr.html">spe_gang_context_sptr</a> d_gang; <span class="comment">// boost::shared_ptr</span>
<a name="l00101"></a>00101
<a name="l00102"></a>00102 <a class="code" href="structworker__ctx.html">worker_ctx</a> d_worker[MAX_SPES]; <span class="comment">// SPE ctx, thread, etc</span>
<a name="l00103"></a>00103 <a class="code" href="structgc__spu__args.html">gc_spu_args_t</a> *d_spu_args; <span class="comment">// 16-byte aligned structs</span>
<a name="l00104"></a>00104 <a class="code" href="classboost_1_1shared__ptr.html">boost::shared_ptr<void></a> _d_spu_args_boost; <span class="comment">// hack for automatic storage mgmt</span>
<a name="l00105"></a>00105
<a name="l00106"></a>00106 <a class="code" href="structgc__comp__info.html" title="Used to return info to PPE on which jobs are completed.">gc_comp_info_t</a> *d_comp_info; <span class="comment">// 128-byte aligned structs</span>
<a name="l00107"></a>00107 <a class="code" href="classboost_1_1shared__ptr.html">boost::shared_ptr<void></a> _d_comp_info_boost; <span class="comment">// hack for automatic storage mgmt</span>
<a name="l00108"></a>00108
<a name="l00109"></a>00109 <span class="comment">// used to coordinate communication w/ the event handling thread</span>
<a name="l00110"></a>00110 <a class="code" href="classomni__mutex.html">omni_mutex</a> d_eh_mutex;
<a name="l00111"></a>00111 <a class="code" href="classomni__condition.html">omni_condition</a> d_eh_cond;
<a name="l00112"></a>00112 <a class="code" href="struct____pthread__transp__t.html">pthread_t</a> d_eh_thread; <span class="comment">// the event handler thread</span>
<a name="l00113"></a>00113 <span class="keyword">volatile</span> <a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31">evt_handler_state</a> d_eh_state;
<a name="l00114"></a>00114 <span class="keyword">volatile</span> <span class="keywordtype">bool</span> d_shutdown_requested;
<a name="l00115"></a>00115 <a class="code" href="structspe__event__handler.html">spe_event_handler</a> d_spe_event_handler;
<a name="l00116"></a>00116
<a name="l00117"></a>00117 <span class="comment">// used to coordinate communication w/ the job completer thread</span>
<a name="l00118"></a>00118 <a class="code" href="classomni__mutex.html">omni_mutex</a> d_jc_mutex;
<a name="l00119"></a>00119 <a class="code" href="classomni__condition.html">omni_condition</a> d_jc_cond;
<a name="l00120"></a>00120 <a class="code" href="struct____pthread__transp__t.html">pthread_t</a> d_jc_thread; <span class="comment">// the job completion thread</span>
<a name="l00121"></a>00121 <span class="keyword">volatile</span> <a class="code" href="gc__job__manager__impl_8h.html#a36f32c1cf3f8307edaa2010844bdfbe8">job_completer_state</a> d_jc_state;
<a name="l00122"></a>00122 <span class="keywordtype">int</span> d_jc_njobs_active; <span class="comment">// # of jobs submitted but not yet reaped</span>
<a name="l00123"></a>00123
<a name="l00124"></a>00124 <span class="comment">// round robin notification of spes</span>
<a name="l00125"></a>00125 <span class="keywordtype">int</span> d_ntell; <span class="comment">// # of spes to tell</span>
<a name="l00126"></a>00126 <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> d_tell_start; <span class="comment">// which one to start with</span>
<a name="l00127"></a>00127
<a name="l00128"></a>00128 <span class="comment">// All of the job descriptors are hung off of here.</span>
<a name="l00129"></a>00129 <span class="comment">// We allocate them all in a single cache aligned chunk.</span>
<a name="l00130"></a>00130 <a class="code" href="structgc__job__desc.html" title="&quot;job description&quot; that is DMA&#39;d to/from the SPE.">gc_job_desc_t</a> *d_jd; <span class="comment">// [options.max_jobs]</span>
<a name="l00131"></a>00131 <a class="code" href="classboost_1_1shared__ptr.html">boost::shared_ptr<void></a> _d_jd_boost; <span class="comment">// hack for automatic storage mgmt</span>
<a name="l00132"></a>00132
<a name="l00133"></a>00133 <a class="code" href="gc__job__manager__impl_8h.html#ad87b3fba7d38c319dd12f035bcb2de88">gc_client_thread_info_sa</a> d_client_thread; <span class="comment">// [options.max_client_threads]</span>
<a name="l00134"></a>00134
<a name="l00135"></a>00135 <span class="comment">// We use bitvectors to represent the completing state of a job. Each</span>
<a name="l00136"></a>00136 <span class="comment">// bitvector is d_bvlen longs in length.</span>
<a name="l00137"></a>00137 <span class="keywordtype">int</span> d_bvlen; <span class="comment">// bit vector length in longs</span>
<a name="l00138"></a>00138
<a name="l00139"></a>00139 <span class="comment">// This contains the storage for all the bitvectors used by the job</span>
<a name="l00140"></a>00140 <span class="comment">// manager. There's 1 for each client thread, in the d_jobs_done</span>
<a name="l00141"></a>00141 <span class="comment">// field. We allocate them all in a single cache aligned chunk.</span>
<a name="l00142"></a>00142 <a class="code" href="classboost_1_1shared__ptr.html">boost::shared_ptr<void></a> _d_all_bitvectors; <span class="comment">// hack for automatic storage mgmt</span>
<a name="l00143"></a>00143
<a name="l00144"></a>00144 <span class="comment">// Lock free stack where we keep track of the free job descriptors.</span>
<a name="l00145"></a>00145 <a class="code" href="gc__jd__stack_8h.html#a9360c9944831212edca9b84fca596b0b" title="Lock free stack for job descriptors (used for free list)">gc_jd_stack_t</a> *d_free_list; <span class="comment">// stack of free job descriptors</span>
<a name="l00146"></a>00146 <a class="code" href="classboost_1_1shared__ptr.html">boost::shared_ptr<void></a> _d_free_list_boost; <span class="comment">// hack for automatic storage mgmt</span>
<a name="l00147"></a>00147
<a name="l00148"></a>00148 <span class="comment">// The PPE inserts jobs here; SPEs pull jobs from here.</span>
<a name="l00149"></a>00149 <a class="code" href="gc__jd__queue__data_8h.html#aeca6b30992a72fdd76c651c12514f6df" title="(Lock free someday...) queue for job descriptors">gc_jd_queue_t</a> *d_queue; <span class="comment">// job queue</span>
<a name="l00150"></a>00150 <a class="code" href="classboost_1_1shared__ptr.html">boost::shared_ptr<void></a> _d_queue_boost; <span class="comment">// hack for automatic storage mgmt</span>
<a name="l00151"></a>00151
<a name="l00152"></a>00152 <span class="keywordtype">int</span> d_ea_args_maxsize;
<a name="l00153"></a>00153
<a name="l00154"></a>00154 <span class="keyword">struct </span><a class="code" href="structgc__proc__def.html">gc_proc_def</a> *d_proc_def; <span class="comment">// the SPE procedure table</span>
<a name="l00155"></a>00155 uint32_t d_proc_def_ls_addr; <span class="comment">// the LS address of the table</span>
<a name="l00156"></a>00156 <span class="keywordtype">int</span> d_nproc_defs; <span class="comment">// number of proc_defs in table</span>
<a name="l00157"></a>00157
<a name="l00158"></a>00158 <a class="code" href="classgc__client__thread__info.html">gc_client_thread_info</a> *alloc_cti();
<a name="l00159"></a>00159 <span class="keywordtype">void</span> free_cti(<a class="code" href="classgc__client__thread__info.html">gc_client_thread_info</a> *cti);
<a name="l00160"></a>00160
<a name="l00161"></a>00161 <span class="keywordtype">void</span> create_event_handler();
<a name="l00162"></a>00162 <span class="keywordtype">void</span> set_eh_state(<a class="code" href="gc__job__manager__impl_8h.html#a12a6d7238a6ecae851836c8480f2ac31">evt_handler_state</a> s);
<a name="l00163"></a>00163 <span class="keywordtype">void</span> set_ea_args_maxsize(<span class="keywordtype">int</span> maxsize);
<a name="l00164"></a>00164
<a name="l00165"></a>00165 <span class="keywordtype">void</span> notify_clients_jobs_are_done(<span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> spe_num,
<a name="l00166"></a>00166 <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> completion_info_idx);
<a name="l00167"></a>00167
<a name="l00168"></a>00168 <span class="keyword">public</span>:
<a name="l00169"></a>00169 <span class="keywordtype">void</span> <a class="code" href="classgc__job__manager__impl.html#a7adab9881fc15eb0766eee5d88ec57ce">event_handler_loop</a>(); <span class="comment">// really private</span>
<a name="l00170"></a>00170 <span class="keywordtype">void</span> <a class="code" href="classgc__job__manager__impl.html#a6ac331cb6ac43bff9ae7176780f3f12b">job_completer_loop</a>(); <span class="comment">// really private</span>
<a name="l00171"></a>00171
<a name="l00172"></a>00172 <span class="keyword">private</span>:
<a name="l00173"></a>00173 <span class="keywordtype">bool</span> send_all_spes(uint32_t msg);
<a name="l00174"></a>00174 <span class="keywordtype">bool</span> send_spe(<span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> spe, uint32_t msg);
<a name="l00175"></a>00175 <span class="keywordtype">void</span> print_event(spe_event_unit_t *evt);
<a name="l00176"></a>00176 <span class="keywordtype">void</span> handle_event(spe_event_unit_t *evt);
<a name="l00177"></a>00177 <span class="keywordtype">bool</span> incr_njobs_active();
<a name="l00178"></a>00178 <span class="keywordtype">void</span> decr_njobs_active(<span class="keywordtype">int</span> n);
<a name="l00179"></a>00179 <span class="keywordtype">void</span> tell_spes_to_check_queue();
<a name="l00180"></a>00180 <span class="keywordtype">void</span> poll_for_job_completion();
<a name="l00181"></a>00181
<a name="l00182"></a>00182 <span class="comment">// bitvector ops</span>
<a name="l00183"></a>00183 <span class="keywordtype">void</span> bv_zero(<span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> *bv);
<a name="l00184"></a>00184 <span class="keywordtype">void</span> bv_clr(<span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> *bv, <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> bitno);
<a name="l00185"></a>00185 <span class="keywordtype">void</span> bv_set(<span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> *bv, <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> bitno);
<a name="l00186"></a>00186 <span class="keywordtype">bool</span> bv_isset(<span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> *bv, <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> bitno);
<a name="l00187"></a>00187 <span class="keywordtype">bool</span> bv_isclr(<span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> *bv, <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> bitno);
<a name="l00188"></a>00188
<a name="l00189"></a>00189 <span class="keywordtype">void</span> setup_logfiles();
<a name="l00190"></a>00190 <span class="keywordtype">void</span> sync_logfiles();
<a name="l00191"></a>00191 <span class="keywordtype">void</span> unmap_logfiles();
<a name="l00192"></a>00192
<a name="l00193"></a>00193 <span class="keyword">friend</span> <a class="code" href="classboost_1_1shared__ptr.html">gc_job_manager_sptr</a> <a class="code" href="classgc__job__manager__impl.html#a7f6bcdc129963cea4ac5ff5d4289858b">gc_make_job_manager</a>(<span class="keyword">const</span> <a class="code" href="structgc__jm__options.html">gc_jm_options</a> *options);
<a name="l00194"></a>00194
<a name="l00195"></a>00195 <a class="code" href="classgc__job__manager__impl.html" title="Concrete class that manages SPE jobs.">gc_job_manager_impl</a>(<span class="keyword">const</span> <a class="code" href="structgc__jm__options.html">gc_jm_options</a> *options = 0);
<a name="l00196"></a>00196
<a name="l00197"></a>00197 <span class="keyword">public</span>:
<a name="l00198"></a>00198 <span class="keyword">virtual</span> <a class="code" href="classgc__job__manager__impl.html#aa945ce568d23390e05a36f81049c194b">~gc_job_manager_impl</a>();
<a name="l00199"></a>00199 <span class="comment"></span>
<a name="l00200"></a>00200 <span class="comment"> /*!</span>
<a name="l00201"></a>00201 <span class="comment"> * Stop accepting new jobs. Wait for existing jobs to complete.</span>
<a name="l00202"></a>00202 <span class="comment"> * Return all managed SPE's to the system.</span>
<a name="l00203"></a>00203 <span class="comment"> */</span>
<a name="l00204"></a>00204 <span class="keyword">virtual</span> <span class="keywordtype">bool</span> <a class="code" href="classgc__job__manager__impl.html#a16166dba92ae5e68d7d45778490585b7">shutdown</a>();
<a name="l00205"></a>00205 <span class="comment"></span>
<a name="l00206"></a>00206 <span class="comment"> /*!</span>
<a name="l00207"></a>00207 <span class="comment"> * \brief Return number of SPE's currently allocated to job manager.</span>
<a name="l00208"></a>00208 <span class="comment"> */</span>
<a name="l00209"></a>00209 <span class="keyword">virtual</span> <span class="keywordtype">int</span> <a class="code" href="classgc__job__manager__impl.html#ac0615bca7876460eb0f5e8dd449a4fb0" title="Return number of SPE&#39;s currently allocated to job manager.">nspes</a>() <span class="keyword">const</span>;
<a name="l00210"></a>00210 <span class="comment"></span>
<a name="l00211"></a>00211 <span class="comment"> /*!</span>
<a name="l00212"></a>00212 <span class="comment"> * \brief Return a pointer to a properly aligned job descriptor,</span>
<a name="l00213"></a>00213 <span class="comment"> * or zero if none are available.</span>
<a name="l00214"></a>00214 <span class="comment"> */</span>
<a name="l00215"></a>00215 <span class="keyword">virtual</span> <a class="code" href="structgc__job__desc.html" title="&quot;job description&quot; that is DMA&#39;d to/from the SPE.">gc_job_desc</a> *<a class="code" href="classgc__job__manager__impl.html#a228e1efb2b9b5deb8687b9cd57c00cb3" title="Return a pointer to a properly aligned job descriptor, or zero if none are available.">alloc_job_desc</a>();
<a name="l00216"></a>00216
<a name="l00217"></a>00217 <span class="comment">/*</span>
<a name="l00218"></a>00218 <span class="comment"> *! Return a job descriptor previously allocated with alloc_job_desc()</span>
<a name="l00219"></a>00219 <span class="comment"> *</span>
<a name="l00220"></a>00220 <span class="comment"> * \param[in] jd pointer to job descriptor to free.</span>
<a name="l00221"></a>00221 <span class="comment"> */</span>
<a name="l00222"></a>00222 <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classgc__job__manager__impl.html#a597a24f5aee6e49b6293f068915ade29">free_job_desc</a>(<a class="code" href="structgc__job__desc.html" title="&quot;job description&quot; that is DMA&#39;d to/from the SPE.">gc_job_desc</a> *jd);
<a name="l00223"></a>00223 <span class="comment"></span>
<a name="l00224"></a>00224 <span class="comment"> /*!</span>
<a name="l00225"></a>00225 <span class="comment"> * \brief Submit a job for asynchronous processing on an SPE.</span>
<a name="l00226"></a>00226 <span class="comment"> *</span>
<a name="l00227"></a>00227 <span class="comment"> * \param[in] jd pointer to job description</span>
<a name="l00228"></a>00228 <span class="comment"> *</span>
<a name="l00229"></a>00229 <span class="comment"> * The caller must not read or write the job description</span>
<a name="l00230"></a>00230 <span class="comment"> * or any of the memory associated with any indirect arguments</span>
<a name="l00231"></a>00231 <span class="comment"> * until after calling wait_job.</span>
<a name="l00232"></a>00232 <span class="comment"> *</span>
<a name="l00233"></a>00233 <span class="comment"> * \returns true iff the job was successfully enqueued.</span>
<a name="l00234"></a>00234 <span class="comment"> * If submit_job returns false, check jd->status for additional info.</span>
<a name="l00235"></a>00235 <span class="comment"> */</span>
<a name="l00236"></a>00236 <span class="keyword">virtual</span> <span class="keywordtype">bool</span> <a class="code" href="classgc__job__manager__impl.html#a4e1c1655e4a97433f870c5276a95e5e4" title="Submit a job for asynchronous processing on an SPE.">submit_job</a>(<a class="code" href="structgc__job__desc.html" title="&quot;job description&quot; that is DMA&#39;d to/from the SPE.">gc_job_desc</a> *jd);
<a name="l00237"></a>00237 <span class="comment"></span>
<a name="l00238"></a>00238 <span class="comment"> /*!</span>
<a name="l00239"></a>00239 <span class="comment"> * \brief Wait for job to complete.</span>
<a name="l00240"></a>00240 <span class="comment"> *</span>
<a name="l00241"></a>00241 <span class="comment"> * A thread may only wait for jobs which it submitted.</span>
<a name="l00242"></a>00242 <span class="comment"> *</span>
<a name="l00243"></a>00243 <span class="comment"> * \returns true if sucessful, else false.</span>
<a name="l00244"></a>00244 <span class="comment"> */</span>
<a name="l00245"></a>00245 <span class="keyword">virtual</span> <span class="keywordtype">bool</span>
<a name="l00246"></a>00246 <a class="code" href="classgc__job__manager__impl.html#a8793896a991f22526528db5c5fd6c266" title="Wait for job to complete.">wait_job</a>(<a class="code" href="structgc__job__desc.html" title="&quot;job description&quot; that is DMA&#39;d to/from the SPE.">gc_job_desc</a> *jd);
<a name="l00247"></a>00247 <span class="comment"></span>
<a name="l00248"></a>00248 <span class="comment"> /*!</span>
<a name="l00249"></a>00249 <span class="comment"> * \brief wait for 1 or more jobs to complete.</span>
<a name="l00250"></a>00250 <span class="comment"> *</span>
<a name="l00251"></a>00251 <span class="comment"> * \param[in] njobs is the length of arrays \p jd and \p done.</span>
<a name="l00252"></a>00252 <span class="comment"> * \param[in] jd are the jobs that are to be waited for.</span>
<a name="l00253"></a>00253 <span class="comment"> * \param[out] done indicates whether the corresponding job is complete.</span>
<a name="l00254"></a>00254 <span class="comment"> * \param[in] mode indicates whether to wait for ALL or ANY of the jobs</span>
<a name="l00255"></a>00255 <span class="comment"> * in \p jd to complete.</span>
<a name="l00256"></a>00256 <span class="comment"> *</span>
<a name="l00257"></a>00257 <span class="comment"> * A thread may only wait for jobs which it submitted.</span>
<a name="l00258"></a>00258 <span class="comment"> *</span>
<a name="l00259"></a>00259 <span class="comment"> * \returns number of jobs completed, or -1 if error.</span>
<a name="l00260"></a>00260 <span class="comment"> */</span>
<a name="l00261"></a>00261 <span class="keyword">virtual</span> <span class="keywordtype">int</span>
<a name="l00262"></a>00262 <a class="code" href="classgc__job__manager__impl.html#abba55d25693227d82ce4afa74b6a1fcb" title="wait for 1 or more jobs to complete.">wait_jobs</a>(<span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> njobs,
<a name="l00263"></a>00263 <a class="code" href="structgc__job__desc.html" title="&quot;job description&quot; that is DMA&#39;d to/from the SPE.">gc_job_desc</a> *jd[], <span class="keywordtype">bool</span> done[], <a class="code" href="gc__job__manager_8h.html#ab5ff7bcddb7471da0c9f1f0d7dbe038c">gc_wait_mode</a> mode);
<a name="l00264"></a>00264
<a name="l00265"></a>00265 <span class="keyword">virtual</span> <span class="keywordtype">int</span> <a class="code" href="classgc__job__manager__impl.html#ad5076a7ebbef03a29f7dbfb15c2b7077">ea_args_maxsize</a>();
<a name="l00266"></a>00266
<a name="l00267"></a>00267 <span class="keyword">virtual</span> <a class="code" href="gc__job__desc_8h.html#a26e60e5aaade61f7c333ee636940a658" title="opaque ID that specifies which code to invoke on the SPE">gc_proc_id_t</a> <a class="code" href="classgc__job__manager__impl.html#ad997884dd828c691e5505f85d9760271">lookup_proc</a>(<span class="keyword">const</span> std::string &<a class="code" href="structgc__proc__def.html#acf5ebe814fe11cbbbcbdb368f12aad1a">name</a>);
<a name="l00268"></a>00268 <span class="keyword">virtual</span> <a class="code" href="classstd_1_1vector.html" title="vector documentation stub">std::vector<std::string></a> <a class="code" href="classgc__job__manager__impl.html#aa2933ca9cfc5623d9041576de73181f4">proc_names</a>();
<a name="l00269"></a>00269
<a name="l00270"></a>00270 <span class="keyword">virtual</span> <span class="keywordtype">void</span> set_debug(<span class="keywordtype">int</span> debug);
<a name="l00271"></a>00271 <span class="keyword">virtual</span> <span class="keywordtype">int</span> debug();
<a name="l00272"></a>00272 };
<a name="l00273"></a>00273
<a name="l00274"></a>00274 <span class="preprocessor">#endif </span><span class="comment">/* INCLUDED_GC_JOB_MANAGER_IMPL_H */</span>
</pre></div></div>
</div>
<div id="nav-path" class="navpath">
<ul>
<li class="navelem"><a class="el" href="gc__job__manager__impl_8h.html">gc_job_manager_impl.h</a> </li>
<li class="footer">Generated on Thu Feb 17 2011 for GNU Radio 3.2.2 C++ API by 
<a href="http://www.doxygen.org/index.html">
<img class="footer" src="doxygen.png" alt="doxygen"/></a> 1.7.3 </li>
</ul>
</div>
</body>
</html>
distrib
>
Fedora
>
14
>
x86_64
>
media
>
updates
>
by-pkgid
>
6e7a2755bd78c9deedab199b86e675f3
>
files
>
3457
