GNU Radio 3.3.0 C++ API
|
Abstract class that manages SPE jobs.There is typically a single instance derived from this class. It is safe to call its methods from any thread. More...
#include <gc_job_manager.h>
Public Member Functions | |
gc_job_manager (const gc_jm_options *options=0) | |
virtual | ~gc_job_manager () |
virtual bool | shutdown ()=0 |
virtual int | nspes () const =0 |
Return number of SPE's currently allocated to job manager. | |
virtual gc_job_desc * | alloc_job_desc ()=0 |
Return a pointer to a properly aligned job descriptor, or throws gc_bad_alloc if there are none available. | |
virtual void | free_job_desc (gc_job_desc *jd)=0 |
virtual bool | submit_job (gc_job_desc *jd)=0 |
Submit a job for asynchronous processing on an SPE. | |
virtual bool | wait_job (gc_job_desc *jd)=0 |
Wait for job to complete. | |
virtual int | wait_jobs (unsigned int njobs, gc_job_desc *jd[], bool done[], gc_wait_mode mode)=0 |
wait for 1 or more jobs to complete. | |
virtual int | ea_args_maxsize ()=0 |
virtual gc_proc_id_t | lookup_proc (const std::string &proc_name)=0 |
virtual std::vector< std::string > | proc_names ()=0 |
Static Public Member Functions | |
static void | set_singleton (gc_job_manager_sptr mgr) |
Set the singleton gc_job_manager instance. | |
static gc_job_manager_sptr | singleton () |
Retrieve the singleton gc_job_manager instance. | |
static gc_job_desc_sptr | alloc_job_desc (gc_job_manager_sptr mgr) |
allocate a job descriptor and return a boost::shared_ptr to it. |
Abstract class that manages SPE jobs.
There is typically a single instance derived from this class. It is safe to call its methods from any thread.
gc_job_manager::gc_job_manager | ( | const gc_jm_options * | options = 0 | ) |
virtual gc_job_manager::~gc_job_manager | ( | ) | [virtual] |
virtual gc_job_desc* gc_job_manager::alloc_job_desc | ( | ) | [pure virtual] |
Return a pointer to a properly aligned job descriptor, or throws gc_bad_alloc if there are none available.
Implemented in gc_job_manager_impl.
static gc_job_desc_sptr gc_job_manager::alloc_job_desc | ( | gc_job_manager_sptr | mgr | ) | [static] |
allocate a job descriptor and return a boost::shared_ptr to it.
virtual int gc_job_manager::ea_args_maxsize | ( | ) | [pure virtual] |
Return the maximum number of bytes of EA arguments that may be copied to or from the SPE in a single job. The limit applies independently to the "get" and "put" args.
Implemented in gc_job_manager_impl.
virtual void gc_job_manager::free_job_desc | ( | gc_job_desc * | jd | ) | [pure virtual] |
Implemented in gc_job_manager_impl.
virtual gc_proc_id_t gc_job_manager::lookup_proc | ( | const std::string & | proc_name | ) | [pure virtual] |
Return gc_proc_id_t associated with spu procedure proc_name
if one exists, otherwise throws gc_unknown_proc.
Implemented in gc_job_manager_impl.
virtual int gc_job_manager::nspes | ( | ) | const [pure virtual] |
Return number of SPE's currently allocated to job manager.
Implemented in gc_job_manager_impl.
virtual std::vector<std::string> gc_job_manager::proc_names | ( | ) | [pure virtual] |
Return a vector of all known spu procedure names.
Implemented in gc_job_manager_impl.
static void gc_job_manager::set_singleton | ( | gc_job_manager_sptr | mgr | ) | [static] |
Set the singleton gc_job_manager instance.
mgr | is the job manager instance. |
The singleton is weakly held, thus the caller must maintain a reference to the mgr for the duration. (If we held the manager strongly, the destructor would never be called, and the resources (SPEs) would not be returned.) Bottom line: the caller is responsible for life-time management.
virtual bool gc_job_manager::shutdown | ( | ) | [pure virtual] |
Stop accepting new jobs. Wait for existing jobs to complete. Return all managed SPE's to the system.
Implemented in gc_job_manager_impl.
static gc_job_manager_sptr gc_job_manager::singleton | ( | ) | [static] |
Retrieve the singleton gc_job_manager instance.
Returns the singleton gc_job_manager instance or raises boost::bad_weak_ptr if the singleton is empty.
virtual bool gc_job_manager::submit_job | ( | gc_job_desc * | jd | ) | [pure virtual] |
Submit a job for asynchronous processing on an SPE.
[in] | jd | pointer to job description |
The caller must not read or write the job description or any of the memory associated with any indirect arguments until after calling wait_job.
Implemented in gc_job_manager_impl.
virtual bool gc_job_manager::wait_job | ( | gc_job_desc * | jd | ) | [pure virtual] |
Wait for job to complete.
A thread may only wait for jobs which it submitted.
Implemented in gc_job_manager_impl.
virtual int gc_job_manager::wait_jobs | ( | unsigned int | njobs, |
gc_job_desc * | jd[], | ||
bool | done[], | ||
gc_wait_mode | mode | ||
) | [pure virtual] |
wait for 1 or more jobs to complete.
[in] | njobs | is the length of arrays jd and done . |
[in] | jd | are the jobs that are to be waited for. |
[out] | done | indicates whether the corresponding job is complete. |
[in] | mode | indicates whether to wait for ALL or ANY of the jobs in jd to complete. |
A thread may only wait for jobs which it submitted.
Implemented in gc_job_manager_impl.