<!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.3.0 C++ API: gc_job_manager_impl.h Source File</title> <link href="tabs.css" rel="stylesheet" type="text/css"/> <link href="doxygen.css" rel="stylesheet" type="text/css"/> </head> <body> <!-- Generated by Doxygen 1.6.3 --> <h1>gc_job_manager_impl.h</h1><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,2010 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 <<a class="code" href="gc__job__manager_8h.html">gcell/gc_job_manager.h</a>></span> <a name="l00026"></a>00026 <span class="preprocessor">#include <<a class="code" href="gc__jd__stack_8h.html">gcell/gc_jd_stack.h</a>></span> <a name="l00027"></a>00027 <span class="preprocessor">#include <<a class="code" href="gc__jd__queue_8h.html">gcell/gc_jd_queue.h</a>></span> <a name="l00028"></a>00028 <span class="preprocessor">#include <<a class="code" href="gc__spu__args_8h.html">gcell/gc_spu_args.h</a>></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> pthread_t <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...">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 boost::mutex d_eh_mutex; <a name="l00111"></a>00111 boost::condition_variable d_eh_cond; <a name="l00112"></a>00112 pthread_t 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 boost::mutex d_jc_mutex; <a name="l00119"></a>00119 boost::condition_variable d_jc_cond; <a name="l00120"></a>00120 pthread_t 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> <hr class="footer"/><address style="text-align: right;"><small>Generated on Wed Dec 29 19:50:59 2010 for GNU Radio 3.3.0 C++ API by <a href="http://www.doxygen.org/index.html"> <img class="footer" src="doxygen.png" alt="doxygen"/></a> 1.6.3 </small></address> </body> </html>