Private class representing a getTile job. More...

#include <ossimMultiThreadSequencer.h>

Inheritance diagram for ossimMultiThreadSequencer::ossimGetTileJob:

Public Member Functions
	ossimGetTileJob (ossim_uint32 tile_id, ossim_uint32 chain_id, ossimMultiThreadSequencer &sequencer)

Public Member Functions inherited from ossimJob
	ossimJob ()

virtual void	start ()
	Main entry point to the job. More...

std::shared_ptr< ossimJob >	getSharedFromThis ()
	This is a convenience method to get the shared representation of this pointer. More...

std::shared_ptr< const ossimJob >	getSharedFromThis () const
	This is a convenience method to get the shared representation of this pointer. More...

void	setPercentComplete (double value)
	When the pernet complete is set for the job it will call any callbacks and nofity percentCompleteChanged. More...

void	setPriority (double value)
	sets the priority of the job More...

double	priority () const

virtual void	release ()
	If derived interfaces implement a block this will allow one to release. More...

State	state () const

virtual void	resetState (int value)
	Will clear out the state and the call setState. More...

virtual void	setState (int value, bool on=true)
	Will allow you to set the state of the job. More...

bool	isCanceled () const

virtual void	cancel ()
	Sets the state if the object as cancelled. More...

virtual void	ready ()
	Sets the state if the object as ready. More...

virtual void	running ()
	Sets the state if the object as running. More...

virtual void	finished ()
	Sets the state if the object as finished. More...

bool	isReady () const

bool	isStopped () const

bool	isFinished () const

bool	isRunning () const

void	setCallback (std::shared_ptr< ossimJobCallback > callback)

void	setName (const ossimString &value)
	Sets the name of a job. More...

const ossimString &	name () const

void	setId (const ossimString &value)

const ossimString &	id () const

void	setDescription (const ossimString &value)

const ossimString &	description () const

std::shared_ptr< ossimJobCallback >	callback ()

Protected Member Functions
virtual void	run ()
	Abstract method and must be overriden by the base class. More...

Private Attributes
ossim_uint32	m_tileID

ossim_uint32	m_chainID

ossimMultiThreadSequencer &	m_sequencer

bool	t_launchNewJob

Friends
class	ossimMultiThreadSequencer

Additional Inherited Members
Public Types inherited from ossimJob
enum	State { ossimJob_NONE = 0, ossimJob_READY = 1, ossimJob_RUNNING = 2, ossimJob_CANCEL = 4, ossimJob_FINISHED = 8, ossimJob_ALL = (ossimJob_READY\|ossimJob_RUNNING\|ossimJob_CANCEL\|ossimJob_FINISHED) }
	This is a Bit vector. More...

typedef std::list< std::shared_ptr< ossimJob > >	List

Protected Attributes inherited from ossimJob
std::mutex	m_jobMutex

ossimString	m_name

ossimString	m_description

ossimString	m_id

State	m_state

double	m_priority

std::shared_ptr< ossimJobCallback >	m_callback

Detailed Description

Private class representing a getTile job.

Definition at line 78 of file ossimMultiThreadSequencer.h.

Constructor & Destructor Documentation

◆ ossimGetTileJob()

ossimMultiThreadSequencer::ossimGetTileJob::ossimGetTileJob	(	ossim_uint32	tile_id,
		ossim_uint32	chain_id,
		ossimMultiThreadSequencer &	sequencer
	)

inline

Definition at line 81 of file ossimMultiThreadSequencer.h.

          :  m_tileID(tile_id), 
             m_chainID(chain_id), 
             m_sequencer(sequencer),
             t_launchNewJob(true) {}

Member Function Documentation

◆ run()

void ossimMultiThreadSequencer::ossimGetTileJob::run ( )

protectedvirtual

Abstract method and must be overriden by the base class.

The base ossimJob will call run from the start method after setting some variables.

Implements ossimJob.

Definition at line 27 of file ossimMultiThreadSequencer.cpp.

References ossimMultiThreadSequencer::d_debugEnabled, ossimImageData::dup(), ossimJob::finished(), ossimImageChainMtAdaptor::getClone(), ossimImageSource::getTile(), ossimImageSourceSequencer::getTileRect(), ossimTimer::instance(), m_chainID, ossimMultiThreadSequencer::m_getTileBlock, ossimMultiThreadSequencer::m_inputChain, m_sequencer, m_tileID, ossimMultiThreadSequencer::nextJob(), ossimMultiThreadSequencer::print(), ossim::Block::release(), ossimJob::running(), ossimImageData::setImageRectangle(), ossimMultiThreadSequencer::setTileInCache(), t_launchNewJob, ossimImageSourceSequencer::theBlankTile, ossimTimer::time_s(), and ossimRefPtr< T >::valid().

 {
    running();
    if (m_sequencer.d_debugEnabled)
    {
       ostringstream s1;
       s1<<"THREAD #"<<m_chainID<<" -- Starting tile/job #"<<m_tileID;
       m_sequencer.print(s1);
    }
 
    // Figure out the rect for this tile. Only process if rect is valid:
    ossimIrect tileRect;
    if (m_sequencer.getTileRect(m_tileID, tileRect))
    {
       // Perform the getTile and save the result:
       ossimRefPtr<ossimImageData> tile = 0;
       ossimImageSource* source = m_sequencer.m_inputChain->getClone(m_chainID);
       double dt = ossimTimer::instance()->time_s(); //###
 
       if (source != NULL)
          tile = source->getTile(tileRect);
       if (!tile.valid())
       {
          tile = m_sequencer.theBlankTile;
          tile->setImageRectangle(tileRect);
       }
       dt = ossimTimer::instance()->time_s() - dt; //###
 
       // Give the sequencer the tile. Execution may pause here while waiting for space to free up
       // if the cache is full.
       m_sequencer.setTileInCache(m_tileID, (ossimImageData*)tile->dup(), m_chainID, dt);
    }
 
    // Unblock the main thread which might be blocked waiting for jobs to finish:
    m_sequencer.m_getTileBlock.release();
 
    // Queue the next job using this job's freed-up image chain:
    if (t_launchNewJob)
       m_sequencer.nextJob(m_chainID);
 
    finished();
    
    if (m_sequencer.d_debugEnabled)
    {
       ostringstream s2;
       s2<<"THREAD #"<<m_chainID<<" -- Finished tile/job #"<<m_tileID;
       m_sequencer.print(s2);
    }
 }